From 4de38496226a4e0c54f1a08e11bcff30f1afe423 Mon Sep 17 00:00:00 2001
From: Prabhjot Singh Sethi <prabhjot.sethi@gmail.com>
Date: Thu, 17 Apr 2025 20:18:50 +0000
Subject: [PATCH] Handle Watch streams when key is not set

Signed-off-by: Prabhjot Singh Sethi <prabhjot.sethi@gmail.com>
---
 db/mongo.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/db/mongo.go b/db/mongo.go
index 2fbea20..dfd6985 100644
--- a/db/mongo.go
+++ b/db/mongo.go
@@ -256,7 +256,7 @@ func (c *mongoCollection) Watch(ctx context.Context, filter interface{}, cb Watc
 			if keyType != nil {
 				key = reflect.New(keyType.Elem()).Interface()
 			} else {
-				key = bson.D{}
+				key = bson.M{}
 			}
 
 			marshaledData, err := bson.Marshal(bKey)