[{"_1":2,"_174":-5,"_175":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":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","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","a45694a1faeed7a48e6b6123449288e884a42bca","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",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":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",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_154":155,"_171":172,"_173":-5},"handle","warrenzhu050413","name","me","path","index.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":73,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":116,"_118":-5,"_119":32,"_14":120,"_121":-5,"_122":-5,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_23":132,"_135":136,"_140":141,"_153":20},"id","313abbee-d3bf-11f0-96ab-42dde27851f2","createdAt",["D",1765147856660],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019afa44-876c-77b1-9efd-212f9e7ca091","pinnedFileId","a99e948e-d3bf-11f0-8f1f-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","019afa44-876c-77b1-9efd-242432ac9736","tursoName","tursoHostname","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_133":134},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zNld2d3Vla0hsaEpJOFV6RTN5SW9wWVlzRWoifQ","org",{"_94":95,"_137":134,"_12":112,"_138":139},"avatar","tier","free","branch",{"_142":143,"_96":44,"_102":144,"_145":103,"_146":-5,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":97,"_152":95},"version",28,"313b0018-d3bf-11f0-96ab-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":156,"_96":99,"_157":114,"_158":-5,"_159":144,"_160":143,"_161":116,"_104":162,"_142":163,"_164":165,"_166":167,"_168":20,"_169":-5,"_98":170},"b47e8208-d840-11f0-bed4-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1765643286607],27,"fileType","http","content","/**\n * Me API - Personal API Template\n *\n * Deploy to Val Town: https://val.town\n *\n * Configuration is loaded from the \"me_config\" blob.\n * Run `me deploy push` to sync your config to Val Town.\n *\n * Endpoints:\n * - GET / API info\n * - GET /status Laptop status\n * - GET /now AI summary of recent activity (auth required)\n * - POST /now/chat Continue conversation with AI (auth required)\n * - GET /skills List skills (auth required)\n * - GET /skills/:name Get SKILL.md content (auth required)\n * - GET /skills/:name/*path Get file content or folder tree (auth required)\n */\n\nimport { Hono } from \"npm:hono\";\nimport type { MiddlewareHandler } from \"npm:hono\";\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst app = new Hono();\n\n// Error handler - don't expose stack traces\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: \"Internal server error\" }, 500);\n});\n\n// ============================================================\n// CONFIGURATION (loaded from blob)\n// ============================================================\n\ninterface MeConfig {\n name: string;\n description: string;\n github_repo: string | null;\n github_branch: string;\n heartbeat_timeout_ms: number;\n max_log_entries: number;\n log_retention_days: number;\n}\n\nconst DEFAULT_CONFIG: MeConfig = {\n name: \"Me API\",\n description: \"Personal API\",\n github_repo: null,\n github_branch: \"main\",\n heartbeat_timeout_ms: 90_000,\n max_log_entries: 10000,\n log_retention_days: 7,\n};\n\nlet configCache: { data: MeConfig; timestamp: number } | null = null;\nconst CONFIG_TTL_MS = 60_000; // 1 minute cache\n\nasync function getConfig(): Promise {\n if (configCache && Date.now() - configCache.timestamp < CONFIG_TTL_MS) {\n return configCache.data;\n }\n const stored = await blob.getJSON(\"me_config\") as Partial | undefined;\n const config = { ...DEFAULT_CONFIG, ...stored };\n configCache = { data: config, timestamp: Date.now() };\n return config;\n}\n\n// Blob keys\nconst BLOB_FRIEND_KEYS = \"friend_keys\";\nconst BLOB_NOW_CACHE = \"now_summary_cache\";\nconst BLOB_REQUEST_LOGS = \"request_logs\";\nconst BLOB_ANALYTICS = \"request_analytics\";\n\n// Environment variables (set in Val Town)\nconst GITHUB_PAT = Deno.env.get(\"GITHUB_PAT\") || \"\";\nconst DAEMON_TOKEN = Deno.env.get(\"DAEMON_TOKEN\") || \"\";\nconst ADMIN_TOKEN = Deno.env.get(\"ADMIN_TOKEN\") || \"\";\n\n// ============================================================\n// HELPER FUNCTIONS\n// ============================================================\n\ninterface FriendKeys {\n [name: string]: string;\n}\n\nasync function getFriendKeys(): Promise {\n const keys = await blob.getJSON(BLOB_FRIEND_KEYS) as FriendKeys | undefined;\n return keys || {};\n}\n\nasync function verifyFriendKey(token: string): Promise {\n try {\n const keys = await getFriendKeys();\n return Object.values(keys).includes(token);\n } catch (e) {\n console.error(\"Error verifying friend key:\", e);\n return false;\n }\n}\n\nasync function getFriendNameByToken(token: string): Promise {\n const keys = await getFriendKeys();\n for (const [name, key] of Object.entries(keys)) {\n if (key === token) return name;\n }\n return null;\n}\n\nasync function getLaptopStatus(): Promise<{ online: boolean; status: any }> {\n const config = await getConfig();\n const status = await blob.getJSON(\"laptop_status\") as any;\n if (!status?.timestamp) {\n return { online: false, status: null };\n }\n const lastSeen = new Date(status.timestamp).getTime();\n const isOnline = Date.now() - lastSeen < config.heartbeat_timeout_ms;\n return { online: isOnline, status };\n}\n\n// ============================================================\n// REQUEST LOGGING\n// ============================================================\n\ninterface RequestLog {\n timestamp: string;\n method: string;\n path: string;\n status: number;\n duration_ms: number;\n user_agent: string;\n ip_hash: string;\n authenticated: boolean;\n user?: string;\n}\n\ninterface RequestLogs {\n entries: RequestLog[];\n total_count: number;\n oldest_entry: string | null;\n last_rotation: string | null;\n}\n\ninterface Analytics {\n total_requests: number;\n requests_today: number;\n endpoints: { [path: string]: { count: number; avg_ms: number } };\n hourly: { [hour: string]: number };\n by_hour: { [hour: string]: number };\n daily: { [date: string]: number };\n by_user: { [user: string]: number };\n authenticated_vs_public: { authenticated: number; public: number };\n error_rate: number;\n last_updated: string;\n}\n\nasync function hashIP(ip: string): Promise {\n const encoder = new TextEncoder();\n const data = encoder.encode(ip + \"salt\");\n const hashBuffer = await crypto.subtle.digest(\"SHA-256\", data);\n return Array.from(new Uint8Array(hashBuffer)).slice(0, 8)\n .map(b => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function getRequestLogs(): Promise {\n const logs = await blob.getJSON(BLOB_REQUEST_LOGS) as RequestLogs | undefined;\n return logs || { entries: [], total_count: 0, oldest_entry: null, last_rotation: null };\n}\n\nasync function getAnalytics(): Promise {\n const analytics = await blob.getJSON(BLOB_ANALYTICS) as Analytics | undefined;\n return analytics || {\n total_requests: 0,\n requests_today: 0,\n endpoints: {},\n hourly: {},\n by_hour: {},\n daily: {},\n by_user: {},\n authenticated_vs_public: { authenticated: 0, public: 0 },\n error_rate: 0,\n last_updated: new Date().toISOString(),\n };\n}\n\nasync function logRequest(entry: RequestLog): Promise {\n const config = await getConfig();\n const logs = await getRequestLogs();\n logs.entries.push(entry);\n logs.total_count++;\n\n // Rotate if needed\n if (logs.entries.length > config.max_log_entries) {\n logs.entries = logs.entries.slice(-Math.floor(config.max_log_entries * 0.8));\n logs.last_rotation = new Date().toISOString();\n }\n\n // Clean old entries\n const cutoff = new Date();\n cutoff.setDate(cutoff.getDate() - config.log_retention_days);\n logs.entries = logs.entries.filter(e => e.timestamp >= cutoff.toISOString());\n logs.oldest_entry = logs.entries[0]?.timestamp || null;\n\n await blob.setJSON(BLOB_REQUEST_LOGS, logs);\n\n // Update analytics every 50 requests\n if (logs.total_count % 50 === 0) {\n await recalculateAnalytics(logs);\n }\n}\n\nasync function recalculateAnalytics(logs: RequestLogs): Promise {\n const now = new Date();\n const todayStr = now.toISOString().split(\"T\")[0];\n const endpoints: Analytics[\"endpoints\"] = {};\n const hourly: Analytics[\"hourly\"] = {};\n const by_hour: Analytics[\"by_hour\"] = {};\n const daily: Analytics[\"daily\"] = {};\n const by_user: Analytics[\"by_user\"] = {};\n let authenticated = 0;\n let publicCount = 0;\n let errors = 0;\n\n for (const e of logs.entries) {\n const path = e.path.split(\"?\")[0];\n if (!endpoints[path]) endpoints[path] = { count: 0, avg_ms: 0 };\n endpoints[path].avg_ms = (endpoints[path].avg_ms * endpoints[path].count + e.duration_ms) / (endpoints[path].count + 1);\n endpoints[path].count++;\n\n const hour = e.timestamp.slice(0, 13);\n hourly[hour] = (hourly[hour] || 0) + 1;\n\n const hourOfDay = new Date(e.timestamp).getUTCHours().toString();\n by_hour[hourOfDay] = (by_hour[hourOfDay] || 0) + 1;\n\n const date = e.timestamp.split(\"T\")[0];\n daily[date] = (daily[date] || 0) + 1;\n\n const user = e.user || (e.authenticated ? \"authenticated\" : \"public\");\n by_user[user] = (by_user[user] || 0) + 1;\n\n if (e.authenticated) authenticated++;\n else publicCount++;\n\n if (e.status >= 400) errors++;\n }\n\n const sortedDaily = Object.fromEntries(\n Object.entries(daily).sort(([a], [b]) => a.localeCompare(b)).slice(-30)\n );\n\n await blob.setJSON(BLOB_ANALYTICS, {\n total_requests: logs.total_count,\n requests_today: logs.entries.filter(e => e.timestamp.startsWith(todayStr)).length,\n endpoints,\n hourly: Object.fromEntries(Object.entries(hourly).slice(-48)),\n by_hour,\n daily: sortedDaily,\n by_user,\n authenticated_vs_public: { authenticated, public: publicCount },\n error_rate: logs.entries.length > 0 ? errors / logs.entries.length : 0,\n last_updated: now.toISOString(),\n } as Analytics);\n}\n\n// Logging middleware\napp.use(\"*\", async (c, next) => {\n const start = Date.now();\n const path = new URL(c.req.url).pathname;\n\n if (path === \"/heartbeat\") return next();\n\n await next();\n\n // Fire-and-forget logging\n (async () => {\n try {\n const ip = c.req.header(\"cf-connecting-ip\") || c.req.header(\"x-forwarded-for\") || \"unknown\";\n const authHeader = c.req.header(\"authorization\");\n let user: string | undefined;\n\n if (authHeader?.startsWith(\"Bearer \")) {\n const token = authHeader.slice(7);\n user = await getFriendNameByToken(token) || undefined;\n }\n\n await logRequest({\n timestamp: new Date().toISOString(),\n method: c.req.method,\n path,\n status: c.res?.status || 200,\n duration_ms: Date.now() - start,\n user_agent: c.req.header(\"user-agent\") || \"unknown\",\n ip_hash: await hashIP(ip),\n authenticated: !!authHeader,\n user,\n });\n } catch (e) {\n console.error(\"Log error:\", e);\n }\n })();\n});\n\n// ============================================================\n// SKILLS (GitHub-backed)\n// ============================================================\n\ninterface TreeNode {\n name: string;\n type: \"file\" | \"folder\";\n}\n\ninterface SkillIndexEntry {\n name: string;\n display_name: string;\n description: string;\n path: string;\n tree: TreeNode[];\n files: string[];\n}\n\ninterface SkillIndex {\n version: string;\n updated: string;\n count: number;\n skills: SkillIndexEntry[];\n}\n\nlet skillIndexCache: { data: SkillIndex; timestamp: number } | null = null;\nconst SKILL_INDEX_TTL_MS = 5 * 60 * 1000;\n\nasync function fetchFromGitHub(path: string): Promise {\n const config = await getConfig();\n if (!GITHUB_PAT || !config.github_repo) {\n console.error(\"GitHub not configured\");\n return null;\n }\n\n const url = `https://raw.githubusercontent.com/${config.github_repo}/${config.github_branch}/${path}`;\n try {\n const resp = await fetch(url, {\n headers: {\n \"Authorization\": `token ${GITHUB_PAT}`,\n \"Accept\": \"application/vnd.github.v3.raw\",\n },\n });\n if (!resp.ok) {\n console.error(`GitHub fetch failed: ${resp.status} for ${path}`);\n return null;\n }\n return await resp.text();\n } catch (e) {\n console.error(`GitHub fetch error for ${path}:`, e);\n return null;\n }\n}\n\nasync function getSkillIndex(): Promise {\n if (skillIndexCache && Date.now() - skillIndexCache.timestamp < SKILL_INDEX_TTL_MS) {\n return skillIndexCache.data;\n }\n\n const content = await fetchFromGitHub(\"skills-index.json\");\n if (!content) return null;\n\n try {\n const index = JSON.parse(content) as SkillIndex;\n skillIndexCache = { data: index, timestamp: Date.now() };\n return index;\n } catch (e) {\n console.error(\"Failed to parse skills index:\", e);\n return null;\n }\n}\n\nasync function listSkills(): Promise> {\n const index = await getSkillIndex();\n if (!index) return [];\n return index.skills.map(s => ({\n name: s.name,\n display_name: s.display_name,\n description: s.description\n }));\n}\n\nfunction findSkillEntry(index: SkillIndex, name: string): SkillIndexEntry | undefined {\n return index.skills.find(s => s.name === name);\n}\n\nasync function getSkillMainContent(skillEntry: SkillIndexEntry): Promise {\n const mainFile = skillEntry.files.find(f =>\n f === \"SKILL.md\" || f === \"SNIPPET.md\" || f.endsWith(\".md\")\n );\n if (!mainFile) return null;\n\n const fullPath = skillEntry.path.endsWith('.md')\n ? skillEntry.path\n : `${skillEntry.path}/${mainFile}`;\n\n return await fetchFromGitHub(fullPath);\n}\n\nasync function getSkillFolderTree(\n skillEntry: SkillIndexEntry,\n subPath: string\n): Promise<{ name: string; type: \"folder\"; children: TreeNode[] } | null> {\n const config = await getConfig();\n if (!config.github_repo) return null;\n\n const apiPath = subPath\n ? `${skillEntry.path}/${subPath}`\n : skillEntry.path;\n\n const url = `https://api.github.com/repos/${config.github_repo}/contents/${apiPath}?ref=${config.github_branch}`;\n\n try {\n const resp = await fetch(url, {\n headers: {\n \"Authorization\": `token ${GITHUB_PAT}`,\n \"Accept\": \"application/vnd.github.v3+json\",\n },\n });\n\n if (!resp.ok) {\n console.error(`GitHub API failed: ${resp.status} for ${apiPath}`);\n return null;\n }\n\n const data = await resp.json() as Array<{ name: string; type: string }>;\n\n const children: TreeNode[] = data\n .filter(item => !item.name.startsWith('.'))\n .map(item => ({\n name: item.name,\n type: item.type === \"dir\" ? \"folder\" : \"file\"\n } as TreeNode))\n .sort((a, b) => a.name.localeCompare(b.name));\n\n const folderName = subPath ? subPath.split('/').pop()! : skillEntry.name;\n return {\n name: folderName,\n type: \"folder\",\n children\n };\n } catch (e) {\n console.error(`GitHub API error for ${apiPath}:`, e);\n return null;\n }\n}\n\nasync function getSkillFileContent(\n skillEntry: SkillIndexEntry,\n filePath: string\n): Promise {\n const fullPath = `${skillEntry.path}/${filePath}`;\n return await fetchFromGitHub(fullPath);\n}\n\n// ============================================================\n// ROUTES\n// ============================================================\n\n// Public: API info\napp.get(\"/\", async (c) => {\n const config = await getConfig();\n const { online, status } = await getLaptopStatus();\n return c.json({\n name: config.name,\n description: config.description,\n online,\n last_seen: status?.timestamp || null,\n now_available: online && status?.now_tunnel?.active,\n endpoints: {\n \"/\": \"API info\",\n \"/status\": \"Laptop status\",\n \"/now\": \"AI summary (auth required)\",\n \"/now/chat\": \"Chat with AI (auth required, POST)\",\n \"/skills\": \"List skills (auth required)\",\n \"/skills/:name\": \"Get skill content (auth required)\",\n \"/admin/analytics\": \"Request analytics (auth required)\",\n \"/admin/logs\": \"Request logs (auth required)\"\n },\n auth: \"Bearer token in Authorization header\"\n });\n});\n\n// Public: API Documentation\napp.get(\"/docs\", async (c) => {\n const config = await getConfig();\n return c.json({\n name: config.name,\n version: \"1.0.0\",\n auth: {\n type: \"bearer\",\n header: \"Authorization: Bearer \",\n description: \"Friend keys are issued by the API owner for trusted access\"\n },\n endpoints: [\n {\n path: \"/\",\n method: \"GET\",\n auth: false,\n description: \"API info and status\",\n response: { name: \"string\", online: \"boolean\", endpoints: \"object\" }\n },\n {\n path: \"/status\",\n method: \"GET\",\n auth: false,\n description: \"Current laptop status - online/offline, idle time, active app\",\n response: { online: \"boolean\", activity: \"string\", idle_seconds: \"number\", active_app: \"string\", timestamp: \"string\" }\n },\n {\n path: \"/now\",\n method: \"GET\",\n auth: true,\n description: \"AI-generated summary of current activity (cached)\",\n params: { refresh: \"boolean (query) - force regenerate summary\" },\n response: { summary: \"string\", timestamp: \"string\", cached: \"boolean\" }\n },\n {\n path: \"/now/summary\",\n method: \"GET\",\n auth: false,\n description: \"Public, work-safe AI summary (always cached)\",\n response: { summary: \"string\", timestamp: \"string\", cached: \"boolean\" }\n },\n {\n path: \"/now/chat\",\n method: \"POST\",\n auth: true,\n description: \"Chat with the AI agent about current context\",\n body: { message: \"string\", session_id: \"string (optional)\" },\n response: { response: \"string\", session_id: \"string\" }\n },\n {\n path: \"/skills\",\n method: \"GET\",\n auth: true,\n description: \"List available Claude Code skills\",\n response: { skills: \"array<{name, display_name, description}>\" }\n },\n {\n path: \"/skills/:name\",\n method: \"GET\",\n auth: true,\n description: \"Get skill content (SKILL.md or main file)\",\n response: \"text/markdown or text/plain\"\n },\n {\n path: \"/admin/analytics\",\n method: \"GET\",\n auth: true,\n description: \"Request analytics and usage statistics\",\n response: { total_requests: \"number\", endpoints: \"object\", by_user: \"object\" }\n }\n ],\n errors: {\n 401: \"Unauthorized - missing or invalid friend key\",\n 404: \"Not found\",\n 500: \"Internal server error\",\n 503: \"Service unavailable - laptop offline or tunnel inactive\"\n }\n });\n});\n\n// Public: Laptop status\napp.get(\"/status\", async (c) => {\n const config = await getConfig();\n const { online, status } = await getLaptopStatus();\n if (!online) {\n return c.json({\n online: false,\n last_seen: status?.timestamp || null,\n message: `${config.name}'s laptop is offline`\n });\n }\n return c.json({\n online: true,\n activity: status.idle_seconds < 60 ? \"active\" :\n status.idle_seconds < 600 ? \"recently active\" : \"idle\",\n idle_seconds: status.idle_seconds,\n active_app: status.active_app,\n timestamp: status.timestamp\n });\n});\n\n// Auth middleware - custom implementation to avoid hono/bearer-auth issues\nconst authMiddleware: MiddlewareHandler = async (c, next) => {\n const authHeader = c.req.header(\"authorization\");\n if (!authHeader || !authHeader.startsWith(\"Bearer \")) {\n return c.json({ error: \"Unauthorized\", message: \"Missing or invalid Authorization header\" }, 401);\n }\n\n const token = authHeader.slice(7);\n const isValid = await verifyFriendKey(token);\n\n if (!isValid) {\n return c.json({ error: \"Unauthorized\", message: \"Invalid friend key\" }, 401);\n }\n\n await next();\n};\n\n// ============================================================\n// NOW AGENT ENDPOINTS\n// ============================================================\n\ninterface NowSummaryCache {\n summary: string;\n session_count: number;\n timestamp: string;\n}\n\n// Public: Get AI summary (work-safe, cached)\napp.get(\"/now/summary\", async (c) => {\n const config = await getConfig();\n const { online, status } = await getLaptopStatus();\n\n const tunnelActive = online && status?.now_tunnel?.active;\n const tunnelUrl = status?.now_tunnel?.url;\n\n if (tunnelActive && tunnelUrl) {\n try {\n const resp = await fetch(`${tunnelUrl}/now/summary`, {\n headers: { \"Authorization\": `Bearer ${DAEMON_TOKEN}` },\n });\n\n if (resp.ok) {\n const data = await resp.json() as any;\n\n // Cache the summary\n if (data.summary) {\n await blob.setJSON(BLOB_NOW_CACHE, {\n summary: data.summary,\n session_count: data.session_count || 0,\n timestamp: new Date().toISOString(),\n } as NowSummaryCache);\n }\n\n return c.json(data);\n }\n } catch (e) {\n console.error(\"Tunnel proxy error:\", e);\n }\n }\n\n // Return cached summary\n const cached = await blob.getJSON(BLOB_NOW_CACHE) as NowSummaryCache | undefined;\n if (cached) {\n return c.json({\n ...cached,\n cached: true,\n message: online\n ? \"Now agent not available. Showing last known summary.\"\n : `${config.name}'s laptop is offline. Showing last known summary.`,\n });\n }\n\n return c.json({\n error: `${config.name}'s laptop is offline and no cached summary available`,\n online: false,\n tunnel_active: tunnelActive,\n }, 503);\n});\n\n// Auth: Get detailed AI summary (friends only)\napp.get(\"/now/private\", authMiddleware, async (c) => {\n const config = await getConfig();\n const { online, status } = await getLaptopStatus();\n\n const tunnelActive = online && status?.now_tunnel?.active;\n const tunnelUrl = status?.now_tunnel?.url;\n\n if (tunnelActive && tunnelUrl) {\n // Check DAEMON_TOKEN is configured\n if (!DAEMON_TOKEN) {\n console.error(\"DAEMON_TOKEN not configured in Val Town environment\");\n return c.json({\n error: \"Server misconfigured: DAEMON_TOKEN not set\",\n online,\n tunnel_active: tunnelActive,\n }, 500);\n }\n\n try {\n const resp = await fetch(`${tunnelUrl}/now/private`, {\n headers: { \"Authorization\": `Bearer ${DAEMON_TOKEN}` },\n });\n\n if (resp.ok) {\n return c.json(await resp.json());\n } else {\n // Return daemon error response\n const errorText = await resp.text();\n let errorData: any;\n try {\n errorData = JSON.parse(errorText);\n } catch {\n errorData = { error: errorText || \"Unknown error\" };\n }\n return c.json(errorData, resp.status);\n }\n } catch (e) {\n console.error(\"Tunnel proxy error:\", e);\n return c.json({\n error: \"Failed to connect to daemon\",\n details: String(e),\n }, 502);\n }\n }\n\n return c.json({\n error: online\n ? \"Now agent not available\"\n : `${config.name}'s laptop is offline`,\n online,\n tunnel_active: tunnelActive,\n }, 503);\n});\n\n// Auth: Get AI summary (legacy route, proxies to /now/summary)\napp.get(\"/now\", authMiddleware, async (c) => {\n const config = await getConfig();\n const { online, status } = await getLaptopStatus();\n\n const tunnelActive = online && status?.now_tunnel?.active;\n const tunnelUrl = status?.now_tunnel?.url;\n\n if (tunnelActive && tunnelUrl) {\n try {\n const refresh = c.req.query(\"refresh\") === \"true\";\n const resp = await fetch(`${tunnelUrl}/now/summary${refresh ? \"?refresh=true\" : \"\"}`, {\n headers: { \"Authorization\": `Bearer ${DAEMON_TOKEN}` },\n });\n\n if (resp.ok) {\n const data = await resp.json() as any;\n\n if (data.summary) {\n await blob.setJSON(BLOB_NOW_CACHE, {\n summary: data.summary,\n session_count: data.session_count || 0,\n timestamp: new Date().toISOString(),\n } as NowSummaryCache);\n }\n\n return c.json(data);\n }\n } catch (e) {\n console.error(\"Tunnel proxy error:\", e);\n }\n }\n\n const cached = await blob.getJSON(BLOB_NOW_CACHE) as NowSummaryCache | undefined;\n if (cached) {\n return c.json({\n ...cached,\n cached: true,\n message: online\n ? \"Now agent not available. Showing last known summary.\"\n : `${config.name}'s laptop is offline. Showing last known summary.`,\n });\n }\n\n return c.json({\n error: `${config.name}'s laptop is offline and no cached summary available`,\n online: false,\n tunnel_active: tunnelActive,\n }, 503);\n});\n\n// Auth: Chat with AI\napp.post(\"/now/chat\", authMiddleware, async (c) => {\n const { online, status } = await getLaptopStatus();\n\n const tunnelActive = online && status?.now_tunnel?.active;\n const tunnelUrl = status?.now_tunnel?.url;\n\n if (!tunnelActive || !tunnelUrl) {\n return c.json({\n error: \"Laptop offline or tunnel not active\",\n online,\n tunnel_active: tunnelActive,\n }, 503);\n }\n\n try {\n const body = await c.req.json();\n const resp = await fetch(`${tunnelUrl}/now/chat`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${DAEMON_TOKEN}`,\n },\n body: JSON.stringify(body),\n });\n\n return c.json(await resp.json());\n } catch (e) {\n console.error(\"Chat proxy error:\", e);\n return c.json({ error: \"Failed to connect to now agent\" }, 502);\n }\n});\n\n// ============================================================\n// SKILLS ENDPOINTS\n// ============================================================\n\napp.get(\"/skills\", authMiddleware, async (c) => {\n const config = await getConfig();\n if (!config.github_repo) {\n return c.json({ error: \"Skills not configured\", skills: [] });\n }\n const skills = await listSkills();\n return c.json({ skills });\n});\n\napp.get(\"/skills/:name\", authMiddleware, async (c) => {\n const name = c.req.param(\"name\");\n\n const index = await getSkillIndex();\n if (!index) {\n return c.json({ error: \"Could not load skills index\" }, 500);\n }\n\n const skillEntry = findSkillEntry(index, name);\n if (!skillEntry) {\n return c.json({ error: `Skill '${name}' not found` }, 404);\n }\n\n const content = await getSkillMainContent(skillEntry);\n if (!content) {\n return c.json({ error: `Could not fetch content for '${name}'` }, 500);\n }\n\n return c.text(content);\n});\n\napp.get(\"/skills/:name/:path{.+}\", authMiddleware, async (c) => {\n const name = c.req.param(\"name\");\n const path = c.req.param(\"path\") || \"\";\n\n const index = await getSkillIndex();\n if (!index) {\n return c.json({ error: \"Could not load skills index\" }, 500);\n }\n\n const skillEntry = findSkillEntry(index, name);\n if (!skillEntry) {\n return c.json({ error: `Skill '${name}' not found` }, 404);\n }\n\n const isFile = /\\.[a-zA-Z0-9]+$/.test(path);\n\n if (isFile) {\n const content = await getSkillFileContent(skillEntry, path);\n if (!content) {\n return c.json({ error: `File '${path}' not found in skill '${name}'` }, 404);\n }\n return c.text(content);\n } else {\n const tree = await getSkillFolderTree(skillEntry, path);\n if (!tree) {\n return c.json({ error: `Folder '${path}' not found in skill '${name}'` }, 404);\n }\n return c.json(tree);\n }\n});\n\napp.get(\"/skills/:name/\", authMiddleware, async (c) => {\n const name = c.req.param(\"name\");\n\n const index = await getSkillIndex();\n if (!index) {\n return c.json({ error: \"Could not load skills index\" }, 500);\n }\n\n const skillEntry = findSkillEntry(index, name);\n if (!skillEntry) {\n return c.json({ error: `Skill '${name}' not found` }, 404);\n }\n\n const tree = await getSkillFolderTree(skillEntry, \"\");\n if (!tree) {\n return c.json({ error: `Could not load folder tree for '${name}'` }, 500);\n }\n return c.json(tree);\n});\n\n// ============================================================\n// ADMIN ENDPOINTS\n// ============================================================\n\napp.get(\"/admin/analytics\", authMiddleware, async (c) => {\n const config = await getConfig();\n const analytics = await getAnalytics();\n const logs = await getRequestLogs();\n\n const sortedEndpoints = Object.fromEntries(\n Object.entries(analytics.endpoints)\n .sort(([, a], [, b]) => b.count - a.count)\n );\n\n const sortedUsers = Object.fromEntries(\n Object.entries(analytics.by_user || {})\n .sort(([, a], [, b]) => b - a)\n );\n\n return c.json({\n ...analytics,\n endpoints: sortedEndpoints,\n by_user: sortedUsers,\n storage: {\n entries: logs.entries.length,\n max: config.max_log_entries,\n usage_pct: Math.round((logs.entries.length / config.max_log_entries) * 100),\n oldest: logs.oldest_entry,\n last_rotation: logs.last_rotation,\n },\n });\n});\n\napp.get(\"/admin/logs\", authMiddleware, async (c) => {\n const limit = Math.min(parseInt(c.req.query(\"limit\") || \"50\"), 500);\n const logs = await getRequestLogs();\n return c.json({\n entries: logs.entries.slice(-limit).reverse(),\n total: logs.total_count,\n showing: Math.min(limit, logs.entries.length),\n });\n});\n\napp.post(\"/admin/analytics/recalculate\", authMiddleware, async (c) => {\n const logs = await getRequestLogs();\n await recalculateAnalytics(logs);\n return c.json({ success: true, entries_processed: logs.entries.length });\n});\n\n// ============================================================\n// INTERNAL: Heartbeat & Key Sync (admin token required)\n// ============================================================\n\nasync function verifyAdminToken(request: Request): Promise {\n const authHeader = request.headers.get(\"Authorization\");\n if (!authHeader) return false;\n\n const token = authHeader.startsWith(\"Bearer \")\n ? authHeader.slice(7)\n : authHeader;\n\n if (!ADMIN_TOKEN) return false;\n return token === ADMIN_TOKEN;\n}\n\napp.post(\"/heartbeat\", async (c) => {\n if (!await verifyAdminToken(c.req.raw)) {\n return c.json({ error: \"Unauthorized\" }, 401);\n }\n const status = await c.req.json();\n status.timestamp = new Date().toISOString();\n await blob.setJSON(\"laptop_status\", status);\n return c.json({ received: true });\n});\n\napp.post(\"/sync/keys\", async (c) => {\n if (!await verifyAdminToken(c.req.raw)) {\n return c.json({ error: \"Unauthorized\" }, 401);\n }\n const { name, key: customKey } = await c.req.json();\n const keys = await getFriendKeys();\n const newKey = customKey || crypto.randomUUID();\n keys[name] = newKey;\n await blob.setJSON(BLOB_FRIEND_KEYS, keys);\n return c.json({ name, key: newKey });\n});\n\napp.get(\"/sync/keys\", async (c) => {\n if (!await verifyAdminToken(c.req.raw)) {\n return c.json({ error: \"Unauthorized\" }, 401);\n }\n const keys = await getFriendKeys();\n return c.json({ keys: Object.keys(keys) });\n});\n\napp.delete(\"/sync/keys/:name\", async (c) => {\n if (!await verifyAdminToken(c.req.raw)) {\n return c.json({ error: \"Unauthorized\" }, 401);\n }\n const name = c.req.param(\"name\");\n const keys = await getFriendKeys();\n delete keys[name];\n await blob.setJSON(BLOB_FRIEND_KEYS, keys);\n return c.json({ deleted: name });\n});\n\n// ============================================================\n// EXPORT\n// ============================================================\n\nexport default app.fetch;\n","deleted","label",[99],"permalink","https://www.val.town/x/warrenzhu050413/me/code/index.ts","extension","actionData","errors"]