Add superjson.

Author: sanny-io

bun.lock

@@ -31,6 +31,11 @@
       "require": "./dist/schemas.cjs",
       "import": "./dist/schemas.mjs"
     },
+    "./superjson": {
+      "@zenstack-cache/source": "./src/superjson.ts",
+      "require": "./dist/superjson.cjs",
+      "import": "./dist/superjson.mjs"
+    },
     "./types": {
       "@zenstack-cache/source": "./src/types.ts",
       "require": "./dist/types.cjs",
@@ -65,6 +70,10 @@
         "require": "./dist/schemas.cjs",
         "import": "./dist/schemas.mjs"
       },
+      "./superjson": {
+        "require": "./dist/superjson.cjs",
+        "import": "./dist/superjson.mjs"
+      },
       "./types": {
         "require": "./dist/types.cjs",
         "import": "./dist/types.mjs"
@@ -86,9 +95,11 @@
     "test:watch": "vitest --watch"
   },
   "dependencies": {
+    "decimal.js": "^10.6.0",
     "ioredis": "catalog:",
     "murmurhash": "^2.0.1",
     "stable-hash": "^0.0.6",
+    "superjson": "^2.2.2",
     "zod": "catalog:"
   },
   "devDependencies": {

packages/cache/package.json

@@ -1,6 +1,7 @@
 import type { CacheInvalidationOptions, CacheProvider, CacheEntry } from '../types'
 import { Redis } from 'ioredis'
 import { getTotalTtl } from '../utils'
+import { superjson } from '../superjson'
 
 export class RedisCacheProvider implements CacheProvider {
   private readonly redis: Redis
@@ -16,14 +17,14 @@ export class RedisCacheProvider implements CacheProvider {
       return undefined
     }
 
-    return JSON.parse(entryJson) as CacheEntry
+    return superjson.parse(entryJson) as CacheEntry
   }
 
   async set(key: string, entry: CacheEntry) {
     const multi = this.redis.multi()
     const formattedKey = formatQueryKey(key)
 
-    multi.set(formattedKey, JSON.stringify(entry))
+    multi.set(formattedKey, superjson.stringify(entry))
 
     const totalTtl = getTotalTtl(entry)
 

packages/cache/src/providers/redis.ts

@@ -0,0 +1,13 @@
+import { Decimal } from 'decimal.js'
+import superjson from 'superjson'
+
+superjson.registerCustom<Decimal, string>(
+  {
+    isApplicable: (v): v is Decimal => Decimal.isDecimal(v),
+    serialize: v => v.toJSON(),
+    deserialize: v => new Decimal(v),
+  },
+  'decimal.js',
+)
+
+export { superjson }