Fix mongo db client to use GridFS API on 16MB exceed file

server/backend/database/mongo/client.go

@@ -22,12 +22,14 @@
 	"context"
 	"errors"
 	"fmt"
+	"log"
 	"strings"
 	gotime "time"
 
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/gridfs"
 	"go.mongodb.org/mongo-driver/mongo/options"
 	"go.mongodb.org/mongo-driver/mongo/readpref"
 
@@ -1068,21 +1070,67 @@
 	docRefKey types.DocRefKey,
 	doc *document.InternalDocument,
 ) error {
+	// 스냅샷 생성
 	snapshot, err := converter.SnapshotToBytes(doc.RootObject(), doc.AllPresences())
 	if err != nil {
 		return err
 	}
 
-	if _, err := c.collection(ColSnapshots).InsertOne(ctx, bson.M{
-		"project_id":     docRefKey.ProjectID,
-		"doc_id":         docRefKey.DocID,
-		"server_seq":     doc.Checkpoint().ServerSeq,
-		"lamport":        doc.Lamport(),
-		"version_vector": doc.VersionVector(),
-		"snapshot":       snapshot,
-		"created_at":     gotime.Now(),
-	}); err != nil {
-		return fmt.Errorf("insert snapshot: %w", err)
+	// 16MB 이상이면 GridFS에 저장
+	const maxSnapshotSize = 16 * 1024 * 1024 // 16MB
+	if len(snapshot) > maxSnapshotSize {
+		log.Println("16MB over!!!")
+
+		db := c.client.Database(c.config.YorkieDatabase)
+
+		// GridFS 버킷 생성
+		bucket, err := gridfs.NewBucket(db) // MongoDB의 c.db는 데이터베이스 객체
+		if err != nil {
+			return fmt.Errorf("failed to create GridFS bucket: %w", err)
+		}
+
+		// GridFS에 파일 업로드
+		uploadStream, err := bucket.OpenUploadStream(fmt.Sprintf("%s_snapshot", docRefKey.DocID))
+		if err != nil {
+			return fmt.Errorf("failed to open GridFS upload stream: %w", err)
+		}
+		defer uploadStream.Close()
+
+		// 스냅샷 데이터를 GridFS에 저장
+		_, err = uploadStream.Write(snapshot)
+		if err != nil {
+			return fmt.Errorf("failed to write to GridFS: %w", err)
+		}
+
+		// 파일의 ID (GridFS에서 파일을 식별하는 ObjectId)
+		fileID := uploadStream.FileID
+
+		// GridFS에 저장된 파일 ID를 사용하여 문서 삽입
+		if _, err := c.collection(ColSnapshots).InsertOne(ctx, bson.M{
+			"project_id":       docRefKey.ProjectID,
+			"doc_id":           docRefKey.DocID,
+			"server_seq":       doc.Checkpoint().ServerSeq,
+			"lamport":          doc.Lamport(),
+			"version_vector":   doc.VersionVector(),
+			"snapshot_file_id": fileID, // GridFS 파일 ID
+			"created_at":       gotime.Now(),
+		}); err != nil {
+			return fmt.Errorf("insert snapshot info: %w", err)
+		}
+
+	} else {
+		// 스냅샷이 16MB 이하일 경우 일반적인 컬렉션에 삽입
+		if _, err := c.collection(ColSnapshots).InsertOne(ctx, bson.M{
+			"project_id":     docRefKey.ProjectID,
+			"doc_id":         docRefKey.DocID,
+			"server_seq":     doc.Checkpoint().ServerSeq,
+			"lamport":        doc.Lamport(),
+			"version_vector": doc.VersionVector(),
+			"snapshot":       snapshot,
+			"created_at":     gotime.Now(),
+		}); err != nil {
+			return fmt.Errorf("insert snapshot: %w", err)
+		}
 	}
 
 	return nil

server/backend/database/testcases/testcases.go

@@ -1619,3 +1619,34 @@
 	}
 	assert.EqualValues(t, expectedKeys, keys)
 }
+
+func CreateLargeSnapshotTest(t *testing.T, db database.Database, projectID types.ID) {
+	t.Run("store and validate large snapshot test", func(t *testing.T) {
+		ctx := context.Background()
+		docKey := key.Key(fmt.Sprintf("tests$%s", t.Name()))
+
+		clientInfo, _ := db.ActivateClient(ctx, projectID, t.Name())
+		bytesID, _ := clientInfo.ID.Bytes()
+		actorID, _ := time.ActorIDFromBytes(bytesID)
+		docInfo, _ := db.FindDocInfoByKeyAndOwner(ctx, clientInfo.RefKey(), docKey, true)
+
+		doc := document.New(docKey)
+		doc.SetActor(actorID)
+
+		largeData := make([]byte, 16*1024*1024+1) // 16MB + 1 byte
+		for i := range largeData {
+			largeData[i] = byte('A' + (i % 26)) // A-Z 반복
+		}
+
+		assert.NoError(t, doc.Update(func(root *json.Object, p *presence.Presence) error {
+			root.SetBytes("largeField", largeData)
+			return nil
+		}))
+
+		docRefKey := docInfo.RefKey()
+
+		// 스냅샷 생성 및 오류 확인
+		err := db.CreateSnapshotInfo(ctx, docRefKey, doc.InternalDocument())
+		assert.NoError(t, err)
+	})
+}

test/complex/mongo_client_test.go

@@ -171,4 +171,8 @@ func TestClientWithShardedDB(t *testing.T) {
 		assert.Equal(t, docInfo1.Key, result.Key)
 		assert.Equal(t, docInfo1.ID, result.ID)
 	})
+
+	t.Run("CreateLargeSnapshotTest test", func(t *testing.T) {
+		testcases.CreateLargeSnapshotTest(t, cli, dummyProjectID)
+	})
 }