feat: set next run

CHANGELOG.md

@@ -5,6 +5,9 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [2.3.0] - 2024-06-03
+- Feature: set next run
+
 ## [2.2.0] - 2024-02-23
 - Feature: order append lines
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@orderingstack/pos-integrator-core",
-  "version": "2.2.0",
+  "version": "2.3.0",
   "description": "Ordering Stack POS integrator core - library for easy developing POS integrations with Ordering Stack platform.",
   "scripts": {
     "test": "jest",

src/db/orders-dao.ts

@@ -98,6 +98,13 @@ function setOrderStage(db: Database, orderId: string, stage: string) {
   stmt.run([stage, orderId]);
 }
 
+function setNextRunInSeconds(db: Database, orderId: string, seconds: number) {
+  const stmt = db.prepare(
+    "UPDATE OSL_ORDER SET nextStageRunAt=DateTime('now', '+? seconds') WHERE id=?",
+  );
+  stmt.run([seconds, orderId]);
+}
+
 // TODO: do not removew if order is not processed and closed - attrs: closed, completed, status, processed
 function removeOlderThan(db: Database, days: number) {
   const stmt = db.prepare(
@@ -192,4 +199,5 @@ module.exports = {
   getOrdersInStage,
   getStats,
   isOrderWithCheckSeqInDb,
+  setNextRunInSeconds,
 };

src/orders-local-queue-service.ts

@@ -120,6 +120,10 @@ function setOrderStage(orderId: string, stage: string) {
   orderDao.setOrderStage(db, orderId, stage);
 }
 
+function setNextRunInSeconds(orderId: string, seconds: number) {
+  orderDao.setNextRunInSeconds(db, orderId, seconds);
+}
+
 function updateOrderBody(orderRec: IOrderRecord) {
   orderDao.updateOrderBody(db, orderRec);
 }
@@ -157,6 +161,7 @@ export function getOrdersQueue(dbFileName?: string) {
     addOrderToProcessingQueue,
     pullOrdersAndAddToProcessingQueue,
     setOrderStage,
+    setNextRunInSeconds,
     updateOrderBody,
     updateOrderExtraData,
     getOrder,