Only use _id field to get streamer ID on delete operation

streamcord · May 8, 2021 · 2496ec0 · 2496ec0
1 parent d35cbaa
commit 2496ec0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/kotlin/App.kt b/src/main/kotlin/App.kt
@@ -84,9 +84,9 @@ suspend fun main() = coroutineScope<Unit> {
         }
 
         val streamerID = when (doc.operationType) {
-            OperationType.INSERT -> doc.fullDocument!!.getString("streamer_id")?.toLong() ?: return@launchWatch
-            OperationType.DELETE, OperationType.UPDATE, OperationType.REPLACE ->
-                ByteBuffer.wrap(doc.documentKey!!.getBinary("_id").data).long
+            OperationType.INSERT, OperationType.UPDATE, OperationType.REPLACE ->
+                doc.fullDocument!!.getString("streamer_id")?.toLong() ?: return@launchWatch
+            OperationType.DELETE -> ByteBuffer.wrap(doc.documentKey!!.getBinary("_id").data).long
             else -> return@launchWatch
         }