feat: implemented the s3 media component for the profile picture

apps/core-api/package.json

@@ -16,6 +16,8 @@
   "license": "ISC",
   "packageManager": "pnpm@10.27.0",
   "dependencies": {
+    "@aws-sdk/client-s3": "^3.1006.0",
+    "@aws-sdk/s3-request-presigner": "^3.1006.0",
     "amqplib": "^0.10.9",
     "bcrypt": "^6.0.0",
     "cookie-parser": "^1.4.7",

apps/core-api/src/controllers/media.controller.ts

@@ -0,0 +1,28 @@
+import type { Request, Response, NextFunction } from "express";
+
+import { generateUploadUrlService } from "../services/media.service.js";
+
+export const generateUploadUrlController = async (
+  req: Request,
+  res: Response,
+  next: NextFunction
+) => {
+  try {
+
+    const { fileName, fileType, folder } = req.body;
+
+    const result = await generateUploadUrlService(
+      folder,
+      fileName,
+      fileType
+    );
+
+    res.status(200).json({
+      success: true,
+      data: result
+    });
+
+  } catch (error) {
+    next(error);
+  }
+};

apps/core-api/src/lib/s3.client.ts

@@ -0,0 +1,9 @@
+import { S3Client } from "@aws-sdk/client-s3";
+
+export const s3Client = new S3Client({
+  region: process.env.AWS_REGION!,
+  credentials: {
+    accessKeyId: process.env.AWS_ACCESS_KEY_ID!,
+    secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY!
+  }
+});

apps/core-api/src/models/brand.model.ts

@@ -19,6 +19,7 @@ export interface IBrandProfile extends Document {
 
   isProfileComplete: boolean;
   isVerified: boolean;
+  profileImageUrl?: string,
 }
 
 const BrandProfileSchema = new Schema<IBrandProfile>(
@@ -65,7 +66,10 @@ const BrandProfileSchema = new Schema<IBrandProfile>(
       type: [String], // store S3 keys
       default: [],
     },
-
+    profileImageUrl: {
+      type: String,
+      default: ""
+    },
     isProfileComplete: {
       type: Boolean,
       default: false,

apps/core-api/src/models/influencer.model.ts

@@ -20,6 +20,7 @@ export interface IInfluencerProfile extends Document {
 
   isProfileComplete: boolean;
   isVerified: boolean;
+  profileImageUrl?: string,
 }
 
 const InfluencerProfileSchema = new Schema<IInfluencerProfile>(
@@ -50,6 +51,10 @@ const InfluencerProfileSchema = new Schema<IInfluencerProfile>(
       type: String,
       maxlength: 500,
     },
+    profileImageUrl: {
+      type: String,
+      default: ""
+    },
 
     instagramUrl: String,
     youtubeUrl: String,

apps/core-api/src/routes/index.ts

@@ -1,4 +1,6 @@
-import { Router } from "express";
+import { Router } from "express";
+
+import mediaRoutes from "../routes/media.routes.js";
 
 import userRoutes from "./users.routes.js";
 import authRoutes from "./auth.routes.js";
@@ -24,5 +26,6 @@ router.use("/bookings", bookingRoutes);
 router.use("/orders", orderRoutes);
 router.use("/payments", paymentRoutes);
 router.use("/search", searchRoutes);
+router.use("/media", mediaRoutes);
 
 export default router

apps/core-api/src/routes/media.routes.ts

@@ -0,0 +1,14 @@
+import { Router } from "express";
+
+import { generateUploadUrlController } from "../controllers/media.controller.js";
+import { authenticate } from "../middlewares/auth.middleware.js";
+
+const router:Router = Router();
+
+router.post(
+  "/upload-url",
+  authenticate,
+  generateUploadUrlController
+);
+
+export default router;

apps/core-api/src/services/media.service.ts

@@ -0,0 +1,33 @@
+import { PutObjectCommand } from "@aws-sdk/client-s3";
+import { getSignedUrl } from "@aws-sdk/s3-request-presigner";
+
+import { s3Client } from "../lib/s3.client.js";
+
+export const generateUploadUrlService = async (
+  folder: string,
+  fileName: string,
+  fileType: string
+) => {
+
+  const uniqueFileName = `${Date.now()}-${fileName}`;
+
+  const key = `${folder}/${uniqueFileName}`;
+
+  const command = new PutObjectCommand({
+    Bucket: process.env.AWS_BUCKET_NAME!,
+    Key: key,
+    ContentType: fileType
+  });
+
+  const uploadUrl = await getSignedUrl(s3Client, command, {
+    expiresIn: 300
+  });
+
+  const fileUrl =
+    `https://${process.env.AWS_BUCKET_NAME}.s3.${process.env.AWS_REGION}.amazonaws.com/${key}`;
+
+  return {
+    uploadUrl,
+    fileUrl
+  };
+};