[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_192":193,"_194":195},"routes/_app.x.$handle.$name",{"_98":97,"_31":44,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":30,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",4,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","backend/index.ts","latestPath","fileId","38451674-b013-11f1-bda7-1607ee4eb77e","name","index.ts","fileType","http","content","// HTTP: интерфейс и API парсера собственников Unlock.\nimport { Hono } from \"npm:hono@4\";\nimport { readFile, serveFile, parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { DEFAULT_SETTINGS, getSettings, migrate, nowIso, parseJson, setSettings, sqlite, STATUSES } from \"./db.ts\";\nimport { sync, inparsSubscription } from \"./inpars.ts\";\nimport { listBrokers, loginByPin, syncBrokers, type User } from \"./auth.ts\";\n\nconst app = new Hono<{ Variables: { user: User } }>();\napp.onError((err) => Promise.reject(err));\n\nlet migrated = false;\napp.use(\"*\", async (_c, next) => { if (!migrated) { await migrate(); migrated = true; } await next(); });\n\n// ---------- статика ----------\napp.get(\"/\", async (c) => c.html(await readFile(\"/frontend/index.html\", import.meta.url), 200, { \"Cache-Control\": \"no-store\" }));\napp.get(\"/app.css\", (c) => serveFile(\"/frontend/app.css\", import.meta.url));\napp.get(\"/app.js\", (c) => serveFile(\"/frontend/app.js\", import.meta.url));\napp.get(\"/manifest.json\", (c) => c.json({ name: \"Unlock · Собственники\", short_name: \"Собственники\", start_url: \"/\", display: \"standalone\", background_color: \"#0e0e1a\", theme_color: \"#1e1b4b\", icons: [] }));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ---------- авторизация ----------\napp.post(\"/api/login\", async (c) => {\n const { pin } = await c.req.json().catch(() => ({}));\n const u = await loginByPin(String(pin || \"\"));\n if (!u) return c.json({ error: \"Неверный ПИН-код\" }, 401);\n return c.json(u);\n});\n\napp.use(\"/api/*\", async (c, next) => {\n if (c.req.path === \"/api/login\") return next();\n const u = await loginByPin(c.req.header(\"x-pin\") || \"\");\n if (!u) return c.json({ error: \"unauthorized\" }, 401);\n c.set(\"user\", u);\n await next();\n});\n\n// ---------- справочники и состояние ----------\nfunction nextRunIso() {\n const hours = [4, 11, 18]; // UTC\n const now = new Date();\n for (const h of hours) {\n const d = new Date(Date.UTC(now.getUTCFullYear(), now.getUTCMonth(), now.getUTCDate(), h, 0, 0));\n if (d > now) return d.toISOString();\n }\n return new Date(Date.UTC(now.getUTCFullYear(), now.getUTCMonth(), now.getUTCDate() + 1, hours[0], 0, 0)).toISOString();\n}\n\napp.get(\"/api/bootstrap\", async (c) => {\n const u = c.get(\"user\");\n const [brokers, s, last, counts, recall] = await Promise.all([\n listBrokers(),\n getSettings(),\n sqlite.execute(\"SELECT * FROM runs ORDER BY id DESC LIMIT 1\"),\n sqlite.execute(`SELECT status, COUNT(*) n FROM objects WHERE hidden=0 AND dup_of IS NULL GROUP BY status`),\n sqlite.execute({ sql: `SELECT COUNT(*) n FROM objects WHERE hidden=0 AND status='recall' AND recall_at <= ? AND (assignee_id=? OR ?=1)`, args: [nowIso(), u.id, u.role === \"boss\" ? 1 : 0] }),\n ]);\n const dayAgo = new Date(Date.now() - 86400000).toISOString();\n const fresh = await sqlite.execute({ sql: \"SELECT COUNT(*) n FROM objects WHERE hidden=0 AND dup_of IS NULL AND first_seen >= ?\", args: [dayAgo] });\n const mine = await sqlite.execute({ sql: \"SELECT COUNT(*) n FROM objects WHERE hidden=0 AND assignee_id=? AND status IN ('work','recall','noanswer','meeting')\", args: [u.id] });\n const byStatus: Record = {};\n for (const r of counts.rows as any[]) byStatus[String(r.status)] = Number(r.n);\n return c.json({\n user: u,\n brokers: brokers.filter((b) => b.active),\n statuses: STATUSES,\n settings: u.role === \"boss\" ? s : { cost_min: s.cost_min, cost_max: s.cost_max },\n lastRun: last.rows[0] || null,\n nextRun: nextRunIso(),\n counts: { byStatus, fresh24h: Number((fresh.rows[0] as any).n), mine: Number((mine.rows[0] as any).n), recallDue: Number((recall.rows[0] as any).n) },\n });\n});\n\n// ---------- список объектов ----------\nconst LIST_COLS = `id, source, url, category, rooms, title, address, district, metro, floor, floors, sq, cost, cost_m2, images, lat, lng, phones, is_new, is_apartments, build_year,\n source_created, first_seen, last_seen, cost_prev, cost_changed_at, score, flags, status, assignee_id, assignee_name, status_at, recall_at, dup_key`;\n\napp.get(\"/api/objects\", async (c) => {\n const u = c.get(\"user\");\n const q = c.req.query();\n const where: string[] = [\"hidden=0\", \"dup_of IS NULL\"];\n const args: any[] = [];\n if (q.status) { const st = q.status.split(\",\").filter((x) => x in STATUSES); if (st.length) { where.push(`status IN (${st.map(() => \"?\").join(\",\")})`); args.push(...st); } }\n if (q.mine === \"1\") { where.push(\"assignee_id=?\"); args.push(u.id); }\n else if (q.broker) { where.push(\"assignee_id=?\"); args.push(Number(q.broker)); }\n if (q.unassigned === \"1\") where.push(\"assignee_id IS NULL\");\n if (q.source) { const s = q.source.split(\",\"); where.push(`source IN (${s.map(() => \"?\").join(\",\")})`); args.push(...s); }\n if (q.rooms) { const r = q.rooms.split(\",\").map(Number).filter((n) => !isNaN(n)); if (r.length) { if (r.includes(4)) { where.push(`(rooms IN (${r.map(() => \"?\").join(\",\")}) OR rooms>=4)`); args.push(...r); } else { where.push(`rooms IN (${r.map(() => \"?\").join(\",\")})`); args.push(...r); } } }\n if (q.costMin) { where.push(\"cost>=?\"); args.push(Number(q.costMin)); }\n if (q.costMax) { where.push(\"cost<=?\"); args.push(Number(q.costMax)); }\n if (q.phone === \"1\") where.push(\"phones IS NOT NULL AND phones != '[]'\");\n if (q.fresh) { const h = Number(q.fresh); if (h > 0) { where.push(\"first_seen>=?\"); args.push(new Date(Date.now() - h * 3600000).toISOString()); } }\n if (q.drop === \"1\") where.push(\"cost_prev IS NOT NULL AND cost < cost_prev\");\n if (q.q) { where.push(\"(address LIKE ? OR metro LIKE ? OR district LIKE ? OR title LIKE ?)\"); const like = `%${q.q}%`; args.push(like, like, like, like); }\n const sorts: Record = {\n fresh: \"first_seen DESC\", price_desc: \"cost DESC\", price_asc: \"cost ASC\", m2: \"cost_m2 ASC\", score: \"score DESC, first_seen DESC\", updated: \"status_at DESC\",\n };\n const order = sorts[q.sort || \"\"] || \"first_seen DESC\";\n const limit = Math.min(Number(q.limit) || 1500, 3000);\n const r = await sqlite.execute({ sql: `SELECT ${LIST_COLS} FROM objects WHERE ${where.join(\" AND \")} ORDER BY ${order} LIMIT ${limit}`, args });\n const rows = (r.rows as any[]).map((o) => shapeListRow(o, u));\n return c.json({ items: rows, total: rows.length });\n});\n\nfunction shapeListRow(o: any, u: User) {\n const images = parseJson(o.images, []);\n const st = STATUSES[String(o.status)] || STATUSES.new;\n const phones = parseJson(o.phones, []);\n return {\n id: Number(o.id), source: o.source, url: o.url, category: o.category, rooms: o.rooms, title: o.title, address: o.address, district: o.district, metro: o.metro,\n floor: o.floor, floors: o.floors, sq: o.sq, cost: o.cost, cost_m2: o.cost_m2, img: images[0] || null, photos: images.length,\n lat: o.lat, lng: o.lng, hasPhone: phones.length > 0, is_new: o.is_new, is_apartments: o.is_apartments, build_year: o.build_year,\n source_created: o.source_created, first_seen: o.first_seen, last_seen: o.last_seen, cost_prev: o.cost_prev, cost_changed_at: o.cost_changed_at,\n score: o.score, flags: parseJson(o.flags, {}), status: o.status, assignee_id: o.assignee_id, assignee_name: o.assignee_name, status_at: o.status_at, recall_at: o.recall_at,\n hidePhone: !!st.hidePhone && u.role !== \"boss\",\n };\n}\n\n// ---------- карточка ----------\napp.get(\"/api/objects/:id\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const r = await sqlite.execute({ sql: \"SELECT * FROM objects WHERE id=?\", args: [id] });\n if (!r.rows.length) return c.json({ error: \"not found\" }, 404);\n const o = r.rows[0] as any;\n const st = STATUSES[String(o.status)] || STATUSES.new;\n const [act, sib] = await Promise.all([\n sqlite.execute({ sql: \"SELECT * FROM activity WHERE object_id=? OR object_id IN (SELECT id FROM objects WHERE dup_of=?) ORDER BY id ASC\", args: [id, id] }),\n o.dup_key ? sqlite.execute({ sql: \"SELECT id, source, url, cost, first_seen, status FROM objects WHERE dup_key=? AND id!=? AND hidden=0\", args: [o.dup_key, id] }) : Promise.resolve({ rows: [] }),\n ]);\n const hide = !!st.hidePhone && u.role !== \"boss\";\n return c.json({\n ...o,\n images: parseJson(o.images, []),\n phones: hide ? [] : parseJson(o.phones, []),\n hidePhone: hide,\n flags: parseJson(o.flags, {}),\n activity: (act.rows as any[]).map((a) => ({ ...a, meta: parseJson(a.meta, null) })),\n siblings: sib.rows,\n });\n});\n\n// ---------- действия ----------\nasync function groupIds(id: number): Promise {\n const r = await sqlite.execute({ sql: \"SELECT id FROM objects WHERE id=? OR dup_of=? OR (dup_of IS NOT NULL AND dup_of=(SELECT dup_of FROM objects WHERE id=?)) OR id=(SELECT dup_of FROM objects WHERE id=?)\", args: [id, id, id, id] });\n return (r.rows as any[]).map((x) => Number(x.id));\n}\n\napp.post(\"/api/objects/:id/status\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const body = await c.req.json().catch(() => ({}));\n const status = String(body.status || \"\");\n if (!(status in STATUSES)) return c.json({ error: \"bad status\" }, 400);\n const ids = await groupIds(id);\n if (!ids.length) return c.json({ error: \"not found\" }, 404);\n const now = nowIso();\n const recallAt = status === \"recall\" && body.recall_at ? String(body.recall_at) : null;\n const cur = await sqlite.execute({ sql: \"SELECT assignee_id, assignee_name, status FROM objects WHERE id=?\", args: [id] });\n const row = cur.rows[0] as any;\n // Смена статуса закрепляет объект за тем, кто её сделал, если объект ещё ничей\n const assignId = row.assignee_id ?? (status === \"new\" ? null : u.id);\n const assignName = row.assignee_id ? row.assignee_name : (status === \"new\" ? null : u.name);\n const stmts: any[] = [{\n sql: `UPDATE objects SET status=?, status_at=?, status_by=?, recall_at=?, assignee_id=?, assignee_name=? WHERE id IN (${ids.map(() => \"?\").join(\",\")})`,\n args: [status, now, u.name, recallAt, assignId, assignName, ...ids],\n }];\n const label = STATUSES[status].label + (recallAt ? \" · \" + new Date(recallAt).toLocaleString(\"ru-RU\", { timeZone: \"Europe/Moscow\", day: \"2-digit\", month: \"2-digit\", hour: \"2-digit\", minute: \"2-digit\" }) : \"\");\n stmts.push({ sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, meta, created_at) VALUES(?,?,?,?,?,?,?)\", args: [id, \"status\", u.id, u.name, label, JSON.stringify({ from: row.status, to: status, recall_at: recallAt }), now] });\n const comment = String(body.comment || \"\").trim();\n if (comment) stmts.push({ sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, created_at) VALUES(?,?,?,?,?,?)\", args: [id, \"comment\", u.id, u.name, comment, now] });\n await sqlite.batch(stmts);\n return c.json({ ok: true, status, assignee_id: assignId, assignee_name: assignName });\n});\n\napp.post(\"/api/objects/:id/assign\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const body = await c.req.json().catch(() => ({}));\n const ids = await groupIds(id);\n if (!ids.length) return c.json({ error: \"not found\" }, 404);\n const now = nowIso();\n let toId: number | null, toName: string | null;\n if (body.release) { toId = null; toName = null; }\n else if (body.broker_id != null && u.role === \"boss\") {\n const b = (await listBrokers()).find((x) => x.id === Number(body.broker_id));\n if (!b) return c.json({ error: \"no broker\" }, 400);\n toId = b.id; toName = b.name;\n } else { toId = u.id; toName = u.name; }\n const cur = await sqlite.execute({ sql: \"SELECT assignee_id, assignee_name, status FROM objects WHERE id=?\", args: [id] });\n const row = cur.rows[0] as any;\n if (!body.release && row.assignee_id && row.assignee_id !== toId && u.role !== \"boss\") return c.json({ error: `Уже в работе: ${row.assignee_name}` }, 409);\n const newStatus = body.release ? (row.status === \"work\" ? \"new\" : row.status) : (row.status === \"new\" ? \"work\" : row.status);\n await sqlite.batch([\n { sql: `UPDATE objects SET assignee_id=?, assignee_name=?, status=?, status_at=?, status_by=? WHERE id IN (${ids.map(() => \"?\").join(\",\")})`, args: [toId, toName, newStatus, now, u.name, ...ids] },\n { sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, created_at) VALUES(?,?,?,?,?,?)\", args: [id, \"assign\", u.id, u.name, body.release ? \"Снял с себя\" : toId === u.id ? \"Взял в работу\" : `Передал: ${toName}`, now] },\n ]);\n return c.json({ ok: true, assignee_id: toId, assignee_name: toName, status: newStatus });\n});\n\napp.post(\"/api/objects/:id/comment\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const body = await c.req.json().catch(() => ({}));\n const text = String(body.text || \"\").trim().slice(0, 2000);\n if (!text) return c.json({ error: \"empty\" }, 400);\n const now = nowIso();\n await sqlite.execute({ sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, created_at) VALUES(?,?,?,?,?,?)\", args: [id, \"comment\", u.id, u.name, text, now] });\n return c.json({ ok: true });\n});\n\n// Лента команды: последние действия по всем объектам\napp.get(\"/api/feed\", async (c) => {\n const r = await sqlite.execute(`SELECT a.id, a.object_id, a.kind, a.broker_name, a.text, a.created_at, o.title, o.address, o.cost, o.status\n FROM activity a JOIN objects o ON o.id=a.object_id ORDER BY a.id DESC LIMIT 60`);\n return c.json({ items: r.rows });\n});\n\n// ---------- руководитель ----------\nconst boss = async (c: any, next: any) => { if (c.get(\"user\").role !== \"boss\") return c.json({ error: \"forbidden\" }, 403); await next(); };\n\napp.post(\"/api/sync\", boss, async (c) => {\n await syncBrokers().catch(() => {});\n const body = await c.req.json().catch(() => ({}));\n const r = await sync(\"manual\", body.days ? { sinceOverride: Math.floor(Date.now() / 1000) - Number(body.days) * 86400 } : {});\n return c.json(r);\n});\n\napp.get(\"/api/runs\", boss, async (c) => {\n const r = await sqlite.execute(\"SELECT * FROM runs ORDER BY id DESC LIMIT 30\");\n return c.json({ items: r.rows });\n});\n\napp.get(\"/api/settings\", boss, async (c) => c.json({ settings: await getSettings(), defaults: DEFAULT_SETTINGS }));\napp.post(\"/api/settings\", boss, async (c) => {\n const body = await c.req.json().catch(() => ({}));\n await setSettings(body);\n return c.json({ settings: await getSettings() });\n});\n\napp.get(\"/api/inpars\", boss, async (c) => {\n try { return c.json(await inparsSubscription(Deno.env.get(\"INPARS_TOKEN\") || \"\")); } catch (e) { return c.json({ error: String((e as Error).message) }, 502); }\n});\n\napp.get(\"/api/team\", boss, async (c) => {\n const r = await sqlite.execute(`SELECT assignee_id, assignee_name, status, COUNT(*) n FROM objects WHERE hidden=0 AND assignee_id IS NOT NULL GROUP BY assignee_id, status`);\n const week = new Date(Date.now() - 7 * 86400000).toISOString();\n const a = await sqlite.execute({ sql: `SELECT broker_id, broker_name, kind, COUNT(*) n FROM activity WHERE created_at>=? AND broker_id IS NOT NULL GROUP BY broker_id, kind`, args: [week] });\n return c.json({ byStatus: r.rows, weekActivity: a.rows });\n});\n\napp.notFound((c) => c.text(\"Not found\", 404));\n\nexport default app.fetch;\n","createdAt",["D",1789373202003],"branchVersion","branchId","9dbe2f34-663f-4856-8384-e8139fd87595","id","616b52aa-94d7-4f07-aa0a-4ebcab25369a","unlock-owners",["D",1789373200178],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Собственники: сбор Inpars + рабочее место брокеров","imageUrl","caa5b6a0-dd4e-4cd6-a997-9389a6a43948","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019eff71-5749-76b5-abdd-e25a47b3deca","tursoName","616b52aa94d74f07aa0a4ebcab25369a","tursoHostname","616b52aa94d74f07aa0a4ebcab25369a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789547455787],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":54,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"isOwned",98,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tambovtsev007","handle","displayName","Кирилл Тамбовцев","avatar","https://lh3.googleusercontent.com/a/ACg8ocKCNneTjcn307kcxhB_NS1R7_0SBhSKM-2hy73z0JvhXFipwkhs=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":187,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":30,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":188,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":189,"_82":190,"_84":191,"_86":24},"tree",[151],"files",[151,152,153,154,155],"counts",{"_140":61,"_141":134,"_142":61,"_143":144,"_145":146},"contents",[129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":130,"_31":131,"_29":132,"_133":-5,"_40":41,"_39":134,"_135":57,"_37":136,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_26":139},"7341a1cc-7dfc-4e42-b726-1f50a9135807","backend","2d175de9-e314-46bc-b472-7c5eb74535c8","parentId",1,"latest",["D",1789373200842],"directory","label",[131],"pulls","branches","forks","envVars",{"_147":149,"_150":61},"connections",{"_147":61,"_148":61},"count","unfilledCount",3,"emptyCount",{"_42":130,"_31":131,"_29":132,"_133":-5,"_40":41,"_39":134,"_135":57,"_37":184,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_162":185,"_26":186},{"_42":176,"_31":177,"_29":178,"_133":132,"_40":41,"_39":179,"_135":57,"_37":180,"_13":61,"_33":160,"_35":181,"_23":24,"_138":-5,"_162":182,"_26":183},{"_42":169,"_31":170,"_29":171,"_133":132,"_40":41,"_39":134,"_135":24,"_37":172,"_13":61,"_33":160,"_35":173,"_23":24,"_138":-5,"_162":174,"_26":175},{"_42":165,"_31":32,"_29":30,"_133":132,"_40":41,"_39":14,"_135":24,"_37":166,"_13":61,"_33":34,"_35":36,"_23":24,"_138":-5,"_162":167,"_26":168},{"_42":156,"_31":157,"_29":158,"_133":132,"_40":41,"_39":149,"_135":24,"_37":159,"_13":61,"_33":160,"_35":161,"_23":24,"_138":-5,"_162":163,"_26":164},"f5c96fd3-4b1e-4509-880d-cb9fb9673396","inpars.ts","380f81f8-b013-11f1-adb7-1607ee4eb77e",["D",1789373201647],"script","// Сбор объявлений собственников из Inpars API v2 и запись в базу.\n// Запускается кроном (07:00 / 14:00 / 21:00 МСК) и вручную из интерфейса.\nimport { getSettings, nowIso, parseJson, sqlite } from \"./db.ts\";\n\nconst API = \"https://inpars.ru/api/v2\";\nconst EXPAND = \"district,metro,rooms,isNew,history,parseId,isApartments,sourceCreated,sourceUpdated,house,repairType\";\n\n// ---------- чистые функции (тестируются отдельно) ----------\n\nconst ADDR_STOP = new Set([\"москва\",\"россия\",\"г\",\"город\",\"ул\",\"улица\",\"пр-т\",\"просп\",\"проспект\",\"пер\",\"переулок\",\"б-р\",\"бул\",\"бульвар\",\"ш\",\"шоссе\",\"наб\",\"набережная\",\"пл\",\"площадь\",\"проезд\",\"пр-д\",\"д\",\"дом\",\"к\",\"корп\",\"корпус\",\"стр\",\"строение\",\"с\",\"вл\",\"владение\",\"район\",\"р-н\",\"округ\",\"ао\",\"нао\",\"тинао\",\"зао\",\"цао\",\"сзао\",\"сао\",\"свао\",\"вао\",\"ювао\",\"юао\",\"юзао\"]);\nexport function normAddress(a: string): string {\n const toks = (a || \"\").toLowerCase().replace(/ё/g, \"е\").split(/[^a-zа-я0-9]+/).filter((t) => t && !ADDR_STOP.has(t));\n return toks.sort().join(\" \");\n}\n\nexport function dupKey(o: { address: string; sq: number; rooms: number | null; floor: number | null }): string {\n const a = normAddress(o.address);\n if (!a) return \"\";\n return `${a}|${Math.round(o.sq || 0)}|${o.rooms ?? \"?\"}|${o.floor ?? \"?\"}`;\n}\n\nconst AGENT_WORDS = /(агентств[оа] недвижимости|наш(а|е|и)? (компани|агентств|риэлтор|риелтор|специалист)|риэлторск(ие|их) услуг|комиссия покупател|без комиссии для|подбер(ём|ем) (вам|для вас)|ипотечн(ый|ого) брокер|поможем (с )?(ипотек|продать)|более \\d+ (лет|объектов)|в нашей базе|эксклюзив от|официальн(ый|ого) партн)/i;\nconst OWNER_WORDS = /(собственник|без посредников|агентам не беспокоить|агентов прошу не беспокоить|риэлторов не беспокоить|услуги риэлтор[а-я]* не требуются|от хозяина|продаю сво[юй])/i;\n\nexport interface Flags { agentWords: boolean; ownerWords: boolean; phoneMulti: number; noPhone: boolean; crossListed: number; fresh: boolean; }\n\nexport function computeFlags(o: { text: string; phones: number[]; ageHours: number }, phoneCount: number, siblings: number): Flags {\n const t = o.text || \"\";\n const owner = OWNER_WORDS.test(t);\n const stripped = t.replace(OWNER_WORDS, \" \");\n return {\n agentWords: AGENT_WORDS.test(stripped),\n ownerWords: owner,\n phoneMulti: phoneCount,\n noPhone: !o.phones || o.phones.length === 0,\n crossListed: siblings,\n fresh: o.ageHours < 24,\n };\n}\n\nexport function computeScore(o: { cost: number; images: string[]; text: string }, f: Flags): number {\n let s = 50;\n if (!f.noPhone) s += 15;\n if (f.fresh) s += 10;\n if (f.crossListed >= 1) s += 10;\n if ((o.images || []).length >= 6) s += 5;\n if (f.ownerWords) s += 8;\n if ((o.text || \"\").length > 400) s += 3;\n if (o.cost >= 50_000_000) s += 5;\n if (f.agentWords) s -= 25;\n if (f.phoneMulti >= 3) s -= 30;\n else if (f.phoneMulti === 2) s -= 10;\n return Math.max(0, Math.min(100, s));\n}\n\nexport function normalize(r: any) {\n const phones: number[] = Array.isArray(r.phones) ? r.phones.filter((p: any) => p) : [];\n const images: string[] = Array.isArray(r.images) ? r.images : [];\n const sq = Number(r.sq) || 0;\n const cost = Number(r.cost) || 0;\n return {\n id: Number(r.id),\n source: r.source || \"\", source_id: r.sourceId ?? null, parse_id: r.parseId ? String(r.parseId) : null,\n url: r.url || \"\",\n type_ad: r.typeAd ?? null, section_id: r.sectionId ?? null, category_id: r.categoryId ?? null,\n category: r.category || null, rooms: r.rooms ?? null,\n title: r.title || \"\", address: r.address || \"\", district: r.district || \"\", metro: r.metro || \"\",\n floor: r.floor ?? null, floors: r.floors ?? null,\n sq, sq_living: r.sqLiving ?? null, sq_kitchen: r.sqKitchen ?? null,\n cost, cost_m2: sq > 0 ? Math.round(cost / sq) : null,\n text: r.text || \"\", images, lat: Number(r.lat) || null, lng: Number(r.lng) || null,\n name: r.name || \"\", phones,\n agent: r.agent ?? 0, is_new: r.isNew ? 1 : 0, is_apartments: r.isApartments ? 1 : 0,\n build_year: r.house?.buildYear ?? null, repair_type: r.repairType ?? null,\n source_created: r.sourceCreated || null, source_updated: r.sourceUpdated || null,\n created: r.created || null, updated: r.updated || null,\n history: Array.isArray(r.history) ? r.history : [],\n };\n}\n\nexport function fmtMln(v: number) { return (v / 1_000_000).toFixed(1).replace(\".0\", \"\").replace(\".\", \",\") + \" млн\"; }\n\n// ---------- HTTP к Inpars ----------\n\nasync function inparsGet(path: string, params: Record, token: string) {\n const u = new URL(API + path);\n for (const [k, v] of Object.entries(params)) if (v !== \"\" && v != null) u.searchParams.set(k, v);\n const r = await fetch(u, { headers: { Accept: \"application/json\", Authorization: \"Basic \" + btoa(token + \":\") } });\n if (r.status === 429) {\n const wait = Number(r.headers.get(\"X-Rate-Limit-Reset\") || \"20\");\n await new Promise((res) => setTimeout(res, Math.min(wait, 60) * 1000));\n return inparsGet(path, params, token);\n }\n if (!r.ok) throw new Error(`Inpars ${r.status}: ${(await r.text()).slice(0, 300)}`);\n return r.json();\n}\n\nexport async function inparsSubscription(token: string) {\n return inparsGet(\"/user/subscribe\", {}, token);\n}\n\n// ---------- основной цикл сбора ----------\n\nexport async function sync(trigger = \"cron\", opts: { token?: string; sinceOverride?: number } = {}) {\n const token = opts.token || Deno.env.get(\"INPARS_TOKEN\") || \"\";\n if (!token) throw new Error(\"Не задан INPARS_TOKEN\");\n const s = await getSettings();\n const started = nowIso();\n const runIns = await sqlite.execute({ sql: \"INSERT INTO runs(started_at, trigger) VALUES(?,?)\", args: [started, trigger] });\n const runId = Number(runIns.lastInsertRowid);\n\n let fetched = 0, inserted = 0, updated = 0, priceChanges = 0;\n try {\n // Начало окна: последний успешный запуск минус 45 минут перекрытия, иначе backfill_days.\n const last = await sqlite.execute(\"SELECT started_at FROM runs WHERE error IS NULL AND finished_at IS NOT NULL ORDER BY id DESC LIMIT 1\");\n let since: number;\n if (opts.sinceOverride) since = opts.sinceOverride;\n else if (last.rows.length) since = Math.floor(new Date(String((last.rows[0] as any).started_at)).getTime() / 1000) - 45 * 60;\n else since = Math.floor(Date.now() / 1000) - Number(s.backfill_days || 7) * 86400;\n\n const base: Record = {\n regionId: s.region_id, typeAd: s.type_ad, sectionId: s.section_ids,\n costMin: s.cost_min, costMax: s.cost_max, sourceId: s.source_ids, isNew: s.is_new,\n sellerType: \"1\", sortBy: \"updated_asc\", limit: \"1000\", expand: EXPAND,\n };\n\n const seenIds = new Set();\n let timeStart = since;\n for (let page = 0; page < 12; page++) {\n const j = await inparsGet(\"/estate\", { ...base, timeStart: String(timeStart) }, token);\n const rows: any[] = j.data || [];\n const fresh = rows.filter((r) => !seenIds.has(Number(r.id)));\n fresh.forEach((r) => seenIds.add(Number(r.id)));\n fetched += fresh.length;\n const res = await upsertBatch(fresh.map(normalize), s);\n inserted += res.inserted; updated += res.updated; priceChanges += res.priceChanges;\n const total = Number(j.meta?.totalCount || 0);\n if (rows.length === 0 || rows.length < 1000 || total <= rows.length) break;\n const lastUpd = rows[rows.length - 1].updated;\n const next = Math.floor(new Date(lastUpd).getTime() / 1000);\n if (!next || next <= timeStart) break;\n timeStart = next;\n await new Promise((r) => setTimeout(r, 6500)); // 10 запросов в минуту\n }\n\n // Скрываем объекты, которые давно не обновлялись на источнике (сняты с продажи).\n const cutoff = new Date(Date.now() - Number(s.retention_days || 60) * 86400000).toISOString();\n await sqlite.execute({ sql: \"UPDATE objects SET hidden=1 WHERE hidden=0 AND status IN ('new','noanswer') AND last_seen < ?\", args: [cutoff] });\n\n await sqlite.execute({\n sql: \"UPDATE runs SET finished_at=?, fetched=?, inserted=?, updated=?, price_changes=? WHERE id=?\",\n args: [nowIso(), fetched, inserted, updated, priceChanges, runId],\n });\n return { runId, fetched, inserted, updated, priceChanges };\n } catch (e) {\n await sqlite.execute({ sql: \"UPDATE runs SET finished_at=?, fetched=?, inserted=?, updated=?, error=? WHERE id=?\", args: [nowIso(), fetched, inserted, updated, String((e as Error).message || e), runId] });\n throw e;\n }\n}\n\nasync function upsertBatch(items: ReturnType[], s: Record) {\n let inserted = 0, updated = 0, priceChanges = 0;\n if (!items.length) return { inserted, updated, priceChanges };\n const now = nowIso();\n\n // Существующие записи одним запросом\n const ids = items.map((i) => i.id);\n const existing = new Map();\n for (let i = 0; i < ids.length; i += 400) {\n const chunk = ids.slice(i, i + 400);\n const r = await sqlite.execute({ sql: `SELECT id, cost, status, first_seen, cost_first, dup_key, phones FROM objects WHERE id IN (${chunk.map(() => \"?\").join(\",\")})`, args: chunk });\n for (const row of r.rows as any[]) existing.set(Number(row.id), row);\n }\n\n // Учёт телефонов: сколько разных объектов у номера\n const phoneStmts: any[] = [];\n for (const it of items) {\n if (existing.has(it.id)) continue;\n for (const p of it.phones) {\n phoneStmts.push({ sql: \"INSERT INTO phone_seen(phone, objects, sources, first_seen) VALUES(?,1,?,?) ON CONFLICT(phone) DO UPDATE SET objects=objects+1\", args: [String(p), it.source, now] });\n }\n }\n if (phoneStmts.length) await sqlite.batch(phoneStmts);\n const allPhones = [...new Set(items.flatMap((i) => i.phones.map(String)))];\n const phoneCount = new Map();\n for (let i = 0; i < allPhones.length; i += 400) {\n const chunk = allPhones.slice(i, i + 400);\n const r = await sqlite.execute({ sql: `SELECT phone, objects FROM phone_seen WHERE phone IN (${chunk.map(() => \"?\").join(\",\")})`, args: chunk });\n for (const row of r.rows as any[]) phoneCount.set(String(row.phone), Number(row.objects));\n }\n\n // Дубли между площадками по адресу+площади+комнатам+этажу\n const keys = [...new Set(items.map(dupKey).filter(Boolean))];\n const dupOwner = new Map();\n for (let i = 0; i < keys.length; i += 400) {\n const chunk = keys.slice(i, i + 400);\n const r = await sqlite.execute({ sql: `SELECT id, dup_key FROM objects WHERE dup_of IS NULL AND dup_key IN (${chunk.map(() => \"?\").join(\",\")})`, args: chunk });\n for (const row of r.rows as any[]) if (!dupOwner.has(String(row.dup_key))) dupOwner.set(String(row.dup_key), Number(row.id));\n }\n\n const stmts: any[] = [];\n for (const it of items) {\n const key = dupKey(it);\n const ex = existing.get(it.id);\n const ageHours = it.source_created ? (Date.now() - new Date(it.source_created).getTime()) / 3600000 : 0;\n const pc = Math.max(0, ...it.phones.map((p) => phoneCount.get(String(p)) || 0));\n const siblings = key && dupOwner.has(key) && dupOwner.get(key) !== it.id ? 1 : 0;\n const flags = computeFlags({ text: it.text, phones: it.phones, ageHours }, pc, siblings);\n const score = computeScore(it, flags);\n const dupOf = key && dupOwner.has(key) && dupOwner.get(key) !== it.id ? dupOwner.get(key)! : null;\n if (key && !dupOwner.has(key)) dupOwner.set(key, it.id);\n\n if (!ex) {\n inserted++;\n stmts.push({\n sql: `INSERT INTO objects(id, source, source_id, parse_id, url, type_ad, section_id, category_id, category, rooms, title, address, district, metro,\n floor, floors, sq, sq_living, sq_kitchen, cost, cost_m2, text, images, lat, lng, name, phones, agent, is_new, is_apartments, build_year, repair_type,\n source_created, source_updated, created, updated, first_seen, last_seen, cost_first, score, flags, status, status_at, dup_key, dup_of)\n VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,'new',?,?,?)`,\n args: [it.id, it.source, it.source_id, it.parse_id, it.url, it.type_ad, it.section_id, it.category_id, it.category, it.rooms, it.title, it.address, it.district, it.metro,\n it.floor, it.floors, it.sq, it.sq_living, it.sq_kitchen, it.cost, it.cost_m2, it.text, JSON.stringify(it.images), it.lat, it.lng, it.name, JSON.stringify(it.phones), it.agent, it.is_new, it.is_apartments, it.build_year, it.repair_type,\n it.source_created, it.source_updated, it.created, it.updated, now, now, it.cost, score, JSON.stringify(flags), now, key || null, dupOf],\n });\n // История цены с источника, если Inpars её отдал\n const hist = it.history.filter((h: any) => h && h.cost).map((h: any) => ({ d: h.date, c: Number(h.cost) }));\n if (hist.length > 1) {\n stmts.push({ sql: \"INSERT INTO activity(object_id, kind, text, meta, created_at) VALUES(?,?,?,?,?)\", args: [it.id, \"system\", `История цены на площадке: ${hist.map((h: any) => fmtMln(h.c)).join(\" → \")}`, JSON.stringify(hist), now] });\n }\n } else {\n updated++;\n const oldCost = Number(ex.cost);\n const changed = oldCost && it.cost && oldCost !== it.cost;\n if (changed) priceChanges++;\n const newPhones = it.phones.length ? JSON.stringify(it.phones) : ex.phones; // не терять телефон, если площадка его скрыла\n stmts.push({\n sql: `UPDATE objects SET url=?, title=?, address=?, district=?, metro=?, floor=?, floors=?, sq=?, sq_living=?, sq_kitchen=?, cost=?, cost_m2=?, text=?, images=?, lat=?, lng=?, name=?, phones=?,\n source_updated=?, updated=?, last_seen=?, hidden=0, score=?, flags=?\n ${changed ? \", cost_prev=?, cost_changed_at=?\" : \"\"} WHERE id=?`,\n args: [it.url, it.title, it.address, it.district, it.metro, it.floor, it.floors, it.sq, it.sq_living, it.sq_kitchen, it.cost, it.cost_m2, it.text, JSON.stringify(it.images), it.lat, it.lng, it.name, newPhones,\n it.source_updated, it.updated, now, score, JSON.stringify(flags), ...(changed ? [oldCost, now] : []), it.id],\n });\n if (changed) {\n const dir = it.cost < oldCost ? \"снижена\" : \"повышена\";\n stmts.push({ sql: \"INSERT INTO activity(object_id, kind, text, meta, created_at) VALUES(?,?,?,?,?)\", args: [it.id, \"system\", `Цена ${dir}: ${fmtMln(oldCost)} → ${fmtMln(it.cost)}`, JSON.stringify({ from: oldCost, to: it.cost }), now] });\n }\n }\n }\n for (let i = 0; i < stmts.length; i += 200) await sqlite.batch(stmts.slice(i, i + 200));\n return { inserted, updated, priceChanges };\n}\n","children",[],[131,157],"644375f8-5a2c-4e59-a1bd-373e47be47b1",["D",1789373202003],[],[131,32],"c8c8d913-e9ea-474b-9cbd-174f846e0f07","db.ts","37957692-b013-11f1-8804-1607ee4eb77e",["D",1789373200842],"// База данных парсера собственников Unlock.\n// Val-scoped SQLite: таблицы объектов, ленты активности, запусков и настроек.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport { sqlite };\n\nexport const STATUSES: Record = {\n new: { label: \"Новый\", color: \"#0ea5e9\" },\n work: { label: \"В работе\", color: \"#5b5bd6\" },\n recall: { label: \"Перезвонить\", color: \"#f59e0b\" },\n noanswer: { label: \"Не дозвонились\", color: \"#94a3b8\" },\n meeting: { label: \"Встреча / договор\", color: \"#10b981\" },\n refused: { label: \"Не готов сотрудничать\", color: \"#6b7280\", done: true },\n agent: { label: \"Это агент\", color: \"#a16207\", done: true },\n aggressive: { label: \"Агрессивен\", color: \"#ef4444\", done: true, hidePhone: true },\n dnc: { label: \"Просит не звонить\", color: \"#171a26\", done: true, hidePhone: true },\n gone: { label: \"Снят / продан\", color: \"#cbd5e1\", done: true },\n};\n\nexport async function migrate() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS objects (\n id INTEGER PRIMARY KEY,\n source TEXT, source_id INTEGER, parse_id TEXT, url TEXT,\n type_ad INTEGER, section_id INTEGER, category_id INTEGER, category TEXT, rooms INTEGER,\n title TEXT, address TEXT, district TEXT, metro TEXT,\n floor INTEGER, floors INTEGER, sq REAL, sq_living REAL, sq_kitchen REAL,\n cost INTEGER, cost_m2 INTEGER, text TEXT, images TEXT, lat REAL, lng REAL,\n name TEXT, phones TEXT, agent INTEGER, is_new INTEGER, is_apartments INTEGER,\n build_year INTEGER, repair_type INTEGER,\n source_created TEXT, source_updated TEXT, created TEXT, updated TEXT,\n first_seen TEXT, last_seen TEXT,\n cost_prev INTEGER, cost_changed_at TEXT, cost_first INTEGER,\n score INTEGER DEFAULT 0, flags TEXT, brief TEXT,\n status TEXT DEFAULT 'new', assignee_id INTEGER, assignee_name TEXT,\n status_at TEXT, status_by TEXT, recall_at TEXT,\n dup_key TEXT, dup_of INTEGER, hidden INTEGER DEFAULT 0\n )`,\n `CREATE INDEX IF NOT EXISTS idx_objects_status ON objects(status)`,\n `CREATE INDEX IF NOT EXISTS idx_objects_first_seen ON objects(first_seen)`,\n `CREATE INDEX IF NOT EXISTS idx_objects_dup ON objects(dup_key)`,\n `CREATE TABLE IF NOT EXISTS activity (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n object_id INTEGER NOT NULL,\n kind TEXT NOT NULL, -- comment | status | assign | system\n broker_id INTEGER, broker_name TEXT,\n text TEXT, meta TEXT,\n created_at TEXT NOT NULL\n )`,\n `CREATE INDEX IF NOT EXISTS idx_activity_obj ON activity(object_id, id)`,\n `CREATE TABLE IF NOT EXISTS runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n started_at TEXT, finished_at TEXT, trigger TEXT,\n fetched INTEGER DEFAULT 0, inserted INTEGER DEFAULT 0, updated INTEGER DEFAULT 0,\n price_changes INTEGER DEFAULT 0, error TEXT, note TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS settings (key TEXT PRIMARY KEY, value TEXT)`,\n `CREATE TABLE IF NOT EXISTS brokers (\n id INTEGER PRIMARY KEY, name TEXT, pin TEXT, active INTEGER, synced_at TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS phone_seen (\n phone TEXT PRIMARY KEY, objects INTEGER DEFAULT 0, sources TEXT, first_seen TEXT\n )`,\n ]);\n}\n\nexport const DEFAULT_SETTINGS: Record = {\n region_id: \"77\",\n type_ad: \"2\", // продажа\n section_ids: \"1,5\", // жилая + загородная\n cost_min: \"30000000\",\n cost_max: \"\",\n source_ids: \"\", // пусто = все источники Inpars\n is_new: \"\", // '' = всё, 0 = вторичка, 1 = новостройки\n backfill_days: \"7\", // глубина первого сбора\n retention_days: \"60\", // скрывать объекты, не обновлявшиеся дольше\n};\n\nexport async function getSettings(): Promise> {\n const r = await sqlite.execute(\"SELECT key, value FROM settings\");\n const s = { ...DEFAULT_SETTINGS };\n for (const row of r.rows as any[]) s[row.key] = String(row.value ?? \"\");\n return s;\n}\n\nexport async function setSettings(patch: Record) {\n const stmts = Object.entries(patch)\n .filter(([k]) => k in DEFAULT_SETTINGS)\n .map(([k, v]) => ({ sql: \"INSERT INTO settings(key,value) VALUES(?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value\", args: [k, String(v ?? \"\")] }));\n if (stmts.length) await sqlite.batch(stmts);\n}\n\nexport const nowIso = () => new Date().toISOString();\n\nexport function parseJson(s: unknown, fallback: T): T {\n if (typeof s !== \"string\" || !s) return fallback;\n try { return JSON.parse(s) as T; } catch { return fallback; }\n}\n",[],[131,170],"75391e84-27fc-4b3e-bd38-580217124b24","auth.ts","37cb20e4-b013-11f1-9622-1607ee4eb77e",2,["D",1789373201197],"// Вход по ПИН-коду — единый с «Воронкой дня»: ПИНы проверяются через её /api/login,\n// список брокеров подтягивается из её /api/team и кэшируется в локальной таблице brokers.\nimport { nowIso, sqlite } from \"./db.ts\";\n\nexport const FUNNEL_URL = Deno.env.get(\"FUNNEL_URL\") || \"https://tambovtsev007--8c600d2286b511f1862b1607ee4eb77e.web.val.run\";\nconst BOSS_PIN = Deno.env.get(\"BOSS_PIN\") || \"1804\";\n\nexport interface User { role: \"boss\" | \"broker\"; id: number; name: string }\n\nconst cache = new Map();\nconst TTL = 10 * 60 * 1000;\n\nexport async function loginByPin(pin: string): Promise {\n if (!/^\\d{4,6}$/.test(pin)) return null;\n const c = cache.get(pin);\n if (c && Date.now() - c.at < TTL) return c.user;\n let user: User | null = null;\n try {\n const r = await fetch(FUNNEL_URL + \"/api/login\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify({ pin }),\n signal: AbortSignal.timeout(8000),\n });\n if (r.ok) {\n const j = await r.json();\n user = j.role === \"boss\" ? { role: \"boss\", id: 0, name: j.name || \"Руководитель\" } : { role: \"broker\", id: Number(j.id), name: j.name };\n }\n } catch {\n // Воронка недоступна — проверяем по локальному кэшу брокеров\n if (pin === BOSS_PIN) user = { role: \"boss\", id: 0, name: \"Руководитель\" };\n else {\n const b = await sqlite.execute({ sql: \"SELECT id, name FROM brokers WHERE pin=? AND active=1\", args: [pin] });\n if (b.rows.length) user = { role: \"broker\", id: Number((b.rows[0] as any).id), name: String((b.rows[0] as any).name) };\n }\n }\n cache.set(pin, { user, at: Date.now() });\n return user;\n}\n\nexport async function syncBrokers() {\n const r = await fetch(FUNNEL_URL + \"/api/team?date=\" + new Date().toISOString().slice(0, 10), { headers: { \"x-pin\": BOSS_PIN }, signal: AbortSignal.timeout(8000) });\n if (!r.ok) throw new Error(\"team \" + r.status);\n const j = await r.json();\n const list: any[] = j.brokers || [];\n if (!list.length) return;\n await sqlite.batch(list.map((b) => ({\n sql: \"INSERT INTO brokers(id,name,pin,active,synced_at) VALUES(?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET name=excluded.name, pin=excluded.pin, active=excluded.active, synced_at=excluded.synced_at\",\n args: [b.id, b.name, String(b.pin || \"\"), b.active ? 1 : 0, nowIso()],\n })));\n}\n\nexport async function listBrokers(): Promise<{ id: number; name: string; active: number }[]> {\n const r = await sqlite.execute(\"SELECT id, name, active FROM brokers ORDER BY name\");\n return (r.rows as any[]).map((b) => ({ id: Number(b.id), name: String(b.name), active: Number(b.active) }));\n}\n",[],[131,177],["D",1789373200842],[152,153,154,155],[131],["D",1789373200178],["D",1789547455787],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":54,"_103":104,"_105":24},{"_13":87,"_31":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_80":-5,"_126":225,"_226":227,"_228":229,"_230":24,"_231":24,"_232":24,"_233":57,"_234":-5,"_235":-7,"_236":-7,"_237":61,"_238":24,"_239":24,"_240":-5,"_241":24,"_242":24,"_243":24,"_244":-5},"ENV",{"_196":197,"_198":199,"_200":88,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v4