@loop-engine/signals

1npm install @loop-engine/signals

1class SignalRegistry {
2  register(spec: SignalSpec): void
3  get(signalId: SignalId): SignalSpec | undefined
4  validatePayload(signalId: SignalId, payload: unknown): { valid: boolean; error?: string }
5  list(): SignalSpec[]
6}
7 
8interface SignalSpec {
9  signalId: SignalId
10  name: string
11  description?: string
12  schema?: ZodType
13  tags?: string[]
14}

1import { z } from "zod"
2import { SignalRegistry } from "@loop-engine/signals"
3import { signalId } from "@loop-engine/core"
4 
5const registry = new SignalRegistry()
6registry.register({
7  signalId: signalId("expense.submitted"),
8  name: "Expense submitted",
9  description: "A user has submitted an expense report for review.",
10  schema: z.object({
11    amount: z.number().positive(),
12    currency: z.string().length(3)
13  })
14})
15 
16const check = registry.validatePayload(signalId("expense.submitted"), {
17  amount: 1200,
18  currency: "USD"
19})
20"cmt">// => { valid: true }

1interface SignalEngine {
2  registerRule(rule: SignalRule): void
3  process(events: LoopEvent[]): Signal[]
4  subscribe(handler: (signal: Signal) => void): () => void
5}
6 
7createSignalEngine(): SignalEngine