Remove payInvoiceList endpoint sync

Author: ZIMkaRU

workers/loc.api/bfx.api.router/index.js

@@ -41,7 +41,6 @@ class BfxApiRouter extends BaseBfxApiRouter {
       ['positionsAudit', 90],
       ['wallets', 90],
       ['ledgers', 90],
-      ['payInvoiceList', 90],
       ['accountTrades', 90],
       ['fundingTrades', 90],
       ['trades', 10],

workers/loc.api/service.report.framework.js

@@ -718,28 +718,6 @@ class FrameworkReportService extends ReportService {
     }, 'getLedgers', args, cb)
   }
 
-  /**
-   * @override
-   */
-  getPayInvoiceList (space, args, cb) {
-    return this._privResponder(async () => {
-      if (!await this.isSyncModeWithDbData(space, args)) {
-        return this._subAccountApiData
-          .getDataForSubAccount(
-            (args) => super.getPayInvoiceList(space, args),
-            args,
-            { datePropName: 't' }
-          )
-      }
-
-      return this._dao.findInCollBy(
-        this._SYNC_API_METHODS.PAY_INVOICE_LIST,
-        args,
-        { isPrepareResponse: true, shouldParamsBeVerified: true }
-      )
-    }, 'getPayInvoiceList', args, cb)
-  }
-
   /**
    * @override
    */

workers/loc.api/service.report.js

@@ -19,10 +19,6 @@ class ReportService extends BaseReportService {
     return super.getLedgers(null, args)
   }
 
-  [SYNC_API_METHODS.PAY_INVOICE_LIST] (args) {
-    return super.getPayInvoiceList(null, args)
-  }
-
   [SYNC_API_METHODS.TRADES] (args) {
     return super.getTrades(null, args)
   }

workers/loc.api/sync/dao/db-migrations/sqlite-migrations/migration.v33.js

@@ -0,0 +1,87 @@
+'use strict'
+
+/*
+ * CREATED_AT: 2025-09-19T07:32:50.867Z
+ * VERSION: v43
+ */
+
+const AbstractMigration = require('./abstract.migration')
+
+class MigrationV43 extends AbstractMigration {
+  /**
+   * @override
+   */
+  up () {
+    const sqlArr = [
+      'DROP TABLE payInvoiceList'
+    ]
+
+    this.addSql(sqlArr)
+  }
+
+  /**
+   * @override
+   */
+  down () {
+    const sqlArr = [
+      `CREATE TABLE payInvoiceList (
+        _id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, 
+        id VARCHAR(255), 
+        t BIGINT, 
+        duration INT, 
+        amount DECIMAL(22,12), 
+        currency VARCHAR(255), 
+        orderId VARCHAR(255), 
+        payCurrencies TEXT, 
+        webhook VARCHAR(255), 
+        redirectUrl VARCHAR(255), 
+        status VARCHAR(255), 
+        customerInfo TEXT, 
+        invoices TEXT, 
+        payment TEXT, 
+        merchantName VARCHAR(255), 
+        subUserId INT, 
+        user_id INT NOT NULL, 
+        CONSTRAINT payInvoiceList_fk_user_id
+          FOREIGN KEY (user_id)
+          REFERENCES users(_id)
+          ON UPDATE CASCADE
+          ON DELETE CASCADE, 
+        CONSTRAINT payInvoiceList_fk_subUserId
+          FOREIGN KEY (subUserId)
+          REFERENCES users(_id)
+          ON UPDATE CASCADE
+          ON DELETE CASCADE
+      )`,
+
+      `CREATE UNIQUE INDEX payInvoiceList_id_user_id
+        ON payInvoiceList(id, user_id)`,
+      `CREATE INDEX payInvoiceList_user_id_currency_t
+        ON payInvoiceList(user_id, currency, t)`,
+      `CREATE INDEX payInvoiceList_user_id_id_t
+        ON payInvoiceList(user_id, id, t)`,
+      `CREATE INDEX payInvoiceList_user_id_t
+        ON payInvoiceList(user_id, t)`,
+      `CREATE INDEX payInvoiceList_user_id_subUserId_t
+        ON payInvoiceList(user_id, subUserId, t) 
+        WHERE subUserId IS NOT NULL`,
+      `CREATE INDEX payInvoiceList_subUserId_id
+        ON payInvoiceList(subUserId, id) 
+        WHERE subUserId IS NOT NULL`
+    ]
+
+    this.addSql(sqlArr)
+  }
+
+  /**
+   * @override
+   */
+  before () { return this.dao.disableForeignKeys() }
+
+  /**
+   * @override
+   */
+  after () { return this.dao.enableForeignKeys() }
+}
+
+module.exports = MigrationV43

workers/loc.api/sync/dao/db-migrations/sqlite-migrations/migration.v43.1758267170867.js

@@ -28,6 +28,5 @@ module.exports = {
   CANDLES: TABLES_NAMES.CANDLES,
   STATUS_MESSAGES: TABLES_NAMES.STATUS_MESSAGES,
   LOGINS: TABLES_NAMES.LOGINS,
-  CHANGE_LOGS: TABLES_NAMES.CHANGE_LOGS,
-  PAY_INVOICE_LIST: TABLES_NAMES.PAY_INVOICE_LIST
+  CHANGE_LOGS: TABLES_NAMES.CHANGE_LOGS
 }

workers/loc.api/sync/schema/allowed.colls.js

@@ -7,7 +7,7 @@
  * in the `workers/loc.api/sync/dao/db-migrations/sqlite-migrations` folder,
  * e.g. `migration.v1.js`, where `v1` is `SUPPORTED_DB_VERSION`
  */
-const SUPPORTED_DB_VERSION = 42
+const SUPPORTED_DB_VERSION = 43
 
 const TABLES_NAMES = require('../tables-names')
 
@@ -26,7 +26,6 @@ const positionsHistory = require('./positions-history')
 const positionsSnapshot = require('./positions-snapshot')
 const logins = require('./logins')
 const changeLogs = require('./change-logs')
-const payInvoiceList = require('./pay-invoice-list')
 const tickersHistory = require('./tickers-history')
 const statusMessages = require('./status-messages')
 const publicCollsConf = require('./public-colls-conf')
@@ -60,7 +59,6 @@ const models = new Map([
   [TABLES_NAMES.POSITIONS_SNAPSHOT, positionsSnapshot],
   [TABLES_NAMES.LOGINS, logins],
   [TABLES_NAMES.CHANGE_LOGS, changeLogs],
-  [TABLES_NAMES.PAY_INVOICE_LIST, payInvoiceList],
   [TABLES_NAMES.TICKERS_HISTORY, tickersHistory],
   [TABLES_NAMES.STATUS_MESSAGES, statusMessages],
   [TABLES_NAMES.PUBLIC_COLLS_CONF, publicCollsConf],

workers/loc.api/sync/schema/models/index.js

@@ -16,7 +16,6 @@ const positionsHistory = require('./positions-history')
 const positionsSnapshot = require('./positions-snapshot')
 const logins = require('./logins')
 const changeLogs = require('./change-logs')
-const payInvoiceList = require('./pay-invoice-list')
 const tickersHistory = require('./tickers-history')
 const wallets = require('./wallets')
 const symbols = require('./symbols')
@@ -43,7 +42,6 @@ const _methodCollMap = new Map([
   [SYNC_API_METHODS.POSITIONS_SNAPSHOT, positionsSnapshot],
   [SYNC_API_METHODS.LOGINS, logins],
   [SYNC_API_METHODS.CHANGE_LOGS, changeLogs],
-  [SYNC_API_METHODS.PAY_INVOICE_LIST, payInvoiceList],
   [SYNC_API_METHODS.TICKERS_HISTORY, tickersHistory],
   [SYNC_API_METHODS.WALLETS, wallets],
   [SYNC_API_METHODS.SYMBOLS, symbols],