applications/prospector
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
prospector/src/stream
History
Exact
Natalie f6e72bf41f feat(prospector): serial core complete — 6 prototype backend reads (stream/bookings + augments for backfill/voice/dashboard/autopilot) + macsync client reads + api.ts clients 
- New sliced modules stream/, bookings/ (thin, real macsync + audit/drafts data, tests, READMEs).
- Augments to tasks/corrections/reports for the rest (cohorts, alignment, dashboard KPIs).
- Extended MacsyncClient with listInboundMessages/listCalls/listCalendarEvents.
- Typed web api.ts for all 6 (shapes from services + prototype).
- Wired modules. All gates pass (type, 301 tests, web build).
- Prepares Waves A/B (views now have data).
2026-06-29 21:49:15 -04:00
..
index.ts feat(prospector): serial core complete — 6 prototype backend reads (stream/bookings + augments for backfill/voice/dashboard/autopilot) + macsync client reads + api.ts clients 2026-06-29 21:49:15 -04:00
README.md feat(prospector): serial core complete — 6 prototype backend reads (stream/bookings + augments for backfill/voice/dashboard/autopilot) + macsync client reads + api.ts clients 2026-06-29 21:49:15 -04:00
stream.controller.ts feat(prospector): serial core complete — 6 prototype backend reads (stream/bookings + augments for backfill/voice/dashboard/autopilot) + macsync client reads + api.ts clients 2026-06-29 21:49:15 -04:00
stream.module.ts feat(prospector): serial core complete — 6 prototype backend reads (stream/bookings + augments for backfill/voice/dashboard/autopilot) + macsync client reads + api.ts clients 2026-06-29 21:49:15 -04:00
stream.service.ts feat(prospector): serial core complete — 6 prototype backend reads (stream/bookings + augments for backfill/voice/dashboard/autopilot) + macsync client reads + api.ts clients 2026-06-29 21:49:15 -04:00
stream.test.ts feat(prospector): serial core complete — 6 prototype backend reads (stream/bookings + augments for backfill/voice/dashboard/autopilot) + macsync client reads + api.ts clients 2026-06-29 21:49:15 -04:00

README.md

stream

Thin read surface for the unified Stream view (#stream).

  • GET /prospector/stream?limit=50 — recent mixed inbound/outbound messages + calls (macsync history + our audit sends). Returns { items: StreamEvent[] }.
  • Reuses MacsyncClient (new list* methods) + AuditService for outbounds (no new tables).
  • Shapes match prototype buildStream (at, handle, kind, dir, text/status/dur).
  • Used by StreamView (Wave B) and future MCP if extended.

Pure normalizer in service (deterministic time fmt). No I/O in pure parts.

See docs/PROSPECTOR.md, PLAN.md § backend reads, and macsync /my/messages /my/calls surfaces.