Hi

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

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys)\n unless otherwise specified\n- **View Source:** Add a view source link by importing & using\n `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the\n client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add\n `` to HTML to capture\n client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local\n resolution; Avoid catches that merely log or return 500s. Let errors bubble up\n with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but\n generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure\n compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer\n simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with\n `?deps=react@18.2.0,react-dom@18.2.0` and start the file with\n `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same\n version\n- **Styling:** Default to using TailwindCSS via\n `` unless otherwise\n specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project\n files:\n ```ts\n import {\n readFile,\n serveFile,\n } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n\n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url));\n\n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async (c) => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n\n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to\n see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:**\n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of\n React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with\n `export default app.fetch // This is the entry point for HTTP vals`",[],[296],"91936f1c-d08c-11f0-9ab4-42dde27851f2",".vtignore","019ae60d-e065-76f8-84ce-6ec4a91936be",["D",1764796260359],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor",[],[303],"91936af8-d08c-11f0-9ab4-42dde27851f2","schema.ts","019ae60d-e065-76f8-84ce-679ce221b432","019ae60d-e065-76f8-84ce-6b2985eaeea2",["D",1764796260359],"/**\n * Drizzle ORM Schema for Claude Plugins API\n */\nimport { sql } from \"npm:drizzle-orm@0.44.2\";\nimport { integer, sqliteTable, text } from \"npm:drizzle-orm@0.44.2/sqlite-core\";\n\n/**\n * Plugins table - stores all registered plugins\n */\nexport const plugins = sqliteTable(\"plugins\", {\n id: text(\"id\").primaryKey(),\n name: text(\"name\").notNull(),\n namespace: text(\"namespace\").notNull(),\n gitUrl: text(\"git_url\").notNull(),\n\n // Search fields\n description: text(\"description\"),\n keywords: text(\"keywords\"), // JSON stringified array\n category: text(\"category\"),\n skills: text(\"skills\"), // JSON stringified array\n\n // Display metadata\n version: text(\"version\").notNull().default(\"1.0.0\"),\n author: text(\"author\").notNull(), // Simple string, no complex object\n\n // All other marketplace data as single JSON blob\n metadata: text(\"metadata\"), // JSON: { homepage, license, commands, agents, mcpServers, etc. }\n\n // GitHub signals\n stars: integer(\"stars\").notNull().default(0),\n\n // Plugin status\n verified: integer(\"verified\", { mode: \"boolean\" }).notNull().default(false),\n downloads: integer(\"downloads\").notNull().default(0),\n\n // Timestamps\n createdAt: text(\"created_at\").notNull().default(sql`CURRENT_TIMESTAMP`),\n updatedAt: text(\"updated_at\").notNull().default(sql`CURRENT_TIMESTAMP`),\n});\n\n/**\n * Plugin stats table - tracks download statistics\n */\nexport const pluginStats = sqliteTable(\"plugin_stats\", {\n pluginId: text(\"plugin_id\")\n .primaryKey()\n .references(() => plugins.id),\n downloadsTotal: integer(\"downloads_total\").notNull().default(0),\n downloadsWeek: integer(\"downloads_week\").notNull().default(0),\n downloadsMonth: integer(\"downloads_month\").notNull().default(0),\n lastDownloadedAt: text(\"last_downloaded_at\"),\n});\n\n/**\n * Search Buckets tabs - stores all search buckets\n */\nexport const searchBuckets = sqliteTable(\"search_buckets\", {\n id: text(\"id\").primaryKey(),\n name: text(\"name\").notNull(),\n buckets: text(\"buckets\").notNull(), // JSON stringified array\n \n // Timestamps\n createdAt: text(\"created_at\").notNull().default(sql`CURRENT_TIMESTAMP`),\n updatedAt: text(\"updated_at\").notNull().default(sql`CURRENT_TIMESTAMP`),\n})\n\n/**\n * Skills table - stores all registered Claude Code Skills\n */\nexport const skills = sqliteTable(\"skills\", {\n id: text(\"id\").primaryKey(),\n name: text(\"name\").notNull(),\n namespace: text(\"namespace\").notNull(), // @owner/repo/skillName\n sourceUrl: text(\"source_url\").notNull(), // GitHub tree URL\n sourceType: text(\"source_type\").notNull().default(\"github\"), // \"github\" | \"r2\"\n\n // From SKILL.md YAML frontmatter\n description: text(\"description\").notNull(), // Max 200 chars\n version: text(\"version\"),\n dependencies: text(\"dependencies\"),\n\n // Metadata\n author: text(\"author\").notNull(),\n stars: integer(\"stars\").notNull().default(0),\n installs: integer(\"installs\").notNull().default(0),\n verified: integer(\"verified\", { mode: \"boolean\" }).notNull().default(false),\n\n // JSON blob for extra data\n metadata: text(\"metadata\"), // {repoOwner, repoName, directoryPath, rawFileUrl, license, ...}\n\n // Timestamps\n createdAt: text(\"created_at\").notNull().default(sql`CURRENT_TIMESTAMP`),\n updatedAt: text(\"updated_at\").notNull().default(sql`CURRENT_TIMESTAMP`),\n});\n\n/**\n * Skill stats table - tracks install statistics\n */\nexport const skillStats = sqliteTable(\"skill_stats\", {\n skillId: text(\"skill_id\")\n .primaryKey()\n .references(() => skills.id),\n installsTotal: integer(\"installs_total\").notNull().default(0),\n installsWeek: integer(\"installs_week\").notNull().default(0),\n installsMonth: integer(\"installs_month\").notNull().default(0),\n lastInstalledAt: text(\"last_installed_at\"),\n});\n\n// Type exports for TypeScript\nexport type Plugin = typeof plugins.$inferSelect;\nexport type NewPlugin = typeof plugins.$inferInsert;\n\nexport type PluginStats = typeof pluginStats.$inferSelect;\nexport type NewPluginStats = typeof pluginStats.$inferInsert;\n\nexport type Skill = typeof skills.$inferSelect;\nexport type NewSkill = typeof skills.$inferInsert;\n\nexport type SkillStats = typeof skillStats.$inferSelect;\nexport type NewSkillStats = typeof skillStats.$inferInsert;",[],[317,310],"database","91936454-d08c-11f0-9ab4-42dde27851f2","run-migrations.ts","019ae60d-e065-76f8-84ce-635055b436bc",["D",1764796260359],"import { runMigrations } from \"./db.ts\";\n\n(async function run() {\n try {\n await runMigrations();\n console.log(\"Migrations completed successfully\");\n } catch (error) {\n console.error(\"Error running migrations:\", error);\n throw error;\n }\n})();",[],[317,319],"91935fc2-d08c-11f0-9ab4-42dde27851f2","db.ts","019ae60d-e065-76f8-84ce-5cb824512c0a",["D",1764796260359],"/**\n * Database connection and utilities\n */\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { sql } from \"npm:drizzle-orm@0.44.2\";\nimport { drizzle } from \"npm:drizzle-orm@0.44.2/libsql\";\nimport * as schema from \"./schema.ts\";\n\n// Initialize Drizzle with Val Town SQLite (without schema to avoid circular refs)\nexport const db = drizzle(sqlite as any);\n\nasync function runCreateSearchBuckets() {\n console.log('Running create search buckets')\n try {\n // Check if tables exist by attempting to query them\n const tableCheck = await db\n .select({ count: sql`count(*)` })\n .from(schema.searchBuckets)\n .limit(1)\n .catch(() => null);\n\n if (tableCheck === null) {\n console.log(\"Creating table for Search Buckets...\");\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS search_buckets (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n buckets TEXT,\n created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n updated_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP\n )\n `);\n console.log(\"Search buckets created successfully\");\n }\n } catch (e) {\n console.error('Table creation failed')\n throw e\n }\n}\n\n/**\n * Run database migrations to create tables and indexes\n */\nasync function runCreateTablesAndIndexes() {\n console.log(\"Running create tables and indexes...\");\n\n try {\n // Check if tables exist by attempting to query them\n const tableCheck = await db\n .select({ count: sql`count(*)` })\n .from(schema.plugins)\n .limit(1)\n .catch(() => null);\n\n if (tableCheck === null) {\n // Tables don't exist, create them using schema-driven SQL\n console.log(\"Creating database schema...\");\n\n // Create tables using Drizzle schema definitions\n // This ensures schema and database stay in sync\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS plugins (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n namespace TEXT NOT NULL,\n git_url TEXT NOT NULL,\n description TEXT,\n keywords TEXT,\n category TEXT,\n version TEXT NOT NULL DEFAULT '1.0.0',\n author TEXT NOT NULL,\n metadata TEXT,\n stars INTEGER NOT NULL DEFAULT 0,\n verified INTEGER NOT NULL DEFAULT 0,\n downloads INTEGER NOT NULL DEFAULT 0,\n created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n updated_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS plugin_stats (\n plugin_id TEXT PRIMARY KEY,\n downloads_total INTEGER NOT NULL DEFAULT 0,\n downloads_week INTEGER NOT NULL DEFAULT 0,\n downloads_month INTEGER NOT NULL DEFAULT 0,\n last_downloaded_at TEXT,\n FOREIGN KEY (plugin_id) REFERENCES plugins(id) ON DELETE CASCADE\n )\n `);\n\n // Create indexes for query performance\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_plugins_namespace ON plugins(namespace)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_plugins_name ON plugins(name)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_plugins_category ON plugins(category)`,\n );\n await sqlite.execute(\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_plugins_namespace_name ON plugins(namespace, name)`,\n );\n\n console.log(\"Schema created successfully\");\n }\n\n console.log(\"Creating database completed successfully\");\n } catch (error) {\n console.error(\"Migration failed:\", error);\n throw error;\n }\n}\n\nasync function runAddSkillsMigration(): Promise {\n console.log(\"Running migration: add `skills` column to `plugins`…\");\n const pragma = await sqlite.execute(`PRAGMA table_info(plugins);`);\n const hasSkills = Array.isArray(pragma?.rows)\n ? pragma.rows.some((r: any) => r.name === \"skills\")\n : false;\n\n if (hasSkills) {\n console.log(\"Column `skills` already exists. Skipping ALTER TABLE.\");\n } else {\n console.log(\"Adding `skills` column (TEXT, nullable) to `plugins`…\");\n await sqlite.execute(`ALTER TABLE plugins ADD COLUMN skills TEXT;`);\n console.log(\"Column `skills` added.\");\n }\n\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_plugins_skills ON plugins(skills);`,\n );\n\n console.log(\"Migration completed: add `skills` column.\");\n}\n\nasync function runAddSkillsTableMigration(): Promise {\n console.log(\"Running migration: create skills and skill_stats tables...\");\n\n try {\n // Check if skills table exists\n const skillsTableCheck = await sqlite\n .execute(`SELECT name FROM sqlite_master WHERE type='table' AND name='skills';`)\n .catch(() => null);\n\n if (!skillsTableCheck || skillsTableCheck.rows.length === 0) {\n console.log(\"Creating skills table...\");\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS skills (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n namespace TEXT NOT NULL,\n source_url TEXT NOT NULL,\n source_type TEXT NOT NULL DEFAULT 'github',\n description TEXT NOT NULL,\n version TEXT,\n dependencies TEXT,\n author TEXT NOT NULL,\n stars INTEGER NOT NULL DEFAULT 0,\n installs INTEGER NOT NULL DEFAULT 0,\n verified INTEGER NOT NULL DEFAULT 0,\n metadata TEXT,\n created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,\n updated_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS skill_stats (\n skill_id TEXT PRIMARY KEY,\n installs_total INTEGER NOT NULL DEFAULT 0,\n installs_week INTEGER NOT NULL DEFAULT 0,\n installs_month INTEGER NOT NULL DEFAULT 0,\n last_installed_at TEXT,\n FOREIGN KEY (skill_id) REFERENCES skills(id) ON DELETE CASCADE\n )\n `);\n\n // Create indexes\n await sqlite.execute(\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_skills_namespace ON skills(namespace)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_skills_name ON skills(name)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_skills_author ON skills(author)`,\n );\n\n console.log(\"Skills tables created successfully\");\n } else {\n console.log(\"Skills table already exists. Skipping.\");\n }\n } catch (error) {\n console.error(\"Skills table migration failed:\", error);\n throw error;\n }\n\n console.log(\"Migration completed: skills tables\");\n}\n\nexport async function runMigrations(): Promise {\n // await runCreateTablesAndIndexes();\n // await runAddSkillsMigration();\n // await runAddSkillsTableMigration();\n await runCreateSearchBuckets()\n}",[],[317,326],"91936dfa-d08c-11f0-9ab4-42dde27851f2",["D",1764796260359],[249,250,251],[317],["D",1764796260359],[],[18,77],["D",1764796260359],[],[18,89],["D",1764796260359],[],[18,96],["D",1764796260359],[],[18,102],["D",1764796260359],[],[18,107],["D",1764796260359],[243,244,245,246,247],[18],"91933d80-d08c-11f0-9ab4-42dde27851f2","github.ts","019ae60d-e064-705a-b378-bc94bfc04ab5","019ae60d-e064-705a-b378-c09a3ddd2928",["D",1764796260359],"import { z } from \"npm:zod@3.24.2\";\n\nconst REQUESTS_PER_INTERVAL = 80;\nconst INTERVAL_MS = 1000;\n\nexport type Bucket = {\n min: number;\n max: number;\n count: number;\n};\n\n/**\n * GitHub code search response types\n */\nconst GitHubSearchItemSchema = z.object({\n name: z.string(),\n path: z.string(),\n sha: z.string(),\n url: z.string().url(),\n html_url: z.string().url(),\n repository: z.object({\n id: z.number(),\n full_name: z.string(),\n html_url: z.string().url(),\n owner: z.object({\n login: z.string(),\n }),\n }),\n});\n\nconst GitHubRepoSchema = z.object({\n id: z.number(),\n full_name: z.string(),\n stargazers_count: z.number(),\n updated_at: z.string(),\n html_url: z.string().url(),\n fork: z.boolean(),\n default_branch: z.string(),\n});\n\nconst GitHubSearchResponseSchema = z.object({\n total_count: z.number(),\n incomplete_results: z.boolean(),\n items: z.array(GitHubSearchItemSchema),\n});\n\nexport type GitHubSearchItem = z.infer;\nexport type GitHubSearchResponse = z.infer;\nexport type GitHubRepo = z.infer;\n\n/**\n * GitHub API client with rate limit handling\n */\nexport class GitHubClient {\n private token: string;\n private baseUrl = \"https://api.github.com\";\n private apiVersion = \"2022-11-28\";\n private tokens = REQUESTS_PER_INTERVAL;\n private lastRefill = Date.now();\n\n constructor(token: string) {\n this.token = token;\n }\n\n /**\n * Search for files matching a path pattern\n */\n async searchCode(\n query: string,\n page: number = 1,\n ): Promise {\n const url = `${this.baseUrl}/search/code?q=${\n encodeURIComponent(query)\n }&per_page=100&page=${page}`;\n\n const response = await this.fetchWithRetry(url);\n\n // Check rate limit\n const remaining = parseInt(\n response.headers.get(\"x-ratelimit-remaining\") || \"10\",\n );\n const resetTime = parseInt(\n response.headers.get(\"x-ratelimit-reset\") || \"0\",\n );\n\n console.log(\n `GitHub rate limit: ${remaining}/10 remaining, resets at ${\n new Date(resetTime * 1000).toISOString()\n }`,\n );\n\n if (remaining <= 2) {\n const waitSeconds = resetTime - Math.floor(Date.now() / 1000) + 5;\n if (waitSeconds > 0) {\n console.warn(\n `Rate limit low. Waiting ${waitSeconds}s before continuing...`,\n );\n await this.sleep(waitSeconds * 1000);\n }\n }\n\n if (!response.ok) {\n throw new Error(\n `GitHub search failed: ${response.status} ${response.statusText}`,\n );\n }\n\n const data = await response.json();\n return GitHubSearchResponseSchema.parse(data);\n }\n\n /**\n * Fetch raw file content from repository\n */\n async fetchFileContent(repoFullName: string, path: string): Promise {\n const url = `${this.baseUrl}/repos/${repoFullName}/contents/${path}`;\n\n const response = await this.fetchWithRetry(url);\n\n if (!response.ok) {\n throw new Error(\n `Failed to fetch ${path} from ${repoFullName}: ${response.status}`,\n );\n }\n\n const data = await response.json();\n\n // Decode base64 content\n if (data.encoding === \"base64\" && data.content) {\n return atob(data.content.replace(/\\n/g, \"\"));\n }\n\n throw new Error(`Unexpected content encoding: ${data.encoding}`);\n }\n\n /**\n * Fetch repository metadata (stars, updated_at, etc.)\n */\n async fetchRepoMetadata(repoFullName: string): Promise {\n const url = `${this.baseUrl}/repos/${repoFullName}`;\n\n const response = await this.fetchWithRetry(url);\n\n if (!response.ok) {\n throw new Error(\n `Failed to fetch repo metadata for ${repoFullName}: ${response.status}`,\n );\n }\n\n const data = await response.json();\n return GitHubRepoSchema.parse(data);\n }\n\n async findBuckets(\n baseQuery: string,\n {\n min,\n max,\n maxPerBucket = 950,\n minSpan = 100,\n }: {\n min: number;\n max: number;\n maxPerBucket?: number;\n minSpan?: number;\n },\n ): Promise> {\n const query = `${baseQuery} size:${min}..${max}`;\n const count = (await this.searchCode(query)).total_count ?? 0;\n\n if (count === 0) return [];\n\n if (count <= maxPerBucket || (max - min) <= minSpan) {\n return [{ min, max, count }];\n }\n\n // Split the range and recurse\n const mid = Math.floor((min + max) / 2);\n const left = await this.findBuckets(\n baseQuery,\n { min: min, max: mid, maxPerBucket, minSpan },\n );\n const right = await this.findBuckets(\n baseQuery,\n { min: mid + 1, max: max, maxPerBucket, minSpan },\n );\n return [...left, ...right];\n }\n\n /**\n * Fetch with exponential backoff retry\n */\n private async fetchWithRetry(\n url: string,\n maxRetries: number = 3,\n ): Promise {\n // Throttling requests to Github before any attempts\n await this.waitForToken();\n\n let lastError: Error | null = null;\n\n for (let attempt = 0; attempt <= maxRetries; attempt++) {\n try {\n const response = await fetch(url, {\n headers: {\n Accept: \"application/vnd.github+json\",\n Authorization: `Bearer ${this.token}`,\n \"X-GitHub-Api-Version\": this.apiVersion,\n },\n });\n\n // Handle rate limiting with Retry-After\n if (response.status === 429 || response.status === 403) {\n const retryAfter = response.headers.get(\"retry-after\");\n if (attempt < maxRetries) {\n const waitSeconds = retryAfter ? parseInt(retryAfter) : 60;\n console.log(\n `Rate limited. Waiting ${waitSeconds}s before retry ${\n attempt + 1\n }...`,\n );\n await this.sleep(waitSeconds * 1000);\n continue;\n }\n }\n\n return response;\n } catch (error) {\n lastError = error as Error;\n\n if (attempt < maxRetries) {\n const delay = Math.min(1000 * Math.pow(2, attempt), 10000);\n console.log(\n `Request failed, retrying in ${delay}ms... (attempt ${\n attempt + 1\n }/${maxRetries})`,\n );\n await this.sleep(delay);\n }\n }\n }\n\n throw lastError || new Error(\"Request failed after retries\");\n }\n\n private async waitForToken(): Promise {\n const now = Date.now();\n const elapsed = now - this.lastRefill;\n if (elapsed >= INTERVAL_MS) {\n const intervals = Math.floor(elapsed / INTERVAL_MS);\n this.tokens = Math.min(\n REQUESTS_PER_INTERVAL,\n this.tokens + intervals * REQUESTS_PER_INTERVAL,\n );\n this.lastRefill = now;\n }\n\n if (this.tokens > 0) {\n this.tokens--;\n return;\n }\n\n const delay = Math.max(0, INTERVAL_MS - (Date.now() - this.lastRefill));\n await this.sleep(delay);\n // After waiting, consume a token\n if (this.tokens > 0) this.tokens--;\n else this.tokens = Math.max(0, this.tokens - 1);\n }\n\n private sleep(ms: number): Promise {\n return new Promise((resolve) => setTimeout(resolve, ms));\n }\n}",[],[362,355],"clients","919346fe-d08c-11f0-9ab4-42dde27851f2",["D",1764796260359],[241],[362],"91932de0-d08c-11f0-9ab4-42dde27851f2","skills.ts","019ae60d-e064-705a-b378-b7f426a53c69","019ae60d-e064-705a-b378-ba8702352eff",["D",1764796260359],"/**\n * Skills API endpoints\n */\nimport type { Context } from \"https://esm.sh/hono@4.9\";\nimport { and, desc, eq, like, or, sql } from \"npm:drizzle-orm@0.44.2\";\nimport { db } from \"../database/db.ts\";\nimport { skills, skillStats } from \"../database/schema.ts\";\n\n/**\n * GET /api/skills/:owner/:repo/:skillName\n * Get skill info (read-only, no install increment)\n */\nexport async function getSkill(c: Context) {\n const { owner, repo, skillName } = c.req.param();\n\n if (!owner || !repo || !skillName) {\n return c.json({ error: \"Missing owner, repo, or skill name\" }, 400);\n }\n\n const namespace = `${owner}/${repo}/${skillName}`;\n\n const skill = await db\n .select()\n .from(skills)\n .where(eq(skills.namespace, namespace))\n .get();\n\n if (!skill) {\n return c.json({\n error: `Skill ${namespace} not found`,\n }, 404);\n }\n\n const metadata = skill.metadata ? JSON.parse(skill.metadata) : {};\n\n return c.json({\n id: skill.id,\n name: skill.name,\n namespace: skill.namespace,\n sourceUrl: skill.sourceUrl,\n sourceType: skill.sourceType,\n description: skill.description,\n version: skill.version,\n dependencies: skill.dependencies,\n author: skill.author,\n stars: skill.stars,\n installs: skill.installs,\n verified: Boolean(skill.verified),\n metadata,\n createdAt: skill.createdAt,\n updatedAt: skill.updatedAt,\n });\n}\n\n/**\n * POST /api/skills/:owner/:repo/:skillName/install\n * Track skill installation\n */\nexport async function installSkill(c: Context) {\n const { owner, repo, skillName } = c.req.param();\n console.log(\"owner\", owner, \"repo\", repo, \"skillName\", skillName);\n\n if (!owner || !repo || !skillName) {\n return c.json({ error: \"Missing owner, repo, or skill name\" }, 400);\n }\n\n const namespace = `${owner}/${repo}/${skillName}`;\n\n const skill = await db\n .select()\n .from(skills)\n .where(eq(skills.namespace, namespace))\n .get();\n\n if (!skill) {\n return c.json({\n error: `Skill ${namespace} not found`,\n }, 404);\n }\n\n try {\n await incrementInstalls(skill.id);\n return c.json({ success: true });\n } catch (error) {\n console.error(\"Failed to increment installs:\", error);\n return c.json({ error: \"Failed to track installation\" }, 500);\n }\n}\n\n/**\n * GET /api/skills/search?q=query&limit=20&offset=0\n * Search skills\n */\nexport async function searchSkills(c: Context) {\n const query = c.req.query(\"q\") || \"\";\n const limit = Math.min(parseInt(c.req.query(\"limit\") || \"20\"), 10000);\n const offset = parseInt(c.req.query(\"offset\") || \"0\");\n\n let queryBuilder = db.select().from(skills);\n\n const conditions = [];\n\n if (query) {\n const searchTerm = `%${query.toLowerCase()}%`;\n conditions.push(\n or(\n like(sql`LOWER(${skills.name})`, searchTerm),\n like(sql`LOWER(${skills.description})`, searchTerm),\n like(sql`LOWER(${skills.namespace})`, searchTerm),\n like(sql`LOWER(${skills.author})`, searchTerm),\n ),\n );\n }\n\n const finalWhere = conditions.length === 0\n ? null\n : conditions.length === 1\n ? conditions[0]\n : and(...conditions);\n\n let countBuilder = db.select({ count: sql`count(*)` }).from(skills);\n if (finalWhere) {\n countBuilder = countBuilder.where(finalWhere);\n }\n\n if (finalWhere) {\n queryBuilder = queryBuilder.where(finalWhere);\n }\n\n queryBuilder = queryBuilder.orderBy(\n desc(skills.installs),\n desc(skills.stars),\n );\n\n const [{ count: total }] = await countBuilder.all();\n const results = await queryBuilder.limit(limit).offset(offset).all();\n\n const formattedSkills = results.map((skill) => ({\n id: skill.id,\n name: skill.name,\n namespace: skill.namespace,\n sourceUrl: skill.sourceUrl,\n description: skill.description,\n version: skill.version,\n dependencies: skill.dependencies,\n author: skill.author,\n stars: skill.stars,\n installs: skill.installs,\n verified: Boolean(skill.verified),\n metadata: skill.metadata ? JSON.parse(skill.metadata) : {},\n createdAt: skill.createdAt,\n updatedAt: skill.updatedAt,\n }));\n\n return c.json({\n skills: formattedSkills,\n total,\n limit,\n offset,\n });\n}\n\n/**\n * GET /api/skills/:owner/:repo/:skillName/stats\n * Get skill statistics\n */\nexport async function getSkillStats(c: Context) {\n const { owner, repo, skillName } = c.req.param();\n const namespace = `@${owner}/${repo}/${skillName}`;\n\n const result = await db\n .select({\n skill: skills,\n stats: skillStats,\n })\n .from(skills)\n .leftJoin(skillStats, eq(skills.id, skillStats.skillId))\n .where(eq(skills.namespace, namespace))\n .get();\n\n if (!result || !result.skill) {\n return c.json({\n error: `Skill ${namespace} not found`,\n }, 404);\n }\n\n return c.json({\n installs: {\n total: result.stats?.installsTotal || 0,\n week: result.stats?.installsWeek || 0,\n month: result.stats?.installsMonth || 0,\n },\n lastInstalled: result.stats?.lastInstalledAt || null,\n });\n}\n\n/**\n * Increment install statistics for a skill\n */\nasync function incrementInstalls(skillId: string) {\n await db\n .update(skills)\n .set({ installs: sql`${skills.installs} + 1` })\n .where(eq(skills.id, skillId));\n\n const now = new Date().toISOString();\n\n const existing = await db\n .select()\n .from(skillStats)\n .where(eq(skillStats.skillId, skillId))\n .get();\n\n if (existing) {\n await db\n .update(skillStats)\n .set({\n installsTotal: sql`${skillStats.installsTotal} + 1`,\n installsWeek: sql`${skillStats.installsWeek} + 1`,\n installsMonth: sql`${skillStats.installsMonth} + 1`,\n lastInstalledAt: now,\n })\n .where(eq(skillStats.skillId, skillId));\n } else {\n await db.insert(skillStats).values({\n skillId,\n installsTotal: 1,\n installsWeek: 1,\n installsMonth: 1,\n lastInstalledAt: now,\n });\n }\n}",[],[375,368],"api","91932944-d08c-11f0-9ab4-42dde27851f2","search.ts","019ae60d-e064-705a-b378-b3e469cf56fd",["D",1764796260359],"/**\n * Plugin search endpoint\n * Search and filter plugins by query, category, etc.\n */\nimport type { Context } from \"https://esm.sh/hono@4.9\";\nimport { and, desc, eq, like, or, sql } from \"npm:drizzle-orm@0.44.2\";\nimport { db } from \"../database/db.ts\";\nimport { plugins } from \"../database/schema.ts\";\n\nexport function getSkillName(path: string): string {\n const prefix = \"./skills/\";\n return path.startsWith(prefix) ? path.slice(prefix.length) : path;\n}\n\n/**\n * GET /api/search?q=supabase&category=database&limit=20&offset=0\n * Search plugins with optional filters\n */\nexport async function searchPlugins(c: Context) {\n const query = c.req.query(\"q\") || \"\";\n const category = c.req.query(\"category\");\n const hasSkills = c.req.query(\"hasSkills\");\n const limit = Math.min(parseInt(c.req.query(\"limit\") || \"20\"), 100); // Max 100\n const offset = parseInt(c.req.query(\"offset\") || \"0\");\n\n console.log(\"Has Skills Value =>\", hasSkills);\n\n let queryBuilder = db.select().from(plugins);\n\n // Build where conditions\n const conditions = [];\n\n if (query) {\n const searchTerm = `%${query.toLowerCase()}%`;\n conditions.push(\n or(\n like(sql`LOWER(${plugins.name})`, searchTerm),\n like(sql`LOWER(${plugins.description})`, searchTerm),\n like(sql`LOWER(${plugins.keywords})`, searchTerm),\n like(sql`LOWER(${plugins.namespace})`, searchTerm),\n like(sql`LOWER(${plugins.skills})`, searchTerm),\n ),\n );\n }\n\n if (category) {\n conditions.push(eq(plugins.category, category));\n }\n\n // Only return plugins with at least 1 skill when hasSkills=true\n if (hasSkills === \"true\") {\n console.log(\"Adding Skills Filter\");\n // Guard that it's a JSON array and has length >= 1\n const hasSkillsFilter =\n sql`json_type(${plugins.skills}) = 'array' AND json_array_length(${plugins.skills}) >= 1`;\n conditions.push(hasSkillsFilter);\n }\n\n const finalWhere = conditions.length === 0\n ? null\n : conditions.length === 1\n ? conditions[0]\n : and(...conditions);\n\n // Get total count before pagination\n let countBuilder = db.select({ count: sql`count(*)` }).from(plugins);\n if (finalWhere) {\n countBuilder = countBuilder.where(finalWhere);\n }\n\n // Apply where to data query\n if (finalWhere) {\n queryBuilder = queryBuilder.where(finalWhere);\n }\n\n queryBuilder = queryBuilder.orderBy(\n desc(plugins.downloads),\n desc(plugins.stars),\n );\n\n const [{ count: total }] = await countBuilder.all();\n const results = await queryBuilder.limit(limit).offset(offset).all();\n const parseSkills = (skills: string) => {\n const parsedSkills = JSON.parse(skills);\n if (Array.isArray(parsedSkills) && parsedSkills.length > 0) {\n return parsedSkills?.map(getSkillName);\n }\n\n return parsedSkills;\n };\n\n // Format results\n const formattedPlugins = results.map((plugin) => ({\n id: plugin.id,\n name: plugin.name,\n namespace: plugin.namespace,\n gitUrl: plugin.gitUrl,\n description: plugin.description,\n version: plugin.version,\n author: plugin.author,\n keywords: plugin.keywords ? JSON.parse(plugin.keywords) : [],\n skills: plugin.skills ? parseSkills(plugin.skills) : [],\n category: plugin.category,\n stars: plugin.stars,\n verified: Boolean(plugin.verified),\n downloads: plugin.downloads,\n metadata: plugin.metadata ? JSON.parse(plugin.metadata) : {},\n createdAt: plugin.createdAt,\n updatedAt: plugin.updatedAt,\n }));\n\n return c.json({\n plugins: formattedPlugins,\n total,\n limit,\n offset,\n });\n}",[],[375,377],"91932200-d08c-11f0-9ab4-42dde27851f2","resolve.ts","019ae60d-e064-705a-b378-ae0900b40ae4",["D",1764796260359],"/**\n * Plugin resolution endpoint\n * Resolves @namespace/name to git URL\n */\nimport type { Context } from \"https://esm.sh/hono@4.9\";\nimport { and, eq, sql } from \"npm:drizzle-orm@0.44.2\";\nimport { db } from \"../database/db.ts\";\nimport { plugins, pluginStats } from \"../database/schema.ts\";\n\n/**\n * GET /api/resolve/:owner/:marketplace/:plugin\n * Resolves plugin identifier to git URL and metadata\n *\n * Examples:\n * /api/resolve/davila7/claude-code-templates/supabase-toolkit\n * /api/resolve/anthropics/claude-code-plugins/agent-sdk-dev\n */\nexport async function resolvePlugin(c: Context) {\n const { owner, marketplace, plugin: pluginName } = c.req.param();\n console.log({ owner, marketplace, pluginName });\n\n if (!owner || !marketplace || !pluginName) {\n return c.json({ error: \"Missing owner, marketplace, or plugin name\" }, 400);\n }\n\n const ownerName = owner.startsWith(\"@\") ? owner : `@${owner}`;\n\n const namespace = `${ownerName}/${marketplace}`;\n console.log(\"Namespace:\", namespace);\n\n // Query database\n const plugin = await db\n .select()\n .from(plugins)\n .where(and(eq(plugins.namespace, namespace), eq(plugins.name, pluginName)))\n .get();\n\n if (!plugin) {\n return c.json({\n error: `Plugin ${owner}/${marketplace}/${pluginName} not found`,\n }, 404);\n }\n\n // Increment download count\n try {\n await incrementDownloads(plugin.id);\n } catch (error) {\n console.error(\"Failed to increment downloads:\", error);\n // Don't fail the request if stats update fails\n }\n\n // Parse JSON fields\n const keywords = plugin.keywords ? JSON.parse(plugin.keywords) : [];\n const metadata = plugin.metadata ? JSON.parse(plugin.metadata) : {};\n\n return c.json({\n name: plugin.name,\n namespace: plugin.namespace,\n gitUrl: plugin.gitUrl,\n description: plugin.description,\n version: plugin.version,\n author: plugin.author,\n keywords,\n category: plugin.category,\n stars: plugin.stars,\n verified: Boolean(plugin.verified),\n downloads: plugin.downloads,\n metadata, // All other fields (homepage, license, commands, agents, mcpServers, etc.)\n });\n}\n\n/**\n * Increment download statistics for a plugin\n */\nasync function incrementDownloads(pluginId: string) {\n // Update total downloads in plugins table\n await db\n .update(plugins)\n .set({ downloads: sql`${plugins.downloads} + 1` })\n .where(eq(plugins.id, pluginId));\n\n // Update stats table\n const now = new Date().toISOString();\n\n // Check if stats entry exists\n const existing = await db\n .select()\n .from(pluginStats)\n .where(eq(pluginStats.pluginId, pluginId))\n .get();\n\n if (existing) {\n await db\n .update(pluginStats)\n .set({\n downloadsTotal: sql`${pluginStats.downloadsTotal} + 1`,\n downloadsWeek: sql`${pluginStats.downloadsWeek} + 1`,\n downloadsMonth: sql`${pluginStats.downloadsMonth} + 1`,\n lastDownloadedAt: now,\n })\n .where(eq(pluginStats.pluginId, pluginId));\n } else {\n // Create new stats entry\n await db.insert(pluginStats).values({\n pluginId,\n downloadsTotal: 1,\n downloadsWeek: 1,\n downloadsMonth: 1,\n lastDownloadedAt: now,\n });\n }\n}",[],[375,384],"9193188c-d08c-11f0-9ab4-42dde27851f2","plugins.ts","019ae60d-e064-705a-b378-aa7d93aa383b",["D",1764796260359],"/**\n * Plugin stats endpoint\n */\nimport type { Context } from \"https://esm.sh/hono@4.9\";\nimport { and, eq } from \"npm:drizzle-orm@0.44.2\";\nimport { db } from \"../database/db.ts\";\nimport { plugins, pluginStats } from \"../database/schema.ts\";\n\n/**\n * GET /api/plugins/:owner/:marketplace/:plugin/stats\n * Get plugin download statistics\n */\nexport async function getPluginStats(c: Context) {\n const { owner, marketplace, plugin: pluginName } = c.req.param();\n const namespace = `${owner}/${marketplace}`;\n\n const result = await db\n .select({\n plugin: plugins,\n stats: pluginStats,\n })\n .from(plugins)\n .leftJoin(pluginStats, eq(plugins.id, pluginStats.pluginId))\n .where(and(eq(plugins.namespace, namespace), eq(plugins.name, pluginName)))\n .get();\n\n if (!result || !result.plugin) {\n return c.json({\n error: `Plugin ${owner}/${marketplace}/${pluginName} not found`,\n }, 404);\n }\n\n return c.json({\n downloads: {\n total: result.stats?.downloadsTotal || 0,\n week: result.stats?.downloadsWeek || 0,\n month: result.stats?.downloadsMonth || 0,\n },\n lastDownloaded: result.stats?.lastDownloadedAt || null,\n });\n}",[],[375,391],"919337ae-d08c-11f0-9ab4-42dde27851f2",["D",1764796260359],[236,237,238,239],[375],["D",1764796260359],{"_11":12,"_160":83},{"_11":12,"_156":-5,"_82":83,"_31":81,"_157":158,"_159":30},{"_39":40,"_13":16,"_33":36,"_145":111,"_146":72,"_147":148,"_149":115,"_150":151,"_152":153,"_154":14,"_155":12},"ctx",{"_52":-5,"_181":438,"_439":440,"_441":442,"_443":30,"_444":30,"_445":30,"_446":24,"_447":-5,"_448":-7,"_449":-7,"_450":26,"_451":30,"_452":30,"_453":-5,"_454":30,"_455":30,"_456":30,"_457":-5},"ENV",{"_409":410,"_411":412,"_413":16,"_414":415,"_416":417,"_418":419,"_420":421,"_422":423,"_424":425,"_426":427,"_428":429,"_430":431,"_432":433,"_434":435,"_436":437},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e8c4b7030cb7600e4eb0736b15f422c8b8bd130f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

History · cron