fix console log

lib/storage/metadata/mongoclient/ListRecordStream.js

@@ -13,6 +13,9 @@ class ListRecordStream extends stream.Transform {
     }
 
     _transform(itemObj, encoding, callback) {
+        if (itemObj && itemObj.o && itemObj.o._id) {
+            console.log('ITEM OBJ', itemObj.o._id);
+        }
         // always update to most recent uniqID
         this._lastUniqID = itemObj.h.toString();
 
@@ -27,21 +30,22 @@ class ListRecordStream extends stream.Transform {
             if (!this._lastEndID || this._lastEndID === itemObj.h.toString()) {
                 this._unpublishedListing = true;
             }
+            console.log('SKIPPING EARLY');
             return callback();
         }
 
         const dbName = itemObj.ns.split('.');
         let entry;
-        if (itemObj.op === 'i' &&
+        if (itemObj.op === 'i' && itemObj.o && itemObj.o._id) {
-            itemObj.o && itemObj.o._id) {
+            console.log('PROCESSING I');
             entry = {
                 type: 'put',
                 key: itemObj.o._id,
                 // value is given as-is for inserts
                 value: JSON.stringify(itemObj.o.value),
             };
-        } else if (itemObj.op === 'u' &&
+        } else if (itemObj.op === 'u' && itemObj.o && itemObj.o2 && itemObj.o2._id) {
-                   itemObj.o && itemObj.o2 && itemObj.o2._id) {
+            console.log('PROCESSING U');
             entry = {
                 type: 'put', // updates overwrite the whole metadata,
                              // so they are considered as puts
@@ -54,12 +58,14 @@ class ListRecordStream extends stream.Transform {
             };
         } else if (itemObj.op === 'd' &&
                    itemObj.o && itemObj.o._id) {
+                       console.log('PROCESSING D');
             entry = {
                 type: 'delete',
                 key: itemObj.o._id,
                 // deletion yields no value
             };
         } else {
+            console.log('SKIPPED ENTRY');
             // skip other entry types as we don't need them for now
             // ('c', ...?)
             return callback();