Debugging Upstash #2

app/api/cart/[cartItemId]/route.ts

@@ -1,7 +1,7 @@
 import { z } from "zod";
-import { redis } from "@/lib/redis";
 import prismadb from "@/lib/prisma";
 import { UserRole } from "@prisma/client";
+import { redisServer } from "@/lib/redis";
 import { NextResponse } from "next/server";
 import { currentRole, currentUser } from "@/lib/auth";
 
@@ -131,7 +131,7 @@ export async function PATCH(
       },
     });
 
-    // await redis.set(`${user.id}-cart`, newCart);
+    await redisServer.set(`${user.id}-cart`, JSON.stringify(newCart));
 
     return NextResponse.json({ message: "Cart item updated!" });
   } catch (err) {
@@ -214,7 +214,7 @@ export async function DELETE(
       },
     });
 
-    // await redis.set(`${user.id}-cart`, newCart);
+    await redisServer.set(`${user.id}-cart`, JSON.stringify(newCart));
 
     return NextResponse.json({ message: "Cart item deleted!" });
   } catch (err) {

app/api/cart/route.ts

@@ -1,6 +1,6 @@
-import { redis } from "@/lib/redis";
 import prismadb from "@/lib/prisma";
 import { UserRole } from "@prisma/client";
+import { redisServer } from "@/lib/redis";
 import { NextResponse } from "next/server";
 import { currentRole, currentUser } from "@/lib/auth";
 import { CartItemSchema } from "@/lib/validators/cart-item";
@@ -168,7 +168,7 @@ export async function POST(request: Request) {
       },
     });
 
-    await redis.set(`${user.id}-cart`, newCart);
+    await redisServer.set(`${user.id}-cart`, JSON.stringify(newCart));
 
     return NextResponse.json({ message: "Item added to cart!" });
   } catch (err) {
@@ -193,12 +193,12 @@ export async function GET(request: Request) {
       return NextResponse.json({ cart: null });
     }
 
-    const cachedCart = await redis.get(`${user.id}-cart`);
+    const cachedCart = await redisServer.get(`${user.id}-cart`);
 
     if (cachedCart) {
       console.log("Cached cart was returned");
 
-      return NextResponse.json(cachedCart);
+      return NextResponse.json(JSON.parse(cachedCart));
     }
 
     const cart = await prismadb.cart.findUnique({
@@ -227,7 +227,7 @@ export async function GET(request: Request) {
       },
     });
 
-    await redis.set(`${user.id}-cart`, cart);
+    await redisServer.set(`${user.id}-cart`, JSON.stringify(cart));
 
     return NextResponse.json(cart);
   } catch (err) {

lib/redis.ts

@@ -1,12 +1,23 @@
-import { Redis } from "@upstash/redis";
+import Redis from "ioredis";
 import { Ratelimit } from "@upstash/ratelimit";
+import { Redis as RedisClient } from "@upstash/redis";
 
-export const redis = new Redis({
+export const redis = new RedisClient({
   url: process.env.UPSTASH_REDIS_REST_URL as string,
   token: process.env.UPSTASH_REDIS_REST_TOKEN as string,
 });
 
 export const apiRatelimit = new Ratelimit({
-  redis: redis ?? Redis.fromEnv(),
+  redis: redis ?? RedisClient.fromEnv(),
   limiter: Ratelimit.slidingWindow(10, "1 m"),
 });
+
+const getRedisUrl = () => {
+  if (process.env.REDIS_URL) {
+    return process.env.REDIS_URL as string;
+  }
+
+  throw new Error("Redis URL not specified!");
+};
+
+export const redisServer = new Redis(getRedisUrl());

package.json

@@ -46,6 +46,7 @@
     "date-fns": "^3.3.1",
     "dotenv": "^16.4.5",
     "firebase": "^10.7.2",
+    "ioredis": "^5.3.2",
     "lucide-react": "^0.319.0",
     "next": "14.1.0",
     "next-auth": "^5.0.0-beta.4",