add tRPC route for resumes (progress)

Author: anna-sage

apps/blade/src/app/member/application/_components/member-application-form.tsx

@@ -50,16 +50,14 @@ export function MemberApplicationForm() {
     },
   });
 
-  const uploadResume = async (file: File): Promise<string> => {
-    if (!file) throw new Error("No file provided");
-
-    const resumeUrl = await api.resume.uploadResume.useMutation().mutateAsync({
-      fileName: file.name,
-      fileContent: file,
-    });
-
-    return resumeUrl;
-  }
+  const uploadResume = api.resume.uploadResume.useMutation({
+    onSuccess() {
+      toast.success("Resume sent to bucket!");
+    },
+    onError() {
+      toast.error("There was a problem storing your resume, please try again!");
+    }
+  });
 
   const form = useForm({
     schema: InsertMemberSchema.extend({
@@ -171,9 +169,22 @@ export function MemberApplicationForm() {
       <form
         className="space-y-4"
         noValidate
-        onSubmit={form.handleSubmit((values) => {
-          const resumeUrl = uploadResume(values.resumeUpload[0]);
-          createMember.mutate(values);
+        onSubmit={form.handleSubmit(async (values) => {
+            try {
+              let resumeUrl = "";
+              if (values.resumeUpload?.length) {
+                const file = values.resumeUpload[0];
+                resumeUrl = await uploadResume.mutateAsync(file);
+              }
+
+              createMember.mutate({
+                ...values,
+                resumeUrl, // Include uploaded resume URL
+              });
+            } catch (error) {
+              console.error("Error uploading resume or creating member:", error);
+              toast.error("Something went wrong while processing your application.");
+            }
         })}
       >
         <h1 className="text-2xl font-bold">Application Form</h1>

packages/api/src/routers/resume-upload.ts

@@ -4,33 +4,27 @@ import { z } from "zod";
 import { env } from "../env";
 
 const s3Client = new Client({
-    endPoint: "",
+    endPoint: env.MINIO_ENDPOINT,
     accessKey: env.MINIO_ACCESS_KEY,
     secretKey: env.MINIO_SECRET_KEY,
 });
 
 export const resumeUploadRouter = {
     uploadResume: protectedProcedure.input(
-        z.object({
-            fileName: z.string(),
-            fileContent: z.instanceof(File),
-        })
+        z.instanceof(File)
     )
     .mutation(async ({ input, ctx }) => {
-        const { fileName, fileContent } = input;
-
         const bucketName = "member-resumes";
-        const objectName = `${ctx.session.user.id}/${fileName}`;
-        const fileStream = fileContent.stream;
+        const objectName = `${ctx.session.user.id}/${input.name}`;
 
         // Ensure bucket exists
         const bucketExists = await s3Client.bucketExists(bucketName);
         if (!bucketExists) {
           await s3Client.makeBucket(bucketName, "us-east-1");
         }
 
-        await s3Client.putObject(bucketName, objectName, fileStream);
-        const resumeUrl = `${env.MINIO_PUBLIC_URL}/${bucketName}/${objectName}`;
+        await s3Client.putObject(bucketName, objectName, file);
+        const resumeUrl = `https://${env.MINIO_ENDPOINT}/${bucketName}/${objectName}`;
     })
 };