wip

Author: soccermax

CHANGELOG.md

@@ -11,7 +11,6 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 - [Event Configuration] `propagateHeaders` allows forwarding headers from the original CDS context to the outbox call by specifying their names in an array.
 
-
 ## v1.11.0 - 2025-10-16
 
 ### Added

docs/configure-event/index.md

@@ -41,7 +41,7 @@ they should be processed.
 ## Parameters
 
 | Property                      | Description                                                                                                                                                                                                                                                                                                                                                                                                                               | Default Value   |
-|-------------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-----------------|
+| ----------------------------- | ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | --------------- |
 | impl                          | Path of the implementation class associated with the event.                                                                                                                                                                                                                                                                                                                                                                               | -               |
 | type                          | Specifies the type of the event.                                                                                                                                                                                                                                                                                                                                                                                                          | -               |
 | subType                       | Specifies the subtype of the event, further categorizing the event type.                                                                                                                                                                                                                                                                                                                                                                  | -               |

src/outbox/eventQueueAsOutbox.js

@@ -97,7 +97,7 @@ const _mapToEventAndPublish = async (context, subType, req, eventHeaders) => {
     for (const field of EVENT_QUEUE_SPECIFIC_FIELDS) {
       if (header.toLocaleLowerCase() === `x-eventqueue-${field.toLocaleLowerCase()}`) {
         eventQueueSpecificValues[field] = req.headers[header];
-        delete req.headers[header];
+        delete eventHeaders[header];
         break;
       }
     }

test/__snapshots__/eventQueueOutbox.test.js.snap

@@ -40,6 +40,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true ad-hoc events overwrite se
   "load": 60,
   "parallelEventProcessing": 5,
   "priority": "medium",
+  "propagateHeaders": [],
   "retryAttempts": 20,
   "selectMaxChunkSize": 10,
   "subType": "NotificationServicePeriodic.action",
@@ -64,6 +65,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true ad-hoc events overwrite se
   "load": 60,
   "parallelEventProcessing": 5,
   "priority": "medium",
+  "propagateHeaders": [],
   "retryAttempts": 20,
   "selectMaxChunkSize": 10,
   "subType": "NotificationServicePeriodic.action",
@@ -88,6 +90,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true custom options should win
   "load": 1,
   "parallelEventProcessing": 5,
   "priority": "medium",
+  "propagateHeaders": [],
   "retryAttempts": 20,
   "selectMaxChunkSize": 10,
   "subType": "NotificationServiceOutboxedByConfig",
@@ -124,6 +127,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true map config to event-queue
   "load": 1,
   "parallelEventProcessing": 5,
   "priority": "medium",
+  "propagateHeaders": [],
   "retryAttempts": 20,
   "selectMaxChunkSize": 10,
   "subType": "NotificationService",
@@ -138,6 +142,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true option to use eventQueue.u
     "subject": "subject",
     "to": "to",
   },
+  "headers": {},
   "subType": "NotificationServiceOutboxedByConfigUserId",
   "user": "dummyTestUser",
 }
@@ -158,6 +163,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true periodic events inherit co
   "keepAliveMaxInProgressTime": 210,
   "load": 60,
   "priority": "medium",
+  "propagateHeaders": [],
   "subType": "NotificationServicePeriodic.main",
   "transactionMode": "isolated",
   "type": "CAP_OUTBOX_PERIODIC",
@@ -191,6 +197,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true periodic events inherit co
   "keepAliveMaxInProgressTime": 210,
   "load": 60,
   "priority": "medium",
+  "propagateHeaders": [],
   "subType": "NotificationServicePeriodic.main",
   "transactionMode": "alwaysRollback",
   "type": "CAP_OUTBOX_PERIODIC",
@@ -215,6 +222,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true periodic events inherit co
   "keepAliveMaxInProgressTime": 210,
   "load": 60,
   "priority": "medium",
+  "propagateHeaders": [],
   "subType": "NotificationServicePeriodic.main",
   "transactionMode": "isolated",
   "type": "CAP_OUTBOX_PERIODIC",
@@ -302,6 +310,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true req.data should be stored
     "subject": "subject",
     "to": "to",
   },
+  "headers": {},
   "subType": "NotificationService",
   "user": "testUser",
 }
@@ -327,6 +336,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true req.data should be stored
     "subject": "subject",
     "to": "to",
   },
+  "headers": {},
   "subType": "NotificationService",
   "user": "testUser",
 }
@@ -370,6 +380,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true should store correct user
     "subject": "subject",
     "to": "to",
   },
+  "headers": {},
   "subType": "NotificationService",
   "user": "badman",
 }
@@ -391,6 +402,7 @@ exports[`event-queue outbox monkeyPatchCAPOutbox=true should work for outboxed s
   "load": 1,
   "parallelEventProcessing": 5,
   "priority": "medium",
+  "propagateHeaders": [],
   "retryAttempts": 20,
   "selectMaxChunkSize": 10,
   "subType": "NotificationServiceOutboxedByConfig",

test/__snapshots__/initialize.test.js.snap

@@ -15,6 +15,7 @@ exports[`initialize read yaml config file 1`] = `
     "load": 40,
     "parallelEventProcessing": 5,
     "priority": "medium",
+    "propagateHeaders": [],
     "subType": "Task",
     "type": "Notifications",
   },
@@ -31,6 +32,7 @@ exports[`initialize read yaml config file 1`] = `
     "load": 10,
     "parallelEventProcessing": 1,
     "priority": "medium",
+    "propagateHeaders": [],
     "subType": "CommunicationSystem",
     "type": "BusinessLogs",
   },

test/eventQueueOutbox.test.js

@@ -1823,7 +1823,7 @@ expect.extend({
     };
   },
   actionCalled: (loggerMock, actionName, properties = {}) => {
-    const call = loggerMock.calls().info.find((c) => c[0]?.includes(actionName));
+    const call = loggerMock.calls().info.find((c) => actionName === c[0]);
     if (!call) {
       return {
         message: () => `action not called! name: ${actionName}`,