createLoopSystem

1createLoopSystem(options: {
2  loops: LoopDefinition[]
3  store?: LoopStore
4  guards?: GuardRegistry
5  signals?: boolean
6  registry?: LoopRegistry
7}): Promise<{
8  engine: LoopEngine
9  eventBus: InMemoryEventBus
10  signals?: SignalEngine
11}>

1import { createLoopSystem } from '@loop-engine/sdk'
2 
3const { engine, eventBus } = await createLoopSystem({ loops: [definition] })

1import { createLoopSystem } from '@loop-engine/sdk'
2import { postgresStore } from '@loop-engine/adapter-postgres'
3import { Pool } from 'pg'
4 
5const pool = new Pool({ connectionString: process.env.DATABASE_URL })
6const { engine } = await createLoopSystem({
7  loops: [definition],
8  store: postgresStore(pool)
9})

1import { createLoopSystem } from '@loop-engine/sdk'
2 
3const { signals } = await createLoopSystem({
4  loops: [definition],
5  signals: true
6})
7 
8signals?.subscribe((signal) => {
9  console.log(signal.type, signal.subject)
10})