[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_175":176,"_177":178},"routes/_app.x.$handle.$name",{"_99":98,"_31":44,"_108":89,"_26":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":24,"_123":124,"_125":24,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",2,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","backend/auth.ts","latestPath","fileId","37cb20e4-b013-11f1-9622-1607ee4eb77e","name","auth.ts","fileType","script","content","// Вход по ПИН-коду — единый с «Воронкой дня»: ПИНы проверяются через её /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","createdAt",["D",1789373201197],"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",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},"branch",{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"isOwned",98,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tambovtsev007","handle","displayName","Кирилл Тамбовцев","avatar","https://lh3.googleusercontent.com/a/ACg8ocKCNneTjcn307kcxhB_NS1R7_0SBhSKM-2hy73z0JvhXFipwkhs=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":170,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":171,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":172,"_83":173,"_85":174,"_87":24},"tree",[152],"files",[152,153,154],"counts",{"_141":62,"_142":135,"_143":62,"_144":145,"_146":147},"contents",[130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":131,"_31":132,"_29":133,"_134":-5,"_40":41,"_39":135,"_136":58,"_37":137,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":140},"7341a1cc-7dfc-4e42-b726-1f50a9135807","backend","2d175de9-e314-46bc-b472-7c5eb74535c8","parentId",1,"latest",["D",1789373200842],"directory","label",[132],"pulls","branches","forks","envVars",{"_148":150,"_151":62},"connections",{"_148":62,"_149":62},"count","unfilledCount",3,"emptyCount",{"_42":131,"_31":132,"_29":133,"_134":-5,"_40":41,"_39":135,"_136":58,"_37":167,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_160":168,"_26":169},{"_42":163,"_31":32,"_29":30,"_134":133,"_40":41,"_39":14,"_136":58,"_37":164,"_13":62,"_33":34,"_35":36,"_23":24,"_139":-5,"_160":165,"_26":166},{"_42":155,"_31":156,"_29":157,"_134":133,"_40":41,"_39":135,"_136":24,"_37":158,"_13":62,"_33":34,"_35":159,"_23":24,"_139":-5,"_160":161,"_26":162},"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","children",[],[132,156],"75391e84-27fc-4b3e-bd38-580217124b24",["D",1789373201197],[],[132,32],["D",1789373200842],[153,154],[132],["D",1789373200178],["D",1789547455787],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_127":208,"_209":210,"_211":212,"_213":24,"_214":24,"_215":24,"_216":58,"_217":-5,"_218":-7,"_219":-7,"_220":62,"_221":24,"_222":24,"_223":-5,"_224":24,"_225":24,"_226":24,"_227":-5},"ENV",{"_179":180,"_181":182,"_183":89,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v2