{"version":3,"sources":["../../../src/events/pipes.ts"],"names":["rabbitmqConfigPipe","v","kafkaConfigPipe"],"mappings":"AAAA,6GAAmC,MAEtBA,CAAAA,CAAqB,CAAA,CAAA,EACjCC,WAAAA,CAAE,IAAA,CACDA,WAAAA,CAAE,MAAA,CAAO,CACR,GAAA,CAAKA,WAAAA,CAAE,MAAA,CAAO,CAAA,CACd,eAAA,CAAiBA,WAAAA,CAAE,MAAA,CAAO,CAC3B,CAAC,CAAA,CACD,CAAE,KAAA,CAAO,iBAAA,CAAmB,MAAA,CAAQ,gBAAiB,CACtD,CAAA,CAEYC,CAAAA,2BAAkB,CAAA,CAAA,EAC9BD,WAAAA,CAAE,IAAA,CACDA,WAAAA,CAAE,MAAA,CAAO,CACR,OAAA,CAASA,WAAAA,CAAE,KAAA,CAAMA,WAAAA,CAAE,MAAA,CAAO,CAAC,CAAA,CAC3B,GAAA,CAAKA,WAAAA,CAAE,QAAA,CAASA,WAAAA,CAAE,OAAA,CAAQ,CAAC,CAAA,CAC3B,IAAA,CAAMA,WAAAA,CAAE,QAAA,CACPA,WAAAA,CAAE,MAAA,CAAO,CACR,SAAA,CAAWA,WAAAA,CAAE,EAAA,CAAG,OAAgB,CAAA,CAChC,QAAA,CAAUA,WAAAA,CAAE,MAAA,CAAO,CAAA,CACnB,QAAA,CAAUA,WAAAA,CAAE,MAAA,CAAO,CACpB,CAAC,CACF,CAAA,CACA,QAAA,CAAUA,WAAAA,CAAE,QAAA,CAASA,WAAAA,CAAE,MAAA,CAAO,CAAC,CAChC,CAAC,CAAA,CACD,CAAE,KAAA,CAAO,cAAA,CAAgB,MAAA,CAAQ,aAAc,CAChD,CAAA,CAAA,4DAAA","file":"/home/runner/work/equipped/equipped/dist/cjs/events/pipes.min.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"]}