Update participant and study API routes

src/app/api/participants/[id]/route.ts

@@ -0,0 +1,37 @@
+import { db } from "~/server/db";
+import { participants } from "~/server/db/schema";
+import { NextResponse } from "next/server";
+import { eq } from "drizzle-orm";
+
+export async function DELETE(
+  request: Request,
+  { params }: { params: { id: string } }
+) {
+  console.log('DELETE route hit, params:', params);
+  const id = parseInt(params.id);
+  
+  if (isNaN(id)) {
+    console.log('Invalid ID:', id);
+    return NextResponse.json({ error: 'Invalid ID' }, { status: 400 });
+  }
+
+  try {
+    console.log('Attempting to delete participant with ID:', id);
+    const deletedParticipant = await db.delete(participants)
+      .where(eq(participants.id, id))
+      .returning();
+
+    console.log('Deleted participant:', deletedParticipant);
+
+    if (deletedParticipant.length === 0) {
+      console.log('Participant not found');
+      return NextResponse.json({ error: 'Participant not found' }, { status: 404 });
+    }
+
+    console.log('Participant deleted successfully');
+    return NextResponse.json({ message: "Participant deleted successfully" });
+  } catch (error) {
+    console.error('Error deleting participant:', error);
+    return NextResponse.json({ error: 'Failed to delete participant', details: String(error) }, { status: 500 });
+  }
+}

src/app/api/participants/route.ts

@@ -0,0 +1,25 @@
+import { db } from "~/server/db";
+import { participants } from "~/server/db/schema";
+import { NextResponse } from "next/server";
+import { eq } from "drizzle-orm";
+
+export async function GET(request: Request) {
+  const { searchParams } = new URL(request.url);
+  const studyId = searchParams.get('studyId');
+  
+  if (!studyId) {
+    return NextResponse.json({ error: 'Study ID is required' }, { status: 400 });
+  }
+
+  const allParticipants = await db.select().from(participants).where(eq(participants.studyId, parseInt(studyId)));
+  return NextResponse.json(allParticipants);
+}
+
+export async function POST(request: Request) {
+  const { name, studyId } = await request.json();
+  if (!name || !studyId) {
+    return NextResponse.json({ error: 'Name and Study ID are required' }, { status: 400 });
+  }
+  const newParticipant = await db.insert(participants).values({ name, studyId }).returning();
+  return NextResponse.json(newParticipant[0]);
+}

src/app/api/studies/[id]/route.ts

@@ -0,0 +1,86 @@
+import { db } from "~/server/db";
+import { studies } from "~/server/db/schema";
+import { NextResponse } from "next/server";
+import { eq, and } from "drizzle-orm";
+import { auth } from "@clerk/nextjs/server";
+
+export async function GET(
+  request: Request,
+  { params }: { params: { id: string } }
+) {
+  const { userId } = auth();
+  if (!userId) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  const id = parseInt(params.id);
+  if (isNaN(id)) {
+    return NextResponse.json({ error: 'Invalid ID' }, { status: 400 });
+  }
+
+  const study = await db.select().from(studies).where(and(eq(studies.id, id), eq(studies.userId, userId))).limit(1);
+
+  if (study.length === 0) {
+    return NextResponse.json({ error: 'Study not found' }, { status: 404 });
+  }
+
+  return NextResponse.json(study[0]);
+}
+
+export async function PUT(
+  request: Request,
+  { params }: { params: { id: string } }
+) {
+  const { userId } = auth();
+  if (!userId) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  const id = parseInt(params.id);
+  if (isNaN(id)) {
+    return NextResponse.json({ error: 'Invalid ID' }, { status: 400 });
+  }
+
+  const { title, description } = await request.json();
+  if (!title) {
+    return NextResponse.json({ error: 'Title is required' }, { status: 400 });
+  }
+
+  const updatedStudy = await db
+    .update(studies)
+    .set({ title, description })
+    .where(and(eq(studies.id, id), eq(studies.userId, userId)))
+    .returning();
+
+  if (updatedStudy.length === 0) {
+    return NextResponse.json({ error: 'Study not found or unauthorized' }, { status: 404 });
+  }
+
+  return NextResponse.json(updatedStudy[0]);
+}
+
+export async function DELETE(
+  request: Request,
+  { params }: { params: { id: string } }
+) {
+  const { userId } = auth();
+  if (!userId) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  const id = parseInt(params.id);
+  if (isNaN(id)) {
+    return NextResponse.json({ error: 'Invalid ID' }, { status: 400 });
+  }
+
+  const deletedStudy = await db
+    .delete(studies)
+    .where(and(eq(studies.id, id), eq(studies.userId, userId)))
+    .returning();
+
+  if (deletedStudy.length === 0) {
+    return NextResponse.json({ error: 'Study not found or unauthorized' }, { status: 404 });
+  }
+
+  return NextResponse.json({ message: "Study deleted successfully" });
+}

src/app/api/studies/route.ts

@@ -2,30 +2,29 @@ import { db } from "~/server/db";
 import { studies } from "~/server/db/schema";
 import { NextResponse } from "next/server";
 import { eq } from "drizzle-orm";
+import { auth } from "@clerk/nextjs/server";
 
-export async function GET() {
-  const allStudies = await db.select().from(studies);
+export async function GET(request: Request) {
+  const { userId } = auth();
+  if (!userId) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  const allStudies = await db.select().from(studies).where(eq(studies.userId, userId));
   return NextResponse.json(allStudies);
 }
 
 export async function POST(request: Request) {
+  const { userId } = auth();
+  if (!userId) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
   const { title, description } = await request.json();
-  const newStudy = await db.insert(studies).values({ title, description }).returning();
+  if (!title) {
+    return NextResponse.json({ error: 'Title is required' }, { status: 400 });
+  }
+
+  const newStudy = await db.insert(studies).values({ title, description, userId }).returning();
   return NextResponse.json(newStudy[0]);
-}
-
-export async function PUT(request: Request) {
-  const { id, title, description } = await request.json();
-  const updatedStudy = await db
-    .update(studies)
-    .set({ title, description })
-    .where(eq(studies.id, id))
-    .returning();
-  return NextResponse.json(updatedStudy[0]);
-}
-
-export async function DELETE(request: Request) {
-  const { id } = await request.json();
-  await db.delete(studies).where(eq(studies.id, id));
-  return NextResponse.json({ message: "Study deleted" });
 }

src/app/api/users/route.ts

@@ -0,0 +1,21 @@
+import { db } from "~/server/db";
+import { users } from "~/server/db/schema";
+import { NextResponse } from "next/server";
+
+export async function POST(request: Request) {
+  try {
+    const { email } = await request.json();
+    
+    // Check if email is provided
+    if (!email) {
+      return NextResponse.json({ error: "Email is required" }, { status: 400 });
+    }
+
+    // Insert the new user into the database
+    const newUser = await db.insert(users).values({ email }).returning();
+    return NextResponse.json(newUser[0]);
+  } catch (error) {
+    console.error("Error creating user:", error);
+    return NextResponse.json({ error: "Failed to create user" }, { status: 500 });
+  }
+}