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

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_244":245,"_246":247},"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",18,"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/cron.ts","latestPath","fileId","387ae42a-b013-11f1-9446-1607ee4eb77e","name","cron.ts","fileType","interval","content","// Крон сбора: 0 4,11,18 * * * (UTC) = 07:00, 14:00, 21:00 МСК.\nimport { migrate } from \"./db.ts\";\nimport { sync } from \"./inpars.ts\";\nimport { syncBrokers } from \"./auth.ts\";\n\nexport default async function () {\n await migrate();\n await syncBrokers().catch((e) => console.warn(\"brokers sync:\", e));\n const r = await sync(\"cron\");\n console.log(\"sync ok\", r);\n return r;\n}\n","// Крон сбора: каждую минуту (* * * * *). Inpars отдаёт только изменившееся с прошлого запуска,\n// поэтому обычный запуск — один запрос к API и несколько секунд работы.\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","createdAt",["D",1789379235107],"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":239,"_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":240,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":241,"_85":242,"_87":243,"_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":236,"_13":64,"_34":141,"_36":-5,"_24":25,"_142":-5,"_177":237,"_27":238},{"_44":229,"_32":230,"_30":231,"_137":146,"_42":43,"_41":204,"_139":60,"_39":232,"_13":64,"_34":205,"_36":233,"_24":25,"_142":-5,"_177":234,"_27":235},{"_44":225,"_32":33,"_30":31,"_137":146,"_42":43,"_41":14,"_139":25,"_39":226,"_13":147,"_34":35,"_36":38,"_24":25,"_142":-5,"_177":227,"_27":228},{"_44":218,"_32":219,"_30":220,"_137":146,"_42":43,"_41":147,"_139":25,"_39":221,"_13":64,"_34":205,"_36":222,"_24":25,"_142":-5,"_177":223,"_27":224},{"_44":209,"_32":210,"_30":58,"_137":146,"_42":43,"_41":211,"_139":25,"_39":212,"_13":213,"_34":214,"_36":215,"_24":25,"_142":-5,"_177":216,"_27":217},{"_44":199,"_32":200,"_30":201,"_137":146,"_42":43,"_41":202,"_139":25,"_39":203,"_13":204,"_34":205,"_36":206,"_24":25,"_142":-5,"_177":207,"_27":208},{"_44":134,"_32":135,"_30":136,"_137":-5,"_42":43,"_41":138,"_139":60,"_39":196,"_13":64,"_34":141,"_36":-5,"_24":25,"_142":-5,"_177":197,"_27":198},{"_44":188,"_32":189,"_30":190,"_137":136,"_42":43,"_41":191,"_139":25,"_39":192,"_13":147,"_34":20,"_36":193,"_24":25,"_142":-5,"_177":194,"_27":195},{"_44":180,"_32":181,"_30":182,"_137":136,"_42":43,"_41":183,"_139":25,"_39":184,"_13":147,"_34":20,"_36":185,"_24":25,"_142":-5,"_177":186,"_27":187},{"_44":171,"_32":172,"_30":173,"_137":136,"_42":43,"_41":174,"_139":25,"_39":175,"_13":147,"_34":20,"_36":176,"_24":25,"_142":-5,"_177":178,"_27":179},"a4d86854-4328-4bc8-8764-229a4e4a80c8","index.html","38ae9b58-b013-11f1-9622-1607ee4eb77e",13,["D",1789378777089],"\n\n\n \n \n \n \n \n \n Unlock · Собственники\n \n \n \n \n\n\n \n \n\n \n

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

\n \n \n \n

\n \n

\n\n

\n \n \n

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

Статус

Комнат

Цена, млн ₽

—

Источник

Брокер

\n Только с телефоном\n Никем не взяты\n

\n \n

\n\n

\n \n

\n\n \n\n \n

\n \n

\n ↗\n

\n\n \n \n

\n\n \n \n\n\n","children",[],[135,172],"9a379fa8-8cae-452a-8765-908cb2081959","app.js","393c694c-b013-11f1-acaf-1607ee4eb77e",15,["D",1789378778118],"/* Unlock · Собственники — фронтенд */\nconst $ = (s, r = document) => r.querySelector(s);\nconst $$ = (s, r = document) => [...r.querySelectorAll(s)];\nlet PIN = \"\", USER = null, BOOT = null, ITEMS = [], SEL = null, MAP = null, LAYER = null, MARKERS = new Map(), QUICK = \"all\";\nconst F = { status: new Set(), rooms: new Set(), source: new Set(), broker: null };\nlet listRendered = 0, searchT = null;\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.first_seen; return t && (Date.now() - new Date(t).getTime()) < 86400000; };\nconst st = (k) => (BOOT && BOOT.statuses[k]) || { label: k, color: \"#999\" };\nfunction toast(m) { const t = $(\"#toast\"); t.textContent = m; t.classList.add(\"show\"); clearTimeout(t._t); t._t = setTimeout(() => t.classList.remove(\"show\"), 2200); }\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\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 if (MAP) setTiles();\n toast(\"Тема: \" + ({ auto: \"как в системе\", dark: \"тёмная\", light: \"светлая\" })[next]);\n}\n\n/* ---------- старт ---------- */\nasync function start() {\n $(\"#loginView\").classList.add(\"hidden\"); $(\"#app\").classList.remove(\"hidden\");\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();\n renderStatusChips();\n renderBrokerChips();\n renderLegend();\n initMap();\n await reload();\n setInterval(refreshBoot, 90000);\n}\nasync function refreshBoot() { try { BOOT = await api(\"/api/bootstrap\"); renderTop(); } catch {} }\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;\n $(\"#syncInfo\").innerHTML = lr ? `Обновлено ${fmtT(lr.finished_at || lr.started_at)}${lr.error ? \" · ошибка\" : lr.inserted != null ? ` · +${lr.inserted}` : \"\"} · следующее в ${fmtT(BOOT.nextRun)}` : `Первый сбор в ${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}\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 renderLegend() {\n const html = Object.entries(BOOT.statuses).map(([k, v]) => `${v.label}`).join(\"\");\n $(\"#legend\").innerHTML = html;\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(); }\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.broker = null;\n $$(\".fchips button\").forEach((b) => b.classList.remove(\"on\"));\n $(\"#fMin\").value = \"\"; $(\"#fMax\").value = \"\"; $(\"#fPhone\").checked = false; $(\"#fUnassigned\").checked = false; $(\"#q\").value = \"\";\n setQuick(\"all\");\n}\nfunction onSearch() { clearTimeout(searchT); searchT = setTimeout(reload, 300); }\nfunction setTab(t) { $(\"#app\").classList.toggle(\"tab-map\", t === \"map\"); $$(\"#tabs button\").forEach((b) => b.classList.toggle(\"on\", b.dataset.t === t)); if (t === \"map\" && MAP) setTimeout(() => { MAP.invalidateSize(); fitAll(); }, 50); }\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.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.broker != null) + $(\"#fPhone\").checked + $(\"#fUnassigned\").checked + !!$(\"#fMin\").value + !!$(\"#fMax\").value;\n $(\"#advN\").textContent = n || \"\";\n return p.toString();\n}\nasync function reload() {\n try {\n const j = await api(\"/api/objects?\" + buildQuery());\n ITEMS = j.items;\n $(\"#listCount\").textContent = ITEMS.length ? `${ITEMS.length} объект${plural(ITEMS.length)}` : \"Ничего не найдено\";\n renderList(true);\n renderMarkers();\n } catch (e) { toast(e.message); }\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);\n const done = s.done;\n const drop = o.cost_prev && o.cost < o.cost_prev;\n const flags = o.flags || {};\n const fresh = isFresh(o);\n const roomsTxt = o.rooms === 0 ? \"Студия\" : o.rooms ? `${o.rooms}-к` : (o.category || \"\");\n return `

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

${fmtMln(o.cost)}${drop ? `~~${fmtMln(o.cost_prev)}~~` : \"\"}${fmtM2(o.cost_m2)}

${esc(roomsTxt)} · ${o.sq} м² · ${o.floor || \"?\"}/${o.floors || \"?\"} эт.${o.is_new ? \" · новостройка\" : \"\"}${o.is_apartments ? \" · апартаменты\" : \"\"}

${esc(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 ${flags.agentWords || flags.phoneMulti >= 3 ? `агент?` : \"\"}\n ${flags.crossListed ? `2 площадки` : \"\"}\n ${!o.hasPhone ? `без телефона` : \"\"}\n ${fresh ? \"новый · \" : \"\"}${ago(o.source_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/* ---------- карта ---------- */\nlet TILES = null;\nfunction setTiles() {\n const dark = document.documentElement.dataset.theme === \"dark\";\n if (TILES) return; // тёмная тема — через CSS-фильтр тайлов\n TILES = L.tileLayer(\"https://tile.openstreetmap.org/{z}/{x}/{y}.png\", { maxZoom: 19, attribution: \"© OpenStreetMap\" }).addTo(MAP);\n}\nfunction initMap() {\n if (MAP) return;\n MAP = L.map(\"map\", { zoomControl: true, preferCanvas: true, attributionControl: false }).setView([55.751, 37.618], 11);\n setTiles();\n LAYER = L.layerGroup().addTo(MAP);\n}\nfunction renderMarkers() {\n if (!MAP) return;\n LAYER.clearLayers(); MARKERS.clear();\n const bounds = [];\n for (const o of ITEMS) {\n if (!o.lat || !o.lng) continue;\n const s = st(o.status);\n const fresh = isFresh(o);\n const m = L.circleMarker([o.lat, o.lng], { radius: o.status === \"new\" ? (fresh ? 8 : 6.5) : 6, color: \"#fff\", weight: 1.5, fillColor: s.color, fillOpacity: s.done ? .55 : .95 });\n m.on(\"click\", () => openObject(o.id));\n m.bindTooltip(`${fmtMln(o.cost)} · ${o.rooms === 0 ? \"студия\" : o.rooms ? o.rooms + \"-к\" : \"\"} ${o.sq} м²
${esc(o.address)}
${s.label}${o.assignee_name ? \" · \" + esc(o.assignee_name.split(\" \")[0]) : \"\"}`, { direction: \"top\", offset: [0, -6], opacity: .95 });\n m.addTo(LAYER); MARKERS.set(o.id, m); bounds.push([o.lat, o.lng]);\n }\n if (bounds.length && !SEL) MAP.fitBounds(bounds, { padding: [30, 30], maxZoom: 14 });\n}\nfunction fitAll() { const b = [...MARKERS.values()].map((m) => m.getLatLng()); if (b.length) MAP.fitBounds(b, { padding: [30, 30], maxZoom: 14 }); }\nfunction highlight(id) {\n MARKERS.forEach((m, k) => { const o = ITEMS.find((x) => x.id === k); if (!o) return; m.setStyle({ weight: k === id ? 3 : 1.5, color: k === id ? \"#171a26\" : \"#fff\", radius: k === id ? 10 : (o.status === \"new\" ? 6.5 : 6) }); if (k === id) m.bringToFront(); });\n}\n\n/* ---------- карточка ---------- */\nlet CUR = null;\nasync function openObject(id) {\n SEL = id;\n $$(\".card\").forEach((c) => c.classList.toggle(\"sel\", Number(c.dataset.id) === id));\n highlight(id);\n $(\"#drawer\").classList.remove(\"hidden\"); if (innerWidth <= 860) $(\"#scrim\").classList.remove(\"hidden\");\n $(\"#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 && MAP && innerWidth > 860) { const dw = $(\"#drawer\").offsetWidth || 0; const pt = MAP.latLngToContainerPoint([o.lat, o.lng]); MAP.panTo(MAP.containerPointToLatLng([pt.x + dw / 2, pt.y]), { animate: true }); }\n $(\"#dTitle\").textContent = `${o.rooms === 0 ? \"Студия\" : o.rooms ? o.rooms + \"-к квартира\" : (o.category || \"Объект\")} · ${o.sq} м²`;\n $(\"#dSrc\").href = o.url;\n renderDrawer();\n}\nfunction closeDrawer() { $(\"#drawer\").classList.add(\"hidden\"); $(\"#scrim\").classList.add(\"hidden\"); SEL = null; highlight(null); $$(\".card.sel\").forEach((c) => c.classList.remove(\"sel\")); }\n\nfunction renderDrawer() {\n const o = CUR, s = st(o.status), f = o.flags || {};\n const mine = o.assignee_id === USER.id;\n const drop = o.cost_prev && o.cost !== o.cost_prev;\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(`Размещён на нескольких площадках`);\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 const boss = USER.role === \"boss\";\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(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(\"\")}

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

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

Жилая / кухня${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\n

Собственник

\n ${o.hidePhone ? `

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

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

${fmtPhone(p)}

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

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

`}\n

\n\n

Кто ведёт

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

\n\n

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

${statusBtns}

\n\n

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

${acts || `

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

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

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

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

` : \"\"}\n\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 = ITEMS.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 const m = MARKERS.get(id); if (m && o) { const s = st(o.status); m.setStyle({ fillColor: s.color, fillOpacity: s.done ? .55 : .95 }); }\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); 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); 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); 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;\n const sub = inp.data && inp.data[0];\n $(\"#setBody\").className = \"\";\n $(\"#setBody\").innerHTML = `\n

Inpars: ${sub ? `${esc(sub.subscribe)} до ${fmtDT(sub.endTime)}` : `${esc(inp.error || \"нет подписки\")}`} · Автообновление в 07:00, 14:00 и 21:00 МСК

Цена от, ₽

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

Разделы

Тип жилья

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

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

Последние сборы${runs.items.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\"].forEach((k) => body[k] = $(\"#s_\" + k).value);\n try { await api(\"/api/settings\", { method: \"POST\", body: JSON.stringify(body) }); toast(\"Сохранено\"); } 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/* ---------- 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],"84c196e1-2cf1-4545-9d12-db1ee500472a","app.css","38f6278e-b013-11f1-b238-1607ee4eb77e",14,["D",1789378777720],":root {\n --bg: #f4f5f9; --bg2: #eceefb; --card: #ffffff; --ink: #171a26; --mut: #7a8095; --line: #e7e9f0;\n --acc: #5b5bd6; --acc2: #8b5cf6; --ok: #10b981; --no: #ef4444; --warn: #f59e0b;\n --shadow: 0 6px 20px rgba(23, 26, 38, 0.06); --shadow2: 0 14px 40px rgba(23, 26, 38, 0.14);\n --fieldBg: #ffffff; --toastBg: #171a26; --toastInk: #fff; --hdr1: #1e1b4b; --hdr2: #4c1d95;\n --side: 430px; --drawer: 520px;\n color-scheme: light;\n}\nhtml[data-theme=\"dark\"] {\n --bg: #0e0e1a; --bg2: #171630; --card: #1a1a2e; --ink: #eceefb; --mut: #9096b4; --line: #2a2a45;\n --acc: #7c6cff; --acc2: #a78bfa; --shadow: 0 6px 20px rgba(0,0,0,.45); --shadow2: 0 14px 40px rgba(0,0,0,.6);\n --fieldBg: #20203a; --toastBg: #2b2b4d; --toastInk: #eceefb; --hdr1: #171545; --hdr2: #3b177a;\n color-scheme: dark;\n}\n* { box-sizing: border-box; -webkit-tap-highlight-color: transparent; }\nhtml, body { height: 100%; margin: 0; }\nbody { font-family: -apple-system, \"Segoe UI\", Roboto, Inter, sans-serif; background: var(--bg); color: var(--ink); font-size: 14px; line-height: 1.4; overflow: hidden; }\nbutton, input, select, textarea { font: inherit; color: inherit; }\nbutton { cursor: pointer; }\na { color: var(--acc); text-decoration: none; }\n.hidden { display: none !important; }\n\n/* login */\n.login { max-width: 340px; margin: 12vh auto 0; padding: 0 20px; text-align: center; }\n.login .logo { width: 76px; height: 76px; margin: 0 auto; border-radius: 22px; background: #15171d; border: 1px solid rgba(255,255,255,.08); display: flex; align-items: center; justify-content: center; font-size: 34px; font-weight: 800; letter-spacing: -1px; color: #f7f4ef; box-shadow: var(--shadow); }\n.login .logo i, .blogo i { color: #e0402a; font-style: normal; }\n.login h2 { font-size: 20px; margin: 12px 0 4px; }\n.login p { font-size: 13px; color: var(--mut); line-height: 1.5; }\n.login input { margin: 22px auto 4px; display: block; width: 170px; text-align: center; letter-spacing: 10px; font-size: 26px; font-weight: 800; border: 0; border-bottom: 2px solid var(--line); outline: none; padding: 6px 0; background: transparent; caret-color: var(--acc); }\n.login input:focus { border-color: var(--acc); }\n.lerr { color: var(--no); font-size: 12px; font-weight: 600; margin-top: 10px; min-height: 16px; }\n.login .go { width: 100%; border: 0; background: linear-gradient(135deg, var(--acc), var(--acc2)); color: #fff; padding: 14px; border-radius: 13px; font-size: 15px; font-weight: 700; margin-top: 14px; }\n\n/* app frame */\n.app { display: flex; flex-direction: column; height: 100dvh; }\n.top { display: flex; align-items: center; gap: 14px; padding: 8px 14px; background: linear-gradient(120deg, var(--hdr1), var(--hdr2)); color: #fff; min-height: 52px; }\n.brand { display: flex; align-items: center; gap: 8px; font-weight: 800; letter-spacing: -.2px; font-size: 15px; }\n.blogo { width: 28px; height: 28px; border-radius: 8px; background: #15171d; display: inline-flex; align-items: center; justify-content: center; font-weight: 800; color: #f7f4ef; }\n.stats { display: flex; gap: 6px; flex-wrap: wrap; }\n.stat { background: rgba(255,255,255,.12); border-radius: 999px; padding: 4px 10px; font-size: 12px; font-weight: 600; white-space: nowrap; }\n.stat b { font-weight: 800; }\n.stat.warn { background: rgba(245,158,11,.28); }\n.sync { margin-left: auto; font-size: 11.5px; opacity: .85; white-space: nowrap; }\n.sync b { font-weight: 700; }\n.hact { display: flex; align-items: center; gap: 6px; }\n.ibtn { border: 0; background: rgba(255,255,255,.12); color: inherit; width: 34px; height: 34px; border-radius: 10px; display: inline-flex; align-items: center; justify-content: center; font-size: 15px; }\n.ibtn:hover { background: rgba(255,255,255,.22); }\n.who { font-size: 12px; font-weight: 700; background: rgba(255,255,255,.16); padding: 6px 10px; border-radius: 999px; white-space: nowrap; }\n\n.body { flex: 1; display: flex; min-height: 0; position: relative; }\n.side { width: var(--side); display: flex; flex-direction: column; border-right: 1px solid var(--line); background: var(--bg); min-height: 0; }\n.mapwrap { flex: 1; position: relative; min-width: 0; }\n#map { position: absolute; inset: 0; background: var(--bg2); }\n.maplegend { position: absolute; left: 12px; bottom: 12px; z-index: 500; background: var(--card); border-radius: 12px; box-shadow: var(--shadow); padding: 8px 10px; display: flex; flex-wrap: wrap; gap: 6px 10px; max-width: 460px; font-size: 11px; }\n.maplegend span { display: inline-flex; align-items: center; gap: 5px; color: var(--mut); font-weight: 600; }\n.maplegend i { width: 10px; height: 10px; border-radius: 50%; display: inline-block; }\n.locate { position: absolute; right: 12px; top: 12px; z-index: 500; border: 0; width: 36px; height: 36px; border-radius: 10px; background: var(--card); box-shadow: var(--shadow); font-size: 16px; }\n\n/* filters */\n.filters { padding: 10px 12px 6px; border-bottom: 1px solid var(--line); background: var(--bg); }\n.srow { display: flex; gap: 8px; }\n.search { flex: 1; border: 1px solid var(--line); background: var(--fieldBg); border-radius: 11px; padding: 9px 12px; outline: none; min-width: 0; }\n.search:focus { border-color: var(--acc); }\n.selbox { border: 1px solid var(--line); background: var(--fieldBg); border-radius: 11px; padding: 0 8px; font-size: 12.5px; max-width: 150px; }\n.chips { display: flex; gap: 6px; margin-top: 8px; overflow-x: auto; scrollbar-width: none; padding-bottom: 2px; }\n.chips::-webkit-scrollbar { display: none; }\n.chips button, .fchips button { border: 1px solid var(--line); background: var(--card); border-radius: 999px; padding: 5px 11px; font-size: 12.5px; font-weight: 600; white-space: nowrap; color: var(--mut); }\n.chips button.on, .fchips button.on { background: var(--acc); border-color: var(--acc); color: #fff; }\n.chips .more { margin-left: auto; }\n.chips .more span:not(:empty) { background: #fff; color: var(--acc); border-radius: 999px; padding: 0 6px; margin-left: 4px; font-size: 11px; }\n.adv { padding-top: 6px; }\n.fgrp { margin-top: 8px; }\n.fgrp label { display: block; font-size: 11px; text-transform: uppercase; letter-spacing: .5px; color: var(--mut); font-weight: 700; margin-bottom: 5px; }\n.fchips { display: flex; flex-wrap: wrap; gap: 5px; }\n.fchips button { padding: 4px 9px; font-size: 12px; }\n.fchips button i { width: 8px; height: 8px; border-radius: 50%; display: inline-block; margin-right: 5px; }\n.range { display: flex; align-items: center; gap: 8px; }\n.range input { width: 90px; border: 1px solid var(--line); background: var(--fieldBg); border-radius: 9px; padding: 6px 9px; outline: none; }\n.row2 { display: flex; gap: 14px; }\n.chk { display: flex !important; align-items: center; gap: 6px; text-transform: none !important; letter-spacing: 0 !important; font-size: 12.5px !important; color: var(--ink) !important; font-weight: 600 !important; }\n.lnk { border: 0; background: none; color: var(--acc); font-size: 12px; font-weight: 600; padding: 8px 0 2px; }\n\n.listhead { display: flex; justify-content: space-between; align-items: center; padding: 6px 14px; font-size: 11.5px; color: var(--mut); font-weight: 600; }\n.list { flex: 1; overflow-y: auto; padding: 0 10px 20px; }\n\n/* card */\n.card { display: grid; grid-template-columns: 96px 1fr; gap: 10px; background: var(--card); border-radius: 14px; padding: 8px; margin-bottom: 8px; box-shadow: var(--shadow); border: 1px solid transparent; cursor: pointer; position: relative; }\n.card:hover { border-color: var(--acc); }\n.card.sel { border-color: var(--acc); box-shadow: 0 0 0 2px rgba(91,91,214,.25); }\n.card.done { opacity: .62; }\n.card .ph { width: 96px; height: 84px; border-radius: 10px; background: var(--bg2) center/cover no-repeat; position: relative; overflow: hidden; }\n.card .ph .n { position: absolute; right: 4px; bottom: 4px; background: rgba(0,0,0,.55); color: #fff; font-size: 10px; padding: 1px 5px; border-radius: 6px; }\n.card .ph .src { position: absolute; left: 4px; top: 4px; font-size: 9.5px; font-weight: 800; padding: 1px 5px; border-radius: 6px; color: #fff; text-transform: uppercase; }\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: 2px; }\n.card .price { display: flex; align-items: baseline; gap: 8px; }\n.card .price b { font-size: 16px; font-weight: 800; letter-spacing: -.3px; }\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; }\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: 3px; flex-wrap: wrap; }\n.pill { display: inline-flex; align-items: center; gap: 5px; font-size: 11px; font-weight: 700; padding: 2px 8px; border-radius: 999px; background: var(--bg2); 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,.14); color: #b45309; }\n.pill.warnr { background: rgba(239,68,68,.12); color: #b91c1c; }\n.pill.ok { background: rgba(16,185,129,.14); color: #047857; }\n.pill.ghost { background: transparent; color: var(--mut); padding-left: 0; }\n.ava { width: 20px; height: 20px; border-radius: 50%; background: linear-gradient(135deg, var(--acc), var(--acc2)); color: #fff; font-size: 9.5px; font-weight: 800; display: inline-flex; align-items: center; justify-content: center; }\n.age { margin-left: auto; color: var(--mut); font-size: 11px; white-space: nowrap; }\n.age.hot { color: var(--ok); font-weight: 700; }\n.empty { text-align: center; color: var(--mut); padding: 40px 20px; font-size: 13px; }\n\n/* drawer */\n.drawer { position: absolute; top: 0; right: 0; bottom: 0; width: var(--drawer); max-width: 100%; background: var(--bg); z-index: 900; display: flex; flex-direction: column; box-shadow: var(--shadow2); border-left: 1px solid var(--line); }\n.dhead { display: flex; align-items: center; gap: 10px; padding: 10px 12px; border-bottom: 1px solid var(--line); background: var(--card); }\n.dhead .ibtn { background: var(--bg2); color: var(--ink); }\n.dtitle { flex: 1; font-weight: 800; font-size: 15px; white-space: nowrap; overflow: hidden; text-overflow: ellipsis; }\n.dbody { flex: 1; overflow-y: auto; padding: 12px 14px 40px; }\n.gal { display: flex; gap: 6px; overflow-x: auto; scroll-snap-type: x mandatory; border-radius: 14px; }\n.gal img { height: 220px; border-radius: 12px; scroll-snap-align: start; flex: 0 0 auto; background: var(--bg2); object-fit: cover; max-width: 92%; }\n.dprice { display: flex; align-items: baseline; gap: 10px; margin: 12px 0 2px; flex-wrap: wrap; }\n.dprice b { font-size: 26px; font-weight: 800; letter-spacing: -.6px; }\n.dprice .m2 { color: var(--mut); font-size: 13px; }\n.dprice .delta { font-size: 12px; font-weight: 700; padding: 2px 8px; border-radius: 999px; }\n.delta.down { background: rgba(16,185,129,.14); color: #047857; } .delta.up { background: rgba(239,68,68,.12); color: #b91c1c; }\n.daddr { font-size: 14px; font-weight: 600; }\n.dsub { color: var(--mut); font-size: 12.5px; margin-top: 2px; }\n.grid { display: grid; grid-template-columns: repeat(3, 1fr); gap: 8px; margin: 12px 0; }\n.kv { background: var(--card); border-radius: 12px; padding: 8px 10px; box-shadow: var(--shadow); }\n.kv small { display: block; color: var(--mut); font-size: 10.5px; text-transform: uppercase; letter-spacing: .4px; font-weight: 700; }\n.kv b { font-size: 14px; font-weight: 700; }\n.sec { background: var(--card); border-radius: 14px; padding: 12px; box-shadow: var(--shadow); margin-bottom: 10px; }\n.sec h4 { margin: 0 0 8px; font-size: 11px; text-transform: uppercase; letter-spacing: .5px; color: var(--mut); }\n.phone { display: flex; align-items: center; gap: 10px; }\n.phone a { font-size: 22px; font-weight: 800; letter-spacing: -.3px; color: var(--ink); }\n.phone .call { margin-left: auto; background: var(--ok); color: #fff; border: 0; border-radius: 12px; padding: 10px 16px; font-weight: 800; }\n.phone .nop { color: var(--mut); font-size: 13px; }\n.own { display: flex; align-items: center; gap: 10px; }\n.own .big { flex: 1; border: 0; border-radius: 12px; padding: 12px; font-weight: 800; font-size: 14px; background: linear-gradient(135deg, var(--acc), var(--acc2)); color: #fff; }\n.own .big.taken { background: var(--bg2); color: var(--ink); }\n.own .rel { border: 1px solid var(--line); background: transparent; border-radius: 12px; padding: 12px; font-weight: 700; color: var(--mut); }\n.stgrid { display: grid; grid-template-columns: repeat(2, 1fr); gap: 6px; }\n.stgrid button { border: 1px solid var(--line); background: var(--bg); border-radius: 11px; padding: 9px 10px; text-align: left; font-weight: 700; font-size: 12.5px; display: flex; align-items: center; gap: 8px; }\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,.1); }\n.recall { display: flex; gap: 8px; margin-top: 8px; align-items: center; }\n.recall input { border: 1px solid var(--line); background: var(--fieldBg); border-radius: 10px; padding: 8px; }\n.recall button { border: 0; background: var(--acc); color: #fff; border-radius: 10px; padding: 9px 14px; font-weight: 700; }\n.cform { display: flex; gap: 8px; }\n.cform textarea { flex: 1; border: 1px solid var(--line); background: var(--fieldBg); border-radius: 11px; padding: 9px 11px; resize: vertical; min-height: 42px; outline: none; }\n.cform button { border: 0; background: var(--acc); color: #fff; border-radius: 11px; padding: 0 16px; font-weight: 800; }\n.act { display: flex; gap: 10px; padding: 8px 0; border-top: 1px solid var(--line); font-size: 13px; }\n.act:first-of-type { border-top: 0; }\n.act .ava { flex: 0 0 auto; margin-top: 2px; }\n.act .sys { width: 20px; height: 20px; border-radius: 50%; background: var(--bg2); display: inline-flex; align-items: center; justify-content: 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; }\n.act .st { font-weight: 700; }\n.txt { white-space: pre-wrap; font-size: 13px; color: var(--ink); line-height: 1.5; }\n.txt.clip { max-height: 120px; overflow: hidden; position: relative; }\n.txt.clip:after { content: \"\"; position: absolute; left: 0; right: 0; bottom: 0; height: 40px; background: linear-gradient(transparent, var(--card)); }\n.flags { display: flex; flex-wrap: wrap; gap: 6px; margin: 10px 0; }\n.sib a { display: block; padding: 6px 0; font-weight: 600; }\n.scrim { position: absolute; inset: 0; background: rgba(0,0,0,.25); z-index: 850; }\n\n/* modal */\n.modal { position: fixed; inset: 0; background: rgba(0,0,0,.45); z-index: 2000; display: flex; align-items: center; justify-content: center; padding: 16px; }\n.mbox { background: var(--bg); border-radius: 18px; width: 560px; max-width: 100%; max-height: 90vh; overflow-y: auto; padding: 18px; box-shadow: var(--shadow2); }\n.mbox h3 { margin: 0 0 12px; font-size: 17px; display: flex; align-items: center; justify-content: space-between; }\n.mbox .frm { display: grid; grid-template-columns: 1fr 1fr; gap: 10px; }\n.mbox .frm label { font-size: 11px; color: var(--mut); text-transform: uppercase; letter-spacing: .4px; font-weight: 700; display: block; }\n.mbox .frm input, .mbox .frm select { width: 100%; border: 1px solid var(--line); background: var(--fieldBg); border-radius: 10px; padding: 8px 10px; margin-top: 4px; }\n.mbox .btns { display: flex; gap: 8px; margin-top: 14px; flex-wrap: wrap; }\n.btn { border: 0; border-radius: 11px; padding: 10px 16px; font-weight: 800; background: var(--acc); color: #fff; }\n.btn.sec2 { background: var(--bg2); color: var(--ink); }\n.runs { font-size: 12px; margin-top: 12px; }\n.runs div { display: flex; gap: 8px; padding: 5px 0; border-top: 1px solid var(--line); }\n.runs .err { color: var(--no); }\n.feed .act { cursor: pointer; }\n.toast { position: fixed; left: 50%; bottom: 24px; transform: translateX(-50%) translateY(20px); background: var(--toastBg); color: var(--toastInk); padding: 10px 16px; border-radius: 12px; font-weight: 600; font-size: 13px; opacity: 0; transition: .2s; z-index: 3000; pointer-events: none; }\n.toast.show { opacity: 1; transform: translateX(-50%); }\n\n.tabs { display: none; }\n.leaflet-container { font: inherit; }\n.leaflet-popup-content-wrapper { border-radius: 12px; }\n.pulse { animation: pulse 1.6s ease-out infinite; }\n@keyframes pulse { 0% { stroke-opacity: .9; } 100% { stroke-opacity: 0; } }\n\n/* mobile */\n@media (max-width: 860px) {\n :root { --side: 100%; }\n .top { flex-wrap: wrap; gap: 8px; padding: 8px 10px; }\n .bname { display: none; }\n .sync { display: none; }\n .stats { order: 3; width: 100%; }\n .side { width: 100%; border-right: 0; }\n .mapwrap { display: none; position: absolute; inset: 0; }\n .app.tab-map .side { display: none; }\n .app.tab-map .mapwrap { display: block; }\n .tabs { display: flex; border-top: 1px solid var(--line); background: var(--card); padding: 6px 10px calc(6px + env(safe-area-inset-bottom)); gap: 6px; }\n .tabs button { flex: 1; border: 0; background: transparent; padding: 9px; border-radius: 10px; font-weight: 700; color: var(--mut); }\n .tabs button.on { background: var(--bg2); color: var(--acc); }\n .drawer { width: 100%; top: 8%; border-radius: 18px 18px 0 0; border-left: 0; }\n .maplegend { max-width: calc(100% - 24px); bottom: 12px; }\n .grid { grid-template-columns: repeat(2, 1fr); }\n .mbox .frm { grid-template-columns: 1fr; }\n}\n\nhtml[data-theme=\"dark\"] .leaflet-tile-pane { filter: invert(1) hue-rotate(180deg) brightness(.85) contrast(.9) saturate(.6); }\n.gal img[data-broken] { display: none; }\n",[],[135,189],["D",1789373202685],[168,169,170],[135],"df5f49b6-646f-4f2c-bc8c-541688b668ed","inpars.ts","380f81f8-b013-11f1-adb7-1607ee4eb77e",16,["D",1789379234322],2,"script","// Сбор объявлений собственников из 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 } = {}) {\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) }, 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",[],[145,200],"9ce2991a-7260-443d-8d46-acfc48693435","index.ts",17,["D",1789379234708],4,"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, 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 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, rooms, title, address, district, metro, floor, floors, sq, cost, cost_m2, images, lat, lng, phones, is_new, is_apartments, build_year,\n source_created, first_seen, last_seen, cost_prev, cost_changed_at, score, flags, status, assignee_id, assignee_name, status_at, recall_at, dup_key,\n (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.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, first_seen)>=?\"); args.push(new Date(Date.now() - h * 3600000).toISOString()); } }\n if (q.drop === \"1\") where.push(\"cost_prev IS NOT NULL AND cost < cost_prev\");\n if (q.q) { where.push(\"(address LIKE ? OR metro LIKE ? OR district LIKE ? OR title LIKE ?)\"); const like = `%${q.q}%`; args.push(like, like, like, like); }\n const sorts: Record = {\n fresh: \"first_seen DESC\", price_desc: \"cost DESC\", price_asc: \"cost ASC\", m2: \"cost_m2 ASC\", score: \"score DESC, first_seen DESC\", updated: \"status_at DESC\",\n };\n const order = sorts[q.sort || \"\"] || \"first_seen DESC\";\n const limit = Math.min(Number(q.limit) || 1500, 3000);\n const r = await sqlite.execute({ sql: `SELECT ${LIST_COLS} FROM objects WHERE ${where.join(\" AND \")} ORDER BY ${order} LIMIT ${limit}`, args });\n const rows = (r.rows as any[]).map((o) => shapeListRow(o, u));\n return c.json({ items: rows, total: rows.length });\n});\n\nfunction shapeListRow(o: any, u: User) {\n const images = parseJson(o.images, []);\n const st = STATUSES[String(o.status)] || STATUSES.new;\n const phones = parseJson(o.phones, []);\n return {\n id: Number(o.id), source: o.source, url: o.url, category: o.category, rooms: o.rooms, title: o.title, address: o.address, district: o.district, metro: o.metro,\n floor: o.floor, floors: o.floors, sq: o.sq, cost: o.cost, cost_m2: o.cost_m2, img: images[0] || null, photos: images.length,\n lat: o.lat, lng: o.lng, hasPhone: phones.length > 0, is_new: o.is_new, is_apartments: o.is_apartments, build_year: o.build_year,\n source_created: o.source_created, first_seen: o.first_seen, last_seen: o.last_seen, cost_prev: o.cost_prev, cost_changed_at: o.cost_changed_at,\n score: o.score, flags: { ...parseJson(o.flags, {}), 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 (объекты или действия команды)\napp.get(\"/api/pulse\", async (c) => {\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/feed\", async (c) => {\n const r = await sqlite.execute(`SELECT a.id, a.object_id, a.kind, a.broker_name, a.text, a.created_at, o.title, o.address, o.cost, o.status\n FROM activity a JOIN objects o ON o.id=a.object_id ORDER BY a.id DESC LIMIT 60`);\n return c.json({ items: r.rows });\n});\n\n// ---------- руководитель ----------\nconst boss = async (c: any, next: any) => { if (c.get(\"user\").role !== \"boss\") return c.json({ error: \"forbidden\" }, 403); await next(); };\n\napp.post(\"/api/sync\", boss, async (c) => {\n await syncBrokers().catch(() => {});\n const body = await c.req.json().catch(() => ({}));\n const r = await sync(\"manual\", body.days ? { sinceOverride: Math.floor(Date.now() / 1000) - Number(body.days) * 86400 } : {});\n return c.json(r);\n});\n\napp.get(\"/api/runs\", boss, async (c) => {\n const r = await sqlite.execute(\"SELECT * FROM runs 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,210],"c8c8d913-e9ea-474b-9cbd-174f846e0f07","db.ts","37957692-b013-11f1-8804-1607ee4eb77e",["D",1789373200842],"// База данных парсера собственников Unlock.\n// Val-scoped SQLite: таблицы объектов, ленты активности, запусков и настроек.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport { sqlite };\n\nexport const STATUSES: Record = {\n new: { label: \"Новый\", color: \"#0ea5e9\" },\n work: { label: \"В работе\", color: \"#5b5bd6\" },\n recall: { label: \"Перезвонить\", color: \"#f59e0b\" },\n noanswer: { label: \"Не дозвонились\", color: \"#94a3b8\" },\n meeting: { label: \"Встреча / договор\", color: \"#10b981\" },\n refused: { label: \"Не готов сотрудничать\", color: \"#6b7280\", done: true },\n agent: { label: \"Это агент\", color: \"#a16207\", done: true },\n aggressive: { label: \"Агрессивен\", color: \"#ef4444\", done: true, hidePhone: true },\n dnc: { label: \"Просит не звонить\", color: \"#171a26\", done: true, hidePhone: true },\n gone: { label: \"Снят / продан\", color: \"#cbd5e1\", done: true },\n};\n\nexport async function migrate() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS objects (\n id INTEGER PRIMARY KEY,\n source TEXT, source_id INTEGER, parse_id TEXT, url TEXT,\n type_ad INTEGER, section_id INTEGER, category_id INTEGER, category TEXT, rooms INTEGER,\n title TEXT, address TEXT, district TEXT, metro TEXT,\n floor INTEGER, floors INTEGER, sq REAL, sq_living REAL, sq_kitchen REAL,\n cost INTEGER, cost_m2 INTEGER, text TEXT, images TEXT, lat REAL, lng REAL,\n name TEXT, phones TEXT, agent INTEGER, is_new INTEGER, is_apartments INTEGER,\n build_year INTEGER, repair_type INTEGER,\n source_created TEXT, source_updated TEXT, created TEXT, updated TEXT,\n first_seen TEXT, last_seen TEXT,\n cost_prev INTEGER, cost_changed_at TEXT, cost_first INTEGER,\n score INTEGER DEFAULT 0, flags TEXT, brief TEXT,\n status TEXT DEFAULT 'new', assignee_id INTEGER, assignee_name TEXT,\n status_at TEXT, status_by TEXT, recall_at TEXT,\n dup_key TEXT, dup_of INTEGER, hidden INTEGER DEFAULT 0\n )`,\n `CREATE INDEX IF NOT EXISTS idx_objects_status ON objects(status)`,\n `CREATE INDEX IF NOT EXISTS idx_objects_first_seen ON objects(first_seen)`,\n `CREATE INDEX IF NOT EXISTS idx_objects_dup ON objects(dup_key)`,\n `CREATE TABLE IF NOT EXISTS activity (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n object_id INTEGER NOT NULL,\n kind TEXT NOT NULL, -- comment | status | assign | system\n broker_id INTEGER, broker_name TEXT,\n text TEXT, meta TEXT,\n created_at TEXT NOT NULL\n )`,\n `CREATE INDEX IF NOT EXISTS idx_activity_obj ON activity(object_id, id)`,\n `CREATE TABLE IF NOT EXISTS runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n started_at TEXT, finished_at TEXT, trigger TEXT,\n fetched INTEGER DEFAULT 0, inserted INTEGER DEFAULT 0, updated INTEGER DEFAULT 0,\n price_changes INTEGER DEFAULT 0, error TEXT, note TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS settings (key TEXT PRIMARY KEY, value TEXT)`,\n `CREATE TABLE IF NOT EXISTS brokers (\n id INTEGER PRIMARY KEY, name TEXT, pin TEXT, active INTEGER, synced_at TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS phone_seen (\n phone TEXT PRIMARY KEY, objects INTEGER DEFAULT 0, sources TEXT, first_seen TEXT\n )`,\n ]);\n}\n\nexport const DEFAULT_SETTINGS: Record = {\n region_id: \"77\",\n type_ad: \"2\", // продажа\n section_ids: \"1,5\", // жилая + загородная\n cost_min: \"30000000\",\n cost_max: \"\",\n source_ids: \"\", // пусто = все источники Inpars\n is_new: \"\", // '' = всё, 0 = вторичка, 1 = новостройки\n backfill_days: \"7\", // глубина первого сбора\n retention_days: \"60\", // скрывать объекты, не обновлявшиеся дольше\n};\n\nexport async function getSettings(): Promise> {\n const r = await sqlite.execute(\"SELECT key, value FROM settings\");\n const s = { ...DEFAULT_SETTINGS };\n for (const row of r.rows as any[]) s[row.key] = String(row.value ?? \"\");\n return s;\n}\n\nexport async function setSettings(patch: Record) {\n const stmts = Object.entries(patch)\n .filter(([k]) => k in DEFAULT_SETTINGS)\n .map(([k, v]) => ({ sql: \"INSERT INTO settings(key,value) VALUES(?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value\", args: [k, String(v ?? \"\")] }));\n if (stmts.length) await sqlite.batch(stmts);\n}\n\nexport const nowIso = () => new Date().toISOString();\n\nexport function parseJson(s: unknown, fallback: T): T {\n if (typeof s !== \"string\" || !s) return fallback;\n try { return JSON.parse(s) as T; } catch { return fallback; }\n}\n",[],[145,219],"d8361bc8-7c2c-4e04-87b4-4d20be4ce4f2",["D",1789379235107],[],[145,33],"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,230],["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":277,"_278":279,"_280":281,"_282":25,"_283":25,"_284":25,"_285":60,"_286":-5,"_287":-7,"_288":-7,"_289":64,"_290":25,"_291":25,"_292":-5,"_293":25,"_294":25,"_295":25,"_296":-5},"ENV",{"_248":249,"_250":251,"_252":91,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","518c05f2c13b243481ef29134a5672756425e459","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 · v18