From 26e79bbb205b1deee9c8633aa0e96b9032f86dbc Mon Sep 17 00:00:00 2001
From: Erki Aas <eaas@k-space.ee>
Date: Tue, 11 Oct 2022 02:24:41 +0300
Subject: [PATCH] Handle non-insert changes

---
 backend/server.js | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/backend/server.js b/backend/server.js
index 6680196..20d9312 100644
--- a/backend/server.js
+++ b/backend/server.js
@@ -33,7 +33,6 @@ async function run() {
   console.log("Started watching changes in database");
 
   const writeMessage = (response, blob) => {
-    // TODO: why no id?
     const id = blob._id || null
     const message = `id: ${id}\nevent: message\ndata: ${JSON.stringify(blob)}\n\n`
     response.write(message)
@@ -55,7 +54,10 @@ async function run() {
         });
 
     const changeListener = async (change) => {
-      writeMessage(response, change.fullDocument)
+      // Ignore events without fullDocument, e.g. deletes.
+      if (change.fullDocument) {
+        writeMessage(response, change.fullDocument)
+      }
     }
     changeStream.on("change", changeListener);
     response.on('close', () => {