Module event_sourcing 

Systematic Event Sourcing

Provides from_events() reconstruction for all core entities, extending the pattern established in agent_state.rs.

Design

The EventSourced trait defines a common interface for entities that can be reconstructed from their event history. Each entity implementation:

1. Sorts events by timestamp to handle out-of-order delivery
2. Filters for relevant event kinds using relevant_event_kinds()
3. Applies events in order via apply_event() to build up state
4. Returns None from from_events() if the creation event is missing

Entities

• Trajectory: TRAJECTORY_CREATED -> TRAJECTORY_UPDATED -> TRAJECTORY_COMPLETED/FAILED/DELETED
• Scope: SCOPE_CREATED -> SCOPE_UPDATED -> SCOPE_CLOSED
• Artifact: ARTIFACT_CREATED -> ARTIFACT_UPDATED -> ARTIFACT_DELETED
• Note: NOTE_CREATED -> NOTE_UPDATED -> NOTE_DELETED

Traits

EventSourced

Trait for entities that can be reconstructed from their event history.

Functions

extract_i32 🔒

Extract an i32 from a JSON payload field, with a default.

extract_id 🔒

Extract a typed ID from a JSON payload field.

extract_optional_i32 🔒

Extract an i32 from a JSON payload field, returning None if absent.

extract_optional_string 🔒

Extract an optional string from a JSON payload field.

extract_string 🔒

Extract a string from a JSON payload field.

sorted_relevant_events 🔒

Sort events by timestamp (ascending), then filter for relevant kinds.

timestamp_to_datetime 🔒

Convert a microsecond timestamp to a chrono DateTime.