From 37fc43f3675d8ac72b074747b6510441ada13fe0 Mon Sep 17 00:00:00 2001
From: Pavel Tiunov <pavel.tiunov@gmail.com>
Date: Sat, 11 Apr 2020 19:27:21 -0700
Subject: [PATCH] fix: Handle invalid lambda process events

---
 packages/cubejs-serverless-aws/index.js | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/packages/cubejs-serverless-aws/index.js b/packages/cubejs-serverless-aws/index.js
index 47390ed31293f..5995f11864425 100644
--- a/packages/cubejs-serverless-aws/index.js
+++ b/packages/cubejs-serverless-aws/index.js
@@ -24,10 +24,17 @@ class AWSHandlers extends Handlers {
   }
 
   async process(event) {
-    await Promise.all(event.Records.map(async record => {
-      const message = JSON.parse(record.Sns.Message);
-      await this.processMessage(message);
-    }));
+    if (event.Records) {
+      await Promise.all(event.Records.map(async record => {
+        const message = JSON.parse(record.Sns.Message);
+        await this.processMessage(message);
+      }));
+    } else {
+      this.serverCore.logger('Invalid Lambda Process Message', {
+        warning: `Event doesn't contain Records field. Skipping.`,
+        lambdaEvent: event
+      });
+    }
 
     return {
       statusCode: 200