token transfer cleanup job

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/workers/priorities.json

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