{"version":3,"sources":["../../../../src/dbs/base/changes.ts"],"names":["config","callbacks","mapper","axios","instance","key","TopicPrefix","err","EquippedError"],"mappings":"AAAA,q4BAAkB,kBAEI,mBACc,yDAGT,MAEpB,CAAA,CAAA,YACN,CAAA,MACWA,CACAC,CAAAA,WADA,CAAA,CAAA,CAAA,CAAA,CAAAD,CAAAA,CACA,CAAA,IAAA,CAAA,MAAA,CAAA,CAAA,CAAAC,IACA,CAAA,SAAAC,CACR,CAEH,CAAA,IAAA,CAAgB,MAAA,CAAA,CAAA,CAAA,MAAA,kBACEC,CAAM,CAAA,CAAA,CAAA,CAAA,CAAA,MAAS,CAAA,CAAA,eAAA,CAAA,MAAc,CAAA,CAAA,OAAO,CAAA,IAAA,CAAA,MACrD,CAAA,WAAO,CAAMC,CAAAA,CACX,OAAI,MAAA,CAAA,CAAA,GAAA,CAAeC,CAAG,YACtB,EAAA,CAAA,CAAA,OAAA,CAAA,CAAA,CAAgBC,cAChB,CAAA,CAAA,CAAA,uBACA,CAAA,OAAA,CAAA,2CACA,CAAA,IAAA,CAAA,mCACA,CAAA,IAAA,CAAA,eAAiB,CAAA,6CACjB,CAAA,8BACA,CAAA,OAAA,CAAA,iBAAmB,CAAA,6CACnB,CAAA,gCAEA,CACA,OAAK,CAAA,GAAA,CAAA,CAAA,CAAA,CACU,IAAA,CAAA,KAAe,CAAA,CAAI,yDAAA,CAAA,MAAA,CAAA,CAAA,GAAA,CAAeD,CAAG,YACtC,EAAA,CAAA,CAAA,OAAW,CAAA,CAAA,CAAA,yBAAA,IAAQ,2BAAA,CAAA,CAAA,mCAAA,MAAc,mCAAK,QAEpD,gCAAOE,CAAAA,CAAAA,GAAQ,eACf,CAAA,GAAA,CAAA,CAAA,KAAUC,CAAAA,CAAc,EAAA,CAAA,MAAA,IAAA,+BAAA,CAAA,6BAG5B,CAAA,CAAA,GAAA,CAAA,CAAA,CAAA,CAAA,CAAA,CAAA,CAAA,CAAA,CAAA,CAAA,8CAAA","file":"/home/runner/work/equipped/equipped/dist/cjs/dbs/base/changes.min.cjs","sourcesContent":["import axios from 'axios'\n\nimport * as core from './core'\nimport { type DbChangeConfig } from './types'\nimport { EquippedError } from '../../errors'\n\nexport const TopicPrefix = 'db-changes'\n\nexport abstract class DbChange<Model extends core.Model<core.IdType>, Entity extends core.Entity> {\n\tconstructor(\n\t\tprotected config: DbChangeConfig,\n\t\tprotected callbacks: core.DbChangeCallbacks<Model, Entity>,\n\t\tprotected mapper: (model: Model) => Entity,\n\t) {}\n\n\tprotected async configureConnector(key: string, data: Record<string, string>) {\n\t\tconst instance = axios.create({ baseURL: this.config.debeziumUrl })\n\t\treturn await instance\n\t\t\t.put(`/connectors/${key}/config`, {\n\t\t\t\t'topic.prefix': TopicPrefix,\n\t\t\t\t'topic.creation.enable': 'false',\n\t\t\t\t'topic.creation.default.replication.factor': `-1`,\n\t\t\t\t'topic.creation.default.partitions': '-1',\n\t\t\t\t'key.converter': 'org.apache.kafka.connect.json.JsonConverter',\n\t\t\t\t'key.converter.schemas.enable': 'false',\n\t\t\t\t'value.converter': 'org.apache.kafka.connect.json.JsonConverter',\n\t\t\t\t'value.converter.schemas.enable': 'false',\n\t\t\t\t...data,\n\t\t\t})\n\t\t\t.then(async () => {\n\t\t\t\tconst topics = await instance.get(`/connectors/${key}/topics`)\n\t\t\t\treturn topics.data[key]?.topics?.includes?.(key) ?? false\n\t\t\t})\n\t\t\t.catch((err) => {\n\t\t\t\tthrow new EquippedError(`Failed to configure watcher`, { key }, err)\n\t\t\t})\n\t}\n}\n"]}