Merge pull request #17 from ETLOnline/feature/create-db-user-on-webhook

fix(auth): dont create new user if user is already created

src/app/api/webhook/user-created/route.ts

@@ -2,7 +2,7 @@ import { Webhook } from 'svix'
 import { headers } from 'next/headers'
 import { WebhookEvent } from '@clerk/nextjs/server'
 import { InsertUser } from '@/src/db/schema'
-import { CreateUser } from '@/src/db/data-access/user/query'
+import { CreateUser, SelectUserByEmail, SelectUserById } from '@/src/db/data-access/user/query'
 
 export async function POST(req: Request) {
 
@@ -59,6 +59,14 @@ export async function POST(req: Request) {
 
   if (evt.type === 'user.created') {
     const userObj = evt.data
+
+		const userById = await SelectUserById(userObj.id)
+		const userByEmail = await SelectUserByEmail(userObj.email_addresses[0].email_address)
+
+		if (userById || userByEmail) {
+			return new Response('', { status: 200 })
+		}
+
     const newUser:InsertUser ={
       first_name: userObj.first_name || '',
       last_name: userObj.last_name || '',

src/db/data-access/user/query.ts

@@ -10,4 +10,11 @@ export async function SelectUserById(id: string) {
     return await db.query.usersTable.findFirst({
         where: eq(usersTable.external_auth_id, id)        
     });
-}
+}
+
+export async function SelectUserByEmail(email: string) {
+    return await db.query.usersTable.findFirst({
+        where: eq(usersTable.email, email)    
+    });
+}
+