Loop Engine™

Running Loops

Adapters

LoopStore interface

All persistence adapters must implement:

1getInstance(aggregateId: AggregateId): Promise<LoopInstance | null>
2saveInstance(instance: LoopInstance): Promise<void>
3getTransitionHistory(aggregateId: AggregateId): Promise<TransitionRecord[]>
4saveTransitionRecord(record: TransitionRecord): Promise<void>
5listOpenInstances(loopId: LoopId, orgId: string): Promise<LoopInstance[]>

@loop-engine/adapter-memory

1import { memoryStore } from '@loop-engine/adapter-memory'
2const store = memoryStore()

Use for tests, local development, browser demos.
Data resets on process restart.

@loop-engine/adapter-postgres

1import { postgresStore, createSchema } from '@loop-engine/adapter-postgres'
2import { Pool } from 'pg'
3 
4const pool = new Pool({ connectionString: process.env.DATABASE_URL })
5await createSchema(pool)
6const store = postgresStore(pool)

Schema creates:

  • loop_instances
    • aggregate_id, loop_id, org_id, current_state, status, started_at, closed_at, correlation_id, metadata
  • loop_transitions
    • id, loop_id, aggregate_id, transition_id, from_state, to_state, actor, evidence, occurred_at, duration_ms

Peer dependency: pg@^8.0.0.

Event bus adapters

@loop-engine/adapter-kafka

  • Provides kafkaEventBus(...)
  • Use for streaming and service-to-service fanout
  • Peer dependency: kafkajs@^2.0.0

@loop-engine/adapter-http

  • Provides httpEventBus(...)
  • Use for webhooks and low-friction integrations
  • subscribe() is intentionally unsupported (emit-only adapter)

Build a custom adapter

Implement LoopStore exactly and pass it to:

1createLoopSystem({ loops, store: myStore })