queue.example.ts

queue.example.ts

type User = any
type Event = {
    id: 'user:new',
    user: User
} | {
    id: 'tick',
    interval: number
}

type EventID = Event['id'] // user:new, tick, etc...

type Action = {
    id: 'notification:email',
    template: string,
    subject: string,
    // ...
}

type ActionID = Action['id']

type Condition = (event: Event) => boolean

type Filter = {
    conditions: Condition[]
}

type Trigger = {
    action: Action,
    when: Filter[]
}

type Handler = (trigger: Trigger, event: Event) => void

let handlers: Record<ActionID, Handler> = {
    "notification:email": (trigger, event) => { 
    },
}

let triggers: Trigger[] = [] // ...

onEvent('tick', event => {
    let triggersToFire= triggers.filter(
        trigger => trigger.when.every(event)
    )
    triggersToFire.forEach(trigger => {
        handlers[trigger.action.id](trigger, event)
    });
})

onEvent('db:new-user', event => {})