Unlock · Собственники

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_276":277,"_278":279},"routes/_app.x.$handle.$name",{"_100":99,"_32":46,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":31,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",78,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"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, inparsTask } from \"./inpars.ts\";\nimport { listBrokers, loginByPin, syncBrokers, type User } from \"./auth.ts\";\nimport { migratePush, saveSub, dropSub, subsFor, notifyBroker, vapidPublic } from \"./push.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(); await migratePush(); 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(\"/app2.js\", (c) => serveFile(\"/frontend/app2.js\", import.meta.url));\napp.get(\"/sw.js\", async (c) => c.body(await readFile(\"/frontend/sw.js\", import.meta.url), 200, { \"Content-Type\": \"application/javascript; charset=utf-8\", \"Service-Worker-Allowed\": \"/\", \"Cache-Control\": \"no-store\" }));\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 // Крон каждую минуту — следующая круглая минута\n const d = new Date(); d.setUTCSeconds(0, 0); d.setUTCMinutes(d.getUTCMinutes() + 1);\n return d.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 WHERE finished_at IS NOT NULL 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 COALESCE(source_created, created, 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 lastData = await sqlite.execute(\"SELECT started_at, inserted, updated FROM runs WHERE inserted>0 ORDER BY id DESC LIMIT 1\");\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 yandexKey: s.yandex_key || Deno.env.get(\"YANDEX_MAPS_KEY\") || \"\",\n zones: (await sqlite.execute(\"SELECT id, name, points, color, created_by, created_by_name FROM zones ORDER BY name\")).rows.map((z: any) => ({ ...z, points: parseJson(z.points, []) })),\n lastRun: last.rows[0] || null,\n lastNew: lastData.rows[0] || null,\n nextRun: nextRunIso(),\n serverTime: nowIso(),\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 = `objects.id, source, url, category, section_id, rooms, sq_land, address, district, metro, floor, floors, sq, cost, cost_m2, images, lat, lng, phones, is_new, is_apartments, build_year,\n source_created, created, first_seen, cost_prev, cost_changed_at, score, status, assignee_id, assignee_name, status_at, recall_at, suspect, phone_req_at, phone_req_status,\n COALESCE(d.c, 1) - 1 AS twins, COALESCE(t.n, 0) AS touches, t.last AS last_touch`;\nconst LIST_JOINS = `LEFT JOIN (SELECT dup_key, COUNT(*) c FROM objects WHERE hidden=0 AND dup_key IS NOT NULL GROUP BY dup_key) d ON d.dup_key=objects.dup_key\n LEFT JOIN (SELECT object_id, COUNT(*) n, MAX(created_at) last FROM activity WHERE kind IN ('status','comment','assign') GROUP BY object_id) t ON t.object_id=objects.id`;\n\napp.get(\"/api/objects\", async (c) => {\n const u = c.get(\"user\");\n const q = c.req.query();\n const where: string[] = [q.gone === \"1\" ? \"hidden=1 AND gone_at IS NOT NULL\" : \"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.assigned === \"1\") where.push(\"assignee_id IS NOT NULL\");\n if (q.section) { const sc = q.section.split(\",\").map(Number).filter((n) => n > 0); if (sc.length) { where.push(`section_id IN (${sc.map(() => \"?\").join(\",\")})`); args.push(...sc); } }\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(\"COALESCE(source_created, created, 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.sqMin) { where.push(\"sq>=?\"); args.push(Number(q.sqMin)); }\n if (q.sqMax) { where.push(\"sq<=?\"); args.push(Number(q.sqMax)); }\n if (q.m2Min) { where.push(\"cost_m2>=?\"); args.push(Number(q.m2Min)); }\n if (q.m2Max) { where.push(\"cost_m2<=?\"); args.push(Number(q.m2Max)); }\n if (q.notFirst === \"1\") where.push(\"(floor IS NULL OR floor>1)\");\n if (q.notLast === \"1\") where.push(\"(floor IS NULL OR floors IS NULL OR floor=?\"); args.push(Number(q.yearMin)); }\n if (q.yearMax) { where.push(\"build_year<=?\"); args.push(Number(q.yearMax)); }\n if (q.hideAgent === \"1\") where.push(\"COALESCE(suspect,0)=0\");\n if (q.cross === \"1\") where.push(\"COALESCE(d.c, 1) > 1\");\n if (q.isNew === \"0\" || q.isNew === \"1\") { where.push(\"is_new=?\"); args.push(Number(q.isNew)); }\n if (q.touched === \"1\") { where.push(\"objects.id IN (SELECT object_id FROM activity WHERE broker_id=? AND kind IN ('comment','status','assign'))\"); args.push(q.broker && u.role === \"boss\" ? Number(q.broker) : u.id); }\n if (q.recallSort === \"1\") where.push(\"recall_at IS NOT NULL\");\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 dom: \"COALESCE(source_created, created, first_seen) ASC\", recall: \"recall_at IS NULL, recall_at ASC\", fresh: \"COALESCE(source_created, created, 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) || 5000, 8000);\n const r = await sqlite.execute({ sql: `SELECT ${LIST_COLS} FROM objects ${LIST_JOINS} 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 st = STATUSES[String(o.status)] || STATUSES.new;\n // первая картинка без разбора всего JSON\n const im = typeof o.images === \"string\" ? o.images.match(/\"([^\"]+)\"/) : null;\n const photos = typeof o.images === \"string\" ? (o.images.match(/\"/g) || []).length / 2 : 0;\n const hasPhone = typeof o.phones === \"string\" && /\\d/.test(o.phones);\n const row: any = {\n id: Number(o.id), source: o.source, url: o.url, category: o.category, section_id: o.section_id, rooms: o.rooms, address: o.address, metro: o.metro,\n floor: o.floor, floors: o.floors, sq: o.sq, cost: o.cost, cost_m2: o.cost_m2, img: im ? im[1] : null, photos,\n lat: o.lat, lng: o.lng, hasPhone, status: o.status, source_created: o.source_created, created: o.created, first_seen: o.first_seen, score: o.score,\n flags: { crossListed: Number(o.twins || 0), agentWords: !!o.suspect, phoneMulti: 0 },\n };\n if (o.sq_land) row.sq_land = o.sq_land; if (o.district) row.district = o.district;\n if (o.is_new) row.is_new = 1; if (o.is_apartments) row.is_apartments = 1; if (o.build_year) row.build_year = o.build_year;\n if (o.cost_prev) { row.cost_prev = o.cost_prev; row.cost_changed_at = o.cost_changed_at; }\n if (o.assignee_id) { row.assignee_id = o.assignee_id; row.assignee_name = o.assignee_name; }\n if (o.status_at) row.status_at = o.status_at; if (o.recall_at) row.recall_at = o.recall_at;\n if (o.phone_req_at) { row.phone_req_at = o.phone_req_at; row.phone_req_status = o.phone_req_status; }\n if (o.touches) { row.touches = Number(o.touches); row.last_touch = o.last_touch; }\n if (st.hidePhone && u.role !== \"boss\") row.hidePhone = true;\n return row;\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 // Сравнение с рынком: средняя цена метра по таким же объектам (метро + комнатность), иначе по району\n let market: any = null;\n if (o.cost_m2 && o.section_id === 1) {\n const tryScope = async (label: string, sql: string, args: any[]) => { const r = await sqlite.execute({ sql, args }); const row = r.rows[0] as any; return row && Number(row.n) >= 4 ? { scope: label, avg: Math.round(Number(row.avg)), n: Number(row.n) } : null; };\n if (o.metro) market = await tryScope(`м. ${o.metro}${o.rooms ? \", \" + (o.rooms >= 4 ? \"4+\" : o.rooms) + \"-к\" : \"\"}`, \"SELECT AVG(cost_m2) avg, COUNT(*) n FROM objects WHERE hidden=0 AND section_id=1 AND cost_m2>0 AND metro=? AND (rooms=? OR (?>=4 AND rooms>=4)) AND id!=?\", [o.metro, o.rooms, o.rooms, id]);\n if (!market && o.metro) market = await tryScope(`м. ${o.metro}`, \"SELECT AVG(cost_m2) avg, COUNT(*) n FROM objects WHERE hidden=0 AND section_id=1 AND cost_m2>0 AND metro=? AND id!=?\", [o.metro, id]);\n if (!market && o.district) market = await tryScope(o.district, \"SELECT AVG(cost_m2) avg, COUNT(*) n FROM objects WHERE hidden=0 AND section_id=1 AND cost_m2>0 AND district=? AND id!=?\", [o.district, id]);\n }\n let comps: any[] = [];\n if (o.section_id === 1 && o.metro) {\n const cr = await sqlite.execute({ sql: \"SELECT id, cost, sq, cost_m2, address, status, rooms, floor, floors FROM objects WHERE hidden=0 AND dup_of IS NULL AND section_id=1 AND metro=? AND (rooms=? OR (?>=4 AND rooms>=4)) AND id!=? ORDER BY ABS(COALESCE(sq,0)-?) LIMIT 5\", args: [o.metro, o.rooms, o.rooms, id, o.sq || 0] });\n comps = cr.rows;\n }\n return c.json({\n ...o,\n market, comps,\n images: parseJson(o.images, []),\n phones: hide ? [] : parseJson(o.phones, []),\n hidePhone: hide,\n flags: { ...parseJson(o.flags, {}), crossListed: sib.rows.length },\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\" || status === \"meeting\") && 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=?, recall_notified=0, 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\" || Number((await sqlite.execute({ sql: \"SELECT assignee_id FROM objects WHERE id=?\", args: [id] })).rows[0]?.assignee_id) === u.id)) {\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 if (toId && toId !== u.id) { const o = (await sqlite.execute({ sql: \"SELECT cost, address, title FROM objects WHERE id=?\", args: [id] })).rows[0] as any; notifyBroker(toId, { title: `${u.name} передал тебе объект`, body: `${(Number(o.cost) / 1e6).toFixed(1).replace(\".0\", \"\")} млн · ${o.title || o.address}`, url: `/?o=${id}`, tag: \"assign-\" + id }).catch(() => {}); }\n return c.json({ ok: true, assignee_id: toId, assignee_name: toName, status: newStatus });\n});\n\n// Запрос номера: просим Inpars перечитать объявление; телефон придёт с ближайшим сбором\napp.post(\"/api/objects/:id/phone\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const r = await sqlite.execute({ sql: \"SELECT url, source, phone_req_at, phones 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 if (!/avito\\.ru|cian\\.ru|youla\\.io|domclick\\.ru/.test(String(o.url))) return c.json({ error: \"Для этой площадки Inpars не делает повторный разбор\" }, 400);\n if (o.phone_req_at && Date.now() - new Date(String(o.phone_req_at)).getTime() < 24 * 3600000) return c.json({ ok: true, status: String(o.phone_req_status || \"inprogress\"), at: o.phone_req_at, repeat: true });\n try {\n const j = await inparsTask([String(o.url)], Deno.env.get(\"INPARS_TOKEN\") || \"\");\n const t = (j.data || [])[0] || {};\n const now = nowIso();\n await sqlite.batch([\n { sql: \"UPDATE objects SET phone_req_at=?, phone_req_status=? WHERE id=?\", args: [now, String(t.status || \"created\"), id] },\n { sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, created_at) VALUES(?,?,?,?,?,?)\", args: [id, \"system\", u.id, u.name, `Запрошен телефон у Inpars (${u.name})`, now] },\n ]);\n return c.json({ ok: true, status: String(t.status || \"created\"), message: t.message, at: now, remaining: j.meta?.updateRemaining, limit: j.meta?.updateLimit });\n } catch (e) { return c.json({ error: String((e as Error).message) }, 502); }\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// Пульс для интерфейса: есть ли новое с момента since (объекты или действия команды)\nlet lazySyncing = false;\n// Ленивый сбор: пока кто-то из команды держит приложение открытым, пульс раз в 30 с\n// сам запускает сбор, если прошлому больше 55 секунд. Крон — страховка, когда никто не смотрит.\nasync function lazySync() {\n if (lazySyncing) return;\n const r = await sqlite.execute(\"SELECT started_at, finished_at FROM runs ORDER BY id DESC LIMIT 1\");\n const last = r.rows[0] as any;\n if (last) {\n const startedAgo = Date.now() - new Date(String(last.started_at)).getTime();\n if (!last.finished_at && startedAgo < 90_000) return; // другой запуск ещё идёт\n if (last.finished_at && startedAgo < 55_000) return;\n }\n lazySyncing = true;\n try { await sync(\"pulse\"); } catch (e) { console.warn(\"lazy sync:\", e); } finally { lazySyncing = false; }\n}\n\napp.get(\"/api/pulse\", async (c) => {\n await lazySync();\n const since = String(c.req.query(\"since\") || \"\");\n if (!since) return c.json({ objects: 0, activity: 0, now: nowIso() });\n const [o, a, ch] = await Promise.all([\n sqlite.execute({ sql: \"SELECT COUNT(*) n FROM objects WHERE hidden=0 AND dup_of IS NULL AND first_seen > ?\", args: [since] }),\n sqlite.execute({ sql: \"SELECT COUNT(*) n FROM activity WHERE created_at > ?\", args: [since] }),\n sqlite.execute({ sql: \"SELECT COUNT(*) n FROM objects WHERE status_at > ? OR cost_changed_at > ?\", args: [since, since] }),\n ]);\n return c.json({ objects: Number((o.rows[0] as any).n), activity: Number((a.rows[0] as any).n), changed: Number((ch.rows[0] as any).n), now: nowIso() });\n});\n\n// Зоны на карте — сохранённые полигоны, общие для команды\napp.get(\"/api/zones\", async (c) => {\n const r = await sqlite.execute(\"SELECT id, name, points, color, created_by, created_by_name FROM zones ORDER BY name\");\n return c.json({ items: (r.rows as any[]).map((z) => ({ ...z, points: parseJson(z.points, []) })) });\n});\napp.post(\"/api/zones\", async (c) => {\n const u = c.get(\"user\");\n const b = await c.req.json().catch(() => ({}));\n const pts = Array.isArray(b.points) ? b.points.filter((p: any) => Array.isArray(p) && p.length === 2 && isFinite(p[0]) && isFinite(p[1])).map((p: any) => [Number(p[0]), Number(p[1])]) : [];\n const name = String(b.name || \"\").trim().slice(0, 60);\n if (pts.length < 3 || !name) return c.json({ error: \"Нужно имя и минимум 3 точки\" }, 400);\n const r = await sqlite.execute({ sql: \"INSERT INTO zones(name, points, color, created_by, created_by_name, created_at) VALUES(?,?,?,?,?,?)\", args: [name, JSON.stringify(pts), String(b.color || \"#5b5bd6\"), u.id, u.name, nowIso()] });\n return c.json({ id: Number(r.lastInsertRowid), name, points: pts, color: String(b.color || \"#5b5bd6\"), created_by: u.id, created_by_name: u.name });\n});\napp.delete(\"/api/zones/:id\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const z = await sqlite.execute({ sql: \"SELECT created_by FROM zones WHERE id=?\", args: [id] });\n if (!z.rows.length) return c.json({ error: \"not found\" }, 404);\n if (u.role !== \"boss\" && Number((z.rows[0] as any).created_by) !== u.id) return c.json({ error: \"Зону может удалить автор или руководитель\" }, 403);\n await sqlite.execute({ sql: \"DELETE FROM zones WHERE id=?\", args: [id] });\n return c.json({ ok: true });\n});\n\n// Push-уведомления\napp.get(\"/api/push\", async (c) => { const u = c.get(\"user\"); return c.json({ key: vapidPublic(), subs: await subsFor(u.id) }); });\napp.post(\"/api/push\", async (c) => {\n const u = c.get(\"user\");\n const b = await c.req.json().catch(() => ({}));\n if (!b.sub || !b.sub.endpoint) return c.json({ error: \"no subscription\" }, 400);\n await saveSub(u.id, u.name, b.sub, (b.zones || []).map(Number), !!b.all_new);\n return c.json({ ok: true });\n});\napp.delete(\"/api/push\", async (c) => { const b = await c.req.json().catch(() => ({})); if (b.endpoint) await dropSub(String(b.endpoint)); return c.json({ ok: true }); });\napp.post(\"/api/push/test\", async (c) => { const u = c.get(\"user\"); const n = await notifyBroker(u.id, { title: \"Уведомления включены\", body: \"Так будут приходить новые собственники и напоминания\", url: \"/\" }); return c.json({ sent: n }); });\n\n// Удалить свой комментарий (руководитель — любой)\napp.delete(\"/api/activity/: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 broker_id, kind FROM activity WHERE id=?\", args: [id] });\n if (!r.rows.length) return c.json({ error: \"not found\" }, 404);\n const a = r.rows[0] as any;\n if (a.kind !== \"comment\") return c.json({ error: \"Удалять можно только комментарии\" }, 400);\n if (u.role !== \"boss\" && Number(a.broker_id) !== u.id) return c.json({ error: \"Это не твой комментарий\" }, 403);\n await sqlite.execute({ sql: \"DELETE FROM activity WHERE id=?\", args: [id] });\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 WHERE a.kind != 'system' 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 now = Math.floor(Date.now() / 1000);\n const r = await sync(\"manual\", body.days ? { sinceOverride: now - Number(body.days) * 86400, untilOverride: body.until_days ? now - Number(body.until_days) * 86400 : undefined } : {});\n return c.json(r);\n});\n\napp.get(\"/api/runs\", boss, async (c) => {\n const r = await sqlite.execute(\"SELECT * FROM runs WHERE fetched>0 OR error IS NOT NULL ORDER BY id DESC LIMIT 40\");\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/export.csv\", boss, async (c) => {\n const r = await sqlite.execute(`SELECT id, source, url, category, rooms, sq, sq_land, floor, floors, cost, cost_m2, address, district, metro, phones, status, assignee_name, status_at, recall_at, source_created, first_seen, cost_prev, build_year FROM objects WHERE hidden=0 AND dup_of IS NULL ORDER BY COALESCE(source_created, created, first_seen) DESC`);\n const cols = [\"id\", \"source\", \"url\", \"category\", \"rooms\", \"sq\", \"sq_land\", \"floor\", \"floors\", \"cost\", \"cost_m2\", \"address\", \"district\", \"metro\", \"phones\", \"status\", \"assignee_name\", \"status_at\", \"recall_at\", \"source_created\", \"first_seen\", \"cost_prev\", \"build_year\"];\n const esc = (v: any) => { const s = v == null ? \"\" : String(v); return /[\";\\n]/.test(s) ? '\"' + s.replace(/\"/g, '\"\"') + '\"' : s; };\n const lines = [cols.join(\";\"), ...(r.rows as any[]).map((row) => cols.map((k) => esc(k === \"phones\" ? parseJson(row[k], []).join(\" \") : row[k])).join(\";\"))];\n return new Response(\"\\ufeff\" + lines.join(\"\\n\"), { headers: { \"Content-Type\": \"text/csv; charset=utf-8\", \"Content-Disposition\": `attachment; filename=\"sobstvenniki_${new Date().toISOString().slice(0, 10)}.csv\"` } });\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\n// Отладка (только руководитель): выполнить SQL в базе парсера\napp.post(\"/api/debug/sql\", boss, async (c) => {\n const body = await c.req.json().catch(() => ({}));\n try {\n const r = body.batch ? await sqlite.batch(body.batch) : await sqlite.execute({ sql: String(body.sql), args: body.args || [] });\n return c.json(Array.isArray(r) ? r.map((x: any) => ({ rows: x.rows, n: x.rowsAffected })) : { rows: r.rows, n: r.rowsAffected });\n } catch (e) { return c.json({ error: String((e as any)?.message || e), stack: String((e as any)?.stack || \"\").slice(0, 500) }, 500); }\n});\n\napp.notFound((c) => c.text(\"Not found\", 404));\n\nexport default app.fetch;\n","// 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, inparsTask } from \"./inpars.ts\";\nimport { listBrokers, loginByPin, syncBrokers, type User } from \"./auth.ts\";\nimport { migratePush, saveSub, dropSub, subsFor, notifyBroker, vapidPublic } from \"./push.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(); await migratePush(); 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(\"/app2.js\", (c) => serveFile(\"/frontend/app2.js\", import.meta.url));\napp.get(\"/sw.js\", async (c) => c.body(await readFile(\"/frontend/sw.js\", import.meta.url), 200, { \"Content-Type\": \"application/javascript; charset=utf-8\", \"Service-Worker-Allowed\": \"/\", \"Cache-Control\": \"no-store\" }));\nconst ICON_PNG = Uint8Array.from(atob(\"iVBORw0KGgoAAAANSUhEUgAAAMAAAADACAYAAABS3GwHAAAICklEQVR42u3da4xU5R3H8d85M8xZ052FSnYHEYSVgviKyyJW1MV7DE2UaIXQbeOKVClivVGIaWk20WiMBjXxmprUG0VL0QgGL6VQFoRuEUFb2AtoUWTZ2V3EKLvM7OzM9k0boxGB3ecc55zn+3nvw5w5/+88z1nY0VGRKk+N7BMioyO93ynG1+Uw7LA5Coehh80xOAw9bI7BYfBhcwgOgw+bQ3AYfNgcgsvwIyz8mC2X4YfNETgMPmw+ErkMP2zeDVyGHzZH4DL8sDkCl+GHzRG4DD9sjsBl+GFzBC7DD5sjcBl+2ByBy1sFm7mmSgLCuAu4DD9sjsBl+GFzBDwDgGcAPv1h6y7ADgB2AD79YesuwA4AdgA+/WHrLsAOAHYAwPoAOP7AxmMQOwDYAQCrA+D4A1uPQewAYAcACAAgAMAuDg/AYAcACAAgAIAAAAIALBCPyoW88MenNL16mtE1F962WKtffzOwa5gz+xo9cF+d0TXXvrlO82+5k0lnBwAIACAAgAAAAgABAAQAEABAAAABAAQAEABAAAABAAQAEABAAAABAAQAEABAAAABAAQAEABAAAABAAQAEABAAAABAAQAEABAAAABAAQAEABAAAABAAQAEABAAAABAAQAEABAAAABAAQAEABgXwD5Qt74mo7jBHoNjmP+duTzvUy5DQH09PQYXzMejwd6DYnEIONrZrM9TLkNAfhxoz0vEeg1DBrkRwBZptyOAMzf6GQyGeg1lJUlQ/HBQABFqKury/iag8vKAr0GP/68rq5uptyGANo7Dhlfc9iwikCv4bTTUj68Lx1MuQ0BpNPtxtcccfrwQK/Bjz8vnSYAKwJo8yGAsT86M7gb4bo6s3K0D+9Lmim3IYADB1qNrzl06KlKpcoDef2VlaN0yikl5t+X1jam3IYAPv7kU2Uy5n8SdO45VYG8/h9PnWJ8zUOfHVZHRydTbkMAhUJBzS17jK87vfr8QF7/9OppxtdsbGxmwm0JQJJ2N7YYX/PKKy6V53m+vu6ysqQuuehCH94PArAqgPd2vG98zWSyVNfM/Imvr3vO7GuVSCRC8X4QQBHbWP+OL+veuuAmlZT4swskk6Wa/8ta4+vm8wVt3tLAhNsUQFu6Xc0te42vO2LEcC1ZdJsvr7lu6RINHXqq8XV3vv+BvvjiSybcpgAkaf2Gel/WvfGGn6tmznVG1/zVzXN13bVX+/M+/H0T021jACtfWe3b2vffu1SL7/r1gP+ZdCKRUN3SJbp78e2+vM5CoaBVr6xhum0MYO/ej7T9vZ2+rb9wwTytXf2yZlx5mWKxk3v74rGYZl41Q2+vXaW5tTW+vcb6zVvVepC/ADuhexLFi1q+4i+qmjzRt/XHnzVWTz2+TJ2dh/T2ug16d/tONbfsVevBNh050qVcLqdEYpCSyaROHz5M488apylVE3X5ZRfph0OG+H/9f1rJZJ8gpzw1si9yVcdi2rButUadMdK6G7prd5NmXDVbfX19TLeNRyBJ6s3nteyRJ6y8oQ8ue4zhtz0ASXptzRv6965Gq27mPxre9e2nYAQQMoVCQXf+5nfK5XJW3Mju7qNatOT3TDQBfKWpeY8eevhxK27kPfc9pE/2f8pEE8DXPf2HZ/XWX9dH+hpXvbpGy1fwk5/+iORPgb6ppMTTihefUdWkCZG7tvpNW1Q7b6F6e/kCLHaAY8hkspo771Z98K9dkbquhn9u1/xb7mL4CeD4Dn/+uWb9bK7+tn5jJK7ntTVvqOb6m3XEh6+DsUnsB6WD62y52FyuV6+vfUue56lq0oTAv/vThN58Xg8/+qTq7nlA+XyeCeYZoH+qJk/UsgfvVeXoM0Lzmpua9+iORb/Vrt1NTC4BmHk4vuH6Gs2/qTaQf6PTX52dh/TYk8/oheV/tubvNQggQKWlpbqxtka/qJmlioryonldB1oP6rnnV+i5F1/S0aMZppUAfH4girmaXn2BZv10pi69+ELffxn+23R3H9W69Rv18spX9c6WBhUKBW4MAQTP8zydO7VK1Recp2nnTdW4sWN8+cX1TCarpuY92rK1QfWbtmrb9h0ccwig+MRjMY0ZU6mzx49T5ehRSqUqNCxVrlSqQkMGl6mkpESel5DneYrH48rlcspme5TNZpXJZPXZ4cNqb+9Uur1dbW3t+vA/+9TY1KJ9+z5WPs+nPAGgKG07+9j/z4JzGr8kANg19FGLgf9LJAY8/AP57wgAoR/+MEdAADA6vGGLgABgfGjDFAEBMPyhWpcAEJohDUMEBACrEQAIABx/bD0GEQDYAQACAAgAIACAAAACQGQF9e/3i/33BAgA7AAAAYBjkGXHHwKAb0Malt8RJgAYH9Yw/YI8AcDo0Ibt2yEIAMaGN4xfjUIAMDLEYf1eIEeS+HIsHEuUvxmuI73fiXOLEcVPdo5AAAEABAB8dwAd6f0ObwVs8v+ZZwcAOwBgfQAcg2Db8YcdAOwAvAUgAI5BsPD4ww4AdoDjFQJE9dOfHQDsACdaChC1T392ALADnGwxQFQ+/Y+7AxABojz8J3QEIgJEdfh5BgDPAKZKAsL26X9SOwARIGrDf9JHICJAlIa/X88ARICoDH+/H4KJAFEY/n4HQASIwvAPKAAiQNiHf8ABEAHCPPzS/74c1xS+ZBdhGXxjOwC7AcI6/MYDIAKEafiNH4E4EiEsgx9IAISAYj9NBHpcIQQU2zH6ezuvEwOK4dmxKB5YiYGh/74U7U9siIJhD8J/Ac42ptm6kP63AAAAAElFTkSuQmCC\"), (ch) => ch.charCodeAt(0));\napp.get(\"/icon.png\", (c) => c.body(ICON_PNG, 200, { \"Content-Type\": \"image/png\", \"Cache-Control\": \"public, max-age=86400\" }));\napp.get(\"/manifest.json\", (c) => c.json({ name: \"Unlock · Собственники\", short_name: \"Собственники\", start_url: \"/\", scope: \"/\", display: \"standalone\", background_color: \"#0f1020\", theme_color: \"#0f1020\", icons: [{ src: \"/icon.png\", sizes: \"192x192\", type: \"image/png\" }, { src: \"/icon.png\", sizes: \"512x512\", type: \"image/png\" }] }));\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 // Крон каждую минуту — следующая круглая минута\n const d = new Date(); d.setUTCSeconds(0, 0); d.setUTCMinutes(d.getUTCMinutes() + 1);\n return d.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 WHERE finished_at IS NOT NULL 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 COALESCE(source_created, created, 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 lastData = await sqlite.execute(\"SELECT started_at, inserted, updated FROM runs WHERE inserted>0 ORDER BY id DESC LIMIT 1\");\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 yandexKey: s.yandex_key || Deno.env.get(\"YANDEX_MAPS_KEY\") || \"\",\n zones: (await sqlite.execute(\"SELECT id, name, points, color, created_by, created_by_name FROM zones ORDER BY name\")).rows.map((z: any) => ({ ...z, points: parseJson(z.points, []) })),\n lastRun: last.rows[0] || null,\n lastNew: lastData.rows[0] || null,\n nextRun: nextRunIso(),\n serverTime: nowIso(),\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 = `objects.id, source, url, category, section_id, rooms, sq_land, address, district, metro, floor, floors, sq, cost, cost_m2, images, lat, lng, phones, is_new, is_apartments, build_year,\n source_created, created, first_seen, cost_prev, cost_changed_at, score, status, assignee_id, assignee_name, status_at, recall_at, suspect, phone_req_at, phone_req_status,\n COALESCE(d.c, 1) - 1 AS twins, COALESCE(t.n, 0) AS touches, t.last AS last_touch`;\nconst LIST_JOINS = `LEFT JOIN (SELECT dup_key, COUNT(*) c FROM objects WHERE hidden=0 AND dup_key IS NOT NULL GROUP BY dup_key) d ON d.dup_key=objects.dup_key\n LEFT JOIN (SELECT object_id, COUNT(*) n, MAX(created_at) last FROM activity WHERE kind IN ('status','comment','assign') GROUP BY object_id) t ON t.object_id=objects.id`;\n\napp.get(\"/api/objects\", async (c) => {\n const u = c.get(\"user\");\n const q = c.req.query();\n const where: string[] = [q.gone === \"1\" ? \"hidden=1 AND gone_at IS NOT NULL\" : \"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.assigned === \"1\") where.push(\"assignee_id IS NOT NULL\");\n if (q.section) { const sc = q.section.split(\",\").map(Number).filter((n) => n > 0); if (sc.length) { where.push(`section_id IN (${sc.map(() => \"?\").join(\",\")})`); args.push(...sc); } }\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(\"COALESCE(source_created, created, 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.sqMin) { where.push(\"sq>=?\"); args.push(Number(q.sqMin)); }\n if (q.sqMax) { where.push(\"sq<=?\"); args.push(Number(q.sqMax)); }\n if (q.m2Min) { where.push(\"cost_m2>=?\"); args.push(Number(q.m2Min)); }\n if (q.m2Max) { where.push(\"cost_m2<=?\"); args.push(Number(q.m2Max)); }\n if (q.notFirst === \"1\") where.push(\"(floor IS NULL OR floor>1)\");\n if (q.notLast === \"1\") where.push(\"(floor IS NULL OR floors IS NULL OR floor=?\"); args.push(Number(q.yearMin)); }\n if (q.yearMax) { where.push(\"build_year<=?\"); args.push(Number(q.yearMax)); }\n if (q.hideAgent === \"1\") where.push(\"COALESCE(suspect,0)=0\");\n if (q.cross === \"1\") where.push(\"COALESCE(d.c, 1) > 1\");\n if (q.isNew === \"0\" || q.isNew === \"1\") { where.push(\"is_new=?\"); args.push(Number(q.isNew)); }\n if (q.touched === \"1\") { where.push(\"objects.id IN (SELECT object_id FROM activity WHERE broker_id=? AND kind IN ('comment','status','assign'))\"); args.push(q.broker && u.role === \"boss\" ? Number(q.broker) : u.id); }\n if (q.recallSort === \"1\") where.push(\"recall_at IS NOT NULL\");\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 dom: \"COALESCE(source_created, created, first_seen) ASC\", recall: \"recall_at IS NULL, recall_at ASC\", fresh: \"COALESCE(source_created, created, 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) || 5000, 8000);\n const r = await sqlite.execute({ sql: `SELECT ${LIST_COLS} FROM objects ${LIST_JOINS} 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 st = STATUSES[String(o.status)] || STATUSES.new;\n // первая картинка без разбора всего JSON\n const im = typeof o.images === \"string\" ? o.images.match(/\"([^\"]+)\"/) : null;\n const photos = typeof o.images === \"string\" ? (o.images.match(/\"/g) || []).length / 2 : 0;\n const hasPhone = typeof o.phones === \"string\" && /\\d/.test(o.phones);\n const row: any = {\n id: Number(o.id), source: o.source, url: o.url, category: o.category, section_id: o.section_id, rooms: o.rooms, address: o.address, metro: o.metro,\n floor: o.floor, floors: o.floors, sq: o.sq, cost: o.cost, cost_m2: o.cost_m2, img: im ? im[1] : null, photos,\n lat: o.lat, lng: o.lng, hasPhone, status: o.status, source_created: o.source_created, created: o.created, first_seen: o.first_seen, score: o.score,\n flags: { crossListed: Number(o.twins || 0), agentWords: !!o.suspect, phoneMulti: 0 },\n };\n if (o.sq_land) row.sq_land = o.sq_land; if (o.district) row.district = o.district;\n if (o.is_new) row.is_new = 1; if (o.is_apartments) row.is_apartments = 1; if (o.build_year) row.build_year = o.build_year;\n if (o.cost_prev) { row.cost_prev = o.cost_prev; row.cost_changed_at = o.cost_changed_at; }\n if (o.assignee_id) { row.assignee_id = o.assignee_id; row.assignee_name = o.assignee_name; }\n if (o.status_at) row.status_at = o.status_at; if (o.recall_at) row.recall_at = o.recall_at;\n if (o.phone_req_at) { row.phone_req_at = o.phone_req_at; row.phone_req_status = o.phone_req_status; }\n if (o.touches) { row.touches = Number(o.touches); row.last_touch = o.last_touch; }\n if (st.hidePhone && u.role !== \"boss\") row.hidePhone = true;\n return row;\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 // Сравнение с рынком: средняя цена метра по таким же объектам (метро + комнатность), иначе по району\n let market: any = null;\n if (o.cost_m2 && o.section_id === 1) {\n const tryScope = async (label: string, sql: string, args: any[]) => { const r = await sqlite.execute({ sql, args }); const row = r.rows[0] as any; return row && Number(row.n) >= 4 ? { scope: label, avg: Math.round(Number(row.avg)), n: Number(row.n) } : null; };\n if (o.metro) market = await tryScope(`м. ${o.metro}${o.rooms ? \", \" + (o.rooms >= 4 ? \"4+\" : o.rooms) + \"-к\" : \"\"}`, \"SELECT AVG(cost_m2) avg, COUNT(*) n FROM objects WHERE hidden=0 AND section_id=1 AND cost_m2>0 AND metro=? AND (rooms=? OR (?>=4 AND rooms>=4)) AND id!=?\", [o.metro, o.rooms, o.rooms, id]);\n if (!market && o.metro) market = await tryScope(`м. ${o.metro}`, \"SELECT AVG(cost_m2) avg, COUNT(*) n FROM objects WHERE hidden=0 AND section_id=1 AND cost_m2>0 AND metro=? AND id!=?\", [o.metro, id]);\n if (!market && o.district) market = await tryScope(o.district, \"SELECT AVG(cost_m2) avg, COUNT(*) n FROM objects WHERE hidden=0 AND section_id=1 AND cost_m2>0 AND district=? AND id!=?\", [o.district, id]);\n }\n let comps: any[] = [];\n if (o.section_id === 1 && o.metro) {\n const cr = await sqlite.execute({ sql: \"SELECT id, cost, sq, cost_m2, address, status, rooms, floor, floors FROM objects WHERE hidden=0 AND dup_of IS NULL AND section_id=1 AND metro=? AND (rooms=? OR (?>=4 AND rooms>=4)) AND id!=? ORDER BY ABS(COALESCE(sq,0)-?) LIMIT 5\", args: [o.metro, o.rooms, o.rooms, id, o.sq || 0] });\n comps = cr.rows;\n }\n return c.json({\n ...o,\n market, comps,\n images: parseJson(o.images, []),\n phones: hide ? [] : parseJson(o.phones, []),\n hidePhone: hide,\n flags: { ...parseJson(o.flags, {}), crossListed: sib.rows.length },\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\" || status === \"meeting\") && 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=?, recall_notified=0, 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\" || Number((await sqlite.execute({ sql: \"SELECT assignee_id FROM objects WHERE id=?\", args: [id] })).rows[0]?.assignee_id) === u.id)) {\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 if (toId && toId !== u.id) { const o = (await sqlite.execute({ sql: \"SELECT cost, address, title FROM objects WHERE id=?\", args: [id] })).rows[0] as any; notifyBroker(toId, { title: `${u.name} передал тебе объект`, body: `${(Number(o.cost) / 1e6).toFixed(1).replace(\".0\", \"\")} млн · ${o.title || o.address}`, url: `/?o=${id}`, tag: \"assign-\" + id }).catch(() => {}); }\n return c.json({ ok: true, assignee_id: toId, assignee_name: toName, status: newStatus });\n});\n\n// Запрос номера: просим Inpars перечитать объявление; телефон придёт с ближайшим сбором\napp.post(\"/api/objects/:id/phone\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const r = await sqlite.execute({ sql: \"SELECT url, source, phone_req_at, phones 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 if (!/avito\\.ru|cian\\.ru|youla\\.io|domclick\\.ru/.test(String(o.url))) return c.json({ error: \"Для этой площадки Inpars не делает повторный разбор\" }, 400);\n if (o.phone_req_at && Date.now() - new Date(String(o.phone_req_at)).getTime() < 24 * 3600000) return c.json({ ok: true, status: String(o.phone_req_status || \"inprogress\"), at: o.phone_req_at, repeat: true });\n try {\n const j = await inparsTask([String(o.url)], Deno.env.get(\"INPARS_TOKEN\") || \"\");\n const t = (j.data || [])[0] || {};\n const now = nowIso();\n await sqlite.batch([\n { sql: \"UPDATE objects SET phone_req_at=?, phone_req_status=? WHERE id=?\", args: [now, String(t.status || \"created\"), id] },\n { sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, created_at) VALUES(?,?,?,?,?,?)\", args: [id, \"system\", u.id, u.name, `Запрошен телефон у Inpars (${u.name})`, now] },\n ]);\n return c.json({ ok: true, status: String(t.status || \"created\"), message: t.message, at: now, remaining: j.meta?.updateRemaining, limit: j.meta?.updateLimit });\n } catch (e) { return c.json({ error: String((e as Error).message) }, 502); }\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// Пульс для интерфейса: есть ли новое с момента since (объекты или действия команды)\nlet lazySyncing = false;\n// Ленивый сбор: пока кто-то из команды держит приложение открытым, пульс раз в 30 с\n// сам запускает сбор, если прошлому больше 55 секунд. Крон — страховка, когда никто не смотрит.\nasync function lazySync() {\n if (lazySyncing) return;\n const r = await sqlite.execute(\"SELECT started_at, finished_at FROM runs ORDER BY id DESC LIMIT 1\");\n const last = r.rows[0] as any;\n if (last) {\n const startedAgo = Date.now() - new Date(String(last.started_at)).getTime();\n if (!last.finished_at && startedAgo < 90_000) return; // другой запуск ещё идёт\n if (last.finished_at && startedAgo < 55_000) return;\n }\n lazySyncing = true;\n try { await sync(\"pulse\"); } catch (e) { console.warn(\"lazy sync:\", e); } finally { lazySyncing = false; }\n}\n\napp.get(\"/api/pulse\", async (c) => {\n await lazySync();\n const since = String(c.req.query(\"since\") || \"\");\n if (!since) return c.json({ objects: 0, activity: 0, now: nowIso() });\n const [o, a, ch] = await Promise.all([\n sqlite.execute({ sql: \"SELECT COUNT(*) n FROM objects WHERE hidden=0 AND dup_of IS NULL AND first_seen > ?\", args: [since] }),\n sqlite.execute({ sql: \"SELECT COUNT(*) n FROM activity WHERE created_at > ?\", args: [since] }),\n sqlite.execute({ sql: \"SELECT COUNT(*) n FROM objects WHERE status_at > ? OR cost_changed_at > ?\", args: [since, since] }),\n ]);\n return c.json({ objects: Number((o.rows[0] as any).n), activity: Number((a.rows[0] as any).n), changed: Number((ch.rows[0] as any).n), now: nowIso() });\n});\n\n// Зоны на карте — сохранённые полигоны, общие для команды\napp.get(\"/api/zones\", async (c) => {\n const r = await sqlite.execute(\"SELECT id, name, points, color, created_by, created_by_name FROM zones ORDER BY name\");\n return c.json({ items: (r.rows as any[]).map((z) => ({ ...z, points: parseJson(z.points, []) })) });\n});\napp.post(\"/api/zones\", async (c) => {\n const u = c.get(\"user\");\n const b = await c.req.json().catch(() => ({}));\n const pts = Array.isArray(b.points) ? b.points.filter((p: any) => Array.isArray(p) && p.length === 2 && isFinite(p[0]) && isFinite(p[1])).map((p: any) => [Number(p[0]), Number(p[1])]) : [];\n const name = String(b.name || \"\").trim().slice(0, 60);\n if (pts.length < 3 || !name) return c.json({ error: \"Нужно имя и минимум 3 точки\" }, 400);\n const r = await sqlite.execute({ sql: \"INSERT INTO zones(name, points, color, created_by, created_by_name, created_at) VALUES(?,?,?,?,?,?)\", args: [name, JSON.stringify(pts), String(b.color || \"#5b5bd6\"), u.id, u.name, nowIso()] });\n return c.json({ id: Number(r.lastInsertRowid), name, points: pts, color: String(b.color || \"#5b5bd6\"), created_by: u.id, created_by_name: u.name });\n});\napp.delete(\"/api/zones/:id\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const z = await sqlite.execute({ sql: \"SELECT created_by FROM zones WHERE id=?\", args: [id] });\n if (!z.rows.length) return c.json({ error: \"not found\" }, 404);\n if (u.role !== \"boss\" && Number((z.rows[0] as any).created_by) !== u.id) return c.json({ error: \"Зону может удалить автор или руководитель\" }, 403);\n await sqlite.execute({ sql: \"DELETE FROM zones WHERE id=?\", args: [id] });\n return c.json({ ok: true });\n});\n\n// Push-уведомления\napp.get(\"/api/push\", async (c) => { const u = c.get(\"user\"); return c.json({ key: vapidPublic(), subs: await subsFor(u.id) }); });\napp.post(\"/api/push\", async (c) => {\n const u = c.get(\"user\");\n const b = await c.req.json().catch(() => ({}));\n if (!b.sub || !b.sub.endpoint) return c.json({ error: \"no subscription\" }, 400);\n await saveSub(u.id, u.name, b.sub, (b.zones || []).map(Number), !!b.all_new);\n return c.json({ ok: true });\n});\napp.delete(\"/api/push\", async (c) => { const b = await c.req.json().catch(() => ({})); if (b.endpoint) await dropSub(String(b.endpoint)); return c.json({ ok: true }); });\napp.post(\"/api/push/test\", async (c) => { const u = c.get(\"user\"); const n = await notifyBroker(u.id, { title: \"Уведомления включены\", body: \"Так будут приходить новые собственники и напоминания\", url: \"/\" }); return c.json({ sent: n }); });\n\n// Удалить свой комментарий (руководитель — любой)\napp.delete(\"/api/activity/: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 broker_id, kind FROM activity WHERE id=?\", args: [id] });\n if (!r.rows.length) return c.json({ error: \"not found\" }, 404);\n const a = r.rows[0] as any;\n if (a.kind !== \"comment\") return c.json({ error: \"Удалять можно только комментарии\" }, 400);\n if (u.role !== \"boss\" && Number(a.broker_id) !== u.id) return c.json({ error: \"Это не твой комментарий\" }, 403);\n await sqlite.execute({ sql: \"DELETE FROM activity WHERE id=?\", args: [id] });\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 WHERE a.kind != 'system' 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 now = Math.floor(Date.now() / 1000);\n const r = await sync(\"manual\", body.days ? { sinceOverride: now - Number(body.days) * 86400, untilOverride: body.until_days ? now - Number(body.until_days) * 86400 : undefined } : {});\n return c.json(r);\n});\n\napp.get(\"/api/runs\", boss, async (c) => {\n const r = await sqlite.execute(\"SELECT * FROM runs WHERE fetched>0 OR error IS NOT NULL ORDER BY id DESC LIMIT 40\");\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/export.csv\", boss, async (c) => {\n const r = await sqlite.execute(`SELECT id, source, url, category, rooms, sq, sq_land, floor, floors, cost, cost_m2, address, district, metro, phones, status, assignee_name, status_at, recall_at, source_created, first_seen, cost_prev, build_year FROM objects WHERE hidden=0 AND dup_of IS NULL ORDER BY COALESCE(source_created, created, first_seen) DESC`);\n const cols = [\"id\", \"source\", \"url\", \"category\", \"rooms\", \"sq\", \"sq_land\", \"floor\", \"floors\", \"cost\", \"cost_m2\", \"address\", \"district\", \"metro\", \"phones\", \"status\", \"assignee_name\", \"status_at\", \"recall_at\", \"source_created\", \"first_seen\", \"cost_prev\", \"build_year\"];\n const esc = (v: any) => { const s = v == null ? \"\" : String(v); return /[\";\\n]/.test(s) ? '\"' + s.replace(/\"/g, '\"\"') + '\"' : s; };\n const lines = [cols.join(\";\"), ...(r.rows as any[]).map((row) => cols.map((k) => esc(k === \"phones\" ? parseJson(row[k], []).join(\" \") : row[k])).join(\";\"))];\n return new Response(\"\\ufeff\" + lines.join(\"\\n\"), { headers: { \"Content-Type\": \"text/csv; charset=utf-8\", \"Content-Disposition\": `attachment; filename=\"sobstvenniki_${new Date().toISOString().slice(0, 10)}.csv\"` } });\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\n// Отладка (только руководитель): выполнить SQL в базе парсера\napp.post(\"/api/debug/sql\", boss, async (c) => {\n const body = await c.req.json().catch(() => ({}));\n try {\n const r = body.batch ? await sqlite.batch(body.batch) : await sqlite.execute({ sql: String(body.sql), args: body.args || [] });\n return c.json(Array.isArray(r) ? r.map((x: any) => ({ rows: x.rows, n: x.rowsAffected })) : { rows: r.rows, n: r.rowsAffected });\n } catch (e) { return c.json({ error: String((e as any)?.message || e), stack: String((e as any)?.stack || \"\").slice(0, 500) }, 500); }\n});\n\napp.notFound((c) => c.text(\"Not found\", 404));\n\nexport default app.fetch;\n","createdAt",["D",1789403967921],"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",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":56,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_44":43,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":46,"_98":99},"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",{"_44":45,"_32":46,"_39":271,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":31,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":272,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":273,"_84":274,"_86":275,"_88":25},"tree",[160,167],"files",[160,161,162,163,164,165,166,167,168,169,170,171,172],"counts",{"_149":63,"_150":146,"_151":63,"_152":153,"_154":155},"contents",[131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":143,"_32":144,"_30":145,"_136":-5,"_42":43,"_41":146,"_138":59,"_39":147,"_13":63,"_34":140,"_36":-5,"_24":25,"_141":-5,"_27":148},{"_44":133,"_32":134,"_30":135,"_136":-5,"_42":43,"_41":137,"_138":59,"_39":139,"_13":63,"_34":140,"_36":-5,"_24":25,"_141":-5,"_27":142},"8618f630-060d-44e1-976f-8f3f90ea873a","frontend","472f4334-eddb-49ac-88ea-7505a2ba216d","parentId",6,"latest",["D",1789373202685],"directory","label",[134],"7341a1cc-7dfc-4e42-b726-1f50a9135807","backend","2d175de9-e314-46bc-b472-7c5eb74535c8",1,["D",1789373200842],[144],"pulls","branches","forks","envVars",{"_156":158,"_159":63},"connections",{"_156":63,"_157":63},"count","unfilledCount",3,"emptyCount",{"_44":143,"_32":144,"_30":145,"_136":-5,"_42":43,"_41":146,"_138":59,"_39":268,"_13":63,"_34":140,"_36":-5,"_24":25,"_141":-5,"_179":269,"_27":270},{"_44":261,"_32":262,"_30":263,"_136":145,"_42":43,"_41":196,"_138":59,"_39":264,"_13":63,"_34":226,"_36":265,"_24":25,"_141":-5,"_179":266,"_27":267},{"_44":252,"_32":253,"_30":254,"_136":145,"_42":43,"_41":255,"_138":59,"_39":256,"_13":196,"_34":257,"_36":258,"_24":25,"_141":-5,"_179":259,"_27":260},{"_44":243,"_32":244,"_30":245,"_136":145,"_42":43,"_41":246,"_138":59,"_39":247,"_13":248,"_34":226,"_36":249,"_24":25,"_141":-5,"_179":250,"_27":251},{"_44":238,"_32":33,"_30":31,"_136":145,"_42":43,"_41":14,"_138":25,"_39":239,"_13":240,"_34":35,"_36":38,"_24":25,"_141":-5,"_179":241,"_27":242},{"_44":230,"_32":231,"_30":232,"_136":145,"_42":43,"_41":233,"_138":59,"_39":234,"_13":214,"_34":226,"_36":235,"_24":25,"_141":-5,"_179":236,"_27":237},{"_44":221,"_32":222,"_30":223,"_136":145,"_42":43,"_41":224,"_138":59,"_39":225,"_13":63,"_34":226,"_36":227,"_24":25,"_141":-5,"_179":228,"_27":229},{"_44":133,"_32":134,"_30":135,"_136":-5,"_42":43,"_41":137,"_138":59,"_39":218,"_13":63,"_34":140,"_36":-5,"_24":25,"_141":-5,"_179":219,"_27":220},{"_44":209,"_32":210,"_30":211,"_136":135,"_42":43,"_41":212,"_138":25,"_39":213,"_13":214,"_34":20,"_36":215,"_24":25,"_141":-5,"_179":216,"_27":217},{"_44":200,"_32":201,"_30":202,"_136":135,"_42":43,"_41":203,"_138":25,"_39":204,"_13":205,"_34":20,"_36":206,"_24":25,"_141":-5,"_179":207,"_27":208},{"_44":191,"_32":192,"_30":193,"_136":135,"_42":43,"_41":194,"_138":25,"_39":195,"_13":196,"_34":20,"_36":197,"_24":25,"_141":-5,"_179":198,"_27":199},{"_44":182,"_32":183,"_30":184,"_136":135,"_42":43,"_41":185,"_138":25,"_39":186,"_13":187,"_34":20,"_36":188,"_24":25,"_141":-5,"_179":189,"_27":190},{"_44":173,"_32":174,"_30":175,"_136":135,"_42":43,"_41":176,"_138":59,"_39":177,"_13":63,"_34":20,"_36":178,"_24":25,"_141":-5,"_179":180,"_27":181},"7b69cff7-cdfe-4d59-b916-066f9001b503","sw.js","197ed63c-b057-11f1-912a-1607ee4eb77e",71,["D",1789402356142],"/* Service worker: показ push-уведомлений и переход в приложение по клику */\nself.addEventListener(\"install\", () => self.skipWaiting());\nself.addEventListener(\"activate\", (e) => e.waitUntil(self.clients.claim()));\nself.addEventListener(\"push\", (e) => {\n let d = {}; try { d = e.data ? e.data.json() : {}; } catch { d = { title: \"Собственники\", body: e.data ? e.data.text() : \"\" }; }\n e.waitUntil(self.registration.showNotification(d.title || \"Собственники\", { body: d.body || \"\", tag: d.tag, data: { url: d.url || \"/\" }, icon: \"/icon.png\", badge: \"/icon.png\", renotify: !!d.tag }));\n});\nself.addEventListener(\"notificationclick\", (e) => {\n e.notification.close();\n const url = new URL(e.notification.data?.url || \"/\", self.location.origin).href;\n e.waitUntil(self.clients.matchAll({ type: \"window\", includeUncontrolled: true }).then((cs) => {\n for (const c of cs) if (\"focus\" in c) { c.navigate(url); return c.focus(); }\n return self.clients.openWindow(url);\n }));\n});\n","children",[],[134,174],"a12158d4-37c5-4ea6-b3bb-99cb86b9a506","index.html","38ae9b58-b013-11f1-9622-1607ee4eb77e",74,["D",1789403324216],8,"\n\n\n \n \n \n \n \n \n \n Unlock · Собственники\n \n \n \n \n \n \n \n\n\n \n

Собственники

Объекты от собственников с ЦИАН, Авито, Яндекса и Домклика — обновляются каждую минуту.

\n \n

\n \n Тот же ПИН-код, что и в «Воронке дня»\n

\n\n \n

\n\n

U.Собственники

\n \n \n \n \n

\n \n \n

\n\n \n\n \n

\n \n \n

\n \n \n \n \n \n \n \n

\n \n \n \n \n \n \n

Автопереход

\n\n \n

\n \n \n

Зажми кнопку мыши (или палец) и обведи зону — как маркером

\n\n\n \n

\n \n

\n \n \n

←Выбери объект в списке
или нажми «Начать обзвон»

\n\n

Фильтры

\n \n \n

\n\n \n \n \n\n\n",[],[134,183],"d421eb65-e59a-4059-b07f-5cd06ed2a7d1","app2.js","2213c76e-b046-11f1-8f8c-1607ee4eb77e",77,["D",1789403325485],2,"/* Unlock · Собственники — фильтр-панель, галерея, удаление комментариев */\n\n/* ---------- фильтры ---------- */\nfunction openFilters() { renderFilters(); $(\"#fdrawer\").classList.remove(\"hidden\"); }\nfunction closeFilters() { $(\"#fdrawer\").classList.add(\"hidden\"); }\nfunction fSet(k, v) { F[k] = v; reload(); renderFilters(); }\nfunction fTog(k) { F[k] = !F[k]; reload(); renderFilters(); }\nfunction fSetToggle(set, v) { if (set.has(v)) set.delete(v); else set.add(v); reload(); renderFilters(); }\nfunction fBroker(v) { F.broker = F.broker === v ? null : v; reload(); renderFilters(); }\nfunction fRange(k, el) { F[k] = el.value.trim(); clearTimeout(fRange._t); fRange._t = setTimeout(() => { reload(); $(\"#fcount\").textContent = countTxt(); }, 350); }\nconst countTxt = () => `${ITEMS.length} объект${plural(ITEMS.length)}`;\nfunction chips(items, isOn, onclick) { return `

${items.map(([v, label, color]) => ``).join(\"\")}

`; }\nfunction range(kMin, kMax, ph1, ph2, unit) { return `

—${unit}

`; }\nfunction tog(k, label, hint) { return `

${label}${hint ? `
${hint}` : \"\"}

`; }\nfunction renderFilters() {\n const pricePresets = [[\"\", \"\", \"Любая\"], [\"30\", \"50\", \"30–50 млн\"], [\"50\", \"100\", \"50–100\"], [\"100\", \"\", \"100+\"]];\n $(\"#fbody\").innerHTML = `\n

Цена, млн ₽\n

${pricePresets.map(([a, b, l]) => ``).join(\"\")}

\n ${range(\"costMin\", \"costMax\", \"от\", \"до\", \"млн\")}

Тип объекта${chips([[\"1\", \"Квартиры\"], [\"5\", \"Дома и участки\"], [\"4\", \"Коммерция\"]], (v) => F.section.has(v), (v) => `fSetToggle(F.section,'${v}')`)}

Комнат${chips([[\"0\", \"Студия\"], [\"1\", \"1\"], [\"2\", \"2\"], [\"3\", \"3\"], [\"4\", \"4+\"]], (v) => F.rooms.has(v), (v) => `fSetToggle(F.rooms,'${v}')`)}

Площадь, м²${range(\"sqMin\", \"sqMax\", \"от\", \"до\", \"м²\")}

Цена за метр, тыс. ₽${range(\"m2Min\", \"m2Max\", \"от\", \"до\", \"т.₽/м²\")}

Жильё${chips([[\"\", \"Любое\"], [\"0\", \"Вторичка\"], [\"1\", \"Новостройка\"]], (v) => F.isNew === v, (v) => `fSet('isNew','${v}')`)}

Год дома${range(\"yearMin\", \"yearMax\", \"от\", \"до\", \"\")}

Свежесть публикации${chips([[\"\", \"Все\"], [\"24\", \"Сутки\"], [\"72\", \"3 дня\"], [\"168\", \"Неделя\"], [\"720\", \"Месяц\"]], (v) => F.fresh === v, (v) => `fSet('fresh','${v}')`)}

Источник${chips([[\"cian.ru\", \"ЦИАН\"], [\"avito.ru\", \"Авито\"], [\"realty.yandex.ru\", \"Яндекс\"], [\"domclick.ru\", \"Домклик\"], [\"youla.io\", \"Юла\"]], (v) => F.source.has(v), (v) => `fSetToggle(F.source,'${v}')`)}

Статус${chips(Object.entries(BOOT.statuses).map(([k, v]) => [k, v.label, v.color]), (v) => F.status.has(v), (v) => `fSetToggle(F.status,'${v}')`)}

Брокер${chips(BOOT.brokers.map((b) => [b.id, b.name.split(\" \")[0]]), (v) => F.broker === v, (v) => `fBroker(${v})`)}

\n ${tog(\"phone\", \"Только с телефоном\")}\n ${tog(\"unassigned\", \"Никем не взяты\")}\n ${tog(\"hideAgent\", \"Скрыть похожих на агентов\", \"агентские обороты в тексте или телефон в 3+ объявлениях\")}\n ${tog(\"cross\", \"Только на нескольких площадках\", \"продавец разместился и на ЦИАН, и на Авито — серьёзнее настроен\")}\n ${tog(\"drop\", \"Только со снижением цены\")}\n ${tog(\"notFirst\", \"Не первый этаж\")}\n ${tog(\"notLast\", \"Не последний этаж\")}\n

`;\n $(\"#fcount\").textContent = countTxt();\n}\n\n/* ---------- галерея ---------- */\nfunction galScroll(dir) { const g = $(\"#gal\"); if (!g) return; const w = g.querySelector(\"img\")?.clientWidth || 300; g.scrollBy({ left: dir * (w + 6), behavior: \"smooth\" }); }\nlet LB = { i: 0, imgs: [] };\nfunction openLightbox(i) {\n if (!CUR || !CUR.images.length) return;\n LB.imgs = CUR.images; LB.i = i;\n $(\"#lbThumbs\").innerHTML = LB.imgs.map((u, k) => `

`).join(\"\");\n $(\"#lightbox\").classList.remove(\"hidden\");\n lbGo(i);\n}\nfunction lbGo(i) {\n LB.i = (i + LB.imgs.length) % LB.imgs.length;\n $(\"#lbImg\").src = LB.imgs[LB.i];\n $$(\"#lbThumbs img\").forEach((im, k) => { im.classList.toggle(\"on\", k === LB.i); if (k === LB.i) im.scrollIntoView({ inline: \"center\", block: \"nearest\", behavior: \"smooth\" }); });\n}\nfunction lbNav(d) { lbGo(LB.i + d); }\nfunction closeLightbox() { $(\"#lightbox\").classList.add(\"hidden\"); }\ndocument.addEventListener(\"keydown\", (e) => {\n if ($(\"#lightbox\").classList.contains(\"hidden\")) return;\n if (e.key === \"ArrowRight\") { lbNav(1); e.stopImmediatePropagation(); }\n if (e.key === \"ArrowLeft\") { lbNav(-1); e.stopImmediatePropagation(); }\n if (e.key === \"Escape\") { closeLightbox(); e.stopImmediatePropagation(); }\n}, true);\n// свайп в лайтбоксе\n(function () { let x0 = null; const lb = $(\"#lightbox\"); lb.addEventListener(\"touchstart\", (e) => { x0 = e.touches[0].clientX; }, { passive: true }); lb.addEventListener(\"touchend\", (e) => { if (x0 == null) return; const dx = e.changedTouches[0].clientX - x0; if (Math.abs(dx) > 40) lbNav(dx < 0 ? 1 : -1); x0 = null; }); })();\n\n/* ---------- комментарии ---------- */\nasync function delComment(id) {\n if (!confirm(\"Удалить комментарий?\")) return;\n try { await api(\"/api/activity/\" + id, { method: \"DELETE\" }); await openObject(CUR.id, true); toast(\"Удалено\"); } catch (e) { toast(e.message); }\n}\n\n\n/* ---------- сохранённые поиски (как saved search в MLS) ---------- */\nfunction savedList() { try { return JSON.parse(localStorage.getItem(\"uo_saved_\" + (USER && USER.id)) || \"[]\"); } catch { return []; } }\nfunction savedWrite(l) { localStorage.setItem(\"uo_saved_\" + USER.id, JSON.stringify(l)); renderSaved(); }\nfunction saveSearch() {\n const name = prompt(\"Название поиска (например «3-к Хамовники до 80»)\"); if (!name) return;\n const snap = { name, quick: QUICK, sort: $(\"#sort\").value, q: $(\"#q\").value, F: { ...F, status: [...F.status], rooms: [...F.rooms], source: [...F.source], section: [...F.section], zones: [...F.zones] } };\n savedWrite([...savedList().filter((x) => x.name !== name), snap]); toast(\"Поиск сохранён\");\n}\nfunction applySaved(i) {\n const sv = savedList()[i]; if (!sv) return;\n Object.assign(F, sv.F, { status: new Set(sv.F.status), rooms: new Set(sv.F.rooms), source: new Set(sv.F.source), section: new Set(sv.F.section), zones: new Set(sv.F.zones) });\n QUICK = sv.quick; $(\"#sort\").value = sv.sort; $(\"#q\").value = sv.q || \"\"; markQuick(); renderZoneBar(); reload(); renderSaved(); if (MODE === \"map\") togglePanel(true);\n}\nfunction delSaved(i, e) { e.stopPropagation(); const l = savedList(); l.splice(i, 1); savedWrite(l); }\nfunction renderSaved() { $(\"#savedBar\").innerHTML = savedList().map((x, i) => ``).join(\"\"); }\n\n/* ---------- push-уведомления ---------- */\nlet PUSH = { key: \"\", subs: [], reg: null };\nasync function initPush() {\n if (!(\"serviceWorker\" in navigator) || !(\"PushManager\" in window)) return;\n try { PUSH.reg = await navigator.serviceWorker.register(\"/sw.js\"); } catch {}\n try { const j = await api(\"/api/push\"); PUSH.key = j.key; PUSH.subs = j.subs || []; } catch {}\n const sub = PUSH.reg && await PUSH.reg.pushManager.getSubscription();\n $(\"#bellBtn\").classList.toggle(\"on\", !!sub && PUSH.subs.length > 0);\n}\nfunction b64ToU8(b) { const p = \"=\".repeat((4 - b.length % 4) % 4); const s = (b + p).replace(/-/g, \"+\").replace(/_/g, \"/\"); const r = atob(s); return Uint8Array.from([...r].map((c) => c.charCodeAt(0))); }\nasync function openPush() {\n if (!(\"PushManager\" in window)) return toast(\"Этот браузер не умеет уведомления. На iPhone — добавь приложение на экран «Домой»\");\n const sub = PUSH.reg && await PUSH.reg.pushManager.getSubscription();\n const cur = PUSH.subs[0] || { zones: [], all_new: 0 };\n const zs = BOOT.zones || [];\n openModal(`

Уведомления

Приходят даже при закрытом приложении: новые собственники в выбранных зонах, напоминания «перезвонить» и «встреча» в назначенное время, объекты, которые тебе передали.

\n Все новые объекты по фильтру сбора (много, до 60 в день)\n ${zs.length ? zs.map((z) => ` ${esc(z.name)}`).join(\"\") : `

Зон пока нет — обведи район на карте, и он появится здесь

`}\n

${sub ? `` : \"\"}

`);\n}\nasync function enablePush() {\n try {\n if (!PUSH.reg) PUSH.reg = await navigator.serviceWorker.register(\"/sw.js\");\n const perm = await Notification.requestPermission();\n if (perm !== \"granted\") return toast(\"Браузер не дал разрешение на уведомления\");\n let sub = await PUSH.reg.pushManager.getSubscription();\n if (!sub) sub = await PUSH.reg.pushManager.subscribe({ userVisibleOnly: true, applicationServerKey: b64ToU8(PUSH.key) });\n const zones = $$(\".pz:checked\").map((x) => Number(x.value));\n await api(\"/api/push\", { method: \"POST\", body: JSON.stringify({ sub: sub.toJSON(), zones, all_new: $(\"#pAll\").checked }) });\n closeModal(); toast(\"Уведомления включены\"); initPush();\n } catch (e) { toast(\"Не удалось: \" + e.message); }\n}\nasync function disablePush() {\n const sub = PUSH.reg && await PUSH.reg.pushManager.getSubscription();\n if (sub) { await api(\"/api/push\", { method: \"DELETE\", body: JSON.stringify({ endpoint: sub.endpoint }) }); await sub.unsubscribe(); }\n closeModal(); toast(\"Уведомления выключены\"); initPush();\n}\n\n\n/* ---------- мобильное меню ---------- */\nfunction openMore() {\n const c = BOOT.counts || {};\n openModal(`

${esc(USER.role === \"boss\" ? \"Руководитель\" : USER.name)}

\n За сутки ${c.fresh24h ?? 0}\n Не прозвонено ${(c.byStatus || {}).new || 0}\n Мои ${c.mine ?? 0}\n ${c.recallDue ? `Перезвонить ${c.recallDue}` : \"\"}\n

\n \n \n ${USER.role === \"boss\" ? `` : \"\"}\n \n \n

${$(\"#syncInfo\").textContent}

`);\n}\n",[],[134,192],"2c7d673d-4159-4360-a57c-51cffb34aae8","app.js","393c694c-b013-11f1-acaf-1607ee4eb77e",76,["D",1789403325108],13,"/* Unlock · Собственники — фронтенд v2 (полноэкранная карта, Яндекс.Карты, зоны) */\nconst $ = (s, r = document) => r.querySelector(s);\nconst $$ = (s, r = document) => [...r.querySelectorAll(s)];\nlet PIN = \"\", USER = null, BOOT = null, ITEMS = [], ALL = [], SEL = null, QUICK = \"all\", CUR = null;\nconst F = { status: new Set(), rooms: new Set(), source: new Set(), section: new Set(), broker: null, zones: new Set(), costMin: \"\", costMax: \"\", sqMin: \"\", sqMax: \"\", m2Min: \"\", m2Max: \"\", yearMin: \"\", yearMax: \"\", fresh: \"\", isNew: \"\", phone: false, unassigned: false, notFirst: false, notLast: false, hideAgent: true, cross: false, drop: false };\nlet MY_BROKER = null;\nlet FOCUS = null; // объекты выбранного кластера на карте\nlet MODE = localStorage.getItem(\"uo_mode\") || \"map\", PANEL_OPEN = false;\nlet listRendered = 0, searchT = null, LAST_PULSE = null, PULSING = false;\n\n/* ---------- утилиты ---------- */\nconst fmtMln = (v) => { if (!v) return \"—\"; const m = v / 1e6; return (m >= 100 ? m.toFixed(0) : m.toFixed(1)).replace(\".0\", \"\").replace(\".\", \",\") + \" млн\"; };\nconst fmtM2 = (v) => v ? Math.round(v / 1000).toLocaleString(\"ru-RU\") + \" т.₽/м²\" : \"\";\nconst fmtPhone = (p) => { const s = String(p); return s.length === 11 ? `+${s[0]} ${s.slice(1, 4)} ${s.slice(4, 7)}-${s.slice(7, 9)}-${s.slice(9)}` : \"+\" + s; };\nconst esc = (s) => String(s ?? \"\").replace(/[&<>\"']/g, (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\", \"'\": \"'\" }[c]));\nconst initials = (n) => (n || \"?\").split(\" \").map((w) => w[0]).slice(0, 2).join(\"\").toUpperCase();\nconst srcCls = (s) => ({ \"cian.ru\": \"cian\", \"avito.ru\": \"avito\", \"realty.yandex.ru\": \"yandex\", \"domclick.ru\": \"domclick\", \"youla.io\": \"youla\" }[s] || \"\");\nconst srcName = (s) => ({ \"cian.ru\": \"ЦИАН\", \"avito.ru\": \"Авито\", \"realty.yandex.ru\": \"Яндекс\", \"domclick.ru\": \"Домклик\", \"youla.io\": \"Юла\", \"sob.ru\": \"Sob\" }[s] || s);\nfunction ago(iso) {\n if (!iso) return \"\";\n const d = (Date.now() - new Date(iso).getTime()) / 60000;\n if (d < 1) return \"только что\";\n if (d < 60) return Math.round(d) + \" мин\";\n if (d < 24 * 60) return Math.round(d / 60) + \" ч\";\n if (d < 48 * 60) return \"вчера\";\n return Math.round(d / 1440) + \" дн\";\n}\nconst fmtDT = (iso) => iso ? new Date(iso).toLocaleString(\"ru-RU\", { timeZone: \"Europe/Moscow\", day: \"2-digit\", month: \"2-digit\", hour: \"2-digit\", minute: \"2-digit\" }) : \"\";\nconst fmtT = (iso) => iso ? new Date(iso).toLocaleString(\"ru-RU\", { timeZone: \"Europe/Moscow\", hour: \"2-digit\", minute: \"2-digit\" }) : \"\";\nconst isFresh = (o) => { const t = o.source_created || o.created || o.first_seen; return t && (Date.now() - new Date(t).getTime()) < 86400000; };\nconst st = (k) => (BOOT && BOOT.statuses[k]) || { label: k, color: \"#999\" };\nconst isMobile = () => innerWidth <= 860;\nfunction toast(m) { const t = $(\"#toast\"); t.textContent = m; t.classList.add(\"show\"); clearTimeout(t._t); t._t = setTimeout(() => t.classList.remove(\"show\"), 2400); }\nfunction roomsTxt(o) {\n const cat = o.category || \"\";\n if (o.section_id === 1 || (!o.section_id && o.rooms != null)) { if (/студ/i.test(cat) || (o.rooms === 0 && !cat)) return \"Студия\"; if (o.rooms) return `${o.rooms}-к`; if (cat) return cat.replace(/ квартира$/i, \"\"); return \"Квартира\"; }\n return cat || (o.section_id === 4 ? \"Коммерция\" : o.section_id === 5 ? \"Загородная\" : \"Объект\");\n}\nfunction specTxt(o) {\n const parts = [roomsTxt(o)];\n if (o.sq > 0) parts.push(`${o.sq} м²`);\n if (o.sq_land > 0) parts.push(`${o.sq_land} сот.`);\n if (o.floor || o.floors) parts.push(`${o.floor || \"?\"}/${o.floors || \"?\"} эт.`);\n if (o.is_new) parts.push(\"новостройка\"); if (o.is_apartments) parts.push(\"апартаменты\");\n return parts.join(\" · \");\n}\n// «На рынке N дней» — как days-on-market в MLS: чем дольше висит, тем сговорчивее продавец\nfunction domDays(o) { const t = o.source_created || o.created || o.first_seen; return t ? Math.max(0, Math.floor((Date.now() - new Date(t).getTime()) / 86400000)) : null; }\nfunction domTxt(o) { const d = domDays(o); if (d == null) return \"\"; if (d === 0) return ago(o.source_created || o.created || o.first_seen); return `на рынке ${d} дн`; }\nconst cleanAddr = (a) => String(a || \"\").replace(/^Россия,\\s*/i, \"\");\n// точка в полигоне (лучевой алгоритм), polygon = [[lat,lng],...]\nfunction inPoly(lat, lng, poly) {\n let ins = false;\n for (let i = 0, j = poly.length - 1; i < poly.length; j = i++) {\n const [yi, xi] = poly[i], [yj, xj] = poly[j];\n if ((yi > lat) !== (yj > lat) && lng < (xj - xi) * (lat - yi) / (yj - yi) + xi) ins = !ins;\n }\n return ins;\n}\n\nasync function api(path, opts = {}) {\n const r = await fetch(path, { ...opts, cache: \"no-store\", headers: { \"Content-Type\": \"application/json\", \"x-pin\": PIN, ...(opts.headers || {}) } });\n if (r.status === 401) { logout(); throw new Error(\"unauthorized\"); }\n const j = await r.json().catch(() => ({}));\n if (!r.ok) throw new Error(j.error || (\"Ошибка \" + r.status));\n return j;\n}\n\n/* ---------- вход ---------- */\nasync function doLogin() {\n const pin = $(\"#loginPin\").value.trim();\n $(\"#loginErr\").textContent = \"\";\n if (!/^\\d{4,6}$/.test(pin)) { $(\"#loginErr\").textContent = \"ПИН — от 4 до 6 цифр\"; return; }\n const r = await fetch(\"/api/login\", { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify({ pin }) });\n const j = await r.json().catch(() => ({}));\n if (!r.ok) { $(\"#loginErr\").textContent = j.error || \"Неверный ПИН-код\"; return; }\n PIN = pin; USER = j;\n localStorage.setItem(\"uo_pin\", pin); localStorage.setItem(\"uo_user\", JSON.stringify(j));\n start();\n}\nfunction logout() {\n PIN = \"\"; USER = null; localStorage.removeItem(\"uo_pin\"); localStorage.removeItem(\"uo_user\");\n $(\"#app\").classList.add(\"hidden\"); $(\"#loginView\").classList.remove(\"hidden\"); $(\"#loginPin\").value = \"\";\n}\n$(\"#loginPin\").addEventListener(\"keydown\", (e) => { if (e.key === \"Enter\") doLogin(); });\n\nfunction cycleTheme() {\n const cur = localStorage.getItem(\"unlock_theme\") || \"auto\";\n const next = cur === \"auto\" ? \"dark\" : cur === \"dark\" ? \"light\" : \"auto\";\n localStorage.setItem(\"unlock_theme\", next);\n const d = next === \"dark\" || (next === \"auto\" && matchMedia(\"(prefers-color-scheme:dark)\").matches);\n document.documentElement.dataset.theme = d ? \"dark\" : \"light\";\n toast(\"Тема: \" + ({ auto: \"как в системе\", dark: \"тёмная\", light: \"светлая\" })[next]);\n}\n\n/* ---------- старт ---------- */\nasync function start() {\n $(\"#loginView\").classList.add(\"hidden\"); $(\"#app\").classList.remove(\"hidden\");\n $(\"#list\").innerHTML = '

';\n try { BOOT = await api(\"/api/bootstrap\"); } catch (e) { toast(e.message); return; }\n USER = BOOT.user;\n $(\"#whoChip\").textContent = USER.role === \"boss\" ? \"Руководитель\" : USER.name.split(\" \")[0];\n $(\"#settingsBtn\").style.display = USER.role === \"boss\" ? \"\" : \"none\";\n renderTop(); renderStatusChips(); renderBrokerChips(); renderZoneBar();\n applyMode();\n await Promise.all([MapX.init(BOOT.yandexKey), reload()]);\n MapX.setMarkers(ITEMS, !SEL);\n LAST_PULSE = BOOT.serverTime || new Date().toISOString();\n setInterval(pulse, 30000);\n initSheet(); renderSaved(); initPush();\n if (isMobile()) { PANEL_OPEN = true; applyMode(); $(\"#panel\").classList.add(\"peek\"); }\n const qo = new URLSearchParams(location.search).get(\"o\");\n if (qo) { history.replaceState(null, \"\", \"/\"); openObject(Number(qo)); }\n}\nasync function refreshBoot() { try { BOOT = await api(\"/api/bootstrap\"); renderTop(); renderZoneBar(); } catch {} }\nasync function pulse() {\n if (PULSING || document.hidden) return;\n PULSING = true;\n try {\n const p = await api(\"/api/pulse?since=\" + encodeURIComponent(LAST_PULSE));\n if (p.objects || p.changed || p.activity) {\n await refreshBoot();\n await reload({ keepScroll: true });\n if (CUR && (p.activity || p.changed) && document.activeElement?.id !== \"cText\") openObject(CUR.id, true);\n if (p.objects) toast(`+${p.objects} нов${p.objects === 1 ? \"ый объект\" : p.objects < 5 ? \"ых объекта\" : \"ых объектов\"}`);\n } else if (Math.random() < 0.2) refreshBoot();\n LAST_PULSE = p.now;\n } catch {} finally { PULSING = false; }\n}\ndocument.addEventListener(\"visibilitychange\", () => { if (!document.hidden) pulse(); });\n\nfunction renderTop() {\n const c = BOOT.counts;\n $(\"#topStats\").innerHTML = `\n За сутки ${c.fresh24h}\n Не прозвонено ${c.byStatus.new || 0}\n Мои ${c.mine}\n ${c.recallDue ? `Перезвонить сегодня ${c.recallDue}` : \"\"}`;\n const lr = BOOT.lastRun, ln = BOOT.lastNew;\n const stale = lr && (Date.now() - new Date(lr.finished_at || lr.started_at).getTime()) > 20 * 60000;\n $(\"#syncInfo\").innerHTML = lr\n ? `${lr.error ? \"сбой сбора\" : stale ? \"сбор не отвечает\" : \"живое обновление\"} · проверено ${fmtT(lr.finished_at || lr.started_at)}${ln ? ` · новое ${fmtT(ln.started_at)} (+${ln.inserted})` : \"\"}`\n : `Первый сбор в ${fmtT(BOOT.nextRun)}`;\n}\nfunction renderStatusChips() {}\nfunction renderBrokerChips() {\n if (USER.role !== \"boss\") { $(\"#myBrokers\").innerHTML = \"\"; return; }\n $(\"#myBrokers\").innerHTML = `` + BOOT.brokers.map((b) => ``).join(\"\");\n}\nfunction setMyBroker(id) { MY_BROKER = id; renderBrokerChips(); reload(); }\nfunction toggleSet(set, v, btn) { if (set.has(v)) set.delete(v); else set.add(v); btn.classList.toggle(\"on\", set.has(v)); }\nfunction setQuick(q) { QUICK = q; F.status.clear(); markQuick(); reload(); if (isMobile()) $(\"#panel\").classList.remove(\"peek\"); if (MODE === \"map\") togglePanel(true); }\nfunction markQuick() { $$(\"#quick button[data-q], #myTabs button[data-q]\").forEach((b) => b.classList.toggle(\"on\", b.dataset.q === QUICK)); }\nfunction resetFilters() {\n F.status.clear(); F.rooms.clear(); F.source.clear(); F.section.clear(); F.broker = null; F.zones.clear(); FOCUS = null;\n Object.assign(F, { costMin: \"\", costMax: \"\", sqMin: \"\", sqMax: \"\", m2Min: \"\", m2Max: \"\", yearMin: \"\", yearMax: \"\", fresh: \"\", isNew: \"\", phone: false, unassigned: false, notFirst: false, notLast: false, hideAgent: true, cross: false, drop: false });\n $(\"#q\").value = \"\";\n renderZoneBar(); if (typeof renderFilters === \"function\" && !$(\"#fdrawer\").classList.contains(\"hidden\")) renderFilters();\n setQuick(MODE === \"my\" ? \"my:work\" : \"all\");\n}\nfunction onSearch() { clearTimeout(searchT); searchT = setTimeout(reload, 300); }\nfunction setTab(t) { if (!isMobile()) return; const p = $(\"#panel\"); p.classList.remove(\"full\", \"peek\"); if (t === \"map\") p.classList.add(\"peek\"); }\n\n/* ---------- режимы ---------- */\nfunction setMode(m) {\n MODE = m; localStorage.setItem(\"uo_mode\", m);\n if (m === \"my\" && !QUICK.startsWith(\"my:\")) QUICK = \"my:work\";\n if (m !== \"my\" && QUICK.startsWith(\"my:\")) QUICK = \"all\";\n markQuick(); applyMode();\n if (m === \"map\") { setTimeout(() => { MapX.resize(); if (!SEL) fitAll(); }, 60); }\n reload();\n}\nfunction applyMode() {\n const app = $(\"#app\");\n app.classList.toggle(\"mode-map\", MODE === \"map\"); app.classList.toggle(\"mode-list\", MODE === \"list\"); app.classList.toggle(\"mode-my\", MODE === \"my\");\n if (!CUR) { $(\"#drawer\").classList.add(\"hidden\"); $(\"#drawer\").classList.remove(\"empty\"); app.classList.remove(\"has-drawer\"); }\n app.classList.toggle(\"panel-open\", PANEL_OPEN);\n $$(\"#modeSeg button\").forEach((b) => b.classList.toggle(\"on\", b.dataset.m === MODE));\n renderPill();\n}\nfunction togglePanel(open) { PANEL_OPEN = open == null ? !PANEL_OPEN : !!open; applyMode(); }\nfunction renderPill() { const n = ITEMS.length; $(\"#listPill\").innerHTML = `Список ${n}`; }\n// Обзвон: следующий объект по списку\nfunction nextAfter(id, dir = 1) {\n const i = ITEMS.findIndex((o) => o.id === id);\n for (let k = i + dir; k >= 0 && k < ITEMS.length; k += dir) { const o = ITEMS[k]; if (MODE !== \"list\" || !st(o.status).done) return o; }\n return null;\n}\nfunction goNext(dir = 1) { const n = CUR ? nextAfter(CUR.id, dir) : ITEMS.find((o) => !st(o.status).done); if (n) openObject(n.id); else toast(dir > 0 ? \"Список закончился\" : \"Это первый объект\"); }\nfunction startCalling() { const n = ITEMS.find((o) => !st(o.status).done && o.status !== \"recall\"); if (!n) return toast(\"Нечего обзванивать по текущим фильтрам\"); openObject(n.id); }\ndocument.addEventListener(\"keydown\", (e) => {\n if ([\"INPUT\", \"TEXTAREA\", \"SELECT\"].includes(document.activeElement?.tagName)) return;\n if (e.key === \"Escape\") { if (!$(\"#modal\").classList.contains(\"hidden\")) closeModal(); else if (!$(\"#fdrawer\").classList.contains(\"hidden\")) closeFilters(); else if (CUR) closeDrawer(); else if (FOCUS) clearFocus(); }\n if (MODE !== \"map\" && CUR) { if (e.key === \"ArrowRight\" || e.key === \"j\") goNext(1); if (e.key === \"ArrowLeft\" || e.key === \"k\") goNext(-1); }\n});\n\n/* ---------- зоны ---------- */\nfunction renderZoneBar() {\n const zs = BOOT.zones || [];\n $(\"#zoneBar\").innerHTML = zs.map((z) => ``).join(\"\");\n MapX.drawZones(zs, F.zones);\n}\nfunction toggleZone(id) { if (F.zones.has(id)) F.zones.delete(id); else F.zones.add(id); if (F.zones.size) togglePanel(true); renderZoneBar(); applyLocal(); }\nasync function delZone(id) {\n const z = (BOOT.zones || []).find((x) => x.id === id);\n if (!confirm(`Удалить зону «${z ? z.name : \"\"}» для всей команды?`)) return;\n try { await api(\"/api/zones/\" + id, { method: \"DELETE\" }); F.zones.delete(id); await refreshBoot(); applyLocal(); toast(\"Зона удалена\"); } catch (e) { toast(e.message); }\n}\nlet DRAWING = false;\nfunction startZone() {\n if (DRAWING) return cancelZone();\n DRAWING = true; $(\"#zoneBtn\").classList.add(\"on\"); $(\"#drawHint\").classList.remove(\"hidden\"); $(\"#map\").classList.add(\"drawing\"); if (!isMobile()) togglePanel(false); else $(\"#panel\").classList.add(\"peek\");\n if (isMobile()) setTab(\"map\");\n MapX.startDraw(async (points) => {\n DRAWING = false; $(\"#zoneBtn\").classList.remove(\"on\"); $(\"#drawHint\").classList.add(\"hidden\"); $(\"#map\").classList.remove(\"drawing\");\n if (!points || points.length < 3) { MapX.clearDraft(); return toast(\"Обведи область побольше\"); }\n const inside = ALL.filter((o) => o.lat && o.lng && inPoly(o.lat, o.lng, points)).length;\n const name = prompt(`В зоне ${inside} объект${plural(inside)}. Как назовём зону?`, \"\");\n if (!name) { MapX.clearDraft(); return; }\n try {\n const z = await api(\"/api/zones\", { method: \"POST\", body: JSON.stringify({ name, points, color: pickColor() }) });\n MapX.clearDraft(); F.zones.add(z.id); await refreshBoot(); applyLocal(); toast(`Зона «${z.name}» сохранена для команды`);\n } catch (e) { MapX.clearDraft(); toast(e.message); }\n });\n}\nfunction cancelZone() { DRAWING = false; $(\"#zoneBtn\").classList.remove(\"on\"); $(\"#drawHint\").classList.add(\"hidden\"); $(\"#map\").classList.remove(\"drawing\"); MapX.cancelDraw(); }\nconst ZCOLORS = [\"#5b5bd6\", \"#0ea5e9\", \"#10b981\", \"#f59e0b\", \"#ec4899\", \"#8b5cf6\", \"#14b8a6\", \"#f97316\"];\nfunction pickColor() { return ZCOLORS[(BOOT.zones || []).length % ZCOLORS.length]; }\n\n/* ---------- список ---------- */\nfunction buildQuery() {\n const p = new URLSearchParams();\n p.set(\"sort\", $(\"#sort\").value);\n if (MODE === \"my\") {\n if (USER.role === \"boss\") { if (MY_BROKER != null) p.set(\"broker\", MY_BROKER); } else p.set(\"mine\", \"1\");\n const tab = QUICK.startsWith(\"my:\") ? QUICK.slice(3) : \"work\";\n if (tab === \"work\") p.set(\"status\", \"work\");\n if (tab === \"recall\") { p.set(\"status\", \"recall\"); p.set(\"sort\", \"recall\"); }\n if (tab === \"meeting\") p.set(\"status\", \"meeting\");\n if (tab === \"noanswer\") p.set(\"status\", \"noanswer\");\n if (tab === \"refused\") p.set(\"status\", \"refused,agent,aggressive,dnc,gone\");\n if (tab === \"touched\") { p.delete(\"mine\"); p.set(\"touched\", \"1\"); }\n if (USER.role === \"boss\" && MY_BROKER == null && tab !== \"touched\") { /* вся команда: все объекты с брокером */ p.set(\"unassigned\", \"0\"); p.set(\"assigned\", \"1\"); }\n } else {\n if (QUICK === \"new\") p.set(\"status\", \"new,noanswer\");\n if (QUICK === \"mine\") p.set(\"mine\", \"1\");\n if (QUICK === \"recall\") { p.set(\"status\", \"recall\"); p.set(\"sort\", \"recall\"); }\n if (QUICK === \"drop\") p.set(\"drop\", \"1\");\n if (QUICK === \"fresh\") p.set(\"fresh\", \"24\");\n if (QUICK === \"call\") { p.set(\"status\", \"new,noanswer\"); p.set(\"phone\", \"1\"); }\n if (QUICK === \"gone\") p.set(\"gone\", \"1\");\n if (F.status.size) p.set(\"status\", [...F.status].join(\",\"));\n if (F.broker != null) p.set(\"broker\", F.broker);\n if (F.fresh) p.set(\"fresh\", F.fresh);\n if (F.phone) p.set(\"phone\", \"1\");\n if (F.unassigned) p.set(\"unassigned\", \"1\");\n if (F.drop) p.set(\"drop\", \"1\");\n }\n if (F.rooms.size) p.set(\"rooms\", [...F.rooms].join(\",\"));\n if (F.source.size) p.set(\"source\", [...F.source].join(\",\"));\n if (F.section.size) p.set(\"section\", [...F.section].join(\",\"));\n if (F.costMin) p.set(\"costMin\", Number(F.costMin) * 1e6);\n if (F.costMax) p.set(\"costMax\", Number(F.costMax) * 1e6);\n if (F.sqMin) p.set(\"sqMin\", F.sqMin); if (F.sqMax) p.set(\"sqMax\", F.sqMax);\n if (F.m2Min) p.set(\"m2Min\", Number(F.m2Min) * 1000); if (F.m2Max) p.set(\"m2Max\", Number(F.m2Max) * 1000);\n if (F.yearMin) p.set(\"yearMin\", F.yearMin); if (F.yearMax) p.set(\"yearMax\", F.yearMax);\n if (F.isNew !== \"\") p.set(\"isNew\", F.isNew);\n if (F.notFirst) p.set(\"notFirst\", \"1\"); if (F.notLast) p.set(\"notLast\", \"1\");\n if (F.hideAgent) p.set(\"hideAgent\", \"1\"); if (F.cross) p.set(\"cross\", \"1\");\n if ($(\"#q\").value.trim()) p.set(\"q\", $(\"#q\").value.trim());\n const n = filterCount();\n $(\"#advN\").textContent = n || \"\";\n return p.toString();\n}\nfunction filterCount() {\n return F.status.size + F.rooms.size + F.source.size + F.section.size + (F.broker != null) + [\"costMin\", \"costMax\", \"sqMin\", \"sqMax\", \"m2Min\", \"m2Max\", \"yearMin\", \"yearMax\", \"fresh\"].filter((k) => F[k]).length + (F.isNew !== \"\") + [\"phone\", \"unassigned\", \"notFirst\", \"notLast\", \"cross\", \"drop\"].filter((k) => F[k]).length + (F.hideAgent ? 0 : 1);\n}\nasync function reload(opts = {}) {\n try {\n const j = await api(\"/api/objects?\" + buildQuery());\n ALL = j.items;\n applyLocal(opts);\n } catch (e) { toast(e.message); }\n}\n// Локальные фильтры (зоны) поверх ответа сервера\nfunction applyLocal(opts = {}) {\n const zs = (BOOT.zones || []).filter((z) => F.zones.has(z.id));\n ITEMS = zs.length ? ALL.filter((o) => o.lat && o.lng && zs.some((z) => inPoly(o.lat, o.lng, z.points))) : ALL;\n const total = ITEMS.length;\n if (FOCUS) { const f = ITEMS.filter((o) => FOCUS.has(o.id)); if (f.length) ITEMS = f; else FOCUS = null; }\n $(\"#listCount\").textContent = total ? `${total} объект${plural(total)}${zs.length ? \" в зоне\" : \"\"}` : \"Ничего не найдено\";\n renderPill();\n { const done = ITEMS.filter((o) => o.status !== \"new\").length; $(\"#callProg\").style.width = (ITEMS.length ? Math.round(done / ITEMS.length * 100) : 0) + \"%\"; $(\"#callStat\").textContent = ITEMS.length ? `${done} из ${ITEMS.length} тронуто` : \"\"; }\n $(\"#focusChip\").innerHTML = FOCUS ? `В точке: ${ITEMS.length} ×` : \"\";\n const top = opts.keepScroll ? $(\"#list\").scrollTop : 0;\n renderList(true);\n if (opts.keepScroll) { while (listRendered < ITEMS.length && listRendered < 600 && $(\"#list\").scrollHeight < top + $(\"#list\").clientHeight * 2) renderList(false); $(\"#list\").scrollTop = top; }\n MapX.setMarkers(FOCUS ? (zs.length ? ALL.filter((o) => o.lat && o.lng && zs.some((z) => inPoly(o.lat, o.lng, z.points))) : ALL) : ITEMS, !opts.keepScroll && !SEL && !FOCUS);\n}\nfunction clearFocus() { FOCUS = null; applyLocal({ keepScroll: false }); }\nfunction focusOn(ids, coords) {\n FOCUS = new Set(ids);\n togglePanel(true); if (isMobile()) $(\"#panel\").classList.remove(\"peek\", \"full\");\n applyLocal({ keepScroll: false });\n if (isMobile()) setTab(\"list\");\n if (coords && coords.length > 1) {\n const lats = coords.map((c) => c[0]), lngs = coords.map((c) => c[1]);\n const spread = Math.max(Math.max(...lats) - Math.min(...lats), Math.max(...lngs) - Math.min(...lngs));\n if (spread > 0.0008) MapX.fitPoints(coords);\n }\n}\nconst plural = (n) => { const m = n % 10, h = n % 100; return (m === 1 && h !== 11) ? \"\" : (m >= 2 && m <= 4 && (h < 12 || h > 14)) ? \"а\" : \"ов\"; };\n\nfunction cardHtml(o) {\n const s = st(o.status), drop = o.cost_prev && o.cost < o.cost_prev, f = o.flags || {}, fresh = isFresh(o);\n const idx = ITEMS.indexOf(o) + 1;\n return `

\n ${idx}\n

${srcName(o.source)}${o.photos ? `${o.photos}` : \"\"}

${fmtMln(o.cost)}${drop ? `~~${fmtMln(o.cost_prev)}~~−${Math.round((1 - o.cost / o.cost_prev) * 100)}%` : \"\"}${fmtM2(o.cost_m2)}

${esc(specTxt(o))}

${esc(cleanAddr(o.address))}${o.metro ? \" · м. \" + esc(o.metro) : \"\"}

\n ${s.label}\n ${o.assignee_name ? `${initials(o.assignee_name)}` : \"\"}\n ${o.status === \"recall\" && o.recall_at ? `⏰ ${fmtDT(o.recall_at)}` : \"\"}\n ${f.agentWords ? `${o.section_id === 4 ? \"застройщик?\" : \"агент?\"}` : \"\"}\n ${o.gone_at ? `ушёл с площадки ${ago(o.gone_at)} назад` : \"\"}\n ${f.crossListed ? `${f.crossListed + 1} площадки` : \"\"}\n ${!o.hasPhone ? `без телефона` : \"\"}\n ${o.touches ? `☎ ${o.touches}` : \"\"}\n ${fresh ? \"новый · \" : \"\"}${domTxt(o)}\n

${o.hasPhone && !o.hidePhone ? `Позвонить` : ``}

`;\n}\nfunction renderList(reset) {\n const el = $(\"#list\");\n if (reset) { el.innerHTML = ITEMS.length ? \"\" : `

Ничего не найдено.
Попробуй убрать часть фильтров.

`; listRendered = 0; el.scrollTop = 0; }\n const chunk = ITEMS.slice(listRendered, listRendered + 120);\n el.insertAdjacentHTML(\"beforeend\", chunk.map(cardHtml).join(\"\"));\n listRendered += chunk.length;\n}\n$(\"#list\").addEventListener(\"scroll\", (e) => { const el = e.target; if (el.scrollTop + el.clientHeight > el.scrollHeight - 600 && listRendered < ITEMS.length) renderList(false); });\n\n/* ---------- карта: Яндекс 2.1 с запасным Leaflet ---------- */\nconst MapX = {\n kind: null, map: null, om: null, zoneObjs: [], draft: null, drawCb: null, sel: null,\n async init(key) {\n if (this.map) return;\n this.kind = await this.loadYandex(key) ? \"ya\" : \"lf\";\n if (this.kind === \"ya\") this.initYa(); else this.initLf();\n },\n loadYandex(key) {\n return new Promise((res) => {\n if (window.ymaps) return res(true);\n const s = document.createElement(\"script\");\n s.src = \"https://api-maps.yandex.ru/2.1/?lang=ru_RU\" + (key ? \"&apikey=\" + encodeURIComponent(key) : \"\");\n const t = setTimeout(() => res(false), 8000);\n s.onload = () => { clearTimeout(t); window.ymaps ? ymaps.ready(() => res(true)) : res(false); };\n s.onerror = () => { clearTimeout(t); res(false); };\n document.head.appendChild(s);\n });\n },\n // ----- Яндекс -----\n initYa() {\n this.map = new ymaps.Map(\"map\", { center: [55.751, 37.618], zoom: 11, controls: [\"zoomControl\"] }, { suppressMapOpenBlock: true, yandexMapDisablePoiInteractivity: true });\n this.map.controls.get(\"zoomControl\").options.set({ position: { left: 12, top: isMobile() ? 124 : 134 }, size: \"small\" });\n const Layout = ymaps.templateLayoutFactory.createClass('

');\n const ClLayout = ymaps.templateLayoutFactory.createClass('

');\n this.om = new ymaps.ObjectManager({ clusterize: true, gridSize: 40, clusterDisableClickZoom: true, clusterOpenBalloonOnClick: false });\n // Область клика заметно больше самой точки — попадать легко\n this.om.objects.options.set({ iconLayout: Layout, iconShape: { type: \"Circle\", coordinates: [0, 0], radius: 18 }, hasBalloon: false, hideIconOnBalloonOpen: false, cursor: \"pointer\" });\n this.om.clusters.options.set({ clusterIconLayout: ClLayout, clusterIconShape: { type: \"Circle\", coordinates: [0, 0], radius: 22 }, hasBalloon: false, cursor: \"pointer\" });\n this.om.objects.events.add(\"click\", (e) => openObject(Number(e.get(\"objectId\"))));\n this.om.clusters.events.add(\"click\", (e) => {\n const cl = this.om.clusters.getById(e.get(\"objectId\")); if (!cl) return;\n const objs = cl.properties.geoObjects || [];\n focusOn(objs.map((g) => Number(g.id)), objs.map((g) => g.geometry.coordinates));\n });\n this.om.objects.events.add(\"mouseenter\", (e) => { const o = ITEMS.find((x) => x.id === Number(e.get(\"objectId\"))); if (o) this.map.hint.open(this.map, [o.lat, o.lng], hintHtml(o)); });\n this.om.objects.events.add(\"mouseleave\", () => this.map.hint.close(true));\n this.map.geoObjects.add(this.om);\n this.map.events.add(\"click\", () => { if (FOCUS && !DRAWING) clearFocus(); });\n },\n // ----- Leaflet (если Яндекс недоступен) -----\n initLf() {\n this.map = L.map(\"map\", { zoomControl: true, attributionControl: false }).setView([55.751, 37.618], 11);\n L.tileLayer(\"https://tile.openstreetmap.org/{z}/{x}/{y}.png\", { maxZoom: 19 }).addTo(this.map);\n this.layer = L.layerGroup().addTo(this.map); this.zl = L.layerGroup().addTo(this.map); this.lfm = new Map();\n this.map.on(\"click\", () => { if (FOCUS && !DRAWING) clearFocus(); });\n },\n resize() { if (this.kind === \"ya\") this.map.container.fitToViewport(); else this.map.invalidateSize(); },\n // Квартиры одного дома приходят с одной координатой — раскладываем их кольцом (~25 м),\n // чтобы на большом зуме кластер раскрывался на отдельные точки.\n spread(items) {\n const groups = new Map();\n for (const o of items) { if (!o.lat || !o.lng) continue; const k = o.lat.toFixed(5) + \",\" + o.lng.toFixed(5); (groups.get(k) || groups.set(k, []).get(k)).push(o); }\n const pos = new Map();\n for (const g of groups.values()) {\n if (g.length === 1) { pos.set(g[0].id, [g[0].lat, g[0].lng]); continue; }\n g.forEach((o, i) => {\n const r = 0.00022 * (1 + Math.floor(i / 8) * 0.9), a = (i % 8) / 8 * Math.PI * 2 + Math.floor(i / 8) * 0.4;\n pos.set(o.id, [o.lat + r * Math.sin(a), o.lng + r * 1.75 * Math.cos(a)]);\n });\n }\n return pos;\n },\n setMarkers(items, fit) {\n const pos = this.spread(items);\n if (this.kind === \"ya\") {\n this.om.removeAll();\n this.om.add({ type: \"FeatureCollection\", features: items.filter((o) => pos.has(o.id)).map((o) => {\n const s = st(o.status);\n return { type: \"Feature\", id: o.id, geometry: { type: \"Point\", coordinates: pos.get(o.id) }, properties: { color: s.done ? s.color + \"99\" : s.color, cls: (o.status === \"new\" && isFresh(o) ? \"fresh \" : \"\") + (SEL === o.id ? \"sel\" : \"\") } };\n }) });\n if (fit && items.length) this.fit();\n } else {\n this.layer.clearLayers(); this.lfm.clear();\n for (const o of items) {\n if (!pos.has(o.id)) continue;\n const s = st(o.status);\n const m = L.marker(pos.get(o.id), { icon: L.divIcon({ className: \"\", html: `

`, iconSize: [36, 36], iconAnchor: [18, 18] }) });\n m.on(\"click\", () => openObject(o.id)); m.bindTooltip(hintHtml(o), { direction: \"top\", offset: [0, -10] });\n m.addTo(this.layer); this.lfm.set(o.id, m);\n }\n if (fit && items.length) this.fit();\n }\n },\n fit() { this.fitPoints(ITEMS.filter((o) => o.lat && o.lng).map((o) => [o.lat, o.lng])); },\n updateOne(o) {\n if (!this.map || !o.lat || !o.lng) return;\n const s = st(o.status);\n if (this.kind === \"ya\") {\n const f = this.om.objects.getById(o.id); if (!f) return;\n this.om.objects.setObjectProperties(o.id, { color: s.done ? s.color + \"99\" : s.color, cls: (o.status === \"new\" && isFresh(o) ? \"fresh \" : \"\") + (SEL === o.id ? \"sel\" : \"\") });\n } else {\n const m = this.lfm.get(o.id); if (!m) return;\n const mk = m.getElement()?.querySelector(\".mk\"); if (mk) { mk.style.background = s.color; mk.style.color = s.color; mk.classList.toggle(\"fresh\", o.status === \"new\" && isFresh(o)); }\n }\n },\n fitPoints(pts) {\n if (!pts.length) return;\n const m = this.margins();\n if (this.kind === \"ya\") this.map.setBounds(ymaps.util.bounds.fromPoints(pts), { checkZoomRange: true, zoomMargin: m, duration: 300 });\n else this.map.fitBounds(pts, { paddingTopLeft: [m[3], m[0]], paddingBottomRight: [m[1], m[2]], maxZoom: 16 });\n },\n // отступы [верх, право, низ, лево]: шапка, панель списка справа, открытая карточка слева\n margins() {\n if (isMobile()) return [80, 30, 30, 30];\n const drawer = $(\"#drawer\").classList.contains(\"hidden\") ? 0 : ($(\"#drawer\").offsetWidth || 540) + 24;\n return [90, ($(\"#panel\").offsetWidth || 450) + 36, 40, Math.max(drawer, 70)];\n },\n highlight(id) {\n if (this.kind === \"ya\") {\n if (this.sel != null) { const p = this.om.objects.getById(this.sel); if (p) this.om.objects.setObjectOptions(this.sel, {}), this.om.objects.setObjectProperties(this.sel, { cls: (p.properties.cls || \"\").replace(\"sel\", \"\") }); }\n if (id != null) { const p = this.om.objects.getById(id); if (p) this.om.objects.setObjectProperties(id, { cls: (p.properties.cls || \"\").replace(\"sel\", \"\") + \" sel\" }); }\n } else {\n this.lfm.forEach((m, k) => { const el = m.getElement(); const mk = el && el.querySelector(\".mk\"); if (mk) mk.classList.toggle(\"sel\", k === id); });\n }\n this.sel = id;\n },\n panTo(lat, lng) {\n if (isMobile()) return;\n // точку ставим в центр свободной области между карточкой слева и списком справа\n const m = this.margins(), W = innerWidth;\n const dx = W / 2 - (m[3] + (W - m[3] - m[1]) / 2);\n if (this.kind === \"ya\") { const z = this.map.getZoom(), pr = this.map.options.get(\"projection\"); const px = pr.toGlobalPixels([lat, lng], z); this.map.panTo(pr.fromGlobalPixels([px[0] + dx, px[1]], z), { duration: 300 }); }\n else { const pt = this.map.latLngToContainerPoint([lat, lng]); this.map.panTo(this.map.containerPointToLatLng([pt.x + dx, pt.y]), { animate: true }); }\n },\n // ----- зоны -----\n drawZones(zones, active) {\n if (!this.map) return;\n if (this.kind === \"ya\") { this.zoneObjs.forEach((z) => this.map.geoObjects.remove(z)); this.zoneObjs = []; }\n else this.zl.clearLayers();\n for (const z of zones) {\n const on = active.has(z.id), col = z.color || \"#5b5bd6\";\n if (this.kind === \"ya\") {\n const p = new ymaps.Polygon([z.points], { hintContent: z.name }, { fillColor: col + (on ? \"33\" : \"14\"), strokeColor: col, strokeWidth: on ? 2.5 : 1.5, strokeStyle: on ? \"solid\" : \"shortdash\", interactivityModel: \"default#transparent\" });\n p.events.add(\"click\", () => toggleZone(z.id)); this.map.geoObjects.add(p); this.zoneObjs.push(p);\n } else {\n L.polygon(z.points, { color: col, weight: on ? 2.5 : 1.5, fillOpacity: on ? .2 : .08, dashArray: on ? null : \"4 4\" }).on(\"click\", () => toggleZone(z.id)).bindTooltip(z.name).addTo(this.zl);\n }\n }\n },\n // Лассо: зажал — обвёл — отпустил. Работает и мышью, и пальцем.\n startDraw(cb) {\n const el = $(\"#map\"); const pts = []; let down = false, lastX = 0, lastY = 0;\n const toGeo = (e) => {\n if (this.kind === \"ya\") { const gp = this.map.converter.pageToGlobal([e.pageX, e.pageY]); return this.map.options.get(\"projection\").fromGlobalPixels(gp, this.map.getZoom()); }\n const ll = this.map.mouseEventToLatLng(e); return [ll.lat, ll.lng];\n };\n const render = () => {\n if (pts.length < 3) return;\n if (this.kind === \"ya\") { if (!this.draft) { this.draft = new ymaps.Polygon([pts.slice()], {}, { fillColor: \"#5b5bd633\", strokeColor: \"#5b5bd6\", strokeWidth: 2.5, interactivityModel: \"default#transparent\" }); this.map.geoObjects.add(this.draft); } else this.draft.geometry.setCoordinates([pts.slice()]); }\n else { if (!this.draftLf) this.draftLf = L.polygon(pts, { color: \"#5b5bd6\", weight: 2.5, fillOpacity: .2, interactive: false }).addTo(this.zl); else this.draftLf.setLatLngs(pts); }\n };\n const onDown = (e) => { if (e.button && e.button !== 0) return; down = true; pts.length = 0; lastX = e.clientX; lastY = e.clientY; pts.push(toGeo(e)); el.setPointerCapture?.(e.pointerId); e.preventDefault(); };\n const onMove = (e) => { if (!down) return; if (Math.hypot(e.clientX - lastX, e.clientY - lastY) < 5) return; lastX = e.clientX; lastY = e.clientY; pts.push(toGeo(e)); render(); e.preventDefault(); };\n const onUp = (e) => { if (!down) return; down = false; this._stopDraw(); const out = pts.slice(); cb(out.length >= 3 ? out : null); };\n this._drawHandlers = { onDown, onMove, onUp };\n el.addEventListener(\"pointerdown\", onDown, { capture: true }); el.addEventListener(\"pointermove\", onMove, { capture: true }); el.addEventListener(\"pointerup\", onUp, { capture: true }); el.addEventListener(\"pointercancel\", onUp, { capture: true });\n if (this.kind === \"ya\") this.map.behaviors.disable([\"drag\", \"scrollZoom\", \"dblClickZoom\", \"multiTouch\"]); else { this.map.dragging.disable(); this.map.touchZoom.disable(); this.map.doubleClickZoom.disable(); }\n },\n _stopDraw() {\n const el = $(\"#map\"), h = this._drawHandlers; if (!h) return;\n el.removeEventListener(\"pointerdown\", h.onDown, { capture: true }); el.removeEventListener(\"pointermove\", h.onMove, { capture: true }); el.removeEventListener(\"pointerup\", h.onUp, { capture: true }); el.removeEventListener(\"pointercancel\", h.onUp, { capture: true });\n this._drawHandlers = null;\n if (this.kind === \"ya\") this.map.behaviors.enable([\"drag\", \"scrollZoom\", \"dblClickZoom\", \"multiTouch\"]); else { this.map.dragging.enable(); this.map.touchZoom.enable(); this.map.doubleClickZoom.enable(); }\n },\n cancelDraw() { this._stopDraw(); this.clearDraft(); },\n clearDraft() { if (this.kind === \"ya\" && this.draft) { this.map.geoObjects.remove(this.draft); this.draft = null; } if (this.kind === \"lf\" && this.draftLf) { this.zl.removeLayer(this.draftLf); this.draftLf = null; } },\n};\nfunction hintHtml(o) { const s = st(o.status); return `${fmtMln(o.cost)} · ${esc(specTxt(o))}
${esc(cleanAddr(o.address))}
${s.label}${o.assignee_name ? \" · \" + esc(o.assignee_name.split(\" \")[0]) : \"\"}`; }\nfunction fitAll() { MapX.fit(); }\n\n/* ---------- карточка ---------- */\nasync function openObject(id, silent) {\n if (FOCUS && !FOCUS.has(id)) { FOCUS = null; applyLocal({ keepScroll: true }); }\n SEL = id;\n $$(\".card\").forEach((c) => c.classList.toggle(\"sel\", Number(c.dataset.id) === id));\n MapX.highlight(id);\n $(\"#drawer\").classList.remove(\"hidden\"); $(\"#drawer\").classList.remove(\"empty\"); $(\"#app\").classList.add(\"has-drawer\");\n if (!silent) $(\"#dBody\").innerHTML = `

`;\n try { CUR = await api(\"/api/objects/\" + id); } catch (e) { toast(e.message); return; }\n const o = CUR;\n if (o.lat && o.lng && !silent) MapX.panTo(o.lat, o.lng);\n $(\"#dTitle\").textContent = specTxt(o);\n $(\"#dSrc\").href = o.url;\n $(\"#dTitle\").textContent = (MODE !== \"map\" ? `${ITEMS.findIndex((x) => x.id === o.id) + 1} из ${ITEMS.length} · ` : \"\") + $(\"#dTitle\").textContent;\n const draft = silent ? ($(\"#cText\")?.value || \"\") : \"\";\n renderDrawer();\n if (draft) $(\"#cText\").value = draft;\n}\nasync function callObj(id) {\n await openObject(id);\n const p = CUR && CUR.phones && CUR.phones[0];\n if (!p) return;\n if (!CUR.assignee_id) { try { const r = await api(`/api/objects/${CUR.id}/assign`, { method: \"POST\", body: JSON.stringify({}) }); patchLocal(CUR.id, { assignee_id: r.assignee_id, assignee_name: r.assignee_name, status: r.status }); openObject(CUR.id, true); } catch {} }\n location.href = \"tel:+\" + p;\n}\nfunction copyLink() { if (!CUR) return; navigator.clipboard.writeText(location.origin + \"/?o=\" + CUR.id).then(() => toast(\"Ссылка скопирована — откроется сразу на объекте\")); }\nfunction closeDrawer() { $(\"#drawer\").classList.add(\"hidden\"); $(\"#app\").classList.remove(\"has-drawer\"); CUR = null; if (MODE !== \"map\") renderList(true); $(\"#scrim\").classList.add(\"hidden\"); SEL = null; MapX.highlight(null); $$(\".card.sel\").forEach((c) => c.classList.remove(\"sel\")); }\n\nfunction renderDrawer() {\n const o = CUR, s = st(o.status), f = o.flags || {}, mine = o.assignee_id === USER.id, drop = o.cost_prev && o.cost !== o.cost_prev, boss = USER.role === \"boss\";\n const flags = [];\n if (f.ownerWords) flags.push(`В тексте: собственник`);\n if (f.agentWords) flags.push(`Агентские обороты в тексте`);\n if (f.developer) flags.push(`Похоже на застройщика / отдел продаж`);\n if (o.gone_at) flags.push(`Ушёл с площадки ${fmtDT(o.gone_at)} — не продан, собственник свободен`);\n if (o.status === \"exclusive\") flags.push(`Эксклюзив · объект не исчезнет из базы`);\n if (f.phoneMulti >= 3) flags.push(`Телефон ещё в ${f.phoneMulti - 1} объявлениях`);\n else if (f.phoneMulti === 2) flags.push(`Телефон ещё в одном объявлении`);\n if (f.crossListed) flags.push(`На ${f.crossListed + 1} площадках`);\n if (o.is_new) flags.push(`Новостройка`);\n if (o.is_apartments) flags.push(`Апартаменты`);\n flags.push(`Приоритет ${o.score}/100`);\n const statusBtns = Object.entries(BOOT.statuses).map(([k, v]) => ``).join(\"\");\n const acts = (o.activity || []).slice().reverse().map((a) => {\n const sys = a.kind === \"system\";\n const canDel = a.kind === \"comment\" && (USER.role === \"boss\" || a.broker_id === USER.id);\n return `

${sys ? `₽` : `${initials(a.broker_name)}`}\n

${a.kind === \"status\" ? \"→ \" : \"\"}${esc(a.text)}

${sys ? \"Система\" : esc(a.broker_name)} · ${fmtDT(a.created_at)}

${canDel ? `` : \"\"}

`;\n }).join(\"\");\n $(\"#dBody\").innerHTML = `\n ${o.images.length ? `

${o.images.slice(0, 30).map((u, i) => `

`).join(\"\")}

${o.images.length} фото

` : \"\"}\n

${fmtMln(o.cost)}${fmtM2(o.cost_m2)}${drop ? `${o.cost < o.cost_prev ? \"↓\" : \"↑\"} было ${fmtMln(o.cost_prev)} · ${ago(o.cost_changed_at)} назад` : \"\"}

${esc(cleanAddr(o.address))}

${[o.metro ? \"м. \" + o.metro : \"\", o.district, srcName(o.source) + (o.source_created ? \", размещено \" + fmtDT(o.source_created) : \"\")].filter(Boolean).map(esc).join(\" · \")}

${flags.join(\"\")}

\n ${o.floor || o.floors ? `

Этаж${o.floor || \"?\"} из ${o.floors || \"?\"}

` : \"\"}\n ${o.sq > 0 ? `

Площадь${o.sq} м²

` : \"\"}\n ${o.sq_land > 0 ? `

Участок${o.sq_land} сот.

` : \"\"}\n ${o.sq_living || o.sq_kitchen ? `

Жилая / кухня${o.sq_living || \"—\"} / ${o.sq_kitchen || \"—\"}

` : \"\"}\n ${o.build_year ? `

Год дома${o.build_year}

` : \"\"}\n ${o.name ? `

Имя в объявлении${esc(o.name)}

` : \"\"}\n

На рынке${domDays(o) ?? \"?\"} дн

\n ${o.market ? `

Рынок · ${esc(o.market.scope)} · ${o.market.n} объект${plural(o.market.n)} у собственников${fmtM2(o.market.avg)} в среднем · этот ${o.cost_m2 < o.market.avg ? `на ${Math.round((1 - o.cost_m2 / o.market.avg) * 100)}% ниже` : `на ${Math.round((o.cost_m2 / o.market.avg - 1) * 100)}% выше`}

` : \"\"}\n

Собственник

\n ${o.hidePhone ? `

Телефон скрыт: статус «${s.label}». Не звонить.

` :\n o.phones.length ? o.phones.map((p) => `

${fmtPhone(p)}

`).join(\"\") :\n phoneReqHtml(o)}\n

Кто ведёт

\n ${o.assignee_id ? `${mine || boss ? `` : \"\"}` :\n `${boss ? `` : \"\"}`}\n

Статус звонка

${statusBtns}

${o.status === \"meeting\" ? \"Дата встречи\" : \"Перезвонить\"}

Комментарии и история

${acts || `

Пока никто не звонил

\n ${o.comps && o.comps.length ? `

Это же объявление

${o.siblings.map((x) => `${srcName(x.source)} · ${fmtMln(x.cost)} ↗`).join(\"\")}

` : \"\"}\n

Текст объявления

${esc(o.text)}

ID ${o.id} · Открыть на площадке ↗

`;\n}\nfunction phoneReqHtml(o) {\n const can = /avito\\.ru|cian\\.ru|youla\\.io|domclick\\.ru/.test(o.url || \"\");\n const pending = o.phone_req_at && Date.now() - new Date(o.phone_req_at).getTime() < 24 * 3600000 && o.phone_req_status !== \"done\";\n return `

\n ${pending ? `Номер запрошен ${fmtDT(o.phone_req_at)} · Inpars перечитывает объявление, обычно 5–10 минут, появится здесь сам` :\n can ? `Площадка скрыла телефон. Попросим Inpars перечитать объявление` :\n `Площадка не отдаёт номер — звонок через объявление ↗`}\n ${o.phone_req_status === \"done\" && !o.phones.length ? `Перечитали — номер площадка не показывает. Остаётся написать в объявлении ↗` : \"\"}\n

`;\n}\nasync function requestPhone() {\n if (!CUR) return;\n try {\n const r = await api(`/api/objects/${CUR.id}/phone`, { method: \"POST\", body: JSON.stringify({}) });\n toast(r.repeat ? \"Запрос уже отправлен, ждём Inpars\" : `Запрошено · осталось ${r.remaining ?? \"?\"} запросов в этом месяце`);\n patchLocal(CUR.id, { phone_req_at: r.at, phone_req_status: r.status });\n await openObject(CUR.id, true);\n } catch (e) { toast(e.message); }\n}\nfunction toLocalInput(iso) { const d = new Date(iso); const p = (n) => String(n).padStart(2, \"0\"); return `${d.getFullYear()}-${p(d.getMonth() + 1)}-${p(d.getDate())}T${p(d.getHours())}:${p(d.getMinutes())}`; }\n\n/* ---------- действия ---------- */\nfunction patchLocal(id, patch) {\n const o = ALL.find((x) => x.id === id); if (o) Object.assign(o, patch);\n const card = $(`.card[data-id=\"${id}\"]`); if (card && o) card.outerHTML = cardHtml(o);\n if (o) MapX.updateOne(o);\n}\nasync function setStatus(k, withDate) {\n if (!CUR) return;\n if ((k === \"recall\" || k === \"meeting\") && !withDate) { $(\"#recallRow\").classList.remove(\"hidden\"); $(\"#recallLbl\").textContent = k === \"meeting\" ? \"Дата встречи\" : \"Перезвонить\"; const inp = $(\"#recallAt\"); if (!inp.value) { const d = new Date(Date.now() + 86400000); d.setHours(11, 0, 0, 0); inp.value = toLocalInput(d.toISOString()); } inp.focus(); return; }\n const comment = $(\"#cText\").value.trim();\n const body = { status: k, comment };\n if (k === \"recall\" || k === \"meeting\") { const v = $(\"#recallAt\").value; if (!v) return toast(\"Укажи дату и время\"); body.recall_at = new Date(v).toISOString(); }\n // оптимистично подсвечиваем выбранный статус сразу\n $$(\".stgrid button\").forEach((b) => b.classList.toggle(\"on\", b.getAttribute(\"onclick\").includes(`'${k}'`)));\n try {\n const r = await api(`/api/objects/${CUR.id}/status`, { method: \"POST\", body: JSON.stringify(body) });\n const now = new Date().toISOString();\n patchLocal(CUR.id, { status: k, assignee_id: r.assignee_id, assignee_name: r.assignee_name, recall_at: body.recall_at || null, status_at: now });\n toast(\"Статус: \" + st(k).label);\n refreshBoot();\n if (MODE === \"list\" && $(\"#autoNext\")?.checked && (st(k).done || k === \"noanswer\")) { const n = nextAfter(CUR.id, 1); if (n) { await openObject(n.id); return; } }\n Object.assign(CUR, { status: k, assignee_id: r.assignee_id, assignee_name: r.assignee_name, recall_at: body.recall_at || null, status_at: now });\n CUR.activity = CUR.activity || [];\n CUR.activity.push({ id: -Date.now(), kind: \"status\", broker_id: USER.id, broker_name: USER.name, text: st(k).label + (body.recall_at ? \" · \" + fmtDT(body.recall_at) : \"\"), created_at: now });\n if (comment) CUR.activity.push({ id: -Date.now() - 1, kind: \"comment\", broker_id: USER.id, broker_name: USER.name, text: comment, created_at: now });\n renderDrawer();\n } catch (e) { toast(e.message); }\n}\nasync function assign(body) {\n if (!CUR) return;\n try {\n const r = await api(`/api/objects/${CUR.id}/assign`, { method: \"POST\", body: JSON.stringify(body) });\n patchLocal(CUR.id, { assignee_id: r.assignee_id, assignee_name: r.assignee_name, status: r.status });\n toast(body.release ? \"Снято\" : r.assignee_id === USER.id ? \"Теперь это твой объект\" : \"Назначено: \" + r.assignee_name);\n await openObject(CUR.id, true); refreshBoot();\n } catch (e) { toast(e.message); }\n}\nfunction assignMenu() {\n openModal(`

Назначить брокера

${BOOT.brokers.map((b) => ``).join(\"\")}

`);\n}\nasync function addComment() {\n const t = $(\"#cText\").value.trim(); if (!t || !CUR) return;\n try { await api(`/api/objects/${CUR.id}/comment`, { method: \"POST\", body: JSON.stringify({ text: t }) }); $(\"#cText\").value = \"\"; await openObject(CUR.id, true); toast(\"Сохранено\"); } catch (e) { toast(e.message); }\n}\n\n/* ---------- модалки ---------- */\nfunction openModal(html) { $(\"#mbox\").innerHTML = html; $(\"#modal\").classList.remove(\"hidden\"); }\nfunction closeModal() { $(\"#modal\").classList.add(\"hidden\"); }\n$(\"#modal\").addEventListener(\"click\", (e) => { if (e.target.id === \"modal\") closeModal(); });\n\nasync function openFeed() {\n openModal(`

Лента команды

`);\n try {\n const j = await api(\"/api/feed\");\n $(\".feed\").innerHTML = j.items.length ? j.items.map((a) => `

\n ${a.kind === \"system\" ? `₽` : `${initials(a.broker_name)}`}\n

${esc(a.text)}

${a.kind === \"system\" ? \"Система\" : esc(a.broker_name)} · ${fmtDT(a.created_at)} · ${fmtMln(a.cost)}, ${esc(a.address)}

`).join(\"\") : `

Пока пусто

`;\n } catch (e) { toast(e.message); }\n}\n\nasync function openSettings() {\n openModal(`

Сбор данных

`);\n try {\n const [s, runs, inp] = await Promise.all([api(\"/api/settings\"), api(\"/api/runs\"), api(\"/api/inpars\").catch((e) => ({ error: e.message }))]);\n const v = s.settings, sub = inp.data && inp.data[0];\n $(\"#setBody\").innerHTML = `\n

Inpars: ${sub ? `${esc(sub.subscribe)} до ${fmtDT(sub.endTime)}` : `${esc(inp.error || \"нет подписки\")}`} · Сбор каждую минуту, пока приложение у кого-то открыто; крон-страховка раз в 15 минут

Цена от, ₽

Цена до, ₽ (пусто = без верха)

Разделы

Тип жилья

Источники (пусто = все)

Скрывать без обновлений, дней

Ключ Яндекс.Карт (JavaScript API)

Выгрузить CSV

Последние сборы с новыми данными${runs.items.filter((r) => r.fetched > 0 || r.error).slice(0, 15).map((r) => `

${fmtDT(r.started_at)}${r.trigger}получено ${r.fetched} · новых ${r.inserted} · обновлено ${r.updated}${r.price_changes ? \" · цена ↕ \" + r.price_changes : \"\"}${r.error ? `${esc(r.error)}` : \"\"}

`).join(\"\")}

`;\n } catch (e) { toast(e.message); }\n}\nasync function exportCsv() {\n try { const r = await fetch(\"/api/export.csv\", { headers: { \"x-pin\": PIN } }); const b = await r.blob(); const a = document.createElement(\"a\"); a.href = URL.createObjectURL(b); a.download = \"sobstvenniki.csv\"; a.click(); } catch (e) { toast(e.message); }\n}\nasync function saveSettings() {\n const body = {}; [\"cost_min\", \"cost_max\", \"section_ids\", \"is_new\", \"source_ids\", \"retention_days\", \"yandex_key\"].forEach((k) => body[k] = $(\"#s_\" + k).value.trim());\n try { await api(\"/api/settings\", { method: \"POST\", body: JSON.stringify(body) }); toast(\"Сохранено\"); if (body.yandex_key !== (BOOT.yandexKey || \"\")) setTimeout(() => location.reload(), 600); } catch (e) { toast(e.message); }\n}\nasync function runSync(days) {\n toast(\"Собираю…\");\n try { const r = await api(\"/api/sync\", { method: \"POST\", body: JSON.stringify(days ? { days } : {}) }); toast(`Готово: +${r.inserted} новых, ${r.updated} обновлено`); closeModal(); await refreshBoot(); await reload(); } catch (e) { toast(\"Ошибка сбора: \" + e.message); }\n}\n\n/* ---------- мобильный лист (свайп панели) ---------- */\nfunction initSheet() {\n const h = $(\"#handle\"), p = $(\"#panel\"); if (!h) return;\n let y0 = 0;\n const states = [\"peek\", \"\", \"full\"];\n const cur = () => p.classList.contains(\"full\") ? 2 : p.classList.contains(\"peek\") ? 0 : 1;\n const set = (i) => { p.classList.remove(\"full\", \"peek\"); if (states[i]) p.classList.add(states[i]); };\n h.addEventListener(\"touchstart\", (e) => { y0 = e.touches[0].clientY; }, { passive: true });\n h.addEventListener(\"touchend\", (e) => { const dy = e.changedTouches[0].clientY - y0; if (dy < -30) set(Math.min(2, cur() + 1)); else if (dy > 30) set(Math.max(0, cur() - 1)); else set(cur() === 2 ? 1 : 2); });\n h.addEventListener(\"click\", () => set(cur() === 0 ? 1 : cur() === 1 ? 2 : 0));\n}\n\n/* ---------- init ---------- */\n(function init() {\n PIN = localStorage.getItem(\"uo_pin\") || \"\";\n try { USER = JSON.parse(localStorage.getItem(\"uo_user\") || \"null\"); } catch { USER = null; }\n if (PIN && USER) start(); else $(\"#loginView\").classList.remove(\"hidden\");\n})();\n",[],[134,201],"72324fce-ff5e-4482-a3f4-38a222ac77dc","app.css","38f6278e-b013-11f1-b238-1607ee4eb77e",75,["D",1789403324620],10,":root {\n --bg: #f3f4f8; --card: #ffffff; --ink: #14162a; --mut: #6f7590; --line: rgba(20,22,42,.08);\n --acc: #5b5bd6; --acc2: #8b5cf6; --ok: #10b981; --no: #ef4444; --warn: #f59e0b;\n --glass: rgba(255,255,255,.74); --glassBorder: rgba(255,255,255,.7);\n --shadow: 0 10px 30px rgba(20,22,42,.10), 0 1px 2px rgba(20,22,42,.06); --shadow2: 0 24px 60px rgba(20,22,42,.22);\n --fieldBg: rgba(20,22,42,.05); --toastBg: #14162a; --toastInk: #fff;\n --panelW: 450px; --drawerW: 540px; --gap: 12px;\n color-scheme: light;\n}\nhtml[data-theme=\"dark\"] {\n --bg: #0b0c16; --card: #171929; --ink: #eceefb; --mut: #8d93b4; --line: rgba(255,255,255,.08);\n --acc: #7c6cff; --acc2: #a78bfa;\n --glass: rgba(20,21,38,.72); --glassBorder: rgba(255,255,255,.08);\n --shadow: 0 10px 30px rgba(0,0,0,.45), 0 1px 2px rgba(0,0,0,.4); --shadow2: 0 24px 60px rgba(0,0,0,.65);\n --fieldBg: rgba(255,255,255,.06); --toastBg: #2a2c48; --toastInk: #eceefb;\n color-scheme: dark;\n}\n* { box-sizing: border-box; -webkit-tap-highlight-color: transparent; }\nhtml, body { height: 100%; margin: 0; }\nbody { font-family: Inter, -apple-system, \"Segoe UI\", Roboto, sans-serif; background: var(--bg); color: var(--ink); font-size: 14px; line-height: 1.4; overflow: hidden; -webkit-font-smoothing: antialiased; }\nbutton, input, select, textarea { font: inherit; color: inherit; }\nbutton { cursor: pointer; border: 0; background: none; padding: 0; }\na { color: var(--acc); text-decoration: none; }\nsvg { width: 18px; height: 18px; fill: none; stroke: currentColor; stroke-width: 1.9; stroke-linecap: round; stroke-linejoin: round; }\n.hidden { display: none !important; }\n.glass { background: var(--glass); backdrop-filter: blur(20px) saturate(1.5); -webkit-backdrop-filter: blur(20px) saturate(1.5); border: 1px solid var(--glassBorder); box-shadow: var(--shadow); }\n\n/* ---------- login ---------- */\n.login { min-height: 100dvh; display: grid; place-items: center; padding: 20px; background: radial-gradient(1200px 600px at 20% -10%, rgba(91,91,214,.28), transparent 60%), radial-gradient(900px 500px at 100% 100%, rgba(139,92,246,.22), transparent 60%), var(--bg); }\n.lcard { width: 360px; max-width: 100%; text-align: center; padding: 34px 28px 26px; border-radius: 28px; background: var(--glass); backdrop-filter: blur(24px); border: 1px solid var(--glassBorder); box-shadow: var(--shadow2); }\n.logo { width: 72px; height: 72px; margin: 0 auto; border-radius: 22px; background: #15171d; display: flex; align-items: center; justify-content: center; line-height: 1; font-size: 32px; font-weight: 800; letter-spacing: -1px; color: #f7f4ef; box-shadow: 0 14px 30px rgba(0,0,0,.25); }\n.logo i, .blogo i { color: #e0402a; font-style: normal; }\n.lcard h2 { font-size: 22px; margin: 16px 0 6px; letter-spacing: -.4px; }\n.lcard p { font-size: 13px; color: var(--mut); line-height: 1.5; margin: 0; }\n.lcard input { margin: 24px auto 4px; display: block; width: 180px; text-align: center; letter-spacing: 12px; font-size: 28px; font-weight: 800; border: 0; border-bottom: 2px solid var(--line); outline: none; padding: 6px 0; background: transparent; caret-color: var(--acc); }\n.lcard input:focus { border-color: var(--acc); }\n.lerr { color: var(--no); font-size: 12px; font-weight: 600; margin-top: 10px; min-height: 16px; }\n.lcard .go { width: 100%; background: linear-gradient(135deg, var(--acc), var(--acc2)); color: #fff; padding: 14px; border-radius: 14px; font-size: 15px; font-weight: 700; margin-top: 12px; box-shadow: 0 10px 24px rgba(91,91,214,.35); transition: transform .15s; }\n.lcard .go:active { transform: scale(.98); }\n.lcard small { display: block; margin-top: 16px; font-size: 11.5px; color: var(--mut); }\n\n/* ---------- frame ---------- */\n.app { position: fixed; inset: 0; }\n.map { position: absolute; inset: 0; background: var(--bg); }\nhtml[data-theme=\"dark\"] .map .leaflet-tile-pane, html[data-theme=\"dark\"] .map [class*=\"ground-pane\"] { filter: invert(1) hue-rotate(190deg) brightness(.82) contrast(.92) saturate(.5); }\n\n.top { position: absolute; top: var(--gap); left: var(--gap); right: var(--gap); height: 58px; z-index: 40; display: flex; align-items: center; gap: 14px; padding: 0 12px 0 14px; border-radius: 18px; }\n.brand { display: flex; align-items: center; gap: 9px; font-weight: 800; letter-spacing: -.3px; font-size: 15px; }\n.blogo { width: 30px; height: 30px; border-radius: 9px; background: #15171d; display: flex; align-items: center; justify-content: center; line-height: 1; font-weight: 800; color: #f7f4ef; }\n.stats { display: flex; gap: 6px; }\n.stat { background: var(--fieldBg); border-radius: 999px; padding: 6px 12px; font-size: 12px; font-weight: 600; white-space: nowrap; color: var(--mut); cursor: pointer; transition: background .15s; }\n.stat:hover { background: rgba(91,91,214,.12); }\n.stat b { color: var(--ink); font-weight: 800; margin-left: 4px; }\n.stat.warn { background: rgba(245,158,11,.16); color: #b45309; } .stat.warn b { color: #b45309; }\n.sync { margin-left: auto; font-size: 11.5px; color: var(--mut); white-space: nowrap; display: flex; align-items: center; gap: 6px; }\n.sync b { color: var(--ink); font-weight: 700; }\n.dot { width: 8px; height: 8px; border-radius: 50%; background: #34d399; box-shadow: 0 0 0 0 rgba(52,211,153,.6); animation: beat 2s infinite; }\n.dot.bad { background: #f87171; animation: none; }\n@keyframes beat { 0% { box-shadow: 0 0 0 0 rgba(52,211,153,.6); } 70% { box-shadow: 0 0 0 7px rgba(52,211,153,0); } 100% { box-shadow: 0 0 0 0 rgba(52,211,153,0); } }\n.hact { display: flex; align-items: center; gap: 6px; }\n.ibtn { width: 36px; height: 36px; border-radius: 11px; display: grid; place-items: center; color: var(--ink); background: var(--fieldBg); transition: background .15s, transform .15s; }\n.ibtn:hover { background: rgba(91,91,214,.14); color: var(--acc); }\n.ibtn:active { transform: scale(.94); }\n.who { font-size: 12px; font-weight: 700; background: linear-gradient(135deg, var(--acc), var(--acc2)); color: #fff; padding: 8px 12px; border-radius: 999px; white-space: nowrap; }\n\n/* ---------- panel ---------- */\n.panel { position: absolute; top: calc(var(--gap) * 2 + 58px); right: var(--gap); bottom: var(--gap); width: var(--panelW); z-index: 30; border-radius: 22px; display: flex; flex-direction: column; overflow: hidden; }\n.handle { display: none; }\n.filters { padding: 12px 12px 8px; border-bottom: 1px solid var(--line); }\n.srow { display: flex; gap: 8px; }\n.search { flex: 1; display: flex; align-items: center; gap: 8px; background: var(--fieldBg); border-radius: 12px; padding: 0 12px; min-width: 0; border: 1px solid transparent; transition: border-color .15s, background .15s; }\n.search:focus-within { border-color: var(--acc); background: var(--card); }\n.search svg { color: var(--mut); flex: 0 0 auto; }\n.search input { flex: 1; border: 0; background: transparent; outline: none; padding: 10px 0; min-width: 0; }\n.selbox { background: var(--fieldBg); border: 1px solid transparent; border-radius: 12px; padding: 0 10px; font-size: 12.5px; font-weight: 600; max-width: 150px; outline: none; }\n.chips { display: flex; gap: 6px; margin-top: 10px; overflow-x: auto; scrollbar-width: none; }\n.chips::-webkit-scrollbar { display: none; }\n.chips button, .fchips button { background: var(--fieldBg); border-radius: 999px; padding: 7px 12px; font-size: 12.5px; font-weight: 600; white-space: nowrap; color: var(--mut); transition: background .15s, color .15s; }\n.chips button:hover, .fchips button:hover { color: var(--ink); }\n.chips button.on, .fchips button.on { background: var(--ink); color: var(--bg); }\nhtml[data-theme=\"dark\"] .chips button.on, html[data-theme=\"dark\"] .fchips button.on { background: #fff; color: #14162a; }\n.chips .more { margin-left: auto; }\n.chips .more span:not(:empty) { background: var(--acc); color: #fff; border-radius: 999px; padding: 0 6px; margin-left: 4px; font-size: 11px; }\n.zones { display: flex; gap: 6px; flex-wrap: wrap; margin-top: 8px; }\n.zones:empty { display: none; }\n.zones button { display: inline-flex; align-items: center; gap: 6px; background: var(--fieldBg); border-radius: 999px; padding: 6px 10px 6px 8px; font-size: 12px; font-weight: 600; color: var(--mut); }\n.zones button i { width: 9px; height: 9px; border-radius: 3px; display: inline-block; }\n.zones button.on { background: rgba(91,91,214,.14); color: var(--acc); }\n.zones button s { text-decoration: none; opacity: .5; margin-left: 2px; font-weight: 800; }\n.zones button s:hover { opacity: 1; color: var(--no); }\n.adv { padding-top: 6px; }\n.fgrp { margin-top: 10px; }\n.fgrp label { display: block; font-size: 10.5px; text-transform: uppercase; letter-spacing: .6px; color: var(--mut); font-weight: 700; margin-bottom: 6px; }\n.fchips { display: flex; flex-wrap: wrap; gap: 5px; }\n.fchips button { padding: 5px 10px; font-size: 12px; }\n.fchips button i { width: 8px; height: 8px; border-radius: 50%; display: inline-block; margin-right: 6px; }\n.range { display: flex; align-items: center; gap: 8px; color: var(--mut); }\n.range input { width: 96px; background: var(--fieldBg); border: 1px solid transparent; border-radius: 10px; padding: 7px 10px; outline: none; }\n.range input:focus { border-color: var(--acc); }\n.row2 { display: flex; gap: 16px; }\n.chk { display: flex !important; align-items: center; gap: 7px; text-transform: none !important; letter-spacing: 0 !important; font-size: 12.5px !important; color: var(--ink) !important; font-weight: 600 !important; margin: 0 !important; }\n.chk input { accent-color: var(--acc); }\n.lnk { color: var(--acc); font-size: 12px; font-weight: 600; padding: 6px 0 2px; }\n.listhead { display: flex; justify-content: space-between; align-items: center; gap: 8px; padding: 6px 16px 4px; font-size: 11.5px; color: var(--mut); font-weight: 600; }\n.focus { display: inline-flex; align-items: center; gap: 6px; background: rgba(91,91,214,.12); color: var(--acc); border-radius: 999px; padding: 4px 10px; font-weight: 700; }\n.focus b { cursor: pointer; font-size: 14px; line-height: 1; }\n.list { flex: 1; overflow-y: auto; padding: 4px 10px 16px; }\n.list::-webkit-scrollbar { width: 6px; } .list::-webkit-scrollbar-thumb { background: var(--line); border-radius: 3px; }\n\n/* ---------- card ---------- */\n.card { display: grid; grid-template-columns: 104px 1fr; gap: 12px; background: var(--card); border-radius: 18px; padding: 8px; margin-bottom: 8px; cursor: pointer; position: relative; border: 1.5px solid transparent; box-shadow: 0 1px 2px rgba(20,22,42,.05); transition: transform .18s, box-shadow .18s, border-color .18s; }\n.card:hover { transform: translateY(-1px); box-shadow: var(--shadow); }\n.card.sel { border-color: var(--acc); box-shadow: 0 0 0 4px rgba(91,91,214,.14); }\n.card.done { opacity: .6; }\n.card .ph { width: 104px; height: 92px; border-radius: 13px; background: var(--fieldBg) center/cover no-repeat; position: relative; overflow: hidden; }\n.card .ph .n { position: absolute; right: 5px; bottom: 5px; background: rgba(0,0,0,.55); color: #fff; font-size: 10px; font-weight: 600; padding: 2px 6px; border-radius: 7px; backdrop-filter: blur(4px); }\n.card .ph .src { position: absolute; left: 5px; top: 5px; font-size: 9px; font-weight: 800; padding: 2px 6px; border-radius: 7px; color: #fff; text-transform: uppercase; letter-spacing: .3px; }\n.src.cian { background: #0468ff; } .src.avito { background: #e0402a; } .src.yandex { background: #f2c94c; color: #111 !important; } .src.domclick { background: #2fb85c; } .src.youla { background: #6d28d9; }\n.card .c { min-width: 0; display: flex; flex-direction: column; gap: 3px; padding: 2px 2px 2px 0; }\n.card .price { display: flex; align-items: baseline; gap: 8px; }\n.card .price b { font-size: 17px; font-weight: 800; letter-spacing: -.4px; }\n.card .price s { color: var(--mut); font-size: 12px; }\n.card .price .m2 { color: var(--mut); font-size: 11.5px; margin-left: auto; white-space: nowrap; font-weight: 500; }\n.card .t { font-weight: 600; font-size: 13px; white-space: nowrap; overflow: hidden; text-overflow: ellipsis; }\n.card .a { color: var(--mut); font-size: 12px; white-space: nowrap; overflow: hidden; text-overflow: ellipsis; }\n.card .foot { display: flex; align-items: center; gap: 6px; margin-top: auto; flex-wrap: wrap; }\n.pill { display: inline-flex; align-items: center; gap: 5px; font-size: 11px; font-weight: 700; padding: 3px 9px; border-radius: 999px; background: var(--fieldBg); color: var(--ink); white-space: nowrap; }\n.pill i { width: 7px; height: 7px; border-radius: 50%; display: inline-block; }\n.pill.flag { background: rgba(245,158,11,.16); color: #b45309; }\n.pill.warnr { background: rgba(239,68,68,.12); color: #dc2626; }\n.pill.ok { background: rgba(16,185,129,.14); color: #059669; }\n.pill.ghost { background: transparent; color: var(--mut); padding-left: 0; font-weight: 500; }\n.ava { width: 22px; height: 22px; border-radius: 50%; background: linear-gradient(135deg, var(--acc), var(--acc2)); color: #fff; font-size: 9.5px; font-weight: 800; display: inline-grid; place-items: center; flex: 0 0 auto; }\n.age { margin-left: auto; color: var(--mut); font-size: 11px; white-space: nowrap; font-weight: 500; }\n.age.hot { color: var(--ok); font-weight: 700; }\n.empty { text-align: center; color: var(--mut); padding: 40px 20px; font-size: 13px; }\n.skel { height: 108px; border-radius: 18px; margin-bottom: 8px; background: linear-gradient(90deg, var(--fieldBg) 25%, rgba(255,255,255,.35) 50%, var(--fieldBg) 75%); background-size: 200% 100%; animation: shimmer 1.2s infinite; }\n@keyframes shimmer { 0% { background-position: 200% 0; } 100% { background-position: -200% 0; } }\n\n/* ---------- map tools ---------- */\n.mtools { position: absolute; left: var(--gap); top: calc(var(--gap) * 2 + 58px); z-index: 30; display: flex; flex-direction: row; gap: 8px; align-items: flex-start; }\n.drawer:not(.hidden) ~ .mtools { display: none; }\n.mbtn { height: 40px; min-width: 40px; padding: 0 12px; border-radius: 12px; display: inline-flex; align-items: center; gap: 8px; font-weight: 700; font-size: 12.5px; color: var(--ink); transition: background .15s; }\n.mbtn:hover { color: var(--acc); }\n.mbtn.on { background: var(--acc); color: #fff; border-color: transparent; }\n.drawhint { position: absolute; top: calc(var(--gap) * 2 + 58px); left: 50%; transform: translateX(-50%); z-index: 35; border-radius: 12px; padding: 10px 14px; font-size: 12.5px; color: var(--ink); white-space: nowrap; }\n.drawhint button { margin-left: 10px; color: var(--no); font-weight: 700; }\n.leaflet-container { font: inherit; background: var(--bg); }\n.leaflet-control-zoom { border: 0 !important; box-shadow: var(--shadow) !important; border-radius: 12px !important; overflow: hidden; }\n.leaflet-control-zoom a { background: var(--glass) !important; color: var(--ink) !important; border: 0 !important; backdrop-filter: blur(12px); }\n.leaflet-tooltip { border-radius: 12px; border: 0; box-shadow: var(--shadow); background: var(--card); color: var(--ink); font: inherit; font-size: 12px; padding: 8px 10px; }\n.leaflet-tooltip-top:before { border-top-color: var(--card); }\n.leaflet-top { top: calc(var(--gap) * 2 + 58px) !important; }\n.leaflet-left { left: var(--gap) !important; }\n.leaflet-top { top: calc(var(--gap) * 2 + 58px + 50px) !important; }\n.mk { position: relative; width: 26px; height: 26px; border-radius: 50%; border: 2.5px solid rgba(255,255,255,.9); box-shadow: 0 3px 10px rgba(0,0,0,.22); opacity: .78; display: grid; place-items: center; color: #fff; font-size: 10px; font-weight: 800; transition: transform .12s; cursor: pointer; }\n.mk:hover, .mk.sel { opacity: 1; }\n.mk.sel { transform: scale(1.35); border-color: var(--ink); }\n.mk.fresh::after { content: \"\"; position: absolute; inset: -7px; border-radius: 50%; border: 2px solid currentColor; opacity: .6; animation: ring 1.6s ease-out infinite; }\n@keyframes ring { 0% { transform: scale(.6); opacity: .8; } 100% { transform: scale(1.35); opacity: 0; } }\n.cl { min-width: 36px; height: 36px; padding: 0 9px; border-radius: 999px; background: rgba(20,22,42,.82); color: #fff; font-weight: 800; font-size: 12px; display: grid; place-items: center; border: 2.5px solid #fff; box-shadow: 0 4px 12px rgba(0,0,0,.28); cursor: pointer; }\nhtml[data-theme=\"dark\"] .cl { background: rgba(255,255,255,.88); color: #14162a; }\n.leaflet-div-icon { background: transparent; border: 0; }\n\n/* ---------- drawer ---------- */\n.drawer { position: absolute; top: calc(var(--gap) * 2 + 58px); left: var(--gap); bottom: var(--gap); width: var(--drawerW); max-width: calc(100% - var(--gap) * 2); z-index: 50; border-radius: 22px; display: flex; flex-direction: column; overflow: hidden; animation: slidein .22s ease-out; }\n@keyframes slidein { from { transform: translateX(-24px); opacity: 0; } to { transform: none; opacity: 1; } }\n.dhead { display: flex; align-items: center; gap: 10px; padding: 10px 12px; border-bottom: 1px solid var(--line); }\n.dtitle { flex: 1; font-weight: 800; font-size: 15px; white-space: nowrap; overflow: hidden; text-overflow: ellipsis; letter-spacing: -.2px; }\n.dbody { flex: 1; overflow-y: auto; padding: 12px 14px 40px; }\n.dbody::-webkit-scrollbar { width: 6px; } .dbody::-webkit-scrollbar-thumb { background: var(--line); border-radius: 3px; }\n.gal { display: flex; gap: 6px; overflow-x: auto; scroll-snap-type: x mandatory; border-radius: 16px; scrollbar-width: none; }\n.gal::-webkit-scrollbar { display: none; }\n.gal img { height: 230px; border-radius: 14px; scroll-snap-align: start; flex: 0 0 auto; background: var(--fieldBg); object-fit: cover; max-width: 92%; }\n.gal img[data-broken] { display: none; }\n.dprice { display: flex; align-items: baseline; gap: 10px; margin: 14px 0 2px; flex-wrap: wrap; }\n.dprice b { font-size: 28px; font-weight: 800; letter-spacing: -.8px; }\n.dprice .m2 { color: var(--mut); font-size: 13px; font-weight: 500; }\n.delta { font-size: 12px; font-weight: 700; padding: 3px 9px; border-radius: 999px; }\n.delta.down { background: rgba(16,185,129,.14); color: #059669; } .delta.up { background: rgba(239,68,68,.12); color: #dc2626; }\n.daddr { font-size: 15px; font-weight: 700; letter-spacing: -.2px; }\n.dsub { color: var(--mut); font-size: 12.5px; margin-top: 3px; }\n.flags { display: flex; flex-wrap: wrap; gap: 6px; margin: 10px 0 12px; }\n.grid { display: grid; grid-template-columns: repeat(3, 1fr); gap: 8px; margin: 0 0 12px; }\n.kv { background: var(--card); border-radius: 14px; padding: 9px 11px; }\n.kv small { display: block; color: var(--mut); font-size: 10px; text-transform: uppercase; letter-spacing: .5px; font-weight: 700; }\n.kv b { font-size: 14px; font-weight: 700; }\n.sec { background: var(--card); border-radius: 18px; padding: 14px; margin-bottom: 10px; }\n.sec h4 { margin: 0 0 10px; font-size: 10.5px; text-transform: uppercase; letter-spacing: .6px; color: var(--mut); font-weight: 700; }\n.phone { display: flex; align-items: center; gap: 10px; }\n.phone a { font-size: 22px; font-weight: 800; letter-spacing: -.4px; color: var(--ink); }\n.phone .call { margin-left: auto; background: var(--ok); color: #fff; border-radius: 13px; padding: 11px 16px; font-weight: 800; box-shadow: 0 8px 20px rgba(16,185,129,.3); }\n.phone .nop { color: var(--mut); font-size: 13px; }\n.own { display: flex; align-items: center; gap: 8px; }\n.own .big { flex: 1; border-radius: 13px; padding: 13px; font-weight: 800; font-size: 14px; background: linear-gradient(135deg, var(--acc), var(--acc2)); color: #fff; box-shadow: 0 8px 20px rgba(91,91,214,.3); transition: transform .12s; }\n.own .big:active { transform: scale(.98); }\n.own .big.taken { background: var(--fieldBg); color: var(--ink); box-shadow: none; }\n.own .rel { background: var(--fieldBg); border-radius: 13px; padding: 13px 14px; font-weight: 700; color: var(--mut); }\n.stgrid { display: grid; grid-template-columns: repeat(2, 1fr); gap: 6px; }\n.stgrid button { background: var(--fieldBg); border-radius: 12px; padding: 10px 11px; text-align: left; font-weight: 700; font-size: 12.5px; display: flex; align-items: center; gap: 9px; border: 1.5px solid transparent; transition: background .15s, border-color .15s; }\n.stgrid button:hover { background: rgba(91,91,214,.1); }\n.stgrid button i { width: 10px; height: 10px; border-radius: 50%; flex: 0 0 auto; }\n.stgrid button.on { border-color: var(--acc); background: rgba(91,91,214,.12); }\n.recall { display: flex; gap: 8px; margin-top: 8px; align-items: center; }\n.recall input { background: var(--fieldBg); border: 1px solid transparent; border-radius: 11px; padding: 9px; outline: none; }\n.recall button { background: var(--acc); color: #fff; border-radius: 11px; padding: 10px 14px; font-weight: 700; }\n.cform { display: flex; gap: 8px; }\n.cform textarea { flex: 1; background: var(--fieldBg); border: 1px solid transparent; border-radius: 12px; padding: 10px 12px; resize: vertical; min-height: 44px; outline: none; }\n.cform textarea:focus { border-color: var(--acc); }\n.cform button { background: var(--acc); color: #fff; border-radius: 12px; padding: 0 16px; font-weight: 800; }\n.act { display: flex; gap: 10px; padding: 9px 0; border-top: 1px solid var(--line); font-size: 13px; }\n.act:first-of-type { border-top: 0; }\n.act .sys { width: 22px; height: 22px; border-radius: 50%; background: var(--fieldBg); display: grid; place-items: center; font-size: 11px; flex: 0 0 auto; }\n.act .w { flex: 1; min-width: 0; }\n.act .m { color: var(--mut); font-size: 11px; margin-top: 2px; }\n.act .st { font-weight: 700; }\n.txt { white-space: pre-wrap; font-size: 13px; line-height: 1.55; }\n.txt.clip { max-height: 120px; overflow: hidden; position: relative; cursor: pointer; }\n.txt.clip:after { content: \"Показать полностью\"; position: absolute; left: 0; right: 0; bottom: 0; padding-top: 40px; text-align: center; color: var(--acc); font-weight: 600; font-size: 12px; background: linear-gradient(transparent, var(--card) 60%); }\n.sib a { display: block; padding: 6px 0; font-weight: 600; }\n.scrim { position: absolute; inset: 0; background: rgba(10,10,20,.35); z-index: 45; backdrop-filter: blur(2px); }\n\n/* ---------- modal / toast ---------- */\n.modal { position: fixed; inset: 0; background: rgba(10,10,20,.45); z-index: 200; display: grid; place-items: center; padding: 16px; backdrop-filter: blur(3px); }\n.mbox { border-radius: 22px; width: 580px; max-width: 100%; max-height: 90vh; overflow-y: auto; padding: 20px; }\n.mbox h3 { margin: 0 0 14px; font-size: 17px; display: flex; align-items: center; justify-content: space-between; letter-spacing: -.3px; }\n.mbox .frm { display: grid; grid-template-columns: 1fr 1fr; gap: 10px; }\n.mbox .frm label { font-size: 10.5px; color: var(--mut); text-transform: uppercase; letter-spacing: .5px; font-weight: 700; display: block; }\n.mbox .frm input, .mbox .frm select { width: 100%; background: var(--fieldBg); border: 1px solid transparent; border-radius: 11px; padding: 9px 11px; margin-top: 4px; outline: none; }\n.mbox .frm input:focus { border-color: var(--acc); }\n.mbox .btns { display: flex; gap: 8px; margin-top: 14px; flex-wrap: wrap; }\n.btn { border-radius: 12px; padding: 11px 16px; font-weight: 800; background: var(--acc); color: #fff; }\n.btn.sec2 { background: var(--fieldBg); color: var(--ink); }\n.runs { font-size: 12px; margin-top: 14px; }\n.runs div { display: flex; gap: 10px; padding: 6px 0; border-top: 1px solid var(--line); }\n.runs .err { color: var(--no); }\n.feed .act { cursor: pointer; border-radius: 10px; padding: 9px 6px; }\n.feed .act:hover { background: var(--fieldBg); }\n.toast { position: fixed; left: 50%; bottom: 24px; transform: translateX(-50%) translateY(20px); background: var(--toastBg); color: var(--toastInk); padding: 11px 18px; border-radius: 14px; font-weight: 600; font-size: 13px; opacity: 0; transition: .2s; z-index: 300; pointer-events: none; box-shadow: var(--shadow2); }\n.toast.show { opacity: 1; transform: translateX(-50%); }\n.tabs { display: none; }\n\n/* ---------- mobile ---------- */\n\n\n/* ---------- режимы: карта / обзвон ---------- */\n.seg { display: inline-flex; background: var(--fieldBg); border-radius: 12px; padding: 3px; gap: 2px; }\n.seg button { padding: 6px 12px; border-radius: 9px; font-size: 12.5px; font-weight: 700; color: var(--mut); }\n.seg button.on { background: var(--card); color: var(--ink); box-shadow: 0 1px 3px rgba(20,22,42,.12); }\n.listpill { position: absolute; right: var(--gap); top: calc(var(--gap) * 2 + 58px); z-index: 31; border-radius: 14px; padding: 10px 14px; font-weight: 700; font-size: 13px; color: var(--ink); display: inline-flex; align-items: center; gap: 8px; }\n.listpill:hover { color: var(--acc); }\n.listpill b { background: var(--acc); color: #fff; border-radius: 999px; padding: 1px 8px; font-size: 12px; }\n.app.panel-open .listpill, .app.mode-list .listpill { display: none; }\n.app.mode-map:not(.panel-open) .panel { display: none; }\n.chk.auto { font-size: 11.5px !important; margin-left: auto !important; color: var(--mut) !important; }\n.app.mode-map .chk.auto { display: none !important; }\n.app.mode-list #fitBtn, .app.mode-list #panelClose { display: none; }\n.app.mode-list .map, .app.mode-list .mtools, .app.mode-list .drawhint { display: none !important; }\n.app.mode-list { background: var(--bg); }\n.app.mode-list .card, .app.mode-my .card { grid-template-columns: 120px 1fr auto; }\n.app.mode-list .card .ph, .app.mode-my .card .ph { width: 120px; height: 100px; }\n.app.mode-list .quick, .app.mode-my .quick { display: flex; flex-direction: column; gap: 6px; justify-content: center; padding-right: 4px; }\n.card .quick { display: none; }\n.quick a, .quick button { border-radius: 10px; padding: 8px 12px; font-size: 12px; font-weight: 700; white-space: nowrap; text-align: center; }\n.quick .tel { background: var(--ok); color: #fff; }\n.quick .tel.no { background: var(--fieldBg); color: var(--mut); }\n.quick .open { background: var(--fieldBg); color: var(--ink); }\n.card .num { position: absolute; left: -2px; top: -2px; background: var(--ink); color: var(--bg); font-size: 10px; font-weight: 800; padding: 2px 7px; border-radius: 8px 0 8px 0; display: none; }\n.app.mode-list .card .num { display: block; }\n.callbar { display: none; align-items: center; gap: 10px; padding: 8px 12px; border-bottom: 1px solid var(--line); font-size: 12.5px; color: var(--mut); }\n.app.mode-list .callbar { display: flex; }\n.callbar .btn { padding: 9px 14px; font-size: 13px; }\n.callbar .prog { flex: 1; height: 6px; background: var(--fieldBg); border-radius: 3px; overflow: hidden; }\n.callbar .prog i { display: block; height: 100%; background: linear-gradient(90deg, var(--acc), var(--acc2)); width: 0; transition: width .3s; }\n.phreq { display: flex; align-items: center; gap: 10px; flex-wrap: wrap; }\n.phreq button { background: var(--acc); color: #fff; border-radius: 12px; padding: 10px 14px; font-weight: 800; }\n.phreq .wait { color: var(--mut); font-size: 12.5px; }\n.mk { position: absolute; left: -13px; top: -13px; }\n.cl { position: absolute; left: -18px; top: -18px; }\n.map.drawing { cursor: crosshair; touch-action: none; }\n\n\n/* ---------- фильтр-панель ---------- */\n.fbtn { height: 40px; min-width: 40px; padding: 0 10px; border-radius: 12px; background: var(--fieldBg); display: inline-flex; align-items: center; gap: 6px; color: var(--ink); font-weight: 700; }\n.fbtn span:not(:empty) { background: var(--acc); color: #fff; border-radius: 999px; padding: 0 7px; font-size: 11px; }\n.mytabs, .mybrokers { display: none; }\n.app.mode-my .mytabs { display: flex; }\n.app.mode-my .mybrokers:not(:empty) { display: flex; }\n.app.mode-my #quick, .app.mode-my .callbar { display: none; }\n.fdrawer { position: absolute; top: calc(var(--gap) * 2 + 58px); right: var(--gap); bottom: var(--gap); width: 400px; max-width: calc(100% - var(--gap) * 2); z-index: 80; border-radius: 22px; display: flex; flex-direction: column; overflow: hidden; animation: slidein .2s ease-out; }\n.fbody { flex: 1; overflow-y: auto; padding: 12px 14px; }\n.fsec { margin-bottom: 14px; }\n.fsec label.t { display: block; font-size: 10.5px; text-transform: uppercase; letter-spacing: .6px; color: var(--mut); font-weight: 700; margin-bottom: 7px; }\n.fsec .presets { display: flex; gap: 5px; flex-wrap: wrap; margin-bottom: 6px; }\n.ffoot { display: flex; align-items: center; gap: 10px; padding: 10px 14px; border-top: 1px solid var(--line); }\n.ffoot span { flex: 1; text-align: center; font-size: 12px; color: var(--mut); font-weight: 600; }\n.tog { display: flex; align-items: center; justify-content: space-between; padding: 9px 0; border-top: 1px solid var(--line); font-size: 13px; font-weight: 600; }\n.tog:first-of-type { border-top: 0; }\n.sw { position: relative; width: 40px; height: 24px; border-radius: 12px; background: var(--fieldBg); transition: background .15s; flex: 0 0 auto; }\n.sw i { position: absolute; top: 3px; left: 3px; width: 18px; height: 18px; border-radius: 50%; background: #fff; box-shadow: 0 1px 3px rgba(0,0,0,.25); transition: left .15s; }\n.sw.on { background: var(--acc); } .sw.on i { left: 19px; }\n\n/* ---------- master-detail: обзвон и «мои» ---------- */\n/* без выбранного объекта список занимает всю ширину; с выбранным — 56 / 44 */\n.app.mode-list .panel, .app.mode-my .panel { left: var(--gap); right: var(--gap); transform: none; width: auto; transition: right .2s; }\n.app.mode-list.has-drawer .panel, .app.mode-my.has-drawer .panel { right: calc(44% + var(--gap) * .5); }\n.app.mode-list .drawer, .app.mode-my .drawer { left: auto; right: var(--gap); width: calc(44% - var(--gap) * 1.5); display: none !important; }\n.app.mode-list.has-drawer .drawer, .app.mode-my.has-drawer .drawer { display: flex !important; }\n.app.mode-list .list, .app.mode-my .list { display: grid; grid-template-columns: repeat(auto-fill, minmax(460px, 1fr)); gap: 8px; align-content: start; }\n.app.mode-list .card, .app.mode-my .card { margin-bottom: 0; }\n.app.mode-list.has-drawer .list, .app.mode-my.has-drawer .list { grid-template-columns: 1fr; }\n/* фильтр открывается над списком: в обзвоне список слева */\n.app.mode-list .fdrawer, .app.mode-my .fdrawer { right: auto; left: var(--gap); }\n.app.mode-my .map, .app.mode-my .mtools, .app.mode-my .drawhint, .app.mode-my .listpill { display: none !important; }\n.drawer.empty { display: none !important; }\n.dempty { flex: 1; display: grid; place-items: center; color: var(--mut); text-align: center; padding: 30px; font-size: 14px; line-height: 1.6; }\n.dempty b { display: block; font-size: 30px; margin-bottom: 6px; }\n.drawer.empty .dhead, .drawer.empty .dbody { display: none; }\n.drawer:not(.empty) .dempty { display: none; }\n.dnav { display: flex; gap: 4px; }\n.app.mode-map .dnav { display: none; }\n.act .del { margin-left: auto; color: var(--mut); font-size: 14px; padding: 0 4px; opacity: 0; transition: opacity .15s; align-self: flex-start; }\n.act:hover .del { opacity: 1; }\n.act .del:hover { color: var(--no); }\n\n/* ---------- галерея ---------- */\n.galw { position: relative; }\n.galw .g-arr { position: absolute; top: 50%; transform: translateY(-50%); width: 40px; height: 40px; border-radius: 50%; background: rgba(20,22,42,.45); color: #fff; font-size: 24px; line-height: 1; display: grid; place-items: center; opacity: 0; transition: opacity .15s; backdrop-filter: blur(4px); z-index: 2; }\n.galw .g-arr.l { left: 8px; } .galw .g-arr.r { right: 8px; }\n.galw:hover .g-arr { opacity: .9; }\n.galw .g-cnt { position: absolute; right: 10px; bottom: 10px; background: rgba(20,22,42,.55); color: #fff; font-size: 11px; font-weight: 700; padding: 3px 8px; border-radius: 8px; backdrop-filter: blur(4px); }\n.gal img { cursor: zoom-in; }\n.lightbox { position: fixed; inset: 0; background: rgba(8,9,20,.72); z-index: 400; display: grid; place-items: center; padding: 24px; backdrop-filter: blur(6px); }\n.lbox { position: relative; width: min(1100px, 92vw); height: min(82vh, 820px); background: #0f1020; border-radius: 22px; overflow: hidden; display: flex; flex-direction: column; box-shadow: var(--shadow2); }\n.lbox img { flex: 1; min-height: 0; width: 100%; object-fit: contain; background: #0f1020; }\n.lb-x { position: absolute; right: 12px; top: 12px; width: 38px; height: 38px; border-radius: 50%; background: rgba(255,255,255,.14); color: #fff; font-size: 16px; z-index: 3; }\n.lb-arr { position: absolute; top: 50%; transform: translateY(-50%); width: 48px; height: 48px; border-radius: 50%; background: rgba(255,255,255,.14); color: #fff; font-size: 34px; line-height: 1; display: grid; place-items: center; z-index: 3; }\n.lb-arr:hover { background: rgba(255,255,255,.3); }\n.lb-arr.l { left: 14px; } .lb-arr.r { right: 14px; }\n.lb-thumbs { display: flex; gap: 6px; padding: 10px; overflow-x: auto; background: #0f1020; scrollbar-width: none; }\n.lb-thumbs img { width: 76px; height: 56px; object-fit: cover; border-radius: 8px; opacity: .5; cursor: pointer; flex: 0 0 auto; }\n.lb-thumbs img.on { opacity: 1; outline: 2px solid var(--acc2); }\n\n\n.saved:empty { display: none; }\n.saved button.on, .saved button { background: rgba(212,160,23,.14); color: #8a6a0a; }\n.saved button s { text-decoration: none; opacity: .5; margin-left: 4px; font-weight: 800; }\n.card.excl { border-color: #d4a017; box-shadow: 0 0 0 3px rgba(212,160,23,.18); }\n.comps a { display: grid; grid-template-columns: 1fr auto auto; gap: 10px; padding: 7px 0; border-top: 1px solid var(--line); color: var(--ink); font-size: 12.5px; align-items: center; }\n.comps a:first-of-type { border-top: 0; }\n.comps a b { font-weight: 800; } .comps a small { color: var(--mut); }\n.comps .cur { background: rgba(91,91,214,.08); border-radius: 8px; padding: 7px 8px; }\n.bell.on { color: var(--ok); }\n.zlist label { display: flex; align-items: center; gap: 8px; padding: 8px 0; border-top: 1px solid var(--line); font-weight: 600; }\n.zlist label:first-of-type { border-top: 0; }\n.zlist input { accent-color: var(--acc); }\n\n#moreBtn { display: none; }\n/* =================== МОБИЛЬНАЯ РАСКЛАДКА =================== */\n@media (max-width: 860px) {\n :root { --gap: 8px; }\n .top { height: 52px; gap: 8px; padding: 0 8px 0 10px; }\n .bname, .sync, .top .stats, .top .hact .who, .top .hact > .ibtn:not(#moreBtn) { display: none; }\n .seg { flex: 1; justify-content: stretch; }\n .seg button { flex: 1; padding: 7px 4px; font-size: 12.5px; text-align: center; }\n #moreBtn { display: grid !important; }\n .listpill, .tabs, .listhead #panelClose, .listhead #fitBtn { display: none !important; }\n\n /* карта: список — нижняя шторка */\n .app.mode-map .panel { display: flex !important; top: auto; left: 0; right: 0; bottom: 0; width: auto; border-radius: 22px 22px 0 0; height: 50dvh; transition: height .25s ease; }\n .app.mode-map .panel.full { height: calc(100dvh - 60px); }\n .app.mode-map .panel.peek { height: 132px; }\n .app.mode-map .panel.peek .list, .app.mode-map .panel.peek .listhead, .app.mode-map .panel.peek .zones, .app.mode-map .panel.peek .saved { display: none; }\n .handle { display: grid; place-items: center; padding: 8px 0 2px; cursor: grab; touch-action: none; }\n .handle i { width: 40px; height: 5px; border-radius: 3px; background: var(--line); }\n .filters { padding: 4px 10px 8px; }\n .srow { gap: 6px; }\n .selbox { max-width: 120px; font-size: 12px; }\n .chips { margin-top: 8px; }\n .mtools { top: calc(var(--gap) * 2 + 52px); left: var(--gap); }\n .drawhint { top: calc(var(--gap) * 2 + 52px); white-space: normal; text-align: center; max-width: 92%; font-size: 12px; }\n\n /* обзвон и мои: список на весь экран, карточка — шторка сверху */\n .app.mode-list .panel, .app.mode-my .panel, .app.mode-list.has-drawer .panel, .app.mode-my.has-drawer .panel { top: calc(var(--gap) * 2 + 52px); left: 0; right: 0; bottom: 0; width: auto; border-radius: 22px 22px 0 0; }\n .app.mode-list .list, .app.mode-my .list { display: block; }\n .app.mode-list .card, .app.mode-my .card { grid-template-columns: 96px 1fr; margin-bottom: 8px; }\n .app.mode-list .card .ph, .app.mode-my .card .ph { width: 96px; height: 92px; }\n .app.mode-list .quick, .app.mode-my .quick { flex-direction: row; grid-column: 1 / -1; padding: 0; }\n .quick a, .quick button { flex: 1; }\n .callbar { padding: 8px 10px; gap: 8px; font-size: 11.5px; }\n .callbar .btn { padding: 8px 10px; font-size: 12px; }\n .card { grid-template-columns: 88px 1fr; gap: 10px; }\n .card .ph { width: 88px; height: 84px; }\n .card .price b { font-size: 16px; }\n .card .foot { gap: 5px; }\n .card .foot .pill { font-size: 10.5px; padding: 2px 7px; }\n\n /* карточка объекта — на весь экран поверх всего */\n .drawer, .app.mode-list .drawer, .app.mode-my .drawer, .app.mode-list.has-drawer .drawer, .app.mode-my.has-drawer .drawer { top: calc(var(--gap) + 52px); left: 0; right: 0; bottom: 0; width: auto; max-width: none; border-radius: 22px 22px 0 0; animation: slideup .22s ease-out; z-index: 70; }\n .app.mode-list .drawer:not(.hidden), .app.mode-my .drawer:not(.hidden) { display: flex !important; }\n @keyframes slideup { from { transform: translateY(30px); opacity: 0; } to { transform: none; opacity: 1; } }\n .scrim { display: none !important; }\n .dnav { display: flex; }\n .dbody { padding: 10px 12px 90px; }\n .gal img { height: 200px; }\n .dprice b { font-size: 24px; }\n .grid { grid-template-columns: repeat(2, 1fr); }\n .stgrid { grid-template-columns: repeat(2, 1fr); }\n .stgrid button { padding: 12px 10px; font-size: 13px; }\n .phone .call { padding: 12px 16px; }\n .own .big { padding: 14px; }\n\n /* фильтр и модалки — во весь экран */\n .fdrawer, .app.mode-list .fdrawer, .app.mode-my .fdrawer { top: calc(var(--gap) + 52px); left: 0; right: 0; bottom: 0; width: auto; max-width: none; border-radius: 22px 22px 0 0; z-index: 90; }\n .modal { padding: 0; align-items: end; }\n .mbox { width: 100%; max-height: 92vh; border-radius: 22px 22px 0 0; padding: 16px; }\n .mbox .frm { grid-template-columns: 1fr; }\n .lbox { width: 100vw; height: 100dvh; border-radius: 0; }\n .lightbox { padding: 0; }\n .lb-thumbs img { width: 60px; height: 44px; }\n .toast { bottom: 20px; width: max-content; max-width: 92vw; }\n}\n",[],[134,210],["D",1789373202685],[168,169,170,171,172],[134],"a7ef0950-9fa9-402e-8591-7ca1d135f5e9","push.ts","19b550e0-b057-11f1-9064-1607ee4eb77e",72,["D",1789402356500],"script","// Web-push уведомления брокерам: новые собственники в выбранных зонах, напоминания о перезвоне/встрече,\n// передача объекта. Ключи VAPID — в переменных окружения.\nimport webpush from \"npm:web-push@3.6.7\";\nimport { nowIso, parseJson, sqlite } from \"./db.ts\";\n\nconst PUB = Deno.env.get(\"VAPID_PUBLIC_KEY\") || \"\";\nconst PRIV = Deno.env.get(\"VAPID_PRIVATE_KEY\") || \"\";\nlet configured = false;\nfunction setup() {\n if (configured || !PUB || !PRIV) return configured;\n webpush.setVapidDetails(\"mailto:tambovtsev007@gmail.com\", PUB, PRIV);\n configured = true;\n return true;\n}\nexport const vapidPublic = () => PUB;\n\nexport async function migratePush() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS push_subs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n broker_id INTEGER NOT NULL, broker_name TEXT, endpoint TEXT UNIQUE, sub TEXT NOT NULL,\n zones TEXT, all_new INTEGER DEFAULT 0, created_at TEXT, last_ok TEXT, fails INTEGER DEFAULT 0\n )`,\n `CREATE INDEX IF NOT EXISTS idx_push_broker ON push_subs(broker_id)`,\n ]);\n}\n\nexport async function saveSub(brokerId: number, brokerName: string, sub: any, zones: number[], allNew: boolean) {\n await sqlite.execute({\n sql: `INSERT INTO push_subs(broker_id, broker_name, endpoint, sub, zones, all_new, created_at) VALUES(?,?,?,?,?,?,?)\n ON CONFLICT(endpoint) DO UPDATE SET broker_id=excluded.broker_id, broker_name=excluded.broker_name, sub=excluded.sub, zones=excluded.zones, all_new=excluded.all_new, fails=0`,\n args: [brokerId, brokerName, String(sub.endpoint), JSON.stringify(sub), JSON.stringify(zones || []), allNew ? 1 : 0, nowIso()],\n });\n}\nexport async function dropSub(endpoint: string) { await sqlite.execute({ sql: \"DELETE FROM push_subs WHERE endpoint=?\", args: [endpoint] }); }\nexport async function subsFor(brokerId: number) {\n const r = await sqlite.execute({ sql: \"SELECT id, zones, all_new, created_at FROM push_subs WHERE broker_id=?\", args: [brokerId] });\n return (r.rows as any[]).map((s) => ({ ...s, zones: parseJson(s.zones, []) }));\n}\n\nasync function send(row: any, payload: any) {\n if (!setup()) return false;\n try {\n await webpush.sendNotification(JSON.parse(String(row.sub)), JSON.stringify(payload), { TTL: 3600 });\n await sqlite.execute({ sql: \"UPDATE push_subs SET last_ok=?, fails=0 WHERE id=?\", args: [nowIso(), row.id] });\n return true;\n } catch (e: any) {\n const code = e?.statusCode;\n if (code === 404 || code === 410) await sqlite.execute({ sql: \"DELETE FROM push_subs WHERE id=?\", args: [row.id] });\n else await sqlite.execute({ sql: \"UPDATE push_subs SET fails=fails+1 WHERE id=?\", args: [row.id] });\n return false;\n }\n}\n\n// Уведомить конкретного брокера (все его устройства)\nexport async function notifyBroker(brokerId: number, payload: { title: string; body: string; url?: string; tag?: string }) {\n const r = await sqlite.execute({ sql: \"SELECT id, sub FROM push_subs WHERE broker_id=?\", args: [brokerId] });\n let n = 0;\n for (const row of r.rows as any[]) if (await send(row, payload)) n++;\n return n;\n}\n\nfunction inPoly(lat: number, lng: number, poly: number[][]) {\n let ins = false;\n for (let i = 0, j = poly.length - 1; i < poly.length; j = i++) {\n const [yi, xi] = poly[i], [yj, xj] = poly[j];\n if ((yi > lat) !== (yj > lat) && lng < (xj - xi) * (lat - yi) / (yj - yi) + xi) ins = !ins;\n }\n return ins;\n}\nconst fmtMln = (v: number) => (v / 1e6).toFixed(1).replace(\".0\", \"\").replace(\".\", \",\") + \" млн\";\n\n// Новые собственники: кому из подписчиков они попадают в зоны (или кто подписан на всё)\nexport async function notifyNewObjects(items: { id: number; lat: number | null; lng: number | null; cost: number; address: string; title: string }[]) {\n if (!items.length || !setup()) return;\n const [subs, zones] = await Promise.all([sqlite.execute(\"SELECT * FROM push_subs\"), sqlite.execute(\"SELECT id, name, points FROM zones\")]);\n const zmap = new Map((zones.rows as any[]).map((z) => [Number(z.id), { name: String(z.name), points: parseJson(z.points, []) }]));\n for (const s of subs.rows as any[]) {\n const zids = parseJson(s.zones, []);\n const hits: { o: any; zone?: string }[] = [];\n for (const o of items) {\n if (Number(s.all_new)) { hits.push({ o }); continue; }\n if (!o.lat || !o.lng) continue;\n for (const zid of zids) { const z = zmap.get(zid); if (z && inPoly(o.lat, o.lng, z.points)) { hits.push({ o, zone: z.name }); break; } }\n }\n if (!hits.length) continue;\n if (hits.length === 1) {\n const h = hits[0];\n await send(s, { title: h.zone ? `Новый собственник · ${h.zone}` : \"Новый собственник\", body: `${fmtMln(h.o.cost)} · ${h.o.title || h.o.address}`, url: `/?o=${h.o.id}`, tag: \"new-\" + h.o.id });\n } else {\n const zn = [...new Set(hits.map((h) => h.zone).filter(Boolean))];\n await send(s, { title: `+${hits.length} новых собственников${zn.length ? \" · \" + zn.join(\", \") : \"\"}`, body: hits.slice(0, 3).map((h) => `${fmtMln(h.o.cost)} · ${h.o.address}`).join(\"\\n\"), url: \"/?q=fresh\", tag: \"new-batch\" });\n }\n }\n}\n\n// Напоминания: перезвонить / встреча — время пришло\nexport async function notifyDue() {\n if (!setup()) return 0;\n const r = await sqlite.execute({ sql: \"SELECT id, status, assignee_id, cost, address, title, recall_at FROM objects WHERE status IN ('recall','meeting') AND recall_at IS NOT NULL AND recall_at <= ? AND COALESCE(recall_notified,0)=0 AND assignee_id IS NOT NULL LIMIT 50\", args: [nowIso()] });\n let n = 0;\n for (const o of r.rows as any[]) {\n await notifyBroker(Number(o.assignee_id), { title: o.status === \"meeting\" ? \"Встреча по объекту\" : \"Пора перезвонить\", body: `${fmtMln(Number(o.cost))} · ${o.title || o.address}`, url: `/?o=${o.id}`, tag: \"due-\" + o.id });\n await sqlite.execute({ sql: \"UPDATE objects SET recall_notified=1 WHERE id=?\", args: [o.id] });\n n++;\n }\n return n;\n}\n",[],[144,222],"5c217946-b5c7-4c1d-81c3-5e03bfaa77be","inpars.ts","380f81f8-b013-11f1-adb7-1607ee4eb77e",73,["D",1789402507637],"// Сбор объявлений собственников из Inpars API v2 и запись в базу.\n// Запускается кроном каждую минуту и вручную из интерфейса.\nimport { getSettings, nowIso, parseJson, sqlite } from \"./db.ts\";\nimport { notifyNewObjects, notifyDue } from \"./push.ts\";\n\nconst API = \"https://inpars.ru/api/v2\";\nconst EXPAND = \"category,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;\n// Застройщики и отделы продаж БЦ: Inpars считает их «собственниками», для нас это не собственник\nconst DEV_WORDS = /(от застройщика|застройщик (продаёт|продает|реализует|предлагает)|отдел продаж|рассрочк[аи] от застройщика|ипотек[аи] от застройщика|скидк[аи] до \\d+ ?%|акци[яи] до конца|бронируйте|звоните в отдел)/i;\nconst DEV_COMMERCIAL = /(застройщик|девелопер|бизнес-центр класса|бц класса|новый бизнес-центр|лоты от \\d|продажа офисов в|помещени[яй] в жк|коворкинг|апарт-отел|управляющ(ая|ей) компани|арендный поток|окупаемост)/i;\nconst OWNER_WORDS = /(собственник|без посредников|агентам не беспокоить|агентов прошу не беспокоить|риэлторов не беспокоить|услуги риэлтор[а-я]* не требуются|от хозяина|продаю сво[юй])/i;\n\nexport interface Flags { agentWords: boolean; developer: boolean; ownerWords: boolean; phoneMulti: number; noPhone: boolean; crossListed: number; fresh: boolean; }\n\nexport function computeFlags(o: { text: string; phones: number[]; ageHours: number; section_id?: number | null }, 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 developer: DEV_WORDS.test(stripped) || (o.section_id === 4 && DEV_COMMERCIAL.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.developer) s -= 35;\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_land: Number(r.sqLand) || null, 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// Задача Inpars на повторный разбор объявления (в т.ч. попытка получить телефон). Асинхронно, 5–10 минут.\nexport async function inparsTask(urls: string[], token: string) {\n const r = await fetch(API + \"/estate/task\", { method: \"POST\", headers: { Accept: \"application/json\", \"Content-Type\": \"application/json\", Authorization: \"Basic \" + btoa(token + \":\") }, body: JSON.stringify({ urls }) });\n if (!r.ok) throw new Error(`Inpars task ${r.status}: ${(await r.text()).slice(0, 300)}`);\n return r.json();\n}\n\n// ---------- основной цикл сбора ----------\n\nexport async function sync(trigger = \"cron\", opts: { token?: string; sinceOverride?: number; untilOverride?: 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 const insertedItems: any[] = [];\n try {\n // Начало окна: последний успешный запуск минус 3 минуты перекрытия, иначе 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) - 3 * 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), ...(opts.untilOverride ? { timeEnd: String(opts.untilOverride) } : {}) }, 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 if (!opts.sinceOverride) insertedItems.push(...res.insertedItems);\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, gone_at=? WHERE hidden=0 AND status IN ('new','noanswer','refused','agent','aggressive','dnc','gone') AND last_seen < ?\", args: [nowIso(), cutoff] });\n // Уведомления: новые объекты в зонах подписчиков и подошедшие напоминания\n try { await notifyNewObjects(insertedItems); await notifyDue(); } catch (e) { console.warn(\"push:\", e); }\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\n// Пакетная запись небольшими порциями; при сбое — по одному, чтобы увидеть проблемную строку.\nasync function safeBatch(stmts: any[], size: number) {\n for (let i = 0; i < stmts.length; i += size) {\n const chunk = stmts.slice(i, i + size);\n try { await sqlite.batch(chunk); }\n catch (e) {\n for (const st of chunk) {\n try { await sqlite.execute(st); }\n catch (e2) { throw new Error(`SQL fail: ${String(st.sql).slice(0, 60)} :: ${String((e2 as any)?.message || e2)} :: args=${JSON.stringify(st.args).slice(0, 300)}`); }\n }\n }\n }\n}\n\nasync function upsertBatch(items: ReturnType[], s: Record) {\n let inserted = 0, updated = 0, priceChanges = 0;\n const insertedItems: any[] = [];\n if (!items.length) return { inserted, updated, priceChanges, insertedItems };\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 safeBatch(phoneStmts, 100);\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, section_id: it.section_id }, 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 if (!dupOf && !(flags.agentWords || flags.developer || flags.phoneMulti >= 3)) insertedItems.push({ id: it.id, lat: it.lat, lng: it.lng, cost: it.cost, address: it.address, title: it.title });\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_land, 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, suspect, 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_land, 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), (flags.agentWords || flags.developer || flags.phoneMulti >= 3) ? 1 : 0, 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 const hadPhone = ex.phones && ex.phones !== \"[]\" && ex.phones !== \"null\";\n if (!hadPhone && it.phones.length) stmts.push({ sql: \"INSERT INTO activity(object_id, kind, text, created_at) VALUES(?,?,?,?)\", args: [it.id, \"system\", \"Получен телефон собственника\", now] });\n stmts.push({\n sql: `UPDATE objects SET category=?, rooms=?, url=?, title=?, address=?, district=?, metro=?, floor=?, floors=?, sq=?, sq_land=?, sq_living=?, sq_kitchen=?, cost=?, cost_m2=?, text=?, images=?, lat=?, lng=?, name=?, phones=?,\n source_updated=?, updated=?, last_seen=?, hidden=0, score=?, flags=?, suspect=?, phone_req_status=CASE WHEN ? THEN 'done' ELSE phone_req_status END\n ${changed ? \", cost_prev=?, cost_changed_at=?\" : \"\"} WHERE id=?`,\n args: [it.category, it.rooms, it.url, it.title, it.address, it.district, it.metro, it.floor, it.floors, it.sq, it.sq_land, 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), (flags.agentWords || flags.developer || flags.phoneMulti >= 3) ? 1 : 0, it.phones.length ? 1 : 0, ...(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 await safeBatch(stmts, 40);\n return { inserted, updated, priceChanges, insertedItems };\n}\n",[],[144,231],"6b983279-9f79-46a5-bc42-8b77b3a50996",["D",1789403967921],15,[],[144,33],"4fad3e1d-b11b-4de6-89f1-316da1c7045c","db.ts","37957692-b013-11f1-8804-1607ee4eb77e",64,["D",1789402351928],7,"// База данных парсера собственников 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 exclusive: { label: \"Эксклюзив\", color: \"#d4a017\" },\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 INDEX IF NOT EXISTS idx_objects_vis ON objects(hidden, dup_of, status)`,\n `CREATE INDEX IF NOT EXISTS idx_objects_assignee ON objects(assignee_id)`,\n `CREATE INDEX IF NOT EXISTS idx_activity_broker ON activity(broker_id, kind)`,\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 ]);\n // Миграции колонок — идемпотентно\n for (const col of [\"sq_land REAL\", \"phone_req_at TEXT\", \"phone_req_status TEXT\", \"suspect INTEGER DEFAULT 0\", \"recall_notified INTEGER DEFAULT 0\", \"gone_at TEXT\"]) {\n try { await sqlite.execute(`ALTER TABLE objects ADD COLUMN ${col}`); } catch { /* уже есть */ }\n }\n await sqlite.batch([\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 zones (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL, points TEXT NOT NULL, color TEXT,\n created_by INTEGER, created_by_name TEXT, created_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,4,5\", // жилая + коммерческая + загородная\n cost_min: \"30000000\",\n cost_max: \"\",\n source_ids: \"\", // пусто = все источники Inpars\n is_new: \"\", // '' = всё, 0 = вторичка, 1 = новостройки\n backfill_days: \"60\", // глубина первого сбора\n retention_days: \"75\", // скрывать объекты, не обновлявшиеся дольше\n yandex_key: \"\", // ключ Яндекс.Карт (JavaScript API); пусто = карта OpenStreetMap\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",[],[144,244],"5fbe9c83-5e0d-4301-8fba-16d891b03c74","cron.ts","387ae42a-b013-11f1-9446-1607ee4eb77e",22,["D",1789379435606],"interval","// Крон сбора — страховка на случай, когда приложение ни у кого не открыто (на free-тарифе Val Town\n// минимум раз в 15 минут; на Pro можно * * * * *). Пока кто-то работает в интерфейсе, сбор идёт\n// каждую минуту через /api/pulse. Inpars отдаёт только изменившееся, запуск занимает секунды.\nimport { migrate, sqlite, nowIso } from \"./db.ts\";\nimport { sync } from \"./inpars.ts\";\nimport { syncBrokers } from \"./auth.ts\";\n\nexport default async function () {\n await migrate();\n // Список брокеров из воронки обновляем раз в час, а не каждую минуту\n const b = await sqlite.execute(\"SELECT MAX(synced_at) t FROM brokers\");\n const t = (b.rows[0] as any)?.t ? new Date(String((b.rows[0] as any).t)).getTime() : 0;\n if (Date.now() - t > 3600_000) await syncBrokers().catch((e) => console.warn(\"brokers sync:\", e));\n const r = await sync(\"cron\");\n // Журнал запусков не копим бесконечно: пустые старше суток и любые старше 14 дней\n await sqlite.batch([\n { sql: \"DELETE FROM runs WHERE fetched=0 AND error IS NULL AND started_at < ?\", args: [new Date(Date.now() - 86400_000).toISOString()] },\n { sql: \"DELETE FROM runs WHERE started_at < ?\", args: [new Date(Date.now() - 14 * 86400_000).toISOString()] },\n ]);\n if (r.fetched) console.log(\"sync\", r);\n return r;\n}\n",[],[144,253],"75391e84-27fc-4b3e-bd38-580217124b24","auth.ts","37cb20e4-b013-11f1-9622-1607ee4eb77e",["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",[],[144,262],["D",1789373200842],[161,162,163,164,165,166],[144],["D",1789373200178],["D",1789547455787],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":56,"_105":106,"_107":25},{"_13":89,"_32":90,"_44":43,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":46,"_98":99},"ctx",{"_82":-5,"_128":309,"_310":311,"_312":313,"_314":25,"_315":25,"_316":25,"_317":59,"_318":-5,"_319":-7,"_320":-7,"_321":63,"_322":25,"_323":25,"_324":-5,"_325":25,"_326":25,"_327":25,"_328":-5},"ENV",{"_280":281,"_282":283,"_284":90,"_285":286,"_287":288,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304,"_305":306,"_307":308},"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"]

Собственники

Уведомления ✕

${esc(USER.role === \"boss\" ? \"Руководитель\" : USER.name)} ✕

Собственник

Кто ведёт

Статус звонка

Комментарии и история

Похожие у собственников · м. ${esc(o.metro)}

Это же объявление

Текст объявления

Назначить брокера ✕

Лента команды ✕

Сбор данных ✕

Уведомления

${esc(USER.role === \"boss\" ? \"Руководитель\" : USER.name)}

Назначить брокера

Лента команды

Сбор данных

Diff · v78