feat: integrate storage actions for user profile photo uploads and update related input schemas

Author: kingRayhan

src/app/api/auth/github/callback/route.ts

@@ -1,7 +1,9 @@
 import { GithubOAuthService } from "@/backend/services/oauth/GithubOAuthService";
 import * as sessionActions from "@/backend/services/session.actions";
 import * as userActions from "@/backend/services/user.action";
+import * as storageActions from "@/backend/services/storage.action";
 import { NextResponse } from "next/server";
+import { DIRECTORY_NAME } from "@/backend/models/domain-models";
 
 const githubOAuthService = new GithubOAuthService();
 
@@ -23,13 +25,26 @@ export async function GET(request: Request) {
     );
   }
 
+  const uploadedFileResponse = await storageActions.uploadByUrl({
+    url: githubUser?.data?.avatar_url,
+    key: `${DIRECTORY_NAME.USER_AVATARS}/${githubUser?.data?.login}.jpeg`,
+  });
+
   const bootedSocialUser = await userActions.bootSocialUser({
     service: "github",
     service_uid: githubUser?.data.id?.toString(),
     name: githubUser?.data?.login,
     username: githubUser?.data?.login,
     email: githubUser?.data.email,
-    profile_photo: githubUser?.data?.avatar_url,
+    profile_photo: uploadedFileResponse.success
+      ? {
+          key: uploadedFileResponse.data.key,
+          provider: uploadedFileResponse.data.provider as
+            | "r2"
+            | "cloudinary"
+            | "direct",
+        }
+      : undefined,
     bio: githubUser?.data?.bio ?? "",
   });
 

src/backend/services/inputs/article.input.ts

@@ -9,7 +9,7 @@ export const ArticleRepositoryInput = {
     cover_image: z
       .object({
         key: z.string(),
-        provider: z.enum(["cloudinary", "direct"]),
+        provider: z.enum(["cloudinary", "direct", "r2"]),
       })
       .optional()
       .nullable(),

src/backend/services/inputs/user.input.ts

@@ -7,7 +7,13 @@ export const UserActionInput = {
     name: z.string(),
     username: z.string(),
     email: z.string().email(),
-    profile_photo: z.string().url(),
+    profile_photo: z
+      .object({
+        key: z.string(),
+        provider: z.enum(["cloudinary", "direct", "r2"]),
+      })
+      .optional()
+      .nullable(),
     bio: z.string().optional().nullable(),
   }),
   updateMyProfileInput: z.object({

src/backend/services/session.actions.ts

@@ -75,7 +75,7 @@ export const validateSessionToken = async (
   }
 
   await persistenceRepository.userSession.update({
-    operationName: "validateSessionToken/userSession.update--",
+    operationName: "validateSessionToken/userSession.update",
     where: eq("id", session.id),
     data: {
       last_action_at: new Date(),

src/backend/services/storage.action.ts

@@ -21,6 +21,13 @@ export const uploadByUrl = async (_input: z.infer<typeof schema>) => {
       Body: body,
     });
     await s3Client.send(command);
+    return {
+      success: true as const,
+      data: {
+        key: input.key,
+        provider: "r2",
+      },
+    };
   } catch (error) {
     return handleActionException(error);
   }

src/backend/services/user.action.ts

@@ -40,7 +40,7 @@ export async function bootSocialUser(
             name: input.name,
             username: input.username,
             email: input.email,
-            profile_photo: null,
+            profile_photo: input.profile_photo,
             bio: input.bio ?? "",
           },
         ])