[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_206":207,"_208":209},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_38":-7,"_130":-5,"_19":131,"_132":133,"_134":135,"_136":137,"_138":139,"_21":140,"_141":-5,"_142":-5,"_143":24,"_144":145,"_146":90,"_147":-5,"_148":-5,"_149":150},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","anastasia","name","mio-line-webhook","branchName","main","path","wake_contract_test.ts","project",{"_32":78,"_13":14,"_36":79,"_68":-5,"_80":24,"_81":82,"_83":82,"_84":85,"_86":-5,"_30":74,"_87":88,"_89":90,"_91":-5,"_92":-5,"_93":26,"_40":41,"_94":95,"_96":97,"_98":99,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_54":110,"_111":112,"_113":114,"_115":24},"file",{"_69":70,"_13":18,"_71":72,"_73":24,"_77":-5},"isDirectory",false,"page",0,"history",[31],"hasNext","userId",{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_21":56,"_57":-5,"_58":59,"_60":-5,"_61":-5,"_62":63},"id","2093e2d0-a0dd-43fc-90eb-cc88268818d6","branchId","1ad158c8-0593-408b-a98b-abb0b1ac9f4f","createdAt",["D",1789573552390],"version",10,"orgId","01a0691f-c4af-758c-bf69-fe8b100ca677","parentId","da20f372-9d2e-4eb5-85bf-61fdf38a5e6f","incomingCommitId","4689dd87-ebc3-4602-89fa-4c9dd4c8191d","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","mcp","clientLabel","ChatGPT","user",{"_32":74,"_40":41,"_11":12,"_75":76},{"_69":70,"_13":18,"_71":72,"_73":24},"pull","merge",{"_34":65,"_13":66,"_38":67,"_68":-5},"revert","multiple","commits",[64],{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_21":56,"_57":-5,"_58":59,"_60":-5},"95747872-5571-403d-8004-722be30988f6","mio-wake-v1",20,"deletedAt","fileId","b2691a3a-b1e5-11f1-9497-1607ee4eb77e","fileType","script","deleted","f80e0332-5ff4-42e7-9cdd-914536960f52","avatar","https://lh3.googleusercontent.com/a/ACg8ocLrh_MIvsiyP_6r1UslBgXp1F9rp3kmgaRobIPI8EpsNEiB2ZHexw=s96-c","deletedAtVersion","54247a5f-1c00-4807-a803-f0437d356148",["D",1788537167681],"legacyEnvVars","privacy","public","httpPrivacy","description","LINE Messaging API webhook for Mio Workroom smoke test","imageUrl","pinnedFileId","ad07988a-a878-11f1-96d5-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_129":76},"org",{"_11":12,"_124":125,"_75":76,"_30":74,"_126":127,"_128":24},"branch",{"_38":39,"_13":16,"_32":35,"_116":78,"_117":-5,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":14,"_123":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Anastasia Hsieh","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":78,"_13":14,"_36":201,"_68":-5,"_80":24,"_81":82,"_83":82,"_84":85,"_86":-5,"_30":74,"_87":88,"_89":90,"_91":-5,"_92":-5,"_93":26,"_40":41,"_94":95,"_96":97,"_98":202,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_54":203,"_111":204,"_113":205,"_115":24},"tree",[171,172,173,174],"files",[171,172,173,174],"counts",{"_159":26,"_160":161,"_162":26,"_163":164,"_165":166},"contents",[],{"_32":151,"_13":18,"_69":70,"_42":-5,"_34":35,"_152":39,"_153":90,"_36":154,"_38":26,"_71":72,"_155":156,"_73":24,"_157":-5,"_17":158},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"6d8bb40e-636f-4be4-891c-0e5cc87c5d26","branchVersion","latest",["D",1789573552390],"content","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","label",[18],"pulls","branches",6,"forks","envVars",{"_167":169,"_170":26},"connections",{"_167":26,"_168":26},"count","unfilledCount",5,"emptyCount",{"_32":193,"_13":194,"_69":88,"_42":-5,"_34":35,"_152":39,"_153":90,"_36":195,"_38":196,"_71":197,"_155":198,"_73":24,"_157":14,"_180":199,"_17":200},{"_32":186,"_13":187,"_69":188,"_42":-5,"_34":35,"_152":39,"_153":90,"_36":189,"_38":26,"_71":72,"_155":190,"_73":24,"_157":-5,"_180":191,"_17":192},{"_32":151,"_13":18,"_69":70,"_42":-5,"_34":35,"_152":39,"_153":90,"_36":183,"_38":26,"_71":72,"_155":156,"_73":24,"_157":-5,"_180":184,"_17":185},{"_32":175,"_13":176,"_69":177,"_42":-5,"_34":35,"_152":39,"_153":90,"_36":178,"_38":26,"_71":72,"_155":179,"_73":24,"_157":-5,"_180":181,"_17":182},"f813593a-e0f5-402a-8287-58f2e2f181cc","wake_dispatch.ts","b26940be-b1e5-11f1-9497-1607ee4eb77e",["D",1789573552390],"import { dispatchReadyWakes } from \"./main.ts\";\n\nconst result = await dispatchReadyWakes(20);\nconsole.log(\"Mio Wake dispatch\", result);\nexport default result;\n","children",[],[176],["D",1789573552390],[],[18],"985625d3-ddbb-41ec-a0ae-671d467ed070","wake_cloud_dispatch.ts","b268ea60-b1e5-11f1-9497-1607ee4eb77e",["D",1789573552390],"import { dispatchReadyWakes } from \"./main.ts\";\n\nconst result = await dispatchReadyWakes(5);\nconsole.log(JSON.stringify(result));\n",[],[187],"eec35442-483d-4a62-ad54-0a11f8e3bf02","main.ts",["D",1789573552390],9,"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 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",[],[194],["D",1788537167681],["D",1789583507842],{"_11":12,"_129":76},{"_11":12,"_124":125,"_75":76,"_30":74,"_126":127,"_128":24},{"_38":39,"_13":16,"_32":35,"_116":78,"_117":-5,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":14,"_123":12},"ctx",{"_54":-5,"_148":239,"_240":241,"_242":243,"_244":24,"_245":24,"_246":24,"_247":90,"_248":-5,"_249":-7,"_250":-7,"_251":26,"_252":24,"_253":24,"_254":-5,"_255":24,"_256":24,"_257":24,"_258":-5},"ENV",{"_210":211,"_212":213,"_214":16,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238},"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"]

History · wake_contract_test.ts