Delete pending orders job

This PR deletes all pending orders with a time greather than ORDER_PUBLISHED_EXPIRATION_WINDOW

Author: grunch

.env-sample

@@ -31,4 +31,7 @@ PENDING_PAYMENT_WINDOW=5
 # Fiat currency rate API
 FIAT_RATE_NAME=''
 FIAT_RATE_EP=''
-NODE_ENV='development'
+NODE_ENV='development'
+
+# Expiration time for published order in seconds
+ORDER_PUBLISHED_EXPIRATION_WINDOW=82800

bot/start.js

@@ -32,7 +32,7 @@ const {
   validateInvoice,
 } = require('./validations');
 const messages = require('./messages');
-const { attemptPendingPayments, cancelOrders } = require('../jobs');
+const { attemptPendingPayments, cancelOrders, deleteOrders } = require('../jobs');
 const addInvoiceWizard = require('./scenes');
 
 const initialize = (botToken, options) => {
@@ -45,6 +45,9 @@ const initialize = (botToken, options) => {
   const cancelOrderJob = schedule.scheduleJob(`*/2 * * * *`, async () => {
     await cancelOrders(bot);
   });
+  const deleteOrdersJob = schedule.scheduleJob(`15 * * * *`, async () => {
+    await deleteOrders(bot);
+  });
 
   const stage = new Scenes.Stage([addInvoiceWizard]);
   bot.use(session());

jobs/delete_published_orders.js

@@ -0,0 +1,21 @@
+const { Order } = require('../models');
+
+const deleteOrders = async (bot) => {
+    const windowTime = new Date();
+    windowTime.setSeconds(windowTime.getSeconds() - parseInt(process.env.ORDER_PUBLISHED_EXPIRATION_WINDOW));
+    // console.log(windowTime)
+    // We get the pending orders where time is expired
+    const pendingOrders = await Order.find({
+        status: 'PENDING',
+        created_at: { $lte: windowTime },
+    });
+    for (const order of pendingOrders) {
+        console.log(`Pending order Id: ${order._id} expired after ${process.env.ORDER_PUBLISHED_EXPIRATION_WINDOW} seconds, deleting it from database and channel`);
+        // We delete the messages related to that order from the channel
+        await bot.telegram.deleteMessage(process.env.CHANNEL, order.tg_channel_message1);
+        await bot.telegram.deleteMessage(process.env.CHANNEL, order.tg_channel_message2);
+        await order.remove();
+    }
+};
+
+module.exports = deleteOrders;

jobs/index.js

@@ -1,4 +1,5 @@
 const attemptPendingPayments = require('./pending_payments');
 const cancelOrders = require('./cancel_orders');
+const deleteOrders = require('./delete_published_orders');
 
-module.exports = { attemptPendingPayments, cancelOrders };
+module.exports = { attemptPendingPayments, cancelOrders, deleteOrders };