Four demo-safety fixes on top of #43, none touching demo-pod data: - De-dup at source: the suppression path returned before activeConflicts.add(), so the same unresolved dismissed collision wrote a SuppressionDoc every frame (~194 spam rows observed on prod). Now mark the conflict handled first, so it records ONCE per recurrence and re-arms via the onScreenFrame resolution sweep. - Await the write: recordSuppression is the visible learning proof, so await it (like recordCollision/recordIntervention) instead of void ...catch(). - Display de-dup: collapse suppressed beats to one per file (most recent) with a stable per-file id, so any pre-fix duplicate rows never render as spam. - Live-graph gate: suppression beats now satisfy the "has activity" check in materializePodGraph, so a clean pod with preserved suppressions (but no collision/file nodes) no longer falls back to the demo graph and hides the proof. - Ops: /api/memory/stats counts `suppressions`; docs/mongodb.md documents the collection and flags it "preserve in DB cleanup" (visible learning evidence). Verified end-to-end on a throwaway pod (not demo-pod): suppression-only pod materializes; 2 dupe rows render as 1 beat. backend+frontend typecheck + eslint pass. Co-authored-by: Claude Opus 4.8 <noreply@anthropic.com>
5.4 KiB
MongoDB Atlas Integration Spec
Status: demo-backed / active
MongoDB Atlas is PodMan's shared memory. It stores live work observations, collision predictions (with vector embeddings for recall), interventions, outcomes, latest engineer state, the materialized Team memory graph, and async Hermes job runs.
See also:
docs/cont_learning.mdfor outcome-backed team memory, graph materialization, and$graphLookuptraversal.
Current Collections
engineer_states
Latest context per engineer. The local git watcher writes git fields; the vision pipeline may write screen-derived fields. Each writer updates only its own fields so MongoDB upserts merge cleanly.
Key fields:
podIdnamecurrentFileinferredTaskconfidencechangedFilesdiffStatrecentCommitbranchvisionUpdatedAtgitUpdatedAtupdatedAt
Primary use: deterministic dirty/unpushed truth for collision detection and graph discovery.
observations
Structured perception events from consented screen context and agent inference.
Key fields:
podIdengineerIdcurrentFilesymbolactivityconfidenceobservedAt
Primary use: observe/store proof and active editing edges in the Team memory graph.
collisions
Predicted coordination risks, with memory enrichment for recall.
Key fields:
idpodIdfilesymbolengineersseverityoverlapKind— optional;file/undefined for same-file collisions,researchfor code-edit ↔ research overlaps.researchTopic,researchSource,researcher,editor— optional fields present only for research overlaps.memorySignaturegithubStatedetectedAtmemoryText— short text embedded for recallembedding— vector (Voyagevoyage-4-liteor Geminigemini-embedding-001)embeddingProvider—voyage|gemini
Vector index collision_embedding (Atlas Vector Search) powers $vectorSearch
recall in backend/src/memory/vectors.ts. When Atlas vector search is
unavailable, recall falls back to app-side cosine, then exact signature/file
matching.
Primary use: collision cards, vector + signature recall, and graph risk paths.
interventions
Actions PodMan sent or suggested.
Key fields:
idpodIdcollisionIdkindmessagesuggestedActionstatuscreatedAt
Primary use: closing the loop from prediction to a visible card, Hermes message, or urgent voice cue.
outcomes
Human or verifier supervision recorded through POST /api/outcome.
Key fields:
podIdinterventionIdcollisionIdacceptedwasRealCollisionrecordedAt
Primary use: accepted and dismissed outcomes drive exact recall, suppression, and learned graph paths.
suppressions
Durable negative-feedback proof: one record per suppressed repeat — a
previously-dismissed collision signature recurred and PodMan stayed quiet.
Written at repeat time by backend/src/agent/podman.ts (once per recurrence,
re-armed on resolution), materialized as suppressed activity by
backend/src/graph/live.ts.
Key fields:
idpodIdcollisionIdfileengineerspriorInterventionId— the dismissed intervention this repeat matchedpriorDismissedAtsuppressedAt— the repeat time (drives recency in the activity stream)
Index { podId: 1, suppressedAt: -1 }. Counted in /api/memory/stats.
Preserve in any DB cleanup — this is visible learning evidence, not noise.
team_model
Durable per-pod summary memory.
Key fields:
podIdownershiphotspotsgraphupdatedAt
Primary use: stable Team memory, including seeded graph snapshots used after
live materialization and before demo fallback.
graph_nodes and graph_edges
Normalized mirror of the Team memory graph for MongoDB traversal.
Indexes:
graph_nodes:{ podId: 1, id: 1 }uniquegraph_edges:{ podId: 1, source: 1 }
Primary use: GET /api/pods/:podId/graph/reach/:id with $graphLookup.
hermes_jobs and hermes_job_events
Async Hermes task runs delegated from the live conversation agent (see
docs/hermes.md).
hermes_jobs— one doc per job (idunique;{ sessionId, status, updatedAt }index). Fields:id,podId,sessionId,prompt,contextScope,riskLevel,successCriteria,status,finalSummary, timestamps.hermes_job_events— append-only step log ({ jobId, createdAt }index):accepted,heartbeat,step_started,step_output,needs_confirmation,step_completed,completed,aborted,failed. Output is redacted + truncated before storage and mirrored to the room over LiveKit.
Primary use: durable, replayable record of what Hermes did, streamed live to the conversation UI.
Graph Truth Order
GET /api/pods/:podId/graph follows this order:
- Live graph from real collections.
- Seeded graph from
team_model.graphand mirrored graph records. - Demo fallback graph for stage safety.
Seeded and fallback graphs are acceptable for demos only when labeled honestly.
Demo Proof Path
Observe screen/git state -> detect collision -> send intervention -> accept or dismiss outcome -> recall similar event -> show changed graph or changed behavior.
What MongoDB Does Not Store
- Raw screenshot frames.
- Screen recordings.
- Secrets or credentials.
- Full terminal logs.
- Full Gemini response objects beyond extracted fields needed for memory.