Do not create publish request entity if event is an empty object

Author: x244777

package-lock.json

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

package.json

@@ -32,7 +32,7 @@ export const publishToEventBridge = ({ // eslint-disable-line import/prefer-defa
 
   const toPublishRequestEntry = (uow) => ({
     ...uow,
-    [publishRequestEntryField]: uow[eventField] ? {
+    [publishRequestEntryField]: uow[eventField] && Object.keys(uow[eventField]).length > 0 ? {
       EventBusName: busName,
       Source: source,
       DetailType: uow[eventField].type,

src/sinks/eventbridge.js

@@ -105,6 +105,27 @@ describe('sinks/eventbridge.js', () => {
       .done(done);
   });
 
+  it('should not publish when emit field is empty object', (done) => {
+    const uows = [{
+      emit: {},
+    }];
+
+    _(uows)
+      .through(publish(
+        {
+          eventField: 'emit', busName: 'b1', debug: (msg, v) => console.log(msg, v), metricsEnabled: true,
+        },
+      ))
+      .collect()
+      .tap((collected) => {
+        // console.log(JSON.stringify(collected, null, 2));
+
+        expect(collected.length).to.equal(1);
+        expect(collected[0].publishRequestEntry).to.be.undefined;
+      })
+      .done(done);
+  });
+
   it('should reject with a fault', (done) => {
     sinon.stub(Connector.prototype, 'putEvents').rejects('test error');