[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_322":323,"_324":325},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_235":-5,"_20":236,"_22":237,"_238":239,"_240":241,"_26":242,"_24":243,"_244":245,"_246":247,"_248":50,"_249":250,"_251":75,"_252":-5,"_253":-5,"_254":255},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":-5,"_31":32,"_33":32,"_34":-5},"handle","dcm31","name","artifact-slackbot2","branchName","main","version","path","lib","project",{"_35":188,"_13":14,"_37":189,"_48":-5,"_190":50,"_51":52,"_191":52,"_192":193,"_194":-5,"_195":196,"_197":148,"_198":75,"_199":-5,"_200":-5,"_201":32,"_54":55,"_202":203,"_204":205,"_206":207,"_208":-5,"_209":210,"_211":210,"_212":213,"_214":213,"_215":213,"_216":210,"_217":210,"_218":219,"_220":221,"_222":223,"_49":50},"tree",[118,119,120,121,122,123],"file",{"_35":114,"_13":19,"_66":69,"_68":-5,"_70":71,"_72":73,"_74":75,"_37":115,"_17":32,"_77":116,"_79":-5,"_81":50,"_82":-5,"_18":117},"contents",[58,59,60,61,62,63],"upstream",{"_35":36,"_37":38,"_39":40,"_13":16,"_41":42,"_17":43,"_44":-5,"_45":-5,"_46":47,"_48":-5,"_49":50,"_51":52,"_53":12,"_54":55,"_56":57},"pull","ahead",0,"behind","envVars","id","4a3acb36-4f05-11f1-8dfd-ee650bb23af1","createdAt",["D",1778701956399],"updatedAt",["D",1778713960501],"projectId","4a3a2d0c-4f05-11f1-8dfd-ee650bb23af1",47,"forkedBranchId","forkedBranchVersion","lockfileKey","1778713985039-esm.town_v_dcm31_artifact-slackbot@47-main","deletedAt","isOwned",false,"privacy","public","userHandle","orgId","d663a026-6449-42f6-9156-1d4a2d64d38c","projectName","artifact-slackbot",{"_35":108,"_13":109,"_66":110,"_68":69,"_70":71,"_72":73,"_74":75,"_37":111,"_17":32,"_77":78,"_79":112,"_81":50,"_82":-5,"_18":113},{"_35":102,"_13":103,"_66":104,"_68":69,"_70":71,"_72":73,"_74":75,"_37":105,"_17":32,"_77":78,"_79":106,"_81":50,"_82":-5,"_18":107},{"_35":96,"_13":97,"_66":98,"_68":69,"_70":71,"_72":73,"_74":75,"_37":99,"_17":32,"_77":78,"_79":100,"_81":50,"_82":-5,"_18":101},{"_35":90,"_13":91,"_66":92,"_68":69,"_70":71,"_72":73,"_74":75,"_37":93,"_17":32,"_77":78,"_79":94,"_81":50,"_82":-5,"_18":95},{"_35":84,"_13":85,"_66":86,"_68":69,"_70":71,"_72":73,"_74":75,"_37":87,"_17":32,"_77":78,"_79":88,"_81":50,"_82":-5,"_18":89},{"_35":64,"_13":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_37":76,"_17":32,"_77":78,"_79":80,"_81":50,"_82":-5,"_18":83},"2d85921a-4fc7-11f1-ba2e-ee650bb23af1","thread-sessions.ts","fileId","019e27dc-9ef4-75a9-bdf4-fe6cd179a1b1","parentId","019e27dc-9ef4-75a9-bdf5-0385c767da94","branchId","2d7ff29c-4fc7-11f1-ba2e-ee650bb23af1","branchVersion",1,"latest",true,["D",1778785230504],"fileType","script","content","// 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","deleted","label",[19,65],"2d857f3c-4fc7-11f1-ba2e-ee650bb23af1","stream.ts","019e27dc-9ef4-75a9-bdf4-f85f449e20a4",["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",[19,85],"2d8567ea-4fc7-11f1-ba2e-ee650bb23af1","slack-utils.ts","019e27dc-9ef4-75a9-bdf4-f564643319ea",["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",[19,91],"2d85523c-4fc7-11f1-ba2e-ee650bb23af1","session.ts","019e27dc-9ef4-75a9-bdf4-f03bb6550142",["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",[19,97],"2d853b80-4fc7-11f1-ba2e-ee650bb23af1","outputs.ts","019e27dc-9ef4-75a9-bdf4-ef533af74609",["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",[19,103],"2d85067e-4fc7-11f1-ba2e-ee650bb23af1","flow.ts","019e27dc-9ef4-75a9-bdf4-eb7f9a7b2e54",["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",[19,109],"2d859d78-4fc7-11f1-ba2e-ee650bb23af1",["D",1778785230504],"directory",[19],{"_35":114,"_13":19,"_66":69,"_68":-5,"_70":71,"_72":73,"_74":75,"_37":161,"_17":32,"_77":116,"_79":-5,"_81":50,"_82":-5,"_129":162,"_18":163},{"_35":154,"_13":155,"_66":156,"_68":-5,"_70":71,"_72":73,"_74":75,"_37":157,"_17":32,"_77":24,"_79":158,"_81":50,"_82":-5,"_129":159,"_18":160},{"_35":146,"_13":147,"_66":148,"_68":-5,"_70":71,"_72":73,"_74":75,"_37":149,"_17":32,"_77":150,"_79":151,"_81":50,"_82":-5,"_129":152,"_18":153},{"_35":139,"_13":140,"_66":141,"_68":-5,"_70":71,"_72":73,"_74":75,"_37":142,"_17":32,"_77":24,"_79":143,"_81":50,"_82":-5,"_129":144,"_18":145},{"_35":132,"_13":133,"_66":134,"_68":-5,"_70":71,"_72":73,"_74":75,"_37":135,"_17":32,"_77":24,"_79":136,"_81":50,"_82":-5,"_129":137,"_18":138},{"_35":124,"_13":125,"_66":126,"_68":-5,"_70":71,"_72":73,"_74":75,"_37":127,"_17":32,"_77":78,"_79":128,"_81":50,"_82":-5,"_129":130,"_18":131},"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