diff --git a/dist/src/controllers/graphSubscription.js b/dist/src/controllers/graphSubscription.js new file mode 100644 index 000000000..1370f8635 --- /dev/null +++ b/dist/src/controllers/graphSubscription.js @@ -0,0 +1,82 @@ +"use strict"; +var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { + function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } + return new (P || (P = Promise))(function (resolve, reject) { + function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } + function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } + function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } + step((generator = generator.apply(thisArg, _arguments || [])).next()); + }); +}; +Object.defineProperty(exports, "__esModule", { value: true }); +exports.getGraphSubscription = exports.addGraphSubscription = void 0; +const models_1 = require("../models"); +const res_1 = require("../utils/res"); +const logger_1 = require("../utils/logger"); +function addGraphSubscription(req, res) { + return __awaiter(this, void 0, void 0, function* () { + if (!req.owner) + return (0, res_1.failure)(res, 'no owner'); + const tenant = req.owner.id; + logger_1.sphinxLogger.info(`=> saveLsat`, logger_1.logging.Express); + const { name, address, weight, status } = req.body; + let { chatIds } = req.body; + if (!name || !address || !weight) { + return (0, res_1.failure)(res, 'Missing required Graph Subscription data'); + } + if (typeof status !== 'number' || status > 1) { + return (0, res_1.failure)(res, 'Provide valid graph status'); + } + if (chatIds !== 'all' && !Array.isArray(chatIds)) { + return (0, res_1.failure)(res, 'Provide valid tribe Id'); + } + if (Array.isArray(chatIds)) { + chatIds = JSON.stringify(chatIds); + } + try { + yield models_1.models.GraphSubscription.create({ + name, + address, + weight, + status, + chatIds, + tenant, + }); + return (0, res_1.success)(res, 'Graph Subscription added successfully'); + } + catch (error) { + console.log(error); + return (0, res_1.failure)(res, 'An internal error occured'); + } + }); +} +exports.addGraphSubscription = addGraphSubscription; +function getGraphSubscription(req, res) { + return __awaiter(this, void 0, void 0, function* () { + if (!req.owner) + return (0, res_1.failure)(res, 'no owner'); + try { + const graphs = (yield models_1.models.GraphSubscription.findAll()); + const newGraphs = []; + for (let i = 0; i < graphs.length; i++) { + const graph = graphs[i]; + const lsat = (yield models_1.models.Lsat.findOne({ + where: { paths: graph.address, status: 1 }, + })); + const obj = { + client_name: graph.name, + prediction_endpoint: graph.address, + lsat: lsat ? `${lsat.macaroon}:${lsat.preimage}` : '', + }; + newGraphs.push(obj); + } + return (0, res_1.success)(res, newGraphs); + } + catch (error) { + console.log(error); + return (0, res_1.failure)(res, 'An internal error occured'); + } + }); +} +exports.getGraphSubscription = getGraphSubscription; +//# sourceMappingURL=graphSubscription.js.map \ No newline at end of file diff --git a/dist/src/controllers/graphSubscription.js.map b/dist/src/controllers/graphSubscription.js.map new file mode 100644 index 000000000..88b6e1b3d --- /dev/null +++ b/dist/src/controllers/graphSubscription.js.map @@ -0,0 +1 @@ +{"version":3,"file":"graphSubscription.js","sourceRoot":"","sources":["../../../src/controllers/graphSubscription.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,sCAAiE;AAGjE,sCAA+C;AAC/C,4CAAuD;AAEvD,SAAsB,oBAAoB,CACxC,GAAQ,EACR,GAAa;;QAEb,IAAI,CAAC,GAAG,CAAC,KAAK;YAAE,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,UAAU,CAAC,CAAA;QAC/C,MAAM,MAAM,GAAW,GAAG,CAAC,KAAK,CAAC,EAAE,CAAA;QAEnC,qBAAY,CAAC,IAAI,CAAC,aAAa,EAAE,gBAAO,CAAC,OAAO,CAAC,CAAA;QAEjD,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,MAAM,EAAE,MAAM,EAAE,GAAG,GAAG,CAAC,IAAI,CAAA;QAClD,IAAI,EAAE,OAAO,EAAE,GAAG,GAAG,CAAC,IAAI,CAAA;QAC1B,IAAI,CAAC,IAAI,IAAI,CAAC,OAAO,IAAI,CAAC,MAAM,EAAE;YAChC,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,0CAA0C,CAAC,CAAA;SAChE;QAED,IAAI,OAAO,MAAM,KAAK,QAAQ,IAAI,MAAM,GAAG,CAAC,EAAE;YAC5C,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,4BAA4B,CAAC,CAAA;SAClD;QAED,IAAI,OAAO,KAAK,KAAK,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE;YAChD,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,wBAAwB,CAAC,CAAA;SAC9C;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE;YAC1B,OAAO,GAAG,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,CAAA;SAClC;QAED,IAAI;YACF,MAAM,eAAM,CAAC,iBAAiB,CAAC,MAAM,CAAC;gBACpC,IAAI;gBACJ,OAAO;gBACP,MAAM;gBACN,MAAM;gBACN,OAAO;gBACP,MAAM;aACP,CAAC,CAAA;YACF,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,uCAAuC,CAAC,CAAA;SAC7D;QAAC,OAAO,KAAK,EAAE;YACd,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAA;YAClB,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,2BAA2B,CAAC,CAAA;SACjD;IACH,CAAC;CAAA;AAzCD,oDAyCC;AAED,SAAsB,oBAAoB,CACxC,GAAQ,EACR,GAAa;;QAEb,IAAI,CAAC,GAAG,CAAC,KAAK;YAAE,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,UAAU,CAAC,CAAA;QAC/C,IAAI;YACF,MAAM,MAAM,GACV,CAAC,MAAM,eAAM,CAAC,iBAAiB,CAAC,OAAO,EAAE,CAA8B,CAAA;YAEzE,MAAM,SAAS,GAIT,EAAE,CAAA;YACR,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,MAAM,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;gBACtC,MAAM,KAAK,GAAG,MAAM,CAAC,CAAC,CAAC,CAAA;gBACvB,MAAM,IAAI,GAAG,CAAC,MAAM,eAAM,CAAC,IAAI,CAAC,OAAO,CAAC;oBACtC,KAAK,EAAE,EAAE,KAAK,EAAE,KAAK,CAAC,OAAO,EAAE,MAAM,EAAE,CAAC,EAAE;iBAC3C,CAAC,CAAS,CAAA;gBACX,MAAM,GAAG,GAAG;oBACV,WAAW,EAAE,KAAK,CAAC,IAAI;oBACvB,mBAAmB,EAAE,KAAK,CAAC,OAAO;oBAClC,IAAI,EAAE,IAAI,CAAC,CAAC,CAAC,GAAG,IAAI,CAAC,QAAQ,IAAI,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC,EAAE;iBACtD,CAAA;gBACD,SAAS,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;aACpB;YACD,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,SAAS,CAAC,CAAA;SAC/B;QAAC,OAAO,KAAK,EAAE;YACd,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAA;YAClB,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,2BAA2B,CAAC,CAAA;SACjD;IACH,CAAC;CAAA;AA/BD,oDA+BC"} \ No newline at end of file diff --git a/dist/src/controllers/index.js b/dist/src/controllers/index.js index be213429a..61744bc10 100644 --- a/dist/src/controllers/index.js +++ b/dist/src/controllers/index.js @@ -38,6 +38,7 @@ const personal = require("./api/personal"); const lsats = require("./lsats"); const action = require("./actionHistory"); const feeds = require("./getFeeds"); +const graphSubscription = require("./graphSubscription"); function set(app) { return __awaiter(this, void 0, void 0, function* () { builtInBots.init(); @@ -173,6 +174,9 @@ function set(app) { app.get('/active_lsat', lsats.getActiveLsat); // Get feeds app.get('/feeds', feeds.getFeeds); + // Graph Subscription + app.post('/addGraph', graphSubscription.addGraphSubscription); + app.get('/getGraph', graphSubscription.getGraphSubscription); }); } exports.set = set; diff --git a/dist/src/controllers/index.js.map b/dist/src/controllers/index.js.map index 47ed29306..6711d3874 100644 --- a/dist/src/controllers/index.js.map +++ b/dist/src/controllers/index.js.map @@ -1 +1 @@ -{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/controllers/index.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,sCAA2C;AAC3C,iCAAgC;AAChC,2CAA0C;AAC1C,+BAA8B;AAC9B,qCAAoC;AACpC,uCAAsC;AACtC,qCAAoC;AACpC,uCAAsC;AACtC,iCAAgC;AAChC,uCAAsC;AACtC,sCAAqC;AACrC,gDAA+C;AAC/C,qCAAoC;AACpC,iDAAgD;AAChD,oCAAmC;AACnC,qCAAoC;AACpC,4CAA2C;AAC3C,0CAAyC;AACzC,0CAAyC;AACzC,iCAAgC;AAChC,4CAAoC;AACpC,+BAA8B;AAC9B,sCAAsC;AACtC,+BAA8B;AAC9B,2CAA0C;AAC1C,iCAAgC;AAEhC,0CAAyC;AACzC,oCAAmC;AAEnC,SAAsB,GAAG,CAAC,GAAG;;QAC3B,WAAW,CAAC,IAAI,EAAE,CAAA;QAElB,IAAI,eAAM,IAAI,eAAM,CAAC,YAAY,EAAE;YACjC,YAAY,CAAC,kBAAkB,EAAE,CAAA;SAClC;QAED,0BAA0B;QAE1B,MAAM,CAAC,YAAY,EAAE,CAAA;QAErB,gCAAgC;QAEhC,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QACjC,GAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,KAAK,CAAC,eAAe,CAAC,CAAA;QACzC,GAAG,CAAC,GAAG,CAAC,YAAY,EAAE,KAAK,CAAC,UAAU,CAAC,CAAA;QACvC,GAAG,CAAC,IAAI,CAAC,8BAA8B,EAAE,KAAK,CAAC,IAAI,CAAC,CAAA;QACpD,GAAG,CAAC,GAAG,CAAC,yBAAyB,EAAE,KAAK,CAAC,cAAc,CAAC,CAAA;QACxD,GAAG,CAAC,MAAM,CAAC,WAAW,EAAE,KAAK,CAAC,UAAU,CAAC,CAAA;QACzC,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,KAAK,CAAC,eAAe,CAAC,CAAA;QAC3C,GAAG,CAAC,GAAG,CAAC,4BAA4B,EAAE,KAAK,CAAC,cAAc,CAAC,CAAA;QAC3D,GAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,UAAU,CAAC,SAAS,CAAC,CAAA;QACxC,GAAG,CAAC,IAAI,CAAC,gBAAgB,EAAE,UAAU,CAAC,aAAa,CAAC,CAAA;QACpD,GAAG,CAAC,MAAM,CAAC,gBAAgB,EAAE,UAAU,CAAC,aAAa,CAAC,CAAA;QACtD,GAAG,CAAC,IAAI,CAAC,eAAe,EAAE,KAAK,CAAC,cAAc,CAAC,CAAA;QAC/C,GAAG,CAAC,GAAG,CACL,uCAAuC,EACvC,UAAU,CAAC,qBAAqB,CACjC,CAAA;QACD,GAAG,CAAC,GAAG,CAAC,YAAY,EAAE,UAAU,CAAC,SAAS,CAAC,CAAA;QAC3C,GAAG,CAAC,GAAG,CAAC,eAAe,EAAE,UAAU,CAAC,UAAU,CAAC,CAAA;QAE/C,GAAG,CAAC,IAAI,CAAC,SAAS,EAAE,OAAO,CAAC,YAAY,CAAC,MAAM,CAAC,MAAM,CAAC,EAAE,OAAO,CAAC,UAAU,CAAC,CAAA;QAE5E,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,OAAO,CAAC,YAAY,CAAC,CAAA;QAC1C,GAAG,CAAC,IAAI,CAAC,6BAA6B,EAAE,OAAO,CAAC,SAAS,CAAC,CAAA;QAC1D,GAAG,CAAC,IAAI,CAAC,iBAAiB,EAAE,OAAO,CAAC,YAAY,CAAC,CAAA;QAEjD,GAAG,CAAC,IAAI,CAAC,kBAAkB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QACpD,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC1C,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,QAAQ,CAAC,kBAAkB,CAAC,CAAA;QAC1D,GAAG,CAAC,GAAG,CAAC,eAAe,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAChD,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QACpD,GAAG,CAAC,GAAG,CAAC,sBAAsB,EAAE,QAAQ,CAAC,cAAc,CAAC,CAAA;QACxD,GAAG,CAAC,IAAI,CAAC,oBAAoB,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QACrD,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAC7C,GAAG,CAAC,MAAM,CAAC,eAAe,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QACnD,GAAG,CAAC,GAAG,CAAC,kBAAkB,EAAE,QAAQ,CAAC,iBAAiB,CAAC,CAAA;QACvD,GAAG,CAAC,IAAI,CAAC,oBAAoB,EAAE,QAAQ,CAAC,+BAA+B,CAAC,CAAA;QACxE,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,eAAe,CAAC,CAAA;QAC/C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,UAAU,CAAC,CAAA;QAEzC,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,QAAQ,CAAC,mBAAmB,CAAC,CAAA;QAClD,GAAG,CAAC,MAAM,CAAC,UAAU,EAAE,QAAQ,CAAC,mBAAmB,CAAC,CAAA;QACpD,GAAG,CAAC,IAAI,CAAC,gBAAgB,EAAE,QAAQ,CAAC,mBAAmB,CAAC,CAAA;QACxD,GAAG,CAAC,IAAI,CAAC,aAAa,EAAE,QAAQ,CAAC,eAAe,CAAC,CAAA;QACjD,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,QAAQ,CAAC,UAAU,CAAC,CAAA;QAC5C,GAAG,CAAC,IAAI,CAAC,kBAAkB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QACpD,GAAG,CAAC,IAAI,CAAC,eAAe,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC/C,GAAG,CAAC,IAAI,CAAC,iBAAiB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAEnD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,QAAQ,CAAC,OAAO,CAAC,CAAA;QAClC,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,QAAQ,CAAC,cAAc,CAAC,CAAA;QAChD,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC1C,GAAG,CAAC,MAAM,CAAC,cAAc,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAClD,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC3C,GAAG,CAAC,IAAI,CAAC,yBAAyB,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QAC1D,GAAG,CAAC,IAAI,CAAC,iBAAiB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAEnD,GAAG,CAAC,GAAG,CAAC,gBAAgB,EAAE,YAAY,CAAC,mBAAmB,CAAC,CAAA;QAC3D,GAAG,CAAC,GAAG,CAAC,mBAAmB,EAAE,YAAY,CAAC,eAAe,CAAC,CAAA;QAC1D,GAAG,CAAC,MAAM,CAAC,mBAAmB,EAAE,YAAY,CAAC,kBAAkB,CAAC,CAAA;QAChE,GAAG,CAAC,IAAI,CAAC,gBAAgB,EAAE,YAAY,CAAC,kBAAkB,CAAC,CAAA;QAC3D,GAAG,CAAC,GAAG,CAAC,mBAAmB,EAAE,YAAY,CAAC,gBAAgB,CAAC,CAAA;QAC3D,GAAG,CAAC,GAAG,CACL,mCAAmC,EACnC,YAAY,CAAC,0BAA0B,CACxC,CAAA;QACD,GAAG,CAAC,GAAG,CAAC,yBAAyB,EAAE,YAAY,CAAC,iBAAiB,CAAC,CAAA;QAClE,GAAG,CAAC,GAAG,CAAC,2BAA2B,EAAE,YAAY,CAAC,mBAAmB,CAAC,CAAA;QAEtE,GAAG,CAAC,IAAI,CAAC,aAAa,EAAE,KAAK,CAAC,qBAAqB,CAAC,CAAA;QACpD,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QACrC,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,KAAK,CAAC,MAAM,CAAC,CAAA;QAE3C,GAAG,CAAC,IAAI,CAAC,kBAAkB,EAAE,IAAI,CAAC,iBAAiB,CAAC,CAAA;QACpD,GAAG,CAAC,GAAG,CAAC,wBAAwB,EAAE,IAAI,CAAC,mBAAmB,CAAC,CAAA;QAE3D,GAAG,CAAC,IAAI,CAAC,SAAS,EAAE,IAAI,CAAC,UAAU,CAAC,CAAA;QAEpC,GAAG,CAAC,GAAG,CAAC,eAAe,EAAE,OAAO,CAAC,cAAc,CAAC,CAAA;QAChD,GAAG,CAAC,GAAG,CAAC,gBAAgB,EAAE,OAAO,CAAC,eAAe,CAAC,CAAA;QAElD,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAC7C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QAC3C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,UAAU,CAAC,CAAA;QACzC,GAAG,CAAC,IAAI,CAAC,kBAAkB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAEpD,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC1C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QAE3C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,OAAO,CAAC,WAAW,CAAC,CAAA;QACzC,GAAG,CAAC,GAAG,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,CAAA;QACvC,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,OAAO,CAAC,qBAAqB,CAAC,CAAA;QACtD,GAAG,CAAC,GAAG,CAAC,UAAU,EAAE,OAAO,CAAC,gBAAgB,CAAC,CAAA;QAC7C,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,OAAO,CAAC,YAAY,CAAC,CAAA;QACtC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,OAAO,CAAC,WAAW,CAAC,CAAA;QACrC,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,OAAO,CAAC,UAAU,CAAC,CAAA;QACrC,GAAG,CAAC,GAAG,CAAC,SAAS,EAAE,OAAO,CAAC,yBAAyB,CAAC,CAAA;QACrD,GAAG,CAAC,GAAG,CAAC,aAAa,EAAE,OAAO,CAAC,eAAe,CAAC,CAAA;QAE/C,GAAG,CAAC,GAAG,CAAC,6BAA6B,EAAE,OAAO,CAAC,mBAAmB,CAAC,CAAA;QACnE,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,OAAO,CAAC,SAAS,CAAC,CAAA;QAEpC,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,OAAO,CAAC,cAAc,CAAC,CAAA;QAC5C,GAAG,CAAC,IAAI,CAAC,SAAS,EAAE,OAAO,CAAC,aAAa,CAAC,CAAA;QAC1C,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,CAAA;QAC9B,GAAG,CAAC,IAAI,CAAC,MAAM,EAAE,IAAI,CAAC,SAAS,CAAC,CAAA;QAChC,GAAG,CAAC,MAAM,CAAC,UAAU,EAAE,IAAI,CAAC,SAAS,CAAC,CAAA;QACtC,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,IAAI,CAAC,cAAc,CAAC,CAAA;QACzC,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,IAAI,CAAC,eAAe,CAAC,CAAA;QAEnD,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,aAAa,CAAC,WAAW,CAAC,CAAA;QAElD,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,KAAK,CAAC,YAAY,CAAC,CAAA;QACxC,GAAG,CAAC,GAAG,CAAC,aAAa,EAAE,KAAK,CAAC,SAAS,CAAC,CAAA;QACvC,GAAG,CAAC,GAAG,CAAC,YAAY,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QAErC,GAAG,CAAC,GAAG,CAAC,UAAU,EAAE,UAAgB,GAAQ,EAAE,GAAG;;gBAC/C,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,OAAO,CAAC,GAAG,EAAE,CAAC,CAAA;YACpC,CAAC;SAAA,CAAC,CAAA;QAEF,GAAG,CAAC,IAAI,CAAC,iBAAiB,EAAE,MAAM,CAAC,UAAU,CAAC,CAAA;QAC9C,GAAG,CAAC,IAAI,CAAC,sBAAsB,EAAE,MAAM,CAAC,cAAc,CAAC,CAAA;QACvD,GAAG,CAAC,GAAG,CAAC,iBAAiB,EAAE,MAAM,CAAC,gBAAgB,CAAC,CAAA;QAEnD,GAAG,CAAC,GAAG,CAAC,SAAS,EAAE,UAAgB,GAAQ,EAAE,GAAG;;gBAC9C,IAAI,CAAC,GAAG,CAAC,KAAK;oBAAE,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,UAAU,CAAC,CAAA;gBAC/C,MAAM,MAAM,GAAW,GAAG,CAAC,KAAK,CAAC,EAAE,CAAA;gBACnC,MAAM,KAAK,GAAc,CAAC,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC;oBACrD,KAAK,EAAE,CAAC;oBACR,KAAK,EAAE,CAAC,CAAC,WAAW,EAAE,MAAM,CAAC,CAAC;oBAC9B,KAAK,EAAE,EAAE,MAAM,EAAE;iBAClB,CAAC,CAAc,CAAA;gBAChB,MAAM,IAAI,GAAG,KAAK,IAAI,KAAK,CAAC,CAAC,CAAC,CAAA;gBAC9B,IAAI,CAAC,IAAI,EAAE;oBACT,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,WAAW,CAAC,CAAA;iBAClC;qBAAM;oBACL,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,CAAA;iBACrC;YACH,CAAC;SAAA,CAAC,CAAA;QAEF,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,CAAC,SAAS,CAAC,CAAA;QAClC,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,KAAK,CAAC,OAAO,CAAC,CAAA;QAC5C,GAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QAClC,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,KAAK,CAAC,UAAU,CAAC,CAAA;QAC/C,GAAG,CAAC,MAAM,CAAC,oBAAoB,EAAE,KAAK,CAAC,UAAU,CAAC,CAAA;QAClD,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,KAAK,CAAC,aAAa,CAAC,CAAA;QAE5C,YAAY;QACZ,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;IACnC,CAAC;CAAA;AAjKD,kBAiKC;AAED,MAAM,QAAQ,GAAG,mBAAS,CAAC,aAAa,CAAA;AAC3B,QAAA,OAAO,GAAG;IACrB,CAAC,QAAQ,CAAC,WAAW,CAAC,EAAE,QAAQ,CAAC,iBAAiB;IAClD,CAAC,QAAQ,CAAC,wBAAwB,CAAC,EAAE,QAAQ,CAAC,wBAAwB;IACtE,CAAC,QAAQ,CAAC,OAAO,CAAC,EAAE,QAAQ,CAAC,cAAc;IAC3C,CAAC,QAAQ,CAAC,OAAO,CAAC,EAAE,QAAQ,CAAC,cAAc;IAC3C,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,QAAQ,CAAC,cAAc;IAClD,CAAC,QAAQ,CAAC,YAAY,CAAC,EAAE,aAAa,CAAC,mBAAmB;IAC1D,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,KAAK,CAAC,iBAAiB;IAC9C,CAAC,QAAQ,CAAC,QAAQ,CAAC,EAAE,KAAK,CAAC,eAAe;IAC1C,CAAC,QAAQ,CAAC,eAAe,CAAC,EAAE,KAAK,CAAC,qBAAqB;IACvD,CAAC,QAAQ,CAAC,aAAa,CAAC,EAAE,KAAK,CAAC,mBAAmB;IACnD,CAAC,QAAQ,CAAC,YAAY,CAAC,EAAE,KAAK,CAAC,0BAA0B;IACzD,CAAC,QAAQ,CAAC,YAAY,CAAC,EAAE,KAAK,CAAC,0BAA0B;IACzD,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,KAAK,CAAC,gBAAgB;IAC7C,CAAC,QAAQ,CAAC,WAAW,CAAC,EAAE,KAAK,CAAC,iBAAiB;IAC/C,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,KAAK,CAAC,gBAAgB;IAC7C,CAAC,QAAQ,CAAC,MAAM,CAAC,EAAE,QAAQ,CAAC,oBAAoB;IAChD,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE,QAAQ,CAAC,gBAAgB;IAC/C,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,UAAU,CAAC,oBAAoB;IAC1D,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,UAAU,CAAC,oBAAoB;IAC1D,CAAC,QAAQ,CAAC,aAAa,CAAC,EAAE,UAAU,CAAC,mBAAmB;IACxD,CAAC,QAAQ,CAAC,YAAY,CAAC,EAAE,UAAU,CAAC,kBAAkB;IACtD,CAAC,QAAQ,CAAC,WAAW,CAAC,EAAE,IAAI,CAAC,iBAAiB;IAC9C,CAAC,QAAQ,CAAC,OAAO,CAAC,EAAE,IAAI,CAAC,aAAa;IACtC,CAAC,QAAQ,CAAC,OAAO,CAAC,EAAE,IAAI,CAAC,aAAa;IACtC,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE,aAAa,CAAC,gBAAgB;IACpD,CAAC,QAAQ,CAAC,sBAAsB,CAAC,EAAE,aAAa,CAAC,4BAA4B;IAC7E,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE,QAAQ,CAAC,YAAY;IACvC,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE,OAAO,CAAC,YAAY;IACtC,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,OAAO,CAAC,oBAAoB;CACxD,CAAA"} \ No newline at end of file +{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/controllers/index.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,sCAA2C;AAC3C,iCAAgC;AAChC,2CAA0C;AAC1C,+BAA8B;AAC9B,qCAAoC;AACpC,uCAAsC;AACtC,qCAAoC;AACpC,uCAAsC;AACtC,iCAAgC;AAChC,uCAAsC;AACtC,sCAAqC;AACrC,gDAA+C;AAC/C,qCAAoC;AACpC,iDAAgD;AAChD,oCAAmC;AACnC,qCAAoC;AACpC,4CAA2C;AAC3C,0CAAyC;AACzC,0CAAyC;AACzC,iCAAgC;AAChC,4CAAoC;AACpC,+BAA8B;AAC9B,sCAAsC;AACtC,+BAA8B;AAC9B,2CAA0C;AAC1C,iCAAgC;AAEhC,0CAAyC;AACzC,oCAAmC;AACnC,yDAAwD;AAExD,SAAsB,GAAG,CAAC,GAAG;;QAC3B,WAAW,CAAC,IAAI,EAAE,CAAA;QAElB,IAAI,eAAM,IAAI,eAAM,CAAC,YAAY,EAAE;YACjC,YAAY,CAAC,kBAAkB,EAAE,CAAA;SAClC;QAED,0BAA0B;QAE1B,MAAM,CAAC,YAAY,EAAE,CAAA;QAErB,gCAAgC;QAEhC,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QACjC,GAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,KAAK,CAAC,eAAe,CAAC,CAAA;QACzC,GAAG,CAAC,GAAG,CAAC,YAAY,EAAE,KAAK,CAAC,UAAU,CAAC,CAAA;QACvC,GAAG,CAAC,IAAI,CAAC,8BAA8B,EAAE,KAAK,CAAC,IAAI,CAAC,CAAA;QACpD,GAAG,CAAC,GAAG,CAAC,yBAAyB,EAAE,KAAK,CAAC,cAAc,CAAC,CAAA;QACxD,GAAG,CAAC,MAAM,CAAC,WAAW,EAAE,KAAK,CAAC,UAAU,CAAC,CAAA;QACzC,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,KAAK,CAAC,eAAe,CAAC,CAAA;QAC3C,GAAG,CAAC,GAAG,CAAC,4BAA4B,EAAE,KAAK,CAAC,cAAc,CAAC,CAAA;QAC3D,GAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,UAAU,CAAC,SAAS,CAAC,CAAA;QACxC,GAAG,CAAC,IAAI,CAAC,gBAAgB,EAAE,UAAU,CAAC,aAAa,CAAC,CAAA;QACpD,GAAG,CAAC,MAAM,CAAC,gBAAgB,EAAE,UAAU,CAAC,aAAa,CAAC,CAAA;QACtD,GAAG,CAAC,IAAI,CAAC,eAAe,EAAE,KAAK,CAAC,cAAc,CAAC,CAAA;QAC/C,GAAG,CAAC,GAAG,CACL,uCAAuC,EACvC,UAAU,CAAC,qBAAqB,CACjC,CAAA;QACD,GAAG,CAAC,GAAG,CAAC,YAAY,EAAE,UAAU,CAAC,SAAS,CAAC,CAAA;QAC3C,GAAG,CAAC,GAAG,CAAC,eAAe,EAAE,UAAU,CAAC,UAAU,CAAC,CAAA;QAE/C,GAAG,CAAC,IAAI,CAAC,SAAS,EAAE,OAAO,CAAC,YAAY,CAAC,MAAM,CAAC,MAAM,CAAC,EAAE,OAAO,CAAC,UAAU,CAAC,CAAA;QAE5E,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,OAAO,CAAC,YAAY,CAAC,CAAA;QAC1C,GAAG,CAAC,IAAI,CAAC,6BAA6B,EAAE,OAAO,CAAC,SAAS,CAAC,CAAA;QAC1D,GAAG,CAAC,IAAI,CAAC,iBAAiB,EAAE,OAAO,CAAC,YAAY,CAAC,CAAA;QAEjD,GAAG,CAAC,IAAI,CAAC,kBAAkB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QACpD,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC1C,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,QAAQ,CAAC,kBAAkB,CAAC,CAAA;QAC1D,GAAG,CAAC,GAAG,CAAC,eAAe,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAChD,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QACpD,GAAG,CAAC,GAAG,CAAC,sBAAsB,EAAE,QAAQ,CAAC,cAAc,CAAC,CAAA;QACxD,GAAG,CAAC,IAAI,CAAC,oBAAoB,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QACrD,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAC7C,GAAG,CAAC,MAAM,CAAC,eAAe,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QACnD,GAAG,CAAC,GAAG,CAAC,kBAAkB,EAAE,QAAQ,CAAC,iBAAiB,CAAC,CAAA;QACvD,GAAG,CAAC,IAAI,CAAC,oBAAoB,EAAE,QAAQ,CAAC,+BAA+B,CAAC,CAAA;QACxE,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,eAAe,CAAC,CAAA;QAC/C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,UAAU,CAAC,CAAA;QAEzC,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,QAAQ,CAAC,mBAAmB,CAAC,CAAA;QAClD,GAAG,CAAC,MAAM,CAAC,UAAU,EAAE,QAAQ,CAAC,mBAAmB,CAAC,CAAA;QACpD,GAAG,CAAC,IAAI,CAAC,gBAAgB,EAAE,QAAQ,CAAC,mBAAmB,CAAC,CAAA;QACxD,GAAG,CAAC,IAAI,CAAC,aAAa,EAAE,QAAQ,CAAC,eAAe,CAAC,CAAA;QACjD,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,QAAQ,CAAC,UAAU,CAAC,CAAA;QAC5C,GAAG,CAAC,IAAI,CAAC,kBAAkB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QACpD,GAAG,CAAC,IAAI,CAAC,eAAe,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC/C,GAAG,CAAC,IAAI,CAAC,iBAAiB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAEnD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,QAAQ,CAAC,OAAO,CAAC,CAAA;QAClC,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,QAAQ,CAAC,cAAc,CAAC,CAAA;QAChD,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC1C,GAAG,CAAC,MAAM,CAAC,cAAc,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAClD,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC3C,GAAG,CAAC,IAAI,CAAC,yBAAyB,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QAC1D,GAAG,CAAC,IAAI,CAAC,iBAAiB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAEnD,GAAG,CAAC,GAAG,CAAC,gBAAgB,EAAE,YAAY,CAAC,mBAAmB,CAAC,CAAA;QAC3D,GAAG,CAAC,GAAG,CAAC,mBAAmB,EAAE,YAAY,CAAC,eAAe,CAAC,CAAA;QAC1D,GAAG,CAAC,MAAM,CAAC,mBAAmB,EAAE,YAAY,CAAC,kBAAkB,CAAC,CAAA;QAChE,GAAG,CAAC,IAAI,CAAC,gBAAgB,EAAE,YAAY,CAAC,kBAAkB,CAAC,CAAA;QAC3D,GAAG,CAAC,GAAG,CAAC,mBAAmB,EAAE,YAAY,CAAC,gBAAgB,CAAC,CAAA;QAC3D,GAAG,CAAC,GAAG,CACL,mCAAmC,EACnC,YAAY,CAAC,0BAA0B,CACxC,CAAA;QACD,GAAG,CAAC,GAAG,CAAC,yBAAyB,EAAE,YAAY,CAAC,iBAAiB,CAAC,CAAA;QAClE,GAAG,CAAC,GAAG,CAAC,2BAA2B,EAAE,YAAY,CAAC,mBAAmB,CAAC,CAAA;QAEtE,GAAG,CAAC,IAAI,CAAC,aAAa,EAAE,KAAK,CAAC,qBAAqB,CAAC,CAAA;QACpD,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QACrC,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,KAAK,CAAC,MAAM,CAAC,CAAA;QAE3C,GAAG,CAAC,IAAI,CAAC,kBAAkB,EAAE,IAAI,CAAC,iBAAiB,CAAC,CAAA;QACpD,GAAG,CAAC,GAAG,CAAC,wBAAwB,EAAE,IAAI,CAAC,mBAAmB,CAAC,CAAA;QAE3D,GAAG,CAAC,IAAI,CAAC,SAAS,EAAE,IAAI,CAAC,UAAU,CAAC,CAAA;QAEpC,GAAG,CAAC,GAAG,CAAC,eAAe,EAAE,OAAO,CAAC,cAAc,CAAC,CAAA;QAChD,GAAG,CAAC,GAAG,CAAC,gBAAgB,EAAE,OAAO,CAAC,eAAe,CAAC,CAAA;QAElD,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAC7C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QAC3C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,UAAU,CAAC,CAAA;QACzC,GAAG,CAAC,IAAI,CAAC,kBAAkB,EAAE,QAAQ,CAAC,aAAa,CAAC,CAAA;QAEpD,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,QAAQ,CAAC,WAAW,CAAC,CAAA;QAC1C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,QAAQ,CAAC,YAAY,CAAC,CAAA;QAE3C,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,OAAO,CAAC,WAAW,CAAC,CAAA;QACzC,GAAG,CAAC,GAAG,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,CAAA;QACvC,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,OAAO,CAAC,qBAAqB,CAAC,CAAA;QACtD,GAAG,CAAC,GAAG,CAAC,UAAU,EAAE,OAAO,CAAC,gBAAgB,CAAC,CAAA;QAC7C,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,OAAO,CAAC,YAAY,CAAC,CAAA;QACtC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,OAAO,CAAC,WAAW,CAAC,CAAA;QACrC,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,OAAO,CAAC,UAAU,CAAC,CAAA;QACrC,GAAG,CAAC,GAAG,CAAC,SAAS,EAAE,OAAO,CAAC,yBAAyB,CAAC,CAAA;QACrD,GAAG,CAAC,GAAG,CAAC,aAAa,EAAE,OAAO,CAAC,eAAe,CAAC,CAAA;QAE/C,GAAG,CAAC,GAAG,CAAC,6BAA6B,EAAE,OAAO,CAAC,mBAAmB,CAAC,CAAA;QACnE,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,OAAO,CAAC,SAAS,CAAC,CAAA;QAEpC,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,OAAO,CAAC,cAAc,CAAC,CAAA;QAC5C,GAAG,CAAC,IAAI,CAAC,SAAS,EAAE,OAAO,CAAC,aAAa,CAAC,CAAA;QAC1C,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,CAAA;QAC9B,GAAG,CAAC,IAAI,CAAC,MAAM,EAAE,IAAI,CAAC,SAAS,CAAC,CAAA;QAChC,GAAG,CAAC,MAAM,CAAC,UAAU,EAAE,IAAI,CAAC,SAAS,CAAC,CAAA;QACtC,GAAG,CAAC,IAAI,CAAC,UAAU,EAAE,IAAI,CAAC,cAAc,CAAC,CAAA;QACzC,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,IAAI,CAAC,eAAe,CAAC,CAAA;QAEnD,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,aAAa,CAAC,WAAW,CAAC,CAAA;QAElD,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,KAAK,CAAC,YAAY,CAAC,CAAA;QACxC,GAAG,CAAC,GAAG,CAAC,aAAa,EAAE,KAAK,CAAC,SAAS,CAAC,CAAA;QACvC,GAAG,CAAC,GAAG,CAAC,YAAY,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QAErC,GAAG,CAAC,GAAG,CAAC,UAAU,EAAE,UAAgB,GAAQ,EAAE,GAAG;;gBAC/C,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,OAAO,CAAC,GAAG,EAAE,CAAC,CAAA;YACpC,CAAC;SAAA,CAAC,CAAA;QAEF,GAAG,CAAC,IAAI,CAAC,iBAAiB,EAAE,MAAM,CAAC,UAAU,CAAC,CAAA;QAC9C,GAAG,CAAC,IAAI,CAAC,sBAAsB,EAAE,MAAM,CAAC,cAAc,CAAC,CAAA;QACvD,GAAG,CAAC,GAAG,CAAC,iBAAiB,EAAE,MAAM,CAAC,gBAAgB,CAAC,CAAA;QAEnD,GAAG,CAAC,GAAG,CAAC,SAAS,EAAE,UAAgB,GAAQ,EAAE,GAAG;;gBAC9C,IAAI,CAAC,GAAG,CAAC,KAAK;oBAAE,OAAO,IAAA,aAAO,EAAC,GAAG,EAAE,UAAU,CAAC,CAAA;gBAC/C,MAAM,MAAM,GAAW,GAAG,CAAC,KAAK,CAAC,EAAE,CAAA;gBACnC,MAAM,KAAK,GAAc,CAAC,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC;oBACrD,KAAK,EAAE,CAAC;oBACR,KAAK,EAAE,CAAC,CAAC,WAAW,EAAE,MAAM,CAAC,CAAC;oBAC9B,KAAK,EAAE,EAAE,MAAM,EAAE;iBAClB,CAAC,CAAc,CAAA;gBAChB,MAAM,IAAI,GAAG,KAAK,IAAI,KAAK,CAAC,CAAC,CAAC,CAAA;gBAC9B,IAAI,CAAC,IAAI,EAAE;oBACT,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,WAAW,CAAC,CAAA;iBAClC;qBAAM;oBACL,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,CAAA;iBACrC;YACH,CAAC;SAAA,CAAC,CAAA;QAEF,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,CAAC,SAAS,CAAC,CAAA;QAClC,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,KAAK,CAAC,OAAO,CAAC,CAAA;QAC5C,GAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QAClC,GAAG,CAAC,GAAG,CAAC,oBAAoB,EAAE,KAAK,CAAC,UAAU,CAAC,CAAA;QAC/C,GAAG,CAAC,MAAM,CAAC,oBAAoB,EAAE,KAAK,CAAC,UAAU,CAAC,CAAA;QAClD,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,KAAK,CAAC,aAAa,CAAC,CAAA;QAE5C,YAAY;QACZ,GAAG,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAA;QAEjC,qBAAqB;QACrB,GAAG,CAAC,IAAI,CAAC,WAAW,EAAE,iBAAiB,CAAC,oBAAoB,CAAC,CAAA;QAC7D,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,iBAAiB,CAAC,oBAAoB,CAAC,CAAA;IAC9D,CAAC;CAAA;AArKD,kBAqKC;AAED,MAAM,QAAQ,GAAG,mBAAS,CAAC,aAAa,CAAA;AAC3B,QAAA,OAAO,GAAG;IACrB,CAAC,QAAQ,CAAC,WAAW,CAAC,EAAE,QAAQ,CAAC,iBAAiB;IAClD,CAAC,QAAQ,CAAC,wBAAwB,CAAC,EAAE,QAAQ,CAAC,wBAAwB;IACtE,CAAC,QAAQ,CAAC,OAAO,CAAC,EAAE,QAAQ,CAAC,cAAc;IAC3C,CAAC,QAAQ,CAAC,OAAO,CAAC,EAAE,QAAQ,CAAC,cAAc;IAC3C,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,QAAQ,CAAC,cAAc;IAClD,CAAC,QAAQ,CAAC,YAAY,CAAC,EAAE,aAAa,CAAC,mBAAmB;IAC1D,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,KAAK,CAAC,iBAAiB;IAC9C,CAAC,QAAQ,CAAC,QAAQ,CAAC,EAAE,KAAK,CAAC,eAAe;IAC1C,CAAC,QAAQ,CAAC,eAAe,CAAC,EAAE,KAAK,CAAC,qBAAqB;IACvD,CAAC,QAAQ,CAAC,aAAa,CAAC,EAAE,KAAK,CAAC,mBAAmB;IACnD,CAAC,QAAQ,CAAC,YAAY,CAAC,EAAE,KAAK,CAAC,0BAA0B;IACzD,CAAC,QAAQ,CAAC,YAAY,CAAC,EAAE,KAAK,CAAC,0BAA0B;IACzD,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,KAAK,CAAC,gBAAgB;IAC7C,CAAC,QAAQ,CAAC,WAAW,CAAC,EAAE,KAAK,CAAC,iBAAiB;IAC/C,CAAC,QAAQ,CAAC,UAAU,CAAC,EAAE,KAAK,CAAC,gBAAgB;IAC7C,CAAC,QAAQ,CAAC,MAAM,CAAC,EAAE,QAAQ,CAAC,oBAAoB;IAChD,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE,QAAQ,CAAC,gBAAgB;IAC/C,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,UAAU,CAAC,oBAAoB;IAC1D,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,UAAU,CAAC,oBAAoB;IAC1D,CAAC,QAAQ,CAAC,aAAa,CAAC,EAAE,UAAU,CAAC,mBAAmB;IACxD,CAAC,QAAQ,CAAC,YAAY,CAAC,EAAE,UAAU,CAAC,kBAAkB;IACtD,CAAC,QAAQ,CAAC,WAAW,CAAC,EAAE,IAAI,CAAC,iBAAiB;IAC9C,CAAC,QAAQ,CAAC,OAAO,CAAC,EAAE,IAAI,CAAC,aAAa;IACtC,CAAC,QAAQ,CAAC,OAAO,CAAC,EAAE,IAAI,CAAC,aAAa;IACtC,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE,aAAa,CAAC,gBAAgB;IACpD,CAAC,QAAQ,CAAC,sBAAsB,CAAC,EAAE,aAAa,CAAC,4BAA4B;IAC7E,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE,QAAQ,CAAC,YAAY;IACvC,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE,OAAO,CAAC,YAAY;IACtC,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,OAAO,CAAC,oBAAoB;CACxD,CAAA"} \ No newline at end of file diff --git a/dist/src/models/index.js b/dist/src/models/index.js index f9d26f255..312e43ecd 100644 --- a/dist/src/models/index.js +++ b/dist/src/models/index.js @@ -1,6 +1,6 @@ "use strict"; Object.defineProperty(exports, "__esModule", { value: true }); -exports.CallRecording = exports.ActionHistory = exports.RequestsTransportTokens = exports.BotMember = exports.Lsat = exports.MediaKey = exports.Accounting = exports.Bot = exports.Timer = exports.ChatBot = exports.Subscription = exports.Invite = exports.ChatMember = exports.Message = exports.Chat = exports.Contact = exports.models = exports.sequelize = void 0; +exports.GraphSubscription = exports.CallRecording = exports.ActionHistory = exports.RequestsTransportTokens = exports.BotMember = exports.Lsat = exports.MediaKey = exports.Accounting = exports.Bot = exports.Timer = exports.ChatBot = exports.Subscription = exports.Invite = exports.ChatMember = exports.Message = exports.Chat = exports.Contact = exports.models = exports.sequelize = void 0; // parse BIGINTs to number const pg = require("pg"); pg.defaults.parseInt8 = true; @@ -42,6 +42,8 @@ const actionHistory_1 = require("./sql/actionHistory"); exports.ActionHistory = actionHistory_1.default; const callRecording_1 = require("./sql/callRecording"); exports.CallRecording = callRecording_1.default; +const graphSubscription_1 = require("./sql/graphSubscription"); +exports.GraphSubscription = graphSubscription_1.default; const argv = minimist(process.argv.slice(2)); const configFile = argv.db ? path.resolve(process.cwd(), argv.db) @@ -77,6 +79,7 @@ const opts = Object.assign(Object.assign({}, config), { logging: appConfig.sql_l requestsTransportTokens_1.default, actionHistory_1.default, callRecording_1.default, + graphSubscription_1.default, ] }); if ((0, proxy_1.isProxy)()) { opts.pool = { diff --git a/dist/src/models/index.js.map b/dist/src/models/index.js.map index b2eff424b..612662910 100644 --- a/dist/src/models/index.js.map +++ b/dist/src/models/index.js.map @@ -1 +1 @@ -{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/models/index.ts"],"names":[],"mappings":";;;AAAA,0BAA0B;AAC1B,yBAAwB;AACxB,EAAE,CAAC,QAAQ,CAAC,SAAS,GAAG,IAAI,CAAA;AAC5B,+DAAgD;AAChD,6BAA4B;AAC5B,qCAA6C;AAkF3C,eAlFK,cAAI,CAkFL;AAjFN,2CAAsD;AA+EpD,kBA/EK,iBAAO,CA+EL;AA9ET,yCAAmD;AA2FjD,iBA3FK,gBAAM,CA2FL;AA1FR,2CAAsD;AAiFpD,kBAjFK,iBAAO,CAiFL;AAhFT,qDAA6C;AA0F3C,uBA1FK,sBAAY,CA0FL;AAzFd,6CAAyD;AA+FvD,mBA/FK,kBAAQ,CA+FL;AA9FV,iDAA+D;AAkF7D,qBAlFK,oBAAU,CAkFL;AAjFZ,uCAA+B;AAyF7B,gBAzFK,eAAK,CAyFL;AAxFP,mCAA0C;AAyFxC,cAzFK,aAAG,CAyFL;AAxFL,2CAAsD;AAsFpD,kBAtFK,iBAAO,CAsFL;AArFT,+CAA4D;AA4F1D,oBA5FK,mBAAS,CA4FL;AA3FX,iDAA+D;AAuF7D,qBAvFK,oBAAU,CAuFL;AAtFZ,qCAA6B;AAyF3B,eAzFK,cAAI,CAyFL;AAxFN,2EAAmE;AA0FjE,kCA1FK,iCAAuB,CA0FL;AAzFzB,qCAAoC;AACpC,4CAA4C;AAC5C,0CAAwC;AACxC,2BAAiC;AACjC,uDAAwE;AAsFtE,wBAtFK,uBAAa,CAsFL;AArFf,uDAAwE;AAuFtE,wBAvFK,uBAAa,CAuFL;AArFf,MAAM,IAAI,GAAG,QAAQ,CAAC,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAA;AAE5C,MAAM,UAAU,GAAG,IAAI,CAAC,EAAE;IACxB,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,GAAG,EAAE,EAAE,IAAI,CAAC,EAAE,CAAC;IACtC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,0BAA0B,CAAC,CAAA;AAEpD,MAAM,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC,QAAQ,IAAI,aAAa,CAAA;AAEjD,IAAI,MAAW,CAAA;AACf,MAAM,OAAO,GAAG,OAAO,CAAC,GAAG,CAAC,UAAU,CAAA;AACtC,MAAM,OAAO,GAAG,OAAO,CAAC,GAAG,CAAC,UAAU,CAAA;AACtC,IAAI,OAAO,IAAI,OAAO,EAAE;IACtB,MAAM,GAAG;QACP,OAAO;QACP,OAAO;KACR,CAAA;CACF;KAAM;IACL,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAA,iBAAY,EAAC,UAAU,CAAC,CAAC,QAAQ,EAAE,CAAC,CAAC,GAAG,CAAC,CAAA;CAC9D;AAED,MAAM,SAAS,GAAG,IAAA,mBAAU,GAAE,CAAA;AAE9B,MAAM,IAAI,mCACL,MAAM,KACT,OAAO,EAAE,SAAS,CAAC,OAAO,KAAK,MAAM,CAAC,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,KAAK,EAC3D,MAAM,EAAE;QACN,cAAI;QACJ,iBAAO;QACP,gBAAM;QACN,iBAAO;QACP,sBAAY;QACZ,kBAAQ;QACR,oBAAU;QACV,eAAK;QACL,aAAG;QACH,iBAAO;QACP,mBAAS;QACT,oBAAU;QACV,cAAI;QACJ,iCAAuB;QACvB,uBAAa;QACb,uBAAa;KACd,GACF,CAAA;AACD,IAAI,IAAA,eAAO,GAAE,EAAE;IACb,IAAI,CAAC,IAAI,GAAG;QACV,GAAG,EAAE,CAAC;QACN,GAAG,EAAE,CAAC;QACN,OAAO,EAAE,KAAK;QACd,IAAI,EAAE,KAAK;KACZ,CAAA;CACF;AAED,MAAM,SAAS,GAAG,IAAI,gCAAS,CAAC,IAAI,CAAC,CAAA;AAInC,8BAAS;AAHX,MAAM,MAAM,GAAG,SAAS,CAAC,MAAM,CAAA;AAI7B,wBAAM"} \ No newline at end of file +{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/models/index.ts"],"names":[],"mappings":";;;AAAA,0BAA0B;AAC1B,yBAAwB;AACxB,EAAE,CAAC,QAAQ,CAAC,SAAS,GAAG,IAAI,CAAA;AAC5B,+DAAgD;AAChD,6BAA4B;AAC5B,qCAA6C;AAsF3C,eAtFK,cAAI,CAsFL;AArFN,2CAAsD;AAmFpD,kBAnFK,iBAAO,CAmFL;AAlFT,yCAAmD;AA+FjD,iBA/FK,gBAAM,CA+FL;AA9FR,2CAAsD;AAqFpD,kBArFK,iBAAO,CAqFL;AApFT,qDAA6C;AA8F3C,uBA9FK,sBAAY,CA8FL;AA7Fd,6CAAyD;AAmGvD,mBAnGK,kBAAQ,CAmGL;AAlGV,iDAA+D;AAsF7D,qBAtFK,oBAAU,CAsFL;AArFZ,uCAA+B;AA6F7B,gBA7FK,eAAK,CA6FL;AA5FP,mCAA0C;AA6FxC,cA7FK,aAAG,CA6FL;AA5FL,2CAAsD;AA0FpD,kBA1FK,iBAAO,CA0FL;AAzFT,+CAA4D;AAgG1D,oBAhGK,mBAAS,CAgGL;AA/FX,iDAA+D;AA2F7D,qBA3FK,oBAAU,CA2FL;AA1FZ,qCAA6B;AA6F3B,eA7FK,cAAI,CA6FL;AA5FN,2EAAmE;AA8FjE,kCA9FK,iCAAuB,CA8FL;AA7FzB,qCAAoC;AACpC,4CAA4C;AAC5C,0CAAwC;AACxC,2BAAiC;AACjC,uDAAwE;AA0FtE,wBA1FK,uBAAa,CA0FL;AAzFf,uDAAwE;AA2FtE,wBA3FK,uBAAa,CA2FL;AA1Ff,+DAEgC;AA0F9B,4BA5FK,2BAAiB,CA4FL;AAxFnB,MAAM,IAAI,GAAG,QAAQ,CAAC,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAA;AAE5C,MAAM,UAAU,GAAG,IAAI,CAAC,EAAE;IACxB,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,GAAG,EAAE,EAAE,IAAI,CAAC,EAAE,CAAC;IACtC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,0BAA0B,CAAC,CAAA;AAEpD,MAAM,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC,QAAQ,IAAI,aAAa,CAAA;AAEjD,IAAI,MAAW,CAAA;AACf,MAAM,OAAO,GAAG,OAAO,CAAC,GAAG,CAAC,UAAU,CAAA;AACtC,MAAM,OAAO,GAAG,OAAO,CAAC,GAAG,CAAC,UAAU,CAAA;AACtC,IAAI,OAAO,IAAI,OAAO,EAAE;IACtB,MAAM,GAAG;QACP,OAAO;QACP,OAAO;KACR,CAAA;CACF;KAAM;IACL,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAA,iBAAY,EAAC,UAAU,CAAC,CAAC,QAAQ,EAAE,CAAC,CAAC,GAAG,CAAC,CAAA;CAC9D;AAED,MAAM,SAAS,GAAG,IAAA,mBAAU,GAAE,CAAA;AAE9B,MAAM,IAAI,mCACL,MAAM,KACT,OAAO,EAAE,SAAS,CAAC,OAAO,KAAK,MAAM,CAAC,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,KAAK,EAC3D,MAAM,EAAE;QACN,cAAI;QACJ,iBAAO;QACP,gBAAM;QACN,iBAAO;QACP,sBAAY;QACZ,kBAAQ;QACR,oBAAU;QACV,eAAK;QACL,aAAG;QACH,iBAAO;QACP,mBAAS;QACT,oBAAU;QACV,cAAI;QACJ,iCAAuB;QACvB,uBAAa;QACb,uBAAa;QACb,2BAAiB;KAClB,GACF,CAAA;AACD,IAAI,IAAA,eAAO,GAAE,EAAE;IACb,IAAI,CAAC,IAAI,GAAG;QACV,GAAG,EAAE,CAAC;QACN,GAAG,EAAE,CAAC;QACN,OAAO,EAAE,KAAK;QACd,IAAI,EAAE,KAAK;KACZ,CAAA;CACF;AAED,MAAM,SAAS,GAAG,IAAI,gCAAS,CAAC,IAAI,CAAC,CAAA;AAInC,8BAAS;AAHX,MAAM,MAAM,GAAG,SAAS,CAAC,MAAM,CAAA;AAI7B,wBAAM"} \ No newline at end of file diff --git a/dist/src/models/sql/graphSubscription.js b/dist/src/models/sql/graphSubscription.js new file mode 100644 index 000000000..6331b60a1 --- /dev/null +++ b/dist/src/models/sql/graphSubscription.js @@ -0,0 +1,60 @@ +"use strict"; +var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) { + var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d; + if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc); + else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r; + return c > 3 && r && Object.defineProperty(target, key, r), r; +}; +var __metadata = (this && this.__metadata) || function (k, v) { + if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v); +}; +Object.defineProperty(exports, "__esModule", { value: true }); +const sequelize_typescript_1 = require("sequelize-typescript"); +let GraphSubscription = class GraphSubscription extends sequelize_typescript_1.Model { +}; +__decorate([ + (0, sequelize_typescript_1.Column)({ + type: sequelize_typescript_1.DataType.BIGINT, + primaryKey: true, + unique: true, + autoIncrement: true, + }), + __metadata("design:type", Number) +], GraphSubscription.prototype, "id", void 0); +__decorate([ + (0, sequelize_typescript_1.Column)(sequelize_typescript_1.DataType.TEXT), + __metadata("design:type", String) +], GraphSubscription.prototype, "name", void 0); +__decorate([ + sequelize_typescript_1.Column, + __metadata("design:type", String) +], GraphSubscription.prototype, "address", void 0); +__decorate([ + (0, sequelize_typescript_1.Column)(sequelize_typescript_1.DataType.TEXT), + __metadata("design:type", String) +], GraphSubscription.prototype, "weight", void 0); +__decorate([ + sequelize_typescript_1.Column, + __metadata("design:type", Number) +], GraphSubscription.prototype, "status", void 0); +__decorate([ + sequelize_typescript_1.Column, + __metadata("design:type", String) +], GraphSubscription.prototype, "chatIds", void 0); +__decorate([ + sequelize_typescript_1.Column, + __metadata("design:type", Number) +], GraphSubscription.prototype, "tenant", void 0); +__decorate([ + sequelize_typescript_1.Column, + __metadata("design:type", Date) +], GraphSubscription.prototype, "createdAt", void 0); +__decorate([ + sequelize_typescript_1.Column, + __metadata("design:type", Date) +], GraphSubscription.prototype, "updatedAt", void 0); +GraphSubscription = __decorate([ + (0, sequelize_typescript_1.Table)({ tableName: 'sphinx_graph_subscription', underscored: true }) +], GraphSubscription); +exports.default = GraphSubscription; +//# sourceMappingURL=graphSubscription.js.map \ No newline at end of file diff --git a/dist/src/models/sql/graphSubscription.js.map b/dist/src/models/sql/graphSubscription.js.map new file mode 100644 index 000000000..5d2206597 --- /dev/null +++ b/dist/src/models/sql/graphSubscription.js.map @@ -0,0 +1 @@ +{"version":3,"file":"graphSubscription.js","sourceRoot":"","sources":["../../../../src/models/sql/graphSubscription.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,+DAAqE;AAGrE,IAAqB,iBAAiB,GAAtC,MAAqB,iBAAkB,SAAQ,4BAAwB;CAkCtE,CAAA;AA3BC;IANC,IAAA,6BAAM,EAAC;QACN,IAAI,EAAE,+BAAQ,CAAC,MAAM;QACrB,UAAU,EAAE,IAAI;QAChB,MAAM,EAAE,IAAI;QACZ,aAAa,EAAE,IAAI;KACpB,CAAC;;6CACQ;AAGV;IADC,IAAA,6BAAM,EAAC,+BAAQ,CAAC,IAAI,CAAC;;+CACV;AAGZ;IADC,6BAAM;;kDACQ;AAGf;IADC,IAAA,6BAAM,EAAC,+BAAQ,CAAC,IAAI,CAAC;;iDACR;AAId;IADC,6BAAM;;iDACO;AAId;IADC,6BAAM;;kDACQ;AAGf;IADC,6BAAM;;iDACO;AAGd;IADC,6BAAM;8BACI,IAAI;oDAAA;AAGf;IADC,6BAAM;8BACI,IAAI;oDAAA;AAjCI,iBAAiB;IADrC,IAAA,4BAAK,EAAC,EAAE,SAAS,EAAE,2BAA2B,EAAE,WAAW,EAAE,IAAI,EAAE,CAAC;GAChD,iBAAiB,CAkCrC;kBAlCoB,iBAAiB"} \ No newline at end of file diff --git a/dist/src/utils/migrate.js b/dist/src/utils/migrate.js index d73dee39e..835b03157 100644 --- a/dist/src/utils/migrate.js +++ b/dist/src/utils/migrate.js @@ -280,6 +280,25 @@ function migrate() { catch (e) { // sphinxLogger.error(['problem adding call recording table:', e.message], logging.DB) } + // add graph subscription table + try { + logger_1.sphinxLogger.info('adding graph subscription table', logger_1.logging.DB); + yield models_1.sequelize.query(` + CREATE TABLE sphinx_graph_subscription ( + id BIGINT NOT NULL PRIMARY KEY, + name TEXT, + created_at DATETIME, + updated_at DATETIME, + address TEXT, + weight TEXT, + status INTEGER, + tenant INTEGER, + chat_ids TEXT + )`); + } + catch (e) { + // sphinxLogger.error(['problem adding graph subscription table:', e.message], logging.DB) + } }); } exports.default = migrate; diff --git a/dist/src/utils/migrate.js.map b/dist/src/utils/migrate.js.map index 7068c183d..27bf09ad0 100644 --- a/dist/src/utils/migrate.js.map +++ b/dist/src/utils/migrate.js.map @@ -1 +1 @@ -{"version":3,"file":"migrate.js","sourceRoot":"","sources":["../../../src/utils/migrate.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,wCAAyC;AACzC,sCAAmD;AACnD,qCAAgD;AAChD,4CAAoC;AAEpC,SAAe,YAAY;;QACzB,IAAI;YACF,MAAM,KAAK,GAAG,CAAC,MAAM,eAAM,CAAC,IAAI,CAAC,OAAO,EAAE,CAAW,CAAA;YACrD,IAAI,GAAG,GAAG,KAAK,CAAA;YACf,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,EAAE;gBAClB,IAAI,CAAC,CAAC,MAAM,KAAK,IAAI,EAAE;oBACrB,GAAG,GAAG,IAAI,CAAA;iBACX;YACH,CAAC,CAAC,CAAA;YACF,IAAI,CAAC,GAAG;gBAAE,OAAM;YAChB,OAAO,CAAC,GAAG,CAAC,0CAA0C,CAAC,CAAA;YACvD,MAAM,IAAA,sBAAY,EAAC,KAAK,EAAE,CAAO,CAAC,EAAE,EAAE;gBACpC,IAAI,CAAC,CAAC,MAAM,KAAK,IAAI,EAAE;oBACrB,MAAM,CAAC,CAAC,MAAM,CAAC;wBACb,MAAM,EAAE,CAAC,CAAC,OAAO;4BACf,CAAC,CAAC,mBAAS,CAAC,aAAa,CAAC,IAAI;4BAC9B,CAAC,CAAC,mBAAS,CAAC,aAAa,CAAC,GAAG;qBAChC,CAAC,CAAA;iBACH;YACH,CAAC,CAAA,CAAC,CAAA;YACF,OAAO,CAAC,GAAG,CAAC,qDAAqD,CAAC,CAAA;SACnE;QAAC,OAAO,CAAC,EAAE;YACV,OAAO,CAAC,GAAG,CAAC,wBAAwB,EAAE,CAAC,CAAC,CAAA;SACzC;IACH,CAAC;CAAA;AAED,SAAe,oBAAoB;;QACjC,MAAM,eAAM,CAAC,uBAAuB,CAAC,OAAO,CAAC;YAC3C,QAAQ,EAAE,IAAI;SACf,CAAC,CAAA;IACJ,CAAC;CAAA;AAED,SAA8B,OAAO;;QACnC,cAAc,CAAC,iBAAiB,EAAE,gBAAgB,EAAE,QAAQ,CAAC,CAAA;QAC7D,MAAM,oBAAoB,EAAE,CAAA;QAC5B,cAAc,CAAC,iBAAiB,EAAE,UAAU,EAAE,SAAS,CAAC,CAAA;QAExD,cAAc,CAAC,cAAc,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAA;QAElD,MAAM,YAAY,EAAE,CAAA;QAEpB,cAAc,CAAC,iBAAiB,EAAE,MAAM,EAAE,SAAS,CAAC,CAAA;QAEpD,cAAc,CAAC,iBAAiB,EAAE,gBAAgB,EAAE,SAAS,CAAC,CAAA;QAC9D,cAAc,CAAC,iBAAiB,EAAE,QAAQ,EAAE,MAAM,CAAC,CAAA;QAEnD,cAAc,CAAC,iBAAiB,EAAE,iBAAiB,CAAC,CAAA;QACpD,cAAc,CAAC,iBAAiB,EAAE,eAAe,CAAC,CAAA;QAElD,cAAc,CAAC,iBAAiB,EAAE,UAAU,CAAC,CAAA;QAE7C,cAAc,CAAC,cAAc,EAAE,WAAW,EAAE,KAAK,CAAC,CAAA;QAElD,cAAc,CAAC,iBAAiB,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;QAEvD,cAAc,CAAC,iBAAiB,EAAE,eAAe,EAAE,QAAQ,CAAC,CAAA;QAC5D,cAAc,CAAC,iBAAiB,EAAE,OAAO,EAAE,SAAS,CAAC,CAAA;QACrD,cAAc,CAAC,iBAAiB,EAAE,aAAa,EAAE,MAAM,CAAC,CAAA;QAExD,cAAc,CAAC,cAAc,EAAE,sBAAsB,EAAE,SAAS,CAAC,CAAA;QAEjE,cAAc,CAAC,cAAc,EAAE,KAAK,CAAC,CAAA;QACrC,cAAc,CAAC,cAAc,EAAE,iBAAiB,EAAE,MAAM,CAAC,CAAA;QACzD,cAAc,CAAC,qBAAqB,EAAE,cAAc,EAAE,QAAQ,CAAC,CAAA;QAC/D,cAAc,CAAC,qBAAqB,EAAE,YAAY,EAAE,QAAQ,CAAC,CAAA;QAE7D,SAAS,CAAC,qBAAqB,CAAC,CAAA;QAChC,SAAS,CAAC,cAAc,CAAC,CAAA;QACzB,SAAS,CAAC,aAAa,CAAC,CAAA;QACxB,SAAS,CAAC,iBAAiB,CAAC,CAAA;QAC5B,SAAS,CAAC,iBAAiB,CAAC,CAAA;QAC5B,SAAS,CAAC,oBAAoB,CAAC,CAAA;QAC/B,SAAS,CAAC,kBAAkB,CAAC,CAAA;QAC7B,SAAS,CAAC,gBAAgB,CAAC,CAAA;QAC3B,SAAS,CAAC,mBAAmB,CAAC,CAAA;QAC9B,SAAS,CAAC,sBAAsB,CAAC,CAAA;QACjC,SAAS,CAAC,eAAe,CAAC,CAAA;QAE1B,cAAc,CAAC,iBAAiB,EAAE,YAAY,CAAC,CAAA;QAC/C,cAAc,CAAC,kBAAkB,EAAE,sBAAsB,CAAC,CAAA;QAC1D,cAAc,CAAC,oBAAoB,EAAE,YAAY,CAAC,CAAA;QAElD,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;;;;MAcpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,oBAAoB,EAAE,cAAc,CAAC,CAAA;QAEpD,cAAc,CAAC,oBAAoB,EAAE,cAAc,CAAC,CAAA;QACpD,cAAc,CAAC,oBAAoB,EAAE,YAAY,EAAE,QAAQ,CAAC,CAAA;QAC5D,cAAc,CAAC,oBAAoB,EAAE,eAAe,EAAE,QAAQ,CAAC,CAAA;QAC/D,cAAc,CAAC,oBAAoB,EAAE,gBAAgB,EAAE,QAAQ,CAAC,CAAA;QAChE,cAAc,CAAC,oBAAoB,EAAE,cAAc,EAAE,QAAQ,CAAC,CAAA;QAE9D,cAAc,CAAC,qBAAqB,EAAE,YAAY,CAAC,CAAA;QAEnD,cAAc,CAAC,cAAc,EAAE,cAAc,CAAC,CAAA;QAC9C,cAAc,CAAC,cAAc,EAAE,UAAU,CAAC,CAAA;QAE1C,cAAc,CAAC,iBAAiB,EAAE,YAAY,CAAC,CAAA;QAE/C,cAAc,CAAC,iBAAiB,EAAE,cAAc,EAAE,SAAS,CAAC,CAAA;QAE5D,cAAc,CAAC,iBAAiB,EAAE,WAAW,EAAE,SAAS,CAAC,CAAA;QAEzD,cAAc,CAAC,cAAc,EAAE,MAAM,CAAC,CAAA;QAEtC,cAAc,CAAC,iBAAiB,EAAE,YAAY,EAAE,QAAQ,CAAC,CAAA;QAEzD,cAAc,CAAC,iBAAiB,EAAE,aAAa,EAAE,UAAU,CAAC,CAAA;QAE5D,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;;;MAapB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CACnB,4EAA4E,CAC7E,CAAA;SACF;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,aAAa,EAAE,SAAS,CAAC,CAAA;QACxC,cAAc,CAAC,aAAa,EAAE,MAAM,CAAC,CAAA;QACrC,cAAc,CAAC,aAAa,EAAE,eAAe,EAAE,KAAK,CAAC,CAAA;QAErD,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;MAQpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,oBAAoB,EAAE,QAAQ,CAAC,CAAA;QAE9C,UAAU;QAEV,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;MAOpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,cAAc,EAAE,SAAS,CAAC,CAAA;QACzC,cAAc,CAAC,cAAc,EAAE,UAAU,CAAC,CAAA;QAE1C,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CACnB,oFAAoF,CACrF,CAAA;SACF;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,cAAc,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;QACpD,cAAc,CAAC,cAAc,EAAE,UAAU,EAAE,SAAS,CAAC,CAAA;QACrD,cAAc,CAAC,qBAAqB,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAA;QAEzD,cAAc,CAAC,cAAc,EAAE,MAAM,EAAE,SAAS,CAAC,CAAA;QAEjD,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CACnB,+DAA+D,CAChE,CAAA;SACF;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,iBAAiB,EAAE,oBAAoB,CAAC,CAAA;QACvD,cAAc,CAAC,iBAAiB,EAAE,YAAY,EAAE,SAAS,CAAC,CAAA;QAC1D,cAAc,CAAC,iBAAiB,EAAE,eAAe,EAAE,SAAS,CAAC,CAAA;QAE7D,cAAc,CAAC,cAAc,EAAE,eAAe,EAAE,QAAQ,CAAC,CAAA;QACzD,cAAc,CAAC,cAAc,EAAE,eAAe,EAAE,QAAQ,CAAC,CAAA;QAEzD,iBAAiB;QACjB,IAAI;YACF,qBAAY,CAAC,IAAI,CAAC,mBAAmB,EAAE,gBAAO,CAAC,EAAE,CAAC,CAAA;YAClD,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;;;MAapB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,4EAA4E;SAC7E;QAED,oCAAoC;QACpC,cAAc,CAAC,cAAc,EAAE,QAAQ,EAAE,KAAK,CAAC,CAAA;QAE/C,kCAAkC;QAClC,IAAI;YACF,qBAAY,CAAC,IAAI,CAAC,sCAAsC,EAAE,gBAAO,CAAC,EAAE,CAAC,CAAA;YACrE,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;MAMpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,0BAA0B;QAC1B,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;MAQpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QACD,cAAc,CAAC,uBAAuB,EAAE,aAAa,EAAE,KAAK,CAAC,CAAA;QAC7D,cAAc,CAAC,cAAc,EAAE,gBAAgB,EAAE,KAAK,CAAC,CAAA;QACvD,cAAc,CAAC,cAAc,EAAE,sBAAsB,EAAE,MAAM,CAAC,CAAA;QAC9D,cAAc,CAAC,cAAc,EAAE,cAAc,EAAE,MAAM,CAAC,CAAA;QACtD,cAAc,CAAC,cAAc,EAAE,kBAAkB,EAAE,MAAM,CAAC,CAAA;QAC1D,cAAc,CAAC,cAAc,EAAE,kBAAkB,EAAE,MAAM,CAAC,CAAA;QAE1D,2BAA2B;QAE3B,IAAI;YACF,qBAAY,CAAC,IAAI,CAAC,6BAA6B,EAAE,gBAAO,CAAC,EAAE,CAAC,CAAA;YAC5D,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;;;MAapB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,sFAAsF;SACvF;IACH,CAAC;CAAA;AA7QD,0BA6QC;AAED,SAAe,SAAS,CAAC,SAAS;;QAChC,MAAM,cAAc,CAAC,SAAS,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAA;QACnD,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CACnB,UAAU,SAAS,oCAAoC,CACxD,CAAA;SACF;QAAC,OAAO,CAAC,EAAE;YACV,oCAAoC;SACrC;IACH,CAAC;CAAA;AAED,SAAe,cAAc,CAAC,KAAa,EAAE,MAAc,EAAE,IAAI,GAAG,MAAM;;QACxE,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC,eAAe,KAAK,QAAQ,MAAM,IAAI,IAAI,EAAE,CAAC,CAAA;SACpE;QAAC,OAAO,CAAC,EAAE;YACV,2DAA2D;SAC5D;IACH,CAAC;CAAA"} \ No newline at end of file +{"version":3,"file":"migrate.js","sourceRoot":"","sources":["../../../src/utils/migrate.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,wCAAyC;AACzC,sCAAmD;AACnD,qCAAgD;AAChD,4CAAoC;AAEpC,SAAe,YAAY;;QACzB,IAAI;YACF,MAAM,KAAK,GAAG,CAAC,MAAM,eAAM,CAAC,IAAI,CAAC,OAAO,EAAE,CAAW,CAAA;YACrD,IAAI,GAAG,GAAG,KAAK,CAAA;YACf,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,EAAE;gBAClB,IAAI,CAAC,CAAC,MAAM,KAAK,IAAI,EAAE;oBACrB,GAAG,GAAG,IAAI,CAAA;iBACX;YACH,CAAC,CAAC,CAAA;YACF,IAAI,CAAC,GAAG;gBAAE,OAAM;YAChB,OAAO,CAAC,GAAG,CAAC,0CAA0C,CAAC,CAAA;YACvD,MAAM,IAAA,sBAAY,EAAC,KAAK,EAAE,CAAO,CAAC,EAAE,EAAE;gBACpC,IAAI,CAAC,CAAC,MAAM,KAAK,IAAI,EAAE;oBACrB,MAAM,CAAC,CAAC,MAAM,CAAC;wBACb,MAAM,EAAE,CAAC,CAAC,OAAO;4BACf,CAAC,CAAC,mBAAS,CAAC,aAAa,CAAC,IAAI;4BAC9B,CAAC,CAAC,mBAAS,CAAC,aAAa,CAAC,GAAG;qBAChC,CAAC,CAAA;iBACH;YACH,CAAC,CAAA,CAAC,CAAA;YACF,OAAO,CAAC,GAAG,CAAC,qDAAqD,CAAC,CAAA;SACnE;QAAC,OAAO,CAAC,EAAE;YACV,OAAO,CAAC,GAAG,CAAC,wBAAwB,EAAE,CAAC,CAAC,CAAA;SACzC;IACH,CAAC;CAAA;AAED,SAAe,oBAAoB;;QACjC,MAAM,eAAM,CAAC,uBAAuB,CAAC,OAAO,CAAC;YAC3C,QAAQ,EAAE,IAAI;SACf,CAAC,CAAA;IACJ,CAAC;CAAA;AAED,SAA8B,OAAO;;QACnC,cAAc,CAAC,iBAAiB,EAAE,gBAAgB,EAAE,QAAQ,CAAC,CAAA;QAC7D,MAAM,oBAAoB,EAAE,CAAA;QAC5B,cAAc,CAAC,iBAAiB,EAAE,UAAU,EAAE,SAAS,CAAC,CAAA;QAExD,cAAc,CAAC,cAAc,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAA;QAElD,MAAM,YAAY,EAAE,CAAA;QAEpB,cAAc,CAAC,iBAAiB,EAAE,MAAM,EAAE,SAAS,CAAC,CAAA;QAEpD,cAAc,CAAC,iBAAiB,EAAE,gBAAgB,EAAE,SAAS,CAAC,CAAA;QAC9D,cAAc,CAAC,iBAAiB,EAAE,QAAQ,EAAE,MAAM,CAAC,CAAA;QAEnD,cAAc,CAAC,iBAAiB,EAAE,iBAAiB,CAAC,CAAA;QACpD,cAAc,CAAC,iBAAiB,EAAE,eAAe,CAAC,CAAA;QAElD,cAAc,CAAC,iBAAiB,EAAE,UAAU,CAAC,CAAA;QAE7C,cAAc,CAAC,cAAc,EAAE,WAAW,EAAE,KAAK,CAAC,CAAA;QAElD,cAAc,CAAC,iBAAiB,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;QAEvD,cAAc,CAAC,iBAAiB,EAAE,eAAe,EAAE,QAAQ,CAAC,CAAA;QAC5D,cAAc,CAAC,iBAAiB,EAAE,OAAO,EAAE,SAAS,CAAC,CAAA;QACrD,cAAc,CAAC,iBAAiB,EAAE,aAAa,EAAE,MAAM,CAAC,CAAA;QAExD,cAAc,CAAC,cAAc,EAAE,sBAAsB,EAAE,SAAS,CAAC,CAAA;QAEjE,cAAc,CAAC,cAAc,EAAE,KAAK,CAAC,CAAA;QACrC,cAAc,CAAC,cAAc,EAAE,iBAAiB,EAAE,MAAM,CAAC,CAAA;QACzD,cAAc,CAAC,qBAAqB,EAAE,cAAc,EAAE,QAAQ,CAAC,CAAA;QAC/D,cAAc,CAAC,qBAAqB,EAAE,YAAY,EAAE,QAAQ,CAAC,CAAA;QAE7D,SAAS,CAAC,qBAAqB,CAAC,CAAA;QAChC,SAAS,CAAC,cAAc,CAAC,CAAA;QACzB,SAAS,CAAC,aAAa,CAAC,CAAA;QACxB,SAAS,CAAC,iBAAiB,CAAC,CAAA;QAC5B,SAAS,CAAC,iBAAiB,CAAC,CAAA;QAC5B,SAAS,CAAC,oBAAoB,CAAC,CAAA;QAC/B,SAAS,CAAC,kBAAkB,CAAC,CAAA;QAC7B,SAAS,CAAC,gBAAgB,CAAC,CAAA;QAC3B,SAAS,CAAC,mBAAmB,CAAC,CAAA;QAC9B,SAAS,CAAC,sBAAsB,CAAC,CAAA;QACjC,SAAS,CAAC,eAAe,CAAC,CAAA;QAE1B,cAAc,CAAC,iBAAiB,EAAE,YAAY,CAAC,CAAA;QAC/C,cAAc,CAAC,kBAAkB,EAAE,sBAAsB,CAAC,CAAA;QAC1D,cAAc,CAAC,oBAAoB,EAAE,YAAY,CAAC,CAAA;QAElD,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;;;;MAcpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,oBAAoB,EAAE,cAAc,CAAC,CAAA;QAEpD,cAAc,CAAC,oBAAoB,EAAE,cAAc,CAAC,CAAA;QACpD,cAAc,CAAC,oBAAoB,EAAE,YAAY,EAAE,QAAQ,CAAC,CAAA;QAC5D,cAAc,CAAC,oBAAoB,EAAE,eAAe,EAAE,QAAQ,CAAC,CAAA;QAC/D,cAAc,CAAC,oBAAoB,EAAE,gBAAgB,EAAE,QAAQ,CAAC,CAAA;QAChE,cAAc,CAAC,oBAAoB,EAAE,cAAc,EAAE,QAAQ,CAAC,CAAA;QAE9D,cAAc,CAAC,qBAAqB,EAAE,YAAY,CAAC,CAAA;QAEnD,cAAc,CAAC,cAAc,EAAE,cAAc,CAAC,CAAA;QAC9C,cAAc,CAAC,cAAc,EAAE,UAAU,CAAC,CAAA;QAE1C,cAAc,CAAC,iBAAiB,EAAE,YAAY,CAAC,CAAA;QAE/C,cAAc,CAAC,iBAAiB,EAAE,cAAc,EAAE,SAAS,CAAC,CAAA;QAE5D,cAAc,CAAC,iBAAiB,EAAE,WAAW,EAAE,SAAS,CAAC,CAAA;QAEzD,cAAc,CAAC,cAAc,EAAE,MAAM,CAAC,CAAA;QAEtC,cAAc,CAAC,iBAAiB,EAAE,YAAY,EAAE,QAAQ,CAAC,CAAA;QAEzD,cAAc,CAAC,iBAAiB,EAAE,aAAa,EAAE,UAAU,CAAC,CAAA;QAE5D,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;;;MAapB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CACnB,4EAA4E,CAC7E,CAAA;SACF;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,aAAa,EAAE,SAAS,CAAC,CAAA;QACxC,cAAc,CAAC,aAAa,EAAE,MAAM,CAAC,CAAA;QACrC,cAAc,CAAC,aAAa,EAAE,eAAe,EAAE,KAAK,CAAC,CAAA;QAErD,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;MAQpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,oBAAoB,EAAE,QAAQ,CAAC,CAAA;QAE9C,UAAU;QAEV,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;MAOpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,cAAc,EAAE,SAAS,CAAC,CAAA;QACzC,cAAc,CAAC,cAAc,EAAE,UAAU,CAAC,CAAA;QAE1C,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CACnB,oFAAoF,CACrF,CAAA;SACF;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,cAAc,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;QACpD,cAAc,CAAC,cAAc,EAAE,UAAU,EAAE,SAAS,CAAC,CAAA;QACrD,cAAc,CAAC,qBAAqB,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAA;QAEzD,cAAc,CAAC,cAAc,EAAE,MAAM,EAAE,SAAS,CAAC,CAAA;QAEjD,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CACnB,+DAA+D,CAChE,CAAA;SACF;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,cAAc,CAAC,iBAAiB,EAAE,oBAAoB,CAAC,CAAA;QACvD,cAAc,CAAC,iBAAiB,EAAE,YAAY,EAAE,SAAS,CAAC,CAAA;QAC1D,cAAc,CAAC,iBAAiB,EAAE,eAAe,EAAE,SAAS,CAAC,CAAA;QAE7D,cAAc,CAAC,cAAc,EAAE,eAAe,EAAE,QAAQ,CAAC,CAAA;QACzD,cAAc,CAAC,cAAc,EAAE,eAAe,EAAE,QAAQ,CAAC,CAAA;QAEzD,iBAAiB;QACjB,IAAI;YACF,qBAAY,CAAC,IAAI,CAAC,mBAAmB,EAAE,gBAAO,CAAC,EAAE,CAAC,CAAA;YAClD,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;;;MAapB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,4EAA4E;SAC7E;QAED,oCAAoC;QACpC,cAAc,CAAC,cAAc,EAAE,QAAQ,EAAE,KAAK,CAAC,CAAA;QAE/C,kCAAkC;QAClC,IAAI;YACF,qBAAY,CAAC,IAAI,CAAC,sCAAsC,EAAE,gBAAO,CAAC,EAAE,CAAC,CAAA;YACrE,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;MAMpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QAED,0BAA0B;QAC1B,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;MAQpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,iBAAiB;SAClB;QACD,cAAc,CAAC,uBAAuB,EAAE,aAAa,EAAE,KAAK,CAAC,CAAA;QAC7D,cAAc,CAAC,cAAc,EAAE,gBAAgB,EAAE,KAAK,CAAC,CAAA;QACvD,cAAc,CAAC,cAAc,EAAE,sBAAsB,EAAE,MAAM,CAAC,CAAA;QAC9D,cAAc,CAAC,cAAc,EAAE,cAAc,EAAE,MAAM,CAAC,CAAA;QACtD,cAAc,CAAC,cAAc,EAAE,kBAAkB,EAAE,MAAM,CAAC,CAAA;QAC1D,cAAc,CAAC,cAAc,EAAE,kBAAkB,EAAE,MAAM,CAAC,CAAA;QAE1D,2BAA2B;QAE3B,IAAI;YACF,qBAAY,CAAC,IAAI,CAAC,6BAA6B,EAAE,gBAAO,CAAC,EAAE,CAAC,CAAA;YAC5D,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;;;MAapB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,sFAAsF;SACvF;QAED,+BAA+B;QAC/B,IAAI;YACF,qBAAY,CAAC,IAAI,CAAC,iCAAiC,EAAE,gBAAO,CAAC,EAAE,CAAC,CAAA;YAChE,MAAM,kBAAS,CAAC,KAAK,CAAC;;;;;;;;;;;MAWpB,CAAC,CAAA;SACJ;QAAC,OAAO,CAAC,EAAE;YACV,0FAA0F;SAC3F;IACH,CAAC;CAAA;AAhSD,0BAgSC;AAED,SAAe,SAAS,CAAC,SAAS;;QAChC,MAAM,cAAc,CAAC,SAAS,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAA;QACnD,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CACnB,UAAU,SAAS,oCAAoC,CACxD,CAAA;SACF;QAAC,OAAO,CAAC,EAAE;YACV,oCAAoC;SACrC;IACH,CAAC;CAAA;AAED,SAAe,cAAc,CAAC,KAAa,EAAE,MAAc,EAAE,IAAI,GAAG,MAAM;;QACxE,IAAI;YACF,MAAM,kBAAS,CAAC,KAAK,CAAC,eAAe,KAAK,QAAQ,MAAM,IAAI,IAAI,EAAE,CAAC,CAAA;SACpE;QAAC,OAAO,CAAC,EAAE;YACV,2DAA2D;SAC5D;IACH,CAAC;CAAA"} \ No newline at end of file diff --git a/src/controllers/graphSubscription.ts b/src/controllers/graphSubscription.ts new file mode 100644 index 000000000..f35754ec3 --- /dev/null +++ b/src/controllers/graphSubscription.ts @@ -0,0 +1,81 @@ +import { GraphSubscriptionRecord, models, Lsat } from '../models' +import { Req } from '../types' +import { Response } from 'express' +import { failure, success } from '../utils/res' +import { logging, sphinxLogger } from '../utils/logger' + +export async function addGraphSubscription( + req: Req, + res: Response +): Promise { + if (!req.owner) return failure(res, 'no owner') + const tenant: number = req.owner.id + + sphinxLogger.info(`=> saveLsat`, logging.Express) + + const { name, address, weight, status } = req.body + let { chatIds } = req.body + if (!name || !address || !weight) { + return failure(res, 'Missing required Graph Subscription data') + } + + if (typeof status !== 'number' || status > 1) { + return failure(res, 'Provide valid graph status') + } + + if (chatIds !== 'all' && !Array.isArray(chatIds)) { + return failure(res, 'Provide valid tribe Id') + } + + if (Array.isArray(chatIds)) { + chatIds = JSON.stringify(chatIds) + } + + try { + await models.GraphSubscription.create({ + name, + address, + weight, + status, + chatIds, + tenant, + }) + return success(res, 'Graph Subscription added successfully') + } catch (error) { + console.log(error) + return failure(res, 'An internal error occured') + } +} + +export async function getGraphSubscription( + req: Req, + res: Response +): Promise { + if (!req.owner) return failure(res, 'no owner') + try { + const graphs = + (await models.GraphSubscription.findAll()) as GraphSubscriptionRecord[] + + const newGraphs: { + client_name: string + prediction_endpoint: string + lsat: string + }[] = [] + for (let i = 0; i < graphs.length; i++) { + const graph = graphs[i] + const lsat = (await models.Lsat.findOne({ + where: { paths: graph.address, status: 1 }, + })) as Lsat + const obj = { + client_name: graph.name, + prediction_endpoint: graph.address, + lsat: lsat ? `${lsat.macaroon}:${lsat.preimage}` : '', + } + newGraphs.push(obj) + } + return success(res, newGraphs) + } catch (error) { + console.log(error) + return failure(res, 'An internal error occured') + } +} diff --git a/src/controllers/index.ts b/src/controllers/index.ts index f21c1a2d8..2feca40c5 100644 --- a/src/controllers/index.ts +++ b/src/controllers/index.ts @@ -27,6 +27,7 @@ import * as lsats from './lsats' import { Req } from '../types' import * as action from './actionHistory' import * as feeds from './getFeeds' +import * as graphSubscription from './graphSubscription' export async function set(app) { builtInBots.init() @@ -189,6 +190,10 @@ export async function set(app) { // Get feeds app.get('/feeds', feeds.getFeeds) + + // Graph Subscription + app.post('/addGraph', graphSubscription.addGraphSubscription) + app.get('/getGraph', graphSubscription.getGraphSubscription) } const msgtypes = constants.message_types diff --git a/src/models/index.ts b/src/models/index.ts index d17ad86d5..9d7b0d2eb 100644 --- a/src/models/index.ts +++ b/src/models/index.ts @@ -23,6 +23,9 @@ import { isProxy } from '../utils/proxy' import { readFileSync } from 'fs' import ActionHistory, { ActionHistoryRecord } from './sql/actionHistory' import CallRecording, { CallRecordingRecord } from './sql/callRecording' +import GraphSubscription, { + GraphSubscriptionRecord, +} from './sql/graphSubscription' const argv = minimist(process.argv.slice(2)) @@ -66,6 +69,7 @@ const opts = { RequestsTransportTokens, ActionHistory, CallRecording, + GraphSubscription, ], } if (isProxy()) { @@ -111,4 +115,6 @@ export { ActionHistoryRecord, CallRecording, CallRecordingRecord, + GraphSubscription, + GraphSubscriptionRecord, } diff --git a/src/models/sql/graphSubscription.ts b/src/models/sql/graphSubscription.ts new file mode 100644 index 000000000..8e945ce3e --- /dev/null +++ b/src/models/sql/graphSubscription.ts @@ -0,0 +1,42 @@ +import { Table, Column, Model, DataType } from 'sequelize-typescript' + +@Table({ tableName: 'sphinx_graph_subscription', underscored: true }) +export default class GraphSubscription extends Model { + @Column({ + type: DataType.BIGINT, + primaryKey: true, + unique: true, + autoIncrement: true, + }) + id: number + + @Column(DataType.TEXT) + name: string + + @Column + address: string + + @Column(DataType.TEXT) + weight: string + + // This would either be 1 or 0 + @Column + status: number + + // The value of this could be ALL or an Array of tribes IDs + @Column + chatIds: string + + @Column + tenant: number + + @Column + createdAt: Date + + @Column + updatedAt: Date +} + +export interface GraphSubscriptionRecord extends GraphSubscription { + dataValues: GraphSubscription +} diff --git a/src/utils/migrate.ts b/src/utils/migrate.ts index bf39e0cd7..4534b5d76 100644 --- a/src/utils/migrate.ts +++ b/src/utils/migrate.ts @@ -304,6 +304,25 @@ export default async function migrate(): Promise { } catch (e) { // sphinxLogger.error(['problem adding call recording table:', e.message], logging.DB) } + + // add graph subscription table + try { + sphinxLogger.info('adding graph subscription table', logging.DB) + await sequelize.query(` + CREATE TABLE sphinx_graph_subscription ( + id BIGINT NOT NULL PRIMARY KEY, + name TEXT, + created_at DATETIME, + updated_at DATETIME, + address TEXT, + weight TEXT, + status INTEGER, + tenant INTEGER, + chat_ids TEXT + )`) + } catch (e) { + // sphinxLogger.error(['problem adding graph subscription table:', e.message], logging.DB) + } } async function addTenant(tableName) {