[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_181":182,"_183":184},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":58,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",23,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","5a9bda2c-a20e-11f1-8003-1607ee4eb77e","name","fileType","http","content","// focus-status: heartbeat endpoint + live \"am I working\" page + focus stats\n// Family checks this page before calling Nishant.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst FRESH_MINUTES = 3;\nconst KEY = \"focus-last-seen\";\nconst IST_MS = 19800000; // +05:30, India has no DST\n\nfunction shifted(ts: number): Date {\n return new Date(ts + IST_MS);\n}\nfunction dayKey(ts: number): string {\n return shifted(ts).toISOString().slice(0, 10);\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\nasync function ensureTable(): Promise {\n await sqlite.execute(\n \"CREATE TABLE IF NOT EXISTS focus_minutes (ts INTEGER PRIMARY KEY)\",\n );\n}\n\nasync function ensureAwayTable(): Promise {\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}\n\nasync function syncAwayToNotion(): Promise {\n const token = Deno.env.get(\"NOTION_TOKEN\") ?? \"\";\n const db = Deno.env.get(\"NOTION_DB\") ?? \"\";\n if (!token || !db) return;\n const res = await sqlite.execute(\n \"SELECT start_ts, end_ts, minutes, note, category FROM away_log WHERE synced = 0 ORDER BY end_ts LIMIT 20\",\n );\n for (const row of res.rows) {\n const [start, end, minutes, note, category] = Array.isArray(row)\n ? row\n : [row.start_ts, row.end_ts, row.minutes, row.note, row.category];\n const resp = await fetch(\"https://api.notion.com/v1/pages\", {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Notion-Version\": \"2022-06-28\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n parent: { database_id: db },\n properties: {\n \"What I did\": {\n title: [{ text: { content: String(note || \"(no note)\") } }],\n },\n \"When\": {\n date: {\n start: new Date(Number(start)).toISOString(),\n end: new Date(Number(end)).toISOString(),\n },\n },\n \"Minutes\": { number: Number(minutes) },\n \"Category\": { select: { name: String(category || \"Unclassified\") } },\n },\n }),\n });\n if (resp.ok) {\n await sqlite.execute({\n sql: \"UPDATE away_log SET synced = 1 WHERE end_ts = ?\",\n args: [end],\n });\n }\n }\n}\n\nasync function recentTs(days: number): Promise {\n await ensureTable();\n const since = Date.now() - days * 86400000;\n const res = await sqlite.execute({\n sql: \"SELECT ts FROM focus_minutes WHERE ts > ? ORDER BY ts\",\n args: [since],\n });\n return res.rows.map((r: any) => Number(Array.isArray(r) ? r[0] : r.ts));\n}\n\nfunction longestStreak(ts: number[]): number {\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 return best; // one heartbeat is roughly one minute\n}\n\n// Learns from the last 2 weeks of heartbeat gaps when Nishant\n// usually steps away, and turns it into advice for callers.\nfunction breakForecast(ts: number[]): string {\n const buckets = new Array(6).fill(0);\n let samples = 0;\n for (let i = 1; i < ts.length; i++) {\n const gap = ts[i] - ts[i - 1];\n if (gap > 180000 && gap <= 1500000) {\n const m = shifted(ts[i - 1] + 60000).getUTCMinutes();\n buckets[Math.floor(m / 10)] += 1;\n samples += 1;\n }\n }\n if (samples < 5) {\n return \"\";\n }\n const best = buckets.indexOf(Math.max(...buckets));\n const a = String(best * 10).padStart(2, \"0\");\n const b = String(best * 10 + 9).padStart(2, \"0\");\n return \"He usually takes a short break between :\" + a + \" and :\" + b +\n \" past the hour. That is the best time to reach him.\";\n}\n\nasync function statsPage(): Promise {\n const all = await recentTs(120);\n const now = Date.now();\n const todayK = dayKey(now);\n const perDay = new Map();\n for (const t of all) perDay.set(dayKey(t), (perDay.get(dayKey(t)) ?? 0) + 1);\n const todayMin = perDay.get(todayK) ?? 0;\n let weekMin = 0;\n for (let i = 0; i < 7; i++) {\n weekMin += perDay.get(dayKey(now - i * 86400000)) ?? 0;\n }\n const streak = longestStreak(all.filter((t) => dayKey(t) === todayK));\n\n // GitHub-style heatmap: 17 columns of weeks, rows Monday..Sunday\n const wd = (shifted(now).getUTCDay() + 6) % 7; // 0 = Monday\n const start = now - (16 * 7 + wd) * 86400000;\n let cols = \"\";\n for (let w = 0; w < 17; w++) {\n let cells = \"\";\n for (let d = 0; d < 7; d++) {\n const t = start + (w * 7 + d) * 86400000;\n if (t > now) {\n cells += '

';\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 // Sleep mode ends the moment he is back at the laptop:\n // send one welcome-back catch-up nudge to the phone.\n try {\n const sleep = await blob.getJSON(\"sleep-mode\").catch(() => null) as {\n lastActivity: number;\n } | null;\n if (sleep && sleep.lastActivity) {\n await blob.setJSON(\"sleep-mode\", null);\n await blob.setJSON(\"nudge-state\", { count: 0, lastNudge: 0 });\n const topic = Deno.env.get(\"NTFY_TOPIC\") ?? \"\";\n const awayMin = Math.round((now - sleep.lastActivity) / 60000);\n if (topic && awayMin > 60) {\n const hh = Math.floor(awayMin / 60);\n const mm = awayMin % 60;\n await fetch(\"https://ntfy.sh/\" + topic, {\n method: \"POST\",\n headers: {\n \"Title\": \"Welcome back\",\n \"Click\":\n \"https://nishantsharma--5a9bda2ca20e11f180031607ee4eb77e.web.val.run/log\",\n \"Tags\": \"sunrise\",\n },\n body: \"You were away \" +\n (hh > 0 ? hh + \"h \" + mm + \"m\" : mm + \"m\") +\n \", likely including sleep. Tap to log the awake part (use Custom minutes).\",\n });\n }\n }\n } catch (_) {}\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}","// focus-status: heartbeat endpoint + live \"am I working\" page + focus stats\n// Family checks this page before calling Nishant.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst FRESH_MINUTES = 3;\nconst KEY = \"focus-last-seen\";\nconst IST_MS = 19800000; // +05:30, India has no DST\n\nfunction shifted(ts: number): Date {\n return new Date(ts + IST_MS);\n}\nfunction dayKey(ts: number): string {\n return shifted(ts).toISOString().slice(0, 10);\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\nasync function ensureTable(): Promise {\n await sqlite.execute(\n \"CREATE TABLE IF NOT EXISTS focus_minutes (ts INTEGER PRIMARY KEY)\",\n );\n}\n\nasync function ensureAwayTable(): Promise {\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}\n\nasync function syncAwayToNotion(): Promise {\n const token = Deno.env.get(\"NOTION_TOKEN\") ?? \"\";\n const db = Deno.env.get(\"NOTION_DB\") ?? \"\";\n if (!token || !db) return;\n const res = await sqlite.execute(\n \"SELECT start_ts, end_ts, minutes, note, category FROM away_log WHERE synced = 0 ORDER BY end_ts LIMIT 20\",\n );\n for (const row of res.rows) {\n const [start, end, minutes, note, category] = Array.isArray(row)\n ? row\n : [row.start_ts, row.end_ts, row.minutes, row.note, row.category];\n const resp = await fetch(\"https://api.notion.com/v1/pages\", {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Notion-Version\": \"2022-06-28\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n parent: { database_id: db },\n properties: {\n \"What I did\": {\n title: [{ text: { content: String(note || \"(no note)\") } }],\n },\n \"When\": {\n date: {\n start: new Date(Number(start)).toISOString(),\n end: new Date(Number(end)).toISOString(),\n },\n },\n \"Minutes\": { number: Number(minutes) },\n \"Category\": { select: { name: String(category || \"Unclassified\") } },\n },\n }),\n });\n if (resp.ok) {\n await sqlite.execute({\n sql: \"UPDATE away_log SET synced = 1 WHERE end_ts = ?\",\n args: [end],\n });\n }\n }\n}\n\nasync function recentTs(days: number): Promise {\n await ensureTable();\n const since = Date.now() - days * 86400000;\n const res = await sqlite.execute({\n sql: \"SELECT ts FROM focus_minutes WHERE ts > ? ORDER BY ts\",\n args: [since],\n });\n return res.rows.map((r: any) => Number(Array.isArray(r) ? r[0] : r.ts));\n}\n\nfunction longestStreak(ts: number[]): number {\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 return best; // one heartbeat is roughly one minute\n}\n\n// Learns from the last 2 weeks of heartbeat gaps when Nishant\n// usually steps away, and turns it into advice for callers.\nfunction breakForecast(ts: number[]): string {\n const buckets = new Array(6).fill(0);\n let samples = 0;\n for (let i = 1; i < ts.length; i++) {\n const gap = ts[i] - ts[i - 1];\n if (gap > 180000 && gap <= 1500000) {\n const m = shifted(ts[i - 1] + 60000).getUTCMinutes();\n buckets[Math.floor(m / 10)] += 1;\n samples += 1;\n }\n }\n if (samples < 5) {\n return \"\";\n }\n const best = buckets.indexOf(Math.max(...buckets));\n const a = String(best * 10).padStart(2, \"0\");\n const b = String(best * 10 + 9).padStart(2, \"0\");\n return \"He usually takes a short break between :\" + a + \" and :\" + b +\n \" past the hour. That is the best time to reach him.\";\n}\n\nasync function statsPage(): Promise {\n const all = await recentTs(120);\n const now = Date.now();\n const todayK = dayKey(now);\n const perDay = new Map();\n for (const t of all) perDay.set(dayKey(t), (perDay.get(dayKey(t)) ?? 0) + 1);\n const todayMin = perDay.get(todayK) ?? 0;\n let weekMin = 0;\n for (let i = 0; i < 7; i++) {\n weekMin += perDay.get(dayKey(now - i * 86400000)) ?? 0;\n }\n const todayTs = all.filter((t) => dayKey(t) === todayK);\n const streak = longestStreak(todayTs);\n\n // Current session: the unbroken run of heartbeats ending right now\n let current = 0;\n const lastHb = todayTs.length > 0 ? todayTs[todayTs.length - 1] : 0;\n if (lastHb && now - lastHb <= 150000) {\n current = 1;\n let i = todayTs.length - 1;\n while (i > 0 && todayTs[i] - todayTs[i - 1] <= 150000) {\n current += 1;\n i -= 1;\n }\n }\n const isRecord = current > 0 && current >= streak;\n\n // GitHub-style heatmap: 17 columns of weeks, rows Monday..Sunday\n const wd = (shifted(now).getUTCDay() + 6) % 7; // 0 = Monday\n const start = now - (16 * 7 + wd) * 86400000;\n let cols = \"\";\n for (let w = 0; w < 17; w++) {\n let cells = \"\";\n for (let d = 0; d < 7; d++) {\n const t = start + (w * 7 + d) * 86400000;\n if (t > now) {\n cells += '

';\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\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

${\n current > 0 ? fmt(current) + (isRecord ? \" 🔥\" : \"\") : \"—\"\n }

${\n current > 0\n ? (isRecord ? \"current session, longest today\" : \"current session\")\n : \"current session (not at desk)\"\n }

${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.

${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}","createdAt",["D",1788069236253],"branchVersion","branchId","a0205d9a-0314-4d23-8d17-4687cd0907ef","id","886b6a3b-a0e7-463d-994e-a08dcfa6ded5","focus-status",["D",1787831795831],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Live am-I-working status page so family knows when not to call","imageUrl","5eed7cc7-1653-46d6-9f0a-663f03b9b7dc","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04311-5e0a-720b-ac0b-96939806979c","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",36,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","NishantSharma","handle","displayName","Solvepreneur Media","avatar","https://lh3.googleusercontent.com/a/ACg8ocLpkUu-WC_ijFivm0BdZ20WTZJfrJr0PPNbEYb7OSIMG1SebIOx=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":177,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":178,"_80":179,"_82":180,"_84":25},"tree",[164,165,166],"files",[164,165,166],"counts",{"_153":62,"_154":155,"_156":62,"_157":158,"_159":160},"contents",[127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":146,"_32":147,"_30":148,"_133":-5,"_41":42,"_40":149,"_135":58,"_38":150,"_13":137,"_33":138,"_35":151,"_24":25,"_140":-5,"_27":152},{"_43":142,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":25,"_38":143,"_13":144,"_33":34,"_35":37,"_24":25,"_140":-5,"_27":145},{"_43":130,"_32":131,"_30":132,"_133":-5,"_41":42,"_40":134,"_135":58,"_38":136,"_13":137,"_33":138,"_35":139,"_24":25,"_140":-5,"_27":141},"82fcc756-dc42-4c63-8884-f95ac042d427","phone_nudge.ts","bbd5155c-a221-11f1-9bd1-1607ee4eb77e","parentId",21,"latest",["D",1787841078785],4,"interval","// Every 5 min: nudge Nishant's Android phone (via ntfy.sh) when the\n// laptop has been quiet for 5+ minutes. Repeats hourly while he's away.\n// After 4 unanswered nudges it assumes he is asleep and goes silent;\n// the /heartbeat handler sends one welcome-back catch-up when he returns.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst BASE = \"https://nishantsharma--5a9bda2ca20e11f180031607ee4eb77e.web.val.run\";\nconst SILENCE_MIN = 5;\nconst NUDGE_GAP_MIN = 60;\nconst SLEEP_AFTER_NUDGES = 4;\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 const topic = Deno.env.get(\"NTFY_TOPIC\") ?? \"\";\n if (!topic) return \"no topic configured\";\n\n const d = await blob.getJSON(\"focus-last-seen\").catch(() => null) as { t: number } | null;\n const lastSeen = d?.t ?? 0;\n if (!lastSeen) return \"no heartbeat data yet\";\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 res = await sqlite.execute(\"SELECT MAX(end_ts) AS m FROM away_log\");\n const row = res.rows[0] as any;\n const lastAway = Number((Array.isArray(row) ? row[0] : row?.m) ?? 0) || 0;\n\n const now = Date.now();\n const lastActivity = Math.max(lastSeen, lastAway);\n const silentMin = Math.round((now - lastActivity) / 60000);\n\n const st = ((await blob.getJSON(\"nudge-state\").catch(() => null)) as\n { count: number; lastNudge: number } | null) ?? { count: 0, lastNudge: 0 };\n\n if (silentMin < SILENCE_MIN) {\n if (st.count !== 0) await blob.setJSON(\"nudge-state\", { count: 0, lastNudge: 0 });\n return \"active recently (\" + silentMin + \"m), no nudge\";\n }\n\n // He responded to a nudge (a log arrived after it): reset the ignore counter\n if (st.lastNudge && lastAway > st.lastNudge && st.count !== 0) {\n st.count = 0;\n await blob.setJSON(\"nudge-state\", { count: 0, lastNudge: st.lastNudge });\n await blob.setJSON(\"sleep-mode\", null);\n }\n\n const sleeping = (await blob.getJSON(\"sleep-mode\").catch(() => null)) as\n { lastActivity: number } | null;\n if (sleeping && sleeping.lastActivity) {\n return \"sleep mode, staying quiet until he reappears\";\n }\n\n if (st.count >= SLEEP_AFTER_NUDGES) {\n await blob.setJSON(\"sleep-mode\", { lastActivity });\n return SLEEP_AFTER_NUDGES + \" nudges unanswered, entering sleep mode\";\n }\n\n const sinceNudge = (now - (st.lastNudge || 0)) / 60000;\n const needed = st.count === 0 ? 0 : NUDGE_GAP_MIN;\n if (sinceNudge < needed) {\n return \"nudged \" + Math.round(sinceNudge) + \"m ago, waiting\";\n }\n\n const resp = await fetch(\"https://ntfy.sh/\" + topic, {\n method: \"POST\",\n headers: {\n \"Title\": \"What are you up to?\",\n \"Click\": BASE + \"/log\",\n \"Tags\": \"hourglass_flowing_sand\",\n },\n body: \"Laptop quiet for \" + fmt(silentMin) + \". Tap to log it into your time tracker.\",\n });\n if (!resp.ok) return \"ntfy failed: \" + resp.status;\n await blob.setJSON(\"nudge-state\", { count: st.count + 1, lastNudge: now });\n return \"nudge \" + (st.count + 1) + \" sent (\" + fmt(silentMin) + \" silent)\";\n}","label",[131],"2d475679-03f8-4fdd-a606-c258caab8ca3",["D",1788069236253],10,[28],"cfcb2400-d7a9-48ad-adc2-945941b34d3c","daily_summary.ts","d9a5dca6-a212-11f1-b70e-1607ee4eb77e",14,["D",1787834857329],"// 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}",[147],"pulls","branches",1,"forks","envVars",{"_161":137,"_163":62},"connections",{"_161":62,"_162":62},"count","unfilledCount","emptyCount",{"_43":146,"_32":147,"_30":148,"_133":-5,"_41":42,"_40":149,"_135":58,"_38":174,"_13":137,"_33":138,"_35":151,"_24":25,"_140":-5,"_168":175,"_27":176},{"_43":142,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":25,"_38":171,"_13":144,"_33":34,"_35":37,"_24":25,"_140":-5,"_168":172,"_27":173},{"_43":130,"_32":131,"_30":132,"_133":-5,"_41":42,"_40":134,"_135":58,"_38":167,"_13":137,"_33":138,"_35":139,"_24":25,"_140":-5,"_168":169,"_27":170},["D",1787841078785],"children",[],[131],["D",1788069236253],[],[28],["D",1787834857329],[],[147],["D",1787831795831],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_124":214,"_215":216,"_217":218,"_219":25,"_220":25,"_221":25,"_222":58,"_223":-5,"_224":-7,"_225":-7,"_226":62,"_227":25,"_228":25,"_229":-5,"_230":25,"_231":25,"_232":25,"_233":-5},"ENV",{"_185":186,"_187":188,"_189":86,"_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 · v23