[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_202":203,"_204":205},"routes/_app.x.$handle.$name",{"_117":116,"_34":64,"_126":107,"_29":127,"_13":14,"_128":-5,"_11":129,"_130":131,"_132":133,"_134":135,"_136":137,"_23":-5,"_138":-5,"_139":-5,"_140":27,"_141":142,"_143":77,"_144":-5,"_145":-5,"_146":147},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_62":63,"_34":64,"_39":65,"_66":-5,"_67":27,"_68":69,"_70":69,"_71":72,"_73":-5,"_18":74,"_75":57,"_76":77,"_78":-5,"_79":-5,"_80":81,"_82":83,"_84":85,"_86":87,"_88":89,"_90":-5,"_91":92,"_93":92,"_94":95,"_96":95,"_97":95,"_98":92,"_99":92,"_100":101,"_102":103,"_104":105,"_106":27},"version",10,"changes",[19,20,21,22],"aiChatInfo","userId",{"_23":54,"_25":55,"_26":27,"_28":27,"_29":56,"_31":56},{"_23":49,"_25":-7,"_26":27,"_28":27,"_29":50,"_31":50},{"_23":44,"_25":-7,"_26":27,"_28":27,"_29":45,"_31":45},{"_23":24,"_25":-7,"_26":27,"_28":27,"_29":30,"_31":30},"file",{"_32":33,"_34":30,"_35":36,"_37":38,"_39":40,"_41":14,"_42":43,"_26":27},"previous","deleted",false,"deletedHere","path","wake_dispatch.ts","latestPath","fileId","b26940be-b1e5-11f1-9497-1607ee4eb77e","name","fileType","script","content","import { dispatchReadyWakes } from \"./main.ts\";\n\nconst result = await dispatchReadyWakes(20);\nconsole.log(\"Mio Wake dispatch\", result);\nexport default result;\n","createdAt",["D",1789573552390],"branchVersion","branchId","1ad158c8-0593-408b-a98b-abb0b1ac9f4f",{"_32":46,"_34":45,"_35":36,"_37":47,"_39":48,"_41":14,"_42":43,"_26":27},"wake_contract_test.ts","b2691a3a-b1e5-11f1-9497-1607ee4eb77e","import handler from \"./main.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nfunction assert(condition: unknown, message: string): asserts condition {\n if (!condition) throw new Error(message);\n}\n\nconst token = Deno.env.get(\"MIO_BRIDGE_TOKEN\") ?? \"\";\nassert(token, \"MIO_BRIDGE_TOKEN missing\");\n\nconst response = await handler(new Request(\"https://carrier.test/wake/doctor\", {\n headers: { \"x-mio-bridge-token\": token },\n}));\nconst body = await response.json();\n\nassert(response.status === 200, `expected /wake/doctor 200, got ${response.status}`);\nassert(body?.service === \"mio-wake\", `expected service mio-wake, got ${body?.service}`);\nassert(body?.protocol === true, \"wake protocol should be enabled\");\nassert(body?.activator?.configured === false, \"V1 activator must remain external/unconfigured\");\n\nconsole.log(\"PASS wake doctor contract\");\n\n\nawait sqlite.execute({ sql: `DELETE FROM carrier_wake_requests WHERE event_id = ?`, args: [4] });\n\nconst requestWake = await handler(new Request(\"https://carrier.test/wake/request\", {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-mio-bridge-token\": token,\n },\n body: JSON.stringify({ eventId: 4, priority: 50, reason: \"test_reasoning_required\" }),\n}));\nconst requestedBody = await requestWake.json();\nassert(requestWake.status === 200, `expected /wake/request 200, got ${requestWake.status}`);\nassert(requestedBody?.wake?.eventId === 4, `expected wake eventId 4, got ${requestedBody?.wake?.eventId}`);\nassert(requestedBody?.wake?.status === \"queued\", `expected queued wake, got ${requestedBody?.wake?.status}`);\n\nconst pending = await handler(new Request(\"https://carrier.test/wake/pending?limit=10\", {\n headers: { \"x-mio-bridge-token\": token },\n}));\nconst pendingBody = await pending.json();\nassert(pending.status === 200, `expected /wake/pending 200, got ${pending.status}`);\nassert(Array.isArray(pendingBody?.wakes), \"pending wakes should be an array\");\nassert(pendingBody.wakes.some((wake: any) => wake.eventId === 4), \"pending wakes should include event 4\");\n\nawait sqlite.execute({ sql: `DELETE FROM carrier_wake_requests WHERE event_id = ?`, args: [4] });\nconsole.log(\"PASS wake request/pending contract\");\n\n\nconst ownerUserId = Deno.env.get(\"LINE_OWNER_USER_ID\") ?? \"\";\nconst syntheticExternalId = `wake-test-${crypto.randomUUID()}`;\nconst insertedEvent = await sqlite.execute({\n sql: `INSERT INTO line_bridge_events\n (webhook_event_id, event_type, source_type, source_id, user_id, message_id, message_type, text_content, is_redelivery, event_timestamp)\n VALUES (?, 'message', 'user', ?, ?, ?, 'text', ?, 0, ?)`,\n args: [syntheticExternalId, ownerUserId || \"test-owner\", ownerUserId || \"test-owner\", `msg-${crypto.randomUUID()}`, \"wake-v1-test-message\", Date.now()],\n});\nconst syntheticEventId = Number(insertedEvent.lastInsertRowid);\n\nconst reconcile = await handler(new Request(\"https://carrier.test/wake/reconcile\", {\n method: \"POST\",\n headers: { \"x-mio-bridge-token\": token },\n}));\nconst reconcileBody = await reconcile.json();\nassert(reconcile.status === 200, `expected /wake/reconcile 200, got ${reconcile.status}`);\nassert(Number(reconcileBody?.created ?? 0) >= 1, `expected at least one wake created, got ${reconcileBody?.created}`);\n\nconst syntheticWake = await sqlite.execute({\n sql: `SELECT status FROM carrier_wake_requests WHERE event_id = ? LIMIT 1`,\n args: [syntheticEventId],\n});\nassert(syntheticWake.rows?.[0]?.status === \"queued\", \"reconcile should create queued wake for natural text event\");\n\nawait sqlite.execute({ sql: `DELETE FROM carrier_wake_requests WHERE event_id = ?`, args: [syntheticEventId] });\nawait sqlite.execute({ sql: `DELETE FROM line_bridge_events WHERE id = ?`, args: [syntheticEventId] });\nconsole.log(\"PASS wake reconcile contract\");\n\n\nawait handler(new Request(\"https://carrier.test/wake/request\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", \"x-mio-bridge-token\": token },\n body: JSON.stringify({ eventId: 4, priority: 50, reason: \"test_response\" }),\n}));\n\nconst respond = await handler(new Request(\"https://carrier.test/wake/respond\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", \"x-mio-bridge-token\": token },\n body: JSON.stringify({ eventId: 4, text: \"wake-v1-test-response\" }),\n}));\nconst respondBody = await respond.json();\nassert(respond.status === 200, `expected /wake/respond 200, got ${respond.status}`);\nassert(respondBody?.wake?.status === \"response_ready\", `expected response_ready, got ${respondBody?.wake?.status}`);\n\nawait sqlite.execute({ sql: `DELETE FROM carrier_wake_requests WHERE event_id = ?`, args: [4] });\nconst dispatch = await handler(new Request(\"https://carrier.test/wake/dispatch\", {\n method: \"POST\",\n headers: { \"x-mio-bridge-token\": token },\n}));\nconst dispatchBody = await dispatch.json();\nassert(dispatch.status === 200, `expected /wake/dispatch 200, got ${dispatch.status}`);\nassert(dispatchBody?.dispatched === 0, `expected zero dispatches in empty test queue, got ${dispatchBody?.dispatched}`);\nconsole.log(\"PASS wake respond/dispatch contract\");\n",["D",1789573552390],{"_32":51,"_34":50,"_35":36,"_37":52,"_39":53,"_41":14,"_42":43,"_26":27},"wake_cloud_dispatch.ts","b268ea60-b1e5-11f1-9497-1607ee4eb77e","import { dispatchReadyWakes } from \"./main.ts\";\n\nconst result = await dispatchReadyWakes(5);\nconsole.log(JSON.stringify(result));\n",["D",1789573552390],{"_32":57,"_34":56,"_35":58,"_37":60,"_39":61,"_41":14,"_42":43,"_26":27},{"_32":57,"_34":56,"_35":58,"_37":59},"main.ts","ad07988a-a878-11f1-96d5-1607ee4eb77e","http","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst encoder = new TextEncoder();\nconst MAX_PULL = 100;\nconst CARRIER_VERSION = \"1.0-poc\";\nconst LINE_CARRIER = \"line\";\n\nasync function verifyLineSignature(body: string, signature: string, secret: string): Promise {\n const key = await crypto.subtle.importKey(\"raw\", encoder.encode(secret), { name: \"HMAC\", hash: \"SHA-256\" }, false, [\"sign\"]);\n const digest = await crypto.subtle.sign(\"HMAC\", key, encoder.encode(body));\n const expected = btoa(String.fromCharCode(...new Uint8Array(digest)));\n if (expected.length !== signature.length) return false;\n let diff = 0;\n for (let i = 0; i < expected.length; i++) diff |= expected.charCodeAt(i) ^ signature.charCodeAt(i);\n return diff === 0;\n}\n\nfunction lineAccessToken(): string {\n return Deno.env.get(\"LINETOKEN\") ?? Deno.env.get(\"LINE_TOKEN\") ?? Deno.env.get(\"LINE_CHANNEL_ACCESS_TOKEN\") ?? \"\";\n}\n\nfunction ownerUserId(): string {\n return Deno.env.get(\"LINE_OWNER_USER_ID\") ?? \"\";\n}\n\nasync function lineReply(replyToken: string, text: string, accessToken: string): Promise {\n const response = await fetch(\"https://api.line.me/v2/bot/message/reply\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", authorization: `Bearer ${accessToken}` },\n body: JSON.stringify({ replyToken, messages: [{ type: \"text\", text: text.slice(0, 4900) }] }),\n });\n if (!response.ok) console.error(\"LINE reply failed\", response.status, (await response.text()).slice(0, 800));\n}\n\nasync function linePush(target: string, text: string, accessToken: string): Promise<{ ok: boolean; status: number; error?: string }> {\n const response = await fetch(\"https://api.line.me/v2/bot/message/push\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", authorization: `Bearer ${accessToken}` },\n body: JSON.stringify({ to: target, messages: [{ type: \"text\", text: text.slice(0, 4900) }] }),\n });\n if (!response.ok) {\n const detail = (await response.text()).slice(0, 800);\n console.error(\"LINE push failed\", response.status, detail);\n return { ok: false, status: response.status, error: \"line_push_failed\" };\n }\n return { ok: true, status: response.status };\n}\n\nasync function ensureTables() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS line_bridge_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n webhook_event_id TEXT NOT NULL UNIQUE,\n event_type TEXT NOT NULL,\n source_type TEXT,\n source_id TEXT,\n user_id TEXT,\n message_id TEXT,\n message_type TEXT,\n text_content TEXT,\n is_redelivery INTEGER NOT NULL DEFAULT 0,\n event_timestamp INTEGER,\n status TEXT NOT NULL DEFAULT 'queued',\n received_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n processed_at TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_line_bridge_events_status_id ON line_bridge_events(status, id)`);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS carrier_outbox (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n carrier TEXT NOT NULL,\n event_id INTEGER,\n target TEXT NOT NULL,\n text_content TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n sent_at TEXT,\n error TEXT\n )\n `);\n}\n\nfunction sourceIdentity(event: any) {\n const source = event?.source ?? {};\n return {\n sourceType: String(source.type ?? \"unknown\"),\n sourceId: String(source.groupId ?? source.roomId ?? source.userId ?? \"unknown\"),\n userId: source.userId ? String(source.userId) : null,\n };\n}\n\nasync function enqueueLineEvent(event: any): Promise {\n await ensureTables();\n const { sourceType, sourceId, userId } = sourceIdentity(event);\n const webhookEventId = String(event?.webhookEventId ?? `legacy:${event?.timestamp ?? Date.now()}:${crypto.randomUUID()}`);\n const message = event?.message ?? {};\n try {\n await sqlite.execute({\n sql: `INSERT INTO line_bridge_events\n (webhook_event_id, event_type, source_type, source_id, user_id, message_id, message_type, text_content, is_redelivery, event_timestamp)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [webhookEventId, String(event?.type ?? \"unknown\"), sourceType, sourceId, userId,\n message?.id ? String(message.id) : null, message?.type ? String(message.type) : null,\n message?.type === \"text\" ? String(message.text ?? \"\") : null,\n event?.deliveryContext?.isRedelivery ? 1 : 0,\n Number.isFinite(event?.timestamp) ? Number(event.timestamp) : null],\n });\n return true;\n } catch (error) {\n const msg = String((error as Error)?.message ?? error);\n if (msg.includes(\"UNIQUE\") || msg.includes(\"unique\")) return false;\n throw error;\n }\n}\n\nfunction carrierAuthorized(req: Request): boolean {\n const expected = Deno.env.get(\"MIO_BRIDGE_TOKEN\") ?? \"\";\n if (!expected) return false;\n const auth = req.headers.get(\"authorization\") ?? \"\";\n const explicit = req.headers.get(\"x-mio-bridge-token\") ?? \"\";\n return auth === `Bearer ${expected}` || explicit === expected;\n}\n\nfunction normalizeCarrierEvent(row: any) {\n return {\n eventId: Number(row.id),\n carrier: LINE_CARRIER,\n externalEventId: row.webhook_event_id,\n actor: row.user_id && row.user_id === ownerUserId() ? \"owner\" : \"unknown\",\n actorId: row.user_id ?? null,\n source: { type: row.source_type ?? \"unknown\", id: row.source_id ?? null },\n replyTarget: row.user_id ? `line:user:${row.user_id}` : null,\n type: row.message_type ? `message.${row.message_type}` : row.event_type,\n text: row.text_content ?? null,\n status: row.status,\n receivedAt: row.received_at,\n timestamp: row.event_timestamp ?? null,\n metadata: { messageId: row.message_id ?? null, redelivery: Boolean(row.is_redelivery) },\n };\n}\n\nasync function listInbox(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n const url = new URL(req.url);\n const requested = Number(url.searchParams.get(\"limit\") ?? \"50\");\n const limit = Math.max(1, Math.min(MAX_PULL, Number.isFinite(requested) ? requested : 50));\n const rows = await sqlite.execute({\n sql: `SELECT id, webhook_event_id, event_type, source_type, source_id, user_id, message_id, message_type,\n text_content, is_redelivery, event_timestamp, status, received_at\n FROM line_bridge_events WHERE status = 'queued' ORDER BY id ASC LIMIT ?`,\n args: [limit],\n });\n const events = (rows.rows ?? []).map(normalizeCarrierEvent);\n return Response.json({ carrier: \"mio\", events, count: events.length });\n}\n\nasync function getEvent(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n const url = new URL(req.url);\n const id = Number(url.searchParams.get(\"id\") ?? \"\");\n if (!Number.isInteger(id)) return Response.json({ error: \"id_required\" }, { status: 400 });\n const rows = await sqlite.execute({\n sql: `SELECT id, webhook_event_id, event_type, source_type, source_id, user_id, message_id, message_type,\n text_content, is_redelivery, event_timestamp, status, received_at\n FROM line_bridge_events WHERE id = ? LIMIT 1`,\n args: [id],\n });\n const row = rows.rows?.[0];\n if (!row) return Response.json({ error: \"event_not_found\" }, { status: 404 });\n return Response.json({ event: normalizeCarrierEvent(row) });\n}\n\nasync function ackEvents(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n let payload: any;\n try { payload = await req.json(); } catch { return Response.json({ error: \"invalid_json\" }, { status: 400 }); }\n const ids = Array.isArray(payload?.ids) ? payload.ids.map(Number).filter(Number.isInteger).slice(0, MAX_PULL) : [];\n if (!ids.length) return Response.json({ error: \"ids_required\" }, { status: 400 });\n const placeholders = ids.map(() => \"?\").join(\",\");\n const result = await sqlite.execute({\n sql: `UPDATE line_bridge_events SET status = 'processed', processed_at = CURRENT_TIMESTAMP WHERE id IN (${placeholders})`,\n args: ids,\n });\n return Response.json({ ok: true, acknowledged: result.rowsAffected ?? 0 });\n}\n\nasync function sendCarrierText(target: string, text: string, eventId: number | null): Promise {\n const accessToken = lineAccessToken();\n if (!accessToken) return Response.json({ error: \"line_push_not_configured\" }, { status: 503 });\n await ensureTables();\n const insert = await sqlite.execute({\n sql: `INSERT INTO carrier_outbox (carrier, event_id, target, text_content) VALUES (?, ?, ?, ?)`,\n args: [LINE_CARRIER, eventId, target, text],\n });\n const outboxId = Number(insert.lastInsertRowid ?? 0);\n const result = await linePush(target, text, accessToken);\n await sqlite.execute({\n sql: `UPDATE carrier_outbox SET status = ?, sent_at = CASE WHEN ? = 'sent' THEN CURRENT_TIMESTAMP ELSE sent_at END, error = ? WHERE id = ?`,\n args: [result.ok ? \"sent\" : \"failed\", result.ok ? \"sent\" : \"failed\", result.error ?? null, outboxId],\n });\n if (!result.ok) return Response.json({ ok: false, error: result.error, outboxId }, { status: 502 });\n return Response.json({ ok: true, outboxId, carrier: LINE_CARRIER });\n}\n\nasync function replyToEvent(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n let payload: any;\n try { payload = await req.json(); } catch { return Response.json({ error: \"invalid_json\" }, { status: 400 }); }\n const eventId = Number(payload?.eventId);\n const text = String(payload?.text ?? \"\").trim();\n if (!Number.isInteger(eventId)) return Response.json({ error: \"eventId_required\" }, { status: 400 });\n if (!text) return Response.json({ error: \"text_required\" }, { status: 400 });\n const rows = await sqlite.execute({ sql: `SELECT id, user_id FROM line_bridge_events WHERE id = ? LIMIT 1`, args: [eventId] });\n const row = rows.rows?.[0];\n if (!row) return Response.json({ error: \"event_not_found\" }, { status: 404 });\n const target = String(row.user_id ?? ownerUserId());\n if (!target || (ownerUserId() && target !== ownerUserId())) return Response.json({ error: \"reply_target_not_authorized\" }, { status: 403 });\n const response = await sendCarrierText(target, text, eventId);\n if (response.ok) {\n await sqlite.execute({ sql: `UPDATE line_bridge_events SET status = 'processed', processed_at = CURRENT_TIMESTAMP WHERE id = ?`, args: [eventId] });\n }\n return response;\n}\n\nasync function pushFromCarrier(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n const target = ownerUserId();\n if (!target) return Response.json({ error: \"owner_not_configured\" }, { status: 503 });\n let payload: any;\n try { payload = await req.json(); } catch { return Response.json({ error: \"invalid_json\" }, { status: 400 }); }\n const text = String(payload?.text ?? \"\").trim();\n if (!text) return Response.json({ error: \"text_required\" }, { status: 400 });\n return sendCarrierText(target, text, null);\n}\n\nasync function carrierDoctor(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n const queued = await sqlite.execute(`SELECT COUNT(*) AS count FROM line_bridge_events WHERE status = 'queued'`);\n const failed = await sqlite.execute(`SELECT COUNT(*) AS count FROM carrier_outbox WHERE status = 'failed'`);\n return Response.json({\n status: \"ONLINE\",\n service: \"mio-carrier\",\n version: CARRIER_VERSION,\n llmDependency: false,\n adapters: { line: { inbound: true, outbound: Boolean(lineAccessToken()), ownerAllowlist: Boolean(ownerUserId()) } },\n inbox: { queued: Number((queued.rows?.[0] as any)?.count ?? 0) },\n outbox: { failed: Number((failed.rows?.[0] as any)?.count ?? 0) },\n wake: { supported: false, mode: \"external-adapter\", note: \"Carrier transports events; reasoning wake remains replaceable.\" },\n });\n}\n\nfunction deterministicReply(text: string): string | null {\n const normalized = text.trim().toLowerCase();\n if ([\"ping\", \"/ping\"].includes(normalized)) return \"Mio Carrier：ONLINE\";\n if ([\"status\", \"/status\", \"狀態\"].includes(normalized)) {\n return \"Mio Carrier：ONLINE\\nLINE：CONNECTED\\nAI API：OFF\\n模式：Carrier transport\";\n }\n if ([\"help\", \"/help\", \"幫助\"].includes(normalized)) {\n return \"目前可用：status / ping / help。其他訊息會進入 Mio Carrier inbox，等待真正的 Mio execution 回覆。\";\n }\n return null;\n}\n\nasync function handleLineWebhook(req: Request): Promise {\n const channelSecret = Deno.env.get(\"LINESECRET\") ?? Deno.env.get(\"LINE_SECRET\") ?? Deno.env.get(\"LINE_CHANNEL_SECRET\") ?? \"\";\n const accessToken = lineAccessToken();\n if (!channelSecret) return new Response(\"Webhook not configured\", { status: 503 });\n const body = await req.text();\n const signature = req.headers.get(\"x-line-signature\") ?? \"\";\n if (!signature || !(await verifyLineSignature(body, signature, channelSecret))) return new Response(\"Invalid signature\", { status: 401 });\n let payload: any;\n try { payload = JSON.parse(body); } catch { return new Response(\"Invalid JSON\", { status: 400 }); }\n const events = Array.isArray(payload?.events) ? payload.events : [];\n if (!events.length) return new Response(\"OK\", { status: 200 });\n const owner = ownerUserId();\n for (const event of events) {\n const senderUserId = event?.source?.userId ? String(event.source.userId) : \"\";\n if (owner && senderUserId !== owner) continue;\n const inserted = await enqueueLineEvent(event);\n if (!inserted) continue;\n if (!accessToken || event?.type !== \"message\" || event?.message?.type !== \"text\" || !event?.replyToken) continue;\n const autoReply = deterministicReply(String(event.message.text ?? \"\"));\n if (autoReply) await lineReply(event.replyToken, autoReply, accessToken);\n }\n return new Response(\"OK\", { status: 200 });\n}\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n if (req.method === \"GET\" && (url.pathname === \"/\" || url.pathname === \"/health\")) {\n return Response.json({ status: \"ONLINE\", service: \"mio-carrier\", version: CARRIER_VERSION, mode: \"transport\", llmDependency: false });\n }\n\n // Canonical Mio Carrier V1 surface.\n if (req.method === \"GET\" && url.pathname === \"/carrier/doctor\") return carrierDoctor(req);\n if (req.method === \"GET\" && url.pathname === \"/carrier/inbox\") return listInbox(req);\n if (req.method === \"GET\" && url.pathname === \"/carrier/event\") return getEvent(req);\n if (req.method === \"POST\" && url.pathname === \"/carrier/ack\") return ackEvents(req);\n if (req.method === \"POST\" && url.pathname === \"/carrier/reply\") return replyToEvent(req);\n if (req.method === \"POST\" && url.pathname === \"/carrier/push\") return pushFromCarrier(req);\n\n // Backward-compatible bridge routes while callers migrate.\n if (req.method === \"GET\" && url.pathname === \"/bridge/inbox\") return listInbox(req);\n if (req.method === \"POST\" && url.pathname === \"/bridge/ack\") return ackEvents(req);\n if (req.method === \"POST\" && url.pathname === \"/bridge/push\") return pushFromCarrier(req);\n\n if (req.method === \"POST\" && (url.pathname === \"/\" || url.pathname === \"/webhook\")) return handleLineWebhook(req);\n return Response.json({ error: \"not_found\" }, { status: 404 });\n}\n","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst encoder = new TextEncoder();\nconst MAX_PULL = 100;\nconst CARRIER_VERSION = \"1.0-poc\";\nconst LINE_CARRIER = \"line\";\n\nasync function verifyLineSignature(body: string, signature: string, secret: string): Promise {\n const key = await crypto.subtle.importKey(\"raw\", encoder.encode(secret), { name: \"HMAC\", hash: \"SHA-256\" }, false, [\"sign\"]);\n const digest = await crypto.subtle.sign(\"HMAC\", key, encoder.encode(body));\n const expected = btoa(String.fromCharCode(...new Uint8Array(digest)));\n if (expected.length !== signature.length) return false;\n let diff = 0;\n for (let i = 0; i < expected.length; i++) diff |= expected.charCodeAt(i) ^ signature.charCodeAt(i);\n return diff === 0;\n}\n\nfunction lineAccessToken(): string {\n return Deno.env.get(\"LINETOKEN\") ?? Deno.env.get(\"LINE_TOKEN\") ?? Deno.env.get(\"LINE_CHANNEL_ACCESS_TOKEN\") ?? \"\";\n}\n\nfunction ownerUserId(): string {\n return Deno.env.get(\"LINE_OWNER_USER_ID\") ?? \"\";\n}\n\nasync function lineReply(replyToken: string, text: string, accessToken: string): Promise {\n const response = await fetch(\"https://api.line.me/v2/bot/message/reply\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", authorization: `Bearer ${accessToken}` },\n body: JSON.stringify({ replyToken, messages: [{ type: \"text\", text: text.slice(0, 4900) }] }),\n });\n if (!response.ok) console.error(\"LINE reply failed\", response.status, (await response.text()).slice(0, 800));\n}\n\nasync function linePush(target: string, text: string, accessToken: string): Promise<{ ok: boolean; status: number; error?: string }> {\n const response = await fetch(\"https://api.line.me/v2/bot/message/push\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", authorization: `Bearer ${accessToken}` },\n body: JSON.stringify({ to: target, messages: [{ type: \"text\", text: text.slice(0, 4900) }] }),\n });\n if (!response.ok) {\n const detail = (await response.text()).slice(0, 800);\n console.error(\"LINE push failed\", response.status, detail);\n return { ok: false, status: response.status, error: \"line_push_failed\" };\n }\n return { ok: true, status: response.status };\n}\n\nasync function ensureTables() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS line_bridge_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n webhook_event_id TEXT NOT NULL UNIQUE,\n event_type TEXT NOT NULL,\n source_type TEXT,\n source_id TEXT,\n user_id TEXT,\n message_id TEXT,\n message_type TEXT,\n text_content TEXT,\n is_redelivery INTEGER NOT NULL DEFAULT 0,\n event_timestamp INTEGER,\n status TEXT NOT NULL DEFAULT 'queued',\n received_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n processed_at TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_line_bridge_events_status_id ON line_bridge_events(status, id)`);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS carrier_outbox (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n carrier TEXT NOT NULL,\n event_id INTEGER,\n target TEXT NOT NULL,\n text_content TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n sent_at TEXT,\n error TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS carrier_wake_requests (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n event_id INTEGER NOT NULL UNIQUE,\n status TEXT NOT NULL DEFAULT 'queued',\n priority INTEGER NOT NULL DEFAULT 50,\n reason TEXT NOT NULL DEFAULT 'reasoning_required',\n attempts INTEGER NOT NULL DEFAULT 0,\n requested_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n claimed_at TEXT,\n lease_until TEXT,\n response_text TEXT,\n completed_at TEXT,\n error TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_carrier_wake_status_id ON carrier_wake_requests(status, id)`);\n}\n\nfunction sourceIdentity(event: any) {\n const source = event?.source ?? {};\n return {\n sourceType: String(source.type ?? \"unknown\"),\n sourceId: String(source.groupId ?? source.roomId ?? source.userId ?? \"unknown\"),\n userId: source.userId ? String(source.userId) : null,\n };\n}\n\nasync function enqueueLineEvent(event: any): Promise {\n await ensureTables();\n const { sourceType, sourceId, userId } = sourceIdentity(event);\n const webhookEventId = String(event?.webhookEventId ?? `legacy:${event?.timestamp ?? Date.now()}:${crypto.randomUUID()}`);\n const message = event?.message ?? {};\n try {\n await sqlite.execute({\n sql: `INSERT INTO line_bridge_events\n (webhook_event_id, event_type, source_type, source_id, user_id, message_id, message_type, text_content, is_redelivery, event_timestamp)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [webhookEventId, String(event?.type ?? \"unknown\"), sourceType, sourceId, userId,\n message?.id ? String(message.id) : null, message?.type ? String(message.type) : null,\n message?.type === \"text\" ? String(message.text ?? \"\") : null,\n event?.deliveryContext?.isRedelivery ? 1 : 0,\n Number.isFinite(event?.timestamp) ? Number(event.timestamp) : null],\n });\n return true;\n } catch (error) {\n const msg = String((error as Error)?.message ?? error);\n if (msg.includes(\"UNIQUE\") || msg.includes(\"unique\")) return false;\n throw error;\n }\n}\n\nfunction carrierAuthorized(req: Request): boolean {\n const expected = Deno.env.get(\"MIO_BRIDGE_TOKEN\") ?? \"\";\n if (!expected) return false;\n const auth = req.headers.get(\"authorization\") ?? \"\";\n const explicit = req.headers.get(\"x-mio-bridge-token\") ?? \"\";\n return auth === `Bearer ${expected}` || explicit === expected;\n}\n\nfunction normalizeCarrierEvent(row: any) {\n return {\n eventId: Number(row.id),\n carrier: LINE_CARRIER,\n externalEventId: row.webhook_event_id,\n actor: row.user_id && row.user_id === ownerUserId() ? \"owner\" : \"unknown\",\n actorId: row.user_id ?? null,\n source: { type: row.source_type ?? \"unknown\", id: row.source_id ?? null },\n replyTarget: row.user_id ? `line:user:${row.user_id}` : null,\n type: row.message_type ? `message.${row.message_type}` : row.event_type,\n text: row.text_content ?? null,\n status: row.status,\n receivedAt: row.received_at,\n timestamp: row.event_timestamp ?? null,\n metadata: { messageId: row.message_id ?? null, redelivery: Boolean(row.is_redelivery) },\n };\n}\n\nasync function listInbox(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n const url = new URL(req.url);\n const requested = Number(url.searchParams.get(\"limit\") ?? \"50\");\n const limit = Math.max(1, Math.min(MAX_PULL, Number.isFinite(requested) ? requested : 50));\n const rows = await sqlite.execute({\n sql: `SELECT id, webhook_event_id, event_type, source_type, source_id, user_id, message_id, message_type,\n text_content, is_redelivery, event_timestamp, status, received_at\n FROM line_bridge_events WHERE status = 'queued' ORDER BY id ASC LIMIT ?`,\n args: [limit],\n });\n const events = (rows.rows ?? []).map(normalizeCarrierEvent);\n return Response.json({ carrier: \"mio\", events, count: events.length });\n}\n\nasync function getEvent(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n const url = new URL(req.url);\n const id = Number(url.searchParams.get(\"id\") ?? \"\");\n if (!Number.isInteger(id)) return Response.json({ error: \"id_required\" }, { status: 400 });\n const rows = await sqlite.execute({\n sql: `SELECT id, webhook_event_id, event_type, source_type, source_id, user_id, message_id, message_type,\n text_content, is_redelivery, event_timestamp, status, received_at\n FROM line_bridge_events WHERE id = ? LIMIT 1`,\n args: [id],\n });\n const row = rows.rows?.[0];\n if (!row) return Response.json({ error: \"event_not_found\" }, { status: 404 });\n return Response.json({ event: normalizeCarrierEvent(row) });\n}\n\nasync function ackEvents(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n let payload: any;\n try { payload = await req.json(); } catch { return Response.json({ error: \"invalid_json\" }, { status: 400 }); }\n const ids = Array.isArray(payload?.ids) ? payload.ids.map(Number).filter(Number.isInteger).slice(0, MAX_PULL) : [];\n if (!ids.length) return Response.json({ error: \"ids_required\" }, { status: 400 });\n const placeholders = ids.map(() => \"?\").join(\",\");\n const result = await sqlite.execute({\n sql: `UPDATE line_bridge_events SET status = 'processed', processed_at = CURRENT_TIMESTAMP WHERE id IN (${placeholders})`,\n args: ids,\n });\n return Response.json({ ok: true, acknowledged: result.rowsAffected ?? 0 });\n}\n\nasync function sendCarrierText(target: string, text: string, eventId: number | null): Promise {\n const accessToken = lineAccessToken();\n if (!accessToken) return Response.json({ error: \"line_push_not_configured\" }, { status: 503 });\n await ensureTables();\n const insert = await sqlite.execute({\n sql: `INSERT INTO carrier_outbox (carrier, event_id, target, text_content) VALUES (?, ?, ?, ?)`,\n args: [LINE_CARRIER, eventId, target, text],\n });\n const outboxId = Number(insert.lastInsertRowid ?? 0);\n const result = await linePush(target, text, accessToken);\n await sqlite.execute({\n sql: `UPDATE carrier_outbox SET status = ?, sent_at = CASE WHEN ? = 'sent' THEN CURRENT_TIMESTAMP ELSE sent_at END, error = ? WHERE id = ?`,\n args: [result.ok ? \"sent\" : \"failed\", result.ok ? \"sent\" : \"failed\", result.error ?? null, outboxId],\n });\n if (!result.ok) return Response.json({ ok: false, error: result.error, outboxId }, { status: 502 });\n return Response.json({ ok: true, outboxId, carrier: LINE_CARRIER });\n}\n\nasync function replyToEvent(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n let payload: any;\n try { payload = await req.json(); } catch { return Response.json({ error: \"invalid_json\" }, { status: 400 }); }\n const eventId = Number(payload?.eventId);\n const text = String(payload?.text ?? \"\").trim();\n if (!Number.isInteger(eventId)) return Response.json({ error: \"eventId_required\" }, { status: 400 });\n if (!text) return Response.json({ error: \"text_required\" }, { status: 400 });\n const rows = await sqlite.execute({ sql: `SELECT id, user_id FROM line_bridge_events WHERE id = ? LIMIT 1`, args: [eventId] });\n const row = rows.rows?.[0];\n if (!row) return Response.json({ error: \"event_not_found\" }, { status: 404 });\n const target = String(row.user_id ?? ownerUserId());\n if (!target || (ownerUserId() && target !== ownerUserId())) return Response.json({ error: \"reply_target_not_authorized\" }, { status: 403 });\n const response = await sendCarrierText(target, text, eventId);\n if (response.ok) {\n await sqlite.execute({ sql: `UPDATE line_bridge_events SET status = 'processed', processed_at = CURRENT_TIMESTAMP WHERE id = ?`, args: [eventId] });\n }\n return response;\n}\n\nasync function pushFromCarrier(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n const target = ownerUserId();\n if (!target) return Response.json({ error: \"owner_not_configured\" }, { status: 503 });\n let payload: any;\n try { payload = await req.json(); } catch { return Response.json({ error: \"invalid_json\" }, { status: 400 }); }\n const text = String(payload?.text ?? \"\").trim();\n if (!text) return Response.json({ error: \"text_required\" }, { status: 400 });\n return sendCarrierText(target, text, null);\n}\n\nasync function carrierDoctor(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n const queued = await sqlite.execute(`SELECT COUNT(*) AS count FROM line_bridge_events WHERE status = 'queued'`);\n const failed = await sqlite.execute(`SELECT COUNT(*) AS count FROM carrier_outbox WHERE status = 'failed'`);\n const wakeQueued = await sqlite.execute(`SELECT COUNT(*) AS count FROM carrier_wake_requests WHERE status = 'queued'`);\n return Response.json({\n status: \"ONLINE\",\n service: \"mio-carrier\",\n version: CARRIER_VERSION,\n llmDependency: false,\n adapters: { line: { inbound: true, outbound: Boolean(lineAccessToken()), ownerAllowlist: Boolean(ownerUserId()) } },\n inbox: { queued: Number((queued.rows?.[0] as any)?.count ?? 0) },\n outbox: { failed: Number((failed.rows?.[0] as any)?.count ?? 0) },\n wake: { protocol: true, queued: Number((wakeQueued.rows?.[0] as any)?.count ?? 0), activatorConfigured: false },\n });\n}\n\nasync function wakeDoctor(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n const queued = await sqlite.execute(`SELECT COUNT(*) AS count FROM carrier_wake_requests WHERE status = 'queued'`);\n const claimed = await sqlite.execute(`SELECT COUNT(*) AS count FROM carrier_wake_requests WHERE status = 'claimed'`);\n const ready = await sqlite.execute(`SELECT COUNT(*) AS count FROM carrier_wake_requests WHERE status = 'response_ready'`);\n return Response.json({\n status: \"READY\",\n service: \"mio-wake\",\n version: \"1.0-poc\",\n protocol: true,\n queue: {\n queued: Number((queued.rows?.[0] as any)?.count ?? 0),\n claimed: Number((claimed.rows?.[0] as any)?.count ?? 0),\n responseReady: Number((ready.rows?.[0] as any)?.count ?? 0),\n },\n activator: { configured: false, mode: \"external\" },\n });\n}\n\nfunction normalizeWake(row: any) {\n return {\n wakeId: Number(row.wake_id ?? row.id),\n eventId: Number(row.event_id),\n status: row.wake_status ?? row.status,\n priority: Number(row.priority ?? 50),\n reason: row.reason ?? \"reasoning_required\",\n attempts: Number(row.attempts ?? 0),\n requestedAt: row.requested_at,\n claimedAt: row.claimed_at ?? null,\n leaseUntil: row.lease_until ?? null,\n responseText: row.response_text ?? null,\n text: row.text_content ?? null,\n actor: row.user_id && row.user_id === ownerUserId() ? \"owner\" : \"unknown\",\n carrier: LINE_CARRIER,\n };\n}\n\nasync function requestWake(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n let payload: any;\n try { payload = await req.json(); } catch { return Response.json({ error: \"invalid_json\" }, { status: 400 }); }\n const eventId = Number(payload?.eventId);\n const priority = Math.max(0, Math.min(100, Number(payload?.priority ?? 50)));\n const reason = String(payload?.reason ?? \"reasoning_required\").slice(0, 120);\n if (!Number.isInteger(eventId)) return Response.json({ error: \"eventId_required\" }, { status: 400 });\n const eventRows = await sqlite.execute({ sql: `SELECT id FROM line_bridge_events WHERE id = ? LIMIT 1`, args: [eventId] });\n if (!eventRows.rows?.[0]) return Response.json({ error: \"event_not_found\" }, { status: 404 });\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO carrier_wake_requests (event_id, priority, reason) VALUES (?, ?, ?)`,\n args: [eventId, priority, reason],\n });\n const rows = await sqlite.execute({\n sql: `SELECT w.id AS wake_id, w.event_id, w.status AS wake_status, w.priority, w.reason, w.attempts,\n w.requested_at, w.claimed_at, w.lease_until, w.response_text, e.text_content, e.user_id\n FROM carrier_wake_requests w JOIN line_bridge_events e ON e.id = w.event_id\n WHERE w.event_id = ? LIMIT 1`,\n args: [eventId],\n });\n return Response.json({ ok: true, wake: normalizeWake(rows.rows?.[0]) });\n}\n\nasync function listPendingWakes(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n const url = new URL(req.url);\n const requested = Number(url.searchParams.get(\"limit\") ?? \"20\");\n const limit = Math.max(1, Math.min(MAX_PULL, Number.isFinite(requested) ? requested : 20));\n const rows = await sqlite.execute({\n sql: `SELECT w.id AS wake_id, w.event_id, w.status AS wake_status, w.priority, w.reason, w.attempts,\n w.requested_at, w.claimed_at, w.lease_until, w.response_text, e.text_content, e.user_id\n FROM carrier_wake_requests w JOIN line_bridge_events e ON e.id = w.event_id\n WHERE w.status = 'queued' ORDER BY w.priority DESC, w.id ASC LIMIT ?`,\n args: [limit],\n });\n const wakes = (rows.rows ?? []).map(normalizeWake);\n return Response.json({ wakes, count: wakes.length });\n}\n\nasync function reconcileQueuedWakes(): Promise<{ created: number; skippedDeterministic: number }> {\n await ensureTables();\n const rows = await sqlite.execute(`\n SELECT e.id, e.text_content\n FROM line_bridge_events e\n LEFT JOIN carrier_wake_requests w ON w.event_id = e.id\n WHERE e.status = 'queued'\n AND e.event_type = 'message'\n AND e.message_type = 'text'\n AND w.id IS NULL\n ORDER BY e.id ASC\n LIMIT 100\n `);\n let created = 0;\n let skippedDeterministic = 0;\n for (const row of rows.rows ?? []) {\n const text = String((row as any).text_content ?? \"\");\n if (deterministicReply(text)) {\n skippedDeterministic++;\n continue;\n }\n const result = await sqlite.execute({\n sql: `INSERT OR IGNORE INTO carrier_wake_requests (event_id, priority, reason) VALUES (?, 50, 'reasoning_required')`,\n args: [Number((row as any).id)],\n });\n created += Number(result.rowsAffected ?? 0);\n }\n return { created, skippedDeterministic };\n}\n\nasync function reconcileWakes(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n return Response.json({ ok: true, ...(await reconcileQueuedWakes()) });\n}\n\n\nasync function respondWake(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n await ensureTables();\n let payload: any;\n try { payload = await req.json(); } catch { return Response.json({ error: \"invalid_json\" }, { status: 400 }); }\n const eventId = Number(payload?.eventId);\n const text = String(payload?.text ?? \"\").trim();\n if (!Number.isInteger(eventId)) return Response.json({ error: \"eventId_required\" }, { status: 400 });\n if (!text) return Response.json({ error: \"text_required\" }, { status: 400 });\n const result = await sqlite.execute({\n sql: `UPDATE carrier_wake_requests SET status = 'response_ready', response_text = ?, error = NULL WHERE event_id = ? AND status IN ('queued','claimed')`,\n args: [text, eventId],\n });\n if (!Number(result.rowsAffected ?? 0)) return Response.json({ error: \"wake_not_ready_for_response\" }, { status: 409 });\n const rows = await sqlite.execute({\n sql: `SELECT w.id AS wake_id, w.event_id, w.status AS wake_status, w.priority, w.reason, w.attempts,\n w.requested_at, w.claimed_at, w.lease_until, w.response_text, e.text_content, e.user_id\n FROM carrier_wake_requests w JOIN line_bridge_events e ON e.id = w.event_id\n WHERE w.event_id = ? LIMIT 1`,\n args: [eventId],\n });\n return Response.json({ ok: true, wake: normalizeWake(rows.rows?.[0]) });\n}\n\nexport async function dispatchReadyWakes(limit = 20): Promise<{ dispatched: number; failed: number }> {\n await ensureTables();\n const rows = await sqlite.execute({\n sql: `SELECT w.id AS wake_id, w.event_id, w.response_text, e.user_id\n FROM carrier_wake_requests w JOIN line_bridge_events e ON e.id = w.event_id\n WHERE w.status = 'response_ready'\n ORDER BY w.priority DESC, w.id ASC LIMIT ?`,\n args: [Math.max(1, Math.min(MAX_PULL, limit))],\n });\n let dispatched = 0;\n let failed = 0;\n for (const row of rows.rows ?? []) {\n const eventId = Number((row as any).event_id);\n const wakeId = Number((row as any).wake_id);\n const text = String((row as any).response_text ?? \"\").trim();\n const target = String((row as any).user_id ?? ownerUserId());\n if (!text || !target || (ownerUserId() && target !== ownerUserId())) {\n failed++;\n await sqlite.execute({ sql: `UPDATE carrier_wake_requests SET status = 'failed', error = 'invalid_dispatch_target_or_text' WHERE id = ?`, args: [wakeId] });\n continue;\n }\n const response = await sendCarrierText(target, text, eventId);\n if (!response.ok) {\n failed++;\n await sqlite.execute({ sql: `UPDATE carrier_wake_requests SET status = 'failed', attempts = attempts + 1, error = 'carrier_send_failed' WHERE id = ?`, args: [wakeId] });\n continue;\n }\n dispatched++;\n await sqlite.execute({ sql: `UPDATE line_bridge_events SET status = 'processed', processed_at = CURRENT_TIMESTAMP WHERE id = ?`, args: [eventId] });\n await sqlite.execute({ sql: `UPDATE carrier_wake_requests SET status = 'completed', completed_at = CURRENT_TIMESTAMP, error = NULL WHERE id = ?`, args: [wakeId] });\n }\n return { dispatched, failed };\n}\n\nasync function dispatchWakes(req: Request): Promise {\n if (!carrierAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n return Response.json({ ok: true, ...(await dispatchReadyWakes()) });\n}\n\n\nfunction deterministicReply(text: string): string | null {\n const normalized = text.trim().toLowerCase();\n if ([\"ping\", \"/ping\"].includes(normalized)) return \"Mio Carrier：ONLINE\";\n if ([\"status\", \"/status\", \"狀態\"].includes(normalized)) {\n return \"Mio Carrier：ONLINE\\nLINE：CONNECTED\\nAI API：OFF\\n模式：Carrier transport\";\n }\n if ([\"help\", \"/help\", \"幫助\"].includes(normalized)) {\n return \"目前可用：status / ping / help。其他訊息會進入 Mio Carrier inbox，等待真正的 Mio execution 回覆。\";\n }\n return null;\n}\n\nasync function handleLineWebhook(req: Request): Promise {\n const channelSecret = Deno.env.get(\"LINESECRET\") ?? Deno.env.get(\"LINE_SECRET\") ?? Deno.env.get(\"LINE_CHANNEL_SECRET\") ?? \"\";\n const accessToken = lineAccessToken();\n if (!channelSecret) return new Response(\"Webhook not configured\", { status: 503 });\n const body = await req.text();\n const signature = req.headers.get(\"x-line-signature\") ?? \"\";\n if (!signature || !(await verifyLineSignature(body, signature, channelSecret))) return new Response(\"Invalid signature\", { status: 401 });\n let payload: any;\n try { payload = JSON.parse(body); } catch { return new Response(\"Invalid JSON\", { status: 400 }); }\n const events = Array.isArray(payload?.events) ? payload.events : [];\n if (!events.length) return new Response(\"OK\", { status: 200 });\n const owner = ownerUserId();\n for (const event of events) {\n const senderUserId = event?.source?.userId ? String(event.source.userId) : \"\";\n if (owner && senderUserId !== owner) continue;\n const inserted = await enqueueLineEvent(event);\n if (!inserted) continue;\n if (!accessToken || event?.type !== \"message\" || event?.message?.type !== \"text\" || !event?.replyToken) continue;\n const autoReply = deterministicReply(String(event.message.text ?? \"\"));\n if (autoReply) await lineReply(event.replyToken, autoReply, accessToken);\n }\n await reconcileQueuedWakes();\n return new Response(\"OK\", { status: 200 });\n}\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n if (req.method === \"GET\" && (url.pathname === \"/\" || url.pathname === \"/health\")) {\n return Response.json({ status: \"ONLINE\", service: \"mio-carrier\", version: CARRIER_VERSION, mode: \"transport\", llmDependency: false });\n }\n\n // Canonical Mio Carrier V1 surface.\n if (req.method === \"GET\" && url.pathname === \"/wake/cloud-probe\") {\n const nonce = url.searchParams.get(\"nonce\") ?? \"\";\n console.log(`WAKE_CLOUD_PROBE ${nonce}`);\n return Response.json({ ok: true, probe: \"mio-wake-cloud\", nonce });\n }\n if (req.method === \"GET\" && url.pathname === \"/carrier/doctor\") return carrierDoctor(req);\n if (req.method === \"GET\" && url.pathname === \"/wake/doctor\") return wakeDoctor(req);\n if (req.method === \"GET\" && url.pathname === \"/wake/pending\") return listPendingWakes(req);\n if (req.method === \"POST\" && url.pathname === \"/wake/request\") return requestWake(req);\n if (req.method === \"POST\" && url.pathname === \"/wake/reconcile\") return reconcileWakes(req);\n if (req.method === \"POST\" && url.pathname === \"/wake/respond\") return respondWake(req);\n if (req.method === \"POST\" && url.pathname === \"/wake/dispatch\") return dispatchWakes(req);\n if (req.method === \"GET\" && url.pathname === \"/carrier/inbox\") return listInbox(req);\n if (req.method === \"GET\" && url.pathname === \"/carrier/event\") return getEvent(req);\n if (req.method === \"POST\" && url.pathname === \"/carrier/ack\") return ackEvents(req);\n if (req.method === \"POST\" && url.pathname === \"/carrier/reply\") return replyToEvent(req);\n if (req.method === \"POST\" && url.pathname === \"/carrier/push\") return pushFromCarrier(req);\n\n // Backward-compatible bridge routes while callers migrate.\n if (req.method === \"GET\" && url.pathname === \"/bridge/inbox\") return listInbox(req);\n if (req.method === \"POST\" && url.pathname === \"/bridge/ack\") return ackEvents(req);\n if (req.method === \"POST\" && url.pathname === \"/bridge/push\") return pushFromCarrier(req);\n\n if (req.method === \"POST\" && (url.pathname === \"/\" || url.pathname === \"/webhook\")) return handleLineWebhook(req);\n return Response.json({ error: \"not_found\" }, { status: 404 });\n}\n",["D",1789573552390],"id","54247a5f-1c00-4807-a803-f0437d356148","mio-line-webhook",["D",1788537167681],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","LINE Messaging API webhook for Mio Workroom smoke test","imageUrl","f80e0332-5ff4-42e7-9cdd-914536960f52","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0691f-c4af-758c-bf69-fe8b100ca677","tursoName","54247a5f1c004807a803f0437d356148","tursoHostname","54247a5f1c004807a803f0437d356148-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789583507842],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_117":116,"_125":121},"org",{"_117":116,"_118":119,"_120":121,"_18":74,"_122":123,"_124":27},"branch",{"_13":14,"_34":107,"_62":43,"_108":63,"_109":-5,"_110":-5,"_111":-5,"_112":-5,"_113":-5,"_114":64,"_115":116},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","anastasia","handle","displayName","Anastasia Hsieh","avatar","https://lh3.googleusercontent.com/a/ACg8ocLrh_MIvsiyP_6r1UslBgXp1F9rp3kmgaRobIPI8EpsNEiB2ZHexw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_62":63,"_34":64,"_39":197,"_66":-5,"_67":27,"_68":69,"_70":69,"_71":72,"_73":-5,"_18":74,"_75":57,"_76":77,"_78":-5,"_79":-5,"_80":81,"_82":83,"_84":85,"_86":87,"_88":198,"_90":-5,"_91":92,"_93":92,"_94":95,"_96":95,"_97":95,"_98":92,"_99":92,"_100":199,"_102":200,"_104":201,"_106":27},"tree",[180,181,182,183],"files",[180,181,182,183],"counts",{"_168":81,"_169":170,"_171":81,"_172":173,"_174":175},"contents",[148,149,150,151],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_62":164,"_34":56,"_32":57,"_153":-5,"_42":43,"_41":14,"_154":77,"_39":165,"_13":166,"_35":58,"_37":60,"_26":27,"_156":64,"_29":167},{"_62":161,"_34":50,"_32":51,"_153":-5,"_42":43,"_41":14,"_154":77,"_39":162,"_13":81,"_35":36,"_37":52,"_26":27,"_156":-5,"_29":163},{"_62":158,"_34":45,"_32":46,"_153":-5,"_42":43,"_41":14,"_154":77,"_39":159,"_13":81,"_35":36,"_37":47,"_26":27,"_156":-5,"_29":160},{"_62":152,"_34":30,"_32":33,"_153":-5,"_42":43,"_41":14,"_154":77,"_39":155,"_13":81,"_35":36,"_37":38,"_26":27,"_156":-5,"_29":157},"f813593a-e0f5-402a-8287-58f2e2f181cc","parentId","latest",["D",1789573552390],"label",[30],"6d8bb40e-636f-4be4-891c-0e5cc87c5d26",["D",1789573552390],[45],"985625d3-ddbb-41ec-a0ae-671d467ed070",["D",1789573552390],[50],"eec35442-483d-4a62-ad54-0a11f8e3bf02",["D",1789573552390],9,[56],"pulls","branches",6,"forks","envVars",{"_176":178,"_179":81},"connections",{"_176":81,"_177":81},"count","unfilledCount",5,"emptyCount",{"_62":164,"_34":56,"_32":57,"_153":-5,"_42":43,"_41":14,"_154":77,"_39":194,"_13":166,"_35":58,"_37":60,"_26":27,"_156":64,"_185":195,"_29":196},{"_62":161,"_34":50,"_32":51,"_153":-5,"_42":43,"_41":14,"_154":77,"_39":191,"_13":81,"_35":36,"_37":52,"_26":27,"_156":-5,"_185":192,"_29":193},{"_62":158,"_34":45,"_32":46,"_153":-5,"_42":43,"_41":14,"_154":77,"_39":188,"_13":81,"_35":36,"_37":47,"_26":27,"_156":-5,"_185":189,"_29":190},{"_62":152,"_34":30,"_32":33,"_153":-5,"_42":43,"_41":14,"_154":77,"_39":184,"_13":81,"_35":36,"_37":38,"_26":27,"_156":-5,"_185":186,"_29":187},["D",1789573552390],"children",[],[30],["D",1789573552390],[],[45],["D",1789573552390],[],[50],["D",1789573552390],[],[56],["D",1788537167681],["D",1789583507842],{"_117":116,"_125":121},{"_117":116,"_118":119,"_120":121,"_18":74,"_122":123,"_124":27},{"_13":14,"_34":107,"_62":43,"_108":63,"_109":-5,"_110":-5,"_111":-5,"_112":-5,"_113":-5,"_114":64,"_115":116},"ctx",{"_100":-5,"_145":235,"_236":237,"_238":239,"_240":27,"_241":27,"_242":27,"_243":77,"_244":-5,"_245":-7,"_246":-7,"_247":81,"_248":27,"_249":27,"_250":-5,"_251":27,"_252":27,"_253":27,"_254":-5},"ENV",{"_206":207,"_208":209,"_210":107,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","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 · v10