[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_319":320,"_321":322},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_39":-7,"_169":-5,"_19":170,"_171":172,"_173":174,"_175":176,"_177":178,"_21":179,"_180":181,"_182":183,"_184":30,"_185":186,"_187":24,"_188":-5,"_189":-5,"_190":191},"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":30,"_31":-5},"handle","dcm31","name","artifact-slackbot2","branchName","main","path","lib","project",{"_33":117,"_13":14,"_37":118,"_75":-5,"_119":30,"_120":121,"_122":121,"_123":124,"_125":-5,"_31":82,"_126":127,"_128":24,"_129":-5,"_130":-5,"_131":26,"_41":42,"_132":133,"_134":135,"_136":137,"_138":-5,"_139":140,"_141":140,"_142":143,"_144":143,"_145":143,"_146":140,"_147":140,"_52":148,"_149":150,"_151":152,"_153":30},"file",{"_76":114,"_13":18,"_79":115,"_81":30,"_116":-5},"isDirectory",true,"page",0,"history",[32],"hasNext",false,"userId",{"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53,"_21":54,"_55":-5,"_56":57,"_58":-5,"_59":60,"_61":62},"id","2d8d499c-4fc7-11f1-ba2e-ee650bb23af1","branchId","2d7ff29c-4fc7-11f1-ba2e-ee650bb23af1","createdAt",["D",1778785230504],"version",1,"orgId","d663a026-6449-42f6-9156-1d4a2d64d38c","parentId","incomingCommitId","3d403698-4f21-11f1-9083-ee650bb23af1","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_33":82,"_41":42,"_11":12,"_83":84},{"_76":112,"_13":113,"_79":80,"_81":30},"pull","merge",{"_35":73,"_13":16,"_39":74,"_75":-5},"revert","multiple",{"_109":110,"_111":26},"commits",[63,64,65,66,67,68],{"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53,"_21":54,"_55":-5,"_56":57,"_58":-5},{"_33":34,"_35":36,"_37":103,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":104,"_21":105,"_55":-5,"_56":106,"_58":-5},{"_33":34,"_35":36,"_37":97,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":98,"_21":99,"_55":-5,"_56":100,"_58":-5},{"_33":34,"_35":36,"_37":91,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":92,"_21":93,"_55":-5,"_56":94,"_58":-5},{"_33":34,"_35":36,"_37":85,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":86,"_21":87,"_55":-5,"_56":88,"_58":-5},{"_33":34,"_35":36,"_37":69,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":70,"_21":71,"_55":-5,"_56":72,"_58":-5},["D",1778785230504],{"_33":82,"_41":42,"_11":12,"_83":84},{"_76":77,"_13":78,"_79":80,"_81":30},{"_35":73,"_13":16,"_39":74,"_75":-5},"4a3acb36-4f05-11f1-8dfd-ee650bb23af1",47,"deletedAt","fileId","019e27dc-9ef4-75a9-bdf4-fe6cd179a1b1","thread-sessions.ts","fileType","script","deleted","9319c175-2593-4f88-ba21-04f2ef7b1c28","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/3e904faa-3764-4629-c475-f561a49b0000/square512?exp=1789660380&sig=3bc6ba381bf1a4dbbd90efa2e3becfd872181381f46a7d2166031c84db9fe35e",["D",1778785230504],{"_33":82,"_41":42,"_11":12,"_83":84},{"_76":89,"_13":90,"_79":80,"_81":30},{"_35":73,"_13":16,"_39":74,"_75":-5},"019e27dc-9ef4-75a9-bdf4-f85f449e20a4","stream.ts",["D",1778785230504],{"_33":82,"_41":42,"_11":12,"_83":84},{"_76":95,"_13":96,"_79":80,"_81":30},{"_35":73,"_13":16,"_39":74,"_75":-5},"019e27dc-9ef4-75a9-bdf4-f564643319ea","slack-utils.ts",["D",1778785230504],{"_33":82,"_41":42,"_11":12,"_83":84},{"_76":101,"_13":102,"_79":80,"_81":30},{"_35":73,"_13":16,"_39":74,"_75":-5},"019e27dc-9ef4-75a9-bdf4-f03bb6550142","session.ts",["D",1778785230504],{"_33":82,"_41":42,"_11":12,"_83":84},{"_76":107,"_13":108,"_79":80,"_81":30},{"_35":73,"_13":16,"_39":74,"_75":-5},"019e27dc-9ef4-75a9-bdf4-ef533af74609","outputs.ts","count",6,"deletedCount","019e27dc-9ef4-75a9-bdf4-eb7f9a7b2e54","flow.ts","019e27dc-9ef4-75a9-bdf5-0385c767da94","directory","deletedAtVersion","2d78ee2a-4fc7-11f1-ba2e-ee650bb23af1",["D",1778785230504],"legacyEnvVars","privacy","public","httpPrivacy","description","An AI slackbot that can ingest data and generate html artifacts","imageUrl","pinnedFileId","019e27dc-9ef4-75a9-bdf5-0baa68c98e91","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","2d78ee2a4fc711f1ba2eee650bb23af1","tursoHostname","2d78ee2a4fc711f1ba2eee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789590677681],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_168":84},"org",{"_11":12,"_163":164,"_83":84,"_31":82,"_165":166,"_167":30},"branch",{"_39":40,"_13":16,"_33":36,"_154":117,"_155":73,"_156":74,"_157":121,"_158":159,"_160":42,"_161":14,"_162":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","4a3a2d0c-4f05-11f1-8dfd-ee650bb23af1","forkedProjectOrgId","projectName","userHandle","displayName","Charlie","tier","pro","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":117,"_13":14,"_37":314,"_75":-5,"_119":30,"_120":121,"_122":121,"_123":124,"_125":-5,"_31":82,"_126":127,"_128":24,"_129":-5,"_130":-5,"_131":26,"_41":42,"_132":133,"_134":135,"_136":315,"_138":-5,"_139":140,"_141":140,"_142":143,"_144":143,"_145":143,"_146":140,"_147":140,"_52":316,"_149":317,"_151":318,"_153":30},"tree",[245,252,253,254,255,256],"files",[245,246,247,248,249,250,251,252,253,254,255,256],"counts",{"_236":26,"_237":40,"_238":26,"_239":240,"_241":242},"contents",[206,207,208,209,210,211],{"_33":199,"_13":18,"_76":114,"_43":-5,"_35":36,"_200":40,"_201":24,"_37":202,"_39":26,"_79":115,"_203":-5,"_81":30,"_204":-5,"_17":205},"upstreamProject",{"_33":159,"_13":197,"_123":124,"_125":-5,"_120":121,"_52":198},"upstreamBranch",{"_33":73,"_37":192,"_193":194,"_13":16,"_154":159,"_39":74,"_155":-5,"_156":-5,"_195":196,"_75":-5,"_153":30,"_120":121,"_162":12,"_41":42,"_161":197},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1778701956399],"updatedAt",["D",1778713960501],"lockfileKey","1778713985039-esm.town_v_dcm31_artifact-slackbot@47-main","artifact-slackbot",{"_11":12,"_168":84},"2d859d78-4fc7-11f1-ba2e-ee650bb23af1","branchVersion","latest",["D",1778785230504],"content","label",[18],{"_33":232,"_13":113,"_76":112,"_43":114,"_35":36,"_200":40,"_201":24,"_37":233,"_39":26,"_79":80,"_203":234,"_81":30,"_204":-5,"_17":235},{"_33":228,"_13":108,"_76":107,"_43":114,"_35":36,"_200":40,"_201":24,"_37":229,"_39":26,"_79":80,"_203":230,"_81":30,"_204":-5,"_17":231},{"_33":224,"_13":102,"_76":101,"_43":114,"_35":36,"_200":40,"_201":24,"_37":225,"_39":26,"_79":80,"_203":226,"_81":30,"_204":-5,"_17":227},{"_33":220,"_13":96,"_76":95,"_43":114,"_35":36,"_200":40,"_201":24,"_37":221,"_39":26,"_79":80,"_203":222,"_81":30,"_204":-5,"_17":223},{"_33":216,"_13":90,"_76":89,"_43":114,"_35":36,"_200":40,"_201":24,"_37":217,"_39":26,"_79":80,"_203":218,"_81":30,"_204":-5,"_17":219},{"_33":212,"_13":78,"_76":77,"_43":114,"_35":36,"_200":40,"_201":24,"_37":213,"_39":26,"_79":80,"_203":214,"_81":30,"_204":-5,"_17":215},"2d85921a-4fc7-11f1-ba2e-ee650bb23af1",["D",1778785230504],"// Maps Slack thread_ts → Anthropic Managed Agents session_id so that\n// follow-up @mentions / DMs in the same thread continue the same session.\n// Per-val SQLite (std/sqlite/main.ts) — isolated per remix, returns rows\n// as keyed objects instead of positional arrays.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TABLE = \"threads\";\n\nlet initialized = false;\nasync function ensureTable() {\n if (initialized) return;\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE} (\n thread_ts TEXT PRIMARY KEY,\n session_id TEXT NOT NULL,\n created_at INTEGER NOT NULL\n )\n `);\n initialized = true;\n}\n\nexport async function getSessionForThread(threadTs: string): Promise {\n await ensureTable();\n const r = await sqlite.execute({\n sql: `SELECT session_id FROM ${TABLE} WHERE thread_ts = ?`,\n args: [threadTs],\n });\n return (r.rows[0]?.session_id as string) ?? null;\n}\n\nexport async function rememberThread(threadTs: string, sessionId: string): Promise {\n await ensureTable();\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO ${TABLE} (thread_ts, session_id, created_at) VALUES (?, ?, ?)`,\n args: [threadTs, sessionId, Date.now()],\n });\n}\n",[18,78],"2d857f3c-4fc7-11f1-ba2e-ee650bb23af1",["D",1778785230504],"// Lossless-reconnect SSE consumer for Managed Agents sessions.\n// Long sessions can drop the stream; on a drop we reopen via\n// events.stream() and use events.list() to seed seen IDs so we\n// don't double-post to Slack.\n\nimport Anthropic from \"npm:@anthropic-ai/sdk@0.96.0\";\nimport { mrkdwnify, slack } from \"./slack-utils.ts\";\nimport { uploadOutputs } from \"./outputs.ts\";\n\nexport async function streamToSlack(\n client: Anthropic,\n sessionId: string,\n channel: string,\n thread_ts: string,\n origin: string,\n): Promise {\n const seen = new Set();\n let postedProgress = false;\n let summary = \"\";\n\n while (true) {\n try {\n const stream = await client.beta.sessions.events.stream(sessionId);\n const history = await client.beta.sessions.events.list(sessionId);\n for (const ev of (history as any).data ?? []) seen.add(ev.id);\n\n for await (const ev of stream) {\n if (seen.has(ev.id)) continue;\n seen.add(ev.id);\n\n if (ev.type === \"agent.tool_use\") {\n // Reset summary at each tool boundary — only keep final\n // post-tool agent.message text.\n summary = \"\";\n if (!postedProgress) {\n await slack.chat.postMessage({\n channel,\n thread_ts,\n text: \"Running analysis...\",\n });\n postedProgress = true;\n }\n } else if (ev.type === \"agent.message\") {\n for (const b of (ev as any).content ?? []) {\n if (b.type === \"text\") summary += b.text;\n }\n } else if (ev.type === \"session.status_terminated\") {\n await slack.chat.postMessage({\n channel,\n thread_ts,\n text: \"⚠️ Session terminated unexpectedly.\",\n });\n return;\n } else if (ev.type === \"session.status_idle\") {\n const sr = (ev as any).stop_reason;\n if (sr?.type === \"requires_action\") continue;\n\n // For chitchat the summary IS the reply; for analysis it's\n // the post-tool summary text.\n if (summary.trim()) {\n await slack.chat.postMessage({\n channel,\n thread_ts,\n text: mrkdwnify(summary),\n });\n }\n\n await uploadOutputs(client, sessionId, channel, thread_ts, origin);\n return;\n }\n }\n } catch (err) {\n if (isTransientStreamError(err)) {\n await new Promise((r) => setTimeout(r, 500));\n continue;\n }\n await slack.chat.postMessage({\n channel,\n thread_ts,\n text: `⚠️ ${err instanceof Error ? err.message : String(err)}`,\n });\n throw err;\n }\n }\n}\n\nfunction isTransientStreamError(err: unknown): boolean {\n const msg = (err instanceof Error ? err.message : String(err)).toLowerCase();\n return (\n msg.includes(\"error reading a body\") ||\n msg.includes(\"connection reset\") ||\n msg.includes(\"connection closed\") ||\n msg.includes(\"network\") ||\n msg.includes(\"econnreset\") ||\n msg.includes(\"socket hang up\") ||\n msg.includes(\"aborted\")\n );\n}\n",[18,90],"2d8567ea-4fc7-11f1-ba2e-ee650bb23af1",["D",1778785230504],"// Slack helpers: signing verification, web client, file download.\n// Modeled on templates/ai-slackbot/lib/slack-utils.ts with the bits the\n// data-bot specifically needs (downloading the user's CSV attachment).\n\nimport { WebClient } from \"npm:@slack/web-api@7.14.1\";\n\nconst signingSecret = Deno.env.get(\"SLACK_SIGNING_SECRET\")!;\n\nexport const slack = new WebClient(Deno.env.get(\"SLACK_BOT_TOKEN\"));\n\n/** See https://api.slack.com/authentication/verifying-requests-from-slack */\nexport async function isValidSlackRequest(\n { request, rawBody }: { request: Request; rawBody: string },\n): Promise {\n const timestamp = request.headers.get(\"X-Slack-Request-Timestamp\");\n const slackSignature = request.headers.get(\"X-Slack-Signature\");\n if (!timestamp || !slackSignature) return false;\n // Reject anything older than 5 minutes (replay protection)\n if (Math.abs(Date.now() / 1000 - parseInt(timestamp)) > 60 * 5) return false;\n\n const enc = new TextEncoder();\n const base = `v0:${timestamp}:${rawBody}`;\n const key = await crypto.subtle.importKey(\n \"raw\",\n enc.encode(signingSecret),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const sig = await crypto.subtle.sign(\"HMAC\", key, enc.encode(base));\n const hmacHex = Array.from(new Uint8Array(sig))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n const computed = enc.encode(`v0=${hmacHex}`);\n const expected = enc.encode(slackSignature);\n if (computed.length !== expected.length) return false;\n // Constant-time compare\n let r = 0;\n for (let i = 0; i < computed.length; i++) r |= computed[i] ^ expected[i];\n return r === 0;\n}\n\nexport async function verifyRequest(\n { requestType, request, rawBody }: {\n requestType: string;\n request: Request;\n rawBody: string;\n },\n) {\n if (\n requestType !== \"event_callback\" ||\n !(await isValidSlackRequest({ request, rawBody }))\n ) {\n throw new Error(\"Invalid request\");\n }\n}\n\nlet cachedBotUserId: string | null = null;\nexport async function getBotId(): Promise {\n if (cachedBotUserId) return cachedBotUserId;\n const { user_id } = await slack.auth.test();\n if (!user_id) throw new Error(\"botUserId is undefined\");\n cachedBotUserId = user_id as string;\n return cachedBotUserId;\n}\n\n/** Download a file from Slack using the bot token. Returns bytes + name. */\nexport async function downloadSlackFile(\n urlPrivate: string,\n filename: string,\n): Promise<{ bytes: Uint8Array; filename: string; contentType: string }> {\n const token = Deno.env.get(\"SLACK_BOT_TOKEN\");\n if (!token) throw new Error(\"SLACK_BOT_TOKEN not set\");\n const resp = await fetch(urlPrivate, {\n headers: { Authorization: `Bearer ${token}` },\n });\n if (!resp.ok) {\n throw new Error(`Slack file download failed: ${resp.status} ${resp.statusText}`);\n }\n const contentType = resp.headers.get(\"content-type\") ?? \"application/octet-stream\";\n const bytes = new Uint8Array(await resp.arrayBuffer());\n return { bytes, filename, contentType };\n}\n\n/**\n * Convert Markdown → Slack mrkdwn. Slack uses `*bold*` (not `**bold**`),\n * `` (not `[text](url)`), no headings, no tables.\n * The Python cookbook uses the `mrkdwn` package; this is a minimal port.\n */\nexport function mrkdwnify(md: string): string {\n return md\n .replace(/\\*\\*([^*]+)\\*\\*/g, \"*$1*\")\n .replace(/\\[([^\\]]+)\\]\\(([^)]+)\\)/g, \"<$2|$1>\")\n .replace(/^#{1,6}\\s+(.+)$/gm, \"*$1*\")\n .slice(0, 3900);\n}\n",[18,96],"2d85523c-4fc7-11f1-ba2e-ee650bb23af1",["D",1778785230504],"// Cached Anthropic agent + environment used by every session the bot\n// creates. Bump SIGNATURE to invalidate the cache when the agent\n// definition (system prompt, model, packages, skills, name) changes.\n\nimport Anthropic from \"npm:@anthropic-ai/sdk@0.96.0\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst CACHE_KEY = \"data-analyst-slackbot:resources\";\nconst SIGNATURE = \"v4\"; // bumped: renamed agent \"Data Analyst\" → \"Junior Analyst\"\nconst MODEL = \"claude-sonnet-4-6\";\n\nexport type Cached = { agentId: string; envId: string; signature: string };\n\nexport async function getResources(client: Anthropic): Promise {\n const cached = (await blob.getJSON(CACHE_KEY)) as Cached | null;\n if (cached?.signature === SIGNATURE) return cached;\n\n const system = await readFile(\"/prompt.md\");\n\n const env = await client.beta.environments.create({\n name: `data-analyst-slackbot-${Date.now()}`,\n config: {\n type: \"cloud\",\n networking: { type: \"unrestricted\" },\n // Pre-install the libraries the Anthropic skills will reach for, so\n // first-time use of each format doesn't pay a pip-install penalty.\n packages: {\n type: \"packages\",\n pip: [\n \"pandas\", // data analysis core\n \"plotly\", // charts in the report\n \"openpyxl\", // Excel (.xlsx) — used by the xlsx skill\n \"pdfplumber\", // PDF tables — used by the pdf skill\n \"pypdf\", // PDF text — used by the pdf skill\n \"python-docx\", // Word — used by the docx skill\n \"python-pptx\", // PowerPoint — used by the pptx skill\n ],\n },\n } as any,\n });\n const agent = await client.beta.agents.create({\n name: \"Junior Analyst\",\n model: MODEL,\n system,\n tools: [{\n type: \"agent_toolset_20260401\",\n default_config: { enabled: true, permission_policy: { type: \"always_allow\" } },\n configs: [\n { name: \"web_search\", enabled: false },\n { name: \"web_fetch\", enabled: false },\n ],\n } as any],\n // Anthropic-curated skills for non-CSV formats. The agent loads each\n // skill's full instructions on demand when it's working with that\n // file type. CSV/TSV/JSON are handled by pandas without a skill.\n skills: [\n { type: \"anthropic\", skill_id: \"xlsx\" },\n { type: \"anthropic\", skill_id: \"docx\" },\n { type: \"anthropic\", skill_id: \"pdf\" },\n { type: \"anthropic\", skill_id: \"pptx\" },\n ],\n } as any);\n const fresh: Cached = { agentId: agent.id, envId: env.id, signature: SIGNATURE };\n await blob.setJSON(CACHE_KEY, fresh);\n return fresh;\n}\n",[18,102],"2d853b80-4fc7-11f1-ba2e-ee650bb23af1",["D",1778785230504],"// Fetch files the agent wrote to /mnt/session/outputs/ and post them\n// back to Slack. Each file is also stashed in Val Town blob storage\n// under an unguessable UUID and linked as `${origin}/reports/${uuid}`\n// so recipients can open it in a browser, not just inside Slack.\n\nimport Anthropic from \"npm:@anthropic-ai/sdk@0.96.0\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { slack } from \"./slack-utils.ts\";\n\nexport async function uploadOutputs(\n client: Anthropic,\n sessionId: string,\n channel: string,\n thread_ts: string,\n origin: string,\n): Promise {\n // 1–3s indexing lag after session.status_idle; retry briefly.\n // Bounded at ~6s so chitchat turns (which never produce a file)\n // don't wait long.\n for (let attempt = 0; attempt < 4; attempt++) {\n if (attempt > 0) await new Promise((r) => setTimeout(r, 2000));\n try {\n const files = await client.beta.files.list({\n scope_id: sessionId,\n betas: [\"managed-agents-2026-04-01\"],\n } as any);\n const agentFiles = ((files as any).data ?? []).filter(\n (f: any) => f.downloadable !== false,\n );\n\n if (!agentFiles.length) {\n if (attempt === 3) return;\n continue;\n }\n\n for (const f of agentFiles) {\n const resp = await client.beta.files.download(f.id);\n const text = typeof resp === \"string\"\n ? resp\n : await (resp as Response).text();\n\n const uuid = crypto.randomUUID();\n await blob.set(\n `data-analyst-slackbot:report:${uuid}`,\n new TextEncoder().encode(text),\n );\n const reportUrl = `${origin}/reports/${uuid}`;\n\n await slack.files.uploadV2({\n channel_id: channel,\n thread_ts,\n filename: f.filename,\n content: text,\n initial_comment: `📊 *${f.filename}* — <${reportUrl}|open in browser>`,\n } as any);\n }\n return;\n } catch (err) {\n if (attempt === 3) {\n await slack.chat.postMessage({\n channel,\n thread_ts,\n text: `(Couldn't fetch generated files: ${\n err instanceof Error ? err.message : err\n })`,\n });\n }\n }\n }\n}\n",[18,108],"2d85067e-4fc7-11f1-ba2e-ee650bb23af1",["D",1778785230504],"// Orchestrator for inbound Slack messages.\n// thread already mapped to session → resume (mount new file if any)\n// no mapping + file attached → create session with mounted file\n// no mapping + no file → create chat-only session\n//\n// Cached agent + environment live in lib/session.ts.\n// Stream consumption + Slack posting live in lib/stream.ts.\n// Pulling generated reports out of the session lives in lib/outputs.ts.\n\nimport Anthropic from \"npm:@anthropic-ai/sdk@0.96.0\";\nimport { slack } from \"./slack-utils.ts\";\nimport { getSessionForThread, rememberThread } from \"./thread-sessions.ts\";\nimport { getResources } from \"./session.ts\";\nimport { streamToSlack } from \"./stream.ts\";\n\nexport interface MessageInput {\n channel: string;\n /** ts of the message itself (or thread_ts on follow-ups). Thread key. */\n thread_ts: string;\n /** User text — already had any <@bot> prefix stripped upstream. */\n question: string;\n /** Optional data file attached by the user. */\n file?: { bytes: Uint8Array; filename: string };\n /** Val origin (e.g. https://...web.val.run) — for hosted report URLs. */\n origin: string;\n}\n\nexport async function handleMessage(ev: MessageInput): Promise {\n const client = new Anthropic();\n const { channel, thread_ts, question } = ev;\n\n // Existing thread → resume the session.\n const existing = await getSessionForThread(thread_ts);\n if (existing) {\n let userMsg = question;\n // Mid-conversation file upload: mount it on the running session\n // and mention the path so the agent looks at it.\n if (ev.file) {\n const uploaded = await client.beta.files.upload({\n file: new File([ev.file.bytes], ev.file.filename, {\n type: \"application/octet-stream\",\n }),\n purpose: \"agent_resource\",\n } as any);\n await (client as any).beta.sessions.resources.add(existing, {\n type: \"file\",\n file_id: uploaded.id,\n mount_path: ev.file.filename,\n });\n userMsg =\n `I've attached another file at /mnt/session/uploads/${ev.file.filename}. ${question}`\n .trim();\n await slack.chat.postMessage({\n channel,\n thread_ts,\n text: `Got *${ev.file.filename}*. Analyzing.`,\n });\n }\n await client.beta.sessions.events.send(existing, {\n events: [{ type: \"user.message\", content: [{ type: \"text\", text: userMsg }] }],\n });\n await streamToSlack(client, existing, channel, thread_ts, ev.origin);\n return;\n }\n\n // New thread.\n const { agentId, envId } = await getResources(client);\n\n let resources: any[] = [];\n let userMsg = question;\n if (ev.file) {\n const file = await client.beta.files.upload({\n file: new File([ev.file.bytes], ev.file.filename, {\n type: \"application/octet-stream\",\n }),\n purpose: \"agent_resource\",\n } as any);\n resources = [{ type: \"file\", file_id: file.id, mount_path: ev.file.filename }];\n userMsg =\n `Analyze the data file at /mnt/session/uploads/${ev.file.filename}. ${question}`\n .trim();\n\n await slack.chat.postMessage({\n channel,\n thread_ts,\n text: `On it. Analyzing *${ev.file.filename}*.`,\n });\n }\n\n const session = await client.beta.sessions.create({\n agent: agentId,\n environment_id: envId,\n title: ev.file ? `Data bot: ${ev.file.filename}` : \"Slack chat\",\n resources,\n } as any);\n\n await rememberThread(thread_ts, session.id);\n\n await client.beta.sessions.events.send(session.id, {\n events: [{ type: \"user.message\", content: [{ type: \"text\", text: userMsg }] }],\n });\n\n await streamToSlack(client, session.id, channel, thread_ts, ev.origin);\n}\n",[18,113],"pulls","branches","forks","envVars",{"_109":26,"_244":26},"connections",{"_109":26,"_243":26},"unfilledCount","emptyCount",{"_33":199,"_13":18,"_76":114,"_43":-5,"_35":36,"_200":40,"_201":24,"_37":311,"_39":26,"_79":115,"_203":-5,"_81":30,"_204":-5,"_262":312,"_17":313},{"_33":232,"_13":113,"_76":112,"_43":114,"_35":36,"_200":40,"_201":24,"_37":308,"_39":26,"_79":80,"_203":234,"_81":30,"_204":-5,"_262":309,"_17":310},{"_33":228,"_13":108,"_76":107,"_43":114,"_35":36,"_200":40,"_201":24,"_37":305,"_39":26,"_79":80,"_203":230,"_81":30,"_204":-5,"_262":306,"_17":307},{"_33":224,"_13":102,"_76":101,"_43":114,"_35":36,"_200":40,"_201":24,"_37":302,"_39":26,"_79":80,"_203":226,"_81":30,"_204":-5,"_262":303,"_17":304},{"_33":220,"_13":96,"_76":95,"_43":114,"_35":36,"_200":40,"_201":24,"_37":299,"_39":26,"_79":80,"_203":222,"_81":30,"_204":-5,"_262":300,"_17":301},{"_33":216,"_13":90,"_76":89,"_43":114,"_35":36,"_200":40,"_201":24,"_37":296,"_39":26,"_79":80,"_203":218,"_81":30,"_204":-5,"_262":297,"_17":298},{"_33":212,"_13":78,"_76":77,"_43":114,"_35":36,"_200":40,"_201":24,"_37":293,"_39":26,"_79":80,"_203":214,"_81":30,"_204":-5,"_262":294,"_17":295},{"_33":286,"_13":287,"_76":288,"_43":-5,"_35":36,"_200":40,"_201":24,"_37":289,"_39":26,"_79":21,"_203":290,"_81":30,"_204":-5,"_262":291,"_17":292},{"_33":279,"_13":280,"_76":127,"_43":-5,"_35":36,"_200":40,"_201":24,"_37":281,"_39":26,"_79":282,"_203":283,"_81":30,"_204":-5,"_262":284,"_17":285},{"_33":272,"_13":273,"_76":274,"_43":-5,"_35":36,"_200":40,"_201":24,"_37":275,"_39":26,"_79":21,"_203":276,"_81":30,"_204":-5,"_262":277,"_17":278},{"_33":265,"_13":266,"_76":267,"_43":-5,"_35":36,"_200":40,"_201":24,"_37":268,"_39":26,"_79":21,"_203":269,"_81":30,"_204":-5,"_262":270,"_17":271},{"_33":257,"_13":258,"_76":259,"_43":-5,"_35":36,"_200":40,"_201":24,"_37":260,"_39":26,"_79":80,"_203":261,"_81":30,"_204":-5,"_262":263,"_17":264},"2d862aa4-4fc7-11f1-ba2e-ee650bb23af1","setup.tsx","019e27dc-9ef4-75a9-bdf5-17a1992a371e",["D",1778785230504],"/** @jsxImportSource npm:hono@4.12.0/jsx */\n// Setup page rendered as a Hono JSX component.\n// Twind CDN handles Tailwind class -> CSS at runtime — no inline

History · lib