Main Processor

[prosdev]

Phase: 4 - Processing Pipeline
Estimated Effort: 2 hours
Tasks: Task 9 from specs/core-pipeline/tasks.md

Checklist

Task 9: Implement Main Processor (2 hours)

• Create Processor class (DI: adapter, sequencer, buffer, error_store)
• Implement enqueue() method
  • Call adapter.adapt()
  • Route to partition via sequencer
  • Enqueue to buffer
  • Invalid events → error_store (not exception)
• Write unit tests (mocked dependencies)
• Write integration tests (RawEvent → EventStore)

Acceptance Criteria

• Processor accepts RawEvent
• Valid events reach EventStore
• Invalid events reach ErrorStore
• No exceptions thrown (errors handled)
• Unit tests pass
• Integration tests pass

Files to Create

src/eventkit/processing/processor.py
tests/unit/processing/test_processor.py
tests/integration/test_full_pipeline.py

Dependencies: Issues #2, #3, #4, #5
User Stories: All (orchestrator)