Clerk Webhooks with Prisma (Sync database, user model)

export async function POST(req: Request) {
  // You can find this in the Clerk Dashboard -> Webhooks -> choose the webhook
  const WEBHOOK_SECRET = process.env.CLERK_WEBHOOK_SECRET!;

  if (!WEBHOOK_SECRET) {
    throw new Error(
      "Please add WEBHOOK_SECRET from Clerk Dashboard to .env or .env.local",
    );
  }

  // Get the headers
  const headerPayload = headers();
  const svix_id = headerPayload.get("svix-id");
  const svix_timestamp = headerPayload.get("svix-timestamp");
  const svix_signature = headerPayload.get("svix-signature");

  // If there are no headers, error out
  if (!svix_id || !svix_timestamp || !svix_signature) {
    return new Response("Error occured -- no svix headers", {
      status: 400,
    });
  }

  // Get the body
  const payload = (await req.json()) as Request;
  const body = JSON.stringify(payload);

  // Create a new SVIX instance with your secret.
  const wh = new Webhook(WEBHOOK_SECRET);

  let evt: WebhookEvent;

  // Verify the payload with the headers
  try {
    evt = wh.verify(body, {
      "svix-id": svix_id,
      "svix-timestamp": svix_timestamp,
      "svix-signature": svix_signature,
    }) as WebhookEvent;
  } catch (err) {
    console.error("Error verifying webhook:", err);
    return new Response("Error occured", {
      status: 400,
    });
  }

  const { id, username, image_url } = evt.data as UserJSON;

const eventType = evt.type;
  // Manage user events
  if (eventType === "user.created") {
    await initiateUserProfile({
      userId: id,
      username: username,
      displayPicture: image_url,
    }).then(() => {
      return new Response("", { status: 201 });
    }),
      (err: unknown) => {
        console.error("Error creating user profile:", err);
        return new Response("Error occured", {
          status: 400,
        });
      };
  }

  return new Response("boop", { status: 201 });
}

export async function POST(req: Request) {
  // You can find this in the Clerk Dashboard -> Webhooks -> choose the webhook
  const WEBHOOK_SECRET = process.env.CLERK_WEBHOOK_SECRET!;

  if (!WEBHOOK_SECRET) {
    throw new Error(
      "Please add WEBHOOK_SECRET from Clerk Dashboard to .env or .env.local",
    );
  }

  // Get the headers
  const headerPayload = headers();
  const svix_id = headerPayload.get("svix-id");
  const svix_timestamp = headerPayload.get("svix-timestamp");
  const svix_signature = headerPayload.get("svix-signature");

  // If there are no headers, error out
  if (!svix_id || !svix_timestamp || !svix_signature) {
    return new Response("Error occured -- no svix headers", {
      status: 400,
    });
  }

  // Get the body
  const payload = (await req.json()) as Request;
  const body = JSON.stringify(payload);

  // Create a new SVIX instance with your secret.
  const wh = new Webhook(WEBHOOK_SECRET);

  let evt: WebhookEvent;

  // Verify the payload with the headers
  try {
    evt = wh.verify(body, {
      "svix-id": svix_id,
      "svix-timestamp": svix_timestamp,
      "svix-signature": svix_signature,
    }) as WebhookEvent;
  } catch (err) {
    console.error("Error verifying webhook:", err);
    return new Response("Error occured", {
      status: 400,
    });
  }

  const { id, username, image_url } = evt.data as UserJSON;

const eventType = evt.type;
  // Manage user events
  if (eventType === "user.created") {
    await initiateUserProfile({
      userId: id,
      username: username,
      displayPicture: image_url,
    }).then(() => {
      return new Response("", { status: 201 });
    }),
      (err: unknown) => {
        console.error("Error creating user profile:", err);
        return new Response("Error occured", {
          status: 400,
        });
      };
  }

  return new Response("boop", { status: 201 });
}

import { db } from '@/server/db/client'
import { currentUser } from '@clerk/nextjs'
import { redirect } from 'next/navigation'

const createNewUser = async (): Promise<void> => {
  try {
    const clerkUser = await currentUser()

    if (!clerkUser?.id) {
      throw new Error('Clerk user ID is undefined.')
    }

    const match = await db.user.findUnique({
      where: {
        clerkId: clerkUser.id,
      },
    })

    if (match && match.onboarded) {
      redirect('/')
    } else if (!match) {
      await db.user.create({
        data: {
          clerkId: clerkUser.id,
          name: clerkUser.firstName,
          email: clerkUser.emailAddresses[0]?.emailAddress,
          createdAt: new Date(),
          
        },
      })
      redirect('/onboarding')
    }

    redirect('/onboarding')
  } catch (error) {
    console.error('Error creating new user:', error)
  }
}

const NewUser = async () => {
  await createNewUser()
  return <div>...loading</div>
}

export default NewUser

import { db } from '@/server/db/client'
import { currentUser } from '@clerk/nextjs'
import { redirect } from 'next/navigation'

const createNewUser = async (): Promise<void> => {
  try {
    const clerkUser = await currentUser()

    if (!clerkUser?.id) {
      throw new Error('Clerk user ID is undefined.')
    }

    const match = await db.user.findUnique({
      where: {
        clerkId: clerkUser.id,
      },
    })

    if (match && match.onboarded) {
      redirect('/')
    } else if (!match) {
      await db.user.create({
        data: {
          clerkId: clerkUser.id,
          name: clerkUser.firstName,
          email: clerkUser.emailAddresses[0]?.emailAddress,
          createdAt: new Date(),
          
        },
      })
      redirect('/onboarding')
    }

    redirect('/onboarding')
  } catch (error) {
    console.error('Error creating new user:', error)
  }
}

const NewUser = async () => {
  await createNewUser()
  return <div>...loading</div>
}

export default NewUser