From 498f5bc1705000d970e401ef61862bc27656eb8f Mon Sep 17 00:00:00 2001 From: soukainna Date: Wed, 12 Feb 2025 11:11:17 +0100 Subject: [PATCH] fix func get Subscriber --- storage/mongodb.go | 25 ------------------------- 1 file changed, 25 deletions(-) diff --git a/storage/mongodb.go b/storage/mongodb.go index 8259249..dc28fa7 100644 --- a/storage/mongodb.go +++ b/storage/mongodb.go @@ -170,31 +170,6 @@ func (s MongoDBStorage) GetSubscriber(subscriber string) ([]Subscription, error) } fmt.Println(subscriptions) return subscriptions, nil - //return nil, nil - // if err != nil { - // return subscriptions, err - // } - - // for cur.Next(context.TODO()) { - // var event Event - // var elem bson.M - - // if err := cur.Decode(&elem); err != nil { - // return subscriptions, err - // } - // for i := range event.Subscriptions { - // if event.Subscriptions[i].Subscriber == subscriber { - // subscriptions = append(subscriptions, event.Subscriptions[i]) - // } - // } - // // bsonBytes, _ := bson.Marshal(elem) - // // bson.Unmarshal(bsonBytes, &event) - - // // subscriptions = append(subscriptions, event.Subscriptions[1]) - - // } - - // return subscriptions, nil } func (s MongoDBStorage) GetSubscriptionByUser(subscriber string) ([]Subscription, error) {