[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_105":106,"_107":108},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","anastasia","name","mio-line-webhook","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":12,"_13":44},"permalink","https://www.val.town/x/anastasia/mio-line-webhook/code/main.ts","extension","id","eec35442-483d-4a62-ad54-0a11f8e3bf02","fileId","ad07988a-a878-11f1-96d5-1607ee4eb77e","parentId","branchId","1ad158c8-0593-408b-a98b-abb0b1ac9f4f","branchVersion",10,"latest",true,"createdAt",["D",1789573552390],"version",9,"fileType","http","content","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","deleted",false,"label",[14],"54247a5f-1c00-4807-a803-f0437d356148",["D",1788537167681],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","LINE Messaging API webhook for Mio Workroom smoke test","imageUrl","userId","f80e0332-5ff4-42e7-9cdd-914536960f52","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0691f-c4af-758c-bf69-fe8b100ca677","tursoName","54247a5f1c004807a803f0437d356148","tursoHostname","54247a5f1c004807a803f0437d356148-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789670463917],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_104":100},"org",{"_9":10,"_97":98,"_99":100,"_55":56,"_101":102,"_103":42},"branch",{"_35":30,"_11":88,"_22":28,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":12,"_96":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Anastasia Hsieh","avatar","https://lh3.googleusercontent.com/a/ACg8ocLrh_MIvsiyP_6r1UslBgXp1F9rp3kmgaRobIPI8EpsNEiB2ZHexw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_138":139,"_140":141,"_142":143,"_144":42,"_145":42,"_146":42,"_147":32,"_148":-5,"_149":-7,"_150":-7,"_151":62,"_152":42,"_153":42,"_154":-5,"_155":42,"_156":42,"_157":42,"_158":-5},"ENV",{"_109":110,"_111":112,"_113":88,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]