Merge pull request #3659 from withchao/3.8.3-patch

withchao · web-flow · commit 5f81f632f88a · 2026-01-15T11:02:35.000+08:00
fix: Mongo Malloc upsert overwrites min_seq initialization
diff --git a/pkg/common/storage/database/mgo/seq_conversation.go b/pkg/common/storage/database/mgo/seq_conversation.go
@@ -57,8 +57,8 @@ func (s *seqConversationMongo) Malloc(ctx context.Context, conversationID string
 	}
 	filter := map[string]any{"conversation_id": conversationID}
 	update := map[string]any{
-		"$inc": map[string]any{"max_seq": size},
-		"$set": map[string]any{"min_seq": int64(0)},
+		"$inc":         map[string]any{"max_seq": size},
+		"$setOnInsert": map[string]any{"min_seq": int64(0)},
 	}
 	opt := options.FindOneAndUpdate().SetUpsert(true).SetReturnDocument(options.After).SetProjection(map[string]any{"_id": 0, "max_seq": 1})
 	lastSeq, err := mongoutil.FindOneAndUpdate[int64](ctx, s.coll, filter, update, opt)

Original file line number	Diff line number	Diff line change
`@@ -57,8 +57,8 @@ func (s *seqConversationMongo) Malloc(ctx context.Context, conversationID string`
`57`	`57`	`}`
`58`	`58`	`filter := map[string]any{"conversation_id": conversationID}`
`59`	`59`	`update := map[string]any{`
`60`		`- "$inc": map[string]any{"max_seq": size},`
`61`		`- "$set": map[string]any{"min_seq": int64(0)},`
	`60`	`+ "$inc": map[string]any{"max_seq": size},`
	`61`	`+ "$setOnInsert": map[string]any{"min_seq": int64(0)},`
`62`	`62`	`}`
`63`	`63`	`opt := options.FindOneAndUpdate().SetUpsert(true).SetReturnDocument(options.After).SetProjection(map[string]any{"_id": 0, "max_seq": 1})`
`64`	`64`	`lastSeq, err := mongoutil.FindOneAndUpdate[int64](ctx, s.coll, filter, update, opt)`