feat: change create watcher function logic

ambrosus · May 24, 2024 · b9e26b2 · b9e26b2
1 parent 4a11286
commit b9e26b2
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/services/watcher/service.go b/services/watcher/service.go
@@ -493,15 +493,18 @@ func (s *service) GetWatcherHistoryPrices(ctx context.Context) *CGData {
 }
 
 func (s *service) CreateWatcher(ctx context.Context, pushToken string, deviceId string) error {
-	//if watcher with deviceId exists then update, not create
+	//if watcher with deviceId exists, delete it before create, not create
 
 	dbWatcher, err := s.repository.GetWatcher(ctx, bson.M{"device_id": deviceId})
 	if err != nil {
 		return err
 	}
 
 	if deviceId != "" && dbWatcher != nil {
-		return s.UpdateWatcherPushToken(ctx, dbWatcher.PushToken, pushToken, deviceId)
+		err := s.DeleteWatcher(ctx, dbWatcher.PushToken)
+		if err != nil {
+			return err
+		}
 	}
 
 	encodePushToken := base64.StdEncoding.EncodeToString([]byte(pushToken))