[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_160":161,"_162":163},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_108":89,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":58,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_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":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":25},"version",9,"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","ad07988a-a878-11f1-96d5-1607ee4eb77e","name","fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst encoder = new TextEncoder();\nconst MAX_PULL = 100;\n\nasync function verifyLineSignature(body: string, signature: string, secret: string): Promise {\n const key = await crypto.subtle.importKey(\n \"raw\",\n encoder.encode(secret),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\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\nasync function replyText(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: {\n \"content-type\": \"application/json\",\n authorization: `Bearer ${accessToken}`,\n },\n body: JSON.stringify({\n replyToken,\n messages: [{ type: \"text\", text: text.slice(0, 4900) }],\n }),\n });\n if (!response.ok) console.error(\"LINE reply failed\", response.status, (await response.text()).slice(0, 800));\n}\n\nasync function pushText(userId: string, text: string, accessToken: string): Promise {\n const response = await fetch(\"https://api.line.me/v2/bot/message/push\", {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n authorization: `Bearer ${accessToken}`,\n },\n body: JSON.stringify({\n to: userId,\n messages: [{ type: \"text\", text: text.slice(0, 4900) }],\n }),\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 Response.json({ ok: false, error: \"line_push_failed\", status: response.status }, { status: 502 });\n }\n return Response.json({ ok: true });\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(`\n CREATE INDEX IF NOT EXISTS idx_line_bridge_events_status_id\n ON line_bridge_events(status, id)\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 enqueueEvent(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: [\n webhookEventId,\n String(event?.type ?? \"unknown\"),\n sourceType,\n sourceId,\n userId,\n message?.id ? String(message.id) : null,\n 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 });\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 bridgeAuthorized(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\nasync function pullInbox(req: Request): Promise {\n if (!bridgeAuthorized(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,\n message_id, message_type, text_content, is_redelivery, event_timestamp,\n status, received_at\n FROM line_bridge_events\n WHERE status = 'queued'\n ORDER BY id ASC\n LIMIT ?`,\n args: [limit],\n });\n return Response.json({ events: rows.rows ?? [], count: rows.rows?.length ?? 0 });\n}\n\nasync function ackInbox(req: Request): Promise {\n if (!bridgeAuthorized(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 pushFromBridge(req: Request): Promise {\n if (!bridgeAuthorized(req)) return Response.json({ error: \"unauthorized\" }, { status: 401 });\n const accessToken = Deno.env.get(\"LINETOKEN\") ?? Deno.env.get(\"LINE_TOKEN\") ?? Deno.env.get(\"LINE_CHANNEL_ACCESS_TOKEN\") ?? \"\";\n const ownerUserId = Deno.env.get(\"LINE_OWNER_USER_ID\") ?? \"\";\n if (!accessToken || !ownerUserId) return Response.json({ error: \"line_push_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 pushText(ownerUserId, text, accessToken);\n}\n\nfunction deterministicReply(text: string): string | null {\n const normalized = text.trim().toLowerCase();\n if ([\"ping\", \"/ping\"].includes(normalized)) return \"Mio LINE Bridge：ONLINE\";\n if ([\"status\", \"/status\", \"狀態\"].includes(normalized)) {\n return \"Mio LINE Bridge：ONLINE\\n模式：Transport only\\nAI API：OFF\\nWorkroom：等待正式 carrier 接手\";\n }\n if ([\"help\", \"/help\", \"幫助\"].includes(normalized)) {\n return \"目前可用：status / ping / help。其他訊息只會進入 Mio inbox，等待真正的 Mio/Chat carrier 回覆。\";\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 = Deno.env.get(\"LINETOKEN\") ?? Deno.env.get(\"LINE_TOKEN\") ?? Deno.env.get(\"LINE_CHANNEL_ACCESS_TOKEN\") ?? \"\";\n if (!channelSecret) return new Response(\"Webhook not configured\", { status: 503 });\n\n const body = await req.text();\n const signature = req.headers.get(\"x-line-signature\") ?? \"\";\n if (!signature || !(await verifyLineSignature(body, signature, channelSecret))) {\n console.warn(\"Rejected webhook with invalid LINE signature\");\n return new Response(\"Invalid signature\", { status: 401 });\n }\n\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\n const ownerUserId = Deno.env.get(\"LINE_OWNER_USER_ID\") ?? \"\";\n for (const event of events) {\n const senderUserId = event?.source?.userId ? String(event.source.userId) : \"\";\n if (ownerUserId && senderUserId !== ownerUserId) {\n console.warn(\"Ignored LINE event from non-owner sender\");\n continue;\n }\n\n const inserted = await enqueueEvent(event);\n if (!inserted) continue;\n if (!accessToken || event?.type !== \"message\" || event?.message?.type !== \"text\" || !event?.replyToken) continue;\n const userText = String(event.message.text ?? \"\").trim();\n const autoReply = userText ? deterministicReply(userText) : null;\n if (autoReply) await replyText(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\n if (req.method === \"GET\" && (url.pathname === \"/\" || url.pathname === \"/health\")) {\n return Response.json({\n status: \"ONLINE\",\n service: \"mio-line-bridge\",\n mode: \"transport-only\",\n llmDependency: false,\n inbox: \"/bridge/inbox\",\n ownerAllowlist: Deno.env.get(\"LINE_OWNER_USER_ID\") ? \"configured\" : \"not-configured\",\n });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/bridge/inbox\") return pullInbox(req);\n if (req.method === \"POST\" && url.pathname === \"/bridge/ack\") return ackInbox(req);\n if (req.method === \"POST\" && url.pathname === \"/bridge/push\") return pushFromBridge(req);\n if (req.method === \"POST\" && (url.pathname === \"/\" || url.pathname === \"/webhook\")) return handleLineWebhook(req);\n\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}\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","createdAt",["D",1789563257897],"branchVersion","branchId","1ad158c8-0593-408b-a98b-abb0b1ac9f4f","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",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",10,"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",{"_43":44,"_32":45,"_38":155,"_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":66,"_67":68,"_69":156,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":157,"_83":158,"_85":159,"_87":25},"tree",[150],"files",[150],"counts",{"_138":62,"_139":140,"_141":62,"_142":143,"_144":145},"contents",[130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":25,"_38":134,"_13":135,"_33":34,"_35":37,"_24":25,"_136":45,"_27":137},"13340bcb-8858-4233-8d27-6708eb69f852","parentId","latest",["D",1789563257897],8,"label",[28],"pulls","branches",6,"forks","envVars",{"_146":148,"_149":62},"connections",{"_146":62,"_147":62},"count","unfilledCount",5,"emptyCount",{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":25,"_38":151,"_13":135,"_33":34,"_35":37,"_24":25,"_136":45,"_152":153,"_27":154},["D",1789563257897],"children",[],[28],["D",1788537167681],["D",1789583507842],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_127":193,"_194":195,"_196":197,"_198":25,"_199":25,"_200":25,"_201":58,"_202":-5,"_203":-7,"_204":-7,"_205":62,"_206":25,"_207":25,"_208":-5,"_209":25,"_210":25,"_211":25,"_212":-5},"ENV",{"_164":165,"_166":167,"_168":89,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192},"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 · v9