update query

rwynn · Nov 24, 2019 · 17d641e · 17d641e
1 parent fc3762d
commit 17d641e
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/mongofluxd.go b/mongofluxd.go
@@ -556,15 +556,15 @@ func saveTokens(client *mongo.Client, tokens bson.M, config *configOptions) erro
 			"resumeName": config.ResumeName,
 			"streamID":   streamID,
 		}
-		replacement := bson.M{
+		update := bson.M{"$set": bson.M{
 			"resumeName": config.ResumeName,
 			"streamID":   streamID,
 			"token":      token,
-		}
-		model := mongo.NewReplaceOneModel()
+		}}
+		model := mongo.NewUpdateManyModel()
 		model.SetUpsert(true)
 		model.SetFilter(filter)
-		model.SetReplacement(replacement)
+		model.SetUpdate(update)
 		models = append(models, model)
 	}
 	_, err = col.BulkWrite(context.Background(), models, bwo)