Changed status of orders after hold invoice expires

bot/ordersActions.js

@@ -290,9 +290,32 @@ const getNewRangeOrderPayload = async order => {
   }
 };
 
+const updateOrderStatus = async (orderId, newStatus) => {
+  try {
+    const order = await Order.findByIdAndUpdate(
+      orderId,
+      { status: newStatus },
+      { new: true }
+    );
+
+    if (order) {
+      OrderEvents.orderUpdated(order);
+    }
+
+    return order;
+  } catch (error) {
+    logger.error(error);
+    return null;
+  }
+};
+
+
+
+
 module.exports = {
   createOrder,
   getOrder,
   getOrders,
   getNewRangeOrderPayload,
+  updateOrderStatus,
 };

jobs/holdInvoiceMonitor.ts

@@ -0,0 +1,40 @@
+import { Order } from '../models';
+import { checkHoldInvoiceExpiration } from '../ln/hold_invoice';
+import { logger } from '../logger';
+import { Document, ObjectId } from 'mongoose';
+
+const CHECK_INTERVAL = 5 * 60 * 1000; // Check every 5 minutes
+
+interface IOrder {
+    // Existing properties of Order, and adding hold_invoice_hash
+    hold_invoice_hash?: string;
+    _id: ObjectId;
+    // Other properties...
+  }
+
+  // Now, for the monitorHoldInvoices function:
+  const monitorHoldInvoices = async () => {
+    try {
+      // Find all orders with PAID_HOLD_INVOICE status
+      const orders: (IOrder & Document)[] = await Order.find({ status: 'PAID_HOLD_INVOICE' });
+
+      for (const order of orders) {
+        if (order.hold_invoice_hash) {
+          await checkHoldInvoiceExpiration({
+            hash: order.hold_invoice_hash,
+            orderId: order._id
+          });
+        }
+      }
+    } catch (error) {
+      logger.error('Error monitoring hold invoices:', error);
+    }
+  };
+
+  // Start monitoring process
+  const startMonitoring = () => {
+    setInterval(monitorHoldInvoices, CHECK_INTERVAL);
+    logger.info('Hold invoice monitoring started');
+  };
+
+  export { startMonitoring };

jobs/index.ts

@@ -7,6 +7,7 @@ import deleteOrders from "./delete_published_orders";
 import calculateEarnings from './calculate_community_earnings'
 import deleteCommunity from './communities'
 import nodeInfo from './node_info'
+import { startMonitoring } from "./holdInvoiceMonitor"; // Imported the startMonitoring function
 
 export {
   attemptPendingPayments,
@@ -16,4 +17,5 @@ export {
   attemptCommunitiesPendingPayments,
   deleteCommunity,
   nodeInfo,
-};
+  startMonitoring,
+};

ln/hold_invoice.js

@@ -2,6 +2,7 @@ const { createHash, randomBytes } = require('crypto');
 const lightning = require('lightning');
 const lnd = require('./connect');
 const { logger } = require('../logger');
+const { updateOrderStatus } = require('../bot/ordersActions');
 
 const createHoldInvoice = async ({ description, amount }) => {
   try {
@@ -54,9 +55,34 @@ const getInvoice = async ({ hash }) => {
   }
 };
 
+
+const checkHoldInvoiceExpiration = async ({ hash, orderId }) => {
+  try {
+    const invoice = await getInvoice({ hash });
+
+    if (invoice && invoice.is_expired) {
+      // Cancel the expired hold invoice
+      await cancelHoldInvoice({ hash });
+
+      // Update the order status
+      await updateOrderStatus(orderId, 'HOLD_INVOICE_EXPIRED');
+
+      logger.info(`Hold invoice ${hash} expired for order ${orderId}`);
+      return true;
+    }
+
+    return false;
+  } catch (error) {
+    logger.error(error);
+    return false;
+  }
+};
+
+
 module.exports = {
   createHoldInvoice,
   settleHoldInvoice,
   cancelHoldInvoice,
   getInvoice,
+  checkHoldInvoiceExpiration,
 };