chore: complete schema.sql bootstrap + remove dead code

schema.sql: add minute_day + read_cache tables and analytics_cursor
wake columns (sleep_phase/phase_since/last_close_date) so a fresh DB
bootstraps fully from schema.sql alone; index minute_day(ymd) for the
seal/prune scans; mark legacy minute table deprecated.
Remove dead code: index.ts cron-sweep helpers (sendChunked/enqueueJobs/
enqueueJobDays/lastNDates) and ingest_signals encodeRr/decodeRr.

Author: abdulsaheel

src/db/schema.sql

@@ -30,10 +30,37 @@ CREATE TABLE IF NOT EXISTS refresh_tokens(
 );
 CREATE INDEX IF NOT EXISTS idx_refresh_user ON refresh_tokens(user_id);
 
--- ── TIMESERIES ROLLUP (≤1440 rows/day/user; pruned to R2 after 90 days) ───────
--- hr_sum / act_sum / act_n are running aggregates kept so the ingest upsert can
--- merge new samples into the stored minute EXACTLY (deterministic idempotency).
--- hr_avg / activity are the derived display values (kept in sync on every write).
+-- ── TIMESERIES (day-packed) ───────────────────────────────────────────────────
+-- [feat/wake-trigger] minute_day is the HOT minute store: ONE row per (user, ymd),
+-- value = gzipped JSON MinuteRec[] (one entry per touched minute; RR rides the blob
+-- as number[]). Ingest read-merge-writes ~1 row/day instead of ~1,440. Days older
+-- than the hot window are sealed to gzipped R2 objects and the D1 row dropped; the
+-- 10-day prune drops ~1 row/day. See minute_store.ts. (migrate_v14)
+CREATE TABLE IF NOT EXISTS minute_day(
+  user_id TEXT NOT NULL,
+  ymd TEXT NOT NULL,              -- 'YYYY-MM-DD' (UTC day of the minute)
+  blob BLOB NOT NULL,             -- gzipped JSON MinuteRec[] (bound param; << 2MB cap)
+  updated_at INTEGER NOT NULL,
+  PRIMARY KEY(user_id, ymd)
+) WITHOUT ROWID;
+-- seal/prune scan by day across all users (WHERE ymd < cutoff) — index the bare ymd.
+CREATE INDEX IF NOT EXISTS idx_minute_day_ymd ON minute_day(ymd);
+
+-- TTL read-cache for Tier 1/2 on-read metrics (no watermark; time-based only).
+-- key e.g. 'today:strain:2026-06-19'; today→60s, past days immutable-until-prune.
+-- See cache.ts. (migrate_v12)
+CREATE TABLE IF NOT EXISTS read_cache(
+  user_id TEXT NOT NULL,
+  key TEXT NOT NULL,
+  payload TEXT NOT NULL,          -- JSON
+  computed_at INTEGER NOT NULL,
+  PRIMARY KEY(user_id, key)
+) WITHOUT ROWID;
+
+-- ── LEGACY ROLLUP (deprecated; empty on fresh DBs) ────────────────────────────
+-- The pre-v14 row-per-minute store. Superseded by minute_day above; left in place so
+-- old deployments keep working, but ingest no longer writes here. Safe to drop once
+-- no instance predates v14.
 CREATE TABLE IF NOT EXISTS minute(
   user_id TEXT NOT NULL,
   ts_min INTEGER NOT NULL,        -- unix sec floored to minute
@@ -177,7 +204,13 @@ CREATE TABLE IF NOT EXISTS analytics_cursor(
   last_run INTEGER DEFAULT 0,
   steps_cursor_ts INTEGER,    -- incremental steps: last settled minute counted (unix s)
   steps_cursor_day TEXT,      -- UTC day the steps accumulator is for
-  bio_last_date TEXT          -- event-driven biometrics: last sleep-date already triggered
+  bio_last_date TEXT,         -- event-driven biometrics: last sleep-date already triggered
+  -- [feat/wake-trigger] incremental sleep/wake state machine (migrate_v13). The */N
+  -- cron reads these: skip awake-and-closed users, peek the asleep ones, fire close_day
+  -- once per physiological day.
+  sleep_phase TEXT,           -- 'awake' | 'asleep' | NULL
+  phase_since INTEGER,        -- unix s of last transition
+  last_close_date TEXT        -- YYYY-MM-DD of last day-close
 );
 
 -- Per-user ingest rate-limit token bucket (RESILIENCE §7).

src/index.ts

@@ -420,34 +420,6 @@ app.post('/admin/prune', async (c) => {
   return c.json({ ok: true, events_deleted: ev.meta?.changes ?? 0 })
 })
 
-// Send messages in sendBatch chunks of 100 (the Queues per-call max), so the cron
-// itself never blows its own subrequest budget no matter how many users.
-async function sendChunked(q: Queue<AnalyticsMessage>, msgs: { body: AnalyticsMessage }[]): Promise<void> {
-  for (let i = 0; i < msgs.length; i += 100) {
-    await q.sendBatch(msgs.slice(i, i + 100))
-  }
-}
-
-// One (user, job) message per user (day-less — for 'sweep').
-async function enqueueJobs(q: Queue<AnalyticsMessage>, userIds: string[], job: AnalyticsJob): Promise<void> {
-  await sendChunked(q, userIds.map((user_id) => ({ body: { user_id, job } })))
-}
-
-// One (user, job, day) message per user × day — heavy R2 jobs fanned out so each
-// consumer invocation processes exactly ONE bounded day (works for any user, no
-// matter how much they wore the band).
-async function enqueueJobDays(q: Queue<AnalyticsMessage>, userIds: string[], job: AnalyticsJob, dates: string[]): Promise<void> {
-  const msgs: { body: AnalyticsMessage }[] = []
-  for (const user_id of userIds) for (const day of dates) msgs.push({ body: { user_id, job, day } })
-  await sendChunked(q, msgs)
-}
-
-// The last `n` UTC dates (today first) as YYYY-MM-DD.
-function lastNDates(n: number): string[] {
-  const now = Math.floor(Date.now() / 1000)
-  return Array.from({ length: n }, (_, d) => new Date((Math.floor((now - d * DAY) / DAY) * DAY) * 1000).toISOString().slice(0, 10))
-}
-
 export default {
   fetch: app.fetch,
 

src/ingest_signals.ts

@@ -103,22 +103,3 @@ export function perMinuteSignals(records: string[]): Map<number, MinuteSignal> {
   }
   return out
 }
-
-/** Encode an RR list (ms) to a compact little-endian int16 blob. */
-export function encodeRr(rr: number[]): Uint8Array | null {
-  if (!rr.length) return null
-  const buf = new Uint8Array(rr.length * 2)
-  const view = new DataView(buf.buffer)
-  for (let i = 0; i < rr.length; i++) view.setInt16(i * 2, Math.max(0, Math.min(32767, Math.round(rr[i]))), true)
-  return buf
-}
-
-/** Decode a minute.rr blob back to an RR list (ms). */
-export function decodeRr(blob: ArrayBuffer | Uint8Array | null | undefined): number[] {
-  if (!blob) return []
-  const u8 = blob instanceof Uint8Array ? blob : new Uint8Array(blob)
-  const view = new DataView(u8.buffer, u8.byteOffset, u8.byteLength)
-  const out: number[] = []
-  for (let i = 0; i + 2 <= u8.byteLength; i += 2) out.push(view.getInt16(i, true))
-  return out
-}