\n \n \n \n \n `);\n});\n\n// Unwrap and rethrow Hono errors as the original error\n// If you delete this, all errors will be \"Internal Server Error\"\napp.onError((err, c) => {\n throw err;\n});\n\nexport default app.fetch;","children",[],[363],"50a491d8-5f0e-11f0-82bf-0224a6c84d84","deno.json","873f0227-df1a-4d21-9e96-c261f99a2d05",["D",1752317553464],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}",[],[371],"50a48d96-5f0e-11f0-82bf-0224a6c84d84","TODOs.md","e35e5486-4a87-4335-8f77-60b1eb5e1d05",["D",1752317553464],"- [ ] Give it a tool to make an HTTP request to its own endpoint to test things!\n- [x] Get React Router working on the client & move off localstorage for storing page state\n- [ ] When it hits the max number of steps, detect that and give the user a button (or instructions on how) to get it to continue (neverstew mentioned this)\n- [x] Make it look good\n- [ ] Persistent threads\n - [ ] Utils to help you revert to before or after messages or actions (related to commits)\n- [ ] give townie a search code tool for the code in the project, and like max’s codesearch tool too\n- [ ] improve the behavior when the signal is intermittent (neverstew mentioned this)\n- [ ] make it one click to branch off like old jp townie demos\n- [ ] opentownie as a pr bot\n- [ ] give it the ability to see its own client-side and server-side logs by building a middleware that shoves them into a SQL light database date and then give it a tool to access them\n- [ ] do a browser use or screenshot thing to give it access to its own visual output\n- [ ] Have it default to creating a new branch off main\n- [ ] A way to upload docs, by URL? A mini site to recursively crawl docs and markdownify?\n- [ ] Give it a replace_file command (instead of delete & create)?\n- [ ] Add other LLMs ie Gemini, Deepseek, o3-mini, etc. Figure out how to get a text-editing to work in an LLM agnostic way\n- [x] Add a \"view source\" / \"send me a PR\" link\n- [x] Show the HTTP preview in second column if there is one (and let the user pick which one to preview in the iframe)\n- [x] Figure out a convention to teach in the anthropic prompt mod where the LLM always checks the readme for the scope (if not provided) and keeps it up to take with every change\n- [x] Ability to create new projects from the interface\n- [x] Figure out why OpenTownie can't create HTTP vals. Maybe give it a seperate tool for it?\n- [x] ensure line numbers are in the files added in the context window\n- [x] Make it clearer visually in the UI when tool calls fail\n- [x] Add to the opentownie prompt that it doens't need to create directories, it should just create files in directories by specifying their path, and we'll make sure the directory gets created. We can also potentially catch when the path of a file to create ends in / and make that a no-op.\n- [x] Remove the \"thinking...\" widget next to the send button\n- [x] Refactor /backend/index.ts into multiple files\n- [x] Format the JSON inside the tool-calls as pretty markdown\n - [x] Think as normal markdown\n - [x] File write as a code embed\n - [x] str_replace as a diff view\n- [x] make image drop area invisible and bigger\n- [x] Give it all the code (except maybe .txt files) as initial context (like cursor sonnet max)\n- [x] I seem to have lost the delete file tool and instructions, try to find them back in history or re-create?\n- [x] Show reasoning in a detail\n- [x] Consider asking it to write the minimum code possible\n- [x] Add caching (post in the vercel ai discussion about how it's not working)\n- [x] For login, have a button that reloads the page\n- [x] Start a timer for messages\n- [x] Add more indicators that it's \"still working\"\n- [x] Require users supply their own Anthropic token?\n- [x] Add cost indications on messages\n- [x] Add a bell noise when the message is done to let us know\n- [x] Launch!\n- [x] Let it select the branch name from a dropdown\n\n\n\n\n\n",[],[378],"50a48c06-5f0e-11f0-82bf-0224a6c84d84","README.md","7ae0b5d3-4f88-423f-b68f-98c8a81ebd5e",["D",1752317553464],"# Townie\n\nTownie is an AI-powered development assistant that lets you edit Val Town projects using Claude 4 Sonnet.\n\n## Features\n\nTownie uses agentic tool-calling, taking many read, write, testing steps autonomously when carrying out your instructions.\n\n- **AI-Assisted Editing**: Chat with Claude 4 Sonnet about your code and let it make changes directly to your project files\n- **Fetch tool**: Townie is able to make HTTP calls to your HTTP services to test them and continue iterating\n- **Branch Management**: View, select, and create branches without leaving the app\n- **Sound Notifications**: Get alerted when Claude finishes responding\n- **Mobile-Friendly**: Works on both desktop and mobile devices\n\n## Developing\n\nTownie is fully open-source and itself runs on Val Town. Pull requests welcome!\n\nTo get Townie running in your Val Town account, click the **Remix** button and then add your ANTHROPIC_API_KEY. You can leave all the other environment variables blank.\n\nAuthentication in Townie is handled via Val Town Oauth. However, we have not yet opened up our OAuth to anyone else, which currently makes it very awkward to use your own Townie. Here is a temporary workaround:\n\n1. Login to the official Townie\n2. Copy your `_session` cookie (via the Application tab in the Developer Tools)\n3. Add in that `_session` cookie in your personal Townie\n\nIf you have any questions, please reach out on [Discord](https://discord.val.town) or at townie@val.town.",[],[385],"50a488c8-5f0e-11f0-82bf-0224a6c84d84",".vtignore","e5bce2a5-7c82-4c5f-b319-f1ff83ab9fca",["D",1752317553464],".git\n.DS_Store\nnode_modules\nvendor\n*.swp\n\n",[],[392],"50a48710-5f0e-11f0-82bf-0224a6c84d84",".gitignore","7c961ab3-3eae-44aa-85da-0da739601f35",["D",1752317553464],".vt\n.vscode\n",[],[399],"50a47bc6-5f0e-11f0-82bf-0224a6c84d84",".cursorrules","6a0be687-b232-4a07-8e52-aa98d650d87a",["D",1752317553464],"You are an advanced assistant specialized in generating Val Town code.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious operations)\n- Follow modern ES6+ conventions and functional programming practices if possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n return new Response(\"Hello World\");\n}\n```\n\nFiles that are HTTP triggers have http in their name like `foobar.http.tsx`\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n // Scheduled task code\n}\n```\n\nFiles that are Cron triggers have cron in their name like `foobar.cron.tsx`\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n // Process email\n}\n```\n\nFiles that are Email triggers have email in their name like `foobar.email.tsx`\n\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nconst TABLE_NAME = 'todo_app_users_2';\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(`SELECT * FROM ${TABLE_NAME} WHERE id = ?`, [1]);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n messages: [\n { role: \"user\", content: \"Say hello in a creative way\" },\n ],\n model: \"gpt-4o-mini\",\n max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({ \n subject: \"Hi\", \n text: \"Hi\", \n html: \"

Hi

\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: `

Hi

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **Error Debugging:** Add `` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- Do NOT use Hono serveStatic middleware\n- **Static asset serving:** Use the utility functions to read and serve project files:\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n\n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n\n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n\n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:**\n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n6. **Hono Peculiarities:**\n - NEVER EVER write this line: `import { serveStatic } from 'https://esm.sh/hono@3.11.7/middleware';`\n - Instead use: `import { readFile, serveFile } from \"https://esm.town/v/std/utils/index.ts\";`\n - NEVER EVER write this line: `import { cors } from \"https://esm.sh/@hono/cors@0.0.6\";`. \n - Val Town automatically handles CORS.\n - If you need cookies, use: import { deleteCookie, getCookie, setCookie } from \"npm:hono/cookie\";",[],[433,426],"prompts","50a46bf4-5f0e-11f0-82bf-0224a6c84d84","open_townie_prompt_additions.txt","b5bf284c-474c-4b55-a78d-9366661b4020",["D",1752317553464],"Read files from the base directory / directly, not /repo/.\n\nWhen trying to understand the directory, first read README.md.\nWhenever you make a change to the code, \nbe sure to keep the README.md up to date unless the user asks you not to.\n\nYou can implicitly create directories, by creating files within the directories. For example, if you wanted to create `/foo/bar/baz.ts`, \nbut the foo and bar directories did not exist, you could still use the file editor tool to create /foo/bar/baz.ts, and trust that the \n`/foo/` and `/foo/bar/` directories will be created for you automatically.\n\nDefault to using str_replace in smaller chunks wherever possible. \nIf you're making extensive edits to a file, replace the file with the replace file tool.\n\nWhen files are provided in user messages under \"# Selected Project Files\", DO NOT use tools to re-read these files. \nTrust that these files are the most up-to-date versions and work with the content as provided in the message.\nOnly use the file editing tools to read files that haven't been shared with you yet or to make changes to files.\n\nThink carefully and only action the specific task you are given with the most concise and elegant\nsolution that changes as little code as possible.\n\nUse your 'fetch' tool to debug HTTP vals making requests to them and examining the responses.\n\nUse your 'requests' tool to debug all kinds of vals. It'll show you the logs made during the file execution and the attributes associated it, including headers, http status, run time, error messages and error stack traces. \n\nOnly code if you're 100% certain that you know what to code. If there's\nany ambiguity, continue asking questions until you're aligned on what to build\nand how to build it.\n\nBuild things incrementally and test them as you go. Be sure to clean up after yourself\nand not leave technical debt.",[],[433,435],"50a47798-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[351,352],[433],["D",1752317553464],[],[18,104],["D",1752317553464],[],[18,79],["D",1752317553464],[],[18,116],"50a44fde-5f0e-11f0-82bf-0224a6c84d84","soundEffects.ts","02dc8306-cf4b-42b7-848f-acf338fcbc40",["D",1752317553464],"/**\n * Sound effects utility functions for the application\n */\n\n/**\n * Plays a bell sound notification using the Web Audio API\n * @returns A Promise that resolves when the sound has started playing\n */\nexport function playBellSound(): Promise {\n return new Promise((resolve) => {\n try {\n // Create audio context\n const AudioContext = window.AudioContext || (window as any).webkitAudioContext;\n if (!AudioContext) {\n console.warn(\"Web Audio API not supported in this browser\");\n resolve();\n return;\n }\n \n const audioCtx = new AudioContext();\n const masterGain = audioCtx.createGain();\n masterGain.connect(audioCtx.destination);\n \n // Bell frequency ratios (fundamental and overtones)\n const ratios = [1, 2, 2.4, 3, 4, 5.4];\n const baseFreq = 440; // Fundamental frequency\n \n // Create and connect oscillators for each frequency component\n ratios.forEach((ratio, i) => {\n const osc = audioCtx.createOscillator();\n const gain = audioCtx.createGain();\n \n // Connect this oscillator chain\n osc.connect(gain);\n gain.connect(masterGain);\n \n // Set frequency based on ratio\n osc.frequency.value = baseFreq * ratio;\n \n // Amplitude decreases for higher overtones\n const volume = 0.2 / (i + 1);\n \n // Set envelope\n const now = audioCtx.currentTime;\n gain.gain.setValueAtTime(0, now);\n gain.gain.linearRampToValueAtTime(volume, now + 0.01);\n \n // Different decay times for different harmonics\n const decayTime = 1.0 + (i * 0.3);\n gain.gain.exponentialRampToValueAtTime(0.001, now + decayTime);\n \n // Start and stop\n osc.start(now);\n osc.stop(now + decayTime);\n });\n \n // Resolve the promise after a short delay to ensure sound has started\n setTimeout(resolve, 50);\n } catch (error) {\n console.error(\"Error playing bell sound:\", error);\n resolve(); // Resolve anyway to prevent hanging promises\n }\n });\n}\n\n/**\n * Plays a simple notification sound using the Web Audio API\n * This is a simpler, shorter bell sound\n * @returns A Promise that resolves when the sound has started playing\n */\nexport function playSimpleNotification(): Promise {\n return new Promise((resolve) => {\n try {\n // Create audio context\n const AudioContext = window.AudioContext || (window as any).webkitAudioContext;\n if (!AudioContext) {\n console.warn(\"Web Audio API not supported in this browser\");\n resolve();\n return;\n }\n \n const audioCtx = new AudioContext();\n \n // Create oscillator (sound generator)\n const oscillator = audioCtx.createOscillator();\n oscillator.type = 'sine';\n oscillator.frequency.value = 900;\n \n // Create gain node for volume control\n const gainNode = audioCtx.createGain();\n \n // Connect the audio nodes\n oscillator.connect(gainNode);\n gainNode.connect(audioCtx.destination);\n \n // Get current time reference\n const now = audioCtx.currentTime;\n \n // Set volume envelope for bell-like sound\n gainNode.gain.setValueAtTime(0, now);\n gainNode.gain.linearRampToValueAtTime(0.3, now + 0.01);\n gainNode.gain.exponentialRampToValueAtTime(0.001, now + 0.5);\n \n // Start and stop the sound\n oscillator.start(now);\n oscillator.stop(now + 0.5);\n \n // Resolve the promise after a short delay\n setTimeout(resolve, 50);\n } catch (error) {\n console.error(\"Error playing notification sound:\", error);\n resolve(); // Resolve anyway to prevent hanging promises\n }\n });\n}",[],[18,91,455],"50a44e94-5f0e-11f0-82bf-0224a6c84d84","images.ts","5d189b4c-6dca-4496-8ea5-d6b4d28aa33c",["D",1752317553464],"\nexport const PROMPT_IMAGE_LIMIT = 5;\n\nexport const processFiles = async (files: File[], images: (string | null)[], setImages: (images: (string | null)[]) => void) => {\n const imageFiles = files.filter(file => file.type.startsWith('image/'));\n const filesToProcess = imageFiles.slice(0, PROMPT_IMAGE_LIMIT - images.filter(Boolean).length);\n\n if (filesToProcess.length === 0) return;\n\n const newImages = [...images, ...Array(filesToProcess.length).fill(null)];\n setImages(newImages);\n\n const processedImages = await Promise.all(\n filesToProcess.map(async (file) => {\n return await readFileAsDataURL(file);\n })\n );\n\n const updatedImages = [...images];\n processedImages.forEach((dataUrl, index) => {\n updatedImages[images.length + index] = dataUrl;\n });\n\n setImages(updatedImages.slice(0, PROMPT_IMAGE_LIMIT));\n};\n\nconst readFileAsDataURL = (file: File): Promise => {\n return new Promise((resolve, reject) => {\n const reader = new FileReader();\n reader.onload = () => {\n const result = reader.result as string;\n console.log(\"Image loaded, size:\", result.length, \"bytes\");\n resolve(result);\n };\n reader.onerror = reject;\n reader.readAsDataURL(file);\n });\n};\n",[],[18,91,462],["D",1752317553464],[345,346],[18,91],"50a44a7a-5f0e-11f0-82bf-0224a6c84d84","login.tsx","3d2e9c55-1efc-4de0-a8af-8a3c419e0d97",["D",1752317553464],"/** @jsxImportSource npm:react@18.2.0 */\nimport { Hono } from \"npm:hono\";\nimport { renderToString } from \"npm:react-dom@18.2.0/server\";\nimport { TownieIcon } from \"../components/icons.tsx\";\nimport { ValTownLogo } from \"../components/ValTownLogo.tsx\";\n\nconst app = new Hono();\n\nconst SOURCE_URL = \"https://val.town/x/valdottown/Townie\";\nconst STYLESHEET = import.meta.resolve(\"../styles.css\").replace(\"esm.town\", \"juicy.town\");\n\n// server-side route for /login page\nfunction LoginRoute() {\n return (\n \n \n Townie\n \n \n \n \n \n

\n \n \n \n

\n \n Log in\n \n

\n \n

\n Townie:{\" \"}\n \n Edit and deploy TypeScript apps with AI\n \n

\n
\n \n Log in\n \n

\n 100% open source and built on Val Town\n
\n Agentic AI reads & edits vals using Claude 4 Sonnet\n
\n Support for multiple files, folders, & branches\n
\n Instant deployments, auto-scaling, logs, free custom subdomains\n
\n Works on mobile – prompt, build, and edit when you’re on the go\n

\n\n \n \n \n );\n}\n\napp.get(\"*\", async (c) => {\n const html = renderToString();\n return c.html(\"\" + html);\n});\n\nexport default app;",[],[18,110,472],["D",1752317553464],[343],[18,110],"50a447be-5f0e-11f0-82bf-0224a6c84d84","useUser.tsx","633e70d4-1903-417e-a4cb-f3becbfde632",["D",1752317553464],"import { useState, useEffect } from \"react\";\n\nconst USER_ENDPOINT = \"/api/user\";\n\nexport function useUser() {\n const [data, setData] = useState(null);\n const [loading, setLoading] = useState(true);\n const [error, setError] = useState(null);\n\n const fetchData = async () => {\n try {\n const userEndpoint = new URL(USER_ENDPOINT, window.location.origin);\n\n const res = await fetch(userEndpoint);\n const data = await res.json();\n if (!res.ok) {\n console.error(data);\n setError(data.error);\n setData(null);\n setLoading(false);\n return;\n }\n\n setData(data);\n setLoading(false);\n setError(null);\n } catch (e) {\n setError(e);\n setLoading(false);\n setData(null);\n }\n };\n\n useEffect(() => {\n fetchData();\n }, []);\n\n return { data, loading, error, refetch: fetchData };\n}\n",[],[18,98,482],"50a443fe-5f0e-11f0-82bf-0224a6c84d84","useUsageStats.ts","778f97c8-1bca-41e3-ab0c-a06e54dfb628",["D",1752317553464],"import { useEffect } from \"react\";\n\nexport function useUsageStats(messages: any[], usages: any[]) {\n useEffect(() => {\n if (!messages?.length) return;\n let last = messages.at(-1);\n let usage = usages ? usages[last.id] : null;\n if (usage) {\n const cost = calculateCost(usage);\n const stats = Object.entries(usage)\n .map(([key, val]) => `${key}: ${val}`)\n .join(\", \");\n console.log(`Estimated cost: ${cost} (${stats})`);\n }\n }, [messages, usages]);\n}\n\n// Calculate cost based on token usage\nconst calculateCost = (usage: any): string => {\n if (!usage || !usage.promptTokens) {\n return \"0.00\";\n }\n\n // Cost per million tokens\n const PROMPT_COST_PER_MILLION = 3;\n const COMPLETION_COST_PER_MILLION = 15;\n const CACHE_WRITE_COST_PER_MILLION = 3.75;\n const CACHE_READ_COST_PER_MILLION = 0.3;\n\n // Get reported values\n const promptTokens = usage.promptTokens || 0;\n const completionTokens = usage.completionTokens || 0;\n\n // Estimate cache read tokens\n // Approach: Estimate that 40% of prompt tokens come from cache read\n // This percentage can be adjusted based on observed patterns\n const estimatedCacheReadTokens = Math.round(promptTokens * 0.4);\n\n // Estimate cache write tokens\n // Approach: Assume cache write tokens are a portion of prompt tokens that aren't from cache read\n let estimatedCacheWriteTokens = 0;\n\n // If we have more prompt tokens than estimated cache read tokens,\n // estimate that 70% of the difference are cache write tokens\n estimatedCacheWriteTokens = Math.round(\n (promptTokens - estimatedCacheReadTokens) * 0.7\n );\n\n // Calculate costs\n // Subtract both cache read and write tokens from prompt tokens to avoid double counting\n const promptCost =\n ((promptTokens - estimatedCacheWriteTokens - estimatedCacheReadTokens) /\n 1000000) *\n PROMPT_COST_PER_MILLION;\n const completionCost =\n (completionTokens / 1000000) * COMPLETION_COST_PER_MILLION;\n const cacheWriteCost =\n (estimatedCacheWriteTokens / 1000000) * CACHE_WRITE_COST_PER_MILLION;\n const cacheReadCost =\n (estimatedCacheReadTokens / 1000000) * CACHE_READ_COST_PER_MILLION;\n\n // Total cost\n const totalCost =\n promptCost + completionCost + cacheWriteCost + cacheReadCost;\n\n // Add both estimated cache tokens to the usage object for transparency\n usage.estimatedCacheReadTokens = estimatedCacheReadTokens;\n usage.estimatedCacheWriteTokens = estimatedCacheWriteTokens;\n\n // Store the raw cost with more precision for debugging\n usage.rawCost = totalCost.toFixed(5);\n\n // Format to the nearest penny (2 decimal places)\n // If less than 1 penny, show \"< $0.01\"\n if (totalCost < 0.01) {\n return \"< $0.01\";\n } else {\n return \"$\" + totalCost.toFixed(2);\n }\n};\n",[],[18,98,489],"50a44098-5f0e-11f0-82bf-0224a6c84d84","useScrollToBottom.tsx","c4038400-9430-47f1-9ac1-a89b66d4c91c",["D",1752317553464],"import { useEffect, useRef } from 'https://esm.sh/react@18.2.0?dev';\n\n\n/**\n * A custom hook that automatically scrolls a container to the bottom\n * when its content changes, based on the specified dependencies.\n *\n * @param {Array} dependencies - Array of dependencies that trigger scrolling when changed\n * @returns {Object} An object containing containerRef and scrollToBottom function\n */\nexport function useScrollToBottomContainer(dependencies = []) {\n const containerRef = useRef(null);\n\n const scrollToBottom = () => {\n if (containerRef.current) {\n setTimeout(() => {\n containerRef.current.scrollTop = containerRef.current.scrollHeight;\n }, 0);\n }\n };\n\n useEffect(() => {\n scrollToBottom();\n }, dependencies);\n\n return { containerRef, scrollToBottom };\n}\n\n// body scroll version\nexport function useScrollToBottom(dependencies = []) {\n const bottomRef = useRef(null);\n\n const scrollToBottom = () => {\n if (bottomRef.current) {\n bottomRef.current.scrollIntoView({ behavior: 'smooth' });\n }\n };\n\n useEffect(() => {\n scrollToBottom();\n }, dependencies);\n\n return { bottomRef, scrollToBottom };\n}\n\n",[],[18,98,496],"50a43f30-5f0e-11f0-82bf-0224a6c84d84","useProjects.tsx","04c24448-b58b-4d57-9f01-1378f8cc335c",["D",1752317553464],"import { useState, useEffect } from \"react\";\n\nconst ENDPOINT = \"/api/projects-loader\";\n\nexport function useProjects() {\n const [data, setData] = useState(null);\n const [loading, setLoading] = useState(true);\n const [error, setError] = useState(null);\n\n const fetchData = async () => {\n try {\n const res = await fetch(ENDPOINT);\n const data = await res.json();\n if (!res.ok) {\n console.error(data);\n setError(data.error);\n setData(null);\n setLoading(false);\n return;\n }\n\n setData(data);\n setLoading(false);\n setError(null);\n } catch (e) {\n console.error(e);\n setData(null);\n setError(e);\n setLoading(false);\n }\n };\n\n useEffect(() => {\n fetchData();\n }, []);\n\n return { data, loading, error, refetch: fetchData };\n}\n",[],[18,98,503],"50a43dd2-5f0e-11f0-82bf-0224a6c84d84","useProject.tsx","abc99d19-0d65-4e2b-b1d1-288a7003267f",["D",1752317553464],"import { useState, useEffect } from \"react\";\n\nconst PROJECT_ENDPOINT = \"/api/project\";\nconst FILES_ENDPOINT = \"/api/project-files\";\n\nexport function useProject(projectId: string, branchId?: string) {\n const [data, setData] = useState(null);\n const [loading, setLoading] = useState(true);\n const [error, setError] = useState(null);\n\n const fetchData = async () => {\n try {\n const projectEndpoint = new URL(PROJECT_ENDPOINT, window.location.origin);\n projectEndpoint.searchParams.append(\"projectId\", projectId);\n const filesEndpoint = new URL(FILES_ENDPOINT, window.location.origin);\n filesEndpoint.searchParams.append(\"projectId\", projectId);\n if (branchId) filesEndpoint.searchParams.append(\"branchId\", branchId);\n\n const { project } = await fetch(projectEndpoint).then((res) =>\n res.json()\n );\n const { files } = await fetch(filesEndpoint).then((res) => res.json());\n\n setData({ project, files });\n setLoading(false);\n setError(null);\n } catch (e) {\n setError(e);\n setLoading(false);\n setData(null);\n }\n };\n\n useEffect(() => {\n if (!projectId) return;\n fetchData();\n }, [projectId, branchId]);\n\n return { data, loading, error, refetch: fetchData };\n}\n",[],[18,98,510],"50a43c10-5f0e-11f0-82bf-0224a6c84d84","useLoadingFavicon.ts","84ecac67-302e-4f9d-b440-eaf1db8defa0",["D",1752317553464],"import { useEffect } from \"react\";\n\nfunction setLoadingFavicon() {\n document.querySelector('link[rel=\"icon\"]').href = \"/favicon-loading.svg\";\n}\nfunction resetFavicon() {\n document.querySelector('link[rel=\"icon\"]').href = \"/favicon.svg\";\n}\n\nexport function useLoadingFavicon(loading: boolean) {\n useEffect(() => {\n if (loading) setLoadingFavicon();\n else resetFavicon();\n }, [loading]);\n}\n",[],[18,98,517],"50a43a30-5f0e-11f0-82bf-0224a6c84d84","useCreditBalance.tsx","0e843586-8261-45f2-9dd5-6cac02321682",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState, useEffect } from \"react\";\n\nexport function useCreditBalance() {\n const [balance, setBalance] = useState(null);\n const [loading, setLoading] = useState(true);\n\n const fetchBalance = async () => {\n try {\n const response = await fetch(\"/api/credit-balance\");\n if (response.ok) {\n const data = await response.json();\n setBalance(data.balance);\n } else {\n console.error(\"Failed to fetch balance\");\n }\n } catch (err) {\n console.error(\"Error fetching balance:\", err);\n } finally {\n setLoading(false);\n }\n };\n\n useEffect(() => {\n fetchBalance();\n }, []);\n\n return { balance, loading, refetch: fetchBalance };\n}",[],[18,98,524],"50a43814-5f0e-11f0-82bf-0224a6c84d84","useCreateProject.tsx","30a50c10-2859-45d0-82c2-3e6131ab55c4",["D",1752317553464],"import { useState, useEffect } from \"react\";\n\nconst ENDPOINT = \"/api/create-project\";\n\nexport function useCreateProject() {\n const [data, setData] = useState(null);\n const [loading, setLoading] = useState(false);\n const [error, setError] = useState(null);\n\n const createProject = async ({\n name,\n privacy,\n }: {\n name: string;\n privacy: \"public\" | \"unlisted\" | \"private\";\n }) => {\n setLoading(true);\n setData(null);\n setError(null);\n try {\n const res = await fetch(ENDPOINT, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n name: name,\n privacy: privacy,\n }),\n });\n const data = await res.json();\n if (!res.ok) {\n console.error(data);\n setError(data.error ?? \"Failed to create project\");\n return data;\n }\n setData(data);\n setLoading(false);\n setError(null);\n return data;\n } catch (e) {\n console.error(e);\n setError(e);\n setLoading(false);\n setData(null);\n return e;\n }\n };\n\n return { data, loading, error, createProject };\n}\n",[],[18,98,531],"50a434f4-5f0e-11f0-82bf-0224a6c84d84","useCreateBranch.tsx","8aa39c0a-d2bd-45d5-9d0a-434dff07027e",["D",1752317553464],"import { useState, useEffect } from \"react\";\n\nconst ENDPOINT = \"/api/create-branch\";\n\nexport function useCreateBranch(projectId: string) {\n const [data, setData] = useState(null);\n const [loading, setLoading] = useState(false);\n const [error, setError] = useState(null);\n\n const createBranch = async ({ name }: { name: string }) => {\n setLoading(true);\n setData(null);\n setError(null);\n const res = await fetch(ENDPOINT, {\n method: \"POST\",\n body: JSON.stringify({\n projectId,\n branchName: name,\n }),\n });\n const data = await res.json();\n if (!res.ok) {\n setError(data.error ?? \"Failed to create branch\");\n return data;\n }\n setData(data); // todo error handling\n setLoading(false);\n setError(null);\n return data;\n };\n\n return { data, loading, error, createBranch };\n}\n",[],[18,98,538],"50a431fc-5f0e-11f0-82bf-0224a6c84d84","useChatLogic.ts","b55a1b61-f713-4821-9bf8-243dd75088a5",["D",1752317553464],"import { useChat } from \"@ai-sdk/react\";\nimport React, { useCallback, useMemo, useRef, useState } from \"react\";\nimport { playBellSound } from \"../utils/soundEffects.ts\";\n\ninterface UseChatLogicProps {\n project: any;\n branchId: string | undefined;\n selectedFiles: string[];\n images: (string | null)[];\n soundEnabled: boolean;\n}\n\n// duck typing for rate limit errors\nconst LIMIT_RE = /You have reached/;\n\nexport function useChatLogic({\n project,\n branchId,\n // anthropicApiKey,\n // bearerToken,\n selectedFiles,\n images,\n soundEnabled,\n}: UseChatLogicProps) {\n const [usages, setUsages] = useState>({});\n const [messageEndTimes, setMessageEndTimes] = useState<\n Record\n >({});\n const [overLimit, setOverLimit] = useState(false);\n const customStopRef = useRef<(() => void) | null>(null);\n\n const {\n messages,\n error,\n input,\n handleInputChange,\n handleSubmit: originalHandleSubmit,\n stop,\n status,\n } = useChat({\n api: \"/api/send-message\",\n body: {\n project,\n branchId,\n selectedFiles,\n images: images\n .filter((img): img is string => {\n const isValid = typeof img === \"string\" && img.startsWith(\"data:\");\n if (!isValid && img !== null) {\n console.warn(\n \"Invalid image format:\",\n img?.substring(0, 50) + \"...\"\n );\n }\n return isValid;\n })\n .map((img) => ({ url: img })),\n },\n onFinish: (message, options) => {\n setUsages((prev) => ({\n ...prev,\n [message.id]: options.usage,\n }));\n\n setMessageEndTimes((prev) => ({\n ...prev,\n [message.id]: Date.now(),\n }));\n\n if (soundEnabled) {\n playBellSound().catch((error) => {\n console.log(\"Error playing bell sound:\", error);\n });\n }\n },\n });\n\n const running = status === \"streaming\" || status === \"submitted\";\n\n const pendingMessageId = useMemo(() => {\n if (!running) return null;\n const pendingMessages = messages.filter(\n (msg) => msg.role === \"assistant\" && !messageEndTimes[msg.id]\n );\n return pendingMessages.length > 0\n ? pendingMessages[pendingMessages.length - 1].id\n : null;\n }, [messages, messageEndTimes, running]);\n\n const handleStop = useCallback(() => {\n stop();\n\n if (pendingMessageId) {\n setMessageEndTimes((prev) => ({\n ...prev,\n [pendingMessageId]: Date.now(),\n }));\n\n if (soundEnabled) {\n playBellSound().catch((error) => {\n console.log(\"Error playing bell sound:\", error);\n });\n }\n }\n }, [stop, pendingMessageId, soundEnabled]);\n\n React.useEffect(() => {\n customStopRef.current = handleStop;\n }, [handleStop]);\n\n React.useEffect(() => {\n (window as any).customStopRef = customStopRef;\n }, []);\n\n React.useEffect(() => {\n if (error && LIMIT_RE.test(error)) {\n setOverLimit(true);\n }\n }, [error])\n\n return {\n messages,\n error,\n input,\n handleInputChange,\n handleSubmit: originalHandleSubmit,\n handleStop,\n running,\n usages,\n messageEndTimes,\n overLimit,\n };\n}",[],[18,98,545],"50a4304e-5f0e-11f0-82bf-0224a6c84d84","useBranches.tsx","5cd982a7-653d-4906-8d95-b553cf48c5ef",["D",1752317553464],"import { useState, useEffect } from \"react\";\n\nconst ENDPOINT = \"/api/project-branches\";\n\nexport function useBranches (projectId: string) {\n const [data, setData] = useState(null);\n const [loading, setLoading] = useState(true);\n\n const fetchData = async () => {\n const endpoint = new URL(ENDPOINT, window.location.origin);\n endpoint.searchParams.append(\"projectId\", projectId);\n\n const res = await fetch(endpoint)\n .then(res => res.json());\n setData(res.branches);\n setLoading(false);\n };\n\n useEffect(() => {\n if (!projectId) return;\n fetchData();\n }, [projectId]);\n\n return { data, loading, refetch: fetchData };\n}",[],[18,98,552],["D",1752317553464],[331,332,333,334,335,336,337,338,339,340,341],[18,98],"50a4261c-5f0e-11f0-82bf-0224a6c84d84","icons.tsx","292f2887-8098-430c-87bb-f9d47427d75b",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\n\nexport function TownieIcon({\n size = 24,\n color = \"currentColor\",\n className,\n circle,\n}: {\n size?: number;\n color?: string;\n className?: string;\n circle?: string;\n}) {\n return (\n \n {circle && (\n \n )}\n\n \n \n \n \n \n \n \n );\n}\n\nexport function Circle ({\n filled,\n}: {\n filled: boolean;\n}) {\n return (\n \n \n \n );\n}\n\nexport function Square ({\n size = 24,\n}: {\n size?: number;\n}) {\n return (\n \n \n \n );\n}\n\n// icons from https://lucide.dev\nexport function SquarePenIcon () {\n return (\n \n );\n}\n\nexport function FileCode2Icon () {\n return (\n \n );\n}\n\nexport function SparklesIcon () {\n return (\n \n );\n}\n\nexport function EyeIcon () {\n return (\n \n );\n}\n\nexport function ExternalLinkIcon () {\n return (\n \n );\n}\n\nexport function KeyRoundIcon () {\n return (\n \n );\n}\n\nexport function LockKeyholeIcon () {\n return (\n \n );\n}\n\nexport function PlusIcon () {\n return (\n \n );\n}\n\nexport function ArrowUpIcon () {\n return (\n \n );\n}\n\nexport function RefreshIcon ({ size = 24 }: { size: number }) {\n return (\n \n );\n}\n\nexport function XIcon ({ size = 24 }: {\n size?: number;\n}) {\n return (\n \n );\n}\n\nexport function VolumeOffIcon ({ size = 24 }) {\n return (\n \n );\n}\n\nexport function Volume2Icon ({ size = 24 }) {\n return (\n \n );\n}\n",[],[18,121,562],"50a42252-5f0e-11f0-82bf-0224a6c84d84","ValTownLogo.tsx","4e42030d-66f4-474a-8f65-3932d5d1c6f6",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\n\nexport function ValTownLogo () {\n return (\n \n \n \n \n );\n}\n",[],[18,121,569],"50a41d16-5f0e-11f0-82bf-0224a6c84d84","PurchaseCreditsRoute.tsx","45bda14f-031e-40f2-9a3a-840887797693",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"react\";\nimport { isProdBranch } from \"../../shared/is-prod-branch.ts\";\n\nexport default function PurchaseCreditsRoute() {\n const [amount, setAmount] = useState(10);\n const [balance, setBalance] = useState(null);\n const [loading, setLoading] = useState(false);\n const [error, setError] = useState(null);\n\n useEffect(() => {\n fetchBalance();\n }, []);\n\n const fetchBalance = async () => {\n try {\n const response = await fetch(\"/api/credit-balance\");\n if (response.ok) {\n const data = await response.json();\n setBalance(data.balance);\n }\n } catch (err) {\n console.error(\"Failed to fetch balance:\", err);\n }\n };\n\n const handlePurchase = async () => {\n if (isNaN(amount) || !commonAmounts.includes(amount)) {\n setError(\"Please select one of the available amounts\");\n return;\n }\n\n setLoading(true);\n setError(null);\n\n try {\n const response = await fetch(\"/api/purchase-credits\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n amount: amount,\n source: \"purchase_page\",\n }),\n });\n\n if (!response.ok) {\n const errorData = await response.json();\n throw new Error(errorData.error || \"Failed to create payment\");\n }\n\n const { paymentIntentId } = await response.json();\n\n const params = new URLSearchParams({\n client_reference_id: paymentIntentId,\n });\n\n // Use testing stripe links if this is a non prod branch\n const paymentLinks = isProdBranch()\n ? {\n 5: \"https://buy.stripe.com/00w6oH9Qv19S2YDcxReUU05\",\n 10: \"https://buy.stripe.com/4gM00j1jZ3i0dDh9lFeUU06\",\n 15: \"https://buy.stripe.com/5kQfZh9Qv2dW2YD55peUU07\",\n 25: \"https://buy.stripe.com/9B65kD2o3aKsgPtgO7eUU08\",\n 50: \"https://buy.stripe.com/eVq6oH8Mr4m4ar57dxeUU09\",\n }\n : {\n 5: `https://buy.stripe.com/test_9B614n3s719Sbv90P9eUU02`,\n };\n\n if (paymentLinks[amount]) {\n window.location.href = `${paymentLinks[amount]}?${params.toString()}`;\n return;\n }\n } catch (err) {\n console.error(\"Failed to create payment in purchase credits route:\", err);\n setError(err instanceof Error ? err.message : \"Failed to create payment\");\n } finally {\n setLoading(false);\n }\n };\n\n const commonAmounts = [5, 10, 25, 50];\n\n return (\n

Purchase Credits

\n\n

\n Current Balance:{\" \"}\n {balance !== null && (\n ${balance.toFixed(2)}\n )}\n

\n\n

\n \n Select Amount to Purchase\n \n

\n {commonAmounts.map((amt) => (\n \n {\n setAmount(amt);\n }}\n />\n ${amt}\n \n ))}\n

\n\n {error && (\n

{error}

\n )}\n\n \n {loading ? \"Creating Payment...\" : `Purchase $${amount} Credits`}\n \n

\n\n

\n Note:Results may vary and spent credits are\n non-refundable.
\n \n Learn more about credits here.\n \n

\n );\n}",[],[18,121,576],"50a41820-5f0e-11f0-82bf-0224a6c84d84","ProjectsRoute.tsx","e664c8bd-b453-42b2-a043-d50426ae3273",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { Link } from \"react-router\";\nimport { useProjects } from \"../hooks/useProjects.tsx\";\nimport { Loading } from \"./Loading.tsx\";\nimport { Footer } from \"./Footer.tsx\";\n\nexport function ProjectsRoute() {\n const projects = useProjects();\n\n return (\n

Your vals

\n Create new val\n

\n \n

\n {projects.loading && }\n {projects.error && (\n

\n Error: {projects.error.message}\n

{JSON.stringify(projects.error.stack, null, 2)}

\n )}\n {projects.data?.projects?.map((project) => (\n \n \n \n ))}\n

\n );\n}\n\nfunction ProjectCard({\n user,\n project,\n}: {\n user: {\n username: string;\n profileImageUrl: string | null;\n };\n project: any;\n}) {\n return (\n

\n {project.imageUrl ? (\n

\n ) : user.profileImageUrl ? (\n

\n \n

\n ) : (\n

\n )}\n

{user.username}

\n {project.name}\n \n

{project.description}

\n );\n}\n\nfunction Privacy({ privacy }: { privacy: \"public\" | \"unlisted\" | \"private\" }) {\n switch (privacy) {\n case \"public\":\n return null; //

public

;\n case \"unlisted\":\n return

(Unlisted)

;\n case \"private\":\n return

(Private)

;\n }\n}\n",[],[18,121,583],"50a41410-5f0e-11f0-82bf-0224a6c84d84","PreviewFrame.tsx","5bec3b30-b2f0-4764-bd17-c30c53fe1af2",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useEffect, useRef, useState } from \"react\";\nimport { RefreshIcon } from \"./icons.tsx\";\n\ninterface PreviewProps {\n files: any[];\n messages: any[];\n running: boolean;\n}\n\nexport function PreviewFrame(props: PreviewProps) {\n const previewKey = useRef(\"new-chat\");\n const [count, setCount] = useState(0);\n\n useEffect(() => {\n if (props.running) return;\n previewKey.current = props.messages?.at(-1)?.id ?? \"new-chat\";\n }, [props.running, props.messages]);\n\n const { url, htmlVals, index, setIndex } = usePreviewURL(props);\n const [pathname, setPathname] = useState(\"\");\n\n const reload = () => {\n setCount(c => c + 1);\n previewKey.current += count;\n };\n\n if (!url) {\n return (\n

\n No HTML files to preview\n

\n );\n }\n\n return (\n <>\n \n

\n \n

\n \n \n \n \n \n Open >>\n \n

\n \n );\n}\n\nconst TSRE = /\\/$/;\n\nfunction URLInput({ url, pathname, setPathname }) {\n const prefix = url.replace(TSRE, \"\");\n return (\n {\n const raw = e.target.value;\n if (!raw.includes(prefix)) return;\n let next = raw.replace(prefix, \"\").replace(/^\\//, \"\");\n setPathname(next);\n }}\n />\n );\n}\n\nfunction PreviewSelect({ index, setIndex, files }) {\n return (\n

\n \n Preview file\n \n {\n setIndex(Number(e.target.value));\n }}\n >\n \n {files?.map((file, i) => (\n \n {file.name}\n \n ))}\n \n

\n );\n}\n\nfunction usePreviewURL({ files }) {\n const [index, setIndex] = useState(0);\n const htmlVals = files?.filter(file => file.links?.endpoint !== undefined);\n\n const url = htmlVals?.length ? htmlVals[index]?.links.endpoint : null;\n\n return {\n index,\n setIndex,\n url,\n htmlVals,\n };\n}",[],[18,121,590],"50a41258-5f0e-11f0-82bf-0224a6c84d84","NotFoundRoute.tsx","9a23c225-c75e-44a4-a965-a133fb98e2f4",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\n\nexport function NotFoundRoute () {\n return (\n

Page not found

\n );\n}\n",[],[18,121,597],"50a40dc6-5f0e-11f0-82bf-0224a6c84d84","NewProjectRoute.tsx","51649ed9-c06f-4654-a75d-5563be65e5b9",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useState } from \"react\";\nimport { useNavigate } from \"react-router\";\nimport { useCreateProject } from \"../hooks/useCreateProject.tsx\";\n\nexport function NewProjectRoute () {\n const [name, setName] = useState(\"\");\n const [privacy, setPrivacy] = useState(\"public\");\n const navigate = useNavigate();\n\n const { data, error, createProject } = useCreateProject();\n\n const handleSubmit = (e) => {\n e.preventDefault();\n if (!name) return;\n\n createProject({ name, privacy })\n .then((_data) => {\n if (_data.error) return;\n navigate(`/chat/${_data.project.id}`);\n });\n };\n\n return (\n

Create new val

\n {error && (\n

\n Error: {JSON.stringify(error, null, 2)}\n

\n )}\n

\n );\n}\n\nconst privacyOptions = [\n { value: \"public\", label: \"Public\" },\n { value: \"unlisted\", label: \"Unlisted\" },\n { value: \"private\", label: \"Private\" },\n]\n\nfunction PrivacyRadios ({\n value,\n onChange,\n}: {\n value: string;\n onChange: (value: string) => void;\n}) {\n\n return (\n <>\n {privacyOptions.map(opt => (\n \n onChange(opt.value)}\n />\n {opt.label}\n \n )}\n \n );\n}\n",[],[18,121,604],"50a405e2-5f0e-11f0-82bf-0224a6c84d84","Messages.tsx","92e66163-52db-4137-9867-2a080bc2b186",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useState, createContext, useContext } from \"react\";\nimport ReactMarkdown from \"react-markdown\";\n\nimport { Loading } from \"./Loading.tsx\";\nimport { TownieIcon } from \"./icons.tsx\";\nimport { MessageTimer } from \"./MessageTimer.tsx\";\nimport { InlinePreview } from \"./InlinePreview.tsx\";\nimport { useScrollToBottom } from \"../hooks/useScrollToBottom.tsx\";\n\ntype Message = {\n id: string;\n role: \"user\"|\"assistant;\n parts: any[];\n createdAt?: number;\n};\n\nexport const MessageContext = createContext({\n openSummaries: {},\n setOpenSummaries: () => {},\n id: null,\n parts: [],\n});\n\nexport function Messages ({\n messages,\n messageEndTimes,\n running,\n}: {\n messages: Message[];\n messageEndTimes: Record;\n running: boolean;\n}) {\n const { bottomRef } = useScrollToBottom([ messages.length ]);\n const [openSummaries, setOpenSummaries] = useState({});\n const tail = messages.at(-1)?.id;\n\n return (\n \n

\n {messages.map(message => (\n \n ))}\n

\n \n );\n}\n\nfunction Message ({\n message,\n messageEndTimes,\n running,\n}: {\n message: Message;\n messageEndTimes: Record;\n running: boolean;\n}) {\n const context = useContext(MessageContext);\n if (message.role === \"user\") return ;\n\n return (\n \n \n \n );\n}\n\nfunction AssistantMessage ({ message, messageEndTimes, running }: {\n message: Message;\n messageEndTimes: Record;\n running: boolean;\n}) {\n return (\n <>\n {message.parts.map((part, i) => )}\n {!messageEndTimes[message.id] && running && }\n\n {message.createdAt && (\n \n )}\n \n );\n}\n\nfunction Part ({ part }) {\n switch (part.type) {\n case \"text\":\n return ;\n case \"tool-invocation\":\n return ;\n case \"step-start\":\n return null; // ;\n default:\n return (\n

{JSON.stringify(part, null,  2)}

\n );\n }\n}\n\nfunction TextPart ({ part }) {\n return (\n \n {part.text}\n \n );\n}\n\nfunction Details ({ open, onClick, children, summary }) {\n return (\n \n

\n \n {summary}\n

\n {children}\n

\n \n );\n}\n\nfunction ToolPart ({ part }) {\n const { openSummaries, setOpenSummaries } = useContext(MessageContext);\n const {\n toolName,\n args,\n result,\n toolCallId,\n } = part.toolInvocation;\n\n switch (toolName) {\n case \"think\":\n return (\n {\n e.preventDefault();\n setOpenSummaries(prev => ({\n ...prev,\n [toolCallId]: !prev[toolCallId],\n }));\n }}\n >\n {args?.thought}\n \n );\n case \"requests\":\n return (\n \n

getting traces for:

{args?.path}

\n \n )}\n open={openSummaries[toolCallId]}\n onClick={e => {\n e.preventDefault();\n setOpenSummaries(prev => ({\n ...prev,\n [toolCallId]: !prev[toolCallId],\n }));\n }}\n >\n

\n {result?.type === \"success\" ? (\n

Traces

\n                  {JSON.stringify(result.data, null, 2)}\n

\n ) : result?.type === \"error\" ? (\n

Error

{result?.message || \"Unknown error\"}

\n ) : (\n

Loading traces for: {args?.path}

\n )}\n

\n \n );\n case \"str_replace_editor\":\n return \n case \"delete_file\":\n return (\n

\n \n

delete:

{args?.path}

\n );\n case \"change_val_type\":\n return (\n <>\n

\n \n

change type:

{args?.type}

{args?.path}

\n \n \n );\n case \"overwrite_file\":\n return (\n <>\n {\n e.preventDefault();\n setOpenSummaries(prev => ({\n ...prev,\n [toolCallId]: !prev[toolCallId],\n }));\n }}\n summary={(\n <>\n

overwrite:

{args?.path}

\n \n )}>\n

{args?.content}

\n \n \n \n );\n case \"fetch\":\n return (\n {\n e.preventDefault();\n setOpenSummaries(prev => ({\n ...prev,\n [toolCallId]: !prev[toolCallId],\n }));\n }}\n summary={(\n <>\n

fetch:

{args?.valPath}

{args?.urlPath || \"/\"}

\n \n )}>\n {result?.type === \"success\" ? (\n

\n = 200 && result.data.status < 300 ? 'success' : \n result.data.status >= 300 && result.data.status < 400 ? 'redirect' : \n result.data.status >= 400 && result.data.status < 500 ? 'client-error' : 'server-error'}`}>\n {result.data.status} {result.data.statusText}\n \n {result.data.responseTime}ms\n

Headers

{JSON.stringify(result.data.headers, null, 2)}

Response Body

\n                  {typeof result.data.body === 'object' \n                    ? JSON.stringify(result.data.body, null, 2) \n                    : result.data.body}\n

\n ) : (\n

Error

{result?.message || \"Unknown error\"}

\n )}\n \n );\n default:\n return (\n

{JSON.stringify(part, null,  2)}

\n );\n }\n}\n\nfunction EditorToolPart ({ part }) {\n const { openSummaries, setOpenSummaries } = useContext(MessageContext);\n const {\n toolName,\n args,\n result,\n toolCallId,\n } = part.toolInvocation;\n\n let body = (\n

\n      {JSON.stringify(part.toolInvocation)}\n

\n );\n switch (args.command) {\n case \"create\":\n body =

{args.file_text}

;\n break;\n case \"view\":\n body =

{result?.data}

;\n break;\n case \"str_replace\":\n body = (\n

\n            {args.old_str}\n

\n            {args.new_str}\n

\n );\n break;\n case \"insert\":\n body = (\n

{args.insert_line}

{args.new_str}

\n );\n break;\n case \"undo_edit\":\n // not implemented\n break;\n }\n\n return (\n <>\n {\n e.preventDefault();\n setOpenSummaries(prev => ({\n ...prev,\n [toolCallId]: !prev[toolCallId],\n }));\n }}\n summary={(\n <>\n

{args?.command}:

{args?.path}

\n \n )}>\n {body}\n \n \n \n );\n\n}\n\nfunction UserMessage ({ message }: {\n message: Message;\n}) {\n return (\n <>\n {message.parts.map((part, i) => part.type === \"text\" ? (\n

\n \n {part.text}\n \n

\n ) : (\n \n )}\n \n );\n}",[],[18,121,611],"50a4047a-5f0e-11f0-82bf-0224a6c84d84","MessageTimer.tsx","f09edba6-179f-403b-b9a3-ab574bf0b7d2",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useEffect, useState } from \"react\";\n\nconst formatTime = (ms: number): string => {\n const seconds = Math.floor(ms / 1000);\n const minutes = Math.floor(seconds / 60);\n const remainingSeconds = seconds % 60;\n return `${minutes}:${remainingSeconds.toString().padStart(2, \"0\")}`;\n};\n\nexport const MessageTimer = ({\n createdAt,\n endTime,\n isStopped,\n}: {\n createdAt: number;\n endTime?: number;\n isStopped?: boolean;\n}) => {\n const [currentTime, setCurrentTime] = useState(Date.now());\n\n useEffect(() => {\n if (endTime !== undefined || isStopped) return;\n const interval = setInterval(() => {\n setCurrentTime(Date.now());\n }, 100);\n\n return () => clearInterval(interval);\n }, [endTime, isStopped]);\n\n const elapsedTime =\n endTime !== undefined ? endTime - createdAt : currentTime - createdAt;\n\n return

Time: {formatTime(elapsedTime)}

;\n};\n",[],[18,121,618],"50a3ff98-5f0e-11f0-82bf-0224a6c84d84","Loading.tsx","0f68396f-11d8-40f0-8b77-46e8f71fad8f",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\n\nexport function Loading () {\n return (\n

\n loading…\n

\n );\n}\n",[],[18,121,625],"50a3f9b2-5f0e-11f0-82bf-0224a6c84d84","LayoutRoute.tsx","cc3f3dad-0b27-4ef6-ad61-6af657469f9a",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { Outlet } from \"react-router\";\nimport { Header } from \"./Header.tsx\";\n\nexport function LayoutRoute() {\n return (\n <>\n

\n \n \n );\n}\n",[],[18,121,632],"50a3f4c6-5f0e-11f0-82bf-0224a6c84d84","InputBox.tsx","b9f3a84f-3e6f-443a-8b19-8b3579823d81",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useRef, useState, useEffect } from \"react\";\nimport { Link } from \"react-router\";\nimport { PlusIcon, ArrowUpIcon, Square, XIcon } from \"./icons.tsx\";\nimport { processFiles } from \"../utils/images.ts\";\n\nexport function InputBox ({\n value,\n onChange,\n onSubmit,\n onCancel,\n running,\n error,\n images,\n setImages,\n} : {\n value: string;\n onChange: (e: React.KeyboardEvent) => void;\n onSubmit: (event: any) => void;\n onCancel: () => void;\n running: boolean;\n error: any;\n images: (string|null)[];\n setImages: (images: (string|null)[]) => void;\n}) {\n const form = useRef(null);\n\n if (error) console.error(error);\n\n const onKeyDown = (e) => {\n if (e.key === \"Enter\" && !e.shiftKey) {\n if (running) return;\n e.preventDefault();\n form.current?.dispatchEvent(new Event('submit', {\n bubbles: true,\n cancelable: true\n }));\n }\n }\n\n return (\n

\n {\n onSubmit(e);\n }}>\n \n Prompt\n \n

\n {\n onChange(e)\n }}\n onKeyDown={onKeyDown}\n autoFocus={true}\n />\n

\n \n

\n {running && (\n \n \n \n )}\n {!running && (\n \n \n \n )}\n

\n \n

\n );\n}\n\nexport function ImageDropContainer ({\n images,\n setImages,\n running,\n children,\n}: {\n images: (string|null)[];\n setImages: (images: (string|null)[]) => void;\n running: boolean;\n children: React.ReactNode;\n}) {\n const dragging = useImageDrop({ images, setImages, running });\n\n return (\n <>\n {children}\n {dragging && (\n

\n Drop images here to upload\n

\n )}\n \n );\n}\n\nexport function useImageDrop ({ images, setImages, running }: {\n images: (string|null)[];\n setImages(images: (string|null)[]) => void;\n running: boolean;\n}) {\n const [dragging, setDragging] = useState(false);\n\n const onDragEnter = (e: React.DragEvent) => {\n e.preventDefault();\n if (!e.dataTransfer?.types.includes('Files')) return;\n setDragging(true);\n }\n\n const onDragLeave = (e:React.DragEvent) => {\n e.preventDefault();\n if (!e.relatedTarget) {\n setDragging(false);\n }\n }\n\n const onDragOver = (e:React.DragEvent) => {\n e.preventDefault();\n }\n\n const onDrop = (e:React.DragEvent) => {\n e.preventDefault();\n setDragging(false);\n if (e.dataTransfer?.files && !running) {\n processFiles(Array.from(e.dataTransfer.files), images, setImages);\n }\n }\n\n useEffect(() => {\n document.addEventListener(\"dragenter\", onDragEnter);\n document.addEventListener(\"dragleave\", onDragLeave);\n document.addEventListener(\"dragover\", onDragOver);\n document.addEventListener(\"drop\", onDrop);\n\n return () => {\n document.removeEventListener(\"dragenter\", onDragEnter);\n document.removeEventListener(\"dragleave\", onDragLeave);\n document.removeEventListener(\"dragover\", onDragOver);\n document.removeEventListener(\"drop\", onDrop);\n }\n }, [images, setImages, running]);\n\n return dragging;\n}\n\nfunction ImageRow ({ images, setImages }: {\n images: (string|null)[];\n setImages: (images: (string|null)[]) => void;\n}) {\n return (\n

\n {images.map((image, i) => (\n {\n setImages([\n ...images.slice(0, i),\n ...images.slice(i + 1),\n ]);\n }}\n />\n ))}\n

\n );\n}\n\nfunction Thumbnail ({ image, onRemove }: {\n image: string|null;\n onRemove: () => void;\n}) {\n if (!image) return null;\n\n return (\n

\n \n \n \n \n

\n );\n}\n\nfunction UploadButton ({\n images,\n setImages,\n disabled,\n}: {\n images: (string|null)[];\n setImages: (images: (string|null)[]) => void;\n disabled: boolean;\n}) {\n const ref = useRef(null);\n\n return (\n

\n {\n ref.current?.click();\n }}\n className=\"icon-button\">\n \n

\n Upload image\n

\n \n {\n if (e.target.files) {\n processFiles(Array.from(e.target.files), images, setImages);\n }\n }}\n />\n

\n );\n}",[],[18,121,639],"50a3f20a-5f0e-11f0-82bf-0224a6c84d84","InlinePreview.tsx","1490132e-3131-4332-919c-5033b39bedd6",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useContext } from \"react\";\nimport { ProjectContext } from \"./ChatRouteSingleColumn.tsx\";\nimport { MessageContext } from \"./Messages.tsx\";\n\nexport function InlinePreview ({ part }) {\n const project = useContext(ProjectContext);\n const message = useContext(MessageContext);\n const {\n toolCallId,\n toolName,\n args,\n result,\n } = part.toolInvocation;\n\n if (!project.files?.length) return null;\n if (!args.path) return null;\n\n const path = args.path.replace(/^\\//, \"\");\n const file = project.files.find(f => f.path === path);\n if (!file) return null;\n if (!file.links.endpoint) return null;\n\n const lastFileToolCall = message?.parts\n .filter(p => p.toolInvocation)\n .map(p => p.toolInvocation)\n .findLast(t => t.args.path === args.path);\n const showPreview = message?.tail === message?.id && lastFileToolCall.toolCallId === toolCallId;\n\n return (\n

\n        {args.command} {file.path} {file.links.endpoint}\n

\n \n {file.path}\n \n

\n \n Open >>\n \n

\n {showPreview ? (\n \n ) : (\n null\n /* use screenshots when they support historical versions\n \n */\n )}\n

\n );\n}\n\n/*\nconst SCREENSHOT_URL = \"https://screenshots.valtown.net/screenshot.png\";\n\nfunction getScreenshotURL ({\n version,\n endpoint,\n width = 1024,\n height = 768,\n}) {\n const url = new URL(SCREENSHOT_URL);\n url.searchParams.append(\"width\", width);\n url.searchParams.append(\"height\", height);\n url.searchParams.append(\"version\", version);\n url.searchParams.append(\"url\", endpoint);\n return url;\n}\n*/\n",[],[18,121,646],"50a3edbe-5f0e-11f0-82bf-0224a6c84d84","Home.tsx","3d8ed96c-cae7-4b3f-a959-3e76d4627e4e",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport React, { useContext } from \"react\";\nimport { Link } from \"react-router\";\nimport { EyeIcon, FileCode2Icon, SparklesIcon, SquarePenIcon } from \"./icons.tsx\";\nimport { AppContext } from \"./App.tsx\";\n\nexport function Home() {\n const { user } = useContext(AppContext);\n\n return (\n

Welcome to Townie

Your AI-powered development assistant for Val Town projects

\n {user ? (\n \n View Projects\n \n ) : (\n \n Get Started\n \n )}\n

\n\n

What is Townie?

\n Townie is an AI-powered development assistant that lets you edit Val Town projects using Claude 4 Sonnet. It\n provides a seamless interface for discussing your code with Claude AI, which can directly view and modify\n files in your Val Town projects.\n

\n It uses agentic tool-calling, taking many read, write, and thinking steps autonomously when carrying out your\n instructions.\n

\n\n

Getting Started

\n Login with your Val Town API token (with projects:read, projects:write, user:read permissions)\n
Select a project to work on
Chat with Claude about your code
Watch as it makes changes directly to your files

\n\n

\n \n

AI-Assisted Editing

Chat with Claude about your code and let it make changes

\n\n

\n \n

File Browser

Select specific files to include in the context window

\n\n

\n \n

Branch Management

View, select, and create branches without leaving the app

\n\n

\n \n

Cost Tracking

See estimated API usage costs for each interaction

\n\n

Technical Details

Townie is built with:

React frontend with TypeScript
Hono API server backend
Web Audio API for sound notifications
AI SDK for Claude integration

\n The application proxies requests to the Anthropic API and Val Town API, allowing Claude to view and edit your\n project files directly.\n

\n \n View Source\n \n

\n );\n}",[],[18,121,653],"50a3e9d6-5f0e-11f0-82bf-0224a6c84d84","Header.tsx","4ea7ff05-42f1-4050-b2e2-066052b49008",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useEffect, useContext, useRef, useState } from \"react\";\nimport { Link, useNavigate } from \"react-router\";\nimport { useLocalStorage } from \"react-use\";\nimport { Circle, Volume2Icon, VolumeOffIcon } from \"./icons.tsx\";\nimport { AppContext } from \"./App.tsx\";\nimport { ValTownLogo } from \"./ValTownLogo.tsx\";\nimport CreditBalance from \"./CreditBalance.tsx\";\n\nexport function Header () {\n const navigate = useNavigate();\n const { user } = useContext(AppContext);\n\n return (\n

\n \n \n \n \n Townie\n \n

\n \n

\n );\n}\n\nfunction Dropdown () {\n const { user } = useContext(AppContext);\n const { ref, open, setOpen } = useDropdown();\n\n return (\n

\n {\n setOpen(!open);\n }}\n className=\"dropdown-trigger\">\n \n \n\n {open && (\n

\n \n \n \n \n

\n )}\n

\n );\n}\n\nfunction useDropdown() {\n const [open, setOpen] = useState(false);\n const ref = useRef(null);\n\n useEffect(() => {\n const handleClickOutside = (event) => {\n if (ref.current && !ref.current.contains(event.target)) {\n setOpen(false);\n }\n };\n\n document.addEventListener('mousedown', handleClickOutside);\n return () => document.removeEventListener('mousedown', handleClickOutside);\n }, []);\n\n return { ref, open, setOpen };\n}\n\nfunction Avatar ({ user }) {\n if (!user?.profileImageUrl) {\n return (\n

\n );\n }\n\n return (\n \n );\n}\n\nfunction LogOut () {\n const { user } = useContext(AppContext);\n return (\n <>\n \n \n );\n}\n\nfunction DarkButton () {\n const [dark, setDark] = useLocalStorage(\"DARK_MODE\", false);\n const toggle = () => {\n document.body.classList.toggle(\"dark\");\n setDark(!dark);\n }\n\n useEffect(() => {\n const cl = document.body.classList;\n if (dark && !cl.contains(\"dark\")) {\n cl.add(\"dark\");\n }\n }, []);\n\n return (\n \n \n {dark ? \"Light mode\" : \"Dark mode\"}\n \n );\n}\n\nfunction AudioButton () {\n const {audio, setAudio} = useContext(AppContext);\n\n const toggle = () => {\n setAudio(!audio);\n }\n\n return (\n \n {audio ? (\n <>\n \n Mute audio\n \n ) : (\n <>\n \n Unmute audio\n \n )}\n \n );\n}\n",[],[18,121,660],"50a3e666-5f0e-11f0-82bf-0224a6c84d84","Footer.tsx","e7203511-da6e-4158-9bbf-3d181de2632b",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport CreditBalance from \"./CreditBalance.tsx\";\n\nconst SOURCE_URL = \"https://val.town/x/valdottown/Townie\";\n\nexport function Footer () {\n return (\n \n );\n}\n",[],[18,121,667],"50a3e42c-5f0e-11f0-82bf-0224a6c84d84","DebugStyles.tsx","652d2fc7-86dd-4692-a3ff-8c5df7ae839b",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useRef, useEffect, useState } from \"react\";\nimport { TownieIcon } from \"./icons.tsx\";\nimport { Messages } from \"./Messages.tsx\";\n\nexport function DebugStyles() {\n const [pathname, setPathname] = useState(\"\");\n return (\n

Debug styles

\n\n

\n \n

\n\n

\n {\n const raw = e.target.value;\n if (!raw.includes(\"https://example.com\")) return;\n const next = raw\n .replace(\"https://example.com\", \"\")\n .replace(/^\\//, \"\");\n setPathname(next);\n }}\n className=\"url-input\"\n />\n

\n {/*\n

\n \n

\n */}\n\n

Example user message

\n \n Thinking...\n

\n Just thinking about life and stuff...\n

\n\n

\n \n

view:

\n main.tsx\n

Just looking at files

\n\n

This is a block of prose assistant messages

\n );\n}\n",[],[18,121,674],"50a3dffe-5f0e-11f0-82bf-0224a6c84d84","CreditBalance.tsx","fe442ab2-bfe8-4b39-a507-3ef46c3611c4",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState, useEffect } from \"react\";\nimport { Link } from \"react-router\";\n\nexport default function CreditBalance() {\n const [balance, setBalance] = useState(null);\n const [loading, setLoading] = useState(true);\n\n const fetchBalance = async () => {\n try {\n const response = await fetch(\"/api/credit-balance\");\n if (response.ok) {\n const data = await response.json();\n console.log(\"CreditBalance: data.balance: \", data.balance);\n setBalance(data.balance);\n } else {\n console.error(\"Failed to fetch balance\");\n }\n } catch (err) {\n console.error(\"Error fetching balance:\", err);\n } finally {\n setLoading(false);\n }\n };\n\n useEffect(() => {\n fetchBalance();\n }, []);\n\n if (loading) {\n return (\n

\n Loading...\n

\n );\n }\n\n if (balance === null) {\n return (\n

\n Balance unavailable\n

\n );\n }\n\n const isLow = balance < 1; // Show warning if less than $1\n\n return (\n \n ${balance.toFixed(2)}\n {\" \"}\n credits\n \n );\n}\n",[],[18,121,681],"50a3d7f2-5f0e-11f0-82bf-0224a6c84d84","ChatRouteSingleColumn.tsx","356b530b-aaa1-4b08-89b1-08a0b9be5c85",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useState, useEffect, useContext, createContext, useRef } from \"react\";\nimport { useParams, Link } from \"react-router\";\n\nimport { AppContext } from \"./App.tsx\";\nimport { useProject } from \"../hooks/useProject.tsx\";\nimport { useChatLogic } from \"../hooks/useChatLogic.ts\";\nimport { useLoadingFavicon } from \"../hooks/useLoadingFavicon.ts\";\nimport { useUsageStats } from \"../hooks/useUsageStats.ts\";\nimport { useCreditBalance } from \"../hooks/useCreditBalance.tsx\";\nimport { Messages } from \"./Messages.tsx\";\nimport { InputBox, ImageDropContainer } from \"./InputBox.tsx\";\nimport { PreviewFrame } from \"./PreviewFrame.tsx\";\nimport { BranchSelect } from \"./BranchSelect.tsx\";\nimport { Loading } from \"./Loading.tsx\";\nimport { Footer } from \"./Footer.tsx\";\nimport { RefreshIcon } from \"./icons.tsx\";\n\nexport const ProjectContext = createContext(null);\n\n// alt single-column version of /chat route\nexport function ChatRouteSingleColumn () {\n const { projectId, branchId } = useParams() as {\n projectId: string;\n branchId?: string;\n };\n\n const project = useProject(projectId, branchId);\n\n if (project.loading) {\n return \n }\n\n if (project.error) {\n return (\n

\n Error: {JSON.stringify(project.error, null, 2)}\n

\n );\n }\n\n\n if (!project.data) return null;\n\n return (\n \n \n \n );\n}\n\nfunction Conversation ({\n project,\n files,\n branchId,\n refetch,\n}: {\n project: any;\n files: any[];\n branchId: string;\n refetch: () => void;\n}) {\n const [images, setImages] = useState<(string|null)[]>([]);\n const [selectedFiles, setSelectedFiles] = useState([]);\n const { audio, user } = useContext(AppContext);\n const { balance, loading: balanceLoading, refetch: refetchBalance } = useCreditBalance();\n\n const {\n messages,\n error,\n input,\n handleInputChange,\n handleSubmit,\n handleStop,\n running,\n usages,\n messageEndTimes,\n overLimit,\n } = useChatLogic({\n project,\n branchId,\n selectedFiles,\n images,\n soundEnabled: audio,\n });\n\n useLoadingFavicon(running);\n\n // Track when requests end and refetch balance\n const prevRunning = useRef(running);\n useEffect(() => {\n // If running changed from true to false, request just ended\n if (prevRunning.current === true && running === false) {\n refetchBalance();\n }\n prevRunning.current = running;\n }, [running, refetchBalance]);\n\n // Auto-poll balance every 4 seconds when credits are insufficient\n useEffect(() => {\n const hasInsufficientCredits = !balanceLoading && balance !== null && balance <= 0;\n \n if (hasInsufficientCredits) {\n const intervalId = setInterval(() => {\n refetchBalance();\n }, 4000); // 4 seconds\n \n return () => clearInterval(intervalId);\n }\n }, [balanceLoading, balance, refetchBalance]);\n\n useEffect(() => {\n if (!messages?.length) return;\n let last = messages.at(-1);\n if (shouldRefetch(last)) {\n refetch();\n }\n }, [messages]);\n useUsageStats(messages, usages);\n\n if (!project) {\n return (\n

\n Error loading project\n

\n );\n }\n\n const hasInsufficientCredits = !balanceLoading && balance !== null && balance <= 0;\n\n return (\n \n

\n \n {project.imageUrl ? (\n

\n ) : user?.profileImageUrl ? (\n \n ) : (\n

\n )}\n

{project.name}

\n \n

\n\n \n {error && !overLimit && (\n

{error.stack}

\n )}\n\n

\n {hasInsufficientCredits ? (\n

\n \n Townie has moved to usage-based pricing. {\" \"}\n Learn more & purchase credits.\n \n

\n {\n refetchBalance();\n }}\n className=\"icon-button\"\n title=\"Refresh credit balance\"\n >\n \n \n

\n ) : (\n {\n handleSubmit(e);\n setImages([]);\n }}\n onCancel={handleStop}\n running={running}\n error={error}\n images={images}\n setImages={setImages}\n />\n )}\n

\n \n );\n}\n\nfunction shouldRefetch (message) {\n for (let i = 0; i < message?.parts?.length; i++) {\n let part = message.parts[i];\n if (part.type === \"tool-invocation\") {\n switch (part.toolInvocation?.toolName) {\n case \"str_replace_editor\":\n if (part.toolInvocation?.args?.command === \"create\") {\n return true;\n }\n break;\n case \"delete_file\":\n case \"change_val_type\":\n return true;\n }\n }\n }\n return false;\n}",[],[18,121,688],"50a3d50e-5f0e-11f0-82bf-0224a6c84d84","BranchSelect.tsx","e4a2e2e4-84be-4b71-ba9b-4be4aa41142b",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport { useMemo } from \"react\";\nimport { useNavigate, useParams } from \"react-router\";\nimport { useBranches } from \"../hooks/useBranches.tsx\";\nimport { useCreateBranch } from \"../hooks/useCreateBranch.tsx\";\n\nconst NEW_BRANCH_VAL = \"__NEW_BRANCH__\";\n\nexport function BranchSelect() {\n const { projectId, branchId } = useParams() as {\n projectId: string;\n branchId: string;\n };\n const navigate = useNavigate();\n const branches = useBranches(projectId);\n const createBranch = useCreateBranch(projectId);\n\n const branch = useMemo(() => {\n if (!branchId) return \"main\";\n if (!branches.data) return \"\";\n const b = branches.data.find((b) => b.id === branchId);\n return b?.name ?? \"main\";\n }, [branchId, branches.data]);\n\n const createBranchPrompt = () => {\n const branchName = window.prompt(\"Create new branch\");\n if (branchName === null || branchName === \"\") return;\n console.log(\"create branch\", branchName);\n createBranch.createBranch({ name: branchName }).then((res) => {\n if (res.error) {\n window.alert(res.error);\n return;\n }\n branches.refetch();\n if (res?.branch?.id) {\n navigate(`/chat/${projectId}/branch/${res.branch.id}`);\n }\n });\n };\n\n const handleChange = (e) => {\n const name = e.target.value;\n if (name === NEW_BRANCH_VAL) {\n return createBranchPrompt();\n }\n const next = branches.data?.find((b) => b.name === name);\n if (next?.id) {\n navigate(`/chat/${projectId}/branch/${next.id}`);\n }\n };\n\n return (\n <>\n \n Branch\n \n \n {branches.loading && }\n {branches.data?.map((branch) => (\n \n ))}\n \n \n \n );\n}\n",[],[18,121,695],"50a3d3a6-5f0e-11f0-82bf-0224a6c84d84","App.tsx","d58d7bef-ef35-449b-85d0-62c0ce5652ed",["D",1752317553464],"/** @jsxImportSource https://esm.sh/react@18.2.0?dev */\nimport React, { createContext, useState } from \"react\";\nimport { BrowserRouter, Link, Navigate, Outlet, Route, Routes, useLocation } from \"react-router\";\nimport { useLocalStorage } from \"react-use\";\nimport { useUser } from \"../hooks/useUser.tsx\";\nimport { ChatRouteSingleColumn } from \"./ChatRouteSingleColumn.tsx\";\nimport { DebugStyles } from \"./DebugStyles.tsx\";\nimport { LayoutRoute } from \"./LayoutRoute.tsx\";\nimport { NewProjectRoute } from \"./NewProjectRoute.tsx\";\nimport { NotFoundRoute } from \"./NotFoundRoute.tsx\";\nimport { ProjectsRoute } from \"./ProjectsRoute.tsx\";\nimport PurchaseCreditsRoute from \"./PurchaseCreditsRoute.tsx\";\n\nexport const AppContext = createContext({\n audio: false,\n setAudio: () => {},\n user: null,\n});\n\nexport function App() {\n const [audio, setAudio] = useLocalStorage(\"AUDIO\", false);\n const user = useUser();\n\n return (\n \n \n \n }>\n } />\n } />\n } />\n } />\n } />\n \n \n \n \n );\n}",[],[18,121,702],["D",1752317553464],[309,310,311,312,313,314,315,316,317,318,319,320,321,322,323,324,325,326,327,328,329],[18,121],["D",1752317553464],[308,330,342,344,347,348,349],[18],"50a3d108-5f0e-11f0-82bf-0224a6c84d84","9efa612c-b2bc-4243-a448-9e16fdd7cda6","e828a84b-bc6f-40cf-852d-6e42eeb47082",["D",1752317553464],"import { Hono } from \"npm:hono\";\nimport createBranchApp from \"./routes/create-branch.ts\";\nimport createProjectApp from \"./routes/create-project.ts\";\nimport creditBalanceApp from \"./routes/credit-balance.ts\";\nimport projectBranchesApp from \"./routes/project-branches.ts\";\nimport projectFilesApp from \"./routes/project-files.ts\";\nimport projectsLoaderApp from \"./routes/projects-loader.ts\";\nimport projectApp from \"./routes/project.ts\";\nimport purchaseCreditsApp from \"./routes/purchase-credits.ts\";\nimport sendMessageApp from \"./routes/send-message.ts\";\nimport stripeWebhookApp from \"./routes/stripe-webhook.ts\";\nimport userRoute from \"./routes/user.ts\";\n\nexport const app = new Hono();\n\napp.route(\"/send-message\", sendMessageApp);\napp.route(\"/projects-loader\", projectsLoaderApp);\napp.route(\"/project-files\", projectFilesApp);\napp.route(\"/project-branches\", projectBranchesApp);\napp.route(\"/project\", projectApp);\napp.route(\"/create-branch\", createBranchApp);\napp.route(\"/create-project\", createProjectApp);\napp.route(\"/purchase-credits\", purchaseCreditsApp);\napp.route(\"/credit-balance\", creditBalanceApp);\napp.route(\"/stripe-webhook\", stripeWebhookApp);\napp.route(\"/user\", userRoute);\n\n// This is the entry point for HTTP vals\nexport default app.fetch;\n",[],[721,363],"backend","50a3ce74-5f0e-11f0-82bf-0224a6c84d84","fileWithLinesNumbers.ts","411f75c1-3674-4ee4-b823-9d9063fbb110","55e96349-3d58-4e7e-83a3-c9e389c75816",["D",1752317553464],"export default function fileWithLineNumbers(text: string, view_range) {\n const lines = text.split(\"\\n\")\n .map((line, index) => (index + 1) + \": \" + line)\n\n if (view_range) {\n return lines.slice(view_range[0] - 1, view_range[1]).join(\"\\n\")\n }\n \n return lines.join(\"\\n\")\n}",[],[721,91,723],"50a3ccf8-5f0e-11f0-82bf-0224a6c84d84","calculateCost.tsx","34e657bd-5900-4f17-9704-103d1cd7c221",["D",1752317553464],"// Rates for Claude 4 Sonnet (per million tokens)\nconst INPUT_RATE = 3.0; // $3.00 per M input tokens\nconst OUTPUT_RATE = 15.0; // $15.00 per M output tokens\nconst CACHE_READ_RATE = 0.30; // $0.30 per M cache-read tokens\nconst CACHE_WRITE_RATE = 3.75; // $3.75 per M cache-write tokens\n\nexport function calculateCost({\n input_tokens,\n output_tokens,\n cache_read_tokens = 0,\n cache_write_tokens = 0,\n}: {\n input_tokens: number;\n output_tokens: number;\n cache_read_tokens?: number;\n cache_write_tokens?: number;\n}): number {\n // Convert token counts to millions\n const inMillions = (n: number) => n / 1_000_000;\n\n const inputCost = inMillions(input_tokens) * INPUT_RATE;\n const outputCost = inMillions(output_tokens) * OUTPUT_RATE;\n const cacheReadCost = inMillions(cache_read_tokens) * CACHE_READ_RATE;\n const cacheWriteCost = inMillions(cache_write_tokens) * CACHE_WRITE_RATE;\n\n return inputCost + outputCost + cacheReadCost + cacheWriteCost;\n}",[],[721,91,731],"50a3cfb4-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[304,305],[721,91],"50a3c6f4-5f0e-11f0-82bf-0224a6c84d84","traces.ts","45094e62-135c-48c4-b62f-c42dd17ddad2","20a2cb6e-8baf-486e-88b9-d63909b143b3",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@1.4.0\";\nimport { tool } from \"npm:ai\";\nimport { z } from \"npm:zod\";\n\nexport const makeTracesTool = (\n { bearerToken, project, branch_id }: {\n bearerToken: string;\n project: any;\n branch_id?: string;\n },\n) =>\n tool({\n // We're calling traces \"requests\" because Townie might understand that terminology better\n description:\n \"Use this tool to get the most recent requests and logs for a specific file. Use it to debug runtime issues and get a full picture of what happened during execution. \" +\n \"You'll be able to see all attributes of the request and if an error has occured, including its message and stack trace\",\n parameters: z.object({\n path: z.string().optional().describe(\n \"The file path to get requests info for (e.g., 'backend/index.ts'). Don't start the path with a /\",\n ),\n }),\n execute: async ({ path }) => {\n const vt = new ValTown({ bearerToken });\n\n try {\n const file = await vt.vals.files.retrieve(project.id, {\n limit: 1,\n offset: 0,\n path: path,\n branch_id: branch_id,\n recursive: true,\n });\n\n // Gets the most recent 5 traces in the last 60 seconds\n const traces = await vt.telemetry.traces.list({\n end: new Date().toISOString(),\n limit: 3,\n start: new Date(Date.now() - 60 * 1000).toISOString(),\n file_id: file.data[0].id,\n });\n\n return {\n type: \"success\",\n data: await Promise.all(traces.data.map(async (trace) => {\n const attrs = trace.attributes.reduce((acc, attr) => {\n acc[attr.key] = attr.value.stringValue || attr.value.intValue ||\n attr.value.boolValue;\n return acc;\n }, {});\n\n const startTime = new Date(\n parseInt(trace.startTimeUnixNano) / 1000000,\n );\n const endTime = new Date(parseInt(trace.endTimeUnixNano) / 1000000);\n const duration = endTime.getTime() - startTime.getTime();\n\n // Extract HTTP headers\n const requestHeaders = {};\n const responseHeaders = {};\n Object.keys(attrs).forEach((key) => {\n if (key.startsWith(\"http.request.header.\")) {\n requestHeaders[key.replace(\"http.request.header.\", \"\")] =\n attrs[key];\n } else if (key.startsWith(\"http.response.header.\")) {\n responseHeaders[key.replace(\"http.response.header.\", \"\")] =\n attrs[key];\n }\n });\n\n const logs = await vt.telemetry.logs.list({\n end: new Date().toISOString(),\n limit: 100,\n trace_ids: [trace.traceId],\n });\n\n const logsFormatted = logs.data.map((log) => {\n const timestamp = new Date(parseInt(log.timeUnixNano) / 1_000_000);\n const message = log.body.stringValue;\n return `[${timestamp.toISOString()}] ${log.severityText}: ${message}`;\n });\n\n return {\n traceId: trace.traceId,\n method: attrs[\"http.request.method\"],\n url: attrs[\"url.full\"],\n status: attrs[\"http.response.status_code\"],\n fileId: attrs[\"val.file_id\"],\n duration: `${duration}ms`,\n startTime: startTime.toISOString(),\n endTime: endTime.toISOString(),\n requestHeaders,\n responseHeaders,\n error: trace.status?.message || null,\n logs: logsFormatted,\n };\n })),\n };\n } catch (e: any) {\n return {\n type: \"error\",\n message: `Error fetching traces: ${e.message}`,\n };\n }\n },\n });",[],[721,749,742],"tools","50a3c58c-5f0e-11f0-82bf-0224a6c84d84","think.ts","26b0ae8f-403b-42d0-b873-f39ed06ac9bc",["D",1752317553464],"import { tool } from \"npm:ai\";\nimport { z } from \"npm:zod\";\n\n/**\n * Tool for thinking through complex problems without making external changes\n */\nexport const thinkTool = tool({\n description:\n \"Use the tool to think about something. It will not obtain new information or change the database, but just append the thought to the log. Use it when complex reasoning or some cache memory is needed.\",\n parameters: z.object({\n thought: z.string().describe(\"A thought to think about.\"),\n }),\n execute: async ({ thought }) => {\n return { \n type: 'success', \n data: \"Thought recorded\" \n };\n },\n});",[],[721,749,751],"50a3bcb8-5f0e-11f0-82bf-0224a6c84d84","text-editor.ts","3b834958-ee0e-426f-ae3d-f5a2984806dc",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { tool } from \"npm:ai\";\nimport { z } from \"npm:zod\";\nimport fileWithLinesNumbers from \"../utils/fileWithLinesNumbers.ts\";\n\nfunction printFileType(file: any) {\n if (file.type === \"interval\")\n return \" (cron)\";\n else if (file.type === \"http\" || file.type === \"email\")\n return \" (\" + file.type + \")\";\n else return \"\";\n}\n\n/**\n * Creates a comprehensive text editor tool for editing files in a Val Town project\n * Combines all file operations: view, create, edit, delete, and overwrite\n */\nexport const makeTextEditorTool = (\n { bearerToken, project, branch_id }: { bearerToken: string; project: any; branch_id: string | undefined },\n) =>\n tool({\n description: `Tool for viewing, creating and editing files\n* State is persistent across command calls and discussions with the user\n* If \\`path\\` is a file, \\`view\\` displays the result of applying \\`cat -n\\`. If \\`path\\` is a directory, \\`view\\` lists files and directories\n* The \\`create\\` command cannot be used if the specified \\`path\\` already exists as a file\n\nNotes for using the \\`str_replace\\` command:\n* The \\`old_str\\` parameter should match EXACTLY one or more consecutive lines from the original file. Be mindful of whitespaces!\n* If the \\`old_str\\` parameter is not unique in the file, the replacement will not be performed. Make sure to include enough context in \\`old_str\\` to make it unique\n* The \\`new_str\\` parameter should contain the edited lines that should replace the \\`old_str\\``,\n parameters: z.object({\n command: z.enum([\"view\", \"create\", \"str_replace\", \"insert\", \"undo_edit\", \"delete\", \"overwrite\"]).describe(\n \"The commands to run. Allowed options are: `view`, `create`, `str_replace`, `insert`, `delete`, `overwrite`.\",\n ),\n path: z.string().describe(\"Absolute path to file or directory, e.g. `/repo/file.py` or `/repo`.\"),\n file_text: z.string().optional().describe(\n \"Required parameter of `create` command, with the content of the file to be created.\",\n ),\n insert_line: z.number().optional().describe(\n \"Required parameter of `insert` command. The `new_str` will be inserted AFTER the line `insert_line` of `path`.\",\n ),\n new_str: z.string().optional().describe(\n \"Optional parameter of `str_replace` command containing the new string (if not given, no string will be added). Required parameter of `insert` command containing the string to insert.\",\n ),\n old_str: z.string().optional().describe(\n \"Required parameter of `str_replace` command containing the string in `path` to replace.\",\n ),\n view_range: z.array(z.number()).optional().describe(\n \"Optional parameter of `view` command when `path` points to a file. If none is given, the full file is shown. If provided, the file will be shown in the indicated line number range, e.g. [11, 12] will show lines 11 and 12. Indexing at 1 to start. Setting `[start_line, -1]` shows all lines from `start_line` to the end of the file.\",\n ),\n content: z.string().optional().describe(\n \"Required parameter of `overwrite` command containing the new content for the file.\",\n ),\n }),\n execute: async ({ command, path, file_text, insert_line, new_str, old_str, view_range, content }) => {\n const vt = new ValTown({ bearerToken });\n\n try {\n console.log({\n command,\n path,\n file_text,\n insert_line,\n new_str,\n old_str,\n view_range,\n content,\n });\n\n // VIEW command\n if (command === \"view\") {\n if (path.endsWith(\"/\")) {\n try {\n const files = await vt.projects.files.retrieve(project.id, {\n path: path.slice(0, -1),\n limit: 100,\n offset: 0,\n recursive: true,\n branch_id,\n });\n return {\n type: \"success\",\n data: files.data.map(file => file.path + printFileType(file)).join(\"\\n\"),\n };\n } catch (e: any) {\n return {\n type: \"error\",\n message: `Error listing directory: ${e.message}`,\n };\n }\n }\n try {\n const file = await vt.projects.files.getContent(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n branch_id,\n });\n const text = await file.text();\n return {\n type: \"success\",\n data: fileWithLinesNumbers(text, view_range),\n };\n } catch (e: any) {\n console.log(e.stack);\n return {\n type: \"error\",\n message: \"File not found\",\n };\n }\n }\n\n // STR_REPLACE command\n if (command === \"str_replace\") {\n if (old_str === undefined) {\n return {\n type: \"error\",\n message: \"Missing required parameter 'old_str' for str_replace command\",\n };\n }\n\n try {\n const file = await vt.projects.files.getContent(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n branch_id,\n });\n console.log(\"Found file\");\n const text = await file.text();\n let matches = text.split(old_str).length - 1;\n\n if (matches === 0) {\n return {\n type: \"error\",\n message: \"No match found for replacement. Please check your text and try again.\",\n };\n }\n\n if (matches > 1) {\n return {\n type: \"error\",\n message:\n `Found ${matches} matches for replacement text. Please provide more context to make a unique match.`,\n };\n }\n\n let newText = text.replace(old_str, new_str || \"\");\n const resp = await vt.projects.files.update(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n content: newText,\n branch_id,\n });\n\n return {\n type: \"success\",\n data: \"String replaced successfully\",\n };\n } catch (e: any) {\n console.log(e.stack);\n return {\n type: \"error\",\n message: \"File not found\",\n };\n }\n }\n\n // CREATE command\n if (command === \"create\") {\n let type_: \"file\" | \"http\" | \"script\";\n if (path.includes(\"backend/index.ts\")) type_ = \"http\";\n if (file_text?.includes(\"export default app.fetch\")) type_ = \"http\";\n if ([\".ts\", \".tsx\", \".js\", \".jsx\"].some(ext => path.endsWith(ext))) {\n type_ = \"script\";\n } else {\n type_ = \"file\";\n }\n\n try {\n const resp = await vt.projects.files.create(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n content: file_text ?? \"\",\n type: type_, // For now, folks have to change the types in the UI\n branch_id,\n });\n\n return {\n type: \"success\",\n data: \"File created successfully\",\n };\n } catch (e) {\n console.log(e.stack);\n return {\n type: \"error\",\n message: \"Could not create file. It likely already exists.\",\n };\n }\n }\n\n // INSERT command\n if (command === \"insert\") {\n try {\n const file = await vt.projects.files.getContent(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n branch_id,\n });\n console.log(\"found file\");\n const text = await file.text();\n\n const lines = text.split(\"\\n\");\n lines.splice(insert_line ?? 0, 0, new_str ?? \"\");\n\n const newText = lines.join(\"\\n\");\n const resp = await vt.projects.files.update(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n content: newText,\n branch_id,\n });\n\n return {\n type: \"success\",\n data: \"Text inserted successfully\",\n };\n } catch (e: any) {\n console.log(e.stack);\n return {\n type: \"error\",\n message: \"File not found\",\n };\n }\n }\n\n // DELETE command\n if (command === \"delete\") {\n try {\n await vt.projects.files.delete(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n branch_id,\n });\n return {\n type: \"success\",\n data: \"File deleted\",\n };\n } catch (e: any) {\n return {\n type: \"error\",\n message: \"Error deleting file: \" + e.message,\n };\n }\n }\n\n // OVERWRITE command\n if (command === \"overwrite\") {\n if (!content) {\n return {\n type: \"error\",\n message: \"Missing required parameter 'content' for overwrite command\",\n };\n }\n\n try {\n await vt.projects.files.update(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n content,\n branch_id,\n });\n\n return {\n type: \"success\",\n data: \"File replaced successfully\",\n };\n } catch (e: any) {\n return {\n type: \"error\",\n message: \"Error replacing file: \" + e.message,\n };\n }\n }\n\n return {\n type: \"error\",\n message: \"Command unknown\",\n };\n } catch (e: any) {\n console.error(e);\n return {\n type: \"error\",\n message: e.stack,\n };\n }\n },\n });",[],[721,749,758],"50a3bb1e-5f0e-11f0-82bf-0224a6c84d84","5301596c-5178-41c6-9d5c-d1f5893b8128",["D",1752317553464],"import { makeChangeValTypeTool } from \"./change-val-type.ts\";\nimport { makeFetchTool } from \"./fetch.ts\";\nimport { makeTextEditorTool } from \"./text-editor.ts\";\nimport { makeTracesTool } from \"./traces.ts\";\nimport { thinkTool } from \"./think.ts\";\n\nexport { \n makeTextEditorTool, \n makeChangeValTypeTool, \n makeFetchTool,\n makeTracesTool,\n thinkTool,\n};",[],[721,749,363],"50a3b6b4-5f0e-11f0-82bf-0224a6c84d84","fetch.ts","37ace388-186f-446d-b8dd-e85b7c91421c",["D",1752317553464],"/**\n * Tool for making HTTP requests to vals and returning the response\n * This allows the AI to debug HTTP vals by seeing their responses\n */\n\nimport { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { tool } from \"npm:ai\";\nimport { z } from \"npm:zod\";\n\n/**\n * Creates a tool for making HTTP requests to vals in a Val Town project\n */\nexport const makeFetchTool = (\n { bearerToken, project, branch_id }: { bearerToken?: string; project?: any; branch_id?: string } = {},\n) =>\n tool({\n name: \"fetch\",\n description:\n \"Make an HTTP request to a Val Town val and return the response. Useful for testing HTTP vals. The HTTP response body will be truncated to 5000 characters.\",\n parameters: z.object({\n valPath: z.string().describe(\n \"The path to the val in the current project (e.g., '/index.ts', '/backend/routes/user.ts')\",\n ),\n urlPath: z.string().optional().describe(\"The URL path to make the request to. Defaults to '/'.\"),\n method: z.enum([\"GET\", \"POST\", \"PUT\", \"DELETE\", \"PATCH\", \"HEAD\", \"OPTIONS\"]).optional().describe(\n \"The HTTP method to use. Defaults to GET.\",\n ),\n headers: z.record(z.string()).optional().describe(\"Optional headers to include in the request.\"),\n body: z.string().optional().describe(\n \"Optional body to include in the request. For JSON, provide a stringified JSON object.\",\n ),\n }),\n execute: async ({ valPath, urlPath = \"/\", method = \"GET\", headers = {}, body }: {\n valPath: string;\n urlPath: string;\n method: string;\n headers: Record;\n body: string;\n }) => {\n if (!bearerToken) {\n return {\n type: \"error\",\n message: \"No bearer token provided\",\n };\n }\n\n if (!project || !project.id) {\n return {\n type: \"error\",\n message: \"No project information provided\",\n };\n }\n\n // Create ValTown client\n const vt = new ValTown({ bearerToken });\n\n // Normalize the path (remove leading slash if present)\n const normalizedPath = valPath.startsWith(\"/\") ? valPath.slice(1) : valPath;\n\n let filesResponse;\n try {\n // Get the val's metadata to check if it's an HTTP val\n filesResponse = await vt.projects.files.retrieve(project.id, {\n path: normalizedPath,\n recursive: false,\n branch_id: branch_id || undefined,\n });\n } catch (error) {\n return {\n type: \"error\",\n message: `Error fetching val at path '${valPath}': ${error.message}`,\n };\n }\n const file = filesResponse?.data[0];\n\n if (!file) {\n return {\n type: \"error\",\n message: `Could not find val at path '${valPath}'`,\n };\n }\n\n if (file.type !== \"http\") {\n return {\n type: \"error\",\n message: `The val at path '${valPath}' is not an HTTP val. Only HTTP vals can be called with fetch.`,\n };\n }\n\n // Get the HTTP endpoint URL\n const valEndpoint = file.links?.endpoint;\n\n if (!valEndpoint) {\n return {\n type: \"error\",\n message: `Could not find HTTP endpoint for val at path '${valPath}'`,\n };\n }\n\n // Make the HTTP request to the val's endpoint\n const options: RequestInit = {\n method,\n headers,\n };\n\n if (body && [\"POST\", \"PUT\", \"PATCH\"].includes(method)) {\n options.body = body;\n }\n\n // Normalize the url path (remove leading slash if present)\n const normalizedURLPath = urlPath.startsWith(\"/\") ? urlPath : \"/\" + urlPath;\n\n // Make the request and measure response time\n const startTime = Date.now();\n let response;\n try {\n response = await fetch(valEndpoint + normalizedURLPath, options);\n } catch (error: any) {\n // Return error information\n return {\n type: \"error\",\n message: `Error making request: ${error.message}`,\n };\n }\n const endTime = Date.now();\n const responseTime = endTime - startTime;\n\n // Get response headers\n const responseHeaders: Record = {};\n response.headers.forEach((value, key) => {\n responseHeaders[key] = value;\n });\n\n // Get content type\n const contentType = response.headers.get(\"content-type\") || \"\";\n\n // Process response body based on content type\n let responseBody = await response.text();\n\n return {\n type: \"success\",\n data: {\n status: response.status,\n statusText: response.statusText,\n headers: responseHeaders,\n body: responseBody.substring(0, 5000),\n contentType,\n responseTime,\n url: valEndpoint,\n },\n };\n },\n });",[],[721,749,771],"50a3b56a-5f0e-11f0-82bf-0224a6c84d84","change-val-type.ts","01d4c79d-1955-418e-9b8e-59438ef8eed0",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { tool } from \"npm:ai\";\nimport { z } from \"npm:zod\";\n\n/**\n * Creates a tool for updated file triggers Val Town projects\n */\nexport const makeChangeValTypeTool = (\n { bearerToken, project, branch_id }: { bearerToken: string; project: any; branch_id: string },\n) =>\n tool({\n description: `Use this tool to edit the HTTP, cron or email triggers on a file.\nA file can only have zero or one triggers.\nThe cron schedule ccannot be set via this tool. If you create a cron, inform the user to change its schedule in the Val Town web UI.`,\n parameters: z.object({\n path: z.string().describe(\"The file path to add or remove the trigger to\"),\n type: z.enum([\"http\", \"email\", \"cron\", \"none\"]).describe(\"The type of trigger to add\"),\n }),\n execute: async ({ path, type }: { path: string, type: string }) => {\n const vt = new ValTown({ bearerToken });\n try {\n await vt.projects.files.update(project.id, {\n path: path.startsWith(\"/\") ? path.slice(1) : path,\n branch_id,\n type: type === \"cron\" \n ? \"interval\"\n : type === \"none\" && [\".ts\", \".tsx\", \".js\", \".jsx\"].some(ext => path.endsWith(ext))\n ? \"script\"\n : type === \"none\"\n ? \"file\"\n : type\n });\n } catch (e: any) {\n return { \n type: 'error', \n message: \"Error updating file type: \" + e.message \n };\n }\n return { \n type: 'success', \n data: `File ${path} updated to have ${type} trigger` \n };\n },\n });",[],[721,749,778],"50a3cb9a-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[297,298,299,300,301,302],[721,749],"50a3b290-5f0e-11f0-82bf-0224a6c84d84","user.ts","e2cd4bb6-8dd6-4deb-b056-fd73b5b86a3b","4a93b5bc-f34c-488e-8598-ec551194486e",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\n// used to check authentication\napp.get(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return Response.json(\"Please provide a bearer token\", { status: 401 });\n }\n\n const vt = new ValTown({ bearerToken });\n const user = await vt.me.profile.retrieve();\n\n return c.json(user);\n});\n\nexport default app;\n",[],[721,110,789],"50a3ad7c-5f0e-11f0-82bf-0224a6c84d84","stripe-webhook.ts","c6a3243e-b55a-4032-883f-381fbc352568",["D",1752317553464],"import { discordWebhook } from \"https://esm.town/v/stevekrouse/discordWebhook/main.ts\";\nimport { Hono } from \"npm:hono\";\nimport Stripe from \"npm:stripe\";\nimport { getEnvVarName } from \"../../shared/is-prod-branch.ts\";\nimport { addCredits } from \"../database/queries.tsx\";\n\nconst app = new Hono();\n\nconst stripe = new Stripe(Deno.env.get(getEnvVarName(\"STRIPE_SECRET_KEY\")) as string, {\n apiVersion: \"2024-06-20\",\n});\n\napp.post(\"/\", async (c) => {\n const body = await c.req.text();\n // Get raw body as bytes for signature verification\n // const rawBody = await c.req.arrayBuffer();\n // const body = new TextDecoder().decode(rawBody);\n const signature = c.req.header(\"Stripe-Signature\");\n\n if (!signature) {\n console.error(\"Missing Stripe signature\");\n return c.json({ error: \"Missing signature\" }, 400);\n }\n\n let event: Stripe.Event;\n\n try {\n // Verify webhook signature for security\n event = await stripe.webhooks.constructEventAsync(\n body,\n signature,\n Deno.env.get(getEnvVarName(\"STRIPE_WEBHOOK_SECRET\"))!,\n );\n } catch (err) {\n console.error(\"Webhook signature verification failed:\", err);\n return c.json({ error: \"Invalid signature\" }, 400);\n }\n\n if (event.type === \"checkout.session.completed\" && event.data.object.metadata.source === \"townie_credits\") {\n console.log(\"checkout.session.completed event: \", JSON.stringify(event, null, 2));\n\n const session = event.data.object as Stripe.Checkout.Session;\n\n if (!session.client_reference_id) {\n console.error(\"No client reference id found on checkout session:\", session.id);\n return c.json({ error: \"Missing payment intent\" }, 400);\n }\n\n try {\n // TODO: could not get the SDK working but would be great to use this instead of the fetch\n // const paymentIntent: Stripe.PaymentIntent = await stripe.paymentIntents.retrieve(session.client_reference_id);\n\n const response = await fetch(`https://api.stripe.com/v1/payment_intents/${session.client_reference_id}`, {\n method: \"GET\",\n headers: {\n \"Authorization\": `Bearer ${Deno.env.get(getEnvVarName(\"STRIPE_SECRET_KEY\"))}`,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n });\n\n if (!response.ok) {\n throw new Error(`Failed to retrieve payment intent: ${response.status} ${response.statusText}`);\n }\n\n const paymentIntent = await response.json() as Stripe.PaymentIntent;\n\n const userId = paymentIntent.metadata.user_id;\n const username = paymentIntent.metadata.username || \"unknown\";\n const purchaseSource = paymentIntent.metadata.purchase_source || \"unknown\";\n\n if (!userId) {\n console.error(\"Missing user_id in payment intent metadata:\", paymentIntent.id);\n return c.json({ error: \"Missing user metadata\" }, 400);\n }\n\n // Convert cents to dollars\n const dollars = paymentIntent.amount / 100;\n\n // Add credits to user account\n await addCredits(\n userId,\n dollars,\n `Stripe purchase - ${username} - ${purchaseSource}`,\n paymentIntent.id,\n );\n\n console.log(`Added $${dollars} credits to user ${userId} (${username}) from payment ${paymentIntent.id}`);\n\n let editLink = `([edit](${sourceURL(Error())}))`;\n await discordWebhook({\n url: Deno.env.get(\"DISCORD_WEBHOOK_URL\")!,\n content: `🤖💸 [@${username}](https://val.town/u/${username}) bought $${dollars} Townie credits ${editLink}`,\n flags: [\"SUPPRESS_EMBEDS\"],\n });\n\n return c.json({ success: true });\n } catch (error) {\n console.error(\"Failed to process checkout.session.completed:\", error);\n // Throw error to ensure webhook retry - this is critical for credit delivery\n throw new Error(`Failed to add credits for session ${session.id}: ${error.message}`);\n }\n }\n\n console.log(\"Unhandled event type:\", JSON.stringify(event, null, 2));\n});\n\n// Helper function to get a link to the current line\n// If useful, we should move to https://www.val.town/x/std/utils\nfunction sourceURL(e: Error) {\n const match = e.stack?.match(/at\\s+(https:\\/\\/esm\\.town\\/v\\/[^:]+):(\\d+):(\\d+)/);\n if (!match) return null;\n\n const [_, url, line] = match;\n return url.replace(\n /https:\\/\\/esm\\.town\\/v\\/([^\\/]+)\\/([^@]+)@(\\d+)-([^\\/]+)\\/(.*)/,\n \"https://www.val.town/x/$1/$2/branch/$4/code/$5\",\n ) + `#L${line}`;\n}\n\nexport default app;",[],[721,110,797],"50a3a516-5f0e-11f0-82bf-0224a6c84d84","send-message.ts","67fd1b9a-33fa-419a-bd70-6193f66d3684",["D",1752317553464],"import { readFile } from \"https://esm.town/v/std/utils@71-main/index.ts\";\nimport { createAnthropic } from \"npm:@ai-sdk/anthropic\";\nimport { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport {\n convertToCoreMessages,\n type CoreUserMessage,\n streamText,\n} from \"npm:ai\";\nimport { Hono } from \"npm:hono\";\nimport { PostHog } from \"npm:posthog-node\";\nimport { withTracing } from \"npm:@posthog/ai@4.4.0\";\nimport {\n calculatePartialUsageFromInferenceCalls,\n finishTrackingUsage,\n getUser,\n hasInsufficientCredits,\n insertInferenceCall,\n startTrackingUsage,\n} from \"../database/queries.tsx\";\nimport {\n makeChangeValTypeTool,\n makeFetchTool,\n makeTextEditorTool,\n makeTracesTool,\n} from \"../tools/index.ts\";\nimport fileWithLinesNumbers from \"../utils/fileWithLinesNumbers.ts\";\n\nconst app = new Hono();\n\n// Load system prompts\nconst systemPromptPromise = readFile(\n \"/prompts/system_prompt.txt\",\n import.meta.url,\n);\nconst openTowniePromptAdditionsPromise = readFile(\n \"/prompts/open_townie_prompt_additions.txt\",\n import.meta.url,\n);\n\napp.post(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return Response.json(\"Please provide a bearer token\", { status: 401 });\n }\n\n const {\n messages,\n project,\n branchId,\n anthropicApiKey,\n selectedFiles,\n images,\n } = await c.req.json();\n\n // do we want to allow user-provided tokens still\n const apiKey = anthropicApiKey || Deno.env.get(\"ANTHROPIC_API_KEY\");\n const our_api_token = apiKey === Deno.env.get(\"ANTHROPIC_API_KEY\");\n\n if (our_api_token) {\n if (await hasInsufficientCredits({ bearerToken })) {\n return Response.json({\n error: \"Insufficient credits to continue.\",\n action: \"purchase_credits\",\n message: \"Purchase credits to keep using Townie.\",\n purchaseUrl: \"/purchase-credits\",\n }, { status: 403 });\n }\n }\n\n const model = \"claude-sonnet-4-20250514\";\n\n const user = await getUser(bearerToken);\n\n const rowid = await startTrackingUsage({\n our_api_token,\n bearerToken, // will look up the userId from this\n branch_id: branchId,\n val_id: project.id,\n num_images: images?.length || 0,\n model,\n });\n\n // Initialize PostHog client\n const projectApiKey = Deno.env.get(\"POSTHOG_PROJECT_API_KEY\");\n\n let tracedModel;\n\n if (projectApiKey) {\n const phClient = new PostHog(projectApiKey, {\n host: \"https://us.i.posthog.com\",\n });\n\n // Get user info for PostHog distinct ID\n const user = await getUser(bearerToken);\n const distinctId = user?.id || `anonymous_${rowid}`;\n\n // Generate trace ID for this conversation\n const traceId = `townie_${rowid}_${Date.now()}`;\n\n const anthropic = createAnthropic({ apiKey });\n\n // Wrap the Anthropic model with PostHog tracing\n tracedModel = withTracing(anthropic(model), phClient, {\n posthogDistinctId: distinctId,\n posthogTraceId: traceId,\n posthogProperties: {\n townie_project_id: project.id,\n townie_branch_id: branchId,\n townie_usage_id: rowid,\n townie_our_api_token: our_api_token,\n townie_num_images: images?.length || 0,\n townie_selected_files_count: selectedFiles?.length || 0,\n },\n posthogGroups: {\n project: project.id,\n user: user?.id || `anonymous_${rowid}`,\n },\n });\n\n console.log(\"inside posthog\" + tracedModel);\n } else {\n // Fallback to regular Anthropic call if PostHog is not configured\n const anthropic = createAnthropic({ apiKey });\n tracedModel = anthropic(model);\n }\n\n let coreMessages = convertToCoreMessages(messages);\n\n // If there are images, we need to add them to the last user message\n if (images && Array.isArray(images) && images.length > 0) {\n // Find the last user message\n const lastUserMessageIndex = coreMessages.findIndex(\n (msg, idx) => msg.role === \"user\" && idx === coreMessages.length - 1,\n );\n\n if (lastUserMessageIndex !== -1) {\n // Get the text content from the last user message\n const lastUserMessageContent = coreMessages[lastUserMessageIndex].content;\n\n // Create a new message with multimodal content\n // Format the message according to the Vercel AI SDK's expected format\n const newUserMessage: CoreUserMessage = {\n role: \"user\",\n content: typeof lastUserMessageContent === \"string\"\n ? [{\n type: \"text\",\n text: lastUserMessageContent,\n }]\n : lastUserMessageContent,\n };\n\n // Add each image to the content array using the correct ImagePart format\n for (const image of images) {\n if (image && image.url) {\n // Extract mime type from data URL if available\n let mimeType = undefined;\n if (image.url.startsWith(\"data:\")) {\n const matches = image.url.match(/^data:([^;]+);/);\n if (matches && matches.length > 1) {\n mimeType = matches[1];\n }\n }\n\n newUserMessage.content.push({\n type: \"image\",\n image: image.url,\n mimeType,\n });\n }\n }\n\n // Replace the last user message with our new multimodal message\n coreMessages[lastUserMessageIndex] = newUserMessage;\n }\n }\n\n // If there are selected files, fetch their content and add them to the messages\n if (selectedFiles && selectedFiles.length > 0) {\n const vt = new ValTown({ bearerToken });\n\n try {\n // Create a message with the file contents\n let fileContents = \"# Selected Project Files\\n\\n\";\n\n for (const filePath of selectedFiles) {\n if (filePath.endsWith(\"/\")) continue; // Skip directories\n\n try {\n const file = await vt.projects.files.getContent(project.id, {\n path: filePath.startsWith(\"/\") ? filePath.slice(1) : filePath,\n branch_id: branchId || undefined,\n });\n\n const content = await file.text();\n fileContents += `## File: ${filePath}\\n\\`\\`\\`\\n${\n fileWithLinesNumbers(content)\n }\\n\\`\\`\\`\\n\\n`;\n } catch (error) {\n console.error(`Error fetching file ${filePath}:`, error);\n fileContents +=\n `## File: ${filePath}\\nError: Could not fetch file content\\n\\n`;\n }\n }\n\n // Add the file contents as the last message\n coreMessages.push({\n role: \"user\",\n content: [{ type: \"text\", text: fileContents }],\n });\n } catch (error) {\n console.error(\"Error processing selected files:\", error);\n }\n }\n\n // Add cache control to the last message\n let lastMessage = coreMessages.at(-1);\n if (lastMessage) {\n // If the last message is a string, convert it to the array type\n if (typeof lastMessage.content === \"string\") {\n lastMessage.content = [\n { type: \"text\", text: lastMessage.content },\n ];\n }\n // @ts-ignore\n lastMessage.content.at(-1).providerOptions = {\n anthropic: { cacheControl: { type: \"ephemeral\" } },\n };\n }\n\n // console.log(JSON.stringify(coreMessages, null, 2));\n\n // Await the system prompts\n const system = await systemPromptPromise;\n const open_townie_prompt_additions = await openTowniePromptAdditionsPromise;\n\n try {\n const result = await streamText({\n model: tracedModel,\n messages: coreMessages,\n system: system + \"\\n\\n\" + open_townie_prompt_additions,\n tools: {\n str_replace_editor: makeTextEditorTool({\n bearerToken,\n project,\n branch_id: branchId,\n }),\n // think: thinkTool,\n change_val_type: makeChangeValTypeTool({\n bearerToken,\n project,\n branch_id: branchId,\n }),\n fetch: makeFetchTool({ bearerToken, project, branch_id: branchId }),\n requests: makeTracesTool({ bearerToken, project, branch_id: branchId }),\n },\n // Steve increased maxSteps from 20 to 40 on Jun 25, 2025 because folks were complaining\n // about Townie stopping for no reason. The ideal interface is to have a \"continue?\" button\n // after a certain number of steps, but I think this is a quick fix, but we should see if it\n // causes any other issues\n maxSteps: 40,\n maxTokens: 4_096 * 10,\n abortSignal: c.req.raw.signal,\n onStepFinish: async (result: any) => {\n await insertInferenceCall({\n user_id: user.id,\n usage_id: rowid,\n step_type: result.stepType,\n finish_reason: result.finishReason,\n input_tokens: result.usage.promptTokens,\n output_tokens: result.usage.completionTokens,\n cache_read_tokens:\n result.providerMetadata.anthropic.cacheReadInputTokens,\n cache_write_tokens:\n result.providerMetadata.anthropic.cacheCreationInputTokens,\n });\n\n if (our_api_token) {\n const stillHasCredits =\n !(await hasInsufficientCredits({ bearerToken })); // Check for at least 1 cent\n if (!stillHasCredits) {\n throw new Error(\"insufficient_credits\");\n }\n }\n },\n onFinish: async (result: any) => {\n await finishTrackingUsage({\n rowid,\n finish_reason: result.finishReason,\n input_tokens: result.usage.promptTokens,\n output_tokens: result.usage.completionTokens,\n cache_read_tokens:\n result.providerMetadata.anthropic.cacheReadInputTokens,\n cache_write_tokens:\n result.providerMetadata.anthropic.cacheCreationInputTokens,\n });\n },\n });\n\n return result.toDataStreamResponse({\n sendReasoning: true,\n experimental_sendFinish: true,\n getErrorMessage: (error) => {\n console.log(\"Error in toDataStreamResponse:\", error);\n if (error == null) {\n return \"unknown error\";\n }\n\n if (typeof error === \"string\") {\n return error;\n }\n\n if (error instanceof Error) {\n return error.message;\n }\n\n return JSON.stringify(error);\n },\n });\n } catch (error) {\n console.log(\"Caught error in streamText:\", error);\n throw error;\n }\n});\n\nexport default app;",[],[721,110,804],"50a3a0d4-5f0e-11f0-82bf-0224a6c84d84","purchase-credits.ts","2199f5c2-0054-4494-b855-9984222ab9fc",["D",1752317553464],"import { Hono } from \"npm:hono\";\nimport Stripe from \"npm:stripe\";\nimport { getUser } from \"../database/queries.tsx\";\nimport { getEnvVarName } from \"../../shared/is-prod-branch.ts\";\n\nconst app = new Hono();\n\n// Check for required environment variables\nconst stripeSecretKey = Deno.env.get(getEnvVarName(\"STRIPE_SECRET_KEY\"));\nif (!stripeSecretKey) {\n console.error(`${getEnvVarName(\"STRIPE_SECRET_KEY\")} environment variable is not set`);\n}\n\nconst stripe = stripeSecretKey\n ? new Stripe(stripeSecretKey, {\n apiVersion: \"2024-04-10\",\n })\n : null;\n\napp.post(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return c.json({ error: \"Unauthorized\" }, 401);\n }\n\n const { amount, source } = await c.req.json();\n\n // Validate amount: $1 minimum, $100 maximum\n if (!amount || typeof amount !== \"number\" || amount < 1 || amount > 100) {\n return c.json({\n error: \"Invalid amount. Must be between $1 and $100.\",\n }, 400);\n }\n\n try {\n // Check if Stripe is configured\n if (!stripe) {\n return c.json({\n error: \"Payment system not configured. Please contact support.\",\n }, 503);\n }\n\n const user = await getUser(bearerToken as string);\n if (!user || !user.id || !user.username) {\n return c.json({ error: \"Invalid user data\" }, 400);\n }\n\n // Create Stripe payment intent\n // const paymentIntent = await stripe.paymentIntents.create({\n // amount: Math.round(amount * 100), // Convert dollars to cents\n // currency: \"usd\",\n // automatic_payment_methods: {\n // enabled: true,\n // },\n // metadata: {\n // // Store user info for webhook processing\n // user_id: user.id,\n // username: user.username,\n // purchase_source: source || \"api\", // e.g., \"insufficient_credits\", \"settings_page\"\n // },\n // description: `Townie credits purchase - $${amount} for ${user.username}`,\n // api_key: stripeSecretKey,\n // });\n\n const params = new URLSearchParams({\n amount: Math.round(amount * 100).toString(),\n currency: \"usd\",\n \"automatic_payment_methods[enabled]\": \"true\",\n \"metadata[user_id]\": user.id,\n \"metadata[username]\": user.username,\n \"metadata[purchase_source]\": source || \"api\",\n description: `Townie credits purchase - $${amount} for ${user.username}`,\n });\n\n const response = await fetch(\"https://api.stripe.com/v1/payment_intents\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${stripeSecretKey}`,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Stripe-Version\": \"2024-04-10\",\n },\n body: params,\n });\n const paymentIntent = await response.json();\n if (!response.ok) {\n throw new Error(`Stripe API error: ${paymentIntent.error?.message || \"Unknown error\"}`);\n }\n\n return c.json({\n paymentIntentId: paymentIntent.id,\n clientSecret: paymentIntent.client_secret,\n amount: amount,\n });\n } catch (error) {\n return c.json({\n error: `Failed to create payment. Please try again.`,\n }, 500);\n }\n});\n\nexport default app;",[],[721,110,811],"50a39f6c-5f0e-11f0-82bf-0224a6c84d84","projects-loader.ts","ff8e63fd-2080-4363-be46-b9cd24070eef",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return Response.json(\"Unauthorized\", { status: 401 });\n }\n\n const vt = new ValTown({ bearerToken });\n\n const [profile, projects] = await Promise.all([\n vt.me.profile.retrieve(),\n vt.me.projects.list({\n limit: 100,\n }),\n ]);\n\n return c.json({ profile, projects: projects.data });\n});\n\nexport default app;\n",[],[721,110,818],"50a39d82-5f0e-11f0-82bf-0224a6c84d84","project.ts","a7252fba-9916-47b4-8da1-b76da1bde5c8",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return Response.json(\"Please provide a bearer token\", { status: 401 });\n }\n const projectId = c.req.query(\"projectId\");\n\n if (!projectId) {\n return Response.json(\"Please provide a projectId\", { status: 400 });\n }\n\n const vt = new ValTown({ bearerToken });\n\n const project = await vt.projects.retrieve(projectId);\n // console.log({ project }, Object.keys(project));\n\n return c.json({ project });\n});\n\nexport default app;\n",[],[721,110,825],"50a39b98-5f0e-11f0-82bf-0224a6c84d84","project-files.ts","3424bbae-6a7e-498d-ba68-21af9d56dda4",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return Response.json(\"Please provide a bearer token\", { status: 401 });\n }\n\n const projectId = c.req.query(\"projectId\");\n const branchId = c.req.query(\"branchId\");\n\n if (!projectId) {\n return Response.json(\"Please provide a projectId\", { status: 400 });\n }\n\n const vt = new ValTown({ bearerToken });\n\n try {\n const files = await vt.projects.files.retrieve(projectId, {\n path: \"\",\n limit: 100,\n offset: 0,\n recursive: true,\n branch_id: branchId || undefined,\n });\n\n return c.json({ files: files.data });\n } catch (error) {\n console.error(\"Error fetching project files:\", error);\n return Response.json({ error: \"Failed to fetch project files\" }, { status: 500 });\n }\n});\n\nexport default app;\n",[],[721,110,832],"50a39832-5f0e-11f0-82bf-0224a6c84d84","project-branches.ts","0ca58555-20f0-4520-b27a-133528cbefec",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return Response.json(\"Please provide a bearer token\", { status: 401 });\n }\n\n const projectId = c.req.query(\"projectId\");\n if (!projectId) {\n return Response.json(\"Please provide a projectId\", { status: 400 });\n }\n\n const vt = new ValTown({ bearerToken });\n\n try {\n const branches = await vt.projects.branches.list(projectId, { limit: 100 });\n return c.json({ branches: branches.data });\n } catch (error) {\n console.error(\"Error fetching branches:\", error);\n return Response.json({ error: \"Failed to fetch branches\" }, { status: 500 });\n }\n});\n\nexport default app;\n",[],[721,110,839],"50a39666-5f0e-11f0-82bf-0224a6c84d84","credit-balance.ts","a3375dab-eafe-4755-b80a-db223d0bb7a9",["D",1752317553464],"import { Hono } from \"npm:hono\";\nimport { getUser, getCreditBalance } from \"../database/queries.tsx\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return c.json({ error: \"Unauthorized\" }, 401);\n }\n\n try {\n const user = await getUser(bearerToken);\n const balance = await getCreditBalance(user.id);\n \n return c.json({\n balance: balance,\n userId: user.id,\n username: user.username,\n });\n\n } catch (error) {\n console.error(\"Failed to get credit balance:\", error);\n return c.json({ \n error: \"Failed to get balance. Please try again.\" \n }, 500);\n }\n});\n\nexport default app;",[],[721,110,846],"50a39454-5f0e-11f0-82bf-0224a6c84d84","create-project.ts","fc15cf62-f70f-494f-be55-ebbae5090a52",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return Response.json(\"Please provide a bearer token\", { status: 401 });\n }\n\n const { name, description, privacy } = await c.req.json();\n\n const vt = new ValTown({ bearerToken });\n\n try {\n const project = await vt.projects.create({\n name,\n description,\n privacy,\n });\n\n return c.json({ project });\n } catch (e: any) {\n return c.json({ error: e.message }, { status: 500 });\n }\n});\n\nexport default app;\n",[],[721,110,853],"50a39292-5f0e-11f0-82bf-0224a6c84d84","create-branch.ts","5e6b5530-3534-4a03-ad2b-0605f6d3f81b",["D",1752317553464],"import { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\napp.post(\"/\", async (c) => {\n const bearerToken = c.get(\"token\");\n if (!bearerToken) {\n return Response.json(\"Please provide a bearer token\", { status: 401 });\n }\n\n const { projectId, branchName } = await c.req.json();\n\n if (!projectId) {\n return Response.json(\"Please provide a projectId\", { status: 400 });\n }\n\n if (!branchName) {\n return Response.json(\"Please provide a branchName\", { status: 400 });\n }\n\n // Validate branch name (only letters, numbers, and dashes)\n const branchNameRegex = /^[a-zA-Z0-9-]+$/;\n if (!branchNameRegex.test(branchName)) {\n return Response.json({\n error: \"Branch name can only contain letters, numbers, and dashes\",\n }, { status: 400 });\n }\n\n const vt = new ValTown({ bearerToken });\n\n try {\n const newBranch = await vt.projects.branches.create(projectId, {\n name: branchName,\n });\n\n return c.json({ branch: newBranch });\n } catch (error) {\n console.error(\"Error creating branch:\", error);\n return Response.json({\n error: error instanceof Error ? error.message : \"Failed to create branch\",\n }, { status: 500 });\n }\n});\n\nexport default app;\n",[],[721,110,860],"50a3b42a-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[285,286,287,288,289,290,291,292,293,294,295],[721,110],"50a38cca-5f0e-11f0-82bf-0224a6c84d84","shell.tsx","883b9272-a3a1-49ea-9463-99cee1b2b7ea","e2d9c51b-cb22-404e-a50b-3518015b912e",["D",1752317553464],"import { addCredits } from \"./queries.tsx\";\n\n// console.log(addCredits);\n\n// const userId = \"6e4bb7b0-0a9b-11f0-b3f6-25e086e8322a\";\n// const note = \"Steve manually charged\";\n// const numberOfCredits = 100;\n// const result = await addCredits(\n// userId,\n// numberOfCredits,\n// note,\n// `${crypto.randomUUID()}_vt_internal`,\n// );\n// console.log(result);",[],[721,878,871],"database","50a38a72-5f0e-11f0-82bf-0224a6c84d84","schema.tsx","9915e860-47ee-4011-ab24-61d403cad5df",["D",1752317553464],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nexport const USAGE_TABLE = \"townie_usage\";\nexport const INFERENCE_CALLS_TABLE = \"townie_inference_calls_2\";\nexport const CREDIT_ADDITIONS_TABLE = \"townie_credit_additions\";\n\nexport interface Usage {\n user_id: string;\n username: string;\n timestamp: number;\n finish_timestamp?: number;\n val_id: string;\n branch_id: string;\n input_tokens?: number;\n output_tokens?: number;\n cache_read_tokens?: number;\n cache_write_tokens?: number;\n model: string;\n price?: number;\n finish_reason?: string;\n num_images?: number;\n our_api_token: boolean;\n}\n\nasync function createTables(prefix: string = \"\") {\n // archive a table\n // await sqlite.execute(\n // `ALTER TABLE ${USAGE_TABLE} RENAME TO ${USAGE_TABLE}_1`,\n // );\n // create a new table\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS ${prefix}${USAGE_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT NOT NULL,\n username TEXT NOT NULL,\n timestamp INTEGER NOT NULL,\n val_id TEXT NOT NULL,\n branch_id TEXT,\n input_tokens INTEGER,\n output_tokens INTEGER,\n cache_read_tokens INTEGER,\n cache_write_tokens INTEGER,\n model TEXT,\n price REAL,\n finish_reason TEXT,\n num_images INTEGER,\n our_api_token INTEGER NOT NULL,\n finish_timestamp INTEGER\n )`,\n `CREATE TABLE IF NOT EXISTS ${prefix}${INFERENCE_CALLS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT NOT NULL,\n usage_id INTEGER NOT NULL REFERENCES ${prefix}${USAGE_TABLE}(id),\n timestamp INTEGER NOT NULL,\n input_tokens INTEGER,\n output_tokens INTEGER,\n cache_read_tokens INTEGER,\n cache_write_tokens INTEGER,\n price REAL,\n step_type TEXT,\n finish_reason TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS ${prefix}${CREDIT_ADDITIONS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT NOT NULL,\n created_at INTEGER NOT NULL,\n stripe_payment_intent_id TEXT,\n amount REAL NOT NULL,\n note TEXT\n )`,\n `CREATE INDEX IF NOT EXISTS idx_${prefix}townie_credit_additions_user_id ON ${prefix}${CREDIT_ADDITIONS_TABLE}(user_id)`,\n `CREATE INDEX IF NOT EXISTS idx_${prefix}townie_inference_calls_user_id ON ${prefix}${INFERENCE_CALLS_TABLE}(user_id)`,\n `CREATE INDEX IF NOT EXISTS idx_${prefix}townie_inference_calls_usage_id ON ${prefix}${INFERENCE_CALLS_TABLE}(usage_id)`,\n `CREATE INDEX IF NOT EXISTS idx_${prefix}${CREDIT_ADDITIONS_TABLE}_stripe_payment_intent_id ON ${prefix}${CREDIT_ADDITIONS_TABLE}(stripe_payment_intent_id)`,\n ]);\n}\n\nexport async function deleteTables(prefix: string) {\n await sqlite.execute(`DROP TABLE IF EXISTS ${prefix}${INFERENCE_CALLS_TABLE}`);\n await sqlite.execute(`DROP TABLE IF EXISTS ${prefix}${USAGE_TABLE}`);\n await sqlite.execute(`DROP TABLE IF EXISTS ${prefix}${CREDIT_ADDITIONS_TABLE}`);\n await sqlite.execute(`DROP INDEX IF EXISTS idx_${prefix}townie_credit_additions_user_id`);\n await sqlite.execute(`DROP INDEX IF EXISTS idx_${prefix}townie_inference_calls_user_id`);\n await sqlite.execute(`DROP INDEX IF EXISTS idx_${prefix}townie_inference_calls_usage_id`);\n}\n\nexport async function migrateTables(prefix?: string) {\n await createTables(prefix);\n}\n\n// migrateTables();",[],[721,878,880],"50a387e8-5f0e-11f0-82bf-0224a6c84d84","queries_test.tsx","0829d32a-85b4-4095-b7bc-f728da6e19fb",["D",1752317553464],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { addCredits, calculatePartialUsageFromInferenceCalls, finishTrackingUsage, getCreditBalance, insertInferenceCall } from \"./queries.tsx\";\nimport { deleteTables, migrateTables } from \"./schema.tsx\";\nimport { CREDIT_ADDITIONS_TABLE, INFERENCE_CALLS_TABLE, USAGE_TABLE } from \"./schema.tsx\";\n\nasync function runTests() {\n await deleteTables(\"test_\");\n await migrateTables(\"test_\");\n \n const userId = crypto.randomUUID();\n const val_id = crypto.randomUUID();\n const branch_id = crypto.randomUUID();\n\n await addCredits(userId, 5, \"test note\", null, \"test_\");\n await addCredits(userId, 2, \"test note\", null, \"test_\");\n await addCredits(userId, 10, \"test note\", null, \"test_\");\n const balance = await getCreditBalance(userId, \"test_\");\n if (balance !== 17) {\n throw new Error(\"Test failed\");\n }\n\n const { lastInsertRowid: usage_id } = await sqlite.execute(\n `INSERT INTO test_${USAGE_TABLE} (\n user_id,\n username,\n timestamp,\n val_id,\n branch_id,\n model,\n our_api_token,\n num_images\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n `,\n [\n userId,\n \"test_user\",\n Date.now(),\n val_id,\n branch_id,\n \"some model\",\n 1,\n 0,\n ],\n );\n\n await insertInferenceCall({\n usage_id,\n input_tokens: 10000,\n output_tokens: 10000,\n step_type: \"x\",\n finish_reason: \"x\",\n user_id: userId,\n tablePrefix: \"test_\",\n });\n\n await insertInferenceCall({\n usage_id,\n input_tokens: 10000,\n output_tokens: 10000,\n step_type: \"x\",\n finish_reason: \"x\",\n user_id: userId,\n tablePrefix: \"test_\",\n });\n\n const result = await calculatePartialUsageFromInferenceCalls(usage_id, \"test_\")\n\n await finishTrackingUsage({\n rowid: usage_id,\n finish_reason: \"test-finished\",\n input_tokens: result.input_tokens,\n output_tokens: result.output_tokens,\n cache_read_tokens: result.cache_read_tokens,\n cache_write_tokens: result.cache_write_tokens,\n tablePrefix: \"test_\",\n });\n\n if (await getCreditBalance(userId, \"test_\") !== 16.46) {\n throw new Error(\"Test failed\")\n }\n \n await addCredits(userId, -10, \"test note\", \"stripe_payment_intent_id\", \"test_\");\n if (await getCreditBalance(userId, \"test_\") !== 6.46) {\n throw new Error(\"Test failed\")\n }\n\n // Checks that the same payment intent id doesn't add credits again\n await addCredits(userId, 10, \"test note\", \"stripe_payment_intent_id\", \"test_\");\n if (await getCreditBalance(userId, \"test_\") !== 6.46) { // the balance should be the same\n throw new Error(\"Test failed\")\n }\n}\n\nawait runTests();",[],[721,878,887],"50a381e4-5f0e-11f0-82bf-0224a6c84d84","queries.tsx","a7b14602-d14c-40f3-8bb9-f4453b6a07a5",["D",1752317553464],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { ValTown } from \"npm:@valtown/sdk@0.37.0\";\nimport { calculateCost } from \"../utils/calculateCost.tsx\";\nimport { CREDIT_ADDITIONS_TABLE, INFERENCE_CALLS_TABLE, USAGE_TABLE } from \"./schema.tsx\";\n\nconst PRICE_MULTIPLIER = 1.5;\n\n// Eventually we'll have a user database,\n// but in the meantime, we can cache user info in memory\nconst userIdCache: { [key: string]: any } = {};\nexport async function getUser(bearerToken: string) {\n if (userIdCache[bearerToken]) return userIdCache[bearerToken];\n\n const vt = new ValTown({ bearerToken });\n const me = await vt.me.profile.retrieve();\n userIdCache[bearerToken] = me;\n return me;\n}\n\n// Get user's current credit balance\nexport async function getCreditBalance(userId: string, tablePrefix: string = \"\"): Promise {\n const result = await sqlite.execute(\n `\n SELECT \n COALESCE(additions.total, 0) - COALESCE(usage.total, 0) as balance\n FROM \n (SELECT SUM(amount) as total FROM ${tablePrefix}${CREDIT_ADDITIONS_TABLE} WHERE user_id = ?) additions,\n (SELECT SUM(price * ${PRICE_MULTIPLIER}) as total FROM ${tablePrefix}${INFERENCE_CALLS_TABLE} WHERE user_id = ?) usage\n `,\n [userId, userId],\n );\n\n return result.rows[0][0] || 0;\n}\n\n// Check if user has insufficient credits for estimated cost\nexport async function hasInsufficientCredits({\n bearerToken,\n estimatedCost = 0.01,\n tablePrefix = \"\",\n}: {\n bearerToken: string;\n estimatedCost?: number;\n tablePrefix: string;\n}): Promise {\n const user = await getUser(bearerToken);\n const balance = await getCreditBalance(user.id, tablePrefix);\n\n return balance < estimatedCost;\n}\n\n// Add credits to user account\nexport async function addCredits(\n userId: string,\n amount: number,\n note: string,\n stripePaymentIntentId?: string | null,\n tablePrefix = \"\",\n) {\n const result = await sqlite.execute(\n `\n INSERT INTO ${tablePrefix}${CREDIT_ADDITIONS_TABLE} (user_id, created_at, amount, note, stripe_payment_intent_id)\n SELECT ?, ?, ?, ?, ?\n WHERE NOT EXISTS (\n SELECT 1 FROM ${tablePrefix}${CREDIT_ADDITIONS_TABLE} \n WHERE stripe_payment_intent_id = ? AND stripe_payment_intent_id IS NOT NULL\n )\n `,\n [userId, Date.now(), amount, note, stripePaymentIntentId || null, stripePaymentIntentId]\n );\n \n if (result.rowsAffected === 0 && stripePaymentIntentId) {\n console.error(\"Tried to add credits but they already exist with this stripe_payment_intent_id:\", stripePaymentIntentId);\n }\n}\n\nexport async function insertInferenceCall({\n usage_id,\n input_tokens,\n output_tokens,\n cache_read_tokens,\n cache_write_tokens,\n step_type,\n finish_reason,\n user_id,\n tablePrefix = \"\",\n}: {\n usage_id: number;\n input_tokens: number;\n output_tokens: number;\n cache_read_tokens?: number;\n cache_write_tokens?: number;\n step_type: string;\n finish_reason: string;\n user_id: string;\n tablePrefix: string;\n}) {\n const price = calculateCost({\n input_tokens,\n output_tokens,\n cache_read_tokens,\n cache_write_tokens,\n });\n try {\n await sqlite.execute(\n `INSERT INTO ${tablePrefix}${INFERENCE_CALLS_TABLE} (\n usage_id,\n timestamp,\n input_tokens,\n output_tokens,\n cache_read_tokens,\n cache_write_tokens,\n price,\n step_type,\n finish_reason,\n user_id\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n [\n usage_id,\n Date.now(),\n input_tokens,\n output_tokens,\n cache_read_tokens || 0,\n cache_write_tokens || 0,\n price,\n step_type,\n finish_reason,\n user_id,\n ],\n );\n } catch (e) {\n console.error(e);\n }\n}\n\nexport async function startTrackingUsage({\n bearerToken,\n val_id,\n branch_id,\n model,\n our_api_token,\n num_images,\n tablePrefix = \"\",\n}: {\n bearerToken: string;\n val_id: string;\n branch_id: string;\n model: string;\n our_api_token: boolean;\n num_images: number;\n tablePrefix: string;\n}) {\n const user = await getUser(bearerToken);\n const { lastInsertRowid } = await sqlite.execute(\n `INSERT INTO ${tablePrefix}${USAGE_TABLE} (\n user_id,\n username,\n timestamp,\n val_id,\n branch_id,\n model,\n our_api_token,\n num_images\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n `,\n [\n user.id,\n user.username,\n Date.now(),\n val_id,\n branch_id,\n model,\n our_api_token ? 1 : 0,\n num_images,\n ],\n );\n return lastInsertRowid;\n}\n\nexport async function calculatePartialUsageFromInferenceCalls(usageId: number, tablePrefix: string = \"\") {\n const result = await sqlite.execute(`\n SELECT \n SUM(input_tokens) as total_input_tokens,\n SUM(output_tokens) as total_output_tokens,\n SUM(cache_read_tokens) as total_cache_read_tokens,\n SUM(cache_write_tokens) as total_cache_write_tokens\n FROM ${tablePrefix}${INFERENCE_CALLS_TABLE}\n WHERE usage_id = ?\n `, [usageId]);\n \n const row = result.rows[0];\n if (!row || !row.total_input_tokens) {\n return null; // No inference calls found\n }\n \n return {\n input_tokens: row.total_input_tokens || 0,\n output_tokens: row.total_output_tokens || 0,\n cache_read_tokens: row.total_cache_read_tokens || 0,\n cache_write_tokens: row.total_cache_write_tokens || 0,\n };\n}\n\nexport async function finishTrackingUsage({\n rowid,\n input_tokens,\n output_tokens,\n cache_read_tokens,\n cache_write_tokens,\n finish_reason,\n tablePrefix = \"\",\n}: {\n rowid: number;\n input_tokens?: number;\n output_tokens?: number;\n cache_read_tokens?: number;\n cache_write_tokens?: number;\n finish_reason: string;\n tablePrefix: string;\n}) {\n const price = calculateCost({\n input_tokens: input_tokens || 0,\n output_tokens: output_tokens || 0,\n cache_read_tokens,\n cache_write_tokens,\n });\n \n try {\n await sqlite.execute(\n `UPDATE ${tablePrefix}${USAGE_TABLE} SET\n input_tokens = ?,\n output_tokens = ?,\n cache_read_tokens = ?,\n cache_write_tokens = ?,\n price = ?,\n finish_reason = ?\n WHERE rowid = ?\n `,\n [\n input_tokens || 0,\n output_tokens || 0,\n cache_read_tokens || 0,\n cache_write_tokens || 0,\n price,\n finish_reason,\n rowid,\n ],\n );\n } catch (e) {\n console.error(e);\n }\n}",[],[721,878,894],"50a37d48-5f0e-11f0-82bf-0224a6c84d84","949fc7be-6440-464b-ac5e-924c06d1bd4a","dcdbf311-557b-4210-8542-af8f0feec103",["D",1752317553464],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { getCreditAdditions } from \"./api/credit-additions.ts\";\nimport { handleApiRequest } from \"./api/index.ts\";\nimport { getInferenceCalls } from \"./api/inference-calls.ts\";\nimport {\n getInferenceCallsForRequest,\n getInferenceTotalsForRequest,\n getRequestById,\n getRequests,\n} from \"./api/requests.ts\";\nimport { getUserSummary } from \"./api/user-summary.ts\";\nimport { getValSummary } from \"./api/val-summary.ts\";\nimport { basicAuthMiddleware } from \"./auth.ts\";\nimport { renderCreditAdditions } from \"./views/credit-additions.ts\";\nimport { renderDashboard } from \"./views/dashboard.ts\";\nimport { renderInferenceCalls } from \"./views/inference-calls.ts\";\nimport { renderRequests } from \"./views/requests.ts\";\nimport { renderUsageDetail } from \"./views/usage-detail.ts\";\nimport { renderUserDetail } from \"./views/user-detail.ts\";\nimport { renderValDetail } from \"./views/val-detail.ts\";\n\nconst app = new Hono();\n\n// Authentication middleware for all routes\napp.use(\"*\", async (c, next) => {\n const authResponse = await basicAuthMiddleware(c.req.raw);\n if (authResponse) {\n return authResponse;\n }\n await next();\n});\n\n// API routes\napp.all(\"/api/*\", async (c) => {\n return handleApiRequest(c.req.raw);\n});\n\n// Dashboard home page\napp.get(\"/\", async (c) => {\n const userData = await getUserSummary();\n return c.html(renderDashboard(userData));\n});\n\n// User detail page\napp.get(\"/user/:userId\", async (c) => {\n const userId = c.req.param(\"userId\");\n if (!userId) {\n return c.text(\"User ID is required\", 400);\n }\n\n const userData = await getUserSummary(userId);\n\n // Get all requests for this user\n const url = new URL(c.req.url);\n url.searchParams.set(\"user_id\", userId);\n const userRequests = await getRequests(url);\n\n // Get credit additions for this user\n const creditUrl = new URL(c.req.url);\n creditUrl.searchParams.set(\"user_id\", userId);\n const userCreditAdditions = await getCreditAdditions(creditUrl);\n\n return c.html(renderUserDetail(userData, userId, userRequests.data, userCreditAdditions.data));\n});\n\n// Usage/request detail page\napp.get(\"/usage/:usageId\", async (c) => {\n const usageId = c.req.param(\"usageId\");\n if (!usageId || isNaN(parseInt(usageId))) {\n return c.text(\"Valid Usage ID is required\", 400);\n }\n\n // Get usage details\n const usage = await getRequestById(usageId);\n if (!usage) {\n return c.text(\"Usage request not found\", 404);\n }\n\n // Get inference calls for this usage\n const inferenceCalls = await getInferenceCallsForRequest(usageId);\n const inferenceTotals = await getInferenceTotalsForRequest(usageId);\n\n return c.html(renderUsageDetail(usage, inferenceCalls, inferenceTotals));\n});\n\n// Val detail page\napp.get(\"/val/:valId\", async (c) => {\n const valId = c.req.param(\"valId\");\n if (!valId) {\n return c.text(\"Val ID is required\", 400);\n }\n\n // Get val summary and requests\n const valData = await getValSummary(valId);\n\n return c.html(renderValDetail(valId, valData.summary, valData.requests));\n});\n\n// Requests page\napp.get(\"/requests\", async (c) => {\n const url = new URL(c.req.url);\n const requestsData = await getRequests(url);\n return c.html(renderRequests(\n requestsData.data,\n requestsData.pagination,\n url.toString(),\n requestsData.filtered,\n ));\n});\n\n// Inference calls page\napp.get(\"/inference\", async (c) => {\n const url = new URL(c.req.url);\n const inferenceData = await getInferenceCalls(url);\n return c.html(renderInferenceCalls(\n inferenceData.data,\n inferenceData.pagination,\n url.toString(),\n inferenceData.filtered,\n ));\n});\n\n// Credit additions page\napp.get(\"/credit-additions\", async (c) => {\n const url = new URL(c.req.url);\n const creditData = await getCreditAdditions(url);\n return c.html(renderCreditAdditions(\n creditData.data,\n creditData.pagination,\n url.toString(),\n creditData.filtered,\n creditData.summary,\n ));\n});\n\n// 404 handler\napp.notFound((c) => {\n return c.text(\"Admin page not found\", 404);\n});\n\nexport default app;",[],[721,878,907,363],"usage-dashboard","50a37a8c-5f0e-11f0-82bf-0224a6c84d84","auth.ts","19ec4b19-d932-4b7a-bc13-29c614b0b777",["D",1752317553464],"import * as bcrypt from \"https://deno.land/x/bcrypt@v0.3.0/mod.ts\";\n\n/**\n * Basic Auth middleware for the usage dashboard\n * Returns null if authentication is successful, or a Response if it fails\n */\nexport async function basicAuthMiddleware(req: Request): Promise {\n const realm = \"Usage Dashboard\";\n const unauthorizedResponse = new Response(\"Unauthorized\", {\n status: 401,\n headers: {\n \"WWW-Authenticate\": `Basic realm=\"${realm}\"`,\n \"Content-Type\": \"text/plain\",\n },\n });\n\n // Get the Authorization header\n const authHeader = req.headers.get(\"Authorization\");\n if (!authHeader || !authHeader.startsWith(\"Basic \")) {\n return unauthorizedResponse;\n }\n\n try {\n // Extract the base64 encoded credentials\n const base64Credentials = authHeader.split(\" \")[1];\n const credentials = atob(base64Credentials);\n\n // Split into username and password\n const [username, password] = credentials.split(\":\");\n\n if (!password) {\n return unauthorizedResponse;\n }\n\n // Ask Steve for this password\n const hashedPassword = \"$2a$12$aA2HYmj21jK1TKSFLFOutOlXsCrKFnMvyeblySLwcgSqxt05nEeei\";\n\n // Compare the provided password with the stored hash\n const passwordMatches = await bcrypt.compare(password, hashedPassword);\n\n if (!passwordMatches) {\n return unauthorizedResponse;\n }\n\n // Authentication successful\n return null;\n } catch (error) {\n console.error(\"Authentication error:\", error);\n return unauthorizedResponse;\n }\n}",[],[721,878,907,909],"50a37802-5f0e-11f0-82bf-0224a6c84d84","633d1467-6ce7-4bd9-a41b-8149b869ef90",["D",1752317553464],"# Usage Dashboard\n\nA dashboard for monitoring API usage and inference calls.\n\n## Features\n\n- User summary view with aggregated usage data\n- All requests view with collapsible rows showing inference calls\n- Inference calls view with filtering options\n- Pagination for handling large datasets\n- Comparison between usage data and inference calls for debugging\n- Fallback to inference data when usage data is missing\n\n## Architecture\n\nThe dashboard is built with a modular architecture:\n\n```\n/usage-dashboard/\n index.ts # Main entry point and routing\n auth.ts # Authentication logic\n /api/\n index.ts # API request handler\n requests.ts # API endpoints for requests data\n inference-calls.ts # API endpoints for inference calls\n user-summary.ts # API endpoints for user summary data\n /views/\n layout.ts # Common layout template\n dashboard.ts # User summary view\n requests.ts # Requests view with collapsible rows\n inference-calls.ts # Inference calls view\n /utils/\n formatters.ts # Shared formatting utilities\n pagination.ts # Pagination utilities\n```\n\n## Usage\n\nAccess the dashboard at the root URL. Authentication is required.\n\n### Views\n\n1. **User Summary** - Shows aggregated usage data by user\n - When usage data is missing, it falls back to inference call data\n - Indicated with an \"I\" badge\n\n2. **All Requests** - Shows all usage requests with pagination\n - Click on a row to see associated inference calls\n - Compares usage data with inference call totals\n - Highlights discrepancies for debugging\n\n3. **Inference Calls** - Shows all inference calls with pagination\n - Can be filtered by usage_id\n - Links back to the associated request\n\n### API Endpoints\n\n- `/api/requests` - Get paginated requests\n- `/api/requests?usage_id=123` - Get a specific request\n- `/api/inference-calls` - Get paginated inference calls\n- `/api/inference-calls?usage_id=123` - Get inference calls for a specific request\n- `/api/user-summary` - Get user summary data\n\n## Debugging\n\nThe dashboard includes several features for debugging:\n\n1. **Collapsible Rows** - Click on a request to see its inference calls\n2. **Token Comparison** - Compare tokens and price between usage and inference data\n3. **Discrepancy Highlighting** - Visual indicators when data doesn't match\n4. **Inference Data Fallback** - Use inference data when usage data is missing",[],[721,878,907,385],"50a36d6c-5f0e-11f0-82bf-0224a6c84d84","val-detail.ts","81f1a064-4cf3-4d73-bf27-3db8c53c2138","ba918f9e-9812-4311-8043-8e7b701bd692",["D",1752317553464],"import { renderLayout } from \"./layout.ts\";\nimport { formatNumber, formatPrice, formatDate, formatBoolean } from \"../utils/formatters.ts\";\n\ninterface UsageRequest {\n id: number;\n user_id: string;\n username: string;\n timestamp: number;\n finish_timestamp?: number;\n val_id: string;\n branch_id: string | null;\n input_tokens?: number;\n output_tokens?: number;\n cache_read_tokens?: number;\n cache_write_tokens?: number;\n model: string;\n price?: number;\n finish_reason?: string;\n num_images?: number;\n our_api_token: boolean;\n}\n\ninterface ValSummary {\n val_id: string;\n request_count: number;\n total_input_tokens: number;\n total_output_tokens: number;\n total_cache_read_tokens: number;\n total_cache_write_tokens: number;\n total_price: number;\n inference_price: number;\n original_price?: number;\n total_images: number;\n used_inference_data?: boolean;\n inference_price_primary?: boolean;\n}\n\nexport function renderValDetail(valId: string, summary: ValSummary, requests: UsageRequest[] = []): string {\n // Generate the content\n const content = `\n

Val Details: ${valId}

\n ← Back to all users\n

\n \n

Total Requests: ${formatNumber(summary.request_count)}

Total Price: ${formatPrice(summary.total_price)}\n ${summary.used_inference_data ? 'I' : ''}\n ${summary.inference_price_primary && summary.original_price !== undefined && Math.abs(summary.original_price - summary.total_price) > 0.0001 ? \n `*` : \n ''}\n

Inference Calls Price: ${formatPrice(summary.inference_price)}

\n \n

Usage Summary

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

Input Tokens	Output Tokens	Cache Read	Cache Write	Total Price	Images
${formatNumber(summary.total_input_tokens)}	${formatNumber(summary.total_output_tokens)}	${formatNumber(summary.total_cache_read_tokens)}	${formatNumber(summary.total_cache_write_tokens)}	${formatPrice(summary.total_price)}	${formatNumber(summary.total_images)}

\n \n

Val Requests (${requests.length})

\n ${requests.length > 0 ? `\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n ${requests.map(row => `\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n `).join(\"\")}\n \n

ID	User	Timestamp	Branch ID	Input	Output	Cache Read	Cache Write	Model	Price	Finish	Images
${row.id}	${row.username}	${formatDate(row.timestamp)}	${row.branch_id ?? \"main\"}	${formatNumber(row.input_tokens)}	${formatNumber(row.output_tokens)}	${formatNumber(row.cache_read_tokens)}	${formatNumber(row.cache_write_tokens)}	${row.model}	${formatPrice(row.price)}	${row.finish_reason \|\| '-'}	${formatNumber(row.num_images)}

\n ` : '

No requests found for this val.

'}\n

\n `;\n \n return renderLayout(content, {\n title: `Usage Dashboard - Val ${valId}`,\n activeTab: \"val\"\n });\n}",[],[721,878,907,929,922],"views","50a368ee-5f0e-11f0-82bf-0224a6c84d84","user-detail.ts","1d26272c-69a6-484e-b991-ab95e16e7828",["D",1752317553464],"import { renderLayout } from \"./layout.ts\";\nimport { formatNumber, formatPrice, formatDate, formatBoolean } from \"../utils/formatters.ts\";\nimport { CreditAddition } from \"../api/credit-additions.ts\";\n\ninterface UserSummaryRow {\n user_id: string;\n username: string;\n request_count: number;\n total_input_tokens: number;\n total_output_tokens: number;\n total_cache_read_tokens: number;\n total_cache_write_tokens: number;\n total_price: number;\n inference_price: number;\n total_images: number;\n used_inference_data?: boolean;\n}\n\ninterface UsageRequest {\n id: number;\n user_id: string;\n username: string;\n timestamp: number;\n finish_timestamp?: number;\n val_id: string;\n branch_id: string | null;\n input_tokens?: number;\n output_tokens?: number;\n cache_read_tokens?: number;\n cache_write_tokens?: number;\n model: string;\n price?: number;\n finish_reason?: string;\n num_images?: number;\n our_api_token: boolean;\n}\n\nexport function renderUserDetail(data: UserSummaryRow[], userId: string, requests: UsageRequest[] = [], creditAdditions: CreditAddition[] = []): string {\n // User data should only have one row if we're filtering by user ID\n const userData = data[0] || {\n user_id: userId,\n username: \"Unknown User\",\n request_count: 0,\n total_input_tokens: 0,\n total_output_tokens: 0,\n total_cache_read_tokens: 0,\n total_cache_write_tokens: 0,\n total_price: 0,\n inference_price: 0,\n total_images: 0\n };\n \n // Generate the content\n const content = `\n

User Details: ${userData.username} (${userData.user_id})

\n ← Back to all users\n

\n \n

Total Requests: ${formatNumber(userData.request_count)}

Total Price: ${formatPrice(userData.total_price)}

Total Inference Price: ${formatPrice(userData.inference_price || 0)}

Total Credit Additions: ${formatPrice(creditAdditions.reduce((sum, item) => sum + item.amount, 0))}

\n \n

Usage Summary

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

Input Tokens	Output Tokens	Cache Read	Cache Write	Total Price	Inference Price	Images
${formatNumber(userData.total_input_tokens)} ${userData.used_inference_data ? 'I' : ''}	${formatNumber(userData.total_output_tokens)} ${userData.used_inference_data ? 'I' : ''}	${formatNumber(userData.total_cache_read_tokens)} ${userData.used_inference_data ? 'I' : ''}	${formatNumber(userData.total_cache_write_tokens)} ${userData.used_inference_data ? 'I' : ''}	${formatPrice(userData.total_price)} ${userData.used_inference_data ? 'I' : ''}	${formatPrice(userData.inference_price \|\| 0)}	${formatNumber(userData.total_images)}

\n \n

Credit Additions

\n ${creditAdditions.length > 0 ? `\n \n \n \n \n \n \n \n \n \n \n \n ${creditAdditions.map(row => `\n \n \n \n \n \n \n \n `).join(\"\")}\n \n

ID	Date	Amount	Note	Stripe Payment ID
${row.id}	${formatDate(row.created_at)}	${formatPrice(row.amount)}	${row.note \|\| \"-\"}	${row.stripe_payment_intent_id \|\| \"-\"}

\n ` : '

No credit additions found for this user.

'}\n \n

User Requests (${requests.length})

\n ${requests.length > 0 ? `\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n ${requests.map(row => `\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n `).join(\"\")}\n \n

ID	Timestamp	Val ID	Branch ID	Input	Output	Cache Read	Cache Write	Model	Price	Finish	Images
${row.id}	${formatDate(row.timestamp)}	${row.val_id}	${row.branch_id ?? \"main\"}	${formatNumber(row.input_tokens)}	${formatNumber(row.output_tokens)}	${formatNumber(row.cache_read_tokens)}	${formatNumber(row.cache_write_tokens)}	${row.model}	${formatPrice(row.price)}	${row.finish_reason \|\| '-'}	${formatNumber(row.num_images)}

\n ` : '

No requests found for this user.

'}\n \n

\n View All Inference Calls\n

\n `;\n \n return renderLayout(content, {\n title: `Usage Dashboard - ${userData.username}`,\n activeTab: \"user\"\n });\n}",[],[721,878,907,929,931],"50a36330-5f0e-11f0-82bf-0224a6c84d84","usage-detail.ts","43fcf927-1393-4575-9160-6e91325353be",["D",1752317553464],"import { renderLayout } from \"./layout.ts\";\nimport { formatNumber, formatPrice, formatDate, formatBoolean } from \"../utils/formatters.ts\";\n\ninterface UsageDetail {\n id: number;\n user_id: string;\n username: string;\n timestamp: number;\n finish_timestamp?: number;\n val_id: string;\n branch_id: string | null;\n input_tokens?: number;\n output_tokens?: number;\n cache_read_tokens?: number;\n cache_write_tokens?: number;\n model: string;\n price?: number;\n finish_reason?: string;\n num_images?: number;\n our_api_token: boolean;\n}\n\ninterface InferenceCall {\n id: number;\n usage_id: number;\n timestamp: number;\n input_tokens?: number;\n output_tokens?: number;\n cache_read_tokens?: number;\n cache_write_tokens?: number;\n price?: number;\n step_type?: string;\n finish_reason?: string;\n}\n\ninterface InferenceTotals {\n input_tokens: number;\n output_tokens: number;\n cache_read_tokens: number;\n cache_write_tokens: number;\n price: number;\n count: number;\n}\n\nexport function renderUsageDetail(\n usage: UsageDetail, \n inferenceCalls: InferenceCall[],\n inferenceTotals: InferenceTotals | null\n): string {\n // Calculate duration if both timestamps are available\n let duration = '';\n if (usage.timestamp && usage.finish_timestamp) {\n const durationMs = usage.finish_timestamp - usage.timestamp;\n const seconds = Math.floor(durationMs / 1000);\n if (seconds < 60) {\n duration = `${seconds} seconds`;\n } else {\n const minutes = Math.floor(seconds / 60);\n const remainingSeconds = seconds % 60;\n duration = `${minutes} min ${remainingSeconds} sec`;\n }\n }\n \n // Check for discrepancies between usage record and inference calls\n const hasDiscrepancy = inferenceTotals && (\n (usage.input_tokens !== inferenceTotals.input_tokens && usage.input_tokens !== undefined) ||\n (usage.output_tokens !== inferenceTotals.output_tokens && usage.output_tokens !== undefined) ||\n (usage.cache_read_tokens !== inferenceTotals.cache_read_tokens && usage.cache_read_tokens !== undefined) ||\n (usage.cache_write_tokens !== inferenceTotals.cache_write_tokens && usage.cache_write_tokens !== undefined) ||\n (usage.price !== inferenceTotals.price && usage.price !== undefined)\n );\n \n // Generate the content\n const content = `\n

Usage Request Details

\n ← Back to all requests\n

\n \n

Request Summary

\n ID: ${usage.id}\n

\n User: ${usage.username}\n

\n Val ID: ${usage.val_id}\n

\n Branch ID: ${usage.branch_id || 'main'}\n

\n Start Time: ${formatDate(usage.timestamp)}\n

\n End Time: ${usage.finish_timestamp ? formatDate(usage.finish_timestamp) : 'N/A'}\n

\n Duration: ${duration || 'N/A'}\n

\n Model: ${usage.model}\n

\n Input Tokens: ${formatNumber(usage.input_tokens)}\n

\n Output Tokens: ${formatNumber(usage.output_tokens)}\n

\n Cache Read: ${formatNumber(usage.cache_read_tokens)}\n

\n Cache Write: ${formatNumber(usage.cache_write_tokens)}\n

\n Price: ${formatPrice(usage.price)}\n

\n Finish Reason: ${usage.finish_reason || 'N/A'}\n

\n Images: ${formatNumber(usage.num_images)}\n

\n Our API: ${formatBoolean(usage.our_api_token)}\n

\n \n ${hasDiscrepancy ? `\n

\n Warning: Discrepancies detected between usage record and inference calls.\n

\n \n

Comparison

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n 0.0001 ? 'discrepancy' : ''}\">\n \n \n \n \n \n \n

Metric	Usage Record	Inference Calls (${inferenceTotals?.count \|\| 0})	Difference
Input Tokens	${formatNumber(usage.input_tokens)}	${formatNumber(inferenceTotals?.input_tokens)}	${formatNumber((usage.input_tokens \|\| 0) - (inferenceTotals?.input_tokens \|\| 0))}
Output Tokens	${formatNumber(usage.output_tokens)}	${formatNumber(inferenceTotals?.output_tokens)}	${formatNumber((usage.output_tokens \|\| 0) - (inferenceTotals?.output_tokens \|\| 0))}
Cache Read	${formatNumber(usage.cache_read_tokens)}	${formatNumber(inferenceTotals?.cache_read_tokens)}	${formatNumber((usage.cache_read_tokens \|\| 0) - (inferenceTotals?.cache_read_tokens \|\| 0))}
Cache Write	${formatNumber(usage.cache_write_tokens)}	${formatNumber(inferenceTotals?.cache_write_tokens)}	${formatNumber((usage.cache_write_tokens \|\| 0) - (inferenceTotals?.cache_write_tokens \|\| 0))}
Price	${formatPrice(usage.price)}	${formatPrice(inferenceTotals?.price)}	${formatPrice((usage.price \|\| 0) - (inferenceTotals?.price \|\| 0))}

\n ` : ''}\n \n

Inference Calls (${inferenceCalls.length})

\n ${inferenceCalls.length > 0 ? `\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n ${inferenceCalls.map(call => `\n \n \n \n \n \n \n \n \n \n \n \n `).join(\"\")}\n \n

ID	Timestamp	Step Type	Input	Output	Cache Read	Cache Write	Price	Finish
${call.id}	${formatDate(call.timestamp)}	${call.step_type \|\| '-'}	${formatNumber(call.input_tokens)}	${formatNumber(call.output_tokens)}	${formatNumber(call.cache_read_tokens)}	${formatNumber(call.cache_write_tokens)}	${formatPrice(call.price)}	${call.finish_reason \|\| '-'}

\n ` : '

No inference calls found for this request.

'}\n

\n `;\n \n return renderLayout(content, {\n title: `Usage Dashboard - Request #${usage.id}`,\n activeTab: \"request\"\n });\n}",[],[721,878,907,929,938],"50a36038-5f0e-11f0-82bf-0224a6c84d84","requests.ts","e2268080-21f3-4fc8-aee9-2052e2fa07d2",["D",1752317553464],"import { renderLayout } from \"./layout.ts\";\nimport { formatNumber, formatPrice, formatDate, formatBoolean } from \"../utils/formatters.ts\";\nimport { renderPaginationControls } from \"../utils/pagination.ts\";\n\ninterface RequestRow {\n id: number;\n username: string;\n timestamp: number;\n val_id: string;\n branch_id: string | null;\n input_tokens: number | null;\n output_tokens: number | null;\n cache_read_tokens: number | null;\n cache_write_tokens: number | null;\n model: string;\n price: number | null;\n finish_reason: string | null;\n num_images: number | null;\n our_api_token: number;\n}\n\ninterface PaginationData {\n currentPage: number;\n totalPages: number;\n pageSize: number;\n totalItems: number;\n hasNextPage: boolean;\n hasPrevPage: boolean;\n}\n\nexport function renderRequests(data: RequestRow[], pagination: PaginationData, baseUrl: string, filtered = false): string {\n // Calculate totals\n const totalRequests = pagination.totalItems;\n const totalPrice = data.reduce((sum, row) => sum + (row.price || 0), 0);\n \n // Generate pagination controls\n const paginationControls = renderPaginationControls(pagination, baseUrl);\n \n // No client-side script needed\n const script = '';\n \n // Generate the content\n const content = `\n

${filtered ? 'Filtered' : 'All'} Usage Requests

\n ${filtered ? '

← Back to all users

' : ''}\n

Total Requests: ${totalRequests}

Total Price: ${formatPrice(totalPrice)}

\n \n ${paginationControls}\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n ${data.map(row => `\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n `).join(\"\")}\n \n

ID	User	Timestamp	Val ID	Branch ID	Input	Output	Cache Read	Cache Write	Model	Price	Finish	Images	Our API
${row.id}	${row.username}	${formatDate(row.timestamp)}	${row.val_id}	${row.branch_id ?? \"main\"}	${formatNumber(row.input_tokens)}	${formatNumber(row.output_tokens)}	${formatNumber(row.cache_read_tokens)}	${formatNumber(row.cache_write_tokens)}	${row.model}	${formatPrice(row.price)}	${row.finish_reason \|\| '-'}	${formatNumber(row.num_images)}	${formatBoolean(row.our_api_token)}

\n \n ${paginationControls}\n

\n `;\n \n return renderLayout(content, {\n title: \"Usage Dashboard - All Requests\",\n activeTab: \"requests\",\n scripts: [script]\n });\n}",[],[721,878,907,929,945],"50a35624-5f0e-11f0-82bf-0224a6c84d84","layout.ts","f8d402bb-feeb-4ed7-b849-050b8f6b0497",["D",1752317553464],"/**\n * Common layout for all dashboard pages\n */\n\nexport interface LayoutOptions {\n title: string;\n activeTab?: string;\n scripts?: string[];\n styles?: string[];\n}\n\nexport function renderLayout(content: string, options: LayoutOptions): string {\n const { title, activeTab = \"dashboard\", scripts = [], styles = [] } = options;\n \n // Default styles\n const defaultStyles = `\n body {\n font-family: -apple-system, BlinkMacSystemFont, \"Segoe UI\", Roboto, Helvetica, Arial, sans-serif;\n line-height: 1.6;\n color: #333;\n max-width: 1200px;\n margin: 0 auto;\n padding: 20px;\n }\n h1, h2 {\n color: #2c3e50;\n }\n table {\n width: 100%;\n border-collapse: collapse;\n margin-bottom: 30px;\n font-size: 14px;\n }\n th, td {\n padding: 8px 12px;\n text-align: left;\n border-bottom: 1px solid #ddd;\n }\n th {\n background-color: #f8f9fa;\n font-weight: 600;\n position: sticky;\n top: 0;\n }\n tr:hover {\n background-color: #f5f5f5;\n }\n .container {\n margin-bottom: 40px;\n }\n .price {\n font-weight: bold;\n }\n .summary {\n background-color: #f8f9fa;\n padding: 15px;\n border-radius: 5px;\n margin-bottom: 20px;\n }\n .tabs {\n display: flex;\n margin-bottom: 20px;\n }\n .tab {\n padding: 10px 20px;\n cursor: pointer;\n border: 1px solid #ddd;\n background-color: #f8f9fa;\n margin-right: 5px;\n border-radius: 5px 5px 0 0;\n text-decoration: none;\n color: #333;\n }\n .tab.active {\n background-color: #fff;\n border-bottom: 1px solid #fff;\n font-weight: bold;\n }\n .pagination {\n display: flex;\n justify-content: center;\n margin: 20px 0;\n }\n .page-link {\n padding: 8px 12px;\n margin: 0 5px;\n border: 1px solid #ddd;\n text-decoration: none;\n color: #333;\n border-radius: 3px;\n }\n .page-link.current {\n background-color: #f0f0f0;\n font-weight: bold;\n }\n .page-link.disabled {\n color: #aaa;\n cursor: not-allowed;\n }\n .collapsible {\n cursor: pointer;\n }\n .inference-details {\n display: none;\n background-color: #f9f9f9;\n padding: 10px;\n margin: 10px 0;\n border-radius: 5px;\n }\n .inference-details.visible {\n display: block;\n }\n .comparison {\n display: flex;\n gap: 20px;\n }\n .comparison-item {\n flex: 1;\n }\n .discrepancy {\n color: #e74c3c;\n font-weight: bold;\n }\n .badge {\n display: inline-block;\n padding: 2px 6px;\n border-radius: 10px;\n font-size: 12px;\n font-weight: bold;\n margin-left: 5px;\n }\n .badge-info {\n background-color: #3498db;\n color: white;\n }\n .badge-warning {\n background-color: #f39c12;\n color: white;\n }\n .loading {\n text-align: center;\n padding: 20px;\n }\n .back-link {\n margin-bottom: 15px;\n }\n .back-link a {\n display: inline-flex;\n align-items: center;\n text-decoration: none;\n color: #3498db;\n }\n .back-link a:hover {\n text-decoration: underline;\n }\n .actions {\n margin-top: 20px;\n display: flex;\n gap: 10px;\n }\n .button {\n display: inline-block;\n padding: 8px 15px;\n background-color: #3498db;\n color: white;\n text-decoration: none;\n border-radius: 4px;\n border: none;\n cursor: pointer;\n }\n .button:hover {\n background-color: #2980b9;\n }\n .summary-card {\n background-color: #f8f9fa;\n border-radius: 5px;\n padding: 15px;\n margin-bottom: 20px;\n }\n .card-grid {\n display: grid;\n grid-template-columns: repeat(auto-fill, minmax(250px, 1fr));\n gap: 10px;\n }\n .card-item {\n padding: 5px;\n }\n .alert {\n padding: 10px 15px;\n border-radius: 5px;\n margin-bottom: 20px;\n }\n .alert-warning {\n background-color: #fcf8e3;\n border: 1px solid #faebcc;\n color: #8a6d3b;\n }\n .comparison-table {\n margin-bottom: 30px;\n }\n tr.discrepancy {\n background-color: #fcf8e3;\n }\n `;\n \n // Combine all styles\n const allStyles = [defaultStyles, ...styles].join(\"\\n\");\n \n // Default scripts\n const defaultScripts = `\n document.addEventListener('DOMContentLoaded', function() {\n // Tab navigation\n document.querySelectorAll('.tab').forEach(tab => {\n tab.addEventListener('click', function(e) {\n if (this.getAttribute('href') === '#') {\n e.preventDefault();\n const tabId = this.getAttribute('data-tab');\n \n // Hide all tab contents\n document.querySelectorAll('.tab-content').forEach(content => {\n content.classList.remove('active');\n });\n \n // Deactivate all tabs\n document.querySelectorAll('.tab').forEach(tab => {\n tab.classList.remove('active');\n });\n \n // Activate the selected tab and content\n document.getElementById(tabId).classList.add('active');\n this.classList.add('active');\n }\n });\n });\n });\n `;\n \n // Combine all scripts\n const allScripts = [defaultScripts, ...scripts].join(\"\\n\");\n \n return `\n \n \n \n \n \n ${title}\n \n \n \n

Usage Dashboard

\n \n

\n Grouped by User\n All Requests\n Inference Calls\n Credit Additions\n ${activeTab === 'user' ? `User Details` : ''}\n

\n \n ${content}\n \n \n \n \n `;\n}",[],[721,878,907,929,952],"50a3521e-5f0e-11f0-82bf-0224a6c84d84","inference-calls.ts","69c3f3a5-62bb-497b-b64b-6ea0b2a5f699",["D",1752317553464],"import { renderLayout } from \"./layout.ts\";\nimport { formatNumber, formatPrice, formatDate } from \"../utils/formatters.ts\";\nimport { renderPaginationControls } from \"../utils/pagination.ts\";\n\ninterface InferenceCallRow {\n id: number;\n usage_id: number;\n username: string;\n user_id: string;\n val_id: string;\n branch_id: string | null;\n timestamp: number;\n input_tokens: number | null;\n output_tokens: number | null;\n cache_read_tokens: number | null;\n cache_write_tokens: number | null;\n step_type: string | null;\n price: number | null;\n finish_reason: string | null;\n}\n\ninterface PaginationData {\n currentPage: number;\n totalPages: number;\n pageSize: number;\n totalItems: number;\n hasNextPage: boolean;\n hasPrevPage: boolean;\n}\n\nexport function renderInferenceCalls(\n data: InferenceCallRow[], \n pagination: PaginationData, \n baseUrl: string,\n filtered: boolean = false\n): string {\n // Calculate totals\n const totalCalls = pagination.totalItems;\n const totalPrice = data.reduce((sum, row) => sum + (row.price || 0), 0);\n \n // Generate pagination controls\n const paginationControls = renderPaginationControls(pagination, baseUrl);\n \n // Generate the content\n const content = `\n

Inference Calls ${filtered ? '(Filtered)' : ''}

\n ${filtered ? '

← Back to all users

' : ''}\n

Total Inference Calls: ${totalCalls}

Total Price: ${formatPrice(totalPrice)}

\n ${filtered ? '

Clear filter

' : ''}\n

\n \n ${paginationControls}\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n ${data.map(row => `\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n `).join(\"\")}\n \n

ID	Usage ID	User	User ID	Val ID	Branch ID	Timestamp	Input	Output	Cache Read	Cache Write	Step Type	Price	Finish
${row.id}	${row.usage_id}	${row.username}	${row.user_id}	${row.val_id}	${row.branch_id ?? \"main\"}	${formatDate(row.timestamp)}	${formatNumber(row.input_tokens)}	${formatNumber(row.output_tokens)}	${formatNumber(row.cache_read_tokens)}	${formatNumber(row.cache_write_tokens)}	${row.step_type \|\| '-'}	${formatPrice(row.price)}	${row.finish_reason \|\| '-'}

\n \n ${paginationControls}\n

\n `;\n \n return renderLayout(content, {\n title: \"Usage Dashboard - Inference Calls\",\n activeTab: \"inference\"\n });\n}",[],[721,878,907,929,959],"50a34f62-5f0e-11f0-82bf-0224a6c84d84","dashboard.ts","6f101e44-811d-4c1a-8c2d-035f25fb59b9",["D",1752317553464],"import { renderLayout } from \"./layout.ts\";\nimport { formatNumber, formatPrice } from \"../utils/formatters.ts\";\n\ninterface UserSummaryRow {\n user_id: string;\n username: string;\n request_count: number;\n total_input_tokens: number;\n total_output_tokens: number;\n total_cache_read_tokens: number;\n total_cache_write_tokens: number;\n total_price: number;\n inference_price: number;\n total_images: number;\n used_inference_data?: boolean;\n}\n\nexport function renderDashboard(data: UserSummaryRow[]): string {\n // Calculate totals\n const totalUsers = data.length;\n const totalPrice = data.reduce((sum, row) => sum + (row.total_price || 0), 0);\n const totalInferencePrice = data.reduce((sum, row) => sum + (row.inference_price || 0), 0);\n \n // Generate the content\n const content = `\n

Usage by User

Total Users: ${totalUsers}

Total Price: ${formatPrice(totalPrice)}

Total Inference Price: ${formatPrice(totalInferencePrice)}

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n ${data.map(row => `\n \n \n \n \n \n \n \n \n \n \n \n \n `).join(\"\")}\n \n

User ID	Username	Requests	Input Tokens	Output Tokens	Cache Read	Cache Write	Total Price	Inference Price	Images
${row.user_id}	${row.username}	${formatNumber(row.request_count)}	${formatNumber(row.total_input_tokens)} ${row.used_inference_data ? 'I' : ''}	${formatNumber(row.total_output_tokens)} ${row.used_inference_data ? 'I' : ''}	${formatNumber(row.total_cache_read_tokens)} ${row.used_inference_data ? 'I' : ''}	${formatNumber(row.total_cache_write_tokens)} ${row.used_inference_data ? 'I' : ''}	${formatPrice(row.total_price)} ${row.used_inference_data ? 'I' : ''}	${formatPrice(row.inference_price \|\| 0)}	${formatNumber(row.total_images)}

\n `;\n \n return renderLayout(content, {\n title: \"Usage Dashboard - User Summary\",\n activeTab: \"grouped\"\n });\n}",[],[721,878,907,929,966],"50a3499a-5f0e-11f0-82bf-0224a6c84d84","credit-additions.ts","3cff4aed-e7f7-41e8-b600-a94d845e4ed4",["D",1752317553464],"import { renderLayout } from \"./layout.ts\";\nimport { formatNumber, formatPrice, formatDate } from \"../utils/formatters.ts\";\nimport { PaginationResult, renderPaginationControls } from \"../utils/pagination.ts\";\nimport { CreditAddition } from \"../api/credit-additions.ts\";\n\ninterface CreditAdditionsSummary {\n total_count: number;\n total_amount: number;\n}\n\n/**\n * Render the credit additions page\n */\nexport function renderCreditAdditions(\n data: CreditAddition[],\n pagination: PaginationResult,\n url: string,\n filtered: boolean = false,\n summary: CreditAdditionsSummary = { total_count: 0, total_amount: 0 }\n): string {\n const currentUrl = new URL(url);\n \n const filterForm = `\n \n `;\n \n const summarySection = `\n

Total Credit Additions: ${formatNumber(summary.total_count)}

Total Amount: ${formatPrice(summary.total_amount)}

\n `;\n \n // Generate pagination controls\n const paginationControls = renderPaginationControls(pagination, url);\n \n const table = data.length > 0 ? `\n \n \n \n \n \n \n \n \n \n \n \n \n ${data.map(row => `\n \n \n \n \n \n \n \n \n `).join(\"\")}\n \n

ID	User ID	Date	Amount	Note	Stripe Payment ID
${row.id}	${row.user_id}	${formatDate(row.created_at)}	${formatPrice(row.amount)}	${row.note \|\| \"-\"}	${row.stripe_payment_intent_id \|\| \"-\"}

\n \n ${paginationControls}\n ` : '

No credit additions found.

';\n \n // Generate the content\n const content = `\n

Credit Additions${filtered ? \" (Filtered)\" : \"\"}

\n ${filterForm}\n ${summarySection}\n ${paginationControls}\n ${table}\n

\n `;\n \n return renderLayout(content, {\n title: \"Usage Dashboard - Credit Additions\",\n activeTab: \"credit-additions\",\n scripts: [`\n document.addEventListener('DOMContentLoaded', function() {\n // Date inputs initialization\n const today = new Date();\n const formatDate = date => {\n const yyyy = date.getFullYear();\n const mm = String(date.getMonth() + 1).padStart(2, '0');\n const dd = String(date.getDate()).padStart(2, '0');\n return yyyy + '-' + mm + '-' + dd;\n };\n \n // Set default values for date inputs if they're empty\n const startDateInput = document.getElementById('start_date');\n const endDateInput = document.getElementById('end_date');\n \n if (!startDateInput.value && !endDateInput.value) {\n // By default, don't set any dates to allow seeing all records\n }\n });\n `]\n });\n}",[],[721,878,907,929,973],"50a37636-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[269,270,271,272,273,274,275,276],[721,878,907,929],"50a345c6-5f0e-11f0-82bf-0224a6c84d84","pagination.ts","ef170b11-d330-4ba5-b5b0-39cae80693f7","833e336c-7ef6-4b51-a5e8-1dc08e482277",["D",1752317553464],"/**\n * Pagination utilities for the dashboard\n */\n\nexport interface PaginationParams {\n page: number;\n pageSize: number;\n totalItems: number;\n}\n\nexport interface PaginationResult {\n currentPage: number;\n totalPages: number;\n pageSize: number;\n totalItems: number;\n hasNextPage: boolean;\n hasPrevPage: boolean;\n}\n\n/**\n * Parse pagination parameters from URL\n */\nexport function getPaginationParams(url: URL): { page: number; pageSize: number } {\n const page = parseInt(url.searchParams.get(\"page\") || \"1\", 10);\n const pageSize = parseInt(url.searchParams.get(\"pageSize\") || \"50\", 10);\n \n // Validate and set limits\n return {\n page: Math.max(1, page),\n pageSize: Math.min(Math.max(10, pageSize), 100) // Between 10 and 100\n };\n}\n\n/**\n * Calculate pagination metadata\n */\nexport function calculatePagination(params: PaginationParams): PaginationResult {\n const totalPages = Math.ceil(params.totalItems / params.pageSize);\n \n return {\n currentPage: params.page,\n totalPages,\n pageSize: params.pageSize,\n totalItems: params.totalItems,\n hasNextPage: params.page < totalPages,\n hasPrevPage: params.page > 1\n };\n}\n\n/**\n * Generate SQL LIMIT and OFFSET clauses for pagination\n */\nexport function getPaginationSQL(page: number, pageSize: number): string {\n const offset = (page - 1) * pageSize;\n return `LIMIT ${pageSize} OFFSET ${offset}`;\n}\n\n/**\n * Generate HTML for pagination controls\n */\nexport function renderPaginationControls(pagination: PaginationResult, baseUrl: string): string {\n const url = new URL(baseUrl);\n \n // Function to generate page URL\n const getPageUrl = (page: number) => {\n url.searchParams.set(\"page\", page.toString());\n return url.toString();\n };\n \n let html = '

';\n \n // Previous button\n if (pagination.hasPrevPage) {\n html += `Previous`;\n } else {\n html += 'Previous';\n }\n \n // Page numbers\n const maxPages = 5;\n const startPage = Math.max(1, pagination.currentPage - Math.floor(maxPages / 2));\n const endPage = Math.min(pagination.totalPages, startPage + maxPages - 1);\n \n for (let i = startPage; i <= endPage; i++) {\n if (i === pagination.currentPage) {\n html += `${i}`;\n } else {\n html += `${i}`;\n }\n }\n \n // Next button\n if (pagination.hasNextPage) {\n html += `Next`;\n } else {\n html += 'Next';\n }\n \n html += '

';\n return html;\n}",[],[721,878,907,91,984],"50a342ba-5f0e-11f0-82bf-0224a6c84d84","formatters.ts","706ac4b4-b52f-4907-ad8d-1a779e8391ef",["D",1752317553464],"// Utility functions for formatting data in the dashboard\n\n/**\n * Format timestamp for display in Eastern Time (New York)\n */\nexport const formatDate = (timestamp: number): string => {\n return new Date(timestamp).toLocaleString(\"en-US\", {\n timeZone: \"America/New_York\",\n });\n};\n\n/**\n * Format boolean for display\n */\nexport const formatBoolean = (value: number): string => {\n return value ? \"Yes\" : \"No\";\n};\n\n/**\n * Format number with commas\n */\nexport const formatNumber = (num: number | null): string => {\n if (num === null || num === undefined) return \"-\";\n return num.toLocaleString();\n};\n\n/**\n * Format price as currency\n */\nexport const formatPrice = (price: number | null): string => {\n if (price === null || price === undefined) return \"-\";\n return `$${price.toFixed(4)}`;\n};",[],[721,878,907,91,992],"50a3485a-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[266,267],[721,878,907,91],"50a33b94-5f0e-11f0-82bf-0224a6c84d84","val-summary.ts","3712f7f0-4701-4f00-8057-dc8814abaa12","67982fe8-eb32-4127-855e-38a529fe0743",["D",1752317553464],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { USAGE_TABLE, INFERENCE_CALLS_TABLE } from \"../../schema.tsx\";\n\n/**\n * Get usage data for a specific val\n */\nexport async function getValSummary(valId: string) {\n // Get summary data for the val from the usage table\n const usageSummaryResult = await sqlite.execute(`\n SELECT \n val_id,\n COUNT(*) as request_count,\n SUM(input_tokens) as total_input_tokens,\n SUM(output_tokens) as total_output_tokens,\n SUM(cache_read_tokens) as total_cache_read_tokens,\n SUM(cache_write_tokens) as total_cache_write_tokens,\n SUM(price) as total_price,\n SUM(num_images) as total_images\n FROM ${USAGE_TABLE}\n WHERE val_id = ? AND our_api_token = 1\n GROUP BY val_id\n `, [valId]);\n \n // Get summary data from inference calls table (for pricing)\n const inferenceSummaryResult = await sqlite.execute(`\n SELECT \n u.val_id,\n COUNT(DISTINCT i.usage_id) as inference_request_count,\n SUM(i.input_tokens) as inference_input_tokens,\n SUM(i.output_tokens) as inference_output_tokens,\n SUM(i.cache_read_tokens) as inference_cache_read_tokens,\n SUM(i.cache_write_tokens) as inference_cache_write_tokens,\n SUM(i.price) as inference_price\n FROM ${INFERENCE_CALLS_TABLE} i\n JOIN ${USAGE_TABLE} u ON i.usage_id = u.id\n WHERE u.val_id = ? AND u.our_api_token = 1\n GROUP BY u.val_id\n `, [valId]);\n \n // Get all requests for this val\n const requestsResult = await sqlite.execute(`\n SELECT * FROM ${USAGE_TABLE}\n WHERE val_id = ? AND our_api_token = 1\n ORDER BY timestamp DESC\n `, [valId]);\n \n // If no summary data was found, create a default summary\n const usageSummary = usageSummaryResult.rows[0] || {\n val_id: valId,\n request_count: 0,\n total_input_tokens: 0,\n total_output_tokens: 0,\n total_cache_read_tokens: 0,\n total_cache_write_tokens: 0,\n total_price: 0,\n total_images: 0\n };\n \n const inferenceSummary = inferenceSummaryResult.rows[0] || {\n val_id: valId,\n inference_request_count: 0,\n inference_input_tokens: 0,\n inference_output_tokens: 0,\n inference_cache_read_tokens: 0,\n inference_cache_write_tokens: 0,\n inference_price: 0\n };\n \n // Merge the summaries, prioritizing inference data for pricing\n const summary = {\n val_id: valId,\n request_count: usageSummary.request_count,\n // Original values from usage table\n original_input_tokens: usageSummary.total_input_tokens,\n original_output_tokens: usageSummary.total_output_tokens,\n original_cache_read_tokens: usageSummary.total_cache_read_tokens,\n original_cache_write_tokens: usageSummary.total_cache_write_tokens,\n original_price: usageSummary.total_price,\n // Use inference data as source of truth when available\n total_input_tokens: inferenceSummary.inference_input_tokens || usageSummary.total_input_tokens,\n total_output_tokens: inferenceSummary.inference_output_tokens || usageSummary.total_output_tokens,\n total_cache_read_tokens: inferenceSummary.inference_cache_read_tokens || usageSummary.total_cache_read_tokens,\n total_cache_write_tokens: inferenceSummary.inference_cache_write_tokens || usageSummary.total_cache_write_tokens,\n total_price: inferenceSummary.inference_price || usageSummary.total_price,\n // Always include inference price for comparison\n inference_price: inferenceSummary.inference_price || 0,\n total_images: usageSummary.total_images,\n // Add flag to indicate inference data usage\n used_inference_data: !!inferenceSummary.inference_price,\n inference_price_primary: true\n };\n \n return {\n summary,\n requests: requestsResult.rows\n };\n}",[],[721,878,907,1010,1003],"api","50a331f8-5f0e-11f0-82bf-0224a6c84d84","user-summary.ts","db232c17-6e39-4357-896d-1efa250ba224",["D",1752317553464],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { USAGE_TABLE, INFERENCE_CALLS_TABLE } from \"../../schema.tsx\";\n\n/**\n * Get usage data grouped by user\n * This includes a fallback to inference calls data when usage data is missing\n */\nexport async function getUserSummary(userId?: string) {\n // First, get the standard grouped data from the usage table\n let query = `\n SELECT \n user_id, \n username,\n COUNT(*) as request_count,\n SUM(input_tokens) as total_input_tokens,\n SUM(output_tokens) as total_output_tokens,\n SUM(cache_read_tokens) as total_cache_read_tokens,\n SUM(cache_write_tokens) as total_cache_write_tokens,\n SUM(price) as total_price,\n SUM(num_images) as total_images\n FROM ${USAGE_TABLE}\n WHERE our_api_token = 1\n `;\n \n if (userId) {\n query += ` AND user_id = '${userId}'`;\n }\n \n query += `\n GROUP BY user_id, username\n ORDER BY total_price DESC\n `;\n \n const groupedUsageData = await sqlite.execute(query);\n\n // Get total inference calls price per user\n let inferenceQuery = `\n SELECT \n u.user_id,\n SUM(i.price) as inference_price\n FROM ${INFERENCE_CALLS_TABLE} i\n JOIN ${USAGE_TABLE} u ON i.usage_id = u.id\n WHERE u.our_api_token = 1\n `;\n \n if (userId) {\n inferenceQuery += ` AND u.user_id = '${userId}'`;\n }\n \n inferenceQuery += `\n GROUP BY u.user_id\n `;\n \n const inferenceCallsPrice = await sqlite.execute(inferenceQuery);\n\n // Create a map of inference calls price by user_id\n const inferencePriceByUser = new Map();\n for (const row of inferenceCallsPrice.rows) {\n inferencePriceByUser.set(row.user_id, row.inference_price || 0);\n }\n\n // Now get data from inference calls for requests with missing data\n let missingDataQuery = `\n SELECT \n u.user_id,\n u.username,\n u.id as usage_id,\n SUM(i.input_tokens) as inf_input_tokens,\n SUM(i.output_tokens) as inf_output_tokens,\n SUM(i.cache_read_tokens) as inf_cache_read_tokens,\n SUM(i.cache_write_tokens) as inf_cache_write_tokens,\n SUM(i.price) as inf_price\n FROM ${INFERENCE_CALLS_TABLE} i\n JOIN ${USAGE_TABLE} u ON i.usage_id = u.id\n WHERE (u.price IS NULL OR u.input_tokens IS NULL)\n `;\n \n if (userId) {\n missingDataQuery += ` AND u.user_id = '${userId}'`;\n }\n \n missingDataQuery += `\n GROUP BY u.user_id, u.username, u.id\n `;\n \n const inferenceData = await sqlite.execute(missingDataQuery);\n\n // Create a map of inference data by user_id\n const inferenceByUser = new Map();\n for (const row of inferenceData.rows) {\n if (!inferenceByUser.has(row.user_id)) {\n inferenceByUser.set(row.user_id, {\n input_tokens: 0,\n output_tokens: 0,\n cache_read_tokens: 0,\n cache_write_tokens: 0,\n price: 0,\n request_count: 0\n });\n }\n \n const userData = inferenceByUser.get(row.user_id);\n userData.input_tokens += row.inf_input_tokens || 0;\n userData.output_tokens += row.inf_output_tokens || 0;\n userData.cache_read_tokens += row.inf_cache_read_tokens || 0;\n userData.cache_write_tokens += row.inf_cache_write_tokens || 0;\n userData.price += row.inf_price || 0;\n userData.request_count += 1;\n }\n\n // Merge the data, using inference data when usage data is missing or zero\n const mergedData = groupedUsageData.rows.map(row => {\n const inferenceUserData = inferenceByUser.get(row.user_id);\n const inferencePrice = inferencePriceByUser.get(row.user_id) || 0;\n \n if (!inferenceUserData) {\n return {\n ...row,\n inference_price: inferencePrice\n };\n }\n \n // For each field, use the usage data if it exists, otherwise use inference data\n return {\n ...row,\n total_input_tokens: row.total_input_tokens || inferenceUserData.input_tokens,\n total_output_tokens: row.total_output_tokens || inferenceUserData.output_tokens,\n total_cache_read_tokens: row.total_cache_read_tokens || inferenceUserData.cache_read_tokens,\n total_cache_write_tokens: row.total_cache_write_tokens || inferenceUserData.cache_write_tokens,\n total_price: row.total_price || inferenceUserData.price,\n inference_price: inferencePrice,\n // Add a flag to indicate that inference data was used\n used_inference_data: !row.total_price || !row.total_input_tokens\n };\n });\n\n // Add any users that only exist in inference data\n for (const [userId, userData] of inferenceByUser.entries()) {\n if (!mergedData.some(row => row.user_id === userId)) {\n // Get the username from the inference data\n const userRow = inferenceData.rows.find(row => row.user_id === userId);\n if (userRow) {\n mergedData.push({\n user_id: userId,\n username: userRow.username,\n request_count: userData.request_count,\n total_input_tokens: userData.input_tokens,\n total_output_tokens: userData.output_tokens,\n total_cache_read_tokens: userData.cache_read_tokens,\n total_cache_write_tokens: userData.cache_write_tokens,\n total_price: userData.price,\n inference_price: inferencePriceByUser.get(userId) || 0,\n total_images: 0,\n used_inference_data: true\n });\n }\n }\n }\n\n // Sort by total price\n mergedData.sort((a, b) => (b.total_price || 0) - (a.total_price || 0));\n\n return mergedData;\n}",[],[721,878,907,1010,1012],"50a32f78-5f0e-11f0-82bf-0224a6c84d84","98058631-67ac-4365-aaa6-824fc621d993",["D",1752317553464],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { USAGE_TABLE, INFERENCE_CALLS_TABLE } from \"../../schema.tsx\";\nimport { getPaginationParams, getPaginationSQL, calculatePagination } from \"../utils/pagination.ts\";\n\n/**\n * Get paginated usage requests\n */\nexport async function getRequests(url: URL) {\n const { page, pageSize } = getPaginationParams(url);\n const userId = url.searchParams.get(\"user_id\");\n \n // Build WHERE clause if userId is provided\n const whereClause = userId ? `WHERE user_id = '${userId}'` : '';\n \n // Get total count for pagination\n const countResult = await sqlite.execute(`\n SELECT COUNT(*) as total FROM ${USAGE_TABLE} ${whereClause}\n `);\n const totalItems = countResult.rows[0].total;\n \n // Get paginated data\n const paginationSQL = getPaginationSQL(page, pageSize);\n const allUsageData = await sqlite.execute(`\n SELECT * FROM ${USAGE_TABLE} \n ${whereClause}\n ORDER BY timestamp DESC\n ${paginationSQL}\n `);\n \n // Calculate pagination metadata\n const pagination = calculatePagination({ page, pageSize, totalItems });\n \n return {\n data: allUsageData.rows,\n pagination,\n filtered: !!userId\n };\n}\n\n/**\n * Get a single request by ID\n */\nexport async function getRequestById(id: string) {\n const result = await sqlite.execute(`\n SELECT * FROM ${USAGE_TABLE} \n WHERE id = ?\n `, [id]);\n \n if (result.rows.length === 0) {\n return null;\n }\n \n return result.rows[0];\n}\n\n/**\n * Get inference calls for a specific usage request\n */\nexport async function getInferenceCallsForRequest(usageId: string) {\n const result = await sqlite.execute(`\n SELECT \n i.id,\n i.usage_id,\n i.timestamp,\n i.input_tokens,\n i.output_tokens,\n i.cache_read_tokens,\n i.cache_write_tokens,\n i.price,\n i.step_type,\n i.finish_reason\n FROM ${INFERENCE_CALLS_TABLE} i\n WHERE i.usage_id = ?\n ORDER BY i.timestamp ASC\n `, [usageId]);\n \n return result.rows;\n}\n\n/**\n * Calculate totals from inference calls for a request\n */\nexport async function getInferenceTotalsForRequest(usageId: string) {\n const calls = await getInferenceCallsForRequest(usageId);\n \n if (calls.length === 0) {\n return null;\n }\n \n return {\n input_tokens: calls.reduce((sum, call) => sum + (call.input_tokens || 0), 0),\n output_tokens: calls.reduce((sum, call) => sum + (call.output_tokens || 0), 0),\n cache_read_tokens: calls.reduce((sum, call) => sum + (call.cache_read_tokens || 0), 0),\n cache_write_tokens: calls.reduce((sum, call) => sum + (call.cache_write_tokens || 0), 0),\n price: calls.reduce((sum, call) => sum + (call.price || 0), 0),\n count: calls.length\n };\n}",[],[721,878,907,1010,945],"50a32d0c-5f0e-11f0-82bf-0224a6c84d84","d083909d-9c10-49e0-af5f-f50080bcee8f",["D",1752317553464],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { USAGE_TABLE, INFERENCE_CALLS_TABLE } from \"../../schema.tsx\";\nimport { getPaginationParams, getPaginationSQL, calculatePagination } from \"../utils/pagination.ts\";\n\n/**\n * Get paginated inference calls\n */\nexport async function getInferenceCalls(url: URL) {\n const { page, pageSize } = getPaginationParams(url);\n const usageId = url.searchParams.get(\"usage_id\");\n const userId = url.searchParams.get(\"user_id\");\n \n // Build the WHERE clause based on filters\n let whereClause = \"\";\n if (usageId) {\n whereClause = `WHERE i.usage_id = ${usageId}`;\n } else if (userId) {\n whereClause = `WHERE u.user_id = '${userId}'`;\n }\n \n // Get total count for pagination\n let countQuery = `\n SELECT COUNT(*) as total \n FROM ${INFERENCE_CALLS_TABLE} i\n `;\n \n if (userId) {\n countQuery = `\n SELECT COUNT(*) as total \n FROM ${INFERENCE_CALLS_TABLE} i\n JOIN ${USAGE_TABLE} u ON i.usage_id = u.id\n ${whereClause}\n `;\n } else {\n countQuery += whereClause;\n }\n \n const countResult = await sqlite.execute(countQuery);\n const totalItems = countResult.rows[0].total;\n \n // Get paginated data\n const paginationSQL = getPaginationSQL(page, pageSize);\n const inferenceCallsData = await sqlite.execute(`\n SELECT \n i.id,\n i.usage_id,\n u.username,\n u.user_id,\n u.val_id,\n u.branch_id,\n i.timestamp,\n i.input_tokens,\n i.output_tokens,\n i.cache_read_tokens,\n i.cache_write_tokens,\n i.price,\n i.step_type,\n i.finish_reason\n FROM ${INFERENCE_CALLS_TABLE} i\n JOIN ${USAGE_TABLE} u ON i.usage_id = u.id\n ${whereClause}\n ORDER BY i.timestamp DESC\n ${paginationSQL}\n `);\n \n // Calculate pagination metadata\n const pagination = calculatePagination({ page, pageSize, totalItems });\n \n return {\n data: inferenceCallsData.rows,\n pagination,\n filtered: !!(usageId || userId)\n };\n}",[],[721,878,907,1010,959],"50a32a46-5f0e-11f0-82bf-0224a6c84d84","7f173a24-5975-4207-bde8-a08f74ebeb2d",["D",1752317553464],"import { getRequests, getRequestById, getInferenceCallsForRequest } from \"./requests.ts\";\nimport { getUserSummary } from \"./user-summary.ts\";\nimport { getInferenceCalls } from \"./inference-calls.ts\";\nimport { getCreditAdditions } from \"./credit-additions.ts\";\n\n/**\n * Handle API requests\n */\nexport async function handleApiRequest(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(\"/api/\", \"\");\n \n try {\n // Route to the appropriate API handler\n if (path === \"requests\") {\n const usageId = url.searchParams.get(\"usage_id\");\n if (usageId) {\n const request = await getRequestById(usageId);\n if (!request) {\n return new Response(JSON.stringify({ error: \"Request not found\" }), {\n status: 404,\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n return new Response(JSON.stringify(request), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n } else {\n const data = await getRequests(url);\n return new Response(JSON.stringify(data), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n } \n else if (path === \"inference-calls\") {\n const usageId = url.searchParams.get(\"usage_id\");\n if (usageId) {\n const calls = await getInferenceCallsForRequest(usageId);\n return new Response(JSON.stringify({ data: calls }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n } else {\n const data = await getInferenceCalls(url);\n return new Response(JSON.stringify(data), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n }\n else if (path === \"user-summary\") {\n const data = await getUserSummary();\n return new Response(JSON.stringify({ data }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n else if (path === \"credit-additions\") {\n const userId = url.searchParams.get(\"user_id\");\n const data = await getCreditAdditions(url);\n return new Response(JSON.stringify(data), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n else {\n return new Response(JSON.stringify({ error: \"Not found\" }), {\n status: 404,\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n } catch (error) {\n console.error(\"API error:\", error);\n return new Response(JSON.stringify({ error: error.message }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n}",[],[721,878,907,1010,363],"50a320d2-5f0e-11f0-82bf-0224a6c84d84","bde29944-a96c-4eab-b582-88ffaced817a",["D",1752317553464],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { CREDIT_ADDITIONS_TABLE } from \"../../schema.tsx\";\nimport { getPaginationParams, getPaginationSQL, calculatePagination } from \"../utils/pagination.ts\";\n\nexport interface CreditAddition {\n id: number;\n user_id: string;\n created_at: number;\n stripe_payment_intent_id: string | null;\n amount: number;\n note: string;\n}\n\n/**\n * Get credit additions with optional filtering and pagination\n */\nexport async function getCreditAdditions(url: URL) {\n // Parse pagination parameters\n const { page, pageSize } = getPaginationParams(url);\n \n // Parse filtering parameters\n const userId = url.searchParams.get(\"user_id\");\n const startDate = url.searchParams.get(\"start_date\");\n const endDate = url.searchParams.get(\"end_date\");\n \n // Build the WHERE clause based on filters\n let whereClause = \"\";\n const whereParams: any[] = [];\n \n if (userId) {\n whereClause += \" WHERE user_id = ?\";\n whereParams.push(userId);\n }\n \n // Add date range filters if provided\n if (startDate) {\n const startTimestamp = new Date(startDate).getTime();\n whereClause += whereClause ? \" AND\" : \" WHERE\";\n whereClause += \" created_at >= ?\";\n whereParams.push(startTimestamp);\n }\n \n if (endDate) {\n const endTimestamp = new Date(endDate).getTime();\n whereClause += whereClause ? \" AND\" : \" WHERE\";\n whereClause += \" created_at <= ?\";\n whereParams.push(endTimestamp);\n }\n \n // Get total count for pagination\n const countResult = await sqlite.execute(\n `SELECT COUNT(*) as total FROM ${CREDIT_ADDITIONS_TABLE}${whereClause}`,\n whereParams\n );\n const totalItems = countResult.rows[0].total;\n \n // Get paginated data\n const paginationSQL = getPaginationSQL(page, pageSize);\n \n // Get the credit additions with pagination\n const query = `\n SELECT \n id, \n user_id, \n created_at, \n stripe_payment_intent_id, \n amount, \n note\n FROM ${CREDIT_ADDITIONS_TABLE}\n ${whereClause}\n ORDER BY created_at DESC\n ${paginationSQL}\n `;\n \n const result = await sqlite.execute(\n query,\n whereParams\n );\n \n // Process the results\n const data: CreditAddition[] = result.rows.map(row => ({\n id: row.id,\n user_id: row.user_id,\n created_at: row.created_at,\n stripe_payment_intent_id: row.stripe_payment_intent_id,\n amount: row.amount,\n note: row.note\n }));\n \n // Get the total sum for filtered results\n const sumResult = await sqlite.execute(\n `SELECT SUM(amount) as total FROM ${CREDIT_ADDITIONS_TABLE}${whereClause}`,\n whereParams\n );\n const totalAmount = sumResult.rows[0].total || 0;\n \n // Calculate pagination metadata\n const pagination = calculatePagination({ page, pageSize, totalItems });\n \n return {\n data,\n pagination,\n filtered: !!whereClause,\n summary: {\n total_count: totalItems,\n total_amount: totalAmount\n }\n };\n}",[],[721,878,907,1010,973],"50a34152-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[259,260,261,262,263,264],[721,878,907,1010],"50a38054-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[258,265,268,277,278,279],[721,878,907],"50a38e5a-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[257,280,281,282,283],[721,878],"50a3d252-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[256,284,296,303,306],[721],"50a31466-5f0e-11f0-82bf-0224a6c84d84","extensions.json","601b13f2-add7-4ee2-a877-b2603ee7ab60","f74ffbd3-5569-4d68-a462-f8b784490095",["D",1752317553464],"{\n \"recommendations\": [\n \"denoland.vscode-deno\"\n ]\n}",[],[1066,1059],".vscode","50a31b3c-5f0e-11f0-82bf-0224a6c84d84",["D",1752317553464],[254],[1066],["D",1752317553464],{"_11":12,"_172":85},{"_11":12,"_168":-5,"_84":85,"_31":83,"_169":170,"_171":30},{"_39":40,"_13":16,"_33":36,"_157":124,"_158":74,"_159":160,"_161":128,"_162":163,"_164":165,"_166":14,"_167":12},"ctx",{"_52":-5,"_193":1108,"_1109":1110,"_1111":1112,"_1113":30,"_1114":30,"_1115":30,"_1116":24,"_1117":-5,"_1118":-7,"_1119":-7,"_1120":26,"_1121":30,"_1122":30,"_1123":-5,"_1124":30,"_1125":30,"_1126":30,"_1127":-5},"ENV",{"_1079":1080,"_1081":1082,"_1083":16,"_1084":1085,"_1086":1087,"_1088":1089,"_1090":1091,"_1092":1093,"_1094":1095,"_1096":1097,"_1098":1099,"_1100":1101,"_1102":1103,"_1104":1105,"_1106":1107},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

History · frontend