From 8d3df83e75cc7638ead0c5231faa67d0b9a7b590 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 4 Apr 2017 20:51:58 +0200
Subject: filter undefined or null objects

---
 worker.js | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index eb41240..b65bb59 100644
--- a/worker.js
+++ b/worker.js
@@ -86,7 +86,9 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI,
         }
 
         // helper: true if object is not in record arr
-        let is_in = (arr, obj) => arr.map((o) => o.api_id).indexOf(obj.api_id) > -1;
+        // also, sort out invalid objects (undefined or null)
+        let is_in = (arr, obj) => obj == undefined ||
+            arr.map((o) => o.api_id).indexOf(obj.api_id) > -1;
 
 
         // we aggregate record objects to do a bulk insert
-- 
cgit v1.3.1