SendPulse Helper — политика конфиденциальности

Личное расширение Chrome для собственного удобства в работе с SendPulse.\nНе распространяется публично.

\n\n

Что делает расширение

Голосовые сообщения. Кнопка в открытом чате SendPulse записывает\nголосовое через микрофон браузера и вкладывает файл в стандартное поле\nзагрузки вложений на той же странице — пользователь сам нажимает\n«Отправить». Запись никуда не передаётся и не сохраняется расширением; она\nсуществует только в памяти вкладки браузера до момента прикрепления.

Поиск чата по номеру телефона. Номер телефона, который пользователь\nвводит в поле поиска, отправляется на личный сервер поиска для нахождения\nсоответствующего чата в SendPulse. Сервер возвращает ссылку на найденный\nчат.

\n\n

Какие данные обрабатываются

Единственные данные, которые расширение передаёт за пределы страницы —\nномер телефона, введённый в поиске. Он используется исключительно для поиска\nчата и может кратковременно присутствовать в технических логах сервера (для\nотладки), но не передаётся третьим лицам, не продаётся, не используется для\nрекламы, аналитики или профилирования.

\n\n

Что расширение не делает

Не собирает историю переписки, не читает содержимое чатов, не отслеживает\nдействия за пределами страниц login.sendpulse.com, не\nустанавливает сторонние библиотеки или трекеры.

\n\n

Контакты

По вопросам — timporello@gmail.com

\n`;\n\nfunction j(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: {\n \"Content-Type\": \"application/json; charset=utf-8\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n}\n\n// phone recovery for route_deal (MoonAI never passes it): exact match -> fuzzy -> most-recent-inbound fallback.\nconst INBOUND_MSG_TTL = 30 * 60 * 1000;\nconst LAST_INBOUND_WINDOW = 60 * 1000;\nconst LAST_KEY = \"__last_inbound__\";\nlet msgTableReady: Promise | null = null;\nfunction ensureMsgTable(): Promise {\n if (!msgTableReady) {\n msgTableReady = sqlite\n .execute(\n \"CREATE TABLE IF NOT EXISTS msg_phone (k TEXT PRIMARY KEY, phone TEXT NOT NULL, ts INTEGER NOT NULL)\",\n )\n .then(() => {})\n .catch((e) => {\n console.log(\"msg_phone table init failed\", String(e));\n msgTableReady = null;\n });\n }\n return msgTableReady ?? Promise.resolve();\n}\nfunction normMsg(s: string): string {\n return String(s || \"\").toLowerCase().replace(/\\s+/g, \" \").trim().slice(\n 0,\n 240,\n );\n}\nasync function rememberInbound(text: string, phone: string): Promise {\n const k = normMsg(text);\n const digits = String(phone || \"\").replace(/[^\\d]/g, \"\");\n if (digits.length < 10) return;\n const now = Date.now();\n try {\n await ensureMsgTable();\n const rows = [{ k: LAST_KEY, p: digits, t: now }];\n if (k.length >= 4) rows.push({ k, p: digits, t: now });\n for (const row of rows) {\n await sqlite.execute({\n sql: \"INSERT INTO msg_phone (k, phone, ts) VALUES (:k, :p, :t) \" +\n \"ON CONFLICT(k) DO UPDATE SET phone = :p, ts = :t\",\n args: row,\n });\n }\n await sqlite.execute({\n sql: \"DELETE FROM msg_phone WHERE ts < :cut\",\n args: { cut: now - INBOUND_MSG_TTL },\n });\n } catch (e) {\n console.log(\"rememberInbound failed\", String(e));\n }\n}\nfunction isGreetingOnly(nk: string): boolean {\n const s = nk.replace(/[^a-zа-яёЀ-ӿ ]/gi, \"\").trim();\n return s.length < 14 ||\n /^(салем|сәлем|сәлеметсіз бе|саламатсыз ба|привет|здравствуйте|здрасте|добрый день|добрый вечер|доброе утро|hi|hello|assalam|ассалам)/i\n .test(s);\n}\nasync function phoneForMessage(text: string): Promise {\n const nk = normMsg(text);\n const now = Date.now();\n const weakKey = isGreetingOnly(nk);\n try {\n await ensureMsgTable();\n // 1. exact\n if (!weakKey && nk.length >= 12) {\n const r = await sqlite.execute({\n sql:\n \"SELECT phone FROM msg_phone WHERE k = :k AND ts > :cut ORDER BY ts DESC LIMIT 1\",\n args: { k: nk, cut: now - INBOUND_MSG_TTL },\n });\n if (r.rows && r.rows[0]) return String((r.rows[0] as unknown[])[0] || \"\");\n }\n // 2. fuzzy against recent relayed messages\n if (!weakKey && nk.length >= 14) {\n const r = await sqlite.execute({\n sql:\n \"SELECT k, phone FROM msg_phone WHERE ts > :cut AND k != :last ORDER BY ts DESC LIMIT 60\",\n args: { cut: now - INBOUND_MSG_TTL, last: LAST_KEY },\n });\n for (const row of (r.rows || []) as unknown[][]) {\n const rk = String(row[0] || \"\");\n if (\n rk.length >= 8 &&\n (nk.includes(rk) || rk.includes(nk) ||\n nk.slice(0, 20) === rk.slice(0, 20))\n ) {\n return String(row[1] || \"\");\n }\n }\n }\n // 3. most recent inbound within the window\n const r = await sqlite.execute({\n sql: \"SELECT phone FROM msg_phone WHERE k = :last AND ts > :cut LIMIT 1\",\n args: { last: LAST_KEY, cut: now - LAST_INBOUND_WINDOW },\n });\n if (r.rows && r.rows[0]) return String((r.rows[0] as unknown[])[0] || \"\");\n return \"\";\n } catch (e) {\n console.log(\"phoneForMessage failed\", String(e));\n return \"\";\n }\n}\n\n// manager takeover = a human operator WRITES (opening the chat alone doesn't count); MGR_PAUSE_MS is the rolling silence window.\nconst MGR_PAUSE_MS = (Number(Deno.env.get(\"MGR_PAUSE_MINUTES\")) || 120) * 60 *\n 1000;\nlet mgrTableReady: Promise | null = null;\nfunction ensureMgrTable(): Promise {\n if (!mgrTableReady) {\n mgrTableReady = sqlite\n .execute(\n \"CREATE TABLE IF NOT EXISTS mgr_active (thread TEXT PRIMARY KEY, ts INTEGER NOT NULL)\",\n )\n .then(() => {})\n .catch((e) => {\n console.log(\"mgr_active init failed\", String(e));\n mgrTableReady = null;\n });\n }\n return mgrTableReady ?? Promise.resolve();\n}\nasync function markManagerActive(thread: string): Promise {\n const t = String(thread || \"\").replace(/[^\\d]/g, \"\");\n if (t.length < 10) return;\n try {\n await ensureMgrTable();\n await sqlite.execute({\n sql: \"INSERT INTO mgr_active (thread, ts) VALUES (:t, :n) \" +\n \"ON CONFLICT(thread) DO UPDATE SET ts = :n\",\n args: { t, n: Date.now() },\n });\n } catch (e) {\n console.log(\"markManagerActive failed\", String(e));\n }\n await clearMediaPending(t).catch((e) =>\n console.log(\"clearMediaPending failed\", String(e))\n );\n}\n\n// media_pending: set by escalateMedia, cleared in markManagerActive — \"until a manager connects\", not a rolling window.\nlet mediaPendingTableReady: Promise | null = null;\nfunction ensureMediaPendingTable(): Promise {\n if (!mediaPendingTableReady) {\n mediaPendingTableReady = sqlite\n .execute(\n \"CREATE TABLE IF NOT EXISTS media_pending (phone TEXT PRIMARY KEY, ts INTEGER NOT NULL)\",\n )\n .then(() => {})\n .catch((e) => {\n console.log(\"media_pending init failed\", String(e));\n mediaPendingTableReady = null;\n });\n }\n return mediaPendingTableReady ?? Promise.resolve();\n}\nasync function setMediaPending(phone: string): Promise {\n const p = String(phone || \"\").replace(/[^\\d]/g, \"\");\n if (p.length < 10) return;\n try {\n await ensureMediaPendingTable();\n await sqlite.execute({\n sql: \"INSERT INTO media_pending (phone, ts) VALUES (:p, :t) \" +\n \"ON CONFLICT(phone) DO UPDATE SET ts = :t\",\n args: { p, t: Date.now() },\n });\n } catch (e) {\n console.log(\"setMediaPending failed\", String(e));\n }\n}\nasync function clearMediaPending(phone: string): Promise {\n const p = String(phone || \"\").replace(/[^\\d]/g, \"\");\n if (p.length < 10) return;\n try {\n await ensureMediaPendingTable();\n await sqlite.execute({\n sql: \"DELETE FROM media_pending WHERE phone = :p\",\n args: { p },\n });\n } catch (e) {\n console.log(\"clearMediaPending failed\", String(e));\n }\n}\nasync function isMediaPending(phone: string): Promise {\n const p = String(phone || \"\").replace(/[^\\d]/g, \"\");\n if (p.length < 10) return false;\n try {\n await ensureMediaPendingTable();\n const r = await sqlite.execute({\n sql: \"SELECT 1 FROM media_pending WHERE phone = :p LIMIT 1\",\n args: { p },\n });\n return !!(r.rows && r.rows[0]);\n } catch (e) {\n console.log(\"isMediaPending failed\", String(e));\n return false;\n }\n}\nasync function isManagerActive(thread: string): Promise {\n const t = String(thread || \"\").replace(/[^\\d]/g, \"\");\n if (t.length < 10) return false;\n try {\n await ensureMgrTable();\n const r = await sqlite.execute({\n sql: \"SELECT ts FROM mgr_active WHERE thread = :t\",\n args: { t },\n });\n const ts = r.rows && r.rows[0] ? Number((r.rows[0] as unknown[])[0]) : 0;\n if (!ts) return false;\n if (Date.now() - ts > MGR_PAUSE_MS) {\n await sqlite.execute({\n sql: \"DELETE FROM mgr_active WHERE thread = :t\",\n args: { t },\n });\n return false;\n }\n return true;\n } catch (e) {\n console.log(\"isManagerActive failed\", String(e));\n return false;\n }\n}\n\n// per-phone salt appended to the MoonAI thread_id so POST /reset starts a fresh conversation; handleOutbound strips \"|\".\nlet saltTableReady: Promise | null = null;\nfunction ensureSaltTable(): Promise {\n if (!saltTableReady) {\n saltTableReady = sqlite\n .execute(\n \"CREATE TABLE IF NOT EXISTS thread_salt (phone TEXT PRIMARY KEY, salt TEXT NOT NULL, ts INTEGER NOT NULL)\",\n )\n .then(() => {})\n .catch((e) => {\n console.log(\"thread_salt init failed\", String(e));\n saltTableReady = null;\n });\n }\n return saltTableReady ?? Promise.resolve();\n}\nasync function saltFor(phone: string): Promise {\n const p = String(phone || \"\").replace(/[^\\d]/g, \"\");\n if (p.length < 10) return \"\";\n try {\n await ensureSaltTable();\n const r = await sqlite.execute({\n sql: \"SELECT salt FROM thread_salt WHERE phone = :p\",\n args: { p },\n });\n if (r.rows && r.rows[0]) return String((r.rows[0] as unknown[])[0] || \"\");\n } catch (_e) { /* ignore */ }\n return \"\";\n}\n\nlet spTok = \"\";\nlet spTokExp = 0;\nasync function spToken(): Promise {\n if (spTok && Date.now() < spTokExp) return spTok;\n const r = await fetch(SP_API + \"/oauth/access_token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n grant_type: \"client_credentials\",\n client_id: Deno.env.get(\"SP_CLIENT_ID\"),\n client_secret: Deno.env.get(\"SP_CLIENT_SECRET\"),\n }),\n });\n const d = await r.json().catch(() => ({}));\n spTok = d.access_token || \"\";\n spTokExp = Date.now() +\n Math.max(0, (Number(d.expires_in) || 3600) - 120) * 1000;\n if (!spTok) {\n throw new Error(\"sp_oauth_failed: \" + JSON.stringify(d).slice(0, 300));\n }\n return spTok;\n}\n\nasync function handleInbound(body: string): Promise {\n const key = Deno.env.get(\"MOONAI_API_KEY\");\n if (!key) return j({ ok: false, error: \"no_moonai_key\" }, 500);\n\n let events: any;\n try {\n events = JSON.parse(body || \"[]\");\n } catch {\n return j({ ok: false, error: \"bad_json\" }, 400);\n }\n if (!Array.isArray(events)) events = [events];\n\n const results: any[] = [];\n for (const ev of events) {\n const title = ev?.title || ev?.event || \"\";\n\n if (title === \"outgoing_message\" || title === \"open_chat\") {\n const om = ev?.info?.message ?? ev?.message ?? {};\n const sentBy = om?.sent_by ?? ev?.info?.sent_by ?? ev?.sent_by ?? null;\n const chan = String(\n om?.channel ?? ev?.info?.channel ?? ev?.channel ?? \"\",\n );\n const human = title === \"outgoing_message\" && (\n (sentBy && typeof sentBy === \"object\") ||\n (typeof sentBy === \"number\" && sentBy > 0) ||\n chan === \"ma\"\n );\n const c = ev?.contact || {};\n const ph = String(\n c?.channel_data?.phone ?? c?.phone ?? c?.username ?? om?.to ??\n om?.from ?? \"\",\n ).replace(/[^\\d]/g, \"\");\n console.log(\n \"INBOUND\",\n title,\n JSON.stringify({ human, chan, by: sentBy && (sentBy.id ?? sentBy), ph })\n .slice(0, 200),\n );\n if (human && ph) {\n await markManagerActive(ph);\n const mtext = om?.data?.text?.body ?? om?.text?.body ??\n om?.data?.text ?? om?.text ?? \"\";\n if (mtext) {\n try {\n await fetch(MOONAI_INBOUND, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"X-API-Key\": key },\n body: JSON.stringify({\n thread_id: ph,\n source: SOURCE,\n from_type: \"operator\",\n from_name: \"Менеджер\",\n message_type: \"text\",\n data: { text: String(mtext) },\n }),\n });\n } catch (_e) { /* proxy-side mute is the real guarantee */ }\n }\n }\n results.push({ handled: title, managerActive: !!(human && ph) });\n continue;\n }\n\n if (title !== \"incoming_message\" && title !== \"message\") {\n results.push({ skipped: title || \"no_title\" });\n continue;\n }\n\n const msg = ev?.info?.message?.channel_data?.message || {};\n const contact = ev?.contact || {};\n const phone = String(\n msg?.from ?? contact?.phone ?? contact?.username ?? \"\",\n ).replace(/[^\\d]/g, \"\");\n\n // MUST be awaited — val.town drops an unawaited multi-call chain once the response is sent (confirmed live 2026-09-11).\n if (phone) {\n await ensureInboxCard(phone).catch((e) =>\n console.log(\"inbox card failed\", String(e))\n );\n }\n\n const mainBot = Deno.env.get(\"SP_BOT_ID\") || \"\";\n const botId = String(ev?.bot?.id || ev?.bot?._id || mainBot);\n\n const mediaType = String(msg?.type || \"\");\n if (MEDIA_LABELS[mediaType]) {\n const caption = String(\n msg?.image?.caption ?? msg?.video?.caption ?? msg?.document?.caption ??\n \"\",\n );\n if (phone) {\n await escalateMedia(phone, mediaType, caption, botId).catch((e) =>\n console.log(\"escalateMedia failed\", String(e))\n );\n }\n results.push({ skipped: \"media_escalated\", mediaType, phone });\n continue;\n }\n\n // repeat message after a media escalation, before a manager connects: skip MoonAI, send the followup ack instead.\n if (phone && await isMediaPending(phone)) {\n const ackText = isCallCenterOpen(Date.now())\n ? MEDIA_FOLLOWUP_WORKHOURS_TEXT\n : MEDIA_ACK_TEXT;\n try {\n const tok = await spToken();\n const ackResp = await fetch(SP_API + \"/whatsapp/contacts/sendByPhone\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: \"Bearer \" + tok,\n },\n body: JSON.stringify({\n bot_id: botId || mainBot,\n phone,\n message: { type: \"text\", text: { body: ackText } },\n }),\n });\n console.log(\"MEDIA followup ack\", phone, \"->\", ackResp.status);\n } catch (e) {\n console.log(\"MEDIA followup ack failed\", String(e));\n }\n results.push({ skipped: \"media_pending_followup\", phone });\n continue;\n }\n\n const text = msg?.text?.body ??\n msg?.button?.text ??\n msg?.interactive?.list_reply?.title ??\n msg?.interactive?.button_reply?.title ??\n ev?.info?.message?.text ??\n ev?.message?.text ??\n ev?.text ??\n \"\";\n const suffix = botId && botId !== mainBot ? \"__\" + botId : \"\";\n // reset salt (POST /reset) -> fresh MoonAI conversation for this phone\n const salt = phone ? await saltFor(phone) : \"\";\n const threadId = phone\n ? phone + suffix + (salt ? \"|\" + salt : \"\")\n : String(contact?.id || \"unknown\");\n // never surface the WhatsApp profile name — \"client_\" everywhere (from_name -> MoonAI's messenger_username param).\n const fromName = phone ? \"client_\" + phone : \"client_unknown\";\n\n if (!text) {\n results.push({ skipped: \"no_text\", threadId });\n continue;\n }\n if (phone) await rememberInbound(String(text), phone);\n\n const payload = {\n thread_id: threadId,\n source: SOURCE,\n from_type: \"user\",\n from_name: fromName,\n message_type: \"text\",\n data: { text: String(text) },\n };\n const r = await fetch(MOONAI_INBOUND, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"X-API-Key\": key },\n body: JSON.stringify(payload),\n });\n const rt = await r.text();\n console.log(\"INBOUND\", threadId, \"->\", r.status, rt.slice(0, 300));\n results.push({\n threadId,\n moonai_status: r.status,\n moonai_body: rt.slice(0, 300),\n });\n }\n // fire-and-forget nudge for the (self-throttled) responsible-owner sync — must never delay the inbound relay.\n if (results.some((r) => r.moonai_status)) {\n syncResponsible().catch((e) => console.log(\"sync nudge failed\", String(e)));\n }\n return j({ ok: true, results });\n}\n\nasync function handleOutbound(body: string): Promise {\n let ev: any;\n try {\n ev = JSON.parse(body || \"{}\");\n } catch {\n return j({ ok: false, error: \"bad_json\" }, 400);\n }\n\n const type = ev?.event_type || \"\";\n if (type !== \"agent_message\" && type !== \"manager_message\") {\n console.log(\"OUTBOUND skip\", type);\n return j({ ok: true, skipped: type || \"no_type\" });\n }\n const m = ev?.message || {};\n if ((m?.message_type || \"text\") !== \"text\") {\n console.log(\"OUTBOUND skip non-text\", m?.message_type);\n return j({ ok: true, skipped: \"non_text:\" + m?.message_type });\n }\n let text = m?.data?.text ?? m?.text ?? \"\";\n // strip leaked markdown fences / whitespace the model sometimes emits\n text = String(text).replace(/```+/g, \"\").replace(/^[\\s`]+|[\\s`]+$/g, \"\");\n const threadId = String(ev?.external_thread_id ?? ev?.thread_id ?? \"\")\n .replace(/^api:[^:]+:/, \"\")\n .replace(/\\|.*$/, \"\"); // drop the reset salt (\"[__]|\")\n if (!text || !threadId) {\n return j({ ok: false, error: \"missing_text_or_thread\", threadId }, 400);\n }\n\n // threadId may be \"__\" (non-main bot) or just \"\"\n const [phonePart, botPart] = threadId.split(\"__\");\n\n // A human operator is handling this chat -> the bot stays out of the way.\n if (await isManagerActive(phonePart)) {\n console.log(\n \"OUTBOUND suppressed (manager active)\",\n phonePart,\n \"|\",\n String(text).slice(0, 80),\n );\n return j({ ok: true, skipped: \"manager_active\", thread: phonePart });\n }\n\n const authoritative = authoritativeCargoText(text);\n if (authoritative) {\n console.log(\n \"OUTBOUND cargo-override\",\n JSON.stringify({\n was: String(text).slice(0, 120),\n now: authoritative.slice(0, 120),\n }),\n );\n text = authoritative;\n }\n\n const digits = String(phonePart || \"\").replace(/[^\\d]/g, \"\");\n const botId = botPart || Deno.env.get(\"SP_BOT_ID\");\n const tok = await spToken();\n\n let endpoint: string;\n let reqBody: string;\n if (digits.length >= 10) {\n endpoint = SP_API + \"/whatsapp/contacts/sendByPhone\";\n reqBody = JSON.stringify({\n bot_id: botId,\n phone: digits,\n message: { type: \"text\", text: { body: String(text) } },\n });\n } else {\n endpoint = SP_API + \"/whatsapp/contacts/send\";\n reqBody = JSON.stringify({\n contact_id: threadId,\n message: { type: \"text\", text: { body: String(text) } },\n });\n }\n\n const r = await fetch(endpoint, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: \"Bearer \" + tok,\n },\n body: reqBody,\n });\n const rt = await r.text();\n console.log(\"OUTBOUND\", digits || threadId, \"->\", r.status, rt.slice(0, 400));\n return j({\n ok: r.ok,\n sp_status: r.status,\n sp_body: rt.slice(0, 400),\n cargo_override: !!authoritative,\n sent_text: String(text).slice(0, 200),\n });\n}\n\n// keeps responsibleId identical across each open deal + its linked contacts/tasks (last-writer-wins).\nconst SYNC_PIPELINES = [183193, 183194, 183195, 183196, 182841];\nconst SYNC_BOARD = 164785;\nconst SYNC_TASK_DONE_STEP = 498988;\nconst SYNC_MIN_GAP = 60 * 1000;\nlet syncRunning = false;\nlet syncLastRun = 0;\nlet respTableReady: Promise | null = null;\n\nfunction ensureRespTable(): Promise {\n if (!respTableReady) {\n respTableReady = sqlite\n .execute(\n \"CREATE TABLE IF NOT EXISTS resp_state (k TEXT PRIMARY KEY, resp INTEGER NOT NULL, ts INTEGER NOT NULL)\",\n )\n .then(() => {})\n .catch((e) => {\n console.log(\"resp_state init failed\", String(e));\n respTableReady = null;\n });\n }\n return respTableReady ?? Promise.resolve();\n}\n\nasync function spCrm(\n method: string,\n path: string,\n body?: unknown,\n): Promise {\n const tok = await spToken();\n const r = await fetch(SP_API + \"/crm/v1\" + path, {\n method,\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: \"Bearer \" + tok,\n },\n body: body === undefined ? undefined : JSON.stringify(body),\n });\n const txt = await r.text();\n let data: any = null;\n try {\n data = txt ? JSON.parse(txt) : null;\n } catch {\n data = txt;\n }\n if (!r.ok) {\n throw new Error(\n method + \" \" + path + \" -> \" + r.status + \" \" + txt.slice(0, 200),\n );\n }\n return data;\n}\n\nasync function priorResp(k: string): Promise {\n try {\n const r = await sqlite.execute({\n sql: \"SELECT resp FROM resp_state WHERE k = :k\",\n args: { k },\n });\n if (r.rows && r.rows[0]) return Number((r.rows[0] as unknown[])[0]);\n } catch (_e) { /* ignore */ }\n return null;\n}\nasync function recordResp(k: string, resp: number): Promise {\n try {\n await sqlite.execute({\n sql: \"INSERT INTO resp_state (k, resp, ts) VALUES (:k, :r, :t) \" +\n \"ON CONFLICT(k) DO UPDATE SET resp = :r, ts = :t\",\n args: { k, r: resp, t: Date.now() },\n });\n } catch (_e) { /* ignore */ }\n}\n\nasync function syncResponsible(): Promise {\n if (syncRunning) return { ok: true, skipped: \"running\" };\n if (Date.now() - syncLastRun < SYNC_MIN_GAP) {\n return { ok: true, skipped: \"throttled\" };\n }\n syncRunning = true;\n syncLastRun = Date.now();\n const changes: any[] = [];\n const errors: any[] = [];\n try {\n await ensureRespTable();\n\n const deals: any[] = [];\n for (const p of SYNC_PIPELINES) {\n try {\n const d = await spCrm(\"POST\", \"/deals/get-list\", {\n pipelineIds: [p],\n limit: 50,\n filter: [{\n name: \"stepId\",\n expression: \"neq\",\n value: String(INBOX_STEP[p] || 0),\n }],\n });\n for (const x of (d?.data || [])) {\n if ((x.status ?? 1) === 1) deals.push(x);\n }\n } catch (e) {\n errors.push({ pipeline: p, error: String(e) });\n }\n }\n\n // dealId -> [full task], every not-done task on the board\n const tasksByDeal = new Map();\n try {\n for (let off = 0; off < 500; off += 50) {\n const tr = await spCrm(\"POST\", \"/tasks/list\", {\n boardId: SYNC_BOARD,\n limit: 50,\n offset: off,\n });\n const list = tr?.data || [];\n for (const row of list) {\n if (row.stepId === SYNC_TASK_DONE_STEP || row.status === 2) continue;\n let full: any = null;\n try {\n full = await spCrm(\"GET\", \"/tasks/\" + row.id);\n } catch (_e) {\n continue;\n }\n const tk = full?.data || {};\n for (const did of (tk.deals || [])) {\n if (!tasksByDeal.has(did)) tasksByDeal.set(did, []);\n tasksByDeal.get(did)!.push(tk);\n }\n }\n if (list.length < 50) break;\n }\n } catch (e) {\n errors.push({ tasks: true, error: String(e) });\n }\n\n for (const deal of deals) {\n try {\n const dc = await spCrm(\"GET\", \"/deals/\" + deal.id + \"/contacts\");\n const contacts = dc?.data || [];\n const tks = tasksByDeal.get(deal.id) || [];\n\n try {\n const cattr = CHAT_ATTR[Number(deal.pipelineId)];\n const cur = (deal.attributes || []).find((a: any) =>\n Number(a.id) === cattr\n );\n const curVal = cur &&\n (typeof cur.value === \"object\" ? cur.value?.value : cur.value);\n if (cattr && !curVal && contacts[0]) {\n const cl = await fillChatLink(\n Number(deal.id),\n Number(deal.pipelineId),\n contacts[0],\n contacts[0]?.phones?.[0]?.phone || \"\",\n );\n if (cl && cl.url) changes.push({ deal: deal.id, chatLink: cl.url });\n }\n } catch (_e) { /* ignore */ }\n\n type M = {\n key: string;\n resp: number;\n upd: string;\n put: (rid: number) => Promise;\n };\n const members: M[] = [];\n members.push({\n key: \"d:\" + deal.id,\n resp: Number(deal.responsibleId) || 0,\n upd: String(deal.updatedAt || \"\"),\n put: (rid) =>\n spCrm(\"PUT\", \"/deals/\" + deal.id, {\n pipelineId: deal.pipelineId,\n status: deal.status ?? 1,\n stepId: deal.stepId,\n name: deal.name,\n price: deal.price ?? 0,\n currency: deal.currency || \"KZT\",\n responsibleId: rid,\n }),\n });\n for (const c of contacts) {\n members.push({\n key: \"c:\" + c.id,\n resp: Number(c.responsibleId) || 0,\n upd: String(c.updatedAt || \"\"),\n put: (rid) =>\n spCrm(\"PUT\", \"/contacts/\" + c.id, {\n responsibleId: rid,\n firstName: c.firstName || (\"Контакт \" + c.id),\n lastName: c.lastName || \"\",\n }),\n });\n }\n for (const tk of tks) {\n members.push({\n key: \"t:\" + tk.id,\n resp: Number(tk.responsibleId) || 0,\n upd: String(tk.updatedAt || \"\"),\n put: (rid) =>\n spCrm(\"PUT\", \"/tasks/\" + tk.id, {\n name: tk.name,\n boardId: tk.boardId || SYNC_BOARD,\n stepId: tk.stepId,\n priority: tk.priority ?? 2,\n responsibleId: rid,\n }),\n });\n }\n\n const live = members.filter((m) => m.resp > 0);\n if (live.length < 2) {\n for (const m of live) await recordResp(m.key, m.resp);\n continue;\n }\n if (new Set(live.map((m) => m.resp)).size === 1) {\n for (const m of live) await recordResp(m.key, m.resp);\n continue;\n }\n\n const moved: M[] = [];\n for (const m of live) {\n const prev = await priorResp(m.key);\n if (prev !== null && prev !== m.resp) moved.push(m);\n }\n let canonical: number;\n if (moved.length) {\n moved.sort((a, b) => (a.upd < b.upd ? 1 : -1));\n canonical = moved[0].resp;\n } else {\n canonical =\n [...live].sort((a, b) => (a.upd < b.upd ? 1 : -1))[0].resp;\n }\n\n for (const m of live) {\n if (m.resp !== canonical) {\n try {\n await m.put(canonical);\n changes.push({\n deal: deal.id,\n member: m.key,\n from: m.resp,\n to: canonical,\n });\n } catch (e) {\n errors.push({ deal: deal.id, member: m.key, error: String(e) });\n }\n }\n await recordResp(m.key, canonical);\n }\n } catch (e) {\n errors.push({ deal: deal.id, error: String(e) });\n }\n }\n\n try {\n await sqlite.execute({\n sql: \"DELETE FROM resp_state WHERE ts < :cut\",\n args: { cut: Date.now() - 14 * 24 * 60 * 60 * 1000 },\n });\n } catch (_e) { /* ignore */ }\n\n return { ok: true, deals: deals.length, changes, errors };\n } catch (e) {\n return { ok: false, error: String(e), changes, errors };\n } finally {\n syncRunning = false;\n }\n}\n\n// fewest-open-deals wins within a pool, ties round-robin; Алия (9501075) is in no pool.\nconst LANG_MANAGERS: Record = {\n RU: [9501565, 9501561],\n KZ: [9501565, 9501561, 9504155, 9501563],\n CN: [9504155, 9501563],\n};\n// per-pipeline override, wins over language; 182841 has none, falls back to LANG_MANAGERS.\nconst POOL_BY_PIPELINE: Record = {\n 183194: [9501565, 9501561, 9501563],\n 183193: [9501563, 9504155, 9501565],\n 183196: [9501565, 9501561, 9501563, 9504155],\n 183195: [9501075],\n};\nlet rrTableReady: Promise | null = null;\nfunction ensureRrTable(): Promise {\n if (!rrTableReady) {\n rrTableReady = sqlite\n .execute(\n \"CREATE TABLE IF NOT EXISTS assign_rr (k TEXT PRIMARY KEY, n INTEGER NOT NULL)\",\n )\n .then(() => {})\n .catch((e) => {\n console.log(\"assign_rr init failed\", String(e));\n rrTableReady = null;\n });\n }\n return rrTableReady ?? Promise.resolve();\n}\nasync function rrNext(k: string): Promise {\n try {\n await ensureRrTable();\n const r = await sqlite.execute({\n sql: \"SELECT n FROM assign_rr WHERE k = :k\",\n args: { k },\n });\n const n = r.rows && r.rows[0] ? Number((r.rows[0] as unknown[])[0]) : 0;\n await sqlite.execute({\n sql:\n \"INSERT INTO assign_rr (k, n) VALUES (:k, 1) ON CONFLICT(k) DO UPDATE SET n = n + 1\",\n args: { k },\n });\n return n;\n } catch (_e) {\n return 0;\n }\n}\nasync function assignDealByLang(\n dealId: number,\n lang: string,\n pipelineId?: number,\n): Promise {\n const L = String(lang || \"\").trim().toUpperCase();\n const pool = POOL_BY_PIPELINE[Number(pipelineId) || 0] || LANG_MANAGERS[L] ||\n LANG_MANAGERS.RU;\n let rid = pool[0];\n if (pool.length > 1) {\n const load = new Map(pool.map((r) => [r, 0]));\n await Promise.all(SYNC_PIPELINES.map(async (p) => {\n try {\n const d = await spCrm(\"POST\", \"/deals/get-list\", {\n pipelineIds: [p],\n limit: 50,\n filter: [{\n name: \"stepId\",\n expression: \"neq\",\n value: String(INBOX_STEP[p] || 0),\n }],\n });\n for (const x of (d?.data || [])) {\n const r = Number(x.responsibleId);\n if ((x.status ?? 1) === 1 && load.has(r)) {\n load.set(r, (load.get(r) || 0) + 1);\n }\n }\n } catch (_e) { /* ignore a bad pipeline */ }\n }));\n const min = Math.min(...pool.map((r) => load.get(r) ?? 0));\n const tied = pool.filter((r) => (load.get(r) ?? 0) === min);\n rid = tied.length === 1\n ? tied[0]\n : tied[await rrNext(\"lang:\" + L) % tied.length];\n }\n const g = await spCrm(\"GET\", \"/deals/\" + dealId);\n const dl = g?.data || {};\n if (!dl.id) return { dealId, error: \"deal_not_found\" };\n if (Number(dl.responsibleId) === rid) {\n return { dealId, rid, lang: L, skipped: \"already\" };\n }\n await spCrm(\"PUT\", \"/deals/\" + dealId, {\n pipelineId: dl.pipelineId,\n status: dl.status ?? 1,\n stepId: dl.stepId,\n name: dl.name,\n price: dl.price ?? 0,\n currency: dl.currency || \"KZT\",\n responsibleId: rid,\n });\n return { dealId, lang: L, rid, from: Number(dl.responsibleId) || 0 };\n}\n\n// per-pipeline \"Чат\" (Link) attribute -> direct URL into the client's WhatsApp dialog, on whichever bot the chat lives on.\nconst CHAT_ATTR: Record = {\n 183193: 1117964,\n 183194: 1117965,\n 183195: 1117966,\n 183196: 1117967,\n 182841: 1117968,\n};\nconst SP_BOTS = [\"69974943d7855b67ca0aa73d\", \"69974b70bcc6ed11b20fd23f\"];\n\n// route -> pipeline/step/responsible/attribute-ids (2026-09-07 CRM snapshot).\nconst ROUTES: Record<\n string,\n {\n pipelineId: number;\n stepId: number;\n responsibleId: number;\n attrs: Record;\n }\n> = {\n support_hozku: {\n pipelineId: 183193,\n stepId: 637991,\n responsibleId: 9321750,\n attrs: {\n track_code: 1116646,\n business_line: 1116647,\n lang: 1116648,\n theme: 1116649,\n deal_status: 1116650,\n deadline: 1116651,\n intent: 1116652,\n },\n },\n support_posylki: {\n pipelineId: 183194,\n stepId: 637994,\n responsibleId: 9321750,\n attrs: {\n track_code: 1116665,\n business_line: 1116666,\n lang: 1116667,\n theme: 1116668,\n deal_status: 1116669,\n deadline: 1116670,\n intent: 1116671,\n },\n },\n sales: {\n pipelineId: 183195,\n stepId: 637997,\n responsibleId: 9321750,\n attrs: {\n track_code: 1116672,\n business_line: 1116673,\n lang: 1116674,\n theme: 1116675,\n deal_status: 1116676,\n deadline: 1116677,\n intent: 1116678,\n },\n },\n warehouse: {\n pipelineId: 183196,\n stepId: 638000,\n responsibleId: 9321750,\n attrs: {\n track_code: 1116679,\n business_line: 1116680,\n lang: 1116681,\n theme: 1116682,\n deal_status: 1116683,\n deadline: 1116684,\n intent: 1116685,\n },\n },\n accounting: {\n pipelineId: 182841,\n stepId: 636727,\n responsibleId: 9321750,\n attrs: {\n track_code: 1116658,\n business_line: 1116659,\n lang: 1116660,\n theme: 1116661,\n deal_status: 1116662,\n deadline: 1116663,\n intent: 1116664,\n },\n },\n};\nconst BL_MAP: Record = {\n hozku: \"Хозтовары\",\n posylki: \"Посылки\",\n \"ХОЗКУ\": \"Хозтовары\",\n \"Хозтовары\": \"Хозтовары\",\n \"Посылки\": \"Посылки\",\n};\nconst SP_WA_TYPE_ID = 5;\nconst ALA_API_BASE = \"https://backend.alatms.com\";\nconst CARGO_DONE_STATUSES = [\"TERMINAL_ISSUED\"];\nconst SLA_MINUTES = 30;\nfunction almatyDeadline(minutesFromNow: number): string {\n const iso = new Date(Date.now() + minutesFromNow * 60000 + 5 * 3600 * 1000)\n .toISOString();\n return iso.slice(0, 10) + \" \" + iso.slice(11, 16);\n}\n\n// \"Входящие\": throwaway tracking card (once/phone/day, all 5 pipelines); deleted on real escalation, else swept at 17:30.\nconst INBOX_STEP: Record = {\n 183193: 639352,\n 183194: 639353,\n 183195: 639354,\n 183196: 639355,\n 182841: 639356,\n};\nconst INBOX_RESPONSIBLE = 9501075; // Алия — she already just observes/triages\nlet inboxTableReady: Promise | null = null;\nfunction ensureInboxTable(): Promise {\n if (!inboxTableReady) {\n inboxTableReady = sqlite\n .execute(\n \"CREATE TABLE IF NOT EXISTS inbox_cards \" +\n \"(phone TEXT NOT NULL, day TEXT NOT NULL, pipeline_id INTEGER NOT NULL, \" +\n \"deal_id INTEGER NOT NULL, ts INTEGER NOT NULL, PRIMARY KEY (phone, pipeline_id))\",\n )\n .then(() =>\n sqlite.execute(\n \"CREATE TABLE IF NOT EXISTS inbox_cleanup (day TEXT PRIMARY KEY, ts INTEGER NOT NULL)\",\n )\n )\n .then(() => {})\n .catch((e) => {\n console.log(\"inbox_cards init failed\", String(e));\n inboxTableReady = null;\n });\n }\n return inboxTableReady ?? Promise.resolve();\n}\nfunction almatyDateStr(ms: number): string {\n // Asia/Almaty = UTC+5, no DST.\n return new Date(ms + 5 * 3600 * 1000).toISOString().slice(0, 10);\n}\n// call-center hours, Asia/Almaty: 09:00-17:30.\nfunction isCallCenterOpen(ms: number): boolean {\n const almaty = new Date(ms + 5 * 3600 * 1000);\n const mins = almaty.getUTCHours() * 60 + almaty.getUTCMinutes();\n return mins >= 9 * 60 && mins < 17 * 60 + 30;\n}\nasync function ensureInboxCard(phone: string): Promise {\n const digits = String(phone || \"\").replace(/[^\\d]/g, \"\");\n if (digits.length < 10) return { skipped: \"no_phone\" };\n try {\n await ensureInboxTable();\n const day = almatyDateStr(Date.now());\n const seen = await sqlite.execute({\n sql: \"SELECT 1 FROM inbox_cards WHERE phone = :p AND day = :d LIMIT 1\",\n args: { p: digits, d: day },\n });\n if (seen.rows && seen.rows[0]) return { skipped: \"already_today\" };\n\n async function resolveContact(): Promise {\n try {\n const tail = digits.slice(-10);\n const found = await spCrm(\"POST\", \"/contacts/get-list\", {\n phone: digits,\n limit: 20,\n });\n const list = found?.data?.list || found?.data || [];\n for (const c of Array.isArray(list) ? list : []) {\n const pj = JSON.stringify(c?.phones || []).replace(/\\D/g, \"\");\n if (pj.includes(tail)) return Number(c.id);\n }\n const made = await spCrm(\"POST\", \"/contacts\", {\n firstName: \"client_\" + digits,\n phones: [digits],\n messengers: [{ typeId: 5, login: digits }],\n responsibleId: INBOX_RESPONSIBLE,\n });\n return Number(made?.data?.id || made?.id || 0);\n } catch (e) {\n console.log(\"inbox contact resolve failed\", String(e));\n return 0;\n }\n }\n const [contactId, chatUrl] = await Promise.all([\n resolveContact(),\n chatUrlForPhone(digits).catch(() => \"\"),\n ]);\n\n const pids = Object.keys(INBOX_STEP).map(Number);\n const perPipeline = await Promise.all(pids.map(async (pid) => {\n try {\n const body: Record = {\n pipelineId: pid,\n stepId: INBOX_STEP[pid],\n responsibleId: INBOX_RESPONSIBLE,\n name: \"Входящее · \" + digits + \" · \" + day,\n };\n if (contactId) body.contact = [contactId];\n const r = await spCrm(\"POST\", \"/deals\", body);\n const id = r?.data?.id || r?.id;\n if (!id) return null;\n if (chatUrl && CHAT_ATTR[pid]) {\n await spCrm(\"POST\", \"/deals/\" + id + \"/attributes\", {\n attributeId: CHAT_ATTR[pid],\n value: chatUrl,\n }).catch((e) =>\n console.log(\"inbox chat link failed\", pid, String(e))\n );\n }\n await sqlite.execute({\n sql:\n \"INSERT INTO inbox_cards (phone, day, pipeline_id, deal_id, ts) VALUES \" +\n \"(:p, :d, :pid, :did, :t) ON CONFLICT(phone, pipeline_id) DO UPDATE SET \" +\n \"day = :d, deal_id = :did, ts = :t\",\n args: { p: digits, d: day, pid, did: id, t: Date.now() },\n });\n return id as number;\n } catch (e) {\n console.log(\"inbox card create failed\", pid, String(e));\n return null;\n }\n }));\n const created = perPipeline.filter((x): x is number => x != null);\n return { phone: digits, day, contactId, chatUrl: !!chatUrl, created };\n } catch (e) {\n return { error: String(e) };\n }\n}\nasync function deleteInboxCards(phone: string): Promise {\n const digits = String(phone || \"\").replace(/[^\\d]/g, \"\");\n if (digits.length < 10) return { skipped: \"no_phone\" };\n try {\n await ensureInboxTable();\n const r = await sqlite.execute({\n sql: \"SELECT deal_id FROM inbox_cards WHERE phone = :p\",\n args: { p: digits },\n });\n const ids = (r.rows || []).map((row) => Number((row as unknown[])[0]));\n const outcomes = await Promise.all(ids.map(async (id) => {\n try {\n await spCrm(\"DELETE\", \"/deals/\" + id);\n return true;\n } catch (_e) {\n return false; // deal may already be gone\n }\n }));\n const deleted = outcomes.filter(Boolean).length;\n await sqlite.execute({\n sql: \"DELETE FROM inbox_cards WHERE phone = :p\",\n args: { p: digits },\n });\n return { phone: digits, deleted };\n } catch (e) {\n return { error: String(e) };\n }\n}\nasync function cleanupInboxCards(): Promise {\n const now = Date.now();\n const almaty = new Date(now + 5 * 3600 * 1000);\n const hour = almaty.getUTCHours();\n const minute = almaty.getUTCMinutes();\n if (hour < 17 || (hour === 17 && minute < 30)) return { skipped: \"not_yet\" };\n try {\n await ensureInboxTable();\n const day = almatyDateStr(now);\n const done = await sqlite.execute({\n sql: \"SELECT 1 FROM inbox_cleanup WHERE day = :d\",\n args: { d: day },\n });\n if (done.rows && done.rows[0]) return { skipped: \"already_done_today\" };\n const r = await sqlite.execute(\"SELECT phone, deal_id FROM inbox_cards\");\n let deleted = 0;\n const errors: string[] = [];\n for (const row of (r.rows || []) as unknown[][]) {\n const id = Number(row[1]);\n try {\n await spCrm(\"DELETE\", \"/deals/\" + id);\n deleted++;\n } catch (e) {\n errors.push(id + \":\" + String(e));\n }\n }\n await sqlite.execute(\"DELETE FROM inbox_cards\");\n await sqlite.execute({\n sql:\n \"INSERT INTO inbox_cleanup (day, ts) VALUES (:d, :t) ON CONFLICT(day) DO NOTHING\",\n args: { d: day, t: now },\n });\n return { day, deleted, errors };\n } catch (e) {\n return { error: String(e) };\n }\n}\n\nasync function spWaGet(path: string): Promise {\n const tok = await spToken();\n const r = await fetch(SP_API + path, {\n headers: { Authorization: \"Bearer \" + tok },\n });\n return r.json().catch(() => ({}));\n}\nfunction chatUrlFromContact(c: any): string {\n const ms = Array.isArray(c?.messengers) ? c.messengers : [];\n const withUrl = ms.filter((m: any) => m && m.chatbotUrl && m.botId);\n if (!withUrl.length) return \"\";\n withUrl.sort((a: any, b: any) =>\n a.isMainChatbot === b.isMainChatbot ? 0 : a.isMainChatbot ? -1 : 1\n );\n return String(withUrl[0].chatbotUrl || \"\");\n}\n// local phone->chat index for partial search — SendPulse's getByPhone is exact-match only.\nlet phoneDirTableReady: Promise | null = null;\nfunction ensurePhoneDirTable(): Promise {\n if (!phoneDirTableReady) {\n phoneDirTableReady = sqlite\n .execute(\n \"CREATE TABLE IF NOT EXISTS phone_dir (phone TEXT PRIMARY KEY, bot TEXT NOT NULL, wa_id TEXT NOT NULL, ts INTEGER NOT NULL)\",\n )\n .then(() => {})\n .catch((e) => {\n console.log(\"phone_dir init failed\", String(e));\n phoneDirTableReady = null;\n });\n }\n return phoneDirTableReady ?? Promise.resolve();\n}\nasync function rememberPhoneDir(\n phone: string,\n bot: string,\n waId: string,\n): Promise {\n if (phone.length < 10) return;\n try {\n await ensurePhoneDirTable();\n await sqlite.execute({\n sql:\n \"INSERT INTO phone_dir (phone, bot, wa_id, ts) VALUES (:p, :b, :w, :t) \" +\n \"ON CONFLICT(phone) DO UPDATE SET bot = :b, wa_id = :w, ts = :t\",\n args: { p: phone, b: bot, w: waId, t: Date.now() },\n });\n } catch (e) {\n console.log(\"rememberPhoneDir failed\", String(e));\n }\n}\nasync function searchPhoneDir(\n partial: string,\n): Promise<{ phone: string; bot: string; id: string }[]> {\n try {\n await ensurePhoneDirTable();\n const r = await sqlite.execute({\n sql:\n \"SELECT phone, bot, wa_id FROM phone_dir WHERE phone LIKE :q ORDER BY ts DESC LIMIT 20\",\n args: { q: \"%\" + partial + \"%\" },\n });\n return ((r.rows || []) as unknown[][]).map((row) => ({\n phone: String(row[0]),\n bot: String(row[1]),\n id: String(row[2]),\n }));\n } catch (e) {\n console.log(\"searchPhoneDir failed\", String(e));\n return [];\n }\n}\nfunction chatUrlFrom(bot: string, id: string): string {\n return \"https://login.sendpulse.com/messengers/chats/\" + bot +\n \"/contacts/all/\" + id + \"/\";\n}\nasync function resolveWaContact(\n phone: string,\n): Promise<{ bot: string; id: string } | null> {\n const digits = String(phone || \"\").replace(/[^\\d]/g, \"\");\n if (digits.length < 10) return null;\n const hits = await Promise.all(SP_BOTS.map(async (bot) => {\n try {\n const d = await spWaGet(\n \"/whatsapp/contacts/getByPhone?bot_id=\" + bot + \"&phone=\" + digits,\n );\n const c = d?.data;\n if (c && c.id) {\n const key = String(c.last_activity_at || \"0000\") +\n (c.is_chat_opened ? \"_1\" : \"_0\");\n return { bot, id: String(c.id), key };\n }\n } catch (_e) { /* ignore this bot */ }\n return null;\n }));\n let best: { bot: string; id: string; key: string } | null = null;\n for (const h of hits) if (h && (!best || h.key > best.key)) best = h;\n if (best) await rememberPhoneDir(digits, best.bot, best.id);\n return best ? { bot: best.bot, id: best.id } : null;\n}\nasync function chatUrlForPhone(phone: string): Promise {\n const best = await resolveWaContact(phone);\n if (!best) return \"\";\n return chatUrlFrom(best.bot, best.id);\n}\n// mirrors the CRM assignment onto the SendPulse chat (operator + mark-unread); `waContact` skips a redundant resolve.\nasync function syncChatOperator(\n phone: string,\n operatorId: number,\n waContact?: { bot: string; id: string } | null,\n): Promise {\n if (!operatorId) return { skipped: \"no_operator\" };\n const c = waContact !== undefined ? waContact : await resolveWaContact(phone);\n if (!c) return { skipped: \"no_chat_yet\" };\n const tok = await spToken();\n const [assign, unread] = await Promise.all([\n fetch(SP_API + \"/whatsapp/contacts/operators/assign\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: \"Bearer \" + tok,\n },\n body: JSON.stringify({ contact_id: c.id, operator_id: operatorId }),\n }).then((r) => r.json()).catch((e) => ({ error: String(e) })),\n fetch(SP_API + \"/whatsapp/contacts/mark-unread?contact_id=\" + c.id, {\n method: \"PUT\",\n headers: { Authorization: \"Bearer \" + tok },\n }).then((r) => r.json()).catch((e) => ({ error: String(e) })),\n ]);\n return { bot: c.bot, contact_id: c.id, operatorId, assign, unread };\n}\nasync function fillChatLink(\n dealId: number,\n pipelineId: number,\n contact?: any,\n phone?: string,\n waContact?: { bot: string; id: string } | null,\n): Promise {\n const attrId = CHAT_ATTR[pipelineId];\n if (!attrId) return { skipped: \"no_attr_for_pipeline\" };\n let url = contact ? chatUrlFromContact(contact) : \"\";\n if (!url && waContact !== undefined) {\n url = waContact\n ? \"https://login.sendpulse.com/messengers/chats/\" + waContact.bot +\n \"/contacts/all/\" + waContact.id + \"/\"\n : \"\";\n } else if (!url) {\n url = await chatUrlForPhone(\n phone || (contact?.phones?.[0]?.phone) || \"\",\n );\n }\n if (!url) return { skipped: \"no_chat_yet\" };\n try {\n await spCrm(\"POST\", \"/deals/\" + dealId + \"/attributes\", {\n attributeId: attrId,\n value: url,\n });\n return { dealId, url };\n } catch (_e) {\n try {\n await spCrm(\"PUT\", \"/deals/\" + dealId + \"/attributes/\" + attrId, {\n value: url,\n });\n return { dealId, url, via: \"put\" };\n } catch (e) {\n return { dealId, error: String(e) };\n }\n }\n}\n\n// SendPulse CRM business logic, ported in-process from the old Apps Script (variable up to ~19s live).\nfunction matchContact(searchData: any, digitsPhone: string): number | null {\n const list = searchData?.data?.list || searchData?.data || [];\n const tail = digitsPhone.slice(-10);\n for (const c of Array.isArray(list) ? list : []) {\n if (JSON.stringify(c.phones || []).replace(/[^\\d]/g, \"\").includes(tail)) {\n return c.id;\n }\n }\n return null;\n}\nasync function createContact(\n phone: string,\n name: string | undefined,\n responsibleId: number,\n): Promise {\n const r = await spCrm(\"POST\", \"/contacts\", {\n firstName: name || (\"client_\" + phone.slice(-10)),\n phones: [phone],\n messengers: [{ typeId: SP_WA_TYPE_ID, login: phone }],\n responsibleId,\n });\n return r?.data?.id || r?.id || null;\n}\nasync function findOrCreateContact(\n phone: string,\n name: string | undefined,\n responsibleId: number,\n): Promise {\n const f = await spCrm(\"POST\", \"/contacts/get-list\", { phone, limit: 20 });\n return matchContact(f, phone) ||\n await createContact(phone, name, responsibleId);\n}\n// contact-search and open-deal-search are independent — run together via Promise.all, not one after another.\nasync function checkOpenDeal(rb: any): Promise {\n const phone = String(rb.phone || \"\").replace(/[^\\d]/g, \"\");\n let contactId = rb.contact_id;\n let deals: any[];\n const dealQuery = {\n phone,\n pipelineIds: SYNC_PIPELINES,\n limit: 50,\n sortBy: { fieldName: \"createdAt\", direction: \"desc\" },\n };\n if (contactId) {\n deals = (await spCrm(\"POST\", \"/deals/get-list\", dealQuery))?.data || [];\n } else {\n const [searchData, dealData] = await Promise.all([\n spCrm(\"POST\", \"/contacts/get-list\", { phone, limit: 20 }),\n spCrm(\"POST\", \"/deals/get-list\", dealQuery),\n ]);\n contactId = matchContact(searchData, phone) ||\n await createContact(phone, rb.contact_name, 9321750);\n deals = dealData?.data || [];\n }\n let open: any = null;\n for (const d of deals) {\n if (Number(d.status) === 1) {\n open = d;\n break;\n }\n }\n return {\n ok: true,\n contact_id: contactId || null,\n hasOpen: !!open,\n dealId: open ? open.id : null,\n pipelineId: open ? open.pipelineId : null,\n dealName: open ? open.name : null,\n };\n}\nfunction dealAttr(\n id: number | undefined,\n val: unknown,\n out: { attributeId: number; value: string }[],\n) {\n if (id && val !== undefined && val !== null && String(val) !== \"\") {\n out.push({ attributeId: id, value: String(val) });\n }\n}\nasync function createDeal(rb: any): Promise {\n const route = ROUTES[rb.route];\n if (!route) {\n return {\n ok: false,\n error: 'route \"' + rb.route + '\" не настроен',\n routes: Object.keys(ROUTES),\n };\n }\n const phone = String(rb.phone || \"\").replace(/[^\\d]/g, \"\");\n const contactId = rb.contact_id ||\n await findOrCreateContact(phone, rb.contact_name, route.responsibleId);\n const deadline = almatyDeadline(SLA_MINUTES);\n const track = rb.track_code || (rb.slots && rb.slots.track_code) || \"\";\n const lang = String(rb.lang || \"\").toUpperCase();\n const bl = BL_MAP[rb.business_line] || \"\";\n const dealStatus = rb.deal_status || (rb.is_repeat ? \"вторичка\" : \"первичка\");\n const attributes: { attributeId: number; value: string }[] = [];\n dealAttr(route.attrs.track_code, track, attributes);\n dealAttr(route.attrs.business_line, bl, attributes);\n dealAttr(route.attrs.lang, lang, attributes);\n dealAttr(route.attrs.theme, rb.theme, attributes);\n dealAttr(route.attrs.deal_status, dealStatus, attributes);\n dealAttr(route.attrs.deadline, deadline, attributes);\n dealAttr(route.attrs.intent, rb.intent, attributes);\n const nm = rb.name ||\n ((bl || \"ALA\") + \" · \" + (rb.intent || \"обращение\") +\n (track ? \" · \" + track : \"\") + \" · \" + phone.slice(-10));\n const payload: any = {\n pipelineId: route.pipelineId,\n stepId: route.stepId,\n responsibleId: route.responsibleId,\n name: nm.slice(0, 255),\n attributes,\n };\n if (contactId) payload.contact = [contactId];\n const r = await spCrm(\"POST\", \"/deals\", payload);\n const id = r?.data?.id || r?.id;\n if (!id) {\n return { ok: false, error: \"SendPulse create deal failed\", response: r };\n }\n const note: string[] = [];\n if (rb.handoff_summary) note.push(rb.handoff_summary);\n if (rb.first_message) note.push(\"Сообщение клиента: \" + rb.first_message);\n if (note.length) {\n await spCrm(\"POST\", \"/deals/\" + id + \"/comments\", {\n message: note.join(\"\\n\"),\n }).catch(() => {});\n }\n return {\n ok: true,\n dealId: id,\n pipelineId: route.pipelineId,\n contact_id: contactId || null,\n deadline,\n };\n}\nasync function attachNote(rb: any): Promise {\n if (!rb.dealId) return { ok: false, error: \"dealId обязателен\" };\n await spCrm(\"POST\", \"/deals/\" + rb.dealId + \"/comments\", {\n message: rb.message || \"\",\n });\n return { ok: true };\n}\nasync function routeDeal(rb: any): Promise {\n let p = rb;\n if (rb.payload) {\n try {\n const extra = typeof rb.payload === \"string\"\n ? JSON.parse(rb.payload)\n : rb.payload;\n p = { ...rb };\n for (const k in extra) {\n if (extra[k] !== undefined && extra[k] !== null && extra[k] !== \"\") {\n p[k] = extra[k];\n }\n }\n } catch (_e) { /* payload not JSON */ }\n }\n if (!p.route) return { ok: false, error: \"route обязателен\" };\n const chk = await checkOpenDeal({\n phone: p.phone,\n contact_name: p.contact_name,\n });\n if (chk.hasOpen && chk.dealId) {\n const msg: string[] = [];\n if (p.handoff_summary) msg.push(p.handoff_summary);\n if (p.first_message) msg.push(\"Сообщение клиента: \" + p.first_message);\n const note = (p.intent ? \"[\" + p.intent + \"] \" : \"\") +\n (msg.join(\"\\n\") || \"повторное обращение\");\n await attachNote({ dealId: chk.dealId, message: note });\n return {\n ok: true,\n action: \"attached\",\n dealId: chk.dealId,\n pipelineId: chk.pipelineId,\n contact_id: chk.contact_id,\n deal_status: \"вторичка\",\n };\n }\n const c = await createDeal({\n ...p,\n contact_id: chk.contact_id,\n deal_status: \"первичка\",\n });\n if (!c.ok) return c;\n c.action = \"created\";\n c.deal_status = \"первичка\";\n return c;\n}\nasync function spCheck(): Promise {\n const pipes = (await spCrm(\"GET\", \"/pipelines\"))?.data || [];\n return {\n ok: true,\n pipelines: pipes.map((p: any) => ({\n id: p.id,\n name: p.name,\n steps: (p.steps || []).map((s: any) => ({\n id: s.id,\n name: s.name,\n order: s.order,\n })),\n })),\n routes_configured: Object.keys(ROUTES),\n };\n}\n\n// shared escalation side-effects for a route_deal result: assign by language (skipped for \"attached\"), fill the \"Чат\" link,\n// mirror the manager onto the SendPulse chat, drop Входящие cards. Used by both handleAction and escalateMedia.\nasync function postRouteDeal(rb: any, rr: any): Promise {\n if (!rr || !rr.dealId) return;\n const phone = String(rb.phone || \"\");\n const waContactP = resolveWaContact(phone);\n const deleteInboxP = deleteInboxCards(phone).catch((e) => ({\n error: String(e),\n }));\n\n let managerId = 0;\n if (rr.action !== \"attached\") {\n let lang = String(rb.lang || \"\");\n try {\n const pl = typeof rb.payload === \"string\"\n ? JSON.parse(rb.payload)\n : (rb.payload || {});\n lang = pl.lang || pl.language || lang;\n } catch (_p) { /* payload not JSON */ }\n const a = await assignDealByLang(\n Number(rr.dealId),\n lang,\n Number(rr.pipelineId),\n )\n .catch((e) => ({ error: String(e) }));\n console.log(\"APPS assignByLang\", JSON.stringify(a));\n managerId = Number((a as any)?.rid) || 0;\n if (rr.pipelineId) {\n const cl = await fillChatLink(\n Number(rr.dealId),\n Number(rr.pipelineId),\n undefined,\n phone,\n await waContactP,\n ).catch((e) => ({ error: String(e) }));\n console.log(\"APPS fillChatLink\", JSON.stringify(cl));\n }\n } else {\n try {\n const g = await spCrm(\"GET\", \"/deals/\" + rr.dealId);\n managerId = Number(g?.data?.responsibleId) || 0;\n } catch (_e) { /* ignore */ }\n }\n if (managerId) {\n const so = await syncChatOperator(phone, managerId, await waContactP)\n .catch((e) => ({ error: String(e) }));\n console.log(\"APPS syncChatOperator\", JSON.stringify(so));\n }\n const dc = await deleteInboxP;\n console.log(\"APPS deleteInboxCards\", JSON.stringify(dc));\n}\n\n// media inbound bypasses MoonAI entirely and escalates straight to a manager; empty lang -> POOL_BY_PIPELINE's default pool.\nconst MEDIA_LABELS: Record = {\n audio: \"аудиосообщение\",\n voice: \"аудиосообщение\",\n image: \"изображение\",\n video: \"видео\",\n document: \"файл\",\n sticker: \"стикер\",\n};\nconst MEDIA_ACK_TEXT =\n \"Сұрағыңызды менеджерге жолдадым. Колл-орталық Алматы уақытымен 09:00-ден \" +\n \"17:30-ға дейін жұмыс істейді — менеджер сізбен жақын жұмыс уақытында \" +\n \"хабарласады.\\n\" +\n \"Передал(а) ваш вопрос менеджеру. Колл-центр работает с 09:00 до 17:30 \" +\n \"(Алматы) — с вами свяжутся в ближайшее рабочее время.\\n\" +\n \"已将您的问题转交给经理。呼叫中心工作时间为阿拉木图时间09:00至17:30——我们将在最近的工作时间与您联系。\";\nconst MEDIA_FOLLOWUP_WORKHOURS_TEXT =\n \"Сұрағыңызды менеджерге жолдадым, жақын арада хабарласады.\\n\" +\n \"Я уже передал(а) ваш вопрос менеджеру, он скоро подключится.\\n\" +\n \"已将您的问题转交给经理，他很快会与您联系。\";\nasync function escalateMedia(\n phone: string,\n mediaType: string,\n caption?: string,\n botId?: string,\n): Promise {\n const label = MEDIA_LABELS[mediaType] || \"вложение\";\n const note = \"Клиент прислал \" + label +\n \" — бот медиа не обрабатывает, нужна ручная проверка.\" +\n (caption ? \" Подпись: «\" + caption.slice(0, 200) + \"».\" : \"\");\n const digits = String(phone || \"\").replace(/[^\\d]/g, \"\");\n const rb: any = {\n action: \"route_deal\",\n route: \"support_posylki\",\n phone: digits,\n contact_name: digits ? \"client_\" + digits : undefined,\n payload: JSON.stringify({\n business_line: \"posylki\",\n lang: \"\",\n intent: \"media_\" + mediaType,\n handoff_summary: note,\n first_message: note,\n }),\n };\n // see checkOpenDeal's note in handleAction — clear Входящие first or route_deal mistakes it for an open deal.\n if (digits) {\n await deleteInboxCards(digits).catch((e) =>\n console.log(\"pre-route_deal inbox clear failed (media)\", String(e))\n );\n }\n let rr: any = {};\n try {\n rr = await routeDeal(rb);\n } catch (e) {\n return { error: String(e) };\n }\n console.log(\"MEDIA route_deal\", JSON.stringify(rr));\n await postRouteDeal(rb, rr).catch((e) =>\n console.log(\"postRouteDeal (media) failed\", String(e))\n );\n if (digits) await setMediaPending(digits);\n if (digits) {\n try {\n const tok = await spToken();\n const ackResp = await fetch(SP_API + \"/whatsapp/contacts/sendByPhone\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: \"Bearer \" + tok,\n },\n body: JSON.stringify({\n bot_id: botId || Deno.env.get(\"SP_BOT_ID\"),\n phone: digits,\n message: { type: \"text\", text: { body: MEDIA_ACK_TEXT } },\n }),\n });\n console.log(\"MEDIA ack\", digits, \"->\", ackResp.status);\n } catch (e) {\n console.log(\"MEDIA ack failed\", String(e));\n }\n }\n return rr;\n}\n\n// ALA Cargo API (backend.alatms.com), same in-process port reasoning as above.\nlet alaTok = \"\";\nlet alaTokExp = 0;\nasync function alaToken(): Promise {\n if (alaTok && Date.now() < alaTokExp) return alaTok;\n const user = Deno.env.get(\"ALA_USERNAME\") || \"\";\n const r = await fetch(ALA_API_BASE + \"/api/auth/login/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"X-Username\": user },\n body: JSON.stringify({\n username: user,\n password: Deno.env.get(\"ALA_PASSWORD\"),\n }),\n });\n const d = await r.json().catch(() => ({}));\n const token = d.jwtToken || d.token || \"\";\n if (!token) {\n throw new Error(\"ALA login failed: \" + JSON.stringify(d).slice(0, 200));\n }\n let ttl = 300;\n try {\n const b64 = token.split(\".\")[1].replace(/-/g, \"+\").replace(/_/g, \"/\");\n const padded = b64 + \"=\".repeat((4 - b64.length % 4) % 4);\n const bytes = Uint8Array.from(atob(padded), (c) => c.charCodeAt(0));\n const claims = JSON.parse(new TextDecoder().decode(bytes));\n if (claims.exp) {\n ttl = Math.min(\n 21600,\n Math.max(60, claims.exp - Math.floor(Date.now() / 1000) - 60),\n );\n }\n } catch (_e) { /* keep default ttl */ }\n alaTok = token;\n alaTokExp = Date.now() + ttl * 1000;\n return alaTok;\n}\nasync function alaGet(\n path: string,\n params: Record,\n): Promise<{ code: number; body: any }> {\n const qs = new URLSearchParams(params).toString();\n const r = await fetch(ALA_API_BASE + path + (qs ? \"?\" + qs : \"\"), {\n headers: {\n Authorization: \"Bearer \" + await alaToken(),\n \"X-Username\": Deno.env.get(\"ALA_USERNAME\") || \"\",\n },\n });\n const txt = await r.text();\n let body: any;\n try {\n body = JSON.parse(txt);\n } catch {\n body = txt;\n }\n return { code: r.status, body };\n}\nfunction mapLine(bagType: string): string | null {\n return bagType === \"HOUSEHOLD_GOODS\"\n ? \"hozku\"\n : bagType === \"PARCELS\"\n ? \"posylki\"\n : null;\n}\n// full bag field set preserved — only status_ru/text dropped, since fixCargo overwrites both anyway.\nasync function findCargo(rb: any): Promise {\n const track = rb.track || (rb.slots && rb.slots.track_code);\n const phone = rb.phone || (rb.slots && rb.slots.phone);\n const includeIssued = rb.include_issued === true;\n let r: { code: number; body: any };\n let source: string;\n if (track) {\n source = \"by-track\";\n r = await alaGet(\"/api/call-center/bags/by-track\", {\n track: String(track).trim(),\n });\n } else if (phone) {\n source = \"by-recipient\";\n r = await alaGet(\"/api/call-center/bags/by-recipient\", {\n recipientNumber: String(phone).replace(/[^\\d]/g, \"\"),\n });\n } else {\n return { ok: false, error: \"нужен track или phone\" };\n }\n if (r.code < 200 || r.code >= 300) {\n return { ok: false, error: \"ALA API \" + r.code, source, response: r.body };\n }\n\n const arr = Array.isArray(r.body)\n ? r.body\n : Array.isArray(r.body?.bags)\n ? r.body.bags\n : Array.isArray(r.body?.data)\n ? r.body.data\n : Array.isArray(r.body?.content)\n ? r.body.content\n : [];\n const all = arr.map((b: any) => ({\n track: b.foreignNumber || \"\",\n places: b.count,\n status: b.status || \"\",\n bag_type: b.bagType || \"\",\n business_line: mapLine(b.bagType),\n warehouse: b.warehouseName || \"\",\n weight_kg: b.actualWeight != null ? b.actualWeight : b.declaredWeight,\n cost_usd: b.totalCostUsd,\n fragile: !!b.isFragile,\n pallet: !!b.isPallet,\n }));\n const active = all.filter((b: any) =>\n !CARGO_DONE_STATUSES.includes(b.status)\n );\n const list = source === \"by-recipient\" && !includeIssued ? active : all;\n const shown = list.slice(0, 25);\n const statusSummary: Record = {};\n for (const b of all) {\n statusSummary[b.status] = (statusSummary[b.status] || 0) + 1;\n }\n const lines = new Set(list.map((b: any) => b.business_line).filter(Boolean));\n\n return {\n ok: true,\n source,\n found: list.length > 0,\n total: all.length,\n active: active.length,\n shown: shown.length,\n business_line: lines.size === 1 ? [...lines][0] : null,\n status_summary: statusSummary,\n bags: shown,\n };\n}\n\nconst CARGO_STATUS_RU: Record = {\n CREATED: \"Создан\",\n RECEIVED: \"Получен\",\n LOADED: \"Загружен\",\n DISPATCHED: \"Отправлен\",\n TRANSIT_RECEIVED: \"Получен на транзите\",\n TRANSIT_ZONED: \"В зоне на транзите\",\n LOADED_TRANSIT: \"Загружен в транзит\",\n TRANSIT_DISPATCHED: \"Затаможка началась\",\n TRANSIT_CUSTOMS_CLEARED: \"Затаможка завершена\",\n TRANSIT_CUSTOMS_EXPORT_COMPLETED: \"Затаможка завершена\",\n CUSTOMS_CLEARED: \"Затаможка завершена\",\n IN_TRANSIT: \"В процессе транзита\",\n CUSTOMS_STARTED: \"Растаможка началась\",\n TERMINAL_CUSTOMS_STARTED: \"Растаможка началась\",\n CUSTOMS: \"Растаможка началась\",\n TO_WAREHOUSE: \"В пути на склад\",\n TERMINAL_DISPATCHED: \"В пути на склад\",\n ARRIVED: \"В пути на склад\",\n TERMINAL_RECEIVED: \"Получен на терминале\",\n TERMINAL_ZONED: \"В зоне терминала\",\n TERMINAL_ISSUED: \"Выдан\",\n RETURNED: \"Возврат\",\n CANCELLED: \"Отменён\",\n};\nfunction cargoStatusRu(code: string): string {\n if (!code) return \"статус уточняется\";\n return CARGO_STATUS_RU[code] || \"в обработке\";\n}\n\nconst cargoAnswerCache = new Map();\nconst CARGO_CACHE_TTL = 6 * 60 * 1000;\nfunction normTrack(s: string): string {\n return String(s || \"\").toUpperCase().replace(/[^A-Z0-9]/g, \"\");\n}\nfunction cacheCargoAnswer(track: string, answer: string) {\n const k = normTrack(track);\n if (k.length < 4 || !answer) return;\n cargoAnswerCache.set(k, { answer, ts: Date.now() });\n if (cargoAnswerCache.size > 500) {\n const cut = Date.now() - CARGO_CACHE_TTL;\n for (const [key, v] of cargoAnswerCache) {\n if (v.ts < cut) cargoAnswerCache.delete(key);\n }\n }\n}\n// returns the cached authoritative answer if the text looks like a cargo status, else null.\nconst CARGO_OVERRIDE_WINDOW = 100 * 1000;\nconst RE_STATUS =\n /(склад|статус|в пути|выдан|транзит|таможн|терминал|получен|отправлен|загружен|в зоне|не нашл|не найд|қойма|жолда|келді|тапсыр|кеден|仓库|清关|已发货|运输|已到)/i;\nconst RE_HANDOFF =\n /(передал|менеджер|уточните|напишите трек|проверьте номер|менеджерге|нақтылап|толық трек|经理|请提供)/i;\nfunction authoritativeCargoText(agentText: string): string | null {\n const t = String(agentText || \"\").trim();\n const looksLikeStatus = /груз[^.]{0,40}:/i.test(t) ||\n /[a-z0-9][a-z0-9-]{3,}\\s*(жүг|жүк)/i.test(t) ||\n /货物?\\s*[a-z0-9-]{3,}/i.test(t) ||\n RE_STATUS.test(t);\n if (!looksLikeStatus) return null;\n if (RE_HANDOFF.test(t)) return null;\n const tn = normTrack(t);\n const now = Date.now();\n for (const [k, v] of cargoAnswerCache) {\n if (now - v.ts > CARGO_CACHE_TTL) {\n cargoAnswerCache.delete(k);\n continue;\n }\n if (now - v.ts > CARGO_OVERRIDE_WINDOW) continue;\n if (tn.includes(k)) return v.answer === t ? null : v.answer;\n }\n return null;\n}\n\n// TERMINAL_* = bag reached the Almaty terminal; `warehouse` still holds the misleading China point.\nconst TERMINAL_STAGE = new Set([\n \"TERMINAL_RECEIVED\",\n \"TERMINAL_ZONED\",\n \"TERMINAL_ISSUED\",\n]);\nfunction bagLoc(b: any, multi: boolean): string {\n const st = String(b.status || \"\");\n if (st === \"TERMINAL_ISSUED\") return \"\";\n if (TERMINAL_STAGE.has(st)) {\n return multi\n ? \" (в Алматы, ожидает выдачи)\"\n : \" Груз в Алматы, ожидает выдачи.\";\n }\n if (!b.warehouse) return \"\";\n return multi ? \", склад \" + b.warehouse : \" Склад: \" + b.warehouse + \".\";\n}\n\nfunction fixCargo(o: any, reqTrack?: string): any {\n if (!o || (o.source !== \"by-track\" && o.source !== \"by-recipient\")) return o;\n const bags = Array.isArray(o.bags) ? o.bags : [];\n for (const b of bags) b.status_ru = cargoStatusRu(String(b.status || \"\"));\n if (o.ok === false) return o;\n if (!bags.length || o.found === false) {\n o.answer =\n \"По этому трек-коду ничего не нашлось. Проверьте номер, пожалуйста — или я передам вопрос менеджеру.\";\n o.text = o.answer;\n if (reqTrack) cacheCargoAnswer(reqTrack, o.answer);\n return o;\n }\n if (bags.length === 1) {\n const b = bags[0];\n o.answer = \"Груз \" + b.track + \": \" + b.status_ru + \".\" + bagLoc(b, false);\n } else {\n const parts = bags.map((b: any, i: number) =>\n \"мешок \" + (i + 1) + \" — \" + b.status_ru + bagLoc(b, true)\n );\n o.answer = \"Груз \" + (bags[0].track || \"\") + \" (\" + bags.length +\n \" мест): \" +\n parts.join(\"; \") + \".\";\n }\n o.text = o.answer;\n for (const b of bags) if (b.track) cacheCargoAnswer(b.track, o.answer);\n if (reqTrack) cacheCargoAnswer(reqTrack, o.answer);\n return o;\n}\n\n// dispatches every MoonAI action in-process — see the ALA/CRM ports above for why.\nasync function handleAction(\n req: Request,\n _inUrl: URL,\n body: string | undefined,\n): Promise {\n if (req.method === \"GET\") {\n return j({ ok: true, hint: \"POST JSON {action:...}\" });\n }\n\n let rb: any = {};\n try {\n rb = JSON.parse(body || \"{}\");\n if (rb && rb.inputs && typeof rb.inputs === \"object\") rb = rb.inputs;\n } catch (_e) {\n rb = {};\n }\n\n // route_deal arrives with an empty phone (MoonAI can't pass it) — recover via phoneForMessage, and force contact_name\n // to \"client_\" so it never falls back to a WhatsApp profile name.\n if (rb.route || rb.action === \"route_deal\") {\n let phone = String(rb.phone || \"\").replace(/[^\\d]/g, \"\");\n let firstMsg = \"\";\n try {\n const pl = typeof rb.payload === \"string\"\n ? JSON.parse(rb.payload)\n : (rb.payload || {});\n firstMsg = pl.first_message || \"\";\n if (!phone) phone = String(pl.phone || \"\").replace(/[^\\d]/g, \"\");\n } catch (_p) { /* payload not JSON */ }\n if (phone.length < 10) {\n const recovered = await phoneForMessage(firstMsg);\n if (recovered) phone = recovered;\n }\n if (phone.length >= 10) {\n rb.phone = phone;\n rb.contact_name = \"client_\" + phone;\n // checkOpenDeal has no Входящие filter — an open Входящие card would get mistaken for an existing deal.\n await deleteInboxCards(phone).catch((e) =>\n console.log(\"pre-route_deal inbox clear failed\", String(e))\n );\n }\n }\n\n let fcPhone = \"\";\n if (rb.action === \"find_cargo\") {\n fcPhone = String(rb.phone || \"\").replace(/[^\\d]/g, \"\");\n if (fcPhone.length < 10) {\n const rec = await phoneForMessage(\"\");\n if (rec && rec.length >= 10) {\n fcPhone = rec;\n rb.phone = fcPhone;\n }\n }\n }\n\n console.log(\"ACTION\", JSON.stringify(rb).slice(0, 400));\n\n let result: any;\n try {\n switch (rb.action) {\n case \"ping\":\n result = { ok: true, pong: true, ts: new Date().toISOString() };\n break;\n case \"sp_check\":\n result = await spCheck();\n break;\n case \"find_cargo\":\n result = fixCargo(\n await findCargo(rb),\n rb.track || (rb.slots && rb.slots.track_code) || \"\",\n );\n break;\n case \"route_deal\":\n result = await routeDeal(rb);\n break;\n case \"check_open_deal\":\n result = await checkOpenDeal(rb);\n break;\n case \"create_deal\":\n result = await createDeal(rb);\n break;\n case \"attach_note\":\n result = await attachNote(rb);\n break;\n default:\n result = { ok: false, error: \"unknown action: \" + rb.action };\n }\n } catch (e) {\n return j({ ok: false, error: String(e), stack: (e as Error)?.stack });\n }\n\n if (\n result?.source === \"by-track\" && result.found === false &&\n fcPhone.length >= 10\n ) {\n try {\n const p2 = await findCargo({ phone: fcPhone });\n if (\n p2 && p2.source === \"by-recipient\" && Array.isArray(p2.bags) &&\n p2.bags.length\n ) {\n const reqTrack = rb.track || (rb.slots && rb.slots.track_code) || \"\";\n const fixed = fixCargo(p2, \"\");\n fixed.answer = \"По трек-коду «\" + (reqTrack || \"—\") +\n \"» ничего не нашёл. По вашему номеру телефона: \" + fixed.answer;\n fixed.text = fixed.answer;\n if (reqTrack) cacheCargoAnswer(reqTrack, fixed.answer);\n result = fixed;\n console.log(\"find_cargo by-recipient fallback\", fcPhone);\n }\n } catch (e) {\n console.log(\"by-recipient fallback failed\", String(e));\n }\n }\n\n if (rb.route || rb.action === \"route_deal\") {\n await postRouteDeal(rb, result).catch((e) =>\n console.log(\"postRouteDeal failed\", String(e))\n );\n }\n\n console.log(\"ACTION RESP\", JSON.stringify(result).slice(0, 800));\n return j(result);\n}\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-API-Key\",\n },\n });\n }\n\n const inUrl = new URL(req.url);\n const path = inUrl.pathname.replace(/\\/+$/, \"\").toLowerCase();\n const body = req.method === \"GET\" || req.method === \"HEAD\"\n ? undefined\n : await req.text();\n\n try {\n if (path === \"/inbound\") return await handleInbound(body ?? \"\");\n if (path === \"/outbound\") return await handleOutbound(body ?? \"\");\n if (path === \"/privacy\") {\n return new Response(PRIVACY_HTML, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n if (path === \"/sync-responsible\") {\n const tok = inUrl.searchParams.get(\"token\") ||\n req.headers.get(\"x-sync-token\") || \"\";\n if (tok !== Deno.env.get(\"SHARED_SECRET\")) {\n return j({ ok: false, error: \"forbidden\" }, 403);\n }\n const sync = await syncResponsible();\n // piggy-backs on the same 15-min cron; cleanupInboxCards self-throttles to once/day.\n const inboxCleanup = await cleanupInboxCards().catch((e) => ({\n error: String(e),\n }));\n return j({ ...sync, inboxCleanup });\n }\n if (path === \"/find-chat\") {\n // used by the SendPulse Helper extension's search box — SendPulse's own \"Чаты\" search only matches the display name.\n const tok = inUrl.searchParams.get(\"token\") || \"\";\n if (tok !== Deno.env.get(\"SHARED_SECRET\")) {\n return j({ ok: false, error: \"forbidden\" }, 403);\n }\n const digits = (inUrl.searchParams.get(\"phone\") || \"\").replace(\n /[^\\d]/g,\n \"\",\n );\n if (digits.length < 4) return j({ ok: false, error: \"too_short\" }, 400);\n\n if (digits.length >= 10) {\n const url = await chatUrlForPhone(digits).catch(() => \"\");\n if (url) return j({ ok: true, url });\n }\n\n const hits = await searchPhoneDir(digits);\n if (!hits.length) return j({ ok: false, error: \"not_found\" }, 404);\n if (hits.length === 1) {\n return j({ ok: true, url: chatUrlFrom(hits[0].bot, hits[0].id) });\n }\n return j({\n ok: true,\n multiple: true,\n matches: hits.map((h) => ({\n phone: h.phone,\n url: chatUrlFrom(h.bot, h.id),\n })),\n });\n }\n if (path === \"/reset\") {\n const tok = inUrl.searchParams.get(\"token\") ||\n req.headers.get(\"x-sync-token\") || \"\";\n if (tok !== Deno.env.get(\"SHARED_SECRET\")) {\n return j({ ok: false, error: \"forbidden\" }, 403);\n }\n const phones = (inUrl.searchParams.get(\"phones\") || \"\")\n .split(/[,\\s]+/).map((p) => p.replace(/[^\\d]/g, \"\")).filter((p) =>\n p.length >= 10\n );\n const done: string[] = [];\n try {\n await ensureSaltTable();\n await ensureMsgTable();\n await ensureMgrTable();\n for (const p of phones) {\n const salt = Date.now().toString(36) +\n Math.random().toString(36).slice(2, 6);\n await sqlite.execute({\n sql:\n \"INSERT INTO thread_salt (phone, salt, ts) VALUES (:p, :s, :t) \" +\n \"ON CONFLICT(phone) DO UPDATE SET salt = :s, ts = :t\",\n args: { p, s: salt, t: Date.now() },\n });\n await sqlite.execute({\n sql: \"DELETE FROM mgr_active WHERE thread = :p\",\n args: { p },\n });\n await sqlite.execute({\n sql: \"DELETE FROM msg_phone WHERE phone = :p\",\n args: { p },\n });\n done.push(p + \"→\" + salt);\n }\n } catch (e) {\n return j({ ok: false, error: String(e), done });\n }\n console.log(\"RESET\", done.join(\" \"));\n return j({ ok: true, reset: done });\n }\n return await handleAction(req, inUrl, body);\n } catch (e) {\n console.log(\"ERR\", path, String(e));\n return j(\n { ok: false, error: \"handler_threw\", path, detail: String(e) },\n 500,\n );\n }\n}","deleted","label","alatmsmoonai",[115],"pulls",1,"forks","envVars",{"_138":140,"_141":54},"connections",{"_138":54,"_139":54},"count","unfilledCount",8,"emptyCount",{"_20":114,"_13":115,"_116":48,"_117":-5,"_118":21,"_119":30,"_120":50,"_22":143,"_29":122,"_123":124,"_125":126,"_127":38,"_128":129,"_144":145,"_91":146},["D",1789466189794],"children",[],[115],["D",1788752076387],{"_11":12,"_89":85},{"_11":12,"_82":83,"_84":85,"_45":46,"_86":87,"_88":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_77":-5,"_78":-5,"_79":-5,"_80":14,"_81":12},"ctx",{"_70":-5,"_110":184,"_185":186,"_187":188,"_189":38,"_190":38,"_191":38,"_192":50,"_193":-5,"_194":-7,"_195":-7,"_196":54,"_197":38,"_198":38,"_199":-5,"_200":38,"_201":38,"_202":38,"_203":-5},"ENV",{"_155":156,"_157":158,"_159":26,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1