feat: added redis store

packages/openauth/package.json

@@ -12,6 +12,7 @@
     "@types/node": "22.10.1",
     "arctic": "2.2.2",
     "hono": "4.6.9",
+    "ioredis": "5.4.1",
     "typescript": "5.6.3",
     "valibot": "1.0.0-beta.5"
   },

packages/openauth/src/storage/redis.ts

@@ -0,0 +1,71 @@
+import { Redis, RedisOptions } from "ioredis"
+import { joinKey, splitKey, StorageAdapter } from "./storage.js"
+
+export interface RedisStorageOptions {
+  connectionUrl: string
+}
+
+export interface RedisStorageCredentials extends RedisOptions {}
+
+type OnlyOne<T> = T extends RedisStorageCredentials
+  ? Required<RedisStorageCredentials> extends T
+    ? T
+    : never
+  : RedisStorageOptions extends T
+    ? T
+    : never
+
+export function RedisStorage<
+  T extends RedisStorageOptions | RedisStorageCredentials,
+>(opts: OnlyOne<T>): StorageAdapter {
+  const client =
+    "connectionUrl" in opts ? new Redis(opts.connectionUrl) : new Redis(opts)
+
+  return {
+    async get(key: string[]) {
+      const value = await client.get(joinKey(key))
+      if (!value) return
+      return JSON.parse(value) as Record<string, any>
+    },
+    async set(key: string[], value: any, ttl?: number) {
+      if (ttl !== undefined && ttl > 0) {
+        await client.set(
+          joinKey(key),
+          JSON.stringify(value),
+          "EX",
+          Math.trunc(ttl),
+        )
+      } else {
+        await client.set(joinKey(key), JSON.stringify(value))
+      }
+    },
+    async remove(key: string[]) {
+      await client.del(joinKey(key))
+    },
+    async *scan(prefix: string[]) {
+      let cursor = "0"
+
+      while (true) {
+        let [next, keys] = await client.scan(
+          cursor,
+          "MATCH",
+          `${joinKey(prefix)}*`,
+        )
+
+        for (const key of keys) {
+          const value = await client.get(key)
+          if (value !== null) {
+            yield [splitKey(key), JSON.parse(value)]
+          }
+        }
+
+        // Number(..) cant handle 64bit integer
+        if (BigInt(next) === BigInt(0)) {
+          break
+        }
+
+        cursor = next
+      }
+    },
+  }
+}