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

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_247":248,"_249":250},"routes/_app.x.$handle.$name",{"_101":100,"_32":46,"_110":91,"_27":111,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_20":-5,"_122":-5,"_123":-5,"_124":25,"_125":126,"_127":60,"_128":-5,"_129":-5,"_130":131},"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":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":25},"version",39,"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/inpars.ts","latestPath","fileId","380f81f8-b013-11f1-adb7-1607ee4eb77e","name","inpars.ts","fileType","script","content","// Сбор объявлений собственников из Inpars API v2 и запись в базу.\n// Запускается кроном каждую минуту и вручную из интерфейса.\nimport { getSettings, nowIso, parseJson, sqlite } from \"./db.ts\";\n\nconst API = \"https://inpars.ru/api/v2\";\nconst EXPAND = \"district,metro,rooms,isNew,history,parseId,isApartments,sourceCreated,sourceUpdated,house,repairType\";\n\n// ---------- чистые функции (тестируются отдельно) ----------\n\nconst ADDR_STOP = new Set([\"москва\",\"россия\",\"г\",\"город\",\"ул\",\"улица\",\"пр-т\",\"просп\",\"проспект\",\"пер\",\"переулок\",\"б-р\",\"бул\",\"бульвар\",\"ш\",\"шоссе\",\"наб\",\"набережная\",\"пл\",\"площадь\",\"проезд\",\"пр-д\",\"д\",\"дом\",\"к\",\"корп\",\"корпус\",\"стр\",\"строение\",\"с\",\"вл\",\"владение\",\"район\",\"р-н\",\"округ\",\"ао\",\"нао\",\"тинао\",\"зао\",\"цао\",\"сзао\",\"сао\",\"свао\",\"вао\",\"ювао\",\"юао\",\"юзао\"]);\nexport function normAddress(a: string): string {\n const toks = (a || \"\").toLowerCase().replace(/ё/g, \"е\").split(/[^a-zа-я0-9]+/).filter((t) => t && !ADDR_STOP.has(t));\n return toks.sort().join(\" \");\n}\n\nexport function dupKey(o: { address: string; sq: number; rooms: number | null; floor: number | null }): string {\n const a = normAddress(o.address);\n if (!a) return \"\";\n return `${a}|${Math.round(o.sq || 0)}|${o.rooms ?? \"?\"}|${o.floor ?? \"?\"}`;\n}\n\nconst AGENT_WORDS = /(агентств[оа] недвижимости|наш(а|е|и)? (компани|агентств|риэлтор|риелтор|специалист)|риэлторск(ие|их) услуг|комиссия покупател|без комиссии для|подбер(ём|ем) (вам|для вас)|ипотечн(ый|ого) брокер|поможем (с )?(ипотек|продать)|более \\d+ (лет|объектов)|в нашей базе|эксклюзив от|официальн(ый|ого) партн)/i;\nconst OWNER_WORDS = /(собственник|без посредников|агентам не беспокоить|агентов прошу не беспокоить|риэлторов не беспокоить|услуги риэлтор[а-я]* не требуются|от хозяина|продаю сво[юй])/i;\n\nexport interface Flags { agentWords: boolean; ownerWords: boolean; phoneMulti: number; noPhone: boolean; crossListed: number; fresh: boolean; }\n\nexport function computeFlags(o: { text: string; phones: number[]; ageHours: number }, phoneCount: number, siblings: number): Flags {\n const t = o.text || \"\";\n const owner = OWNER_WORDS.test(t);\n const stripped = t.replace(OWNER_WORDS, \" \");\n return {\n agentWords: AGENT_WORDS.test(stripped),\n ownerWords: owner,\n phoneMulti: phoneCount,\n noPhone: !o.phones || o.phones.length === 0,\n crossListed: siblings,\n fresh: o.ageHours < 24,\n };\n}\n\nexport function computeScore(o: { cost: number; images: string[]; text: string }, f: Flags): number {\n let s = 50;\n if (!f.noPhone) s += 15;\n if (f.fresh) s += 10;\n if (f.crossListed >= 1) s += 10;\n if ((o.images || []).length >= 6) s += 5;\n if (f.ownerWords) s += 8;\n if ((o.text || \"\").length > 400) s += 3;\n if (o.cost >= 50_000_000) s += 5;\n if (f.agentWords) s -= 25;\n if (f.phoneMulti >= 3) s -= 30;\n else if (f.phoneMulti === 2) s -= 10;\n return Math.max(0, Math.min(100, s));\n}\n\nexport function normalize(r: any) {\n const phones: number[] = Array.isArray(r.phones) ? r.phones.filter((p: any) => p) : [];\n const images: string[] = Array.isArray(r.images) ? r.images : [];\n const sq = Number(r.sq) || 0;\n const cost = Number(r.cost) || 0;\n return {\n id: Number(r.id),\n source: r.source || \"\", source_id: r.sourceId ?? null, parse_id: r.parseId ? String(r.parseId) : null,\n url: r.url || \"\",\n type_ad: r.typeAd ?? null, section_id: r.sectionId ?? null, category_id: r.categoryId ?? null,\n category: r.category || null, rooms: r.rooms ?? null,\n title: r.title || \"\", address: r.address || \"\", district: r.district || \"\", metro: r.metro || \"\",\n floor: r.floor ?? null, floors: r.floors ?? null,\n sq, sq_living: r.sqLiving ?? null, sq_kitchen: r.sqKitchen ?? null,\n cost, cost_m2: sq > 0 ? Math.round(cost / sq) : null,\n text: r.text || \"\", images, lat: Number(r.lat) || null, lng: Number(r.lng) || null,\n name: r.name || \"\", phones,\n agent: r.agent ?? 0, is_new: r.isNew ? 1 : 0, is_apartments: r.isApartments ? 1 : 0,\n build_year: r.house?.buildYear ?? null, repair_type: r.repairType ?? null,\n source_created: r.sourceCreated || null, source_updated: r.sourceUpdated || null,\n created: r.created || null, updated: r.updated || null,\n history: Array.isArray(r.history) ? r.history : [],\n };\n}\n\nexport function fmtMln(v: number) { return (v / 1_000_000).toFixed(1).replace(\".0\", \"\").replace(\".\", \",\") + \" млн\"; }\n\n// ---------- HTTP к Inpars ----------\n\nasync function inparsGet(path: string, params: Record, token: string) {\n const u = new URL(API + path);\n for (const [k, v] of Object.entries(params)) if (v !== \"\" && v != null) u.searchParams.set(k, v);\n const r = await fetch(u, { headers: { Accept: \"application/json\", Authorization: \"Basic \" + btoa(token + \":\") } });\n if (r.status === 429) {\n const wait = Number(r.headers.get(\"X-Rate-Limit-Reset\") || \"20\");\n await new Promise((res) => setTimeout(res, Math.min(wait, 60) * 1000));\n return inparsGet(path, params, token);\n }\n if (!r.ok) throw new Error(`Inpars ${r.status}: ${(await r.text()).slice(0, 300)}`);\n return r.json();\n}\n\nexport async function inparsSubscription(token: string) {\n return inparsGet(\"/user/subscribe\", {}, token);\n}\n\n// ---------- основной цикл сбора ----------\n\nexport async function sync(trigger = \"cron\", opts: { token?: string; sinceOverride?: number; 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 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 const total = Number(j.meta?.totalCount || 0);\n if (rows.length === 0 || rows.length < 1000 || total <= rows.length) break;\n const lastUpd = rows[rows.length - 1].updated;\n const next = Math.floor(new Date(lastUpd).getTime() / 1000);\n if (!next || next <= timeStart) break;\n timeStart = next;\n await new Promise((r) => setTimeout(r, 6500)); // 10 запросов в минуту\n }\n\n // Скрываем объекты, которые давно не обновлялись на источнике (сняты с продажи).\n const cutoff = new Date(Date.now() - Number(s.retention_days || 60) * 86400000).toISOString();\n await sqlite.execute({ sql: \"UPDATE objects SET hidden=1 WHERE hidden=0 AND status IN ('new','noanswer') AND last_seen < ?\", args: [cutoff] });\n\n await sqlite.execute({\n sql: \"UPDATE runs SET finished_at=?, fetched=?, inserted=?, updated=?, price_changes=? WHERE id=?\",\n args: [nowIso(), fetched, inserted, updated, priceChanges, runId],\n });\n return { runId, fetched, inserted, updated, priceChanges };\n } catch (e) {\n await sqlite.execute({ sql: \"UPDATE runs SET finished_at=?, fetched=?, inserted=?, updated=?, error=? WHERE id=?\", args: [nowIso(), fetched, inserted, updated, String((e as Error).message || e), runId] });\n throw e;\n }\n}\n\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 if (!items.length) return { inserted, updated, priceChanges };\n const now = nowIso();\n\n // Существующие записи одним запросом\n const ids = items.map((i) => i.id);\n const existing = new Map();\n for (let i = 0; i < ids.length; i += 400) {\n const chunk = ids.slice(i, i + 400);\n const r = await sqlite.execute({ sql: `SELECT id, cost, status, first_seen, cost_first, dup_key, phones FROM objects WHERE id IN (${chunk.map(() => \"?\").join(\",\")})`, args: chunk });\n for (const row of r.rows as any[]) existing.set(Number(row.id), row);\n }\n\n // Учёт телефонов: сколько разных объектов у номера\n const phoneStmts: any[] = [];\n for (const it of items) {\n if (existing.has(it.id)) continue;\n for (const p of it.phones) {\n phoneStmts.push({ sql: \"INSERT INTO phone_seen(phone, objects, sources, first_seen) VALUES(?,1,?,?) ON CONFLICT(phone) DO UPDATE SET objects=objects+1\", args: [String(p), it.source, now] });\n }\n }\n if (phoneStmts.length) await 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 }, pc, siblings);\n const score = computeScore(it, flags);\n const dupOf = key && dupOwner.has(key) && dupOwner.get(key) !== it.id ? dupOwner.get(key)! : null;\n if (key && !dupOwner.has(key)) dupOwner.set(key, it.id);\n\n if (!ex) {\n inserted++;\n stmts.push({\n sql: `INSERT INTO objects(id, source, source_id, parse_id, url, type_ad, section_id, category_id, category, rooms, title, address, district, metro,\n floor, floors, sq, sq_living, sq_kitchen, cost, cost_m2, text, images, lat, lng, name, phones, agent, is_new, is_apartments, build_year, repair_type,\n source_created, source_updated, created, updated, first_seen, last_seen, cost_first, score, flags, status, status_at, dup_key, dup_of)\n VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,'new',?,?,?)`,\n args: [it.id, it.source, it.source_id, it.parse_id, it.url, it.type_ad, it.section_id, it.category_id, it.category, it.rooms, it.title, it.address, it.district, it.metro,\n it.floor, it.floors, it.sq, it.sq_living, it.sq_kitchen, it.cost, it.cost_m2, it.text, JSON.stringify(it.images), it.lat, it.lng, it.name, JSON.stringify(it.phones), it.agent, it.is_new, it.is_apartments, it.build_year, it.repair_type,\n it.source_created, it.source_updated, it.created, it.updated, now, now, it.cost, score, JSON.stringify(flags), now, key || null, dupOf],\n });\n // История цены с источника, если Inpars её отдал\n const hist = it.history.filter((h: any) => h && h.cost).map((h: any) => ({ d: h.date, c: Number(h.cost) }));\n if (hist.length > 1) {\n stmts.push({ sql: \"INSERT INTO activity(object_id, kind, text, meta, created_at) VALUES(?,?,?,?,?)\", args: [it.id, \"system\", `История цены на площадке: ${hist.map((h: any) => fmtMln(h.c)).join(\" → \")}`, JSON.stringify(hist), now] });\n }\n } else {\n updated++;\n const oldCost = Number(ex.cost);\n const changed = oldCost && it.cost && oldCost !== it.cost;\n if (changed) priceChanges++;\n const newPhones = it.phones.length ? JSON.stringify(it.phones) : ex.phones; // не терять телефон, если площадка его скрыла\n stmts.push({\n sql: `UPDATE objects SET url=?, title=?, address=?, district=?, metro=?, floor=?, floors=?, sq=?, sq_living=?, sq_kitchen=?, cost=?, cost_m2=?, text=?, images=?, lat=?, lng=?, name=?, phones=?,\n source_updated=?, updated=?, last_seen=?, hidden=0, score=?, flags=?\n ${changed ? \", cost_prev=?, cost_changed_at=?\" : \"\"} WHERE id=?`,\n args: [it.url, it.title, it.address, it.district, it.metro, it.floor, it.floors, it.sq, it.sq_living, it.sq_kitchen, it.cost, it.cost_m2, it.text, JSON.stringify(it.images), it.lat, it.lng, it.name, newPhones,\n it.source_updated, it.updated, now, score, JSON.stringify(flags), ...(changed ? [oldCost, now] : []), it.id],\n });\n if (changed) {\n const dir = it.cost < oldCost ? \"снижена\" : \"повышена\";\n stmts.push({ sql: \"INSERT INTO activity(object_id, kind, text, meta, created_at) VALUES(?,?,?,?,?)\", args: [it.id, \"system\", `Цена ${dir}: ${fmtMln(oldCost)} → ${fmtMln(it.cost)}`, JSON.stringify({ from: oldCost, to: it.cost }), now] });\n }\n }\n }\n await safeBatch(stmts, 40);\n return { inserted, updated, priceChanges };\n}\n","// Сбор объявлений собственников из Inpars API v2 и запись в базу.\n// Запускается кроном каждую минуту и вручную из интерфейса.\nimport { getSettings, nowIso, parseJson, sqlite } from \"./db.ts\";\n\nconst API = \"https://inpars.ru/api/v2\";\nconst EXPAND = \"district,metro,rooms,isNew,history,parseId,isApartments,sourceCreated,sourceUpdated,house,repairType\";\n\n// ---------- чистые функции (тестируются отдельно) ----------\n\nconst ADDR_STOP = new Set([\"москва\",\"россия\",\"г\",\"город\",\"ул\",\"улица\",\"пр-т\",\"просп\",\"проспект\",\"пер\",\"переулок\",\"б-р\",\"бул\",\"бульвар\",\"ш\",\"шоссе\",\"наб\",\"набережная\",\"пл\",\"площадь\",\"проезд\",\"пр-д\",\"д\",\"дом\",\"к\",\"корп\",\"корпус\",\"стр\",\"строение\",\"с\",\"вл\",\"владение\",\"район\",\"р-н\",\"округ\",\"ао\",\"нао\",\"тинао\",\"зао\",\"цао\",\"сзао\",\"сао\",\"свао\",\"вао\",\"ювао\",\"юао\",\"юзао\"]);\nexport function normAddress(a: string): string {\n const toks = (a || \"\").toLowerCase().replace(/ё/g, \"е\").split(/[^a-zа-я0-9]+/).filter((t) => t && !ADDR_STOP.has(t));\n return toks.sort().join(\" \");\n}\n\nexport function dupKey(o: { address: string; sq: number; rooms: number | null; floor: number | null }): string {\n const a = normAddress(o.address);\n if (!a) return \"\";\n return `${a}|${Math.round(o.sq || 0)}|${o.rooms ?? \"?\"}|${o.floor ?? \"?\"}`;\n}\n\nconst AGENT_WORDS = /(агентств[оа] недвижимости|наш(а|е|и)? (компани|агентств|риэлтор|риелтор|специалист)|риэлторск(ие|их) услуг|комиссия покупател|без комиссии для|подбер(ём|ем) (вам|для вас)|ипотечн(ый|ого) брокер|поможем (с )?(ипотек|продать)|более \\d+ (лет|объектов)|в нашей базе|эксклюзив от|официальн(ый|ого) партн)/i;\nconst OWNER_WORDS = /(собственник|без посредников|агентам не беспокоить|агентов прошу не беспокоить|риэлторов не беспокоить|услуги риэлтор[а-я]* не требуются|от хозяина|продаю сво[юй])/i;\n\nexport interface Flags { agentWords: boolean; ownerWords: boolean; phoneMulti: number; noPhone: boolean; crossListed: number; fresh: boolean; }\n\nexport function computeFlags(o: { text: string; phones: number[]; ageHours: number }, phoneCount: number, siblings: number): Flags {\n const t = o.text || \"\";\n const owner = OWNER_WORDS.test(t);\n const stripped = t.replace(OWNER_WORDS, \" \");\n return {\n agentWords: AGENT_WORDS.test(stripped),\n ownerWords: owner,\n phoneMulti: phoneCount,\n noPhone: !o.phones || o.phones.length === 0,\n crossListed: siblings,\n fresh: o.ageHours < 24,\n };\n}\n\nexport function computeScore(o: { cost: number; images: string[]; text: string }, f: Flags): number {\n let s = 50;\n if (!f.noPhone) s += 15;\n if (f.fresh) s += 10;\n if (f.crossListed >= 1) s += 10;\n if ((o.images || []).length >= 6) s += 5;\n if (f.ownerWords) s += 8;\n if ((o.text || \"\").length > 400) s += 3;\n if (o.cost >= 50_000_000) s += 5;\n if (f.agentWords) s -= 25;\n if (f.phoneMulti >= 3) s -= 30;\n else if (f.phoneMulti === 2) s -= 10;\n return Math.max(0, Math.min(100, s));\n}\n\nexport function normalize(r: any) {\n const phones: number[] = Array.isArray(r.phones) ? r.phones.filter((p: any) => p) : [];\n const images: string[] = Array.isArray(r.images) ? r.images : [];\n const sq = Number(r.sq) || 0;\n const cost = Number(r.cost) || 0;\n return {\n id: Number(r.id),\n source: r.source || \"\", source_id: r.sourceId ?? null, parse_id: r.parseId ? String(r.parseId) : null,\n url: r.url || \"\",\n type_ad: r.typeAd ?? null, section_id: r.sectionId ?? null, category_id: r.categoryId ?? null,\n category: r.category || null, rooms: r.rooms ?? null,\n title: r.title || \"\", address: r.address || \"\", district: r.district || \"\", metro: r.metro || \"\",\n floor: r.floor ?? null, floors: r.floors ?? null,\n sq, sq_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// ---------- основной цикл сбора ----------\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 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 const total = Number(j.meta?.totalCount || 0);\n if (rows.length === 0 || rows.length < 1000 || total <= rows.length) break;\n const lastUpd = rows[rows.length - 1].updated;\n const next = Math.floor(new Date(lastUpd).getTime() / 1000);\n if (!next || next <= timeStart) break;\n timeStart = next;\n await new Promise((r) => setTimeout(r, 6500)); // 10 запросов в минуту\n }\n\n // Скрываем объекты, которые давно не обновлялись на источнике (сняты с продажи).\n const cutoff = new Date(Date.now() - Number(s.retention_days || 60) * 86400000).toISOString();\n await sqlite.execute({ sql: \"UPDATE objects SET hidden=1 WHERE hidden=0 AND status IN ('new','noanswer') AND last_seen < ?\", args: [cutoff] });\n\n await sqlite.execute({\n sql: \"UPDATE runs SET finished_at=?, fetched=?, inserted=?, updated=?, price_changes=? WHERE id=?\",\n args: [nowIso(), fetched, inserted, updated, priceChanges, runId],\n });\n return { runId, fetched, inserted, updated, priceChanges };\n } catch (e) {\n await sqlite.execute({ sql: \"UPDATE runs SET finished_at=?, fetched=?, inserted=?, updated=?, error=? WHERE id=?\", args: [nowIso(), fetched, inserted, updated, String((e as Error).message || e), runId] });\n throw e;\n }\n}\n\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 if (!items.length) return { inserted, updated, priceChanges };\n const now = nowIso();\n\n // Существующие записи одним запросом\n const ids = items.map((i) => i.id);\n const existing = new Map();\n for (let i = 0; i < ids.length; i += 400) {\n const chunk = ids.slice(i, i + 400);\n const r = await sqlite.execute({ sql: `SELECT id, cost, status, first_seen, cost_first, dup_key, phones FROM objects WHERE id IN (${chunk.map(() => \"?\").join(\",\")})`, args: chunk });\n for (const row of r.rows as any[]) existing.set(Number(row.id), row);\n }\n\n // Учёт телефонов: сколько разных объектов у номера\n const phoneStmts: any[] = [];\n for (const it of items) {\n if (existing.has(it.id)) continue;\n for (const p of it.phones) {\n phoneStmts.push({ sql: \"INSERT INTO phone_seen(phone, objects, sources, first_seen) VALUES(?,1,?,?) ON CONFLICT(phone) DO UPDATE SET objects=objects+1\", args: [String(p), it.source, now] });\n }\n }\n if (phoneStmts.length) await 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 }, pc, siblings);\n const score = computeScore(it, flags);\n const dupOf = key && dupOwner.has(key) && dupOwner.get(key) !== it.id ? dupOwner.get(key)! : null;\n if (key && !dupOwner.has(key)) dupOwner.set(key, it.id);\n\n if (!ex) {\n inserted++;\n stmts.push({\n sql: `INSERT INTO objects(id, source, source_id, parse_id, url, type_ad, section_id, category_id, category, rooms, title, address, district, metro,\n floor, floors, sq, sq_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, 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), now, key || null, dupOf],\n });\n // История цены с источника, если Inpars её отдал\n const hist = it.history.filter((h: any) => h && h.cost).map((h: any) => ({ d: h.date, c: Number(h.cost) }));\n if (hist.length > 1) {\n stmts.push({ sql: \"INSERT INTO activity(object_id, kind, text, meta, created_at) VALUES(?,?,?,?,?)\", args: [it.id, \"system\", `История цены на площадке: ${hist.map((h: any) => fmtMln(h.c)).join(\" → \")}`, JSON.stringify(hist), now] });\n }\n } else {\n updated++;\n const oldCost = Number(ex.cost);\n const changed = oldCost && it.cost && oldCost !== it.cost;\n if (changed) priceChanges++;\n const newPhones = it.phones.length ? JSON.stringify(it.phones) : ex.phones; // не терять телефон, если площадка его скрыла\n stmts.push({\n sql: `UPDATE objects SET url=?, title=?, address=?, district=?, metro=?, floor=?, floors=?, sq=?, sq_land=?, sq_living=?, sq_kitchen=?, cost=?, cost_m2=?, text=?, images=?, lat=?, lng=?, name=?, phones=?,\n source_updated=?, updated=?, last_seen=?, hidden=0, score=?, flags=?\n ${changed ? \", cost_prev=?, cost_changed_at=?\" : \"\"} WHERE id=?`,\n args: [it.url, it.title, it.address, it.district, it.metro, it.floor, it.floors, it.sq, it.sq_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), ...(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 };\n}\n","createdAt",["D",1789392207972],"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","38451674-b013-11f1-bda7-1607ee4eb77e","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",{"_101":100,"_109":105},"org",{"_101":100,"_102":103,"_104":105,"_18":56,"_106":107,"_108":25},"branch",{"_13":90,"_32":91,"_44":43,"_92":45,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":46,"_99":100},"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":242,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":243,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":244,"_85":245,"_87":246,"_89":25},"tree",[161,167],"files",[161,162,163,164,165,166,167,168,169,170],"counts",{"_150":64,"_151":147,"_152":64,"_153":154,"_155":156},"contents",[132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":144,"_32":145,"_30":146,"_137":-5,"_42":43,"_41":147,"_139":60,"_39":148,"_13":64,"_34":141,"_36":-5,"_24":25,"_142":-5,"_27":149},{"_44":134,"_32":135,"_30":136,"_137":-5,"_42":43,"_41":138,"_139":60,"_39":140,"_13":64,"_34":141,"_36":-5,"_24":25,"_142":-5,"_27":143},"8618f630-060d-44e1-976f-8f3f90ea873a","frontend","472f4334-eddb-49ac-88ea-7505a2ba216d","parentId",6,"latest",["D",1789373202685],"directory","label",[135],"7341a1cc-7dfc-4e42-b726-1f50a9135807","backend","2d175de9-e314-46bc-b472-7c5eb74535c8",1,["D",1789373200842],[145],"pulls","branches","forks","envVars",{"_157":159,"_160":64},"connections",{"_157":64,"_158":64},"count","unfilledCount",3,"emptyCount",{"_44":144,"_32":145,"_30":146,"_137":-5,"_42":43,"_41":147,"_139":60,"_39":239,"_13":64,"_34":141,"_36":-5,"_24":25,"_142":-5,"_177":240,"_27":241},{"_44":232,"_32":233,"_30":234,"_137":146,"_42":43,"_41":227,"_139":60,"_39":235,"_13":64,"_34":35,"_36":236,"_24":25,"_142":-5,"_177":237,"_27":238},{"_44":222,"_32":223,"_30":224,"_137":146,"_42":43,"_41":225,"_139":60,"_39":226,"_13":227,"_34":228,"_36":229,"_24":25,"_142":-5,"_177":230,"_27":231},{"_44":214,"_32":215,"_30":216,"_137":146,"_42":43,"_41":217,"_139":25,"_39":218,"_13":159,"_34":35,"_36":219,"_24":25,"_142":-5,"_177":220,"_27":221},{"_44":205,"_32":206,"_30":58,"_137":146,"_42":43,"_41":207,"_139":25,"_39":208,"_13":209,"_34":210,"_36":211,"_24":25,"_142":-5,"_177":212,"_27":213},{"_44":201,"_32":33,"_30":31,"_137":146,"_42":43,"_41":14,"_139":25,"_39":202,"_13":194,"_34":35,"_36":38,"_24":25,"_142":-5,"_177":203,"_27":204},{"_44":134,"_32":135,"_30":136,"_137":-5,"_42":43,"_41":138,"_139":60,"_39":198,"_13":64,"_34":141,"_36":-5,"_24":25,"_142":-5,"_177":199,"_27":200},{"_44":189,"_32":190,"_30":191,"_137":136,"_42":43,"_41":192,"_139":25,"_39":193,"_13":194,"_34":20,"_36":195,"_24":25,"_142":-5,"_177":196,"_27":197},{"_44":180,"_32":181,"_30":182,"_137":136,"_42":43,"_41":183,"_139":25,"_39":184,"_13":185,"_34":20,"_36":186,"_24":25,"_142":-5,"_177":187,"_27":188},{"_44":171,"_32":172,"_30":173,"_137":136,"_42":43,"_41":174,"_139":25,"_39":175,"_13":159,"_34":20,"_36":176,"_24":25,"_142":-5,"_177":178,"_27":179},"5ac6d45d-0d00-42e2-927e-85b68c13d1b3","index.html","38ae9b58-b013-11f1-9622-1607ee4eb77e",33,["D",1789392020184],"\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","children",[],[135,172],"4b28a58c-c87f-4074-87c6-48fa439fe110","app.js","393c694c-b013-11f1-acaf-1607ee4eb77e",37,["D",1789392176719],7,"/* 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() };\nlet FOCUS = null; // объекты выбранного кластера на карте\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}\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 await MapX.init(BOOT.yandexKey);\n await reload();\n LAST_PULSE = BOOT.serverTime || new Date().toISOString();\n setInterval(pulse, 30000);\n initSheet();\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() {\n $(\"#fStatus\").innerHTML = Object.entries(BOOT.statuses).map(([k, v]) => ``).join(\"\");\n $$(\"#fStatus button\").forEach((b) => b.onclick = () => { toggleSet(F.status, b.dataset.v, b); QUICK = \"all\"; markQuick(); reload(); });\n $$(\"#fRooms button\").forEach((b) => b.onclick = () => { toggleSet(F.rooms, b.dataset.v, b); reload(); });\n $$(\"#fSource button\").forEach((b) => b.onclick = () => { toggleSet(F.source, b.dataset.v, b); reload(); });\n $$(\"#fSection button\").forEach((b) => b.onclick = () => { toggleSet(F.section, b.dataset.v, b); reload(); });\n}\nfunction renderBrokerChips() {\n $(\"#fBroker\").innerHTML = BOOT.brokers.map((b) => ``).join(\"\");\n $$(\"#fBroker button\").forEach((b) => b.onclick = () => { const v = Number(b.dataset.v); F.broker = F.broker === v ? null : v; $$(\"#fBroker button\").forEach((x) => x.classList.toggle(\"on\", Number(x.dataset.v) === F.broker)); reload(); });\n}\nfunction toggleSet(set, v, btn) { if (set.has(v)) set.delete(v); else set.add(v); btn.classList.toggle(\"on\", set.has(v)); }\nfunction toggleAdv() { $(\"#adv\").classList.toggle(\"hidden\"); }\nfunction setQuick(q) { QUICK = q; F.status.clear(); $$(\"#fStatus button\").forEach((b) => b.classList.remove(\"on\")); markQuick(); reload(); if (isMobile()) setTab(\"list\"); }\nfunction markQuick() { $$(\"#quick 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 $$(\".fchips button\").forEach((b) => b.classList.remove(\"on\"));\n $(\"#fMin\").value = \"\"; $(\"#fMax\").value = \"\"; $(\"#fPhone\").checked = false; $(\"#fUnassigned\").checked = false; $(\"#q\").value = \"\";\n renderZoneBar(); setQuick(\"all\");\n}\nfunction onSearch() { clearTimeout(searchT); searchT = setTimeout(reload, 300); }\nfunction setTab(t) {\n $(\"#app\").classList.toggle(\"tab-map\", t === \"map\");\n $$(\"#tabs button\").forEach((b) => b.classList.toggle(\"on\", b.dataset.t === t));\n if (t === \"map\") setTimeout(() => { MapX.resize(); fitAll(); }, 60);\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); 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\");\n if (isMobile()) setTab(\"map\");\n MapX.startDraw(async (points) => {\n DRAWING = false; $(\"#zoneBtn\").classList.remove(\"on\"); $(\"#drawHint\").classList.add(\"hidden\");\n if (!points || points.length < 3) { MapX.clearDraft(); return toast(\"Нужно минимум 3 точки\"); }\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\"); 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 (QUICK === \"new\") p.set(\"status\", \"new,noanswer\");\n if (QUICK === \"mine\") p.set(\"mine\", \"1\");\n if (QUICK === \"recall\") p.set(\"status\", \"recall\");\n if (QUICK === \"drop\") p.set(\"drop\", \"1\");\n if (QUICK === \"fresh\") p.set(\"fresh\", \"24\");\n if (F.status.size) p.set(\"status\", [...F.status].join(\",\"));\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.broker != null) p.set(\"broker\", F.broker);\n if ($(\"#fMin\").value) p.set(\"costMin\", Number($(\"#fMin\").value) * 1e6);\n if ($(\"#fMax\").value) p.set(\"costMax\", Number($(\"#fMax\").value) * 1e6);\n if ($(\"#fPhone\").checked) p.set(\"phone\", \"1\");\n if ($(\"#fUnassigned\").checked) p.set(\"unassigned\", \"1\");\n if ($(\"#q\").value.trim()) p.set(\"q\", $(\"#q\").value.trim());\n const n = F.status.size + F.rooms.size + F.source.size + F.section.size + (F.broker != null) + $(\"#fPhone\").checked + $(\"#fUnassigned\").checked + !!$(\"#fMin\").value + !!$(\"#fMax\").value;\n $(\"#advN\").textContent = n || \"\";\n return p.toString();\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 $(\"#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 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 return `

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

${fmtMln(o.cost)}${drop ? `~~${fmtMln(o.cost_prev)}~~` : \"\"}${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 || f.phoneMulti >= 3 ? `агент?` : \"\"}\n ${f.crossListed ? `${f.crossListed + 1} площадки` : \"\"}\n ${!o.hasPhone ? `без телефона` : \"\"}\n ${fresh ? \"новый · \" : \"\"}${ago(o.source_created || o.created || o.first_seen)}\n

`;\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 build() { Layout.superclass.build.call(this); this.getData().options.set(\"shape\", { type: \"Circle\", coordinates: [0, 0], radius: 15 }); },\n });\n const ClLayout = ymaps.templateLayoutFactory.createClass('

', {\n build() { ClLayout.superclass.build.call(this); this.getData().options.set(\"shape\", { type: \"Circle\", coordinates: [0, 0], radius: 20 }); },\n });\n this.om = new ymaps.ObjectManager({ clusterize: true, gridSize: 48, clusterDisableClickZoom: true, clusterOpenBalloonOnClick: false });\n this.om.objects.options.set({ iconLayout: Layout, iconOffset: [-13, -13], hasBalloon: false, hideIconOnBalloonOpen: false });\n this.om.clusters.options.set({ clusterIconLayout: ClLayout, clusterIconOffset: [-18, -18], hasBalloon: false });\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 },\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 },\n resize() { if (this.kind === \"ya\") this.map.container.fitToViewport(); else this.map.invalidateSize(); },\n setMarkers(items, fit) {\n if (this.kind === \"ya\") {\n this.om.removeAll();\n this.om.add({ type: \"FeatureCollection\", features: items.filter((o) => o.lat && o.lng).map((o) => {\n const s = st(o.status);\n return { type: \"Feature\", id: o.id, geometry: { type: \"Point\", coordinates: [o.lat, o.lng] }, 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 (!o.lat || !o.lng) continue;\n const s = st(o.status);\n const m = L.marker([o.lat, o.lng], { icon: L.divIcon({ className: \"\", html: `

`, iconSize: [26, 26], iconAnchor: [13, 13] }) });\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 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(); if (el) el.firstChild.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 startDraw(cb) {\n this.drawCb = cb;\n if (this.kind === \"ya\") {\n this.draft = new ymaps.Polygon([[]], {}, { fillColor: \"#5b5bd633\", strokeColor: \"#5b5bd6\", strokeWidth: 2.5, editorDrawingCursor: \"crosshair\", editorMaxPoints: 60 });\n this.map.geoObjects.add(this.draft); this.draft.editor.startDrawing();\n this.draft.editor.events.add(\"drawingstop\", () => { const pts = (this.draft.geometry.getCoordinates()[0] || []).map((p) => [p[0], p[1]]); this.draft.editor.stopEditing(); cb(pts); });\n } else {\n this.pts = []; this.draftLf = L.polygon([], { color: \"#5b5bd6\", weight: 2.5, fillOpacity: .2 }).addTo(this.zl);\n this.map.getContainer().style.cursor = \"crosshair\"; this.map.doubleClickZoom.disable();\n this._click = (e) => { this.pts.push([e.latlng.lat, e.latlng.lng]); this.draftLf.setLatLngs(this.pts); };\n this._dbl = () => { this.map.off(\"click\", this._click); this.map.off(\"dblclick\", this._dbl); this.map.getContainer().style.cursor = \"\"; this.map.doubleClickZoom.enable(); cb(this.pts.slice(0, -2)); };\n this.map.on(\"click\", this._click); this.map.on(\"dblclick\", this._dbl);\n }\n },\n cancelDraw() { if (this.kind === \"ya\" && this.draft) { this.draft.editor.stopDrawing(); this.draft.editor.stopEditing(); } if (this.kind === \"lf\") { this.map.off(\"click\", this._click); this.map.off(\"dblclick\", this._dbl); this.map.getContainer().style.cursor = \"\"; this.map.doubleClickZoom.enable(); } 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 SEL = id;\n $$(\".card\").forEach((c) => c.classList.toggle(\"sel\", Number(c.dataset.id) === id));\n MapX.highlight(id);\n $(\"#drawer\").classList.remove(\"hidden\"); if (isMobile()) $(\"#scrim\").classList.remove(\"hidden\");\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 const draft = silent ? ($(\"#cText\")?.value || \"\") : \"\";\n renderDrawer();\n if (draft) $(\"#cText\").value = draft;\n}\nfunction closeDrawer() { $(\"#drawer\").classList.add(\"hidden\"); $(\"#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.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 return `

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

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

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

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

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

`).join(\"\")}

` : \"\"}\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

В базе с${fmtDT(o.first_seen)}

Собственник

\n ${o.hidePhone ? `

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

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

${fmtPhone(p)}

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

Площадка не отдаёт номер — звонок через объявление ↗

`}\n

Кто ведёт

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

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

${statusBtns}

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

${acts || `

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

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

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

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

` : \"\"}\n

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

${esc(o.text)}

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

`;\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 MapX.setMarkers(ITEMS, false); MapX.highlight(id);\n}\nasync function setStatus(k, withDate) {\n if (!CUR) return;\n if (k === \"recall\" && !withDate) { $(\"#recallRow\").classList.remove(\"hidden\"); 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\") { const v = $(\"#recallAt\").value; if (!v) return toast(\"Укажи дату и время\"); body.recall_at = new Date(v).toISOString(); }\n try {\n const r = await api(`/api/objects/${CUR.id}/status`, { method: \"POST\", body: JSON.stringify(body) });\n patchLocal(CUR.id, { status: k, assignee_id: r.assignee_id, assignee_name: r.assignee_name, recall_at: body.recall_at || null, status_at: new Date().toISOString() });\n toast(\"Статус: \" + st(k).label);\n await openObject(CUR.id, true); refreshBoot();\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)

Последние сборы с новыми данными${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 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() === 2 ? 1 : 2));\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",[],[135,181],"7cd7aa36-2e72-4b95-86ec-9ef474c06efa","app.css","38f6278e-b013-11f1-b238-1607ee4eb77e",34,["D",1789392020785],4,":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@media (max-width: 860px) {\n :root { --gap: 8px; }\n .top { height: 52px; gap: 8px; padding: 0 8px 0 10px; }\n .bname, .sync, .top .stats { display: none; }\n .who { padding: 7px 10px; }\n .panel { top: auto; left: 0; right: 0; bottom: 0; width: auto; border-radius: 22px 22px 0 0; height: 48dvh; transition: height .25s ease; padding-bottom: 64px; }\n .panel.full { height: calc(100dvh - 64px); }\n .panel.peek { height: 150px; }\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: 6px 10px 8px; }\n .mtools { top: calc(var(--gap) * 2 + 52px); }\n .leaflet-left { left: var(--gap) !important; } .leaflet-top { top: calc(var(--gap) * 2 + 52px) !important; }\n .drawhint { top: calc(var(--gap) * 2 + 52px); white-space: normal; text-align: center; max-width: 90%; }\n .app.tab-map .panel { display: none; }\n .tabs { display: flex; position: absolute; left: var(--gap); right: var(--gap); bottom: calc(var(--gap) + env(safe-area-inset-bottom)); z-index: 60; border-radius: 16px; padding: 6px; gap: 6px; }\n .tabs button { flex: 1; padding: 10px; border-radius: 11px; font-weight: 700; color: var(--mut); }\n .tabs button.on { background: var(--ink); color: var(--bg); }\n html[data-theme=\"dark\"] .tabs button.on { background: #fff; color: #14162a; }\n .drawer { top: 8%; left: 0; right: 0; bottom: 0; width: auto; max-width: none; border-radius: 22px 22px 0 0; animation: slideup .22s ease-out; }\n @keyframes slideup { from { transform: translateY(30px); opacity: 0; } to { transform: none; opacity: 1; } }\n .grid { grid-template-columns: repeat(2, 1fr); }\n .mbox .frm { grid-template-columns: 1fr; }\n}\n",[],[135,190],["D",1789373202685],[168,169,170],[135],"553e8abf-8709-4549-86b8-97b28f3f75a5",["D",1789392207972],[],[145,33],"9a2f06a5-fe2a-4519-8f37-39853951d363","index.ts",36,["D",1789392174963],8,"http","// HTTP: интерфейс и API парсера собственников Unlock.\nimport { Hono } from \"npm:hono@4\";\nimport { readFile, serveFile, parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { DEFAULT_SETTINGS, getSettings, migrate, nowIso, parseJson, setSettings, sqlite, STATUSES } from \"./db.ts\";\nimport { sync, inparsSubscription } from \"./inpars.ts\";\nimport { listBrokers, loginByPin, syncBrokers, type User } from \"./auth.ts\";\n\nconst app = new Hono<{ Variables: { user: User } }>();\napp.onError((err) => Promise.reject(err));\n\nlet migrated = false;\napp.use(\"*\", async (_c, next) => { if (!migrated) { await migrate(); migrated = true; } await next(); });\n\n// ---------- статика ----------\napp.get(\"/\", async (c) => c.html(await readFile(\"/frontend/index.html\", import.meta.url), 200, { \"Cache-Control\": \"no-store\" }));\napp.get(\"/app.css\", (c) => serveFile(\"/frontend/app.css\", import.meta.url));\napp.get(\"/app.js\", (c) => serveFile(\"/frontend/app.js\", import.meta.url));\napp.get(\"/manifest.json\", (c) => c.json({ name: \"Unlock · Собственники\", short_name: \"Собственники\", start_url: \"/\", display: \"standalone\", background_color: \"#0e0e1a\", theme_color: \"#1e1b4b\", icons: [] }));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ---------- авторизация ----------\napp.post(\"/api/login\", async (c) => {\n const { pin } = await c.req.json().catch(() => ({}));\n const u = await loginByPin(String(pin || \"\"));\n if (!u) return c.json({ error: \"Неверный ПИН-код\" }, 401);\n return c.json(u);\n});\n\napp.use(\"/api/*\", async (c, next) => {\n if (c.req.path === \"/api/login\") return next();\n const u = await loginByPin(c.req.header(\"x-pin\") || \"\");\n if (!u) return c.json({ error: \"unauthorized\" }, 401);\n c.set(\"user\", u);\n await next();\n});\n\n// ---------- справочники и состояние ----------\nfunction nextRunIso() {\n // Крон каждую минуту — следующая круглая минута\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 = `id, source, url, category, section_id, rooms, sq_land, title, 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, last_seen, cost_prev, cost_changed_at, score, flags, status, assignee_id, assignee_name, status_at, recall_at, dup_key,\n (SELECT COUNT(*) FROM objects o2 WHERE o2.dup_key=objects.dup_key AND o2.id!=objects.id AND o2.hidden=0) AS twins`;\n\napp.get(\"/api/objects\", async (c) => {\n const u = c.get(\"user\");\n const q = c.req.query();\n const where: string[] = [\"hidden=0\", \"dup_of IS NULL\"];\n const args: any[] = [];\n if (q.status) { const st = q.status.split(\",\").filter((x) => x in STATUSES); if (st.length) { where.push(`status IN (${st.map(() => \"?\").join(\",\")})`); args.push(...st); } }\n if (q.mine === \"1\") { where.push(\"assignee_id=?\"); args.push(u.id); }\n else if (q.broker) { where.push(\"assignee_id=?\"); args.push(Number(q.broker)); }\n if (q.unassigned === \"1\") where.push(\"assignee_id IS NULL\");\n if (q.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.q) { where.push(\"(address LIKE ? OR metro LIKE ? OR district LIKE ? OR title LIKE ?)\"); const like = `%${q.q}%`; args.push(like, like, like, like); }\n const sorts: Record = {\n fresh: \"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) || 1500, 3000);\n const r = await sqlite.execute({ sql: `SELECT ${LIST_COLS} FROM objects WHERE ${where.join(\" AND \")} ORDER BY ${order} LIMIT ${limit}`, args });\n const rows = (r.rows as any[]).map((o) => shapeListRow(o, u));\n return c.json({ items: rows, total: rows.length });\n});\n\nfunction shapeListRow(o: any, u: User) {\n const images = parseJson(o.images, []);\n const st = STATUSES[String(o.status)] || STATUSES.new;\n const phones = parseJson(o.phones, []);\n return {\n id: Number(o.id), source: o.source, url: o.url, category: o.category, section_id: o.section_id, rooms: o.rooms, sq_land: o.sq_land, title: o.title, address: o.address, district: o.district, metro: o.metro,\n floor: o.floor, floors: o.floors, sq: o.sq, cost: o.cost, cost_m2: o.cost_m2, img: images[0] || null, photos: images.length,\n lat: o.lat, lng: o.lng, hasPhone: phones.length > 0, is_new: o.is_new, is_apartments: o.is_apartments, build_year: o.build_year,\n source_created: o.source_created, created: o.created, first_seen: o.first_seen, last_seen: o.last_seen, cost_prev: o.cost_prev, cost_changed_at: o.cost_changed_at,\n score: o.score, flags: { ...parseJson(o.flags, {}), crossListed: Number(o.twins || 0) }, status: o.status, assignee_id: o.assignee_id, assignee_name: o.assignee_name, status_at: o.status_at, recall_at: o.recall_at,\n hidePhone: !!st.hidePhone && u.role !== \"boss\",\n };\n}\n\n// ---------- карточка ----------\napp.get(\"/api/objects/:id\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const r = await sqlite.execute({ sql: \"SELECT * FROM objects WHERE id=?\", args: [id] });\n if (!r.rows.length) return c.json({ error: \"not found\" }, 404);\n const o = r.rows[0] as any;\n const st = STATUSES[String(o.status)] || STATUSES.new;\n const [act, sib] = await Promise.all([\n sqlite.execute({ sql: \"SELECT * FROM activity WHERE object_id=? OR object_id IN (SELECT id FROM objects WHERE dup_of=?) ORDER BY id ASC\", args: [id, id] }),\n o.dup_key ? sqlite.execute({ sql: \"SELECT id, source, url, cost, first_seen, status FROM objects WHERE dup_key=? AND id!=? AND hidden=0\", args: [o.dup_key, id] }) : Promise.resolve({ rows: [] }),\n ]);\n const hide = !!st.hidePhone && u.role !== \"boss\";\n return c.json({\n ...o,\n images: parseJson(o.images, []),\n phones: hide ? [] : parseJson(o.phones, []),\n hidePhone: hide,\n flags: { ...parseJson(o.flags, {}), 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\" && body.recall_at ? String(body.recall_at) : null;\n const cur = await sqlite.execute({ sql: \"SELECT assignee_id, assignee_name, status FROM objects WHERE id=?\", args: [id] });\n const row = cur.rows[0] as any;\n // Смена статуса закрепляет объект за тем, кто её сделал, если объект ещё ничей\n const assignId = row.assignee_id ?? (status === \"new\" ? null : u.id);\n const assignName = row.assignee_id ? row.assignee_name : (status === \"new\" ? null : u.name);\n const stmts: any[] = [{\n sql: `UPDATE objects SET status=?, status_at=?, status_by=?, recall_at=?, assignee_id=?, assignee_name=? WHERE id IN (${ids.map(() => \"?\").join(\",\")})`,\n args: [status, now, u.name, recallAt, assignId, assignName, ...ids],\n }];\n const label = STATUSES[status].label + (recallAt ? \" · \" + new Date(recallAt).toLocaleString(\"ru-RU\", { timeZone: \"Europe/Moscow\", day: \"2-digit\", month: \"2-digit\", hour: \"2-digit\", minute: \"2-digit\" }) : \"\");\n stmts.push({ sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, meta, created_at) VALUES(?,?,?,?,?,?,?)\", args: [id, \"status\", u.id, u.name, label, JSON.stringify({ from: row.status, to: status, recall_at: recallAt }), now] });\n const comment = String(body.comment || \"\").trim();\n if (comment) stmts.push({ sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, created_at) VALUES(?,?,?,?,?,?)\", args: [id, \"comment\", u.id, u.name, comment, now] });\n await sqlite.batch(stmts);\n return c.json({ ok: true, status, assignee_id: assignId, assignee_name: assignName });\n});\n\napp.post(\"/api/objects/:id/assign\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const body = await c.req.json().catch(() => ({}));\n const ids = await groupIds(id);\n if (!ids.length) return c.json({ error: \"not found\" }, 404);\n const now = nowIso();\n let toId: number | null, toName: string | null;\n if (body.release) { toId = null; toName = null; }\n else if (body.broker_id != null && u.role === \"boss\") {\n const b = (await listBrokers()).find((x) => x.id === Number(body.broker_id));\n if (!b) return c.json({ error: \"no broker\" }, 400);\n toId = b.id; toName = b.name;\n } else { toId = u.id; toName = u.name; }\n const cur = await sqlite.execute({ sql: \"SELECT assignee_id, assignee_name, status FROM objects WHERE id=?\", args: [id] });\n const row = cur.rows[0] as any;\n if (!body.release && row.assignee_id && row.assignee_id !== toId && u.role !== \"boss\") return c.json({ error: `Уже в работе: ${row.assignee_name}` }, 409);\n const newStatus = body.release ? (row.status === \"work\" ? \"new\" : row.status) : (row.status === \"new\" ? \"work\" : row.status);\n await sqlite.batch([\n { sql: `UPDATE objects SET assignee_id=?, assignee_name=?, status=?, status_at=?, status_by=? WHERE id IN (${ids.map(() => \"?\").join(\",\")})`, args: [toId, toName, newStatus, now, u.name, ...ids] },\n { sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, created_at) VALUES(?,?,?,?,?,?)\", args: [id, \"assign\", u.id, u.name, body.release ? \"Снял с себя\" : toId === u.id ? \"Взял в работу\" : `Передал: ${toName}`, now] },\n ]);\n return c.json({ ok: true, assignee_id: toId, assignee_name: toName, status: newStatus });\n});\n\napp.post(\"/api/objects/:id/comment\", async (c) => {\n const u = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const body = await c.req.json().catch(() => ({}));\n const text = String(body.text || \"\").trim().slice(0, 2000);\n if (!text) return c.json({ error: \"empty\" }, 400);\n const now = nowIso();\n await sqlite.execute({ sql: \"INSERT INTO activity(object_id, kind, broker_id, broker_name, text, created_at) VALUES(?,?,?,?,?,?)\", args: [id, \"comment\", u.id, u.name, text, now] });\n return c.json({ ok: true });\n});\n\n// Пульс для интерфейса: есть ли новое с момента 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// Лента команды: последние действия по всем объектам\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/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",[],[145,206],"57ba1cb1-a176-4b93-9d84-08d591edf1a5","db.ts","37957692-b013-11f1-8804-1607ee4eb77e",38,["D",1789392207169],"// База данных парсера собственников Unlock.\n// Val-scoped SQLite: таблицы объектов, ленты активности, запусков и настроек.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport { sqlite };\n\nexport const STATUSES: Record = {\n new: { label: \"Новый\", color: \"#0ea5e9\" },\n work: { label: \"В работе\", color: \"#5b5bd6\" },\n recall: { label: \"Перезвонить\", color: \"#f59e0b\" },\n noanswer: { label: \"Не дозвонились\", color: \"#94a3b8\" },\n meeting: { label: \"Встреча / договор\", color: \"#10b981\" },\n refused: { label: \"Не готов сотрудничать\", color: \"#6b7280\", done: true },\n agent: { label: \"Это агент\", color: \"#a16207\", done: true },\n aggressive: { label: \"Агрессивен\", color: \"#ef4444\", done: true, hidePhone: true },\n dnc: { label: \"Просит не звонить\", color: \"#171a26\", done: true, hidePhone: true },\n gone: { label: \"Снят / продан\", color: \"#cbd5e1\", done: true },\n};\n\nexport async function migrate() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS objects (\n id INTEGER PRIMARY KEY,\n source TEXT, source_id INTEGER, parse_id TEXT, url TEXT,\n type_ad INTEGER, section_id INTEGER, category_id INTEGER, category TEXT, rooms INTEGER,\n title TEXT, address TEXT, district TEXT, metro TEXT,\n floor INTEGER, floors INTEGER, sq REAL, sq_living REAL, sq_kitchen REAL,\n cost INTEGER, cost_m2 INTEGER, text TEXT, images TEXT, lat REAL, lng REAL,\n name TEXT, phones TEXT, agent INTEGER, is_new INTEGER, is_apartments INTEGER,\n build_year INTEGER, repair_type INTEGER,\n source_created TEXT, source_updated TEXT, created TEXT, updated TEXT,\n first_seen TEXT, last_seen TEXT,\n cost_prev INTEGER, cost_changed_at TEXT, cost_first INTEGER,\n score INTEGER DEFAULT 0, flags TEXT, brief TEXT,\n status TEXT DEFAULT 'new', assignee_id INTEGER, assignee_name TEXT,\n status_at TEXT, status_by TEXT, recall_at TEXT,\n dup_key TEXT, dup_of INTEGER, hidden INTEGER DEFAULT 0\n )`,\n `CREATE INDEX IF NOT EXISTS idx_objects_status ON objects(status)`,\n `CREATE INDEX IF NOT EXISTS idx_objects_first_seen ON objects(first_seen)`,\n `CREATE INDEX IF NOT EXISTS idx_objects_dup ON objects(dup_key)`,\n `CREATE TABLE IF NOT EXISTS activity (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n object_id INTEGER NOT NULL,\n kind TEXT NOT NULL, -- comment | status | assign | system\n broker_id INTEGER, broker_name TEXT,\n text TEXT, meta TEXT,\n created_at TEXT NOT NULL\n )`,\n `CREATE INDEX IF NOT EXISTS idx_activity_obj ON activity(object_id, id)`,\n `CREATE TABLE IF NOT EXISTS runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n started_at TEXT, finished_at TEXT, trigger TEXT,\n fetched INTEGER DEFAULT 0, inserted INTEGER DEFAULT 0, updated INTEGER DEFAULT 0,\n price_changes INTEGER DEFAULT 0, error TEXT, note TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS settings (key TEXT PRIMARY KEY, value TEXT)`,\n ]);\n // Миграции колонок — идемпотентно\n for (const col of [\"sq_land REAL\"]) {\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",[],[145,215],"5fbe9c83-5e0d-4301-8fba-16d891b03c74","cron.ts","387ae42a-b013-11f1-9446-1607ee4eb77e",22,["D",1789379435606],2,"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",[],[145,223],"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",[],[145,233],["D",1789373200842],[162,163,164,165,166],[145],["D",1789373200178],["D",1789547455787],{"_101":100,"_109":105},{"_101":100,"_102":103,"_104":105,"_18":56,"_106":107,"_108":25},{"_13":90,"_32":91,"_44":43,"_92":45,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":46,"_99":100},"ctx",{"_83":-5,"_129":280,"_281":282,"_283":284,"_285":25,"_286":25,"_287":25,"_288":60,"_289":-5,"_290":-7,"_291":-7,"_292":64,"_293":25,"_294":25,"_295":-5,"_296":25,"_297":25,"_298":25,"_299":-5},"ENV",{"_251":252,"_253":254,"_255":91,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

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

Собственник

Кто ведёт

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

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

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

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

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

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

Сбор данных ✕

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

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

Сбор данных

Diff · v39