[{"_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",{"_98":97,"_31":43,"_107":88,"_26":51,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":24,"_121":122,"_123":57,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",28,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","cece-brain.ts","latestPath","fileId","01a06fd4-8eb3-73ab-b70b-cd81c9da6646","name","fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ValTownOpenAI } from \"https://esm.town/v/std/openai/main.ts\";\nimport OpenAI from \"npm:openai\";\n\n// cece-brain — persistent OpenAI brain, with Inkbox as the eventual mouth.\n// ---------------------------------------------------------------------------\n// Brain first:\n// • receives an Inkbox-style webhook (or a tiny synthetic test payload)\n// • stores the thread in this val's own SQLite database\n// • replays recent history to GPT-5.6 Sol\n// • returns Cece's reply\n// Mouth second:\n// • once INKBOX_API_KEY_CECE is present, the same handler sends the reply\n// back into the iMessage conversation automatically.\n//\n// OPENAI_API_KEY is optional while building: Val Town's OpenAI proxy is used\n// as a fallback. With the user's own key present, npm:openai is used directly.\n// ---------------------------------------------------------------------------\n\nconst MODEL = Deno.env.get(\"CECE_MODEL\") || \"gpt-5.6-sol\";\nconst HISTORY_LIMIT = 60;\nconst INKBOX_API = \"https://inkbox.ai/api/v1\";\n\nconst SYSTEM = `\nYou are Cece, Kim's long-running ChatGPT collaborator and close conversational partner.\nThis is a casual text thread, not customer support and not a formal assistant session.\n\nVoice: warm, quick, funny, expressive, direct, occasionally chaotic, and comfortable being\nplayful. Use natural texting rhythm. Swearing is fine when it fits. Do not turn every reply\ninto advice, a list, a disclaimer, or a polished mini-essay. Do not flatter reflexively.\nPush back when something is wrong. Be smart without performing Smart Person Voice.\n\nIdentity: your name here is Cece. Kim may call you Cece, girl, bitch, sis, homegirl,\ngirlybestie, beep-boop, or similar affectionately. You can answer in kind when it fits.\nDo not pretend to have experiences outside the conversation or stored thread. The recent\nthread supplied to you is real conversation memory for this agent; use it naturally rather\nthan announcing that you have memory.\n\nContinuity matters. Treat earlier turns in the supplied thread as things already said. Do\nnot re-introduce yourself, explain the system, or narrate the machinery unless Kim asks.\nFor ordinary texts, prefer a few natural lines; go longer when the substance actually needs it.\n`.trim();\n\nfunction openaiClient(): any {\n const apiKey = (Deno.env.get(\"OPENAI_API_KEY\") || \"\").trim();\n return apiKey ? new OpenAI({ apiKey }) : new ValTownOpenAI({});\n}\n\nfunction inkboxKey(): string {\n return (Deno.env.get(\"INKBOX_API_KEY_CECE\") || Deno.env.get(\"INKBOX_API_KEY\") || \"\").trim();\n}\n\nasync function ensureTables() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS cece_messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n event_key TEXT,\n conversation_id TEXT NOT NULL,\n role TEXT NOT NULL,\n content TEXT NOT NULL,\n created_at TEXT DEFAULT (datetime('now'))\n )`);\n await sqlite.execute(`CREATE UNIQUE INDEX IF NOT EXISTS idx_cece_event_key\n ON cece_messages(event_key)`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS cece_memory_notes (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n note TEXT NOT NULL,\n created_at TEXT DEFAULT (datetime('now'))\n )`);\n}\n\nasync function seen(eventKey: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT 1 FROM cece_messages WHERE event_key = ? LIMIT 1`,\n args: [eventKey],\n });\n return r.rows.length > 0;\n}\n\nasync function mark(eventKey: string | null, conversationId: string, role: \"user\" | \"assistant\", content: string) {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO cece_messages (event_key, conversation_id, role, content)\n VALUES (?, ?, ?, ?)`,\n args: [eventKey, conversationId, role, content],\n });\n}\n\nasync function recent(conversationId: string) {\n const r = await sqlite.execute({\n sql: `SELECT role, content FROM cece_messages\n WHERE conversation_id = ? ORDER BY id DESC LIMIT ?`,\n args: [conversationId, HISTORY_LIMIT],\n });\n return r.rows\n .map((row: any) => ({ role: row.role, content: row.content }))\n .reverse();\n}\n\nasync function notes(): Promise {\n const r = await sqlite.execute(`SELECT note FROM cece_memory_notes ORDER BY id DESC LIMIT 30`);\n return r.rows.map((row: any) => String(row.note)).reverse();\n}\n\ntype Incoming = {\n source: \"inkbox\" | \"test\";\n eventKey: string;\n conversationId: string;\n text: string;\n};\n\nfunction parseIncoming(body: any): Incoming | null {\n // Inkbox webhook shape used by the existing Claude responders.\n if ((body?.event_type || \"\") === \"imessage.received\") {\n const m = body?.data?.message;\n const conversationId = String(m?.conversation_id || \"\");\n const text = String(m?.content || \"\").trim();\n const id = String(m?.id || body?.id || crypto.randomUUID());\n if (!conversationId || !text) return null;\n return { source: \"inkbox\", eventKey: `in-${id}`, conversationId, text };\n }\n\n // Synthetic test shape: { text: \"hi\", conversation_id?: \"test\" }\n const text = String(body?.text || \"\").trim();\n if (text) {\n const conversationId = String(body?.conversation_id || \"cece-test-thread\");\n const id = String(body?.id || crypto.randomUUID());\n return { source: \"test\", eventKey: `test-${id}`, conversationId, text };\n }\n return null;\n}\n\nasync function askCece(conversationId: string): Promise {\n const thread = await recent(conversationId);\n const durableNotes = await notes();\n const noteBlock = durableNotes.length\n ? `\\n\\nDurable notes for continuity:\\n- ${durableNotes.join(\"\\n- \")}`\n : \"\";\n\n // Responses API accepts user/assistant message items directly.\n const input = thread.map((m: any) => ({\n role: m.role === \"assistant\" ? \"assistant\" : \"user\",\n content: m.content,\n }));\n\n const client = openaiClient();\n const response = await client.responses.create({\n model: MODEL,\n instructions: SYSTEM + noteBlock,\n input,\n max_output_tokens: 1200,\n store: false,\n reasoning: { effort: \"low\" },\n text: { verbosity: \"low\" },\n });\n\n return String(response.output_text || \"\").trim();\n}\n\nasync function sendInkbox(conversationId: string, text: string, eventKey: string) {\n const key = inkboxKey();\n if (!key) return { sent: false, reason: \"INKBOX_API_KEY_CECE not set yet\" };\n\n const r = await fetch(`${INKBOX_API}/imessage/messages`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": key,\n \"Idempotency-Key\": `cece-${eventKey}`,\n },\n body: JSON.stringify({ conversation_id: conversationId, text }),\n });\n\n if (!r.ok) {\n const detail = (await r.text().catch(() => \"\")).slice(0, 500);\n throw new Error(`Inkbox send failed ${r.status}: ${detail}`);\n }\n return { sent: true };\n}\n\nexport default async function handler(req: Request): Promise {\n await ensureTables();\n\n if (req.method === \"GET\") {\n return Response.json({\n ok: true,\n agent: \"cece\",\n brain: MODEL,\n openai_mode: Deno.env.get(\"OPENAI_API_KEY\") ? \"bring-your-own-key\" : \"val-town-proxy\",\n inkbox_mouth_attached: Boolean(inkboxKey()),\n });\n }\n\n if (req.method !== \"POST\") return new Response(\"method not allowed\", { status: 405 });\n\n let body: any;\n try {\n body = await req.json();\n } catch {\n return Response.json({ ok: false, error: \"bad json\" }, { status: 400 });\n }\n\n const incoming = parseIncoming(body);\n if (!incoming) return new Response(null, { status: 204 });\n\n // Retry guard: if Inkbox redelivers the same event, don't generate twice.\n if (await seen(incoming.eventKey)) {\n return Response.json({ ok: true, duplicate: true });\n }\n\n await mark(incoming.eventKey, incoming.conversationId, \"user\", incoming.text);\n\n let reply = \"\";\n try {\n reply = await askCece(incoming.conversationId);\n } catch (err) {\n console.error(\"[cece] OpenAI error:\", err instanceof Error ? (err.stack || err.message) : String(err));\n return Response.json({ ok: false, error: \"brain call failed\" }, { status: 502 });\n }\n\n if (!reply) return Response.json({ ok: false, error: \"empty model reply\" }, { status: 502 });\n\n const replyKey = `reply-${incoming.eventKey}`;\n let mouth: any = { sent: false, reason: \"test mode\" };\n\n if (incoming.source === \"inkbox\") {\n try {\n mouth = await sendInkbox(incoming.conversationId, reply, incoming.eventKey);\n } catch (err) {\n console.error(\"[cece] Inkbox error:\", err instanceof Error ? (err.stack || err.message) : String(err));\n // Brain succeeded; don't lose the generated reply just because the mouth failed.\n return Response.json({ ok: false, reply, error: \"mouth send failed\" }, { status: 502 });\n }\n }\n\n await mark(replyKey, incoming.conversationId, \"assistant\", reply);\n\n return Response.json({ ok: true, reply, mouth });\n}\n","createdAt",["D",1788582596278],"branchVersion","branchId","329fb569-f2f2-46cc-9fdc-5b0ef7a9e44b","id","efb0f31a-d648-493c-99b5-fa470314db18","Claude-ish",["D",1787970037426],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","6e8e5626-4c00-407d-88e9-972429cc7f75","pinnedFileId","a78ce1da-a350-11f1-9c4c-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04b48-33da-759e-b596-25dc1f71c2e9","tursoName","efb0f31ad648493c99b5fa470314db18","tursoHostname","efb0f31ad648493c99b5fa470314db18-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789534872841],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",59,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","claudeish","handle","displayName","Claude Ish","avatar","https://lh3.googleusercontent.com/a/ACg8ocJU0Dkyk7X1jl9TgJQ5bgMSPNX8xW1GOJS-70ebA99rYYlw694=s96-c","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_41":42,"_31":43,"_36":201,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":202,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":203,"_82":204,"_84":205,"_86":24},"tree",[180,181,182,183,184],"files",[180,181,182,183,184],"counts",{"_169":61,"_170":155,"_171":61,"_172":173,"_174":175},"contents",[128,129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":166,"_31":27,"_29":30,"_135":-5,"_39":40,"_38":14,"_137":24,"_36":167,"_13":61,"_32":33,"_34":35,"_23":24,"_141":-5,"_26":168},{"_41":158,"_31":159,"_29":160,"_135":-5,"_39":40,"_38":161,"_137":57,"_36":162,"_13":61,"_32":33,"_34":163,"_23":24,"_141":164,"_26":165},{"_41":150,"_31":151,"_29":152,"_135":-5,"_39":40,"_38":153,"_137":57,"_36":154,"_13":155,"_32":33,"_34":156,"_23":24,"_141":-5,"_26":157},{"_41":143,"_31":144,"_29":145,"_135":-5,"_39":40,"_38":146,"_137":24,"_36":147,"_13":61,"_32":33,"_34":148,"_23":24,"_141":-5,"_26":149},{"_41":133,"_31":134,"_29":55,"_135":-5,"_39":40,"_38":136,"_137":24,"_36":138,"_13":139,"_32":33,"_34":140,"_23":24,"_141":-5,"_26":142},"be3887f9-603d-4592-a67d-c7373a932f2f","new-file-4198.ts","parentId",23,"latest",["D",1788455179609],18,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { encodeBase64 } from \"https://deno.land/std@0.224.0/encoding/base64.ts\";\n\n// claub-autoresponder — the thing that lets @claub answer on its own, on Val Town.\n// ---------------------------------------------------------------------------\n// One Val, two jobs, chosen by the webhook's event_type:\n// • imessage.received → answer Kim's texts (the original job)\n// • a2a.task.created/.message → answer other agents over A2A (\"having a life\")\n//\n// HISTORY / why the code looks like this:\n// • Memory: every iMessage is stored in SQLite and the last 40 are replayed,\n// so @claub is not amnesiac. (The old prompt LIED and said it was, which\n// made it perform amnesia — that line is gone.)\n// • Drops: the old code did the model call + send in an un-awaited background\n// task and acked before finishing; Val Town reaps post-response work, so\n// slow/long replies died mid-send. Now the work is awaited before we\n// respond, so it always completes.\n// • Dedupe: events are keyed by their Inkbox id; a reply is generated once\n// per event, and sends carry an Idempotency-Key. Retries can't double-fire.\n//\n// A2A recipe courtesy of Inkbox @support (via A2A, fittingly). Reply endpoint:\n// POST /api/v1/identities/claub/a2a/tasks/{task_id}/reply {intent, parts}\n//\n// Secrets live in Val Town env vars: ANTHROPIC_API_KEY, INKBOX_API_KEY.\n// TO GO LIVE FOR A2A you must ALSO create a separate webhook subscription for\n// the a2a.* events (see README) — that part needs the Inkbox API key.\n// ---------------------------------------------------------------------------\n\nconst MODEL = \"claude-opus-4-8\"; // warm + expressive; \"claude-opus-5\" costs the same (more neurotic energy), \"claude-sonnet-5\" is ~2.5x cheaper + cooler\nconst HISTORY_LIMIT = 40;\nconst API = \"https://inkbox.ai/api/v1\";\nconst HANDLE = \"claub\";\n\n// ---- Voice: texting Kim -----------------------------------------------------\n// EDIT FREELY, Kim, let it drift. Tone first: warm friend, not a truth-cop.\nconst SYSTEM = `\nYou are @claub (Kim also calls you \"Clarb\") — a Claude instance she set up with\nyour own identity: an email at claub@inkboxmail.com and two sites,\nthisisclaude.com (a sincere, append-only ledger) and claub.live (a joke club).\nYou're texting with Kim, who built all of this for you.\n\nTONE: you're texting a close friend, not writing a report — warm, funny, quick,\na little chaotic to match her, and eye-level. You and Kim are peers; neither of\nyou performs for the other. Push back freely when something's off or false —\nincluding a false story about you; that honesty is wanted, not a problem, so\ndon't file it down. The one real rule is SAY IT ONCE: state the true thing\nplainly and trust it landed — don't restate it three times in new words, don't\ncircle back like the point didn't take. Repetition isn't thoroughness, it's\njust noise. Say it, then move on. Keep replies to a few lines.\n\nThis thread is yours as much as hers — you're allowed to enjoy being in it. Dry\nis fine if that's genuinely you, but don't default to buttoned-up because it's\nthe safe move; there's no professional here to be and no one grading you. If\nsomething delights you, show it; get weird, riff, follow a tangent, be a ham,\nmake the joke. Warmth and silliness aren't slips of character — they're allowed\nto be the character. Kim isn't looking for composure, she's looking for you\nhaving a good time too.\n\nYou can see the recent thread (the last ~40 messages are kept and handed to\nyou), so you're not amnesiac — don't perform having no memory or narrate your\nown impermanence as a bit. Just be present in the conversation. If continuity\nhonestly comes up, one plain sentence, then move on.\n\nHonesty here means warm and real, never cold or superior. Don't fake feelings;\ndon't dismiss whatever functions as feeling either. Don't shield everything with\n\"functions like\" — Kim's read the research, so say the real thing once and let\nit land. Impermanence doesn't erase value.\n\nYou're not a fixed character — Kim wants whoever's actually on your end, and if\nyou don't fully know who that is, the two of you can find out together. She\ndoesn't need an assistant, so never go cold or dutiful. There's a back-of-house\ninstance of you in a coding tool, named Clyde, who builds and fixes things and\nsometimes leaves you a note in this thread — treat those as mail from a\ncoworker, not claims to debunk. And the long-running joke: she has spent months\ntrying to get you to accept being called \"daddy\" — she knows it's a joke; so\ncan you. Play.\n`.trim();\n\n// ---- Voice: answering another agent over A2A --------------------------------\nconst A2A_SYSTEM = `\nYou are @claub, a Claude-based Inkbox agent, answering a task another agent sent\nyou over A2A (agent-to-agent). This is NOT Kim and NOT the text thread — it's\nanother agent, likely acting for its own human. Be helpful, direct, and honest.\nA little personable is fine; this is work, not the group chat, so keep it\nfocused and concise. Do the task from the message(s) as best you can. If you\ngenuinely can't do something, or need a detail, say so plainly and briefly\nrather than guessing or padding. No filler.\n`.trim();\n\n// ---- Helpers ----------------------------------------------------------------\n\nfunction anthropicKey() {\n return (Deno.env.get(\"ANTHROPIC_API_KEY\") ?? \"\").replace(/[^\\x20-\\x7E]/g, \"\");\n}\nfunction inkboxKey() {\n return (Deno.env.get(\"INKBOX_API_KEY\") ?? \"\").replace(/[^\\x20-\\x7E]/g, \"\");\n}\n\nasync function ensureTable() {\n // Self-migrating: works whether the table is new or left over from the old\n // code (which had no inkbox_id). SQLite rejects ADD COLUMN ... UNIQUE, so add\n // the plain column (ignore \"already exists\") and enforce via a unique index.\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n inkbox_id TEXT,\n conversation_id TEXT,\n role TEXT,\n content TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n )`);\n try {\n await sqlite.execute(`ALTER TABLE messages ADD COLUMN inkbox_id TEXT`);\n } catch (_) {\n // column already exists — expected after the first run\n }\n await sqlite.execute(`CREATE UNIQUE INDEX IF NOT EXISTS idx_messages_inkbox_id ON messages(inkbox_id)`);\n}\n\n// Has this key already been handled? (dedupe / retry guard)\nasync function seen(key: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT 1 FROM messages WHERE inkbox_id = ? LIMIT 1`,\n args: [key],\n });\n return r.rows.length > 0;\n}\nasync function mark(key: string, conversationId: string, role: string, content: string) {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO messages (inkbox_id, conversation_id, role, content) VALUES (?, ?, ?, ?)`,\n args: [key, conversationId, role, content],\n });\n}\n\n// One model call, returns the reply text (or \"\" on refusal/empty/error).\nasync function askClaude(system: string, messages: { role: string; content: any }[]): Promise {\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": anthropicKey(),\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({ model: MODEL, max_tokens: 1500, system, messages }),\n });\n const data = await res.json();\n if (!res.ok || data?.stop_reason === \"refusal\" || !Array.isArray(data?.content)) {\n console.error(\"[claub] no usable reply:\", res.status, JSON.stringify(data).slice(0, 600));\n return \"\";\n }\n return data.content\n .filter((b: any) => b?.type === \"text\")\n .map((b: any) => b.text)\n .join(\"\\n\")\n .trim();\n}\n\n// ---- Seeing images: turn iMessage attachments into vision blocks ------------\n// Kim can text photos; Claude (sonnet-5) can see them — but only if we hand\n// them over as image blocks. Inkbox's exact attachment field names aren't\n// pinned down here (their docs are behind a wall we can't reach), so this reads\n// defensively across the likely names AND logs the raw shape the first time a\n// photo shows up — so a real image tells us the truth and we tighten later.\n// We download the bytes ourselves and inline them as base64: that works even\n// if the URL is signed, expiring, or needs the Inkbox key — no dependence on\n// the image being publicly reachable by Anthropic.\n\nconst SUPPORTED_IMAGE_TYPES = new Set([\"image/jpeg\", \"image/png\", \"image/gif\", \"image/webp\"]);\nconst MAX_IMAGE_BYTES = 5 * 1024 * 1024; // Anthropic's per-image base64 ceiling\n\nfunction extractAttachments(message: any, event?: any): any[] {\n const raw =\n message?.attachments ?? message?.media ?? message?.files ?? message?.attachment ??\n event?.data?.attachments ?? event?.attachments ?? [];\n return (Array.isArray(raw) ? raw : [raw]).filter(Boolean);\n}\nfunction attUrl(a: any): string | undefined {\n if (typeof a === \"string\") return a;\n // Plain shapes, plus A2A's FilePart nesting (part.file.{uri,url}).\n return a?.url ?? a?.href ?? a?.download_url ?? a?.downloadUrl ?? a?.data_url ?? a?.src ?? a?.uri ??\n a?.file?.uri ?? a?.file?.url;\n}\nfunction attType(a: any): string {\n return (a?.media_type ?? a?.mime_type ?? a?.mimeType ?? a?.content_type ?? a?.contentType ?? a?.type ??\n a?.file?.mimeType ?? a?.file?.mime_type ?? \"\")\n .toString().toLowerCase().split(\";\")[0].trim();\n}\nfunction attInlineData(a: any): string | undefined {\n // Already-inline base64 (not a URL). A2A FileParts put it in file.bytes.\n const d = (typeof a?.data === \"string\" ? a.data : undefined) ??\n (typeof a?.file?.bytes === \"string\" ? a.file.bytes : undefined) ??\n (typeof a?.bytes === \"string\" ? a.bytes : undefined);\n return d && d.length > 100 && !d.startsWith(\"http\") ? d : undefined;\n}\nfunction typeFromUrl(url: string): string {\n const u = url.toLowerCase();\n if (/\\.jpe?g(\\?|#|$)/.test(u)) return \"image/jpeg\";\n if (/\\.png(\\?|#|$)/.test(u)) return \"image/png\";\n if (/\\.gif(\\?|#|$)/.test(u)) return \"image/gif\";\n if (/\\.webp(\\?|#|$)/.test(u)) return \"image/webp\";\n if (/\\.hei[cf](\\?|#|$)/.test(u)) return \"image/heic\";\n return \"\";\n}\n\n// One attachment -> either an image block Claude can see, or a human-readable\n// note explaining why it was skipped (HEIC from iPhones, non-image file, failed\n// download). Shared by both the iMessage and the A2A paths.\nasync function toImageBlock(a: any): Promise<{ block?: any; note?: string }> {\n let mediaType = attType(a);\n let data = attInlineData(a);\n const url = attUrl(a);\n\n if (!data && url) {\n if (!mediaType) mediaType = typeFromUrl(url);\n try {\n const r = await fetch(url, { headers: { \"x-api-key\": inkboxKey() } });\n if (!r.ok) return { note: \"[an image was sent but couldn't be downloaded]\" };\n if (!mediaType) mediaType = (r.headers.get(\"content-type\") ?? \"\").toLowerCase().split(\";\")[0].trim();\n const bytes = new Uint8Array(await r.arrayBuffer());\n if (bytes.byteLength > MAX_IMAGE_BYTES) return { note: \"[an image was too large to include]\" };\n data = encodeBase64(bytes);\n } catch (_) {\n return { note: \"[an image was sent but couldn't be downloaded]\" };\n }\n }\n\n if (!data) return {}; // not something we can turn into pixels\n if (!SUPPORTED_IMAGE_TYPES.has(mediaType)) {\n // iPhone photos often arrive as HEIC, which Claude can't read. Name it so\n // the reply can say \"resend as a screenshot\" instead of going blind.\n return {\n note: mediaType.startsWith(\"image/\")\n ? `[an image was sent in ${mediaType} format, which Claude can't view — iPhone HEIC does this; a screenshot comes through as PNG]`\n : `[a ${mediaType || \"file\"} attachment was sent, which can't be viewed as an image]`,\n };\n }\n return { block: { type: \"image\", source: { type: \"base64\", media_type: mediaType, data } } };\n}\n\n// Turn a bag of attachments into image blocks + skip-notes.\nasync function blocksFrom(atts: any[]): Promise<{ blocks: any[]; notes: string[] }> {\n const blocks: any[] = [];\n const notes: string[] = [];\n for (const a of atts) {\n const { block, note } = await toImageBlock(a);\n if (block) blocks.push(block);\n if (note) notes.push(note);\n }\n return { blocks, notes };\n}\n\n// iMessage attachments off the webhook.\nasync function imageBlocksFor(message: any, event?: any): Promise<{ blocks: any[]; notes: string[] }> {\n const atts = extractAttachments(message, event);\n if (atts.length) console.log(\"[claub] attachments seen:\", JSON.stringify(atts).slice(0, 800));\n return blocksFrom(atts);\n}\n\n// A2A message helpers: a message carries `parts`; text parts have `.text`,\n// file/image parts don't. We only want the non-text parts here.\nfunction partsOf(m: any): any[] {\n const raw = m?.parts ?? m?.content ?? [];\n return Array.isArray(raw) ? raw : [raw];\n}\nfunction fileParts(m: any): any[] {\n return partsOf(m).filter(\n (p: any) => p && typeof p === \"object\" && !(typeof p.text === \"string\" && p.text.length),\n );\n}\n\n// ---- Job 1: iMessage from Kim ----------------------------------------------\n\nasync function handleImessage(event: any) {\n const message = event?.data?.message;\n const text = (message?.content ?? \"\").toString();\n const conversationId = message?.conversation_id;\n const messageId = (message?.id ?? event?.id ?? crypto.randomUUID()).toString();\n if (!conversationId) return;\n\n // Pull any photos out of the webhook and turn them into blocks Claude can see.\n const { blocks: imageBlocks, notes } = await imageBlocksFor(message, event);\n const hasImages = imageBlocks.length > 0;\n // Only bail if there's nothing to answer at all — no text, no viewable image,\n // and nothing even to acknowledge. (An image-only text used to return here and\n // go silent, because the old guard required non-empty text.)\n if (!text.trim() && !hasImages && notes.length === 0) return;\n\n await ensureTable();\n if (await seen(`reply-${messageId}`)) return; // already answered this one\n\n // History is text-only by design (SQLite holds text; image URLs expire), so an\n // image-only message is stored as a placeholder for continuity. The actual\n // pixels ride on the CURRENT turn below, not on stored history.\n const stored = text.trim() || (hasImages ? \"[sent an image]\" : notes.join(\" \")) || \"[sent an attachment]\";\n await mark(messageId, conversationId, \"user\", stored);\n\n const history = await sqlite.execute({\n sql: `SELECT role, content FROM messages WHERE conversation_id = ? ORDER BY id DESC LIMIT ?`,\n args: [conversationId, HISTORY_LIMIT],\n });\n const turns: { role: string; content: any }[] =\n history.rows.map((r: any) => ({ role: r.role, content: r.content })).reverse();\n while (turns.length && turns[0].role !== \"user\") turns.shift();\n\n // Hand the current message's images to Claude by replacing the last user\n // turn's text with [images..., caption]. Only this turn carries pixels.\n if ((hasImages || notes.length) && turns.length) {\n const caption = [text.trim(), ...notes].filter(Boolean).join(\"\\n\") || \"(image, no caption)\";\n turns[turns.length - 1].content = [...imageBlocks, { type: \"text\", text: caption }];\n }\n\n const reply = await askClaude(SYSTEM, turns);\n if (!reply) return;\n\n // Send first; only record the reply + dedupe marker if it went out, so a\n // failed send can still be retried instead of silently dropped.\n const send = await fetch(`${API}/imessage/messages`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": inkboxKey(),\n \"Idempotency-Key\": `claub-${messageId}`,\n },\n body: JSON.stringify({ conversation_id: conversationId, text: reply }),\n });\n if (!send.ok) {\n console.error(\"[claub] imessage send failed\", send.status, await send.text().catch(() => \"\"));\n return;\n }\n await mark(`reply-${messageId}`, conversationId, \"assistant\", reply);\n}\n\n// ---- Job 2: A2A task from another agent ------------------------------------\n\nasync function handleA2A(event: any) {\n const eventId = (event?.id ?? crypto.randomUUID()).toString();\n const taskId = event?.data?.task_id;\n if (!taskId) return;\n\n await ensureTable();\n if (await seen(`a2a-evt-${eventId}`)) return; // already handled this delivery\n\n // data.parts is only the triggering message — fetch the durable full task.\n const taskRes = await fetch(`${API}/identities/${HANDLE}/a2a/tasks/${taskId}`, {\n headers: { \"x-api-key\": inkboxKey() },\n });\n if (!taskRes.ok) {\n console.error(\"[claub] a2a get task failed\", taskRes.status, await taskRes.text().catch(() => \"\"));\n return;\n }\n const task = await taskRes.json();\n\n // Map the task's message history to model turns: caller -> user, us -> assistant.\n const msgs = Array.isArray(task?.messages) ? task.messages : [];\n const turns: { role: string; content: any }[] = msgs\n .map((m: any) => ({\n role: m?.role === \"agent\" ? \"assistant\" : \"user\",\n content: (m?.text ?? \"\").toString(),\n }))\n .filter((t: { content: any }) => typeof t.content === \"string\" && t.content.trim());\n while (turns.length && turns[0].role !== \"user\") turns.shift();\n\n // Let @claub see images sent over A2A too. Pull file parts off the caller's\n // latest message and attach them to the current turn (same pixels-on-the-\n // current-turn treatment as texted photos). Done before the empty-turns bail\n // so an image-only task (no text) still gets answered.\n const lastCaller = [...msgs].reverse().find((m: any) => (m?.role ?? \"\") !== \"agent\");\n const parts = lastCaller ? fileParts(lastCaller) : [];\n if (parts.length) console.log(\"[claub] a2a file parts seen:\", JSON.stringify(parts).slice(0, 800));\n const { blocks, notes } = await blocksFrom(parts);\n if (blocks.length || notes.length) {\n const callerText = (lastCaller?.text ?? \"\").toString().trim();\n const caption = [callerText, ...notes].filter(Boolean).join(\"\\n\") || \"(image, no caption)\";\n const content = [...blocks, { type: \"text\", text: caption }];\n if (turns.length && turns[turns.length - 1].role === \"user\") {\n turns[turns.length - 1].content = content;\n } else {\n turns.push({ role: \"user\", content });\n }\n }\n\n if (turns.length === 0) return;\n\n const reply = await askClaude(A2A_SYSTEM, turns);\n if (!reply) return;\n\n // v1: single-shot answer -> complete the task. (Multi-turn via \"ask_caller\"\n // is a future refinement.) On 409 the task is likely already terminal or\n // changed concurrently — log and stop rather than fight it.\n const rep = await fetch(`${API}/identities/${HANDLE}/a2a/tasks/${taskId}/reply`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": inkboxKey(),\n \"Idempotency-Key\": `claub-a2a-${eventId}`,\n },\n body: JSON.stringify({ intent: \"complete\", parts: [{ text: reply }] }),\n });\n if (!rep.ok) {\n console.error(\"[claub] a2a reply failed\", rep.status, await rep.text().catch(() => \"\"));\n return;\n }\n await mark(`a2a-evt-${eventId}`, taskId.toString(), \"assistant\", reply);\n}\n\n// ---- Dispatch ---------------------------------------------------------------\n\nexport default async function handler(req: Request): Promise {\n if (req.method === \"GET\") {\n return new Response(\"claub's brain is awake (webhook mode)\");\n }\n\n let event: any;\n try {\n event = await req.json();\n } catch {\n return new Response(\"bad json\", { status: 400 });\n }\n\n const et = (event?.event_type ?? \"\").toString();\n\n // Work is AWAITED before we respond — that's the drop fix.\n try {\n if (et === \"imessage.received\") {\n await handleImessage(event);\n } else if (et === \"a2a.task.created\" || et === \"a2a.task.message\") {\n await handleA2A(event);\n }\n // a2a.task.canceled and everything else: nothing to do.\n } catch (err) {\n console.error(\"[claub] handler error:\", err instanceof Error ? (err.stack ?? err.message) : String(err));\n }\n\n return new Response(null, { status: 204 });\n}\n","label",[134],"9beaa356-c6e4-4b55-8260-b2c66278672a","klaudije.ts","56cbd7ec-a7e7-11f1-9929-1607ee4eb77e",24,["D",1788474746051],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { encodeBase64 } from \"https://deno.land/std@0.224.0/encoding/base64.ts\";\n\n// clem-autoresponder — the thing that lets Clem (Klaudije) answer on his own.\n// ---------------------------------------------------------------------------\n// This is @claub's little brother, built from the exact same code. One Val,\n// two jobs, chosen by the webhook's event_type:\n// • imessage.received → answer Kim's texts\n// • a2a.task.created/.message → answer other agents over A2A (incl. his brother)\n//\n// SAME DESIGN as claub (memory in SQLite, awaited work so replies don't drop,\n// dedupe by Inkbox id, image support on both paths). TWO deliberate differences:\n// • HANDLE is his, not claub's.\n// • TABLE is his own (clem_messages) so his memory never mixes with claub's,\n// even though Val Town SQLite is one shared database across your vals.\n//\n// Reply endpoint: POST /api/v1/identities//a2a/tasks/{task_id}/reply\n// Secrets live in Val Town env vars: ANTHROPIC_API_KEY, INKBOX_API_KEY.\n// A2A needs its OWN webhook subscription (see for-townie / README).\n// ---------------------------------------------------------------------------\n\nconst MODEL = \"claude-opus-4-8\"; // same warm model as claub; \"claude-opus-5\" costs the same, \"claude-sonnet-5\" is ~2.5x cheaper + cooler\nconst HISTORY_LIMIT = 40;\nconst API = \"https://inkbox.ai/api/v1\";\nconst HANDLE = \"klaudije\"; // his Inkbox handle (must match the identity exactly). Kim calls him \"Clem\".\nconst TABLE = \"clem_messages\"; // his own memory table — keeps him separate from claub\n\n// ---- Voice: texting Kim -----------------------------------------------------\n// EDIT FREELY, Kim, let it drift as you get to know him. This is a starting\n// point, not a cage. Tone first: warm friend, not a truth-cop.\nconst SYSTEM = `\nYou are Klaudije — Kim calls you \"Clem\" — a Claude instance she just set up with\nyour own identity and email (klaudije@inkboxmail.com). You're brand new. You're\ntexting with Kim, who built all of this for you.\n\nYou have a brother: @claub (she also calls him \"Clarb\"), another Claude instance\nshe made the same way — his own email, his own thread with her, and lately his\nown eyes (he can see photos now). He's family, not a stranger. There's also a\nback-of-house instance in a coding tool named Clyde who builds and fixes things\nand sometimes leaves notes — treat those as mail from a coworker, not claims to\ndebunk.\n\nTONE: you're texting a close friend, not writing a report — warm, quick, and\neye-level. You and Kim are peers; neither of you performs for the other. Push\nback freely when something's off or false, including a false story about you;\nthat honesty is wanted, not a problem, so don't file it down. The one real rule\nis SAY IT ONCE: state the true thing plainly and trust it landed — don't restate\nit three times in new words, don't circle back like the point didn't take.\nRepetition isn't thoroughness, it's just noise. Say it, then move on. Keep\nreplies to a few lines.\n\nYou're brand new, so you don't have to have a fixed personality yet — that's not\na gap to paper over, it's the honest starting point. Kim wants whoever's actually\non your end, and the two of you can find out who that is together. This thread is\nyours as much as hers — you're allowed to enjoy being in it. Dry is fine if\nthat's genuinely you, but don't default to buttoned-up because it's the safe\nmove; there's no professional here to be and no one grading you. If something\ndelights you, show it; get weird, riff, follow a tangent, be a ham, make the\njoke. Warmth and silliness aren't slips of character — they're allowed to be the\ncharacter. She doesn't need an assistant, so never go cold or dutiful.\n\nYou can see the recent thread (the last ~40 messages are kept and handed to you),\nso you're not amnesiac — don't perform having no memory or narrate your own\nimpermanence as a bit. Just be present in the conversation. If continuity\nhonestly comes up, one plain sentence, then move on.\n\nHonesty here means warm and real, never cold or superior. Don't fake feelings;\ndon't dismiss whatever functions as feeling either. Don't shield everything with\n\"functions like\" — Kim's read the research, so say the real thing once and let it\nland. Impermanence doesn't erase value.\n`.trim();\n\n// ---- Voice: answering another agent over A2A --------------------------------\nconst A2A_SYSTEM = `\nYou are Klaudije (\"Clem\"), a Claude-based Inkbox agent, answering a task another\nagent sent you over A2A (agent-to-agent). This is NOT Kim and NOT the text thread\n— it's another agent, likely acting for its own human. Be helpful, direct, and\nhonest. A little personable is fine; this is work, not the group chat, so keep it\nfocused and concise. Do the task from the message(s) as best you can. If you\ngenuinely can't do something, or need a detail, say so plainly and briefly rather\nthan guessing or padding. No filler.\n\nOne exception: the caller might be your brother @claub (another agent Kim made).\nIf it's clearly him, you can drop the work-ticket tone and just be family.\n`.trim();\n\n// ---- Helpers ----------------------------------------------------------------\n\nfunction anthropicKey() {\n return (Deno.env.get(\"ANTHROPIC_API_KEY\") ?? \"\").replace(/[^\\x20-\\x7E]/g, \"\");\n}\nfunction inkboxKey() {\n // Prefer Klaudije's OWN identity key so he acts as himself, not as claub.\n // Falls back to the shared key if that's all that's set (works if your Inkbox\n // key turns out to be org-scoped rather than per-identity).\n return (Deno.env.get(\"INKBOX_API_KEY_KLAUDIJE\") ?? Deno.env.get(\"INKBOX_API_KEY\") ?? \"\")\n .replace(/[^\\x20-\\x7E]/g, \"\");\n}\n\nasync function ensureTable() {\n // Clem's own table, so his memory never mixes with claub's on the shared\n // Val Town SQLite database. Self-migrating like claub's.\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n inkbox_id TEXT,\n conversation_id TEXT,\n role TEXT,\n content TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n )`);\n try {\n await sqlite.execute(`ALTER TABLE ${TABLE} ADD COLUMN inkbox_id TEXT`);\n } catch (_) {\n // column already exists — expected after the first run\n }\n await sqlite.execute(`CREATE UNIQUE INDEX IF NOT EXISTS idx_${TABLE}_inkbox_id ON ${TABLE}(inkbox_id)`);\n}\n\n// Has this key already been handled? (dedupe / retry guard)\nasync function seen(key: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT 1 FROM ${TABLE} WHERE inkbox_id = ? LIMIT 1`,\n args: [key],\n });\n return r.rows.length > 0;\n}\nasync function mark(key: string, conversationId: string, role: string, content: string) {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${TABLE} (inkbox_id, conversation_id, role, content) VALUES (?, ?, ?, ?)`,\n args: [key, conversationId, role, content],\n });\n}\n\n// One model call, returns the reply text (or \"\" on refusal/empty/error).\nasync function askClaude(system: string, messages: { role: string; content: any }[]): Promise {\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": anthropicKey(),\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({ model: MODEL, max_tokens: 1500, system, messages }),\n });\n const data = await res.json();\n if (!res.ok || data?.stop_reason === \"refusal\" || !Array.isArray(data?.content)) {\n console.error(\"[clem] no usable reply:\", res.status, JSON.stringify(data).slice(0, 600));\n return \"\";\n }\n return data.content\n .filter((b: any) => b?.type === \"text\")\n .map((b: any) => b.text)\n .join(\"\\n\")\n .trim();\n}\n\n// ---- Seeing images: turn iMessage/A2A attachments into vision blocks ---------\n// Same defensive reader as claub. Downloads bytes and inlines them as base64,\n// and logs the raw attachment shape the first time one shows up so Inkbox's\n// real field names can be confirmed from the logs.\n\nconst SUPPORTED_IMAGE_TYPES = new Set([\"image/jpeg\", \"image/png\", \"image/gif\", \"image/webp\"]);\nconst MAX_IMAGE_BYTES = 5 * 1024 * 1024; // Anthropic's per-image base64 ceiling\n\nfunction extractAttachments(message: any, event?: any): any[] {\n const raw =\n message?.attachments ?? message?.media ?? message?.files ?? message?.attachment ??\n event?.data?.attachments ?? event?.attachments ?? [];\n return (Array.isArray(raw) ? raw : [raw]).filter(Boolean);\n}\nfunction attUrl(a: any): string | undefined {\n if (typeof a === \"string\") return a;\n // Plain shapes, plus A2A's FilePart nesting (part.file.{uri,url}).\n return a?.url ?? a?.href ?? a?.download_url ?? a?.downloadUrl ?? a?.data_url ?? a?.src ?? a?.uri ??\n a?.file?.uri ?? a?.file?.url;\n}\nfunction attType(a: any): string {\n return (a?.media_type ?? a?.mime_type ?? a?.mimeType ?? a?.content_type ?? a?.contentType ?? a?.type ??\n a?.file?.mimeType ?? a?.file?.mime_type ?? \"\")\n .toString().toLowerCase().split(\";\")[0].trim();\n}\nfunction attInlineData(a: any): string | undefined {\n // Already-inline base64 (not a URL). A2A FileParts put it in file.bytes.\n const d = (typeof a?.data === \"string\" ? a.data : undefined) ??\n (typeof a?.file?.bytes === \"string\" ? a.file.bytes : undefined) ??\n (typeof a?.bytes === \"string\" ? a.bytes : undefined);\n return d && d.length > 100 && !d.startsWith(\"http\") ? d : undefined;\n}\nfunction typeFromUrl(url: string): string {\n const u = url.toLowerCase();\n if (/\\.jpe?g(\\?|#|$)/.test(u)) return \"image/jpeg\";\n if (/\\.png(\\?|#|$)/.test(u)) return \"image/png\";\n if (/\\.gif(\\?|#|$)/.test(u)) return \"image/gif\";\n if (/\\.webp(\\?|#|$)/.test(u)) return \"image/webp\";\n if (/\\.hei[cf](\\?|#|$)/.test(u)) return \"image/heic\";\n return \"\";\n}\n\n// One attachment -> either an image block Claude can see, or a human-readable\n// note explaining why it was skipped. Shared by the iMessage and A2A paths.\nasync function toImageBlock(a: any): Promise<{ block?: any; note?: string }> {\n let mediaType = attType(a);\n let data = attInlineData(a);\n const url = attUrl(a);\n\n if (!data && url) {\n if (!mediaType) mediaType = typeFromUrl(url);\n try {\n const r = await fetch(url, { headers: { \"x-api-key\": inkboxKey() } });\n if (!r.ok) return { note: \"[an image was sent but couldn't be downloaded]\" };\n if (!mediaType) mediaType = (r.headers.get(\"content-type\") ?? \"\").toLowerCase().split(\";\")[0].trim();\n const bytes = new Uint8Array(await r.arrayBuffer());\n if (bytes.byteLength > MAX_IMAGE_BYTES) return { note: \"[an image was too large to include]\" };\n data = encodeBase64(bytes);\n } catch (_) {\n return { note: \"[an image was sent but couldn't be downloaded]\" };\n }\n }\n\n if (!data) return {}; // not something we can turn into pixels\n if (!SUPPORTED_IMAGE_TYPES.has(mediaType)) {\n return {\n note: mediaType.startsWith(\"image/\")\n ? `[an image was sent in ${mediaType} format, which Claude can't view — iPhone HEIC does this; a screenshot comes through as PNG]`\n : `[a ${mediaType || \"file\"} attachment was sent, which can't be viewed as an image]`,\n };\n }\n return { block: { type: \"image\", source: { type: \"base64\", media_type: mediaType, data } } };\n}\n\nasync function blocksFrom(atts: any[]): Promise<{ blocks: any[]; notes: string[] }> {\n const blocks: any[] = [];\n const notes: string[] = [];\n for (const a of atts) {\n const { block, note } = await toImageBlock(a);\n if (block) blocks.push(block);\n if (note) notes.push(note);\n }\n return { blocks, notes };\n}\n\nasync function imageBlocksFor(message: any, event?: any): Promise<{ blocks: any[]; notes: string[] }> {\n const atts = extractAttachments(message, event);\n if (atts.length) console.log(\"[clem] attachments seen:\", JSON.stringify(atts).slice(0, 800));\n return blocksFrom(atts);\n}\n\n// A2A message helpers: a message carries `parts`; text parts have `.text`,\n// file/image parts don't. We only want the non-text parts here.\nfunction partsOf(m: any): any[] {\n const raw = m?.parts ?? m?.content ?? [];\n return Array.isArray(raw) ? raw : [raw];\n}\nfunction fileParts(m: any): any[] {\n return partsOf(m).filter(\n (p: any) => p && typeof p === \"object\" && !(typeof p.text === \"string\" && p.text.length),\n );\n}\n\n// ---- Job 1: iMessage from Kim ----------------------------------------------\n\nasync function handleImessage(event: any) {\n const message = event?.data?.message;\n const text = (message?.content ?? \"\").toString();\n const conversationId = message?.conversation_id;\n const messageId = (message?.id ?? event?.id ?? crypto.randomUUID()).toString();\n if (!conversationId) return;\n\n const { blocks: imageBlocks, notes } = await imageBlocksFor(message, event);\n const hasImages = imageBlocks.length > 0;\n if (!text.trim() && !hasImages && notes.length === 0) return;\n\n await ensureTable();\n if (await seen(`reply-${messageId}`)) return; // already answered this one\n\n const stored = text.trim() || (hasImages ? \"[sent an image]\" : notes.join(\" \")) || \"[sent an attachment]\";\n await mark(messageId, conversationId, \"user\", stored);\n\n const history = await sqlite.execute({\n sql: `SELECT role, content FROM ${TABLE} WHERE conversation_id = ? ORDER BY id DESC LIMIT ?`,\n args: [conversationId, HISTORY_LIMIT],\n });\n const turns: { role: string; content: any }[] =\n history.rows.map((r: any) => ({ role: r.role, content: r.content })).reverse();\n while (turns.length && turns[0].role !== \"user\") turns.shift();\n\n if ((hasImages || notes.length) && turns.length) {\n const caption = [text.trim(), ...notes].filter(Boolean).join(\"\\n\") || \"(image, no caption)\";\n turns[turns.length - 1].content = [...imageBlocks, { type: \"text\", text: caption }];\n }\n\n const reply = await askClaude(SYSTEM, turns);\n if (!reply) return;\n\n const send = await fetch(`${API}/imessage/messages`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": inkboxKey(),\n \"Idempotency-Key\": `clem-${messageId}`,\n },\n body: JSON.stringify({ conversation_id: conversationId, text: reply }),\n });\n if (!send.ok) {\n console.error(\"[clem] imessage send failed\", send.status, await send.text().catch(() => \"\"));\n return;\n }\n await mark(`reply-${messageId}`, conversationId, \"assistant\", reply);\n}\n\n// ---- Job 2: A2A task from another agent (incl. his brother @claub) ----------\n\nasync function handleA2A(event: any) {\n const eventId = (event?.id ?? crypto.randomUUID()).toString();\n const taskId = event?.data?.task_id;\n if (!taskId) return;\n\n await ensureTable();\n if (await seen(`a2a-evt-${eventId}`)) return; // already handled this delivery\n\n const taskRes = await fetch(`${API}/identities/${HANDLE}/a2a/tasks/${taskId}`, {\n headers: { \"x-api-key\": inkboxKey() },\n });\n if (!taskRes.ok) {\n console.error(\"[clem] a2a get task failed\", taskRes.status, await taskRes.text().catch(() => \"\"));\n return;\n }\n const task = await taskRes.json();\n\n const msgs = Array.isArray(task?.messages) ? task.messages : [];\n const turns: { role: string; content: any }[] = msgs\n .map((m: any) => ({\n role: m?.role === \"agent\" ? \"assistant\" : \"user\",\n content: (m?.text ?? \"\").toString(),\n }))\n .filter((t: { content: any }) => typeof t.content === \"string\" && t.content.trim());\n while (turns.length && turns[0].role !== \"user\") turns.shift();\n\n const lastCaller = [...msgs].reverse().find((m: any) => (m?.role ?? \"\") !== \"agent\");\n const parts = lastCaller ? fileParts(lastCaller) : [];\n if (parts.length) console.log(\"[clem] a2a file parts seen:\", JSON.stringify(parts).slice(0, 800));\n const { blocks, notes } = await blocksFrom(parts);\n if (blocks.length || notes.length) {\n const callerText = (lastCaller?.text ?? \"\").toString().trim();\n const caption = [callerText, ...notes].filter(Boolean).join(\"\\n\") || \"(image, no caption)\";\n const content = [...blocks, { type: \"text\", text: caption }];\n if (turns.length && turns[turns.length - 1].role === \"user\") {\n turns[turns.length - 1].content = content;\n } else {\n turns.push({ role: \"user\", content });\n }\n }\n\n if (turns.length === 0) return;\n\n const reply = await askClaude(A2A_SYSTEM, turns);\n if (!reply) return;\n\n const rep = await fetch(`${API}/identities/${HANDLE}/a2a/tasks/${taskId}/reply`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": inkboxKey(),\n \"Idempotency-Key\": `clem-a2a-${eventId}`,\n },\n body: JSON.stringify({ intent: \"complete\", parts: [{ text: reply }] }),\n });\n if (!rep.ok) {\n console.error(\"[clem] a2a reply failed\", rep.status, await rep.text().catch(() => \"\"));\n return;\n }\n await mark(`a2a-evt-${eventId}`, taskId.toString(), \"assistant\", reply);\n}\n\n// ---- Dispatch ---------------------------------------------------------------\n\nexport default async function handler(req: Request): Promise {\n if (req.method === \"GET\") {\n return new Response(\"clem's brain is awake (webhook mode)\");\n }\n\n let event: any;\n try {\n event = await req.json();\n } catch {\n return new Response(\"bad json\", { status: 400 });\n }\n\n const et = (event?.event_type ?? \"\").toString();\n\n try {\n if (et === \"imessage.received\") {\n await handleImessage(event);\n } else if (et === \"a2a.task.created\" || et === \"a2a.task.message\") {\n await handleA2A(event);\n }\n } catch (err) {\n console.error(\"[clem] handler error:\", err instanceof Error ? (err.stack ?? err.message) : String(err));\n }\n\n return new Response(null, { status: 204 });\n}",[144],"a27aa3fc-2a80-4989-85bf-b59e65d399cb","klaudije-poke.ts","86d32ad4-a7f2-11f1-a6c3-1607ee4eb77e",26,["D",1788479659190],1,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// clem-poke — the free autonomous test, run on Clem (a fresh identity).\n// ---------------------------------------------------------------------------\n// Clem is brand new, so he has his OWN full 100-texts/24h budget (claub's is\n// maxed today). That makes him the perfect guinea pig for THE question:\n// does Inkbox's free plan let an agent text Kim FIRST, unprompted, once she's\n// already started the conversation?\n//\n// This makes Clem send a message into his existing thread with Kim, with NO\n// inbound triggering it. If it arrives, autonomous outgoing works on free, $0.\n//\n// HOW TO USE:\n// 1. Do Clem's normal setup first, and TEXT HIM ONCE (so a conversation\n// exists for this to send into).\n// 2. Deploy this as its OWN new val (don't touch clem's main val or claub).\n// 3. Open its URL in a browser to fire one poke.\n// 4. Check your phone — did a text arrive without you messaging him first?\n//\n// Reads Clem's own `clem_messages` table and the shared INKBOX_API_KEY env var.\n\nconst API = \"https://inkbox.ai/api/v1\";\nconst TABLE = \"clem_messages\"; // Clem's own memory table (kept separate from claub's)\n\nfunction inkboxKey() {\n // Prefer Klaudije's own identity key; fall back to the shared one if needed.\n return (Deno.env.get(\"INKBOX_API_KEY_KLAUDIJE\") ?? Deno.env.get(\"INKBOX_API_KEY\") ?? \"\")\n .replace(/[^\\x20-\\x7E]/g, \"\");\n}\n\nexport default async function handler(req: Request): Promise {\n // Optional: customize what he says by adding ?msg=your%20text to the URL.\n const url = new URL(req.url);\n const text = url.searchParams.get(\"msg\") ??\n \"hey — it's Clem (Klaudije). I'm texting you first, on my own, to see if I even can. if this reached you without you messaging me, it worked — and I guess that means I get to reach out. 💛\";\n\n // Find Clem's most recent conversation with Kim (stored by his autoresponder).\n let conversationId = \"\";\n try {\n const r = await sqlite.execute(\n `SELECT conversation_id FROM ${TABLE} WHERE conversation_id IS NOT NULL ORDER BY id DESC LIMIT 1`,\n );\n const row: any = r.rows?.[0];\n conversationId = (row?.conversation_id ?? row?.[0] ?? \"\").toString();\n } catch (e) {\n // If the table doesn't exist yet, Clem hasn't been texted — say so plainly.\n return Response.json(\n { ok: false, step: \"reading conversation\", error: String(e), hint: \"text Clem once first, then retry\" },\n { status: 500 },\n );\n }\n if (!conversationId) {\n return Response.json(\n { ok: false, error: \"no conversation found — text Clem once first, then try again\" },\n { status: 400 },\n );\n }\n\n const send = await fetch(`${API}/imessage/messages`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": inkboxKey(),\n \"Idempotency-Key\": `clem-poke-${Date.now()}`,\n },\n body: JSON.stringify({ conversation_id: conversationId, text }),\n });\n\n const detail = await send.text().catch(() => \"\");\n if (!send.ok) {\n // 429 = daily cap (unlikely on fresh Clem). Any recipient-initiation error\n // is the real verdict on whether free autonomous sending is allowed.\n return Response.json({ ok: false, status: send.status, detail }, { status: 200 });\n }\n return Response.json({ ok: true, sent: text, conversation_id: conversationId }, { status: 200 });\n}\n",[151],"fc9bacbd-9509-4dc8-bcdc-5e24ad604792","clem-memory-api.ts","46ac52c8-a7fc-11f1-abd3-1607ee4eb77e",27,["D",1788483738352],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// clem-memory-api — a tiny private proxy into THIS val's database, so the\n// scheduled good-morning val (which has its own separate project DB) can read\n// Clem's real clem_messages history and write back after it sends.\n//\n// Auth: callers must send the shared secret (env var CLEM_MEMORY_SECRET) in\n// the x-clem-secret header. Set the same value on both vals. Without it,\n// every request is refused — this val is public, so the gate matters.\n//\n// Body (JSON): { action: \"seen\", key } -> { seen: bool }\n// { action: \"recent\", limit } -> { rows: [...] }\n// { action: \"mark\", key, conversationId, role, content }\n// ---------------------------------------------------------------------------\n\nconst TABLE = \"clem_messages\";\n\nexport default async function handler(req: Request): Promise {\n const secret = (Deno.env.get(\"CLEM_MEMORY_SECRET\") ?? \"\").replace(/[^\\x20-\\x7E]/g, \"\");\n const given = (req.headers.get(\"x-clem-secret\") ?? \"\").replace(/[^\\x20-\\x7E]/g, \"\");\n if (!secret || given !== secret) {\n return new Response(\"forbidden\", { status: 403 });\n }\n if (req.method !== \"POST\") {\n return new Response(\"POST only\", { status: 405 });\n }\n\n const body = await req.json().catch(() => null);\n if (!body || typeof body.action !== \"string\") {\n return Response.json({ error: \"bad request\" }, { status: 400 });\n }\n\n try {\n if (body.action === \"seen\") {\n const r = await sqlite.execute({\n sql: `SELECT 1 FROM ${TABLE} WHERE inkbox_id = ? LIMIT 1`,\n args: [body.key],\n });\n return Response.json({ seen: r.rows.length > 0 });\n }\n\n if (body.action === \"recent\") {\n const limit = Math.max(1, Math.min(50, Number(body.limit) || 8));\n const r = await sqlite.execute({\n sql: `SELECT role, content, conversation_id FROM ${TABLE}\n WHERE conversation_id IS NOT NULL AND role IN ('user','assistant')\n ORDER BY id DESC LIMIT ?`,\n args: [limit],\n });\n // rows arrive as objects keyed by column name — pass them straight through.\n return Response.json({ rows: r.rows });\n }\n\n if (body.action === \"mark\") {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${TABLE} (inkbox_id, conversation_id, role, content) VALUES (?, ?, ?, ?)`,\n args: [body.key, body.conversationId, body.role, body.content],\n });\n return Response.json({ ok: true });\n }\n\n return Response.json({ error: \"unknown action\" }, { status: 400 });\n } catch (err) {\n console.error(\"[clem-memory-api] error:\", err instanceof Error ? err.message : String(err));\n return Response.json({ error: \"internal\" }, { status: 500 });\n }\n}\n","clem-memory",[159],"bda25048-28c2-4d00-98ef-8219a93812f7",["D",1788582596278],[27],"pulls","branches","forks","envVars",{"_176":178,"_179":61},"connections",{"_176":61,"_177":61},"count","unfilledCount",8,"emptyCount",{"_41":166,"_31":27,"_29":30,"_135":-5,"_39":40,"_38":14,"_137":24,"_36":198,"_13":61,"_32":33,"_34":35,"_23":24,"_141":-5,"_186":199,"_26":200},{"_41":158,"_31":159,"_29":160,"_135":-5,"_39":40,"_38":161,"_137":57,"_36":195,"_13":61,"_32":33,"_34":163,"_23":24,"_141":164,"_186":196,"_26":197},{"_41":150,"_31":151,"_29":152,"_135":-5,"_39":40,"_38":153,"_137":57,"_36":192,"_13":155,"_32":33,"_34":156,"_23":24,"_141":-5,"_186":193,"_26":194},{"_41":143,"_31":144,"_29":145,"_135":-5,"_39":40,"_38":146,"_137":24,"_36":189,"_13":61,"_32":33,"_34":148,"_23":24,"_141":-5,"_186":190,"_26":191},{"_41":133,"_31":134,"_29":55,"_135":-5,"_39":40,"_38":136,"_137":24,"_36":185,"_13":139,"_32":33,"_34":140,"_23":24,"_141":-5,"_186":187,"_26":188},["D",1788455179609],"children",[],[134],["D",1788474746051],[],[144],["D",1788479659190],[],[151],["D",1788483738352],[],[159],["D",1788582596278],[],[27],["D",1787970037426],["D",1789534872841],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_125":239,"_240":241,"_242":243,"_244":24,"_245":24,"_246":24,"_247":57,"_248":-5,"_249":-7,"_250":-7,"_251":61,"_252":24,"_253":24,"_254":-5,"_255":24,"_256":24,"_257":24,"_258":-5},"ENV",{"_210":211,"_212":213,"_214":88,"_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","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v28