feat: implement File Upload

- FINALLLLYYY!!!!!!!!!!

package.json

@@ -31,6 +31,7 @@
     "@nestjs/jwt": "^10.1.1",
     "@nestjs/platform-express": "^10.2.5",
     "@prisma/client": "^5.3.1",
+    "@supabase/supabase-js": "^2.38.2",
     "argon2": "^0.31.1",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.0",
@@ -39,6 +40,7 @@
     "reflect-metadata": "^0.1.13",
     "rxjs": "^7.8.1",
     "slugify": "^1.6.6",
+    "tus-js-client": "^3.1.1",
     "zod": "^3.22.3"
   },
   "devDependencies": {

prisma/schema.prisma

@@ -7,8 +7,9 @@ generator client {
 }
 
 datasource db {
-  provider = "postgresql"
-  url      = env("DATABASE_URL")
+  provider     = "mysql"
+  url          = env("DATABASE_URL")
+  relationMode = "prisma"
 }
 
 model User {

src/api/project/project.controller.ts

@@ -12,11 +12,12 @@ import {
     Patch,
     Post,
     UploadedFile,
+    UseInterceptors,
     UsePipes,
 } from "@nestjs/common";
+import { FileInterceptor } from "@nestjs/platform-express";
 
 import { Express } from "express";
-import { Multer } from "multer";
 
 import {
     projectAccessDto,
@@ -26,7 +27,11 @@ import {
     ProjectDataDto,
     projectDataSchema,
 } from "../../shared/dto";
-import { AuthRole, Roles } from "../../shared/guards/auth.decorator";
+import {
+    AuthRole,
+    PublicRoute,
+    Roles,
+} from "../../shared/guards/auth.decorator";
 import { ZodValidationPipe } from "../../shared/pipes/zodPipe";
 import { ProjectService } from "./project.service";
 
@@ -107,15 +112,19 @@ export class ProjectController {
 
     @AuthRole(Roles.Verified)
     @Post("/:slug/data/new")
-    @UsePipes(new ZodValidationPipe(projectDataSchema))
+    @PublicRoute()
+    @UseInterceptors(FileInterceptor("image"))
+    // TODO: Fix this pipe cause it will be receiving stuff in the form of multipart body form
+    // @UsePipes(new ZodValidationPipe(projectDataSchema))
     CreateProjectData(
         @Body() dto: ProjectDataDto,
         @Param("slug") slug: string,
         @UploadedFile(
             new ParseFilePipe({
                 validators: [
-                    new MaxFileSizeValidator({ maxSize: 1000 }),
-                    new FileTypeValidator({ fileType: "image/jpeg" }),
+                    new FileTypeValidator({
+                        fileType: /image\/(jpeg|png|jpg)/,
+                    }),
                 ],
             }),
         )

src/api/project/project.module.ts

@@ -4,6 +4,7 @@ import { APP_GUARD } from "@nestjs/core";
 import { JwtService } from "@nestjs/jwt";
 import { PasswordService } from "src/api/auth/pwd.service";
 import { AuthGuard } from "src/shared/guards/auth.guard";
+import { SupabaseService } from "../../supabase/supabase.service";
 import { ProjectController } from "./project.controller";
 import { ProjectService } from "./project.service";
 
@@ -12,11 +13,11 @@ import { ProjectService } from "./project.service";
     controllers: [ProjectController],
     providers: [
         ProjectService,
+        SupabaseService,
         // ? The Below Are dependencies of the AuthGuard
         JwtService,
         ConfigService,
         PasswordService,
-        // TODO: Add AWS Service
         {
             provide: APP_GUARD,
             useClass: AuthGuard,

src/api/project/project.service.ts

@@ -1,15 +1,20 @@
-import { HttpException, HttpStatus, Injectable } from "@nestjs/common";
+import { HttpException, HttpStatus, Injectable, Logger } from "@nestjs/common";
 import { Express } from "express";
+import { Multer } from "multer";
 import { PrismaService } from "src/prisma/prisma.service";
 import {
     projectAccessDto,
     projectCreateDto,
     ProjectDataDto,
 } from "../../shared/dto";
+import { SupabaseService } from "../../supabase/supabase.service";
 
 @Injectable()
 export class ProjectService {
-    constructor(private readonly prisma: PrismaService) {}
+    constructor(
+        private readonly prisma: PrismaService,
+        private readonly supabase: SupabaseService,
+    ) {}
 
     async GetProject(Slug: string) {
         console.log(Slug);
@@ -62,14 +67,7 @@ export class ProjectService {
     }
 
     async DeleteProject(Slug: string) {
-        const PROJECT = await this.prisma.project.findUnique({
-            where: {
-                slug: `${Slug}`,
-            },
-            select: {
-                slug: true,
-            },
-        });
+        const PROJECT = await this.GetProject(Slug);
 
         if (!PROJECT) {
             throw new HttpException("Project Not Found", HttpStatus.NOT_FOUND);
@@ -78,33 +76,33 @@ export class ProjectService {
         return await this.prisma.DeleteProject(Slug);
     }
 
-    async UpdateProjectAccess(slug: string, dto: projectAccessDto) {
-        const PROJECT = await this.prisma.project.findUnique({
-            where: {
-                slug: `${slug}`,
-            },
-            select: {
-                slug: true,
-            },
-        });
-
+    async UpdateProjectAccess(Slug: string, dto: projectAccessDto) {
+        const PROJECT = await this.GetProject(Slug);
         if (!PROJECT) {
             throw new HttpException("Project Not Found", HttpStatus.NOT_FOUND);
         }
 
-        return await this.prisma.UpdateProjectAccess(dto, slug);
+        return await this.prisma.UpdateProjectAccess(dto, Slug);
     }
 
     async AddProjectData(
         slug: string,
         dto: ProjectDataDto,
         file: Express.Multer.File,
     ) {
-        console.log(slug, dto, file);
-
-        // TODO: Upload Project Data to S3
-        // this.aws.
-        // TODO: Add Project Data from prisma
-        // this.prisma.
+        console.log(slug, dto);
+
+        try {
+            const link = await this.supabase.uploadFile(file);
+            console.log("=>", link);
+            // TODO: Add Project Data from prisma
+            // this.prisma.
+        } catch (error) {
+            Logger.debug(error);
+            throw new HttpException(
+                "Something Went Wrong",
+                HttpStatus.INTERNAL_SERVER_ERROR,
+            );
+        }
     }
 }

src/prisma/prisma.service.ts

@@ -1,4 +1,10 @@
-import { HttpException, HttpStatus, Injectable } from "@nestjs/common";
+import {
+    HttpException,
+    HttpStatus,
+    Injectable,
+    Logger,
+    OnModuleInit,
+} from "@nestjs/common";
 import { ConfigService } from "@nestjs/config";
 import { PrismaClient, Role } from "@prisma/client";
 import * as argon from "argon2";
@@ -14,15 +20,32 @@ import {
 config();
 
 @Injectable()
-export class PrismaService extends PrismaClient {
+export class PrismaService extends PrismaClient implements OnModuleInit {
     constructor(private readonly config: ConfigService) {
-        super({
-            datasources: {
-                db: {
-                    url: config.get("DATABASE_URL"),
-                },
-            },
-        });
+        super();
+        const uriRegExp =
+            /^mysql:\/\/([a-zA-Z0-9_]+):(.\S+)@([a-zA-Z0-9-.]+)\//;
+        const url = this.config.get("DATABASE_URL");
+        if (!url) {
+            Logger.error("DATABASE_URL not found", "CONFIG");
+            throw Error("[CONFIG] DATABASE_URL Not Found");
+        }
+        Logger.debug("DATABASE_URL Found", "CONFIG");
+        if (!uriRegExp.exec(url)) {
+            Logger.error("DATABASE_URL is not valid", "CONFIG");
+            throw Error("[CONFIG] DATABASE_URL Not Valid");
+        }
+        Logger.debug("DATABASE_URL is Valid", "CONFIG");
+    }
+
+    async onModuleInit() {
+        try {
+            await this.$connect();
+            Logger.debug("Connected to Database", "Prisma");
+        } catch (error) {
+            Logger.error("Could Not Connect to Database", "PRISMA");
+            Logger.debug(error, "PRISMA");
+        }
     }
 
     async Slugify(text: string): Promise<string> {
@@ -50,7 +73,7 @@ export class PrismaService extends PrismaClient {
 
         if (!res) {
             throw new HttpException(
-                `${email} does not exists`,
+                "Email does not exists",
                 HttpStatus.FORBIDDEN,
             );
         }

src/supabase/supabase.module.ts

@@ -0,0 +1,10 @@
+import { Global, Module } from "@nestjs/common";
+import { ConfigService } from "@nestjs/config";
+import { PrismaService } from "../prisma/prisma.service";
+
+@Global()
+@Module({
+    providers: [ConfigService, PrismaService],
+    exports: [PrismaService],
+})
+export class SupabaseModule {}

src/supabase/supabase.service.ts

@@ -0,0 +1,37 @@
+import { Injectable } from "@nestjs/common";
+import { Express } from "express";
+import * as fs from "fs";
+import { Multer } from "multer";
+import { createClient } from "@supabase/supabase-js";
+import { timestamp } from "rxjs";
+import * as timers from "timers";
+
+const supabase = createClient(
+    // TODO: implement config service and constructor
+    "",
+    "",
+);
+
+@Injectable()
+export class SupabaseService {
+    async uploadFile(file: Express.Multer.File) {
+        const time = Date.now();
+        const { data, error } = await supabase.storage
+            .from("EzMs-bucket")
+            .upload(
+                `/data/${file.originalname}-${time}.${
+                    file.mimetype.split("/")[1]
+                }`,
+                file.buffer,
+            );
+
+        console.log(data);
+
+        if (error) {
+            // Handle error
+            throw error;
+        } else {
+            return data.path;
+        }
+    }
+}