processor

Processor Service

The processor service consumes test events from NATS JetStream and persists them to MongoDB. It's responsible for durable storage of test runs.

Architecture

The processor service handles:

1. Consuming test events from NATS JetStream
2. Writing structured data to MongoDB with idempotent upserts
3. (Future) Uploading artifacts to object store
4. (Future) Emitting summaries for fast UI queries

Current State

Currently, the processor service runs as a NATS consumer with MongoDB persistence. It requires both NATS and MongoDB.

Running

With MongoDB + NATS (required)

Start infrastructure:

make mongo-up nats-up

Then run the processor:

make build-processor
MONGODB_URI='mongodb://root:password@localhost:27017/observer?authSource=admin' \
NATS_URL='nats://localhost:4222' \
./bin/processor

Environment Variables

Database

The processor uses MongoDB and does not run SQL migrations.

Future Enhancements

• Object storage integration (MinIO/S3)
• Summary generation and caching
• Consumer group scaling
• Metrics and tracing