mako-engine — event-sourced process runtime for German energy market communication (MaKo).

Architecture

Raw EDIFACT bytes (AS4 transport)
        │
        ▼
[edi-energy] parse · validate
        │
        ▼  Command (typed, validated)
EngineContext::spawn / ::resume → Process::execute / ::execute_with / ::execute_with_retry
        │
        ├─ load events → reconstruct state (Workflow::apply + upcast)
        ├─ handle command (Workflow::handle — pure, deterministic)
        └─ append EventEnvelope batch (optimistic concurrency)

EventStore ──► ProjectionRunner ──► Read models
SnapshotStore ──► Process::state_with_snapshot (O(k) replay)
OutboxStore ──► delivery worker ──► AS4 endpoint
DeadlineStore ──► scheduler ──► TimeoutDeadline command
ProcessRegistry ──► inbound message routing ──► Process

Quick start

use mako_engine::{
    builder::EngineBuilder,
    ids::TenantId,
    version::WorkflowId,
    event_store::InMemoryEventStore,
};

let ctx = EngineBuilder::new()
    .with_event_store(InMemoryEventStore::new())
    .build();

// Spawn a new process.
let process = ctx.spawn::<MyWorkflow>(TenantId::new(), WorkflowId::new("…", "FV2024-10-01"));
let envelopes = process.execute(my_command).await?;

// Reconstruct typed state by replaying all events.
let state = process.state().await?;

// Persist routing information and resume on the next message.
ctx.registry().register(tenant, &conv_id.to_string(), process.identity()).await?;
let identity = ctx.registry().lookup(tenant, &conv_id.to_string()).await?.unwrap();
let resumed  = ctx.resume::<MyWorkflow>(identity);

Crate modules