';\n continue;\n }\n const m = perDay.get(dayKey(t)) ?? 0;\n const lvl = m === 0 ? 0 : m < 30 ? 1 : m < 60 ? 2 : m < 120 ? 3 : 4;\n cells += '

';\n }\n cols += '

' + cells + \"

\";\n }\n\n return `\n\n\n\n\nNishant's focus stats\n\n\n\n

Nishant's deep work

${\n fmt(todayMin)\n }

locked in today

${\n fmt(weekMin)\n }

last 7 days

${\n fmt(streak)\n }

longest session today

${cols}

Each square is one day over the last 17 weeks. Greener means more locked-in time.
Back to live status

\n\n\n`;\n}\n\n// Mobile logging page: Nishant logs offline time from his phone.\nfunction logPage(): string {\n return `\n\n\n\n\nLog away time\n\n\n\n

What were you doing?

\n \n

Minutes

Secret key (asked once, stays on this phone)

\n \n \n \n

Logged. It's in your Notion. You can close this.

\n\n\n`;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // The Mac agent POSTs here once a minute while Nishant is at the desk\n if (req.method === \"POST\" && url.pathname === \"/heartbeat\") {\n const secret = Deno.env.get(\"FOCUS_SECRET\") ?? \"\";\n if (!secret || req.headers.get(\"x-secret\") !== secret) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n const now = Date.now();\n await blob.setJSON(KEY, { t: now });\n await ensureTable();\n await sqlite.execute({\n sql: \"INSERT OR IGNORE INTO focus_minutes (ts) VALUES (?)\",\n args: [now],\n });\n return Response.json({ ok: true });\n }\n\n // The Mac agent POSTs here when Nishant returns after being away\n if (req.method === \"POST\" && url.pathname === \"/away\") {\n const secret = Deno.env.get(\"FOCUS_SECRET\") ?? \"\";\n if (!secret || req.headers.get(\"x-secret\") !== secret) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n const b = await req.json().catch(() => null) as any;\n if (\n !b || typeof b.start !== \"number\" || typeof b.end !== \"number\" ||\n b.end <= b.start\n ) {\n return new Response(\"bad request\", { status: 400 });\n }\n await ensureAwayTable();\n await sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO away_log (start_ts, end_ts, minutes, note, category, synced) VALUES (?, ?, ?, ?, ?, 0)\",\n args: [\n b.start,\n b.end,\n Math.round((b.end - b.start) / 60000),\n String(b.note ?? \"\").slice(0, 500),\n [\"Productive\", \"Wasted\"].includes(b.category)\n ? b.category\n : \"Unclassified\",\n ],\n });\n let notionSynced = true;\n try {\n await syncAwayToNotion();\n } catch (_) {\n notionSynced = false;\n }\n return Response.json({ ok: true, notionSynced });\n }\n\n if (url.pathname === \"/stats\") {\n return new Response(await statsPage(), {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n }\n\n if (url.pathname === \"/log\") {\n return new Response(logPage(), {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n }\n\n if (url.pathname === \"/log-meta\") {\n await ensureAwayTable();\n const lastAwayRes = await sqlite.execute(\n \"SELECT MAX(end_ts) AS m FROM away_log\",\n );\n const lrow = lastAwayRes.rows[0] as any;\n const lastAwayEnd =\n Number((Array.isArray(lrow) ? lrow[0] : lrow?.m) ?? 0) || 0;\n const meta2 = await blob.getJSON(KEY).catch(() => null) as\n | { t: number }\n | null;\n return Response.json({ lastSeen: meta2?.t ?? 0, lastAwayEnd }, {\n headers: { \"cache-control\": \"no-store\" },\n });\n }\n\n const data = await blob.getJSON(KEY).catch(() => null) as\n | { t: number }\n | null;\n const last = data?.t ?? 0;\n const working = last > 0 && Date.now() - last < FRESH_MINUTES * 60_000;\n\n if (url.pathname === \"/status.json\") {\n return Response.json({ working, lastSeen: last }, {\n headers: { \"cache-control\": \"no-store\" },\n });\n }\n\n const lastStr = last\n ? new Date(last).toLocaleString(\"en-IN\", {\n timeZone: \"Asia/Kolkata\",\n hour: \"numeric\",\n minute: \"2-digit\",\n hour12: true,\n day: \"numeric\",\n month: \"short\",\n })\n : \"\";\n const mins = last ? Math.round((Date.now() - last) / 60000) : null;\n const forecast = working ? breakForecast(await recentTs(14)) : \"\";\n\n const emoji = working ? \"🔴\" : \"🟢\";\n const heading = working ? \"Locked in. Working.\" : \"Free right now\";\n const sub = working\n ? \"Nishant is at his desk and focused. He won't pick up calls. Send a message instead and he'll reply on his next break.\"\n : \"He's not at his desk. Feel free to call his phone.\";\n const detail = working\n ? `At the desk, last checked ${lastStr} IST`\n : (last\n ? `Last seen at the desk ${lastStr} IST (${mins} min ago)`\n : \"No activity recorded yet\");\n const bg = working ? \"#1c0a0b\" : \"#08150e\";\n const accent = working ? \"#ff5d5d\" : \"#3ddc84\";\n\n const html = `\n\n\n\n\n\nIs Nishant free?\n\n\n\n

${emoji}

${heading}

${sub}

${detail}

\n ${working && forecast ? '

' + forecast + \"

\" : \"\"}\n

Updates automatically every 30 seconds · focus stats

\n\n\n`;\n\n return new Response(html, {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n}",[138],"cfcb2400-d7a9-48ad-adc2-945941b34d3c","daily_summary.ts","d9a5dca6-a212-11f1-b70e-1607ee4eb77e",14,["D",1787834857329],4,"interval","// Daily 10 PM IST productivity recap: focus, away time, and mentor feedback.\n// Runs on a cron trigger at 16:30 UTC (= 22:00 IST).\n\nimport { email } from \"https://esm.town/v/std/email\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst IST_MS = 19800000; // +05:30\n\nfunction dayKey(ts: number): string {\n return new Date(ts + IST_MS).toISOString().slice(0, 10);\n}\nfunction istTime(ts: number): string {\n return new Date(ts).toLocaleString(\"en-IN\", {\n timeZone: \"Asia/Kolkata\",\n hour: \"numeric\",\n minute: \"2-digit\",\n hour12: true,\n });\n}\nfunction fmt(mins: number): string {\n const h = Math.floor(mins / 60);\n const m = mins % 60;\n return h > 0 ? h + \"h \" + m + \"m\" : m + \"m\";\n}\n\nexport default async function (): Promise {\n await sqlite.execute(\n \"CREATE TABLE IF NOT EXISTS focus_minutes (ts INTEGER PRIMARY KEY)\",\n );\n await sqlite.execute(\n \"CREATE TABLE IF NOT EXISTS away_log (start_ts INTEGER, end_ts INTEGER PRIMARY KEY, minutes INTEGER, note TEXT, category TEXT, synced INTEGER DEFAULT 0)\",\n );\n const since = Date.now() - 2 * 86400000;\n const res = await sqlite.execute({\n sql: \"SELECT ts FROM focus_minutes WHERE ts > ? ORDER BY ts\",\n args: [since],\n });\n const all = res.rows.map((r: any) => Number(Array.isArray(r) ? r[0] : r.ts));\n const todayK = dayKey(Date.now());\n const yestK = dayKey(Date.now() - 86400000);\n const ts = all.filter((t) => dayKey(t) === todayK);\n const yts = all.filter((t) => dayKey(t) === yestK);\n\n let best = 0, run = 0;\n for (let i = 0; i < ts.length; i++) {\n if (i > 0 && ts[i] - ts[i - 1] <= 150000) run += 1;\n else run = 1;\n if (run > best) best = run;\n }\n\n const ares = await sqlite.execute({\n sql:\n \"SELECT start_ts, end_ts, minutes, note, category FROM away_log WHERE end_ts > ? ORDER BY end_ts\",\n args: [since],\n });\n const aways = ares.rows\n .map((r: any) =>\n Array.isArray(r)\n ? {\n s: Number(r[0]),\n e: Number(r[1]),\n m: Number(r[2]),\n note: String(r[3] ?? \"\"),\n cat: String(r[4] ?? \"Unclassified\"),\n }\n : {\n s: Number(r.start_ts),\n e: Number(r.end_ts),\n m: Number(r.minutes),\n note: String(r.note ?? \"\"),\n cat: String(r.category ?? \"Unclassified\"),\n }\n )\n .filter((a) => dayKey(a.e) === todayK);\n\n const awayTotal = aways.reduce((x, a) => x + a.m, 0);\n const prod = aways.filter((a) => a.cat === \"Productive\").reduce(\n (x, a) => x + a.m,\n 0,\n );\n const wasted = aways.filter((a) => a.cat === \"Wasted\").reduce(\n (x, a) => x + a.m,\n 0,\n );\n const uncl = awayTotal - prod - wasted;\n const f = ts.length;\n\n const lines: string[] = [];\n lines.push(\"FOCUS\");\n lines.push(\n \"Locked in: \" + fmt(f) +\n (yts.length ? \" (yesterday: \" + fmt(yts.length) + \")\" : \"\"),\n );\n lines.push(\"Longest session: \" + fmt(best));\n if (f > 0) {\n lines.push(\"First heartbeat: \" + istTime(ts[0]));\n lines.push(\"Last heartbeat: \" + istTime(ts[ts.length - 1]));\n }\n lines.push(\"\");\n lines.push(\"AWAY FROM DESK\");\n if (aways.length === 0) {\n lines.push(\"No logged absences today.\");\n } else {\n lines.push(\n \"Total away: \" + fmt(awayTotal) + \" across \" + aways.length + \" absences\",\n );\n lines.push(\n \"Productive: \" + fmt(prod) + \" | Wasted: \" + fmt(wasted) +\n \" | Unclassified: \" + fmt(uncl),\n );\n for (const a of aways.slice(-8)) {\n lines.push(\n \"- \" + istTime(a.s) + \", \" + a.m + \" min, \" + a.cat +\n (a.note ? \": \" + a.note : \"\"),\n );\n }\n }\n lines.push(\"\");\n lines.push(\"MENTOR'S NOTE\");\n if (f >= 300) {\n lines.push(\n \"Outstanding. \" + fmt(f) +\n \" of deep work is elite output. Protect whatever made today work.\",\n );\n } else if (f >= 180) {\n lines.push(\n \"Solid day. \" + fmt(f) +\n \" of real focus. One more 50-minute block tomorrow beats a perfect plan.\",\n );\n } else if (f >= 60) {\n lines.push(\n \"A start, but thin: \" + fmt(f) +\n \" of focus. Pick ONE task tomorrow and give it your first 50-minute block before anything else.\",\n );\n } else {lines.push(\n \"Barely any locked-in time today. Don't moralize it. Schedule tomorrow's first block tonight and just show up.\",\n );}\n if (yts.length > 0 && f > 0) {\n const d = Math.round(((f - yts.length) / yts.length) * 100);\n if (d >= 15) {\n lines.push(\n \"Momentum: up \" + d + \"% vs yesterday. Keep the streak alive.\",\n );\n } else if (d <= -15) {\n lines.push(\n \"Down \" + Math.abs(d) +\n \"% vs yesterday. One bad day is data, two is a pattern. Guard tomorrow.\",\n );\n }\n }\n if (wasted >= 45) {\n lines.push(\n \"You tagged \" + fmt(wasted) +\n \" as wasted. That's a full deep-work block. Find the single trigger behind the biggest one and remove it tomorrow.\",\n );\n }\n const shortBreaks = aways.filter((a) => a.m >= 5 && a.m <= 15).length;\n if (shortBreaks >= 4) {\n lines.push(\n shortBreaks +\n \" short absences today. Batch them: one proper break per hour beats constant context switching.\",\n );\n }\n if (best < 50 && f >= 60) {\n lines.push(\n \"Longest unbroken session: \" + fmt(best) +\n \". Aim for one full 50-minute block tomorrow, phone in another room.\",\n );\n }\n lines.push(\"\");\n lines.push(\n \"Heatmap: https://nishantsharma--5a9bda2ca20e11f180031607ee4eb77e.web.val.run/stats\",\n );\n\n await email({\n subject: \"Focus recap: \" + fmt(f) + \" locked in, \" + fmt(wasted) +\n \" wasted\",\n text: lines.join(\"\\n\"),\n });\n return \"sent\";\n}",[146],"pulls","branches","forks","envVars",{"_161":150,"_163":63},"connections",{"_161":63,"_162":63},"count","unfilledCount","emptyCount",{"_43":145,"_32":146,"_30":147,"_131":-5,"_41":42,"_40":148,"_132":59,"_38":174,"_13":150,"_34":151,"_36":152,"_24":25,"_135":-5,"_168":175,"_27":176},{"_43":137,"_32":138,"_30":57,"_131":-5,"_41":42,"_40":139,"_132":25,"_38":171,"_13":141,"_34":142,"_36":143,"_24":25,"_135":-5,"_168":172,"_27":173},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":167,"_13":134,"_34":35,"_36":37,"_24":25,"_135":-5,"_168":169,"_27":170},["D",1787840133134],"children",[],[28],["D",1787840093343],[],[138],["D",1787834857329],[],[146],["D",1787831795831],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_124":214,"_215":216,"_217":218,"_219":25,"_220":25,"_221":25,"_222":59,"_223":-5,"_224":-7,"_225":-7,"_226":63,"_227":25,"_228":25,"_229":-5,"_230":25,"_231":25,"_232":25,"_233":-5},"ENV",{"_185":186,"_187":188,"_189":87,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v18