add-eb-global-support

package.json

@@ -1,6 +1,6 @@
 {
   "name": "aws-lambda-stream",
-  "version": "1.0.30",
+  "version": "1.0.31",
   "description": "Create stream processors with AWS Lambda functions.",
   "keywords": [
     "aws",

src/sinks/eventbridge.js

@@ -21,6 +21,7 @@ export const publishToEventBridge = ({ // eslint-disable-line import/prefer-defa
   maxPublishRequestSize = Number(process.env.PUBLISH_MAX_REQ_SIZE) || Number(process.env.MAX_REQ_SIZE) || 256 * 1024,
   batchSize = Number(process.env.PUBLISH_BATCH_SIZE) || Number(process.env.BATCH_SIZE) || 10,
   parallel = Number(process.env.PUBLISH_PARALLEL) || Number(process.env.PARALLEL) || 8,
+  endpointId = process.env.BUS_ENDPOINT_ID,
   handleErrors = true,
   retryConfig,
   step = 'publish',
@@ -41,14 +42,21 @@ export const publishToEventBridge = ({ // eslint-disable-line import/prefer-defa
     } : undefined,
   });
 
-  const toPublishRequest = (batchUow) => ({
-    ...batchUow,
-    [publishRequestField]: {
-      Entries: batchUow.batch
-        .filter((uow) => uow[publishRequestEntryField])
-        .map((uow) => uow[publishRequestEntryField]),
-    },
-  });
+  const toPublishRequest = (batchUow) => {
+    const Entries = batchUow.batch
+      .filter((uow) => uow[publishRequestEntryField])
+      .map((uow) => uow[publishRequestEntryField]);
+
+    return {
+      ...batchUow,
+      [publishRequestField]: endpointId ? /* istanbul ignore next */ {
+        Entries,
+        EndpointId: endpointId,
+      } : {
+        Entries,
+      },
+    };
+  };
 
   const putEvents = (batchUow) => {
     if (!batchUow[publishRequestField].Entries.length) {