[{"_1":2,"_180":-5,"_181":-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","939580425be10a31a46c456dba7cc90bab2194e6","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,"_156":157,"_177":178,"_179":-5},"handle","paulkinlan","name","email-agent","path","main.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":-5,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":134,"_137":138,"_142":143,"_155":20},"id","2229998a-17f4-11f1-9791-42dde27851f2","createdAt",["D",1772647273772],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","25f41957-737e-448b-bae4-dec9937eed5b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","f5d3fee2-e1c2-4f2b-b60d-716ec388aac8","tursoName","2229998a17f411f1979142dde27851f2","tursoHostname","2229998a17f411f1979142dde27851f2-val-town.aws-us-east-2.turso.io","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_135":136},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yWG9oT0R2UTMxam83NXp1d0RRaGJYVTY0aFYifQ","org",{"_95":96,"_139":136,"_12":113,"_140":141},"avatar","tier","pro","branch",{"_144":145,"_97":45,"_103":146,"_147":104,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":98,"_154":96},"version",55,"222a1edc-17f4-11f1-9791-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":158,"_97":100,"_159":160,"_161":-5,"_162":146,"_163":164,"_165":166,"_105":167,"_144":168,"_169":170,"_171":172,"_173":20,"_174":175,"_99":176},"6ad14db6-1819-11f1-b5ab-42dde27851f2","fileId","222d82f2-17f4-11f1-9791-42dde27851f2","parentId","branchId","branchVersion",30,"latest",true,["D",1772663286967],3,"fileType","http","content","/**\n * Email Agent — HTTP endpoint for status, admin, and debugging.\n */\n\nimport { initDatabase } from \"./db/schema.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport default async function (req: Request): Promise {\n await initDatabase();\n\n const url = new URL(req.url);\n\n // GET /stats or GET / — show system stats\n if (url.pathname === \"/stats\" || url.pathname === \"/\") {\n const [totalEntries, users] = await Promise.all([\n sqlite.execute(\"SELECT COUNT(*) as count FROM entries\"),\n sqlite.execute(\"SELECT COUNT(*) as count FROM users\"),\n ]);\n\n // Entry counts by type\n const typeCounts = await sqlite.execute(\n \"SELECT type, COUNT(*) as count FROM entries GROUP BY type ORDER BY count DESC\",\n );\n\n // Pending tasks\n const pendingTasks = await sqlite.execute(\n \"SELECT COUNT(*) as count FROM entries WHERE type = 'task' AND status = 'pending'\",\n );\n\n // Entry links\n const linkCount = await sqlite.execute(\n \"SELECT COUNT(*) as count FROM entry_links\",\n );\n\n // Type counts as an object\n const types: Record = {};\n for (const row of typeCounts.rows) {\n const r = row as Record;\n types[r.type as string] = r.count as number;\n }\n\n return new Response(\n JSON.stringify(\n {\n name: \"Email Agent\",\n status: \"running\",\n stats: {\n users: (users.rows[0] as Record).count,\n total_entries: (totalEntries.rows[0] as Record)\n .count,\n entries_by_type: types,\n pending_tasks: (pendingTasks.rows[0] as Record)\n .count,\n entry_links: (linkCount.rows[0] as Record).count,\n },\n email: \"memory-do@valtown.email\",\n },\n null,\n 2,\n ),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // GET /user/:email — show user details\n if (url.pathname.startsWith(\"/user/\")) {\n const email = decodeURIComponent(url.pathname.replace(\"/user/\", \"\"));\n const user = await sqlite.execute({\n sql: \"SELECT * FROM users WHERE email = ?\",\n args: [email],\n });\n\n if (user.rows.length === 0) {\n return new Response(JSON.stringify({ error: \"User not found\" }), {\n status: 404,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n const userId = (user.rows[0] as Record).id as number;\n\n // Get all entries grouped by type\n const entries = await sqlite.execute({\n sql: \"SELECT * FROM entries WHERE user_id = ? ORDER BY created_at DESC\",\n args: [userId],\n });\n\n // Group entries by type\n const grouped: Record = {};\n for (const row of entries.rows) {\n const r = row as Record;\n const type = r.type as string;\n if (!grouped[type]) grouped[type] = [];\n grouped[type].push(r);\n }\n\n // Get entry links for this user's entries\n const links = await sqlite.execute({\n sql: `SELECT el.* FROM entry_links el\n JOIN entries e ON el.from_entry_id = e.id\n WHERE e.user_id = ?\n LIMIT 100`,\n args: [userId],\n });\n\n return new Response(\n JSON.stringify(\n {\n user: user.rows[0],\n entries_by_type: grouped,\n entry_links: links.rows,\n },\n null,\n 2,\n ),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // GET /migrate — run migration from old tables (one-time)\n if (url.pathname === \"/migrate\") {\n const { migrateToUnifiedSchema } = await import(\"./db/schema.ts\");\n await migrateToUnifiedSchema();\n return new Response(\n JSON.stringify({ status: \"migration complete\" }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n return new Response(\n JSON.stringify(\n {\n endpoints: {\n \"/\": \"System stats\",\n \"/stats\": \"System stats\",\n \"/user/:email\": \"User details (URL-encode the email)\",\n \"/migrate\": \"Run data migration from old tables (one-time)\",\n },\n },\n null,\n 2,\n ),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n}\n","deleted","label","memory-do",[100],"permalink","https://www.val.town/x/paulkinlan/email-agent/code/main.ts","extension","actionData","errors"]