{"version":3,"sources":["../../../src/events/pipes.ts","/home/runner/work/equipped/equipped/dist/cjs/events/pipes.cjs"],"names":[],"mappings":"AAAA,6GAAmC;AAE5B,MAAM,mBAAA,EAAqB,CAAA,EAAA,GACjC,WAAA,CAAE,IAAA;AAAA,EACD,WAAA,CAAE,MAAA,CAAO;AAAA,IACR,GAAA,EAAK,WAAA,CAAE,MAAA,CAAO,CAAA;AAAA,IACd,eAAA,EAAiB,WAAA,CAAE,MAAA,CAAO;AAAA,EAC3B,CAAC,CAAA;AAAA,EACD,EAAE,KAAA,EAAO,iBAAA,EAAmB,MAAA,EAAQ,iBAAiB;AACtD,CAAA;AAEM,MAAM,gBAAA,EAAkB,CAAA,EAAA,GAC9B,WAAA,CAAE,IAAA;AAAA,EACD,WAAA,CAAE,MAAA,CAAO;AAAA,IACR,OAAA,EAAS,WAAA,CAAE,KAAA,CAAM,WAAA,CAAE,MAAA,CAAO,CAAC,CAAA;AAAA,IAC3B,GAAA,EAAK,WAAA,CAAE,QAAA,CAAS,WAAA,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA,IAC3B,IAAA,EAAM,WAAA,CAAE,QAAA;AAAA,MACP,WAAA,CAAE,MAAA,CAAO;AAAA,QACR,SAAA,EAAW,WAAA,CAAE,EAAA,CAAG,OAAgB,CAAA;AAAA,QAChC,QAAA,EAAU,WAAA,CAAE,MAAA,CAAO,CAAA;AAAA,QACnB,QAAA,EAAU,WAAA,CAAE,MAAA,CAAO;AAAA,MACpB,CAAC;AAAA,IACF,CAAA;AAAA,IACA,QAAA,EAAU,WAAA,CAAE,QAAA,CAAS,WAAA,CAAE,MAAA,CAAO,CAAC;AAAA,EAChC,CAAC,CAAA;AAAA,EACD,EAAE,KAAA,EAAO,cAAA,EAAgB,MAAA,EAAQ,cAAc;AAChD,CAAA;ACHD;AACE;AACA;AACF,2FAAC","file":"/home/runner/work/equipped/equipped/dist/cjs/events/pipes.cjs","sourcesContent":["import { type PipeOutput, v } from 'valleyed'\n\nexport const rabbitmqConfigPipe = () =>\n\tv.meta(\n\t\tv.object({\n\t\t\turi: v.string(),\n\t\t\teventColumnName: v.string(),\n\t\t}),\n\t\t{ title: 'Rabbitmq Config', $refId: 'RabbitmqConfig' },\n\t)\n\nexport const kafkaConfigPipe = () =>\n\tv.meta(\n\t\tv.object({\n\t\t\tbrokers: v.array(v.string()),\n\t\t\tssl: v.optional(v.boolean()),\n\t\t\tsasl: v.optional(\n\t\t\t\tv.object({\n\t\t\t\t\tmechanism: v.is('plain' as const),\n\t\t\t\t\tusername: v.string(),\n\t\t\t\t\tpassword: v.string(),\n\t\t\t\t}),\n\t\t\t),\n\t\t\tclientId: v.optional(v.string()),\n\t\t}),\n\t\t{ title: 'Kafka Config', $refId: 'KafkaConfig' },\n\t)\n\nexport type KafkaConfig = PipeOutput<ReturnType<typeof kafkaConfigPipe>>\nexport type RabbitMQConfig = PipeOutput<ReturnType<typeof rabbitmqConfigPipe>>\n",null]}