Clear tt (#327)

* token transfer cleanup job

* add migration

Author: antoinedc

run/jobs/index.js

@@ -31,5 +31,6 @@ module.exports = {
     batchBlockDelete: require('./batchBlockDelete'),
     batchContractDelete: require('./batchContractDelete'),
     cancelDemoExplorers: require('./cancelDemoExplorers'),
-    deleteWorkspace: require('./deleteWorkspace')
+    deleteWorkspace: require('./deleteWorkspace'),
+    tokenTransferCleanup: require('./tokenTransferCleanup')
 };

run/jobs/tokenTransferCleanup.js

@@ -0,0 +1,15 @@
+const { TokenTransfer } = require('../models');
+
+module.exports = async job => {
+    const data = job.data;
+
+    const tokenTransfers = await TokenTransfer.findAll({
+        where: { id: data.ids }
+    });
+
+    for (let i = 0; i < tokenTransfers.length; i++) {
+        await tokenTransfers[i].safeDestroy();
+    }
+
+    return true;
+};

run/migrations/20240214104658-token-transfer-fk.js

@@ -0,0 +1,50 @@
+'use strict';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up (queryInterface, Sequelize) {
+    const transaction = await queryInterface.sequelize.transaction();
+    try {
+      await queryInterface.sequelize.query(`
+        ALTER TABLE token_transfers
+        ADD CONSTRAINT "token_transfers_transactionId_fkey"
+        FOREIGN KEY ("transactionId")
+        REFERENCES transactions(id);
+      `, { transaction });
+
+      await queryInterface.sequelize.query(`
+        ALTER TABLE token_transfers
+        ADD CONSTRAINT "token_transfers_transactionLogId_fkey"
+        FOREIGN KEY ("transactionLogId")
+        REFERENCES transaction_logs(id);
+      `, { transaction });
+
+      await transaction.commit();
+    } catch(error) {
+      console.log(error);
+      await transaction.rollback();
+      throw error;
+    }
+  },
+
+  async down (queryInterface, Sequelize) {
+    const transaction = await queryInterface.sequelize.transaction();
+    try {
+      await queryInterface.sequelize.query(`
+        ALTER TABLE token_transfers
+        DROP CONSTRAINT "token_transfers_transactionId_fkey";
+      `, { transaction });
+
+      await queryInterface.sequelize.query(`
+        ALTER TABLE token_transfers
+        DROP CONSTRAINT "token_transfers_transactionLogId_fkey";
+      `, { transaction });
+
+      await transaction.commit();
+    } catch(error) {
+      console.log(error);
+      await transaction.rollback();
+      throw error;
+    }
+  }
+};

run/workers/priorities.json

@@ -31,6 +31,7 @@
         "batchBlockDelete",
         "batchContractDelete",
         "cancelDemoExplorers",
-        "deleteWorkspace"
+        "deleteWorkspace",
+        "tokenTransferCleanup"
     ]
 }