fix(offset): allow creating offset in not existing

okp4 · Nov 23, 2022 · 65c84f2 · 65c84f2
1 parent a7bdb35
commit 65c84f2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/app/offset/store.go b/app/offset/store.go
@@ -7,6 +7,7 @@ import (
 
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
 )
 
 const collectionName = "offsets"
@@ -41,6 +42,7 @@ func (s *Store) Save(ctx context.Context, offset interface{}) error {
 					"offset": offset,
 				},
 			},
+			options.Update().SetUpsert(true),
 		)
 	return err
 }