[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":53,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":58,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",13,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","0c92d832-aa6d-11f1-b23f-1607ee4eb77e","name","fileType","http","content","// -----------------------------------------------------------------------------\n// val: timporello/GoogleApps -> https://alatmsmoonai.val.run/\n//\n// Three roles, routed by URL path:\n//\n// POST / MoonAI Custom Integration -> Google Apps Script (/exec)\n// redirect-follow proxy; unwraps MoonAI's {inputs:{...}} body.\n// Handles: ping / sp_check / find_cargo / route_deal / ...\n//\n// POST /inbound SendPulse WhatsApp bot webhook (\"incoming message\")\n// -> MoonAI API channel inbound\n// POST core.mooonai.com/api/v1/channels/api/messages\n// (thread_id = client phone digits)\n//\n// POST /outbound MoonAI API channel outgoing webhook (agent replies)\n// -> SendPulse WhatsApp send\n// POST api.sendpulse.com/whatsapp/contacts/sendByPhone\n//\n// Env vars:\n// APPS_SCRIPT_URL https://script.google.com/macros/s/.../exec (no query)\n// SHARED_SECRET token appended to the Apps Script call\n// MOONAI_API_KEY X-API-Key for the MoonAI API channel (agent 6739)\n// SP_CLIENT_ID SendPulse OAuth client id\n// SP_CLIENT_SECRET SendPulse OAuth client secret\n// SP_BOT_ID SendPulse internal bot id for WhatsApp 77757088880\n// -----------------------------------------------------------------------------\n\nconst MOONAI_INBOUND = \"https://core.mooonai.com/api/v1/channels/api/messages\";\nconst SP_API = \"https://api.sendpulse.com\";\nconst SOURCE = \"wa\";\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// -- SendPulse OAuth (module-level cache) --------------------------------------\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\n// -- /inbound : SendPulse bot webhook -> MoonAI API channel ---------------------\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 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 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 contact = ev?.contact || {};\n const phone = String(\n msg?.from ?? contact?.phone ?? contact?.username ?? \"\",\n ).replace(/[^\\d]/g, \"\");\n // Multi-bot: keep phone as thread id for the main bot, append \"__\"\n // for any other SendPulse bot so /outbound can reply through the right one.\n const mainBot = Deno.env.get(\"SP_BOT_ID\") || \"\";\n const botId = String(ev?.bot?.id || ev?.bot?._id || mainBot);\n const suffix = botId && botId !== mainBot ? \"__\" + botId : \"\";\n const threadId = phone ? phone + suffix : String(contact?.id || \"unknown\");\n const fromName = contact?.name || contact?.username || \"WhatsApp\";\n\n if (!text) {\n results.push({ skipped: \"no_text\", threadId });\n continue;\n }\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 return j({ ok: true, results });\n}\n\n// -- /outbound : MoonAI agent webhook -> SendPulse WhatsApp ---------------------\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 const threadId = String(ev?.external_thread_id ?? ev?.thread_id ?? \"\")\n .replace(\n /^api:[^:]+:/,\n \"\",\n );\n if (!text || !threadId) {\n return j({ ok: false, error: \"missing_text_or_thread\", threadId }, 400);\n }\n\n // If the agent mangled a cargo-status reply, replace it with the authoritative\n // answer we computed from find_cargo a moment ago.\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 // threadId may be \"__\" (non-main bot) or just \"\"\n const [phonePart, botPart] = threadId.split(\"__\");\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({ ok: r.ok, sp_status: r.status, sp_body: rt.slice(0, 400) });\n}\n\n// -- find_cargo post-processing --------------------------------------------------\n// Status wording taken VERBATIM from the ALA TMS call-center UI\n// (alatms.com .../landing-bills/client-cargo-in-transit, \"Статус\" filter, 15 states).\n// Confirmed API-code <-> TMS-label pairs: LOADED=Загружен, DISPATCHED=Отправлен,\n// TRANSIT_DISPATCHED=Затаможка началась, TERMINAL_ISSUED=Выдан,\n// LOADED_TRANSIT=Загружен в транзит, TERMINAL_ZONED=В зоне терминала,\n// TRANSIT_RECEIVED=Получен на транзите, TRANSIT_ZONED=В зоне на транзите,\n// TERMINAL_RECEIVED=Получен на терминале. The rest are inferred from order and\n// fall back safely; ALA to confirm the exact codes for the 4 middle states.\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 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\n// -- anti-mangle cache --------------------------------------------------------\n// GPT-5.4 in MoonAI rewrites find_cargo results (turns \"Выдан\" into \"в пути\",\n// swaps warehouses, invents statuses). We cache the exact `answer` per track for\n// a few minutes; /outbound then replaces the agent's cargo message with it.\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// If the agent's outgoing text is a cargo-status reply, return the authoritative\n// cached answer for the track it mentions; else null (send agent text as-is).\n// Guards: only for status-shaped messages, and only within 100s of the lookup\n// (so a later \"передал менеджеру\" reply is never overwritten).\nconst CARGO_OVERRIDE_WINDOW = 100 * 1000;\nfunction authoritativeCargoText(agentText: string): string | null {\n const t = String(agentText || \"\").trim();\n const looksLikeStatus = /груз[^.]{0,40}:/i.test(t) ||\n /(склад|статус|в пути|выдан|транзит|таможн|терминал|получен|отправлен|загружен|зоне)/i\n .test(t);\n if (!looksLikeStatus) return null;\n if (/(передал|менеджер|уточните|напишите трек|проверьте номер)/i.test(t)) {\n return null;\n }\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// Rewrites a find_cargo response before it reaches MoonAI:\n// - fills status_ru from the complete map\n// - builds one ready-to-send `answer` string (single or multi-bag)\n// - on an empty result, sets a clear \"not found\" answer (never a fake status)\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 +\n (b.warehouse ? \". Склад: \" + b.warehouse + \".\" : \".\");\n } else {\n const parts = bags.map((b: any, i: number) =>\n \"мешок \" + (i + 1) + \" — \" + b.status_ru +\n (b.warehouse ? \", склад \" + b.warehouse : \"\")\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// -- / : existing MoonAI -> Apps Script proxy -----------------------------------\nasync function handleAppsScript(\n req: Request,\n inUrl: URL,\n body: string | undefined,\n): Promise {\n const TARGET = Deno.env.get(\"APPS_SCRIPT_URL\");\n const TOKEN = Deno.env.get(\"SHARED_SECRET\");\n if (!TARGET || !TOKEN) {\n return j(\n {\n ok: false,\n error: \"proxy_misconfigured\",\n hint: \"set APPS_SCRIPT_URL and SHARED_SECRET\",\n },\n 500,\n );\n }\n\n const outUrl = new URL(TARGET);\n outUrl.searchParams.set(\"token\", TOKEN);\n for (const [k, v] of inUrl.searchParams) {\n if (k !== \"token\") outUrl.searchParams.set(k, v);\n }\n\n const method = req.method === \"GET\" ? \"GET\" : \"POST\";\n let out = method === \"GET\" ? undefined : body ?? \"\";\n try {\n const _p = JSON.parse(out || \"{}\");\n if (_p && _p.inputs && typeof _p.inputs === \"object\") {\n out = JSON.stringify(_p.inputs);\n }\n } catch (_e) {\n /* not JSON - forward as-is */\n }\n console.log(\"APPS\", JSON.stringify({ m: method, b: out }));\n\n let resp: Response;\n try {\n resp = await fetch(outUrl.toString(), {\n method,\n headers: { \"Content-Type\": \"application/json\" },\n body: out,\n redirect: \"follow\",\n });\n } catch (e) {\n return j(\n { ok: false, error: \"proxy_fetch_failed\", detail: String(e) },\n 502,\n );\n }\n let reqTrack = \"\";\n try {\n const rb = JSON.parse(out || \"{}\");\n reqTrack = rb.track || (rb.slots && rb.slots.track_code) || \"\";\n } catch (_e) { /* ignore */ }\n\n let text = await resp.text();\n try {\n const parsed = JSON.parse(text);\n if (\n parsed &&\n (parsed.source === \"by-track\" || parsed.source === \"by-recipient\")\n ) {\n text = JSON.stringify(fixCargo(parsed, reqTrack));\n }\n } catch (_e) {\n /* non-JSON - pass through */\n }\n console.log(\"APPS RESP\", text.slice(0, 800));\n return new Response(text, {\n status: resp.status,\n headers: {\n \"Content-Type\": resp.headers.get(\"Content-Type\") ??\n \"application/json; charset=utf-8\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\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 return await handleAppsScript(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}","// -----------------------------------------------------------------------------\n// val: timporello/GoogleApps -> https://alatmsmoonai.val.run/\n//\n// Three roles, routed by URL path:\n//\n// POST / MoonAI Custom Integration -> Google Apps Script (/exec)\n// redirect-follow proxy; unwraps MoonAI's {inputs:{...}} body.\n// Handles: ping / sp_check / find_cargo / route_deal / ...\n//\n// POST /inbound SendPulse WhatsApp bot webhook (\"incoming message\")\n// -> MoonAI API channel inbound\n// POST core.mooonai.com/api/v1/channels/api/messages\n// (thread_id = client phone digits)\n//\n// POST /outbound MoonAI API channel outgoing webhook (agent replies)\n// -> SendPulse WhatsApp send\n// POST api.sendpulse.com/whatsapp/contacts/sendByPhone\n//\n// Env vars:\n// APPS_SCRIPT_URL https://script.google.com/macros/s/.../exec (no query)\n// SHARED_SECRET token appended to the Apps Script call\n// MOONAI_API_KEY X-API-Key for the MoonAI API channel (agent 6739)\n// SP_CLIENT_ID SendPulse OAuth client id\n// SP_CLIENT_SECRET SendPulse OAuth client secret\n// SP_BOT_ID SendPulse internal bot id for WhatsApp 77757088880\n// -----------------------------------------------------------------------------\n\nconst MOONAI_INBOUND = \"https://core.mooonai.com/api/v1/channels/api/messages\";\nconst SP_API = \"https://api.sendpulse.com\";\nconst SOURCE = \"wa\";\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// -- SendPulse OAuth (module-level cache) --------------------------------------\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\n// -- /inbound : SendPulse bot webhook -> MoonAI API channel ---------------------\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 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 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 contact = ev?.contact || {};\n const phone = String(\n msg?.from ?? contact?.phone ?? contact?.username ?? \"\",\n ).replace(/[^\\d]/g, \"\");\n // Multi-bot: keep phone as thread id for the main bot, append \"__\"\n // for any other SendPulse bot so /outbound can reply through the right one.\n const mainBot = Deno.env.get(\"SP_BOT_ID\") || \"\";\n const botId = String(ev?.bot?.id || ev?.bot?._id || mainBot);\n const suffix = botId && botId !== mainBot ? \"__\" + botId : \"\";\n const threadId = phone ? phone + suffix : String(contact?.id || \"unknown\");\n const fromName = contact?.name || contact?.username || \"WhatsApp\";\n\n if (!text) {\n results.push({ skipped: \"no_text\", threadId });\n continue;\n }\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 return j({ ok: true, results });\n}\n\n// -- /outbound : MoonAI agent webhook -> SendPulse WhatsApp ---------------------\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 const threadId = String(ev?.external_thread_id ?? ev?.thread_id ?? \"\")\n .replace(\n /^api:[^:]+:/,\n \"\",\n );\n if (!text || !threadId) {\n return j({ ok: false, error: \"missing_text_or_thread\", threadId }, 400);\n }\n\n // If the agent mangled a cargo-status reply, replace it with the authoritative\n // answer we computed from find_cargo a moment ago.\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 // threadId may be \"__\" (non-main bot) or just \"\"\n const [phonePart, botPart] = threadId.split(\"__\");\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// -- find_cargo post-processing --------------------------------------------------\n// Status wording taken VERBATIM from the ALA TMS call-center UI\n// (alatms.com .../landing-bills/client-cargo-in-transit, \"Статус\" filter, 15 states).\n// Confirmed API-code <-> TMS-label pairs: LOADED=Загружен, DISPATCHED=Отправлен,\n// TRANSIT_DISPATCHED=Затаможка началась, TERMINAL_ISSUED=Выдан,\n// LOADED_TRANSIT=Загружен в транзит, TERMINAL_ZONED=В зоне терминала,\n// TRANSIT_RECEIVED=Получен на транзите, TRANSIT_ZONED=В зоне на транзите,\n// TERMINAL_RECEIVED=Получен на терминале. The rest are inferred from order and\n// fall back safely; ALA to confirm the exact codes for the 4 middle states.\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 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\n// -- anti-mangle cache --------------------------------------------------------\n// GPT-5.4 in MoonAI rewrites find_cargo results (turns \"Выдан\" into \"в пути\",\n// swaps warehouses, invents statuses). We cache the exact `answer` per track for\n// a few minutes; /outbound then replaces the agent's cargo message with it.\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// If the agent's outgoing text is a cargo-status reply, return the authoritative\n// cached answer for the track it mentions; else null (send agent text as-is).\n// Guards: only for status-shaped messages, and only within 100s of the lookup\n// (so a later \"передал менеджеру\" reply is never overwritten).\nconst CARGO_OVERRIDE_WINDOW = 100 * 1000;\nfunction authoritativeCargoText(agentText: string): string | null {\n const t = String(agentText || \"\").trim();\n // The cached `answer` is Russian. Only \"correct\" Russian replies — never touch a\n // Kazakh or Chinese message (we trust the agent's translation there).\n if (/[әғқңөұүһі]/i.test(t) || /[㐀-鿿豈-﫿]/.test(t)) return null;\n const looksLikeStatus = /груз[^.]{0,40}:/i.test(t) ||\n /(склад|статус|в пути|выдан|транзит|таможн|терминал|получен|отправлен|загружен|зоне)/i\n .test(t);\n if (!looksLikeStatus) return null;\n if (/(передал|менеджер|уточните|напишите трек|проверьте номер)/i.test(t)) {\n return null;\n }\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// Rewrites a find_cargo response before it reaches MoonAI:\n// - fills status_ru from the complete map\n// - builds one ready-to-send `answer` string (single or multi-bag)\n// - on an empty result, sets a clear \"not found\" answer (never a fake status)\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 +\n (b.warehouse ? \". Склад: \" + b.warehouse + \".\" : \".\");\n } else {\n const parts = bags.map((b: any, i: number) =>\n \"мешок \" + (i + 1) + \" — \" + b.status_ru +\n (b.warehouse ? \", склад \" + b.warehouse : \"\")\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// -- / : existing MoonAI -> Apps Script proxy -----------------------------------\nasync function handleAppsScript(\n req: Request,\n inUrl: URL,\n body: string | undefined,\n): Promise {\n const TARGET = Deno.env.get(\"APPS_SCRIPT_URL\");\n const TOKEN = Deno.env.get(\"SHARED_SECRET\");\n if (!TARGET || !TOKEN) {\n return j(\n {\n ok: false,\n error: \"proxy_misconfigured\",\n hint: \"set APPS_SCRIPT_URL and SHARED_SECRET\",\n },\n 500,\n );\n }\n\n const outUrl = new URL(TARGET);\n outUrl.searchParams.set(\"token\", TOKEN);\n for (const [k, v] of inUrl.searchParams) {\n if (k !== \"token\") outUrl.searchParams.set(k, v);\n }\n\n const method = req.method === \"GET\" ? \"GET\" : \"POST\";\n let out = method === \"GET\" ? undefined : body ?? \"\";\n try {\n const _p = JSON.parse(out || \"{}\");\n if (_p && _p.inputs && typeof _p.inputs === \"object\") {\n out = JSON.stringify(_p.inputs);\n }\n } catch (_e) {\n /* not JSON - forward as-is */\n }\n console.log(\"APPS\", JSON.stringify({ m: method, b: out }));\n\n let resp: Response;\n try {\n resp = await fetch(outUrl.toString(), {\n method,\n headers: { \"Content-Type\": \"application/json\" },\n body: out,\n redirect: \"follow\",\n });\n } catch (e) {\n return j(\n { ok: false, error: \"proxy_fetch_failed\", detail: String(e) },\n 502,\n );\n }\n let reqTrack = \"\";\n try {\n const rb = JSON.parse(out || \"{}\");\n reqTrack = rb.track || (rb.slots && rb.slots.track_code) || \"\";\n } catch (_e) { /* ignore */ }\n\n let text = await resp.text();\n try {\n const parsed = JSON.parse(text);\n if (\n parsed &&\n (parsed.source === \"by-track\" || parsed.source === \"by-recipient\")\n ) {\n text = JSON.stringify(fixCargo(parsed, reqTrack));\n }\n } catch (_e) {\n /* non-JSON - pass through */\n }\n console.log(\"APPS RESP\", text.slice(0, 800));\n return new Response(text, {\n status: resp.status,\n headers: {\n \"Content-Type\": resp.headers.get(\"Content-Type\") ??\n \"application/json; charset=utf-8\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\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 return await handleAppsScript(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}","createdAt",["D",1788781297733],"branchVersion","branchId","5261a48a-4e48-4d3e-a959-2c0cd46109c4","id","a2846e9c-cffb-4106-82df-12868a39062c","GoogleApps",["D",1788752076387],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","ce838876-d9c7-481d-b172-ac9fe672bd77","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a079ed-a798-7549-8fa9-b8d52f316ced","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",49,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","timporello","handle","displayName","Temirlan Kassymkul","avatar","https://lh3.googleusercontent.com/a/ACg8ocK3F3VjTFMvULcxz4CS7J7Hecrru3ZQ_PmzQOvDbreGsF0rIvQkSg=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":152,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":153,"_80":154,"_82":155,"_84":25},"tree",[147],"files",[147],"counts",{"_135":62,"_136":137,"_138":62,"_139":140,"_141":142},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":133,"_27":134},"22549ba6-a747-408f-9d82-cd3434c11db5","parentId","latest",["D",1788781297733],12,"label","alatmsmoonai",[28],"pulls","branches",1,"forks","envVars",{"_143":145,"_146":62},"connections",{"_143":62,"_144":62},"count","unfilledCount",8,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":148,"_13":131,"_33":34,"_35":37,"_24":25,"_132":133,"_149":150,"_27":151},["D",1788781297733],"children",[],[28],["D",1788752076387],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_123":189,"_190":191,"_192":193,"_194":25,"_195":25,"_196":25,"_197":58,"_198":-5,"_199":-7,"_200":-7,"_201":62,"_202":25,"_203":25,"_204":-5,"_205":25,"_206":25,"_207":25,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":86,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"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"]

Diff · v13