some fixes

Author: devkiran

apps/web/app/api/cron/shopify/checkout-completed/route.ts

@@ -127,13 +127,13 @@ export async function POST(req: Request) {
       ]);
     }
 
-    const amount = Number(parsedOrder.total_price);
+    const eventId = nanoid(16);
+    const amount = Number(parsedOrder.total_price) * 100;
     const currency = parsedOrder.currency;
     const invoiceId = parsedOrder.confirmation_number;
-
-    const eventId = nanoid(16);
     const paymentProcessor = "shopify";
 
+
     const [_sale, link, _project] = await Promise.all([
       // record sale
       recordSale({
@@ -145,9 +145,8 @@ export async function POST(req: Request) {
         amount,
         currency,
         invoice_id: invoiceId,
-        metadata: JSON.stringify({
-          parsedOrder,
-        }),
+        metadata: JSON.stringify(parsedOrder),
+        
       }),
 
       // update link sales count

apps/web/app/api/shopify/webhook/customer-created.ts

@@ -1,25 +1,20 @@
-import { parseRequestBody } from "@/lib/api/utils";
 import { log } from "@dub/utils";
 import { NextResponse } from "next/server";
-import { customerCreated } from "./customer-created";
 import { orderPaid } from "./order-paid";
+import { verifyShopifySignature } from "./utils";
 
-// TODO:
-// Verify the webhook signature
-
-const relevantTopics = new Set([
-  "customers/create",
-  "customers/update",
-  "orders/paid",
-]);
+const relevantTopics = new Set(["orders/paid"]);
 
 // POST /api/shopify/webhook – Listen to Shopify webhook events
 export const POST = async (req: Request) => {
-  const body = await parseRequestBody(req);
+  const body = await req.json();
 
   // Find the topic from the headers
   const headers = req.headers;
   const topic = headers.get("x-shopify-topic") || "";
+  const signature = headers.get("x-shopify-hmac-sha256") || "";
+
+  await verifyShopifySignature({ body, signature });
 
   if (!relevantTopics.has(topic)) {
     return new Response("Unsupported topic, skipping...", {
@@ -29,9 +24,6 @@ export const POST = async (req: Request) => {
 
   try {
     switch (topic) {
-      case "customers/create":
-        await customerCreated(body);
-        break;
       case "orders/paid":
         await orderPaid(body);
         break;

apps/web/app/api/shopify/webhook/route.ts

@@ -1,22 +1,25 @@
 import crypto from "crypto";
-import { NextRequest } from "next/server";
 
-export async function verifyWebhookSignature(req: NextRequest) {
-  const signature = req.headers["x-shopify-hmac-sha256"];
-
-  const genSig = crypto
+export const verifyShopifySignature = async ({
+  body,
+  signature,
+}: {
+  body: Record<string, unknown>;
+  signature: string;
+}) => {
+  const generatedSignature = crypto
     .createHmac("sha256", `${process.env.SHOPIFY_WEBHOOK_SECRET}`)
-    .update(JSON.stringify(req))
+    .update(JSON.stringify(body))
     .digest("base64");
 
   console.log({
-    genSig,
+    generatedSignature,
     signature,
   });
 
-  if (genSig !== signature) {
+  if (generatedSignature !== signature) {
     throw new Error("Invalid webhook signature.");
   }
 
   return true;
-}
+};