{"version":3,"sources":["../../../../src/dbs/base/changes.ts","/home/runner/work/equipped/equipped/dist/cjs/dbs/base/changes.cjs"],"names":[],"mappings":"AAAA,+mCAAkB;AAElB,mFAAsB;AACtB,uBAAoC;AACpC,kDAA8B;AAEvB,MAAM,YAAA,EAAc,YAAA;AAEpB,MAAe,SAA4E;AAAA,EACjG,WAAA,CACW,MAAA,EACA,SAAA,EACA,MAAA,EACT;AAHS,IAAA,IAAA,CAAA,OAAA,EAAA,MAAA;AACA,IAAA,IAAA,CAAA,UAAA,EAAA,SAAA;AACA,IAAA,IAAA,CAAA,OAAA,EAAA,MAAA;AAAA,EACR;AAAA,EAEH,MAAgB,kBAAA,CAAmB,GAAA,EAAa,IAAA,EAA8B;AAC7E,IAAA,MAAM,SAAA,EAAW,eAAA,CAAM,MAAA,CAAO,EAAE,OAAA,EAAS,IAAA,CAAK,MAAA,CAAO,YAAY,CAAC,CAAA;AAClE,IAAA,OAAO,MAAM,QAAA,CACX,GAAA,CAAI,CAAA,YAAA,EAAe,GAAG,CAAA,OAAA,CAAA,EAAW;AAAA,MACjC,cAAA,EAAgB,WAAA;AAAA,MAChB,uBAAA,EAAyB,OAAA;AAAA,MACzB,2CAAA,EAA6C,CAAA,EAAA,CAAA;AAAA,MAC7C,mCAAA,EAAqC,IAAA;AAAA,MACrC,eAAA,EAAiB,6CAAA;AAAA,MACjB,8BAAA,EAAgC,OAAA;AAAA,MAChC,iBAAA,EAAmB,6CAAA;AAAA,MACnB,gCAAA,EAAkC,OAAA;AAAA,MAClC,GAAG;AAAA,IACJ,CAAC,CAAA,CACA,IAAA,CAAK,MAAA,CAAA,EAAA,GAAY;AACjB,MAAA,MAAM,OAAA,EAAS,MAAM,QAAA,CAAS,GAAA,CAAI,CAAA,YAAA,EAAe,GAAG,CAAA,OAAA,CAAS,CAAA;AAC7D,MAAA,wCAAO,MAAA,mBAAO,IAAA,qBAAK,GAAG,CAAA,6BAAG,MAAA,6BAAQ,QAAA,0BAAA,CAAW,GAAG,GAAA,UAAK,OAAA;AAAA,IACrD,CAAC,CAAA,CACA,KAAA,CAAM,CAAC,GAAA,EAAA,GAAQ;AACf,MAAA,MAAM,IAAI,4BAAA,CAAc,CAAA,2BAAA,CAAA,EAA+B,EAAE,IAAI,CAAA,EAAG,GAAG,CAAA;AAAA,IACpE,CAAC,CAAA;AAAA,EACH;AACD;ACNA;AACE;AACA;AACF,+DAAC","file":"/home/runner/work/equipped/equipped/dist/cjs/dbs/base/changes.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",null]}