\n \n \n \n \n",[],[181,331],"c39e01a8-3432-11f0-9dcf-9e149126039e","hono.ts","176742de-9f89-48c0-b3d1-38fd0cff455b",["D",1747605308326],"// deno-lint-ignore-file no-window\n\nimport { hc } from \"https://esm.sh/hono@4.7.7/client?deps=hono@4.7.7\";\nimport { QueryClient } from \"https://esm.sh/@tanstack/react-query@5.74.7?deps=react@19.0.0\";\nimport { AppType } from \"../backend/api/mod.ts\";\nimport { APP_URL } from \"../shared/consts.ts\";\n\nexport const client = hc(\n typeof window !== \"undefined\"\n ? window.location.origin + \"/api\"\n : APP_URL + \"/api\",\n { init: { credentials: \"include\" } },\n);\nexport const queryClient = new QueryClient();\n",[],[181,338],"c39df654-3432-11f0-9dcf-9e149126039e","SearchPage.tsx","c8ba29e7-259c-40fc-8063-7655865013c9","b6acd229-9ed6-42d5-85af-b20ccb055d18",["D",1747605308326],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport InfiniteScroll from \"https://esm.sh/react-infinite-scroll-component@6.1.0?deps=react@18.2.0,react-dom@18.2.0\";\nimport { FormEvent, useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { marked } from \"https://esm.sh/marked@4.3.0\";\nimport { DEFAULT_QUERY } from \"../../shared/consts.ts\";\nimport { NpmPackage } from \"../../shared/schemas.ts\";\nimport { client } from \"../hono.ts\";\nimport { SearchIcon } from \"./icons/SearchIcon.tsx\";\n\nexport function SearchPage() {\n const [items, setItems] = useState([]);\n const [query, setQuery] = useState(DEFAULT_QUERY);\n const [page, setPage] = useState(1);\n const [hasMore, setHasMore] = useState(true);\n const [loading, setLoading] = useState(false);\n\n const fetchPackages = async (\n searchQuery: string,\n pageNum: number,\n append = false,\n ) => {\n if (loading) return;\n\n setLoading(true);\n try {\n const response = await client.search.$get({\n query: {\n q: searchQuery,\n n: \"10\",\n page: pageNum.toString(),\n },\n });\n\n const data = await response.json();\n\n if (append) {\n setItems((prevItems) => [...prevItems, ...data.packages]);\n } else {\n setItems(data.packages);\n }\n\n setHasMore(data.hasMore || false);\n setLoading(false);\n } catch (error) {\n console.error(\"Error fetching packages:\", error);\n setLoading(false);\n }\n };\n\n const handleSearch = (e: FormEvent) => {\n e.preventDefault();\n if (query.trim()) {\n setPage(1);\n setItems([]);\n fetchPackages(query.trim(), 1);\n }\n };\n\n const loadMorePackages = () => {\n if (!hasMore || loading) return;\n const nextPage = page + 1;\n setPage(nextPage);\n fetchPackages(query, nextPage, true);\n };\n\n useEffect(() => {\n fetchPackages(query, 1);\n }, []);\n\n // Function to render markdown safely\n const renderMarkdown = (text: string) => {\n try {\n return { __html: marked(text) };\n } catch (error) {\n console.error(\"Error rendering markdown:\", error);\n return { __html: text };\n }\n };\n\n return (\n

\n {/* Header */}\n

\n {/* Top navigation */}\n

\n \n \n \n \n

\n Sign Up\n Sign In\n

\n \n {/* Search bar */}\n

\n\n {/* Results */}\n

\n \n

\n }\n endMessage={\n

\n {items.length > 0\n ? \"Yay! You have seen all packages\"\n : \"No packages found\"}\n

\n }\n >\n

\n {items.map((item) => (\n

\n \n {item.name}\n \n \n

\n\n

\n {item.tags.map((tag) => (\n \n {tag}\n \n ))}\n

\n\n

\n \n {item.author}\n \n • v{item.version}\n \n • Published {new Date(item.updated).toLocaleDateString()}\n \n

\n \n

\n {item.downloads.toLocaleString()} downloads per week\n

\n {item.license}\n

\n ))}\n

\n \n

\n );\n}",[],[181,352,345],"components","c39df4ec-3432-11f0-9dcf-9e149126039e","SearchBox.tsx","d8b3ca23-c8a1-4376-9f79-ed155fa9ac1f",["D",1747605308326],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { FormEvent, useState } from \"https://esm.sh/react@18.2.0\";\nimport { SearchIcon } from \"./icons/SearchIcon.tsx\";\n\ninterface SearchBoxProps {\n onSearch: (query: string) => void;\n initialQuery?: string;\n}\n\nexport function SearchBox({ onSearch, initialQuery = \"\" }: SearchBoxProps) {\n const [query, setQuery] = useState(initialQuery);\n\n const handleSubmit = (e: FormEvent) => {\n e.preventDefault();\n if (query.trim()) {\n onSearch(query.trim());\n }\n };\n\n return (\n

\n \n

\n );\n}\n",[],[181,352,354],"c39dec90-3432-11f0-9dcf-9e149126039e","PackageDetail.tsx","ae5a78f7-e8bf-4842-8a61-b4cee3f5bff9",["D",1747605308326],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { marked } from \"https://esm.sh/marked@4.3.0\";\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { client } from \"../hono.ts\";\nimport { NpmPackage } from \"../../shared/schemas.ts\";\nimport { APP_URL } from \"../../shared/consts.ts\";\nimport { SearchIcon } from \"./icons/SearchIcon.tsx\";\n\ninterface PackageDetailProps {\n packageName: string;\n}\n\nexport function PackageDetail({ packageName }: PackageDetailProps) {\n const [packageData, setPackageData] = useState(null);\n const [readme, setReadme] = useState(\"\");\n const [loading, setLoading] = useState(true);\n\n const packageDownloadLink = packageData\n ? `${APP_URL}api/npm-package/${packageData.name}`\n : \"\";\n\n useEffect(() => {\n const fetchPackageDetails = async () => {\n try {\n // Fetch package details\n const response = await client.package\n .$get({ query: { name: packageName } });\n const data = await response.json();\n setPackageData(data.package);\n setReadme(marked(data.readme || \"\"));\n } catch (error) {\n console.error(\"Error fetching package details:\", error);\n } finally {\n setLoading(false);\n }\n };\n\n fetchPackageDetails();\n }, [packageName]);\n\n if (loading) {\n return (\n

\n );\n }\n\n if (!packageData) {\n return (\n

\n Package not found\n

\n The package \"{packageName}\" could not be found.\n

\n \n Return to search\n \n

\n );\n }\n\n return (\n

\n {/* Header */}\n

\n {/* Top navigation */}\n

\n \n \n \n \n

\n Sign Up\n Sign In\n

\n \n {/* Search bar */}\n

\n \n

\n \n Back to Search\n \n

\n\n

\n {/* Package header */}\n

\n {packageData.name}\n

\n {packageData.tags.map((tag) => (\n \n {tag}\n \n ))}\n

\n\n

\n v{packageData.version}\n •\n \n Published {new Date(packageData.updated).toLocaleDateString()}\n \n

\n License: {packageData.license}\n

\n \n {packageData.downloads.toLocaleString()} weekly downloads\n \n

\n\n {/* Package content */}\n

\n {/* Sidebar */}\n

\n Installation\n

\n {\n navigator.clipboard.writeText(\n `npm install ${packageDownloadLink}`,\n );\n const target = e.currentTarget;\n const originalText = target.textContent;\n target.textContent = \"Copied!\";\n setTimeout(() => {\n target.textContent = originalText;\n }, 1500);\n }}\n >\n npm install {packageDownloadLink}\n \n

\n\n

\n Author\n

\n {packageData.author}\n

\n\n

\n Download\n

\n \n Download Package\n \n

\n\n {/* Main content */}\n

\n \n

\n \n \n );\n}\n",[],[181,352,361],"c39de894-3432-11f0-9dcf-9e149126039e","LibraryItem.tsx","e6de56cb-c898-459f-bc38-96fb14834f8d","b5b264af-9384-4694-8e6b-10811e33b1ea",["D",1747605308326],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\ntype LibraryItemProps = {\n title: string;\n subtitle: string;\n tags: string[];\n avatarText: string;\n author: string;\n version: string;\n updated: string;\n dependents: number | string;\n license: string;\n downloads: number;\n};\n\nexport default function LibraryItem({\n title,\n subtitle,\n tags,\n avatarText,\n author,\n version,\n updated,\n dependents,\n license,\n downloads,\n}: LibraryItemProps) {\n return (\n

{title}

{subtitle}

\n\n

\n {tags.map((tag) => (\n \n {tag}\n \n ))}\n

\n\n

\n \n {avatarText}\n \n {author}\n • {version}\n • {updated}\n • {dependents} dependents\n • {license}\n

\n\n

\n {downloads.toLocaleString()}\n

\n );\n}\n",[],[181,352,375,368],"npm","c39deb32-3432-11f0-9dcf-9e149126039e",["D",1747605308326],[275],[181,352,375],"c39de614-3432-11f0-9dcf-9e149126039e","SearchIcon.tsx","ff1b3978-4a5b-4f13-b471-119e3f395115","4675836a-cdb1-4852-a8a9-20c7fffd614d",["D",1747605308326],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\ninterface SearchIconProps {\n className?: string;\n}\n\nexport function SearchIcon({ className = \"w-4 h-4 text-gray-500\" }: SearchIconProps) {\n return (\n \n );\n}",[],[181,352,388,381],"icons","c39de754-3432-11f0-9dcf-9e149126039e",["D",1747605308326],[273],[181,352,388],"c39e0040-3432-11f0-9dcf-9e149126039e",["D",1747605308326],[272,274,276,277,278],[181,352],["D",1747605308326],[271,279,280,281,282],[181],"c39de34e-3432-11f0-9dcf-9e149126039e","ef4aeb3b-642c-4a01-9707-f4a1c2429d46",["D",1747605308326],"http","import {\n readFile,\n serveFile,\n} from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { Hono } from \"https://esm.sh/hono@4.7.7\";\nimport { apiRoute } from \"./api/mod.ts\";\n\nconst app = new Hono()\n .get(\"/\", () => serveFile(\"/frontend/index.html\", import.meta.url))\n .get(\"/package/:name\", async (c) => {\n // Serve the same HTML but with the package name in the title\n const packageName = c.req.param(\"name\");\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n\n // Update the title to include the package name\n html = html.replace(\n \"React Hono Val Town Starter\",\n `${packageName} - npm`,\n );\n\n // Add a script to pass the package name to the frontend\n const packageScript =\n ``;\n html = html.replace(\"\", `${packageScript}`);\n\n return c.html(html);\n })\n .route(\"/api\", apiRoute)\n .get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url))\n .get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url))\n .onError((err) => {\n throw err;\n });\n\nexport default app.fetch;\n",[],[186,32],"c39de20e-3432-11f0-9dcf-9e149126039e","env.ts","ef23a523-4739-47b3-a4de-55bc1a572030",["D",1747605308326],"import { safeEnv, string } from \"https://esm.sh/jsr/@safe-env/safe-env@0.1.7\";\n\nexport const env = safeEnv({\n GOOGLE_GENERATIVE_AI_API_KEY: string(),\n});\n",[],[186,408],"c39ddef8-3432-11f0-9dcf-9e149126039e","mod.ts","aae344e1-aa12-4433-8e28-46b0de268eb5","75d4c6b1-319b-4367-b412-4759de45c44f",["D",1747605308326],"import { Hono } from \"https://esm.sh/hono@4.7.7\";\nimport { searchRoute } from \"./routes/search.ts\";\nimport { packageRoute } from \"./routes/package.ts\";\nimport { npmPackageRoute } from \"./routes/npm-package.ts\";\n\nexport const apiRoute = new Hono()\n .route(\"/search\", searchRoute)\n .route(\"/package\", packageRoute)\n .route(\"/npm-package\", npmPackageRoute);\n\nexport type AppType = typeof apiRoute;\n",[],[186,422,415],"api","c39dd976-3432-11f0-9dcf-9e149126039e","package-generator.ts","a41f57ec-d566-4195-a7f0-a25e7b7f9808","212c9cbd-c3f0-4216-b8d0-3ad0e59cb503",["D",1747605308326],"import { TarStream } from \"https://esm.sh/jsr/@std/tar@0.1.6\";\nimport { generateFakeNpmPackages } from \"../ai/generate.ts\";\nimport { geminiFlashModel } from \"../ai/models.ts\";\nimport { generateText } from \"https://esm.sh/ai@4.3.15?deps=zod@3.23.4\";\n\n/**\n * Generates a TypeScript implementation for a package based on its name and description\n */\nexport async function generatePackageImplementation(\n packageName: string,\n description: string,\n): Promise {\n const prompt = `\nCreate a simple TypeScript implementation for an npm package with the following details:\n- Package name: ${packageName}\n- Description: ${description}\n\nThe implementation should:\n1. Be a single TypeScript file\n2. Export a main function or class that fulfills the package description\n3. Include proper JSDoc comments\n4. Be simple but functional\n5. Include 2-3 helper functions if appropriate\n\nOnly return the TypeScript code without any explanation or markdown formatting.\n`;\n const response = await generateText({ model: geminiFlashModel, prompt });\n return response.text.trim();\n}\n\n/**\n * Compiles TypeScript to JavaScript\n * This is a simple implementation that doesn't use the TypeScript compiler\n * In a real-world scenario, you would use the TypeScript compiler API\n */\nexport function compileTypeScript(tsCode: string): string {\n // This is a very simplified \"compilation\" that just removes TypeScript types\n // In a real implementation, you would use the TypeScript compiler\n return tsCode\n .replace(/: [A-Za-z<>[\\]|&]+/g, \"\") // Remove type annotations\n .replace(/<[A-Za-z,\\s]+>/g, \"\") // Remove generic type parameters\n .replace(/export default/g, \"module.exports =\") // Convert export default to module.exports\n .replace(/export /g, \"\") // Remove export keywords\n .replace(/import .* from .*;\\n/g, \"\"); // Remove import statements\n}\n\n/**\n * Creates a tar archive for an npm package\n */\nexport async function createPackageTar(\n packageName: string,\n version: string = \"1.0.0\",\n description: string = \"\",\n author: string = \"Val Town\",\n license: string = \"MIT\",\n): Promise> {\n // Generate implementation if description is empty\n if (!description) {\n const results = await generateFakeNpmPackages(packageName, 1);\n description = results.packages[0].description;\n }\n\n // Generate TypeScript implementation\n const tsImplementation = await generatePackageImplementation(\n packageName,\n description,\n );\n\n // Compile to JavaScript\n const jsImplementation = compileTypeScript(tsImplementation);\n\n // Create package.json\n const packageJson = {\n name: packageName,\n version,\n description,\n main: \"index.js\",\n types: \"index.d.ts\",\n scripts: {\n test: 'echo \"Error: no test specified\" && exit 1',\n },\n keywords: packageName.split(\"-\"),\n author,\n license,\n };\n\n // Create type definition file\n const dtsContent = `/**\n * Type definitions for ${packageName}\n */\n${\n tsImplementation.replace(/export function/g, \"export declare function\")\n .replace(/export class/g, \"export declare class\")\n .replace(/export const/g, \"export declare const\")\n .replace(/export default/g, \"export default\")\n .replace(/= [^;]+;/g, \";\")\n }\n`;\n\n // Convert content to bytes\n const packageJsonBytes = new TextEncoder().encode(\n JSON.stringify(packageJson, null, 2),\n );\n const indexJsBytes = new TextEncoder().encode(jsImplementation);\n const indexTsBytes = new TextEncoder().encode(tsImplementation);\n const indexDtsBytes = new TextEncoder().encode(dtsContent);\n\n // Create a ReadableStream of TarStreamInput objects\n const inputStream = new ReadableStream({\n start(controller) {\n // Add package directory\n controller.enqueue({\n type: \"directory\",\n path: \"package\",\n });\n\n // Add package.json file\n controller.enqueue({\n type: \"file\",\n path: \"package/package.json\",\n size: packageJsonBytes.length,\n readable: ReadableStream.from([packageJsonBytes]),\n });\n\n // Add index.js file\n controller.enqueue({\n type: \"file\",\n path: \"package/index.js\",\n size: indexJsBytes.length,\n readable: ReadableStream.from([indexJsBytes]),\n });\n\n // Add index.ts file\n controller.enqueue({\n type: \"file\",\n path: \"package/index.ts\",\n size: indexTsBytes.length,\n readable: ReadableStream.from([indexTsBytes]),\n });\n\n // Add index.d.ts file\n controller.enqueue({\n type: \"file\",\n path: \"package/index.d.ts\",\n size: indexDtsBytes.length,\n readable: ReadableStream.from([indexDtsBytes]),\n });\n\n controller.close();\n },\n });\n\n // Pipe the input stream through the TarStream to create the tar archive\n return inputStream.pipeThrough(new TarStream());\n}\n",[],[186,422,431,424],"utils","c39ddd68-3432-11f0-9dcf-9e149126039e",["D",1747605308326],[266],[186,422,431],"c39dd674-3432-11f0-9dcf-9e149126039e","search.ts","6a766ccd-c8d7-477c-a567-a59e994bbb65","bef1d36f-3bc1-4435-866e-42c1a7dc6d29",["D",1747605308326],"import { Hono } from \"https://esm.sh/hono@4.7.7\";\nimport { z } from \"https://esm.sh/zod@3.23.4\";\nimport { zValidator } from \"https://esm.sh/@hono/zod-validator@0.4.3?deps=hono@4.7.7,zod@3.23.4\";\nimport { generateFakeNpmPackages } from \"../ai/generate.ts\";\nimport { blob } from \"https://esm.town/v/std/blob?v=13\";\nimport { searchResultSchema } from \"../../../shared/schemas.ts\";\nimport { S3_PREFIX } from \"../../../shared/consts.ts\";\n\nexport const searchRoute = new Hono()\n .get(\n \"/\",\n zValidator(\n \"query\",\n z.object({\n q: z.string().min(1).describe(\"Search query term\"),\n n: z.string().transform((val) => parseInt(val, 10)),\n page: z.string().transform((val) => parseInt(val, 10)).default(\"1\"),\n }),\n ),\n async (c) => {\n const { q, n, page } = c.req.valid(\"query\");\n\n // Create a cache key based on the search query and page\n const cacheKey = `${S3_PREFIX}npm_search_${q}_${n}_${page}`;\n\n // Try to get cached results\n const cachedResults = await blob.getJSON(cacheKey);\n if (cachedResults) {\n // Validate the cached data against our schema\n const validatedResults = searchResultSchema.parse(cachedResults);\n return c.json(validatedResults);\n }\n\n // Generate new results\n const results = await generateFakeNpmPackages(q, n);\n\n // Add pagination info\n const resultsWithPagination = {\n ...results,\n page,\n hasMore: page < 10, // Limit to 10 pages for demo purposes\n };\n\n // Cache the results\n try {\n await blob.setJSON(cacheKey, resultsWithPagination);\n } catch (error) {\n console.error(\"Error caching results:\", error);\n }\n\n return c.json(resultsWithPagination);\n },\n );\n",[],[186,422,444,437],"routes","c39dd2aa-3432-11f0-9dcf-9e149126039e","package.ts","54b5a4f0-8714-4272-b769-d32bf25f789f",["D",1747605308326],"import { Hono } from \"https://esm.sh/hono@4.7.7\";\nimport { z } from \"https://esm.sh/zod@3.23.4\";\nimport { zValidator } from \"https://esm.sh/@hono/zod-validator@0.4.3?deps=hono@4.7.7,zod@3.23.4\";\nimport { generateFakeNpmPackages } from \"../ai/generate.ts\";\nimport { blob } from \"https://esm.town/v/std/blob?v=13\";\nimport { generatePackageReadme } from \"../ai/generate-readme.ts\";\n\nexport const packageRoute = new Hono()\n .get(\n \"/\",\n zValidator(\n \"query\",\n z.object({ name: z.string().min(1).describe(\"Package name\") }),\n ),\n async (c) => {\n const { name } = c.req.valid(\"query\");\n\n // Create a cache key for the package\n const cacheKey = `npm_package_${name}`;\n\n // Try to get cached package data\n const cachedPackage = await blob.getJSON(cacheKey);\n if (cachedPackage) {\n return c.json(cachedPackage);\n }\n\n // Generate a fake package\n const results = await generateFakeNpmPackages(name, 1);\n const packageData = results.packages[0];\n\n // Generate a fake README\n const readme = await generatePackageReadme(packageData);\n\n const packageResponse = {\n package: packageData,\n readme,\n };\n\n // Cache the package data\n try {\n await blob.setJSON(cacheKey, packageResponse);\n } catch (error) {\n console.error(\"Error caching package data:\", error);\n }\n\n return c.json(packageResponse);\n },\n );\n",[],[186,422,444,446],"c39dcfda-3432-11f0-9dcf-9e149126039e","npm-package.ts","3b5f1255-6208-4f61-8cdb-d69ab0426494",["D",1747605308326],"import { zValidator } from \"https://esm.sh/@hono/zod-validator@0.4.3?deps=hono@4.7.7,zod@3.23.4\";\nimport { Hono } from \"https://esm.sh/hono@4.7.7\";\nimport { z } from \"https://esm.sh/zod@3.23.4\";\nimport { blob } from \"https://esm.town/v/std/blob?v=13\";\nimport { S3_PREFIX } from \"../../../shared/consts.ts\";\nimport { createPackageTar } from \"../utils/package-generator.ts\";\n\nexport const npmPackageRoute = new Hono()\n .get(\n \"/:packageName\",\n zValidator(\n \"param\",\n z.object({\n packageName: z.string().min(1).describe(\"Package name\"),\n }),\n ),\n async (c) => {\n const { packageName } = c.req.valid(\"param\");\n\n const cacheKey = `${S3_PREFIX}npm_package_tar_${packageName}`;\n\n try {\n const cachedPackage = await blob.get(cacheKey);\n if (cachedPackage) {\n return new Response(cachedPackage.body, {\n headers: {\n \"Content-Type\": \"application/x-tar\",\n \"Content-Disposition\": `attachment; filename=${packageName}.tar`,\n },\n });\n }\n } catch {\n console.log(`Cache miss for package: ${packageName}`);\n }\n\n // Create the tar archive\n const tarArchive = await createPackageTar(packageName);\n \n // Clone the stream for caching and response\n const [cacheStream, responseStream] = tarArchive.tee();\n \n // Cache the package in the background\n cachePackage(cacheKey, cacheStream).catch(err => {\n console.error(`Error caching package ${packageName}:`, err);\n });\n \n // Return the response stream\n return new Response(responseStream, {\n headers: {\n \"Content-Type\": \"application/x-tar\",\n \"Content-Disposition\": `attachment; filename=${packageName}.tar`,\n },\n });\n },\n );\n\nasync function cachePackage(\n cacheKey: string,\n stream: ReadableStream,\n) {\n const response = new Response(stream);\n const bytes = await response.arrayBuffer();\n await blob.set(cacheKey, new Uint8Array(bytes));\n console.log(`Successfully cached package: ${cacheKey}`);\n}",[],[186,422,444,453],"c39dd7dc-3432-11f0-9dcf-9e149126039e",["D",1747605308326],[262,263,264],[186,422,444],"c39dcc56-3432-11f0-9dcf-9e149126039e","models.ts","42ebe57f-606a-4b9d-8442-94818b66cd15","ecf8bcc9-c4df-4f8d-9ff1-9e7522cf7a72",["D",1747605308326],"import { google } from \"https://esm.sh/@ai-sdk/google@1.2.18\";\nimport { wrapLanguageModel } from \"https://esm.sh/ai@4.3.15\";\n\nexport const geminiFlashModel = wrapLanguageModel({\n model: google(\"gemini-1.5-flash-002\"),\n middleware: {},\n});\n",[],[186,422,471,464],"ai","c39dc800-3432-11f0-9dcf-9e149126039e","generate.ts","8ae2d0d7-387a-408b-8f69-c415c326376a",["D",1747605308326],"import { generateObject } from \"https://esm.sh/ai@4.3.15?deps=zod@3.23.4\";\nimport { z } from \"https://esm.sh/zod@3.23.4\";\nimport { geminiFlashModel } from \"./models.ts\";\n\nconst packageSchema = z.object({\n name: z.string()\n .describe(\"NPM package name following standard naming conventions\"),\n description: z.string()\n .describe(\"Brief description of what the package does, using markdown formatting for emphasis and links. Keep it realistic and focused on practical use cases.\"),\n tags: z.array(\n z.string()\n .describe(\"Technologies or categories related to this package. Use common, realistic tags like 'react', 'node', 'utility', 'api', etc.\"),\n ),\n author: z.string()\n .describe(\"Name of the fictional package author\"),\n version: z.string()\n .describe(\"Package version (e.g., '1.2.3')\"),\n license: z.string()\n .describe(\"Open source license (e.g., MIT, Apache-2.0)\"),\n downloads: z.number()\n .describe(\"Number of downloads (between 1,000 and 5,000,000)\"),\n avatarText: z.string()\n .describe(\"Text to display in the package avatar (usually initials)\"),\n updated: z.string()\n .describe(\"Date when the package was last updated (ISO format)\"),\n dependents: z.number()\n .describe(\"Number of packages that depend on this one\"),\n id: z.string()\n .describe(\"Unique identifier for the package\"),\n});\n\nexport type NpmPackage = z.infer;\n\nexport async function generateFakeNpmPackages(\n query: string,\n count: number = 5,\n): Promise<{ packages: NpmPackage[] }> {\n // Create an array of prompts with slight variations to increase diversity\n const prompts = Array.from({ length: count }, (_, i) => {\n const variations = [\n `Generate a realistic NPM package related to \"${query}\". Make it practical and focused on common developer needs. Use markdown formatting in the description field to emphasize key points or add links.`,\n `Create a fictional but realistic NPM package for \"${query}\" with practical features and naming. The description should use markdown formatting to highlight important features. Focus on common use cases that developers would actually need.`,\n `Invent a practical NPM package that would appear when searching \"${query}\". Be realistic with names and details. Use markdown in the description to make it more readable with emphasis or links. Avoid exotic or impractical technologies.`,\n `Design a realistic NPM package for \"${query}\" purposes. The description should use markdown formatting like **bold**, *italic*, or \\`code\\`. Focus on solving real-world problems that developers face.`,\n `Generate a practical NPM package related to \"${query}\". Use realistic naming and download counts. Include markdown formatting in the description to make it look like a real npm package description. Focus on common development needs.`,\n ];\n\n // Choose a prompt variation, cycling through them or randomly\n return variations[i % variations.length] + ` Index: ${i}`;\n });\n\n // Create an array of promises for concurrent execution with different prompts\n const generatePromises = prompts.map((prompt) =>\n generateObject({\n schema: packageSchema,\n model: geminiFlashModel,\n prompt: prompt + ` Make sure the package is realistic and practical, not using exotic technologies or making unrealistic claims. Focus on common developer needs and real-world use cases.`,\n temperature: 0.7,\n })\n );\n\n // Wait for all promises to resolve\n const results = await Promise.all(generatePromises);\n\n // Extract the objects from results and ensure uniqueness\n const packages = results.map((result, index) => ({\n ...result.object,\n // Ensure unique fields by adding index if necessary\n id: `${result.object.id}-${index}`,\n downloads: Math.floor(100000 + Math.random() * 4900000),\n updated: new Date(Date.now() - Math.floor(Math.random() * 30 * 86400000))\n .toISOString(),\n dependents: Math.floor(10 + Math.random() * 3000),\n }));\n\n return { packages };\n}\n\nexport type FakeNpmPackage = z.infer;\n\nexport type FakeNpmPackage = z.infer;\n",[],[186,422,471,473],"c39db4d2-3432-11f0-9dcf-9e149126039e","generate-readme.ts","44465e62-03c0-4d58-9249-d1d5070bda3f",["D",1747605308326],"import { geminiFlashModel } from \"./models.ts\";\nimport { NpmPackage } from \"../../../shared/schemas.ts\";\nimport { APP_URL } from \"../../../shared/consts.ts\";\n\nexport async function generatePackageReadme(\n packageData: NpmPackage,\n): Promise {\n const downloadUrl = `${APP_URL}api/npm-package/${packageData.name}`;\n \n const prompt = `\nGenerate a realistic README.md for an npm package with the following details:\n\n- Package name: ${packageData.name}\n- Description: ${packageData.description}\n- Tags/Keywords: ${packageData.tags.join(\", \")}\n- Author: ${packageData.author}\n- Version: ${packageData.version}\n- License: ${packageData.license}\n\nThe README should include:\n1. A title and badges (npm version, license, downloads)\n2. A brief introduction explaining what the package does\n3. Installation instructions\n4. Basic usage examples with code snippets\n5. API documentation for the main functions\n6. Contributing guidelines\n7. License information\n\nMake it look like a real npm package README with proper markdown formatting.\n\nIMPORTANT: Keep the content realistic and practical. Focus on common developer needs and real-world use cases. Avoid exotic technologies or making unrealistic claims. The package should solve practical problems that developers actually face.\n\nUse realistic code examples that demonstrate the actual functionality described. Don't include references to quantum computing, blockchain, AI, or other advanced technologies unless they're directly relevant to the package's core purpose.\n`;\n\n try {\n const response = await geminiFlashModel.generateContent(prompt);\n let markdown = response.response.text();\n \n // Post-process the markdown to replace npm install commands\n markdown = replaceNpmInstallCommands(markdown, packageData.name, downloadUrl);\n \n return markdown;\n } catch (error) {\n console.error(\"Error generating README:\", error);\n return generateFallbackReadme(packageData.name, packageData.description, downloadUrl);\n }\n}\n\n/**\n * Replaces npm install commands in the markdown with our download URL instructions\n */\nfunction replaceNpmInstallCommands(markdown: string, packageName: string, downloadUrl: string): string {\n // Replace npm install commands in code blocks\n const npmInstallRegex = new RegExp(`(npm|yarn) (install|add) ${packageName}`, 'g');\n const pnpmAddRegex = new RegExp(`pnpm add ${packageName}`, 'g');\n \n // First, find all code blocks and replace npm install commands\n let processedMarkdown = markdown.replace(/```(?:bash|sh)?\\n([\\s\\S]*?)```/g, (match, codeContent) => {\n // Check if this code block contains an npm install command\n if (npmInstallRegex.test(codeContent) || pnpmAddRegex.test(codeContent)) {\n // Replace with our download instructions\n return \"```bash\\n\" +\n `npm install ${downloadUrl}\\n` +\n \"```\";\n }\n return match; // Return unchanged if no npm install command\n });\n \n // Also replace any inline npm install commands\n processedMarkdown = processedMarkdown.replace(\n /`(npm|yarn) (install|add) ${packageName}`/g, \n `\\`npm install ${downloadUrl}\\``\n );\n \n // Add our installation section if none exists\n if (!processedMarkdown.includes(\"# Installation\") && !processedMarkdown.includes(\"## Installation\")) {\n processedMarkdown += `\\n\\n## Installation\\n\\n` +\n \"```bash\\n\" +\n `npm install ${downloadUrl}\\n` +\n \"```\\n\";\n }\n \n return processedMarkdown;\n}\n\n/**\n * Generates a fallback README if AI generation fails\n */\nfunction generateFallbackReadme(packageName: string, description: string, downloadUrl: string): string {\n return `# ${packageName}\n\n${description}\n\n## Installation\n\n\\`\\`\\`bash\nnpm install ${downloadUrl}\n\\`\\`\\`\n\n## Usage\n\n\\`\\`\\`javascript\nconst ${packageName.replace(/-([a-z])/g, (_, letter) => letter.toUpperCase())} = require('${packageName}');\n\n// Use the package according to its functionality\n\\`\\`\\`\n\n## License\n\nMIT\n`;\n}\n",[],[186,422,471,480],"c39dce7c-3432-11f0-9dcf-9e149126039e",["D",1747605308326],[258,259,260],[186,422,471],"c39de07e-3432-11f0-9dcf-9e149126039e",["D",1747605308326],[257,261,265,267],[186,422],["D",1747605308326],[256,268,269],[186],"c5bd0baa-3432-11f0-aee7-9e149126039e","c5bd0c4a-3432-11f0-aee7-9e149126039e",24,["D",1747605311743],"import { serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport ValTown from \"jsr:@valtown/sdk\";\nimport { Hono } from \"npm:hono\";\nimport { cache } from \"npm:hono/cache\";\nimport { deleteCookie, getCookie, setCookie } from \"npm:hono/cookie\";\nimport { csrf } from \"npm:hono/csrf\";\nimport * as client from \"npm:openid-client\";\nimport { app as backend } from \"./backend/index.ts\";\nimport favicon from \"./frontend/favicon.http.tsx\";\n\nconst MODULE_URL = import.meta.resolve(\"./frontend/index.tsx\");\nconst STYLESHEET = import.meta\n .resolve(\"./frontend/styles.css\")\n .replace(\"esm.town\", \"juicy.town\");\n\nconst SCOPE = \"openid offline_access project_r project_rw user_r user_rw\";\nconst REDIRECT_URI = \"https://townie.val.run/\";\nconst VALTOWN_URL = \"https://val.town/\";\n\nconst app = new Hono();\n\nlet config: client.Configuration = await client.discovery(\n new URL(`https://www.val.town/oauth`),\n \"val_town_townie\",\n { client_secret: Deno.env.get(\"OAUTH_TOWNIE_CLIENT_SECRET\") },\n undefined,\n {}\n);\n\napp.use(csrf());\n\n// Cache all responses for 5 minutes on townie.val.town\n// TODO what is meant to be cached here??\napp.get(\n \"/frontend/*\",\n cache({\n cacheName: \"townie\",\n cacheControl: \"public, max-age=300\",\n wait: true,\n })\n);\n\n// token middleware for API requests\napp.all(\"/api/*\", async (c, next) => {\n const sessionCookie = getCookie(c, \"_session\");\n if (!sessionCookie) {\n return c.json({ error: \"Unauthorized\" }, 401);\n }\n const tokens = sessionCookie.split(\".\");\n c.set(\"token\", tokens[0]);\n return next();\n});\n\napp.route(\"/api\", backend);\n\napp.get(\"/frontend/*\", (c) => {\n return serveFile(c.req.path, import.meta.url);\n});\n\napp.get(\"/favicon.svg\", (c) => {\n return favicon();\n});\napp.get(\"/favicon-loading.svg\", (c) => {\n return favicon(true);\n});\n\n// log in UI\napp.get(\"/login\", async (c) => {\n return c.html(`\n \n \n Townie\n \n \n \n \n \n

Townie

\n
\n \n Log in with Val Town\n \n

\n \n \n `);\n});\n\napp.post(\"/logout\", (c) => {\n deleteCookie(c, \"_session\");\n return c.redirect(VALTOWN_URL);\n});\n\n// redirect to OAuth flow\napp.get(\"/auth\", async (c) => {\n const sessionCookie = getCookie(c, \"_session\");\n if (sessionCookie) return c.redirect(\"/\");\n\n const codeVerifier = client.randomPKCECodeVerifier();\n const codeChallenge = await client.calculatePKCECodeChallenge(codeVerifier);\n const state = client.randomState();\n\n const parameters = {\n redirect_uri: REDIRECT_URI,\n scope: SCOPE,\n code_challenge: codeChallenge,\n code_challenge_method: \"S256\",\n prompt: \"login consent\",\n state,\n };\n const redirectUrl = client.buildAuthorizationUrl(config, parameters);\n setCookie(c, \"codeVerifier\", codeVerifier);\n setCookie(c, \"state\", state);\n\n return c.redirect(redirectUrl);\n});\n\n// OAuth callback\napp.get(\"*\", async (c, next) => {\n const code = c.req.query(\"code\");\n if (!code) return next();\n\n const pkceCodeVerifier = getCookie(c, \"codeVerifier\");\n const expectedState = getCookie(c, \"state\");\n const tokens = await client.authorizationCodeGrant(\n config,\n new URL(c.req.url),\n {\n pkceCodeVerifier,\n expectedState,\n }\n );\n const expiration = new Date(Date.now() + tokens.expires_in * 1000).getTime();\n const cookie = `${tokens.access_token}.${expiration}`;\n setCookie(c, \"_session\", cookie);\n return c.redirect(\"/\");\n});\n\n// check token expiration\napp.get(\"*\", async (c, next) => {\n const sessionCookie = getCookie(c, \"_session\");\n if (!sessionCookie) return next();\n\n let tokens = sessionCookie.split(\".\");\n const expiration = new Date(parseInt(tokens[1])).getTime();\n if (expiration < Date.now()) {\n deleteCookie(c, \"_session\");\n return c.redirect(\"/auth\");\n }\n return next();\n});\n\n// SPA routes\napp.get(\"*\", async (c) => {\n const sessionCookie = getCookie(c, \"_session\");\n\n try {\n // validate session\n const tokens = sessionCookie.split(\".\");\n const vt = new ValTown({ bearerToken: tokens[0] });\n const user = await vt.me.profile.retrieve();\n // console.log(\"logged in as user\", user.name);\n } catch (err) {\n console.log(err);\n deleteCookie(c, \"_session\");\n return c.redirect(\"/login\");\n }\n\n return c.html(`\n \n \n Townie\n \n \n \n \n \n \n

\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;\n",[],[191,32],"c5a983aa-3432-11f0-a1b3-9e149126039e","c5a9845e-3432-11f0-a1b3-9e149126039e",19,["D",1747605311768],"{\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}",[],[191,153],"c5a740fe-3432-11f0-8289-9e149126039e","TODOs.md","c5a741b2-3432-11f0-8289-9e149126039e",18,["D",1747605311742],"- [ ] 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",[],[191,512],"c5abd9e8-3432-11f0-a74a-9e149126039e","c5abdaba-3432-11f0-a74a-9e149126039e",20,["D",1747605311771],"# OpenTownie\n\nOpenTownie is an AI-powered development assistant that lets you edit Val Town projects using Claude 3.7 Sonnet. It provides a seamless interface for discussing your code with Claude AI, which can directly view and modify files in your Val Town projects.\n\n## Features\nIt uses agentic tool-calling, taking many read, write, and thinking steps autonomously when carrying out your instructions.\n\n- **AI-Assisted Editing**: Chat with Claude 3.7 Sonnet about your code and let it make changes directly to your project files\n- **File Browser**: Select specific files to include in the context window for more focused AI assistance\n- **Branch Management**: View, select, and create branches without leaving the app\n- **Cost Tracking**: See estimated API usage costs for each interaction\n- **Sound Notifications**: Get alerted when Claude finishes responding\n- **Mobile-Friendly**: Works on both desktop and mobile devices\n- **Usage Dashboard**: Monitor API usage and inference calls with detailed analytics\n\n## How It Works\n\n1. **Login**: Authenticate with your Val Town API token and Anthropic API key\n2. **Select a Project**: Choose which Val Town project you want to work on\n3. **Select Files**: Browse your project files and select which ones to include in the context window\n4. **Chat with Claude**: Describe what you want to build or modify, and Claude will help implement it\n5. **Branch Management**: Create and switch between branches to organize your development work\n\n## Getting Started\n\n### Prerequisites\n\n- A Val Town account with API access\n- An Anthropic API key (Claude 3.7 Sonnet)\n\n### Setup\n\n1. Visit the OpenTownie app\n2. Enter your Val Town API token (with `projects:write` and `users:read` permissions)\n3. Enter your Anthropic API key\n4. Click \"Login\" to access your projects\n\n## Usage Tips\n\n- **Be Specific**: When asking Claude to make changes, be as specific as possible about what you want\n- **Include Context**: Select relevant files to give Claude the context it needs\n- **Create Branches**: Create a new branch before making significant changes to avoid affecting your main code\n- **Review Changes**: Always review Claude's changes before merging them into your main branch\n- **Iterative Development**: Break down complex tasks into smaller steps for better results\n\n## Technical Details\n\nOpenTownie is built with:\n- React frontend with TypeScript\n- React Router\n- Hono API server backend\n- Web Audio API for sound notifications\n- AI SDK for Claude integration\n\nThe application proxies requests to the Anthropic API and Val Town API, allowing Claude to view and edit your project files directly.\n\n## Privacy & Security\n\n- Your Val Town API token and Anthropic API key are stored locally in your browser\n- No data is stored on our servers\n- All communication with the APIs is done directly from your browser\n",[],[191,163],"c5a57152-3432-11f0-af8a-9e149126039e","c5a57224-3432-11f0-af8a-9e149126039e",17,["D",1747605311740],".git\n.DS_Store\nnode_modules\nvendor\n*.swp\n\n",[],[191,169],"c534b322-3432-11f0-a617-9e149126039e","prompts","c534b3b8-3432-11f0-a617-9e149126039e",5,["D",1747605311003],[],[191,534],"c56285fe-3432-11f0-aee7-9e149126039e","c56286bc-3432-11f0-aee7-9e149126039e","c52c3756-3432-11f0-8628-9e149126039e",10,["D",1747605311303],[],[191,181,431],"c56aeac8-3432-11f0-aee7-9e149126039e","hooks","c56aeb9a-3432-11f0-aee7-9e149126039e",11,["D",1747605311358],[],[191,181,548],"c574fa0e-3432-11f0-a1b3-9e149126039e","c574fab8-3432-11f0-a1b3-9e149126039e",12,["D",1747605311422],[],[191,181,352],"c52c36a2-3432-11f0-8628-9e149126039e",4,["D",1747605310946],[246,247,248],[191,181],"c5b0db82-3432-11f0-9fcb-9e149126039e","c5b0dc4a-3432-11f0-9fcb-9e149126039e","c5234754-3432-11f0-aee7-9e149126039e",21,["D",1747605311812],"import { Hono } from \"npm:hono\";\nimport createBranchApp from \"./routes/create-branch.ts\";\nimport createProjectApp from \"./routes/create-project.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 sendMessageApp from \"./routes/send-message.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(\"/user\", userRoute);\n\n// This is the entry point for HTTP vals\nexport default app.fetch;\n",[],[191,186,32],"c5e41e98-3432-11f0-8608-9e149126039e","fileWithLinesNumbers.ts","c5e41f4c-3432-11f0-8608-9e149126039e","c546fa8c-3432-11f0-92b1-9e149126039e",39,["D",1747605312139],"export default function fileWithLineNumbers(text: string, view_range = []) {\n return [\n undefined, // Line numbers are 1-indexed\n ...text.split(\"\\n\"),\n ]\n .map((line, index) => index + \": \" + line)\n .slice(...view_range)\n .join(\"\\n\");\n}",[],[191,186,431,574],"c5de27e0-3432-11f0-93a3-9e149126039e","calculateCost.tsx","c5de28a8-3432-11f0-93a3-9e149126039e",37,["D",1747605312111],"// Rates for Claude 3.7 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}",[],[191,186,431,583],"c546f9ce-3432-11f0-92b1-9e149126039e",7,["D",1747605311120],[242,243],[191,186,431],"c5ff9f10-3432-11f0-83ee-9e149126039e","think.ts","c5ff9fa6-3432-11f0-83ee-9e149126039e","c5595222-3432-11f0-b02f-9e149126039e",47,["D",1747605312332],"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});",[],[191,186,604,596],"tools","c5fb0928-3432-11f0-84b1-9e149126039e","text-editor.ts","c5fb09dc-3432-11f0-84b1-9e149126039e",46,["D",1747605312303],"import { anthropic } from \"npm:@ai-sdk/anthropic\";\nimport { ValTown } from \"npm:@valtown/sdk@0.37.0\";\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 * View a file or directory in a Val Town project\n */\nasync function view(\n vt: ValTown,\n project: any,\n branch_id: string | undefined,\n path: string,\n view_range: number[] | undefined,\n) {\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 if (!view_range) {\n return {\n type: \"success\",\n data: fileWithLinesNumbers(text),\n };\n }\n\n return {\n type: \"success\",\n data: fileWithLinesNumbers(text),\n };\n } catch (e: any) {\n console.log(e.stack);\n // likely due to a 404\n return {\n type: \"error\",\n message: \"File not found\",\n };\n }\n}\n\n/**\n * Replace a string in a file in a Val Town project\n */\nasync function str_replace(\n vt: ValTown,\n project: any,\n branch_id: string | undefined,\n path: string,\n old_str?: string,\n new_str?: string,\n) {\n if (old_str === undefined || new_str === undefined) {\n return {\n type: \"error\",\n message: \"What do you mean by replace with no old_str?\",\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: `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 // likely due to a 404\n return {\n type: \"error\",\n message: \"File not found\",\n };\n }\n}\n\n/**\n * Create a new file in a Val Town project\n */\nasync function create(vt: ValTown, project: any, branch_id: string | undefined, path: string, file_text?: string) {\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/**\n * Insert a string at a specific line in a file in a Val Town project\n */\nasync function insert(\n vt: ValTown,\n project: any,\n branch_id: string | undefined,\n path: string,\n insert_line?: number,\n new_str?: string,\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\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 // likely due to a 404\n return {\n type: \"error\",\n message: \"File not found\",\n };\n }\n}\n\n/**\n * Undo the last edit to a file in a Val Town project (not implemented)\n */\nasync function undo_edit(vt: ValTown, project: any, branch_id: string | undefined) {\n return {\n type: \"error\",\n message: \"Command unimplemented\",\n };\n}\n\n/**\n * Creates a text editor tool for editing files in a Val Town project\n */\nexport function getTextEditorTool(bearerToken: string, project: any, branch_id: string | undefined) {\n const vt = new ValTown({ bearerToken });\n return anthropic.tools.textEditor_20250124({\n execute: async ({\n command,\n path,\n file_text,\n insert_line,\n new_str,\n old_str,\n view_range,\n }) => {\n console.log({\n command,\n path,\n file_text,\n insert_line,\n new_str,\n old_str,\n view_range,\n });\n try {\n if (command === \"view\") return view(vt, project, branch_id, path, view_range);\n if (command === \"str_replace\") return str_replace(vt, project, branch_id, path, old_str, new_str);\n if (command === \"create\") return create(vt, project, branch_id, path, file_text);\n if (command === \"insert\") return insert(vt, project, branch_id, path, insert_line, new_str);\n if (command === \"undo_edit\") return undo_edit(vt, project, branch_id);\n else 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 });\n}",[],[191,186,604,606],"c6079cba-3432-11f0-a74a-9e149126039e","overwrite-file.ts","c6079d82-3432-11f0-a74a-9e149126039e",49,["D",1747605312385],"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 replacing files in a Val Town project\n * This deletes the existing file and creates a new one with the provided content\n */\nexport const makeOverwriteFileTool = (\n { bearerToken, project, branch_id }: { bearerToken: string; project: any; branch_id: string },\n) =>\n tool({\n description: \"Use this tool to completely replace a file with new content.\",\n parameters: z.object({\n path: z.string().describe(\"The file path to replace\"),\n content: z.string().describe(\"The new content for the file\"),\n }),\n execute: async ({ path, content }: { path: string; content: string }) => {\n const vt = new ValTown({ bearerToken });\n const normalizedPath = path.startsWith(\"/\") ? path.slice(1) : path;\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 });",[],[191,186,604,614],"c60c00e8-3432-11f0-84b1-9e149126039e",["D",1747605312411],[],[191,186,604,32],"c5595182-3432-11f0-b02f-9e149126039e",9,["D",1747605311243],[237,238,239,240],[191,186,604],"c5e13048-3432-11f0-af8a-9e149126039e","user.ts","c5e130d4-3432-11f0-af8a-9e149126039e","c550cabc-3432-11f0-92b1-9e149126039e",38,["D",1747605312133],"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",[],[191,186,444,631],"c5e7077a-3432-11f0-a694-9e149126039e","send-message.ts","c5e70874-3432-11f0-a694-9e149126039e",40,["D",1747605312171],"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 { convertToCoreMessages, type CoreUserMessage, streamText } from \"npm:ai\";\nimport { Hono } from \"npm:hono\";\nimport { finishTrackingUsage, insertInferenceCall, overLimit, startTrackingUsage } from \"../database/queries.tsx\";\nimport {\n getTextEditorTool,\n makeChangeValTypeTool,\n makeDeleteTool,\n makeOverwriteFileTool,\n thinkTool,\n} from \"../tools/index.ts\";\nimport fileWithLinesNumbers from \"../utils/fileWithLinesNumbers.ts\";\n\nconst app = new Hono();\n\n// Load system prompts\nconst systemPromptPromise = readFile(\"/prompts/system_prompt.txt\", import.meta.url);\nconst openTowniePromptAdditionsPromise = readFile(\"/prompts/open_townie_prompt_additions.txt\", import.meta.url);\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 { messages, project, branchId, anthropicApiKey, selectedFiles, images } = 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 overLimit(bearerToken)) {\n return Response.json(\n \"You have reached the 24-hour Townie limit. Upgrade to Pro for 10x limits: https://val.town/pricing. Email help@val.town to pay for even higher limits.\",\n { status: 403 },\n );\n }\n }\n\n const model = \"claude-3-7-sonnet-20250219\";\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: \"claude-3-7-sonnet-20250219\",\n });\n\n const anthropic = createAnthropic({\n apiKey,\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${fileWithLinesNumbers(content)}\\n\\`\\`\\`\\n\\n`;\n } catch (error) {\n console.error(`Error fetching file ${filePath}:`, error);\n fileContents += `## 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 const result = await streamText({\n model: anthropic(model),\n messages: coreMessages,\n system: system + \"\\n\\n\" + open_townie_prompt_additions,\n tools: {\n str_replace_editor: getTextEditorTool(bearerToken, project, branchId),\n think: thinkTool,\n delete_file: makeDeleteTool({ bearerToken, project, branch_id: branchId }),\n change_val_type: makeChangeValTypeTool({ bearerToken, project, branch_id: branchId }),\n overwrite_file: makeOverwriteFileTool({ bearerToken, project, branch_id: branchId }),\n },\n maxSteps: 20,\n maxTokens: 4_096 * 10,\n abortSignal: c.req.raw.signal,\n onStepFinish: async (result: any) => {\n await insertInferenceCall({\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: result.providerMetadata.anthropic.cacheReadInputTokens,\n cache_write_tokens: result.providerMetadata.anthropic.cacheCreationInputTokens,\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: result.providerMetadata.anthropic.cacheReadInputTokens,\n cache_write_tokens: 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});\n\nexport default app;",[],[191,186,444,640],"c5f17ec6-3432-11f0-a74a-9e149126039e","projects-loader.ts","c5f17f8e-3432-11f0-a74a-9e149126039e",44,["D",1747605312238],"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",[],[191,186,444,648],"c5e94576-3432-11f0-83ee-9e149126039e","project.ts","c5e9462a-3432-11f0-83ee-9e149126039e",41,["D",1747605312186],"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",[],[191,186,444,656],"c5eb1b44-3432-11f0-84b1-9e149126039e","project-files.ts","c5eb1bd0-3432-11f0-84b1-9e149126039e",42,["D",1747605312198],"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",[],[191,186,444,664],"c602d59a-3432-11f0-93a3-9e149126039e","project-branches.ts","c602d644-3432-11f0-93a3-9e149126039e",48,["D",1747605312276],"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",[],[191,186,444,672],"c5ef4f48-3432-11f0-a1b3-9e149126039e","create-project.ts","c5ef4fde-3432-11f0-a1b3-9e149126039e",43,["D",1747605312226],"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",[],[191,186,444,680],"c5f71fe8-3432-11f0-9fcb-9e149126039e","create-branch.ts","c5f72074-3432-11f0-9fcb-9e149126039e",45,["D",1747605312275],"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",[],[191,186,444,688],"c550ca12-3432-11f0-92b1-9e149126039e",8,["D",1747605311185],[228,229,230,231,232,233,234,235],[191,186,444],"c5beb450-3432-11f0-8289-9e149126039e","schema.tsx","c5beb504-3432-11f0-8289-9e149126039e","c53d0a22-3432-11f0-a617-9e149126039e",25,["D",1747605311833],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nexport const USAGE_TABLE = \"townie_usage\";\nexport const INFERENCE_CALLS_TABLE = \"townie_inference_calls\";\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() {\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.execute(`\n CREATE TABLE IF NOT EXISTS ${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 `);\n // add all the data from the old table\n // await sqlite.execute(`INSERT INTO ${USAGE_TABLE} SELECT * FROM ${USAGE_TABLE}_1`);\n\n // TODO add an index on usage_id\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${INFERENCE_CALLS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n usage_id INTEGER NOT NULL REFERENCES ${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 `);\n}\n\nasync function deleteTables() {\n await sqlite.execute(`DROP TABLE IF EXISTS ${USAGE_TABLE}`);\n await sqlite.execute(`DROP TABLE IF EXISTS ${INFERENCE_CALLS_TABLE}`);\n}\n\n// await deleteTables();\nawait createTables();",[],[191,186,709,701],"database","c5b813ac-3432-11f0-8608-9e149126039e","queries.tsx","c5b815fa-3432-11f0-8608-9e149126039e",22,["D",1747605311829],"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 { INFERENCE_CALLS_TABLE, USAGE_TABLE } from \"./schema.tsx\";\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\nasync function last24Hours(userId: string) {\n const usage = await sqlite.execute(\n `SELECT \n sum(price) \n FROM ${USAGE_TABLE} \n WHERE \n user_id = ? \n AND timestamp > ?\n AND our_api_token = 1\n `,\n [userId, new Date().getTime() - 24 * 60 * 60 * 1000],\n );\n return usage.rows[0][0] || 0;\n}\n\n// These are reasonable placeholders.\n// If this takes off, we should give less free stuff (or maybe a limited free trial of $5 ever)\n// and then let folks buy credits via Stripe.\nconst DAILY_FREE_LIMIT = 0.5; // 50 cents per day\nconst DAILY_PRO_LIMIT = 5; // $5 per day\n\nconst LIMITS: { [key: string]: number } = {\n \"devto\": 100, // hardcoded limit of $100 per day for dev.to, billed later\n};\nexport async function overLimit(bearerToken: string) {\n const user = await getUser(bearerToken);\n const last24HourUsage = await last24Hours(user.id);\n\n const limit = LIMITS[user.username] ?? (user.tier === \"pro\" ? DAILY_PRO_LIMIT : DAILY_FREE_LIMIT);\n\n return last24HourUsage >= limit;\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}: {\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}) {\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 ${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 ) 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 ],\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}: {\n bearerToken: string;\n val_id: string;\n branch_id: string;\n model: string;\n our_api_token: boolean;\n num_images: number;\n}) {\n const user = await getUser(bearerToken);\n const { lastInsertRowid } = await sqlite.execute(\n `INSERT INTO ${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 finishTrackingUsage({\n rowid,\n input_tokens,\n output_tokens,\n cache_read_tokens,\n cache_write_tokens,\n finish_reason,\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}) {\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 `UPDATE ${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}",[],[191,186,709,711],"c5ce46c2-3432-11f0-93a3-9e149126039e","c5ce4758-3432-11f0-93a3-9e149126039e","c57d303e-3432-11f0-a1b3-9e149126039e",31,["D",1747605311995],"import { basicAuthMiddleware } from \"./auth.ts\";\nimport { handleApiRequest } from \"./api/index.ts\";\nimport { getRequests } from \"./api/requests.ts\";\nimport { getUserSummary } from \"./api/user-summary.ts\";\nimport { getInferenceCalls } from \"./api/inference-calls.ts\";\nimport { renderDashboard } from \"./views/dashboard.ts\";\nimport { renderRequests } from \"./views/requests.ts\";\nimport { renderInferenceCalls } from \"./views/inference-calls.ts\";\n\n/**\n * Main entry point for the usage dashboard\n */\nexport default async function(req: Request) {\n // Check authentication first\n const authResponse = await basicAuthMiddleware(req);\n if (authResponse) {\n return authResponse;\n }\n\n // Parse the URL\n const url = new URL(req.url);\n const path = url.pathname;\n\n // Handle API requests\n if (path.startsWith(\"/api/\")) {\n return handleApiRequest(req);\n }\n\n // Handle page requests\n try {\n if (path === \"/\" || path === \"\") {\n // User summary page\n const userData = await getUserSummary();\n return new Response(renderDashboard(userData), {\n headers: { \"Content-Type\": \"text/html\" }\n });\n }\n else if (path === \"/requests\") {\n // Requests page\n const usageId = url.searchParams.get(\"usage_id\");\n const requestsData = await getRequests(url);\n return new Response(renderRequests(\n requestsData.data, \n requestsData.pagination, \n url.toString()\n ), {\n headers: { \"Content-Type\": \"text/html\" }\n });\n }\n else if (path === \"/inference\") {\n // Inference calls page\n const inferenceData = await getInferenceCalls(url);\n return new Response(renderInferenceCalls(\n inferenceData.data, \n inferenceData.pagination, \n url.toString(),\n inferenceData.filtered\n ), {\n headers: { \"Content-Type\": \"text/html\" }\n });\n }\n else {\n // 404 page\n return new Response(\"Page not found\", {\n status: 404,\n headers: { \"Content-Type\": \"text/plain\" }\n });\n }\n } catch (error) {\n console.error(\"Error rendering page:\", error);\n return new Response(`Error: ${error.message}`, {\n status: 500,\n headers: { \"Content-Type\": \"text/plain\" }\n });\n }\n}",[],[191,186,709,726,32],"usage-dashboard","c5c9b918-3432-11f0-8608-9e149126039e","auth.ts","c5c9b9d6-3432-11f0-8608-9e149126039e",30,["D",1747605311976],"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}",[],[191,186,709,726,728],"c5ba8196-3432-11f0-8db4-9e149126039e","c5ba824a-3432-11f0-8db4-9e149126039e",23,["D",1747605311879],"# 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",[],[191,186,709,726,163],"c5c0727c-3432-11f0-aee7-9e149126039e","requests.ts","c5c072fe-3432-11f0-aee7-9e149126039e","c5876928-3432-11f0-b278-9e149126039e",26,["D",1747605311919],"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): 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 // Client-side script for collapsible rows\n const script = `\n // Function to toggle inference details\n function toggleInferenceDetails(usageId) {\n const detailsElement = document.getElementById('inference-' + usageId);\n \n if (detailsElement) {\n // Toggle visibility of existing details\n detailsElement.classList.toggle('visible');\n } else {\n // Create a placeholder while loading\n const row = document.querySelector('tr[data-id=\"' + usageId + '\"]');\n const colSpan = row.querySelectorAll('td').length;\n const newRow = document.createElement('tr');\n newRow.id = 'inference-' + usageId;\n newRow.classList.add('inference-details', 'visible');\n newRow.innerHTML = 'Loading inference calls...';\n row.parentNode.insertBefore(newRow, row.nextSibling);\n \n // Fetch the inference calls data\n fetch('/api/inference-calls?usage_id=' + usageId)\n .then(response => response.json())\n .then(data => {\n // Calculate totals from inference calls\n const totalInputTokens = data.data.reduce((sum, call) => sum + (call.input_tokens || 0), 0);\n const totalOutputTokens = data.data.reduce((sum, call) => sum + (call.output_tokens || 0), 0);\n const totalCacheReadTokens = data.data.reduce((sum, call) => sum + (call.cache_read_tokens || 0), 0);\n const totalCacheWriteTokens = data.data.reduce((sum, call) => sum + (call.cache_write_tokens || 0), 0);\n const totalPrice = data.data.reduce((sum, call) => sum + (call.price || 0), 0);\n \n // Get the usage row data\n const usageRow = document.querySelector('tr[data-id=\"' + usageId + '\"]');\n const usageInputTokens = parseInt(usageRow.getAttribute('data-input-tokens') || '0');\n const usageOutputTokens = parseInt(usageRow.getAttribute('data-output-tokens') || '0');\n const usageCacheReadTokens = parseInt(usageRow.getAttribute('data-cache-read-tokens') || '0');\n const usageCacheWriteTokens = parseInt(usageRow.getAttribute('data-cache-write-tokens') || '0');\n const usagePrice = parseFloat(usageRow.getAttribute('data-price') || '0');\n \n // Check for discrepancies\n const inputDiscrepancy = totalInputTokens !== usageInputTokens && usageInputTokens !== 0;\n const outputDiscrepancy = totalOutputTokens !== usageOutputTokens && usageOutputTokens !== 0;\n const cacheReadDiscrepancy = totalCacheReadTokens !== usageCacheReadTokens && usageCacheReadTokens !== 0;\n const cacheWriteDiscrepancy = totalCacheWriteTokens !== usageCacheWriteTokens && usageCacheWriteTokens !== 0;\n const priceDiscrepancy = Math.abs(totalPrice - usagePrice) > 0.0001 && usagePrice !== 0;\n \n // Format numbers for display\n const formatNumber = num => num.toLocaleString();\n const formatPrice = price => '$' + price.toFixed(4);\n \n // Build the HTML for the inference calls\n let html = '';\n \n // Add comparison summary\n html += '

';\n html += '

Usage Record

';\n html += '

Input Tokens: ' + formatNumber(usageInputTokens) + '

';\n html += '

Output Tokens: ' + formatNumber(usageOutputTokens) + '

';\n html += '

Cache Read: ' + formatNumber(usageCacheReadTokens) + '

';\n html += '

Cache Write: ' + formatNumber(usageCacheWriteTokens) + '

';\n html += '

Price: ' + formatPrice(usagePrice) + '

';\n html += '

';\n \n html += '

';\n html += '

Inference Calls (' + data.data.length + ')

';\n html += '

Input Tokens: ' + formatNumber(totalInputTokens) + (inputDiscrepancy ? ' Mismatch!' : '') + '

';\n html += '

Output Tokens: ' + formatNumber(totalOutputTokens) + (outputDiscrepancy ? ' Mismatch!' : '') + '

';\n html += '

Cache Read: ' + formatNumber(totalCacheReadTokens) + (cacheReadDiscrepancy ? ' Mismatch!' : '') + '

';\n html += '

Cache Write: ' + formatNumber(totalCacheWriteTokens) + (cacheWriteDiscrepancy ? ' Mismatch!' : '') + '

';\n html += '

Price: ' + formatPrice(totalPrice) + (priceDiscrepancy ? ' Mismatch!' : '') + '

';\n html += '

';\n \n // Add inference calls table\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n \n data.data.forEach(call => {\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n });\n \n html += '

ID	Timestamp	Step Type	Input	Output	Cache Read	Cache Write	Price	Finish
' + call.id + '	' + new Date(call.timestamp).toLocaleString(\"en-US\", { timeZone: \"America/New_York\" }) + '	' + (call.step_type \|\| '-') + '	' + (call.input_tokens ? formatNumber(call.input_tokens) : '-') + '	' + (call.output_tokens ? formatNumber(call.output_tokens) : '-') + '	' + (call.cache_read_tokens ? formatNumber(call.cache_read_tokens) : '-') + '	' + (call.cache_write_tokens ? formatNumber(call.cache_write_tokens) : '-') + '	' + (call.price ? formatPrice(call.price) : '-') + '	' + (call.finish_reason \|\| '-') + '

';\n html += '';\n \n // Update the details row\n document.getElementById('inference-' + usageId).innerHTML = html;\n })\n .catch(error => {\n document.getElementById('inference-' + usageId).innerHTML = \n 'Error loading inference calls: ' + error.message + '';\n });\n }\n }\n \n // Add click event listeners to all collapsible rows\n document.addEventListener('DOMContentLoaded', function() {\n document.querySelectorAll('.collapsible').forEach(row => {\n row.addEventListener('click', function() {\n const usageId = this.getAttribute('data-id');\n toggleInferenceDetails(usageId);\n });\n });\n });\n `;\n \n // Generate the content\n const content = `\n

All Usage Requests

Total Requests: ${totalRequests}

Total Price: ${formatPrice(totalPrice)}

Click on a row to see associated inference calls

\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}",[],[191,186,709,726,751,743],"views","c5c2b712-3432-11f0-8289-9e149126039e","layout.ts","c5c2b7c6-3432-11f0-8289-9e149126039e",27,["D",1747605311934],"/**\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 `;\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

\n \n ${content}\n \n \n \n \n `;\n}",[],[191,186,709,726,751,753],"c5c61b78-3432-11f0-a617-9e149126039e","inference-calls.ts","c5c61c36-3432-11f0-a617-9e149126039e",28,["D",1747605311955],"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)' : ''}

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}",[],[191,186,709,726,751,761],"c5c7f998-3432-11f0-88fa-9e149126039e","dashboard.ts","c5c7fa4c-3432-11f0-88fa-9e149126039e",29,["D",1747605311957],"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 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 \n // Generate the content\n const content = `\n

Usage by User

Total Users: ${totalUsers}

Total Price: ${formatPrice(totalPrice)}

\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 `).join(\"\")}\n \n

User ID	Username	Requests	Input Tokens	Output Tokens	Cache Read	Cache Write	Total 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' : ''}	${formatNumber(row.total_images)}

\n `;\n \n return renderLayout(content, {\n title: \"Usage Dashboard - User Summary\",\n activeTab: \"grouped\"\n });\n}",[],[191,186,709,726,751,769],"c58767ca-3432-11f0-b278-9e149126039e",14,["D",1747605311542],[218,219,220,221],[191,186,709,726,751],"c5d14430-3432-11f0-8289-9e149126039e","pagination.ts","c5d144e4-3432-11f0-8289-9e149126039e","c591e588-3432-11f0-b278-9e149126039e",32,["D",1747605312018],"/**\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}",[],[191,186,709,726,431,782],"c5d3d48e-3432-11f0-a694-9e149126039e","formatters.ts","c5d3d542-3432-11f0-a694-9e149126039e",33,["D",1747605312043],"// 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};",[],[191,186,709,726,431,791],"c591e506-3432-11f0-b278-9e149126039e",15,["D",1747605311611],[215,216],[191,186,709,726,431],"c5dc465a-3432-11f0-88fa-9e149126039e","c5dc4704-3432-11f0-88fa-9e149126039e","c59ba7da-3432-11f0-aee7-9e149126039e",36,["D",1747605312100],"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 \n // Get total count for pagination\n const countResult = await sqlite.execute(`\n SELECT COUNT(*) as total FROM ${USAGE_TABLE}\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 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 };\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}",[],[191,186,709,726,422,743],"c5d552d2-3432-11f0-af8a-9e149126039e","c5d55386-3432-11f0-af8a-9e149126039e",34,["D",1747605312045],"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 \n // Build the WHERE clause if we have a usage_id filter\n const whereClause = usageId ? `WHERE i.usage_id = ${usageId}` : \"\";\n \n // Get total count for pagination\n const countResult = await sqlite.execute(`\n SELECT COUNT(*) as total \n FROM ${INFERENCE_CALLS_TABLE} i\n ${whereClause}\n `);\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\n };\n}",[],[191,186,709,726,422,761],"c5d82426-3432-11f0-88fa-9e149126039e","c5d824b2-3432-11f0-88fa-9e149126039e",35,["D",1747605312074],"import { getRequests, getRequestById, getInferenceCallsForRequest } from \"./requests.ts\";\nimport { getUserSummary } from \"./user-summary.ts\";\nimport { getInferenceCalls } from \"./inference-calls.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 {\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}",[],[191,186,709,726,422,32],"c59ba73a-3432-11f0-aee7-9e149126039e",16,["D",1747605311678],[211,212,213],[191,186,709,726,422],"c57d2f94-3432-11f0-a1b3-9e149126039e",13,["D",1747605311478],[210,214,217,222,223,224],[191,186,709,726],"c53d0950-3432-11f0-a617-9e149126039e",6,["D",1747605311058],[209,225,226],[191,186,709],"c5234678-3432-11f0-aee7-9e149126039e",3,["D",1747605310889],[208,227,236,241,244],[191,186],["D",1747605310834],[207,245,249,250,251,252,253,254],[191],["D",1747420256725],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":53,"_101":102,"_103":24},{"_13":84,"_31":85,"_42":41,"_86":43,"_87":88,"_89":90,"_91":49,"_92":43,"_93":63,"_94":44,"_95":96},"ctx",{"_77":-5,"_126":885,"_886":887,"_888":889,"_890":24,"_891":24,"_892":24,"_893":57,"_894":-5,"_895":-7,"_896":-7,"_897":158,"_898":24,"_899":24,"_900":-5,"_901":24,"_902":24,"_903":24,"_904":-5},"ENV",{"_856":857,"_858":859,"_860":132,"_861":862,"_863":864,"_865":866,"_867":868,"_869":870,"_871":872,"_873":874,"_875":876,"_877":878,"_879":880,"_881":882,"_883":884},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v50