fix: use superjson for local serialization

packages/@eventual/core-runtime/package.json

@@ -20,6 +20,7 @@
     "@opensearch-project/opensearch": "^2.2.1",
     "heap-js": "2.2.0",
     "itty-router": "^2.6.6",
+    "superjson": "^1.13.1",
     "ulidx": "^0.3.0",
     "zod": "^3.21.4"
   },

packages/@eventual/core-runtime/src/local/serialize.ts

@@ -0,0 +1,9 @@
+import superjson from "superjson";
+
+export function toJSON(data: any) {
+  return JSON.stringify(superjson.serialize(data));
+}
+
+export function fromJSON<T = any>(data: string): T {
+  return superjson.deserialize(JSON.parse(data));
+}

packages/@eventual/core-runtime/src/local/stores/entity-store.ts

@@ -39,6 +39,7 @@ import {
 import { LocalEnvConnector } from "../local-container.js";
 import { LocalSerializable } from "../local-persistance-store.js";
 import { paginateItems } from "./pagination.js";
+import { fromJSON, toJSON } from "../serialize.js";
 
 type PK = KeyValue;
 type SK = KeyValue;
@@ -622,11 +623,11 @@ function serializeTableMap(tableMap: TableMap): Buffer {
       ] as const;
     })
   );
-  return Buffer.from(JSON.stringify(record));
+  return Buffer.from(toJSON(record));
 }
 
 function deserializeTableMap(data: Buffer): TableMap {
-  const record: SerializedData = JSON.parse(data.toString("utf-8"));
+  const record: SerializedData = fromJSON(data.toString("utf-8"));
   return new Map(
     Object.entries(record).map(([pk, partition]) => {
       return [

packages/@eventual/core-runtime/src/local/stores/execution-history-state-store.ts

@@ -4,6 +4,7 @@ import type {
   UpdateHistoryRequest,
 } from "../../stores/execution-history-state-store.js";
 import type { LocalSerializable } from "../local-persistance-store.js";
+import { fromJSON, toJSON } from "../serialize.js";
 
 export class LocalExecutionHistoryStateStore
   implements ExecutionHistoryStateStore, LocalSerializable
@@ -16,7 +17,7 @@ export class LocalExecutionHistoryStateStore
     return Object.fromEntries(
       Object.entries(this.executionHistory).map(([e, history]) => [
         e,
-        Buffer.from(JSON.stringify(history)),
+        Buffer.from(toJSON(history)),
       ])
     );
   }
@@ -29,7 +30,7 @@ export class LocalExecutionHistoryStateStore
       Object.fromEntries(
         Object.entries(data).map(([key, value]) => [
           key,
-          JSON.parse(value.toString("utf-8")),
+          fromJSON(value.toString("utf-8")),
         ])
       )
     );

packages/@eventual/core-runtime/src/local/stores/execution-history-store.ts

@@ -7,6 +7,7 @@ import type { WorkflowEvent } from "@eventual/core/internal";
 import { ExecutionHistoryStore } from "../../stores/execution-history-store.js";
 import type { LocalSerializable } from "../local-persistance-store.js";
 import { paginateItems } from "./pagination.js";
+import { fromJSON, toJSON } from "../serialize.js";
 
 export class LocalExecutionHistoryStore
   extends ExecutionHistoryStore
@@ -20,7 +21,7 @@ export class LocalExecutionHistoryStore
     return Object.fromEntries(
       Object.entries(this.eventStore).map(([key, value]) => [
         key,
-        Buffer.from(JSON.stringify(value)),
+        Buffer.from(toJSON(value)),
       ])
     );
   }
@@ -31,7 +32,7 @@ export class LocalExecutionHistoryStore
         ? Object.fromEntries(
             Object.entries(data).map(([key, value]) => [
               key,
-              JSON.parse(value.toString("utf-8")),
+              fromJSON(value.toString("utf-8")),
             ])
           )
         : {}