import { EventHandler } from './event-handler' import { EventMeta, HandlerBookmark, Provider, StreamsHandler, Event, HandlerBody, DomainHandlerOpts, } from './types' type Options = { bookmark: HandlerBookmark streams: Array provider: Provider | Promise> } & DomainHandlerOpts export function createHandler(options: Options) { const handler = new EventHandler({ bookmark: options.bookmark, provider: options.provider, stream: options.streams as string[], hooks: options.hooks, alwaysTailStream: options.alwaysTailStream, tailStream: options.tailStream, continueOnError: options.continueOnError, }) type CB = (id: string, event: Event, meta: EventMeta) => any const callbacks = new Map() const handle: StreamsHandler = (stream, type, callback) => { callbacks.set(`${stream.toString()}-${type}`, callback as any) handler.handle(type, (id, event, meta) => { const cb = callbacks.get(`${meta.stream}-${event.type}`) if (!cb) return return cb(id, event as any, meta) }) } const handleStream = (stream: S, handlers: HandlerBody) => { for (const [type, handler] of Object.entries(handlers)) { handle(stream, type, handler as any) } } return { handle, handleStream, start: handler.start, stop: handler.stop, runOnce: handler.runOnce, run: handler.run, setPosition: handler.setPosition, getPosition: handler.getPosition, reset: handler.reset, __handler: handler, name: handler.name, } }