learning_ai_common_plat/services
saravanakumardb1 15e24e5710 feat(platform): Phase 1 — Durable Event Bus + Worker Runtime
- New module: event-subscriptions/ (types, repository, routes, 15 tests)
  - Subscription CRUD: create/list/get/update/delete event subscriptions
  - DLQ: list/retry/delete/purge dead-letter queue entries
  - Event replay: POST /events/replay by topic + time range
- New lib: event-dispatcher.ts — subscription-driven dispatch with retry + DLQ
- New lib: event-store-bridge.ts — persistent event log for replay capability
- Worker runtime hardening (jobs/runner.ts):
  - Concurrency limit (MAX_CONCURRENT_JOBS=5)
  - Stuck-job recovery (10min threshold)
  - Graceful shutdown (30s drain)
  - Active job tracking + diagnostics (getActiveJobs/getActiveJobCount)
  - Per-job dedup (skip if already running)
- Wired dispatcher + event-subscriptions into server.ts startup
- Cosmos containers: event_subscriptions, event_dlq, event_log
- 1,293 tests passing (15 new)
2026-03-20 03:12:54 -07:00
..
extraction-service fix(extraction-service): fix QueueJob generic type mismatch in createJob 2026-03-19 18:12:34 -07:00
mcp-server feat(mcp-server): add team provisioning follow-up hooks 2026-03-15 09:59:35 +00:00
monitoring fix(monitoring): update health-check endpoints for consolidated services 2026-02-17 20:53:37 -08:00
platform-service feat(platform): Phase 1 — Durable Event Bus + Worker Runtime 2026-03-20 03:12:54 -07:00