Packages

@loop-engine/events

@loop-engine/events defines the event contract and ships an in-memory event bus implementation.

Install

1npm install @loop-engine/events

Event catalog

The exported LOOP_EVENT_TYPES constant enumerates the nine canonical lifecycle events:

loop.started
loop.completed
loop.cancelled
loop.failed
loop.transition.requested
loop.transition.executed
loop.transition.blocked
loop.guard.failed
loop.signal.received

Every event extends:

1interface LoopEventBase {
2  eventId: string
3  type: string
4  loopId: LoopId
5  aggregateId: AggregateId
6  occurredAt: string
7  correlationId?: string
8  causationId?: string
9}

InMemoryEventBus

1class InMemoryEventBus {
2  emit(event: LoopEvent): Promise<void>
3  subscribe(handler: (event: LoopEvent) => Promise<void>): () => void
4}

subscribe() returns an unsubscribe callback, and handler failures do not block other subscribers.

1import { InMemoryEventBus } from "@loop-engine/events"
2 
3const bus = new InMemoryEventBus()
4const unsubscribe = bus.subscribe(async (event) => {
5  if (event.type === "loop.transition.executed") {
6    console.log(event.transitionId, event.actor.type)
7  }
8})
9 
10unsubscribe()

Learning signal extraction

1extractLearningSignal(
2  completed: LoopCompletedEvent,
3  history: LoopTransitionExecutedEvent[],
4  definition: LoopDefinitionLike,
5  predicted?: Record<string, number>
6): LearningSignal

The helper derives actual, predicted, and numeric delta fields from the completed event, the executed-transition history, and the loop definition's declared business metrics. predicted keys not declared in definition.outcome.businessMetrics are dropped with a warning.