{"version":3,"sources":["../src/index.ts","../src/dispatcher.ts"],"sourcesContent":["export type {\n\tChannelId,\n\tCronDeliveryMode,\n\tCronDelivery,\n\tTriggerRequest,\n\tTriggerResponse,\n\tChannelAdapter,\n\tChannelDispatcher\n} from \"@hybrd/types\"\n\nexport { dispatchToChannel, DEFAULT_ADAPTER_PORTS } from \"./dispatcher.js\"\n","import type { ChannelId, TriggerRequest, TriggerResponse } from \"@hybrd/types\"\n\nexport const DEFAULT_ADAPTER_PORTS: Record<string, number> = {\n\t// telegram: 8456,  // future\n\t// slack: 8457,     // future\n}\n\nexport async function dispatchToChannel(params: {\n\tchannel: ChannelId\n\tto: string\n\tmessage: string\n\tmetadata?: TriggerRequest[\"metadata\"]\n}): Promise<TriggerResponse> {\n\tconst port = DEFAULT_ADAPTER_PORTS[params.channel]\n\n\tif (!port) {\n\t\treturn { delivered: false, error: `Unknown channel: ${params.channel}` }\n\t}\n\n\tconst url = `http://127.0.0.1:${port}/api/trigger`\n\n\ttry {\n\t\tconst res = await fetch(url, {\n\t\t\tmethod: \"POST\",\n\t\t\theaders: { \"Content-Type\": \"application/json\" },\n\t\t\tbody: JSON.stringify({\n\t\t\t\tto: params.to,\n\t\t\t\tmessage: params.message,\n\t\t\t\tmetadata: params.metadata\n\t\t\t})\n\t\t})\n\n\t\tif (!res.ok) {\n\t\t\treturn {\n\t\t\t\tdelivered: false,\n\t\t\t\terror: `Channel adapter returned ${res.status}: ${res.statusText}`\n\t\t\t}\n\t\t}\n\n\t\treturn (await res.json()) as TriggerResponse\n\t} catch (err) {\n\t\treturn {\n\t\t\tdelivered: false,\n\t\t\terror:\n\t\t\t\terr instanceof Error\n\t\t\t\t\t? err.message\n\t\t\t\t\t: \"Failed to connect to channel adapter\"\n\t\t}\n\t}\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;;;ACEO,IAAM,wBAAgD;AAAA;AAAA;AAG7D;AAEA,eAAsB,kBAAkB,QAKX;AAC5B,QAAM,OAAO,sBAAsB,OAAO,OAAO;AAEjD,MAAI,CAAC,MAAM;AACV,WAAO,EAAE,WAAW,OAAO,OAAO,oBAAoB,OAAO,OAAO,GAAG;AAAA,EACxE;AAEA,QAAM,MAAM,oBAAoB,IAAI;AAEpC,MAAI;AACH,UAAM,MAAM,MAAM,MAAM,KAAK;AAAA,MAC5B,QAAQ;AAAA,MACR,SAAS,EAAE,gBAAgB,mBAAmB;AAAA,MAC9C,MAAM,KAAK,UAAU;AAAA,QACpB,IAAI,OAAO;AAAA,QACX,SAAS,OAAO;AAAA,QAChB,UAAU,OAAO;AAAA,MAClB,CAAC;AAAA,IACF,CAAC;AAED,QAAI,CAAC,IAAI,IAAI;AACZ,aAAO;AAAA,QACN,WAAW;AAAA,QACX,OAAO,4BAA4B,IAAI,MAAM,KAAK,IAAI,UAAU;AAAA,MACjE;AAAA,IACD;AAEA,WAAQ,MAAM,IAAI,KAAK;AAAA,EACxB,SAAS,KAAK;AACb,WAAO;AAAA,MACN,WAAW;AAAA,MACX,OACC,eAAe,QACZ,IAAI,UACJ;AAAA,IACL;AAAA,EACD;AACD;","names":[]}