From 84e2db1b736dc3efbd1442e2cff48124fb7fc514 Mon Sep 17 00:00:00 2001 From: soukainna Date: Wed, 12 Feb 2025 11:05:24 +0100 Subject: [PATCH] fix db --- storage/mongodb.go | 8 -------- 1 file changed, 8 deletions(-) diff --git a/storage/mongodb.go b/storage/mongodb.go index db13f2f..8259249 100644 --- a/storage/mongodb.go +++ b/storage/mongodb.go @@ -92,16 +92,11 @@ func (s MongoDBStorage) GetEvents(namespaces []string) (events []Event, err erro for cur.Next(context.TODO()) { var event Event - //var elem bson.M if err := cur.Decode(&event); err != nil { return events, err } - // bsonBytes, _ := bson.Marshal(elem) - // fmt.Println(string(bsonBytes)) - // bson.Unmarshal(bsonBytes, &event) - events = append(events, event) } @@ -157,9 +152,6 @@ func (s MongoDBStorage) GetSubscriber(subscriber string) ([]Subscription, error) subscriptions := []Subscription{} var cur *mongo.Cursor - // findOptions := options.Find() - - // cur, err := collection.Find(context.TODO(), bson.M{"subscriptions": subscriber}, findOptions) cur, err := collection.Find(context.TODO(), bson.M{"subscriptions": bson.M{"$elemMatch": bson.M{"subscriber": subscriber}}}) if err != nil {