From e8bd26b92a34a9b72869d096766870e9af3bd2b2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=98=E5=8F=B8?= <mosluce@gmail.com>
Date: Fri, 8 Nov 2024 17:35:36 +0800
Subject: [PATCH] fix(checkpoint-mongodb): fix utf8 encoding support

---
 libs/checkpoint-mongodb/src/index.ts | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/libs/checkpoint-mongodb/src/index.ts b/libs/checkpoint-mongodb/src/index.ts
index 94e4eddf..77c9d6b7 100644
--- a/libs/checkpoint-mongodb/src/index.ts
+++ b/libs/checkpoint-mongodb/src/index.ts
@@ -87,7 +87,7 @@ export class MongoDBSaver extends BaseCheckpointSaver {
     };
     const checkpoint = (await this.serde.loadsTyped(
       doc.type,
-      doc.checkpoint.value()
+      doc.checkpoint.value("utf8")
     )) as Checkpoint;
     const serializedWrites = await this.db
       .collection(this.checkpointWritesCollectionName)
@@ -100,7 +100,7 @@ export class MongoDBSaver extends BaseCheckpointSaver {
           serializedWrite.channel,
           await this.serde.loadsTyped(
             serializedWrite.type,
-            serializedWrite.value.value()
+            serializedWrite.value.value("utf8")
           ),
         ] as CheckpointPendingWrite;
       })
@@ -111,7 +111,7 @@ export class MongoDBSaver extends BaseCheckpointSaver {
       pendingWrites,
       metadata: (await this.serde.loadsTyped(
         doc.type,
-        doc.metadata.value()
+        doc.metadata.value("utf8")
       )) as CheckpointMetadata,
       parentConfig:
         doc.parent_checkpoint_id != null
@@ -171,11 +171,11 @@ export class MongoDBSaver extends BaseCheckpointSaver {
     for await (const doc of result) {
       const checkpoint = (await this.serde.loadsTyped(
         doc.type,
-        doc.checkpoint.value()
+        doc.checkpoint.value("utf8")
       )) as Checkpoint;
       const metadata = (await this.serde.loadsTyped(
         doc.type,
-        doc.metadata.value()
+        doc.metadata.value("utf8")
       )) as CheckpointMetadata;
 
       yield {