[{"_1":2,"_181":-5,"_182":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","08df2158b567c8dc30dd332965dd8203fb644318","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_155":156,"_178":179,"_180":-5},"handle","kamenxrider","name","readwise-mastra","path","lib/db.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":121,"_122":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":133,"_136":137,"_141":142,"_154":20},"id","cbd319ae-ffd3-11f0-bcd8-42dde27851f2","createdAt",["D",1769994557115],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","d4de366f-8281-484e-8856-3824b6bdfb0b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","9bb2e2b6-8aa1-4b6a-b4ef-ad7adab2b868","tursoName","cbd319aeffd311f0bcd842dde27851f2","tursoHostname","cbd319aeffd311f0bcd842dde27851f2-val-town.aws-us-east-2.turso.io","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_134":135},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ybFJkNm8zSzFzbGE5RzhsTUt3OGJMZFdGZFkifQ","org",{"_95":96,"_138":135,"_12":113,"_139":140},"avatar","tier","pro","branch",{"_143":144,"_97":45,"_103":145,"_146":104,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":98,"_153":96},"version",51,"cbd4b750-ffd3-11f0-bcd8-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":157,"_97":158,"_159":160,"_161":162,"_163":145,"_164":165,"_166":167,"_105":168,"_143":169,"_170":171,"_172":173,"_174":20,"_175":-5,"_99":176},"96a49d12-ffd7-11f0-897f-42dde27851f2","db.ts","fileId","b46ae58e-ffd4-11f0-97f3-42dde27851f2","parentId","99160818-ffd4-11f0-97f3-42dde27851f2","branchId","branchVersion",39,"latest",true,["D",1769996185880],2,"fileType","script","content","/**\n * SQLite helpers - migrations, row mapping, indexes\n * Uses Val Town's std/sqlite for project-scoped database\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite@14-main/main.ts\";\n\n/**\n * Run all migrations (idempotent - safe to call multiple times)\n */\nexport async function runMigrations(): Promise {\n await sqlite.batch([\n // Documents table - mirrors Readwise docs\n {\n sql: `CREATE TABLE IF NOT EXISTS docs (\n id TEXT PRIMARY KEY,\n title TEXT,\n author TEXT,\n site_name TEXT,\n source_url TEXT,\n url TEXT,\n category TEXT,\n location TEXT,\n word_count INTEGER,\n reading_progress REAL,\n created_at TEXT,\n updated_at TEXT,\n published_date TEXT,\n notes TEXT,\n summary TEXT,\n last_moved_at TEXT,\n saved_at TEXT,\n image_url TEXT,\n parent_id TEXT\n )`,\n },\n // Tags table\n {\n sql: `CREATE TABLE IF NOT EXISTS tags (\n key TEXT PRIMARY KEY,\n name TEXT,\n type TEXT,\n created INTEGER\n )`,\n },\n // Document-Tag junction table\n {\n sql: `CREATE TABLE IF NOT EXISTS doc_tags (\n doc_id TEXT,\n tag_key TEXT,\n PRIMARY KEY (doc_id, tag_key),\n FOREIGN KEY (doc_id) REFERENCES docs(id) ON DELETE CASCADE\n )`,\n },\n // Saved views\n {\n sql: `CREATE TABLE IF NOT EXISTS views (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n filter_json TEXT NOT NULL\n )`,\n },\n // Projects (collections + automation)\n {\n sql: `CREATE TABLE IF NOT EXISTS projects (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n tag_key TEXT,\n rule_prompt TEXT,\n created_at TEXT NOT NULL\n )`,\n },\n // Sync state (single row)\n {\n sql: `CREATE TABLE IF NOT EXISTS sync_state (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n updated_after TEXT,\n last_sync_started_at TEXT,\n last_sync_finished_at TEXT,\n last_error TEXT\n )`,\n },\n // AI plans\n {\n sql: `CREATE TABLE IF NOT EXISTS ai_plans (\n id TEXT PRIMARY KEY,\n created_at TEXT NOT NULL,\n goal TEXT,\n scope_json TEXT,\n plan_json TEXT,\n status TEXT NOT NULL DEFAULT 'pending'\n )`,\n },\n // AI jobs\n {\n sql: `CREATE TABLE IF NOT EXISTS ai_jobs (\n id TEXT PRIMARY KEY,\n plan_id TEXT,\n started_at TEXT,\n finished_at TEXT,\n applied_count INTEGER DEFAULT 0,\n error TEXT,\n FOREIGN KEY (plan_id) REFERENCES ai_plans(id)\n )`,\n },\n ]);\n\n // Create indexes (separate batch for indexes)\n await sqlite.batch([\n { sql: `CREATE INDEX IF NOT EXISTS idx_docs_location_updated ON docs(location, updated_at)` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_docs_category ON docs(category)` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_docs_site_name ON docs(site_name)` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_doc_tags_tag_key ON doc_tags(tag_key)` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_docs_saved_at ON docs(saved_at)` },\n ]);\n\n // Initialize sync_state if not exists\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO sync_state (id) VALUES (1)`,\n });\n\n // Run model cache migrations\n await runModelCacheMigrations();\n}\n\n// ============ Row Mapping Helpers ============\n\nexport interface Doc {\n id: string;\n title: string | null;\n author: string | null;\n site_name: string | null;\n source_url: string | null;\n url: string | null;\n category: string | null;\n location: string | null;\n word_count: number | null;\n reading_progress: number | null;\n created_at: string | null;\n updated_at: string | null;\n published_date: string | null;\n notes: string | null;\n summary: string | null;\n last_moved_at: string | null;\n saved_at: string | null;\n image_url: string | null;\n parent_id: string | null;\n}\n\nexport interface Tag {\n key: string;\n name: string | null;\n type: string | null;\n created: number | null;\n}\n\nexport interface SyncState {\n updated_after: string | null;\n last_sync_started_at: string | null;\n last_sync_finished_at: string | null;\n last_error: string | null;\n}\n\nexport interface View {\n id: string;\n name: string;\n filter_json: string;\n}\n\nexport interface Project {\n id: string;\n name: string;\n tag_key: string | null;\n rule_prompt: string | null;\n created_at: string;\n}\n\nexport interface AIPlan {\n id: string;\n created_at: string;\n goal: string | null;\n scope_json: string | null;\n plan_json: string | null;\n status: string;\n}\n\n/**\n * Map a result row array to an object using column names\n */\nexport function mapRow(columns: string[], row: unknown[]): T {\n const obj: Record = {};\n for (let i = 0; i < columns.length; i++) {\n obj[columns[i]] = row[i];\n }\n return obj as T;\n}\n\n/**\n * Map all rows in a result to objects\n */\nexport function mapRows(result: { columns: string[]; rows: unknown[][] }): T[] {\n return result.rows.map((row) => mapRow(result.columns, row));\n}\n\n// ============ Sync State Helpers ============\n\nexport async function getSyncState(): Promise {\n const result = await sqlite.execute(\"SELECT * FROM sync_state WHERE id = 1\");\n if (result.rows.length === 0) {\n return {\n updated_after: null,\n last_sync_started_at: null,\n last_sync_finished_at: null,\n last_error: null,\n };\n }\n return mapRow(result.columns, result.rows[0]);\n}\n\nexport async function updateSyncState(updates: Partial): Promise {\n const fields: string[] = [];\n const args: (string | null)[] = [];\n\n if (updates.updated_after !== undefined) {\n fields.push(\"updated_after = ?\");\n args.push(updates.updated_after);\n }\n if (updates.last_sync_started_at !== undefined) {\n fields.push(\"last_sync_started_at = ?\");\n args.push(updates.last_sync_started_at);\n }\n if (updates.last_sync_finished_at !== undefined) {\n fields.push(\"last_sync_finished_at = ?\");\n args.push(updates.last_sync_finished_at);\n }\n if (updates.last_error !== undefined) {\n fields.push(\"last_error = ?\");\n args.push(updates.last_error);\n }\n\n if (fields.length > 0) {\n await sqlite.execute({\n sql: `UPDATE sync_state SET ${fields.join(\", \")} WHERE id = 1`,\n args,\n });\n }\n}\n\n// ============ Doc CRUD Helpers ============\n\nexport async function upsertDoc(doc: Partial & { id: string }): Promise {\n await sqlite.execute({\n sql: `INSERT INTO docs (\n id, title, author, site_name, source_url, url, category, location,\n word_count, reading_progress, created_at, updated_at, published_date,\n notes, summary, last_moved_at, saved_at, image_url, parent_id\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n title = excluded.title,\n author = excluded.author,\n site_name = excluded.site_name,\n source_url = excluded.source_url,\n url = excluded.url,\n category = excluded.category,\n location = excluded.location,\n word_count = excluded.word_count,\n reading_progress = excluded.reading_progress,\n created_at = excluded.created_at,\n updated_at = excluded.updated_at,\n published_date = excluded.published_date,\n notes = excluded.notes,\n summary = excluded.summary,\n last_moved_at = excluded.last_moved_at,\n saved_at = excluded.saved_at,\n image_url = excluded.image_url,\n parent_id = excluded.parent_id`,\n args: [\n doc.id,\n doc.title ?? null,\n doc.author ?? null,\n doc.site_name ?? null,\n doc.source_url ?? null,\n doc.url ?? null,\n doc.category ?? null,\n doc.location ?? null,\n doc.word_count ?? null,\n doc.reading_progress ?? null,\n doc.created_at ?? null,\n doc.updated_at ?? null,\n doc.published_date ?? null,\n doc.notes ?? null,\n doc.summary ?? null,\n doc.last_moved_at ?? null,\n doc.saved_at ?? null,\n doc.image_url ?? null,\n doc.parent_id ?? null,\n ],\n });\n}\n\nexport async function getDocById(id: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM docs WHERE id = ?\",\n args: [id],\n });\n if (result.rows.length === 0) return null;\n return mapRow(result.columns, result.rows[0]);\n}\n\nexport async function getDocTags(docId: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT tag_key FROM doc_tags WHERE doc_id = ?\",\n args: [docId],\n });\n return result.rows.map((row) => row[0] as string);\n}\n\nexport async function setDocTags(docId: string, tagKeys: string[]): Promise {\n // Delete existing tags\n await sqlite.execute({\n sql: \"DELETE FROM doc_tags WHERE doc_id = ?\",\n args: [docId],\n });\n\n // Insert new tags\n if (tagKeys.length > 0) {\n const placeholders = tagKeys.map(() => \"(?, ?)\").join(\", \");\n const args: string[] = [];\n for (const key of tagKeys) {\n args.push(docId, key);\n }\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO doc_tags (doc_id, tag_key) VALUES ${placeholders}`,\n args,\n });\n }\n}\n\nexport async function upsertTag(tag: Tag): Promise {\n await sqlite.execute({\n sql: `INSERT INTO tags (key, name, type, created) VALUES (?, ?, ?, ?)\n ON CONFLICT(key) DO UPDATE SET name = excluded.name, type = excluded.type`,\n args: [tag.key, tag.name, tag.type, tag.created],\n });\n}\n\n// ============ Query Helpers ============\n\nexport async function getDocsByLocation(\n location: string,\n limit: number = 50,\n offset: number = 0\n): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM docs WHERE location = ? ORDER BY updated_at DESC LIMIT ? OFFSET ?`,\n args: [location, limit, offset],\n });\n return mapRows(result);\n}\n\nexport async function getStats(): Promise<{\n totalDocs: number;\n byLocation: Record;\n byCategory: Record;\n syncState: SyncState;\n}> {\n const [totalResult, locationResult, categoryResult, syncState] = await Promise.all([\n sqlite.execute(\"SELECT COUNT(*) as count FROM docs\"),\n sqlite.execute(\"SELECT location, COUNT(*) as count FROM docs GROUP BY location\"),\n sqlite.execute(\"SELECT category, COUNT(*) as count FROM docs GROUP BY category\"),\n getSyncState(),\n ]);\n\n const byLocation: Record = {};\n for (const row of locationResult.rows) {\n const loc = row[0] as string | null;\n if (loc) byLocation[loc] = row[1] as number;\n }\n\n const byCategory: Record = {};\n for (const row of categoryResult.rows) {\n const cat = row[0] as string | null;\n if (cat) byCategory[cat] = row[1] as number;\n }\n\n return {\n totalDocs: (totalResult.rows[0]?.[0] as number) || 0,\n byLocation,\n byCategory,\n syncState,\n };\n}\n\n\n// ============ Model Cache (Pollinations) ============\n\nexport interface ModelCache {\n name: string;\n type: \"text\" | \"image\";\n aliases: string[] | null;\n description: string | null;\n tools: boolean;\n reasoning: boolean;\n context_window: number | null;\n pricing_json: string | null;\n input_modalities: string[] | null;\n output_modalities: string[] | null;\n last_updated: string;\n}\n\nexport interface ModelConfig {\n key: string;\n value: string;\n updated_at: string;\n}\n\n/**\n * Run model cache migrations (called from runMigrations)\n */\nexport async function runModelCacheMigrations(): Promise {\n await sqlite.batch([\n // Discovered models from Pollinations API\n {\n sql: `CREATE TABLE IF NOT EXISTS model_cache (\n name TEXT PRIMARY KEY,\n type TEXT NOT NULL,\n aliases TEXT,\n description TEXT,\n tools INTEGER DEFAULT 0,\n reasoning INTEGER DEFAULT 0,\n context_window INTEGER,\n pricing_json TEXT,\n input_modalities TEXT,\n output_modalities TEXT,\n last_updated TEXT NOT NULL\n )`,\n },\n // Selected model configuration\n {\n sql: `CREATE TABLE IF NOT EXISTS model_config (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n },\n ]);\n}\n\n/**\n * Upsert a model into the cache\n */\nexport async function upsertModelCache(model: ModelCache): Promise {\n await sqlite.execute({\n sql: `INSERT INTO model_cache (\n name, type, aliases, description, tools, reasoning,\n context_window, pricing_json, input_modalities, output_modalities, last_updated\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(name) DO UPDATE SET\n type = excluded.type,\n aliases = excluded.aliases,\n description = excluded.description,\n tools = excluded.tools,\n reasoning = excluded.reasoning,\n context_window = excluded.context_window,\n pricing_json = excluded.pricing_json,\n input_modalities = excluded.input_modalities,\n output_modalities = excluded.output_modalities,\n last_updated = excluded.last_updated`,\n args: [\n model.name,\n model.type,\n model.aliases ? JSON.stringify(model.aliases) : null,\n model.description,\n model.tools ? 1 : 0,\n model.reasoning ? 1 : 0,\n model.context_window,\n model.pricing_json,\n model.input_modalities ? JSON.stringify(model.input_modalities) : null,\n model.output_modalities ? JSON.stringify(model.output_modalities) : null,\n model.last_updated,\n ],\n });\n}\n\n/**\n * Get all cached models by type\n */\nexport async function getModelCache(type?: \"text\" | \"image\"): Promise {\n const sql = type\n ? \"SELECT * FROM model_cache WHERE type = ? ORDER BY name\"\n : \"SELECT * FROM model_cache ORDER BY type, name\";\n const args = type ? [type] : [];\n\n const result = await sqlite.execute({ sql, args });\n\n return result.rows.map((row) => {\n const obj = mapRow<{\n name: string;\n type: string;\n aliases: string | null;\n description: string | null;\n tools: number;\n reasoning: number;\n context_window: number | null;\n pricing_json: string | null;\n input_modalities: string | null;\n output_modalities: string | null;\n last_updated: string;\n }>(result.columns, row);\n\n return {\n name: obj.name,\n type: obj.type as \"text\" | \"image\",\n aliases: obj.aliases ? JSON.parse(obj.aliases) : null,\n description: obj.description,\n tools: obj.tools === 1,\n reasoning: obj.reasoning === 1,\n context_window: obj.context_window,\n pricing_json: obj.pricing_json,\n input_modalities: obj.input_modalities ? JSON.parse(obj.input_modalities) : null,\n output_modalities: obj.output_modalities ? JSON.parse(obj.output_modalities) : null,\n last_updated: obj.last_updated,\n };\n });\n}\n\n/**\n * Get a single model from cache by name\n */\nexport async function getModelByName(name: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM model_cache WHERE name = ?\",\n args: [name],\n });\n\n if (result.rows.length === 0) return null;\n\n const obj = mapRow<{\n name: string;\n type: string;\n aliases: string | null;\n description: string | null;\n tools: number;\n reasoning: number;\n context_window: number | null;\n pricing_json: string | null;\n input_modalities: string | null;\n output_modalities: string | null;\n last_updated: string;\n }>(result.columns, result.rows[0]);\n\n return {\n name: obj.name,\n type: obj.type as \"text\" | \"image\",\n aliases: obj.aliases ? JSON.parse(obj.aliases) : null,\n description: obj.description,\n tools: obj.tools === 1,\n reasoning: obj.reasoning === 1,\n context_window: obj.context_window,\n pricing_json: obj.pricing_json,\n input_modalities: obj.input_modalities ? JSON.parse(obj.input_modalities) : null,\n output_modalities: obj.output_modalities ? JSON.parse(obj.output_modalities) : null,\n last_updated: obj.last_updated,\n };\n}\n\n/**\n * Clear all cached models (useful before refresh)\n */\nexport async function clearModelCache(type?: \"text\" | \"image\"): Promise {\n if (type) {\n await sqlite.execute({ sql: \"DELETE FROM model_cache WHERE type = ?\", args: [type] });\n } else {\n await sqlite.execute(\"DELETE FROM model_cache\");\n }\n}\n\n/**\n * Get a model config value\n */\nexport async function getModelConfig(key: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT value FROM model_config WHERE key = ?\",\n args: [key],\n });\n if (result.rows.length === 0) return null;\n return result.rows[0][0] as string;\n}\n\n/**\n * Set a model config value\n */\nexport async function setModelConfig(key: string, value: string): Promise {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO model_config (key, value, updated_at) VALUES (?, ?, ?)\n ON CONFLICT(key) DO UPDATE SET value = excluded.value, updated_at = excluded.updated_at`,\n args: [key, value, now],\n });\n}\n\n/**\n * Get all model config as an object\n */\nexport async function getAllModelConfig(): Promise> {\n const result = await sqlite.execute(\"SELECT key, value FROM model_config\");\n const config: Record = {};\n for (const row of result.rows) {\n config[row[0] as string] = row[1] as string;\n }\n return config;\n}\n","deleted","label",[177,158],"lib","permalink","https://www.val.town/x/kamenxrider/readwise-mastra/code/lib/db.ts","extension","actionData","errors"]