Merge pull request #415 from jgilbert01/encrypt-event-eem-as-function

Encrypt event eem as function

Author: JoshuaLamke

package-lock.json

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

package.json

@@ -128,10 +128,11 @@ export const encryptEvent = ({
       return _(Promise.resolve(uow));
     }
 
+    const eemMetadata = typeof eem === 'function' ? eem(uow[sourceField], uow) : eem;
     const p = encryptObject(uow[sourceField], {
       masterKeyAlias,
       regions,
-      ...eem, // fields and overrides
+      ...eemMetadata, // fields and overrides
       AES,
     })
       // .tap(debug)

src/utils/encryption.js

@@ -91,6 +91,79 @@ describe('utils/encryption.js', () => {
         .done(done);
     });
 
+    it('should encrypt an event - trigger function w/ eem function', (done) => {
+      const events = toDynamodbRecords([
+        {
+          timestamp: 1572832690,
+          keys: {
+            pk: '1',
+            sk: 'thing',
+          },
+          newImage: {
+            pk: '1',
+            sk: 'thing',
+            discriminator: 'thing',
+            name: 'n1',
+            description: 'd1',
+            status: 's1',
+          },
+        },
+      ]);
+
+      fromDynamodb(events)
+        .through(encryptEvent({
+          eem: (event, _uow) => {
+            if (event.raw.new.discriminator === 'thing') {
+              return {
+                fields: ['name', 'description'],
+              };
+            }
+            return {
+              fields: [],
+            };
+          },
+          masterKeyAlias: 'alias/aws-kms-ee',
+          AES: false,
+        }))
+        .collect()
+        .tap((collected) => {
+          // console.log(JSON.stringify(collected, null, 2));
+
+          expect(collected.length).to.equal(1);
+          expect(collected[0].event).to.deep.equal({
+            id: '0',
+            type: 'thing-created',
+            partitionKey: '1',
+            timestamp: 1572832690000,
+            tags: {
+              region: 'us-west-2',
+            },
+            raw: {
+              new: {
+                pk: '1',
+                sk: 'thing',
+                discriminator: 'thing',
+                name: 'Im4xIg==',
+                description: 'ImQxIg==',
+                status: 's1',
+              },
+              old: undefined,
+            },
+            eem: {
+              masterKeyAlias: 'alias/aws-kms-ee',
+              dataKeys: {
+                'us-west-2': MOCK_GEN_DK_RESPONSE.CiphertextBlob.toString('base64'),
+              },
+              fields: [
+                'name',
+                'description',
+              ],
+            },
+          });
+        })
+        .done(done);
+    });
+
     it('should decrypt an event - listener function', (done) => {
       const events = toKinesisRecords([
         {