upload file functionlity

Author: Mehak

app/api/contractor/projects/upload-material/route.ts

@@ -0,0 +1,43 @@
+import { NextResponse } from "next/server";
+import { getServerSession } from "next-auth";
+import { authOptions } from "@/app/api/auth/[...nextauth]/route";
+import prisma from "@/server/utills/db";
+
+interface Material {
+  productId: string;
+  quantity: number;
+}
+
+export async function POST(req: Request) {
+  const session = await getServerSession(authOptions);
+  if (!session) {
+    return new NextResponse("Unauthorized", { status: 401 });
+  }
+
+  const { projectId, filePath } = await req.json();
+
+  if (!projectId || !filePath) {
+    return new NextResponse("Project ID and file path are required", {
+      status: 400,
+    });
+  }
+
+  try {
+    const materials: Material[] = [];
+
+    for (const material of materials) {
+      await prisma.projectProduct.create({
+        data: {
+          projectId: projectId,
+          productId: material.productId,
+          quantity: material.quantity,
+        },
+      });
+    }
+
+    return NextResponse.json({ message: "Materials uploaded successfully" });
+  } catch (error) {
+    console.error("Error uploading materials:", error);
+    return new NextResponse("Internal Server Error", { status: 500 });
+  }
+}

app/api/contractor/projects/uploaded-files/route.ts

@@ -0,0 +1,22 @@
+import { NextResponse } from "next/server";
+import fs from "fs";
+import path from "path";
+
+export async function GET() {
+  const uploadDir = path.join(process.cwd(), "server", "uploads");
+
+  try {
+    const files = await fs.promises.readdir(uploadDir);
+    const pdfFiles = files
+      .filter((file) => file.endsWith(".pdf"))
+      .map((file) => ({
+        name: file,
+        path: `uploads/${file}`,
+      }));
+
+    return NextResponse.json(pdfFiles);
+  } catch (error) {
+    console.error("Error reading upload directory:", error);
+    return new NextResponse("Internal Server Error", { status: 500 });
+  }
+}

app/api/upload/route.ts

@@ -0,0 +1,39 @@
+import { NextResponse } from "next/server";
+import { getServerSession } from "next-auth";
+import { authOptions } from "@/app/api/auth/[...nextauth]/route";
+import { v4 as uuidv4 } from "uuid";
+import { promises as fs } from "fs";
+import path from "path";
+
+export async function POST(req: Request) {
+  const session = await getServerSession(authOptions);
+  if (!session) {
+    return new NextResponse("Unauthorized", { status: 401 });
+  }
+
+  const formData = await req.formData();
+  const file = formData.get("uploadedFile") as File;
+
+  if (!file) {
+    return new NextResponse("No file uploaded", { status: 400 });
+  }
+
+  if (file.type !== "application/pdf") {
+    return new NextResponse("Only PDF files are allowed", { status: 400 });
+  }
+
+  const uniqueFileName = `${uuidv4()}-${file.name}`;
+  const uploadPath = path.join(
+    process.cwd(),
+    "server",
+    "uploads",
+    uniqueFileName
+  );
+
+  await fs.mkdir(path.dirname(uploadPath), { recursive: true });
+
+  const buffer = Buffer.from(await file.arrayBuffer());
+  await fs.writeFile(uploadPath, Uint8Array.from(buffer));
+
+  return NextResponse.json({ filePath: `uploads/${uniqueFileName}` });
+}