fix promise handling

CHANGELOG.md

@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
+## v1.2.4 - 2024-02-07
+
+### Changed
+
+- Optimize promise handling
+
 ## v1.2.3 - 2024-02-07
 
 ### Changed

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@cap-js-community/event-queue",
-  "version": "1.2.3",
+  "version": "1.2.4",
   "description": "An event queue that enables secure transactional processing of asynchronous and periodic events, featuring instant event processing with Redis Pub/Sub and load distribution across all application instances.",
   "main": "src/index.js",
   "files": [

src/EventQueueProcessorBase.js

@@ -21,7 +21,7 @@ const SELECT_LIMIT_EVENTS_PER_TICK = 100;
 const TRIES_FOR_EXCEEDED_EVENTS = 3;
 const EVENT_START_AFTER_HEADROOM = 3 * 1000;
 
-let serviceBindingCache = {};
+let serviceBindingCache = null;
 
 class EventQueueProcessorBase {
   #eventsWithExceededTries = [];
@@ -700,13 +700,16 @@ class EventQueueProcessorBase {
   }
 
   async #getServiceBindings() {
-    if (serviceBindingCache && serviceBindingCache.exipreTs >= Date.now()) {
-      return serviceBindingCache.value;
+    if (!(serviceBindingCache && serviceBindingCache.expireTs >= Date.now())) {
+      const mtxServiceManager = require("@sap/cds-mtxs/srv/plugins/hana/srv-mgr");
+      serviceBindingCache = {
+        expireTs: Date.now() + 10 * 60 * 1000,
+        value: mtxServiceManager.getAll().catch(() => {
+          serviceBindingCache = null;
+        }),
+      };
     }
-    const mtxServiceManager = require("@sap/cds-mtxs/srv/plugins/hana/srv-mgr");
-    serviceBindingCache.value = await mtxServiceManager.getAll();
-    serviceBindingCache.exipreTs = Date.now() + 10 * 60 * 1000;
-    return serviceBindingCache.value;
+    return await serviceBindingCache.value;
   }
 
   async #selectLastSuccessfulPeriodicTimestamp() {