feat(core): add upstash kv adapter

.changeset/small-oranges-return.md

@@ -0,0 +1,5 @@
+---
+"@bigcommerce/catalyst-core": patch
+---
+
+Add upstash kv adapter.

core/lib/kv/adapters/upstash.ts

@@ -0,0 +1,40 @@
+import { Redis } from '@upstash/redis';
+
+import { KvAdapter, SetCommandOptions } from '../types';
+
+import { MemoryKvAdapter } from './memory';
+
+const memoryKv = new MemoryKvAdapter();
+
+export class UpstashKvAdapter implements KvAdapter {
+  private upstashKv = Redis.fromEnv();
+  private memoryKv = memoryKv;
+
+  async get<Data>(key: string) {
+    const memoryValue = await this.memoryKv.get<Data>(key);
+
+    return memoryValue ?? this.upstashKv.get<Data>(key);
+  }
+
+  async mget<Data>(...keys: string[]) {
+    const memoryValues = await this.memoryKv.mget<Data>(...keys);
+
+    return memoryValues.length ? memoryValues : this.upstashKv.mget<Data[]>(keys);
+  }
+
+  async set<Data, Options extends SetCommandOptions = SetCommandOptions>(
+    key: string,
+    value: Data,
+    opts?: Options,
+  ) {
+    await this.memoryKv.set(key, value, opts);
+
+    const response = await this.upstashKv.set(key, value, opts);
+
+    if (response === 'OK') {
+      return null;
+    }
+
+    return response;
+  }
+}

core/lib/kv/index.ts

@@ -77,6 +77,12 @@ async function createKVAdapter() {
     return new VercelKvAdapter();
   }
 
+  if (process.env.UPSTASH_REDIS_REST_URL && process.env.UPSTASH_REDIS_REST_TOKEN) {
+    const { UpstashKvAdapter } = await import('./adapters/upstash');
+
+    return new UpstashKvAdapter();
+  }
+
   const { MemoryKvAdapter } = await import('./adapters/memory');
 
   return new MemoryKvAdapter();

core/package.json

@@ -26,6 +26,7 @@
     "@radix-ui/react-select": "^2.0.0",
     "@radix-ui/react-slot": "^1.0.2",
     "@radix-ui/react-tabs": "^1.0.4",
+    "@upstash/redis": "^1.31.3",
     "@vercel/analytics": "^1.3.1",
     "@vercel/kv": "^2.0.0",
     "@vercel/speed-insights": "^1.0.11",