feat(resources): get file md5& bunble module

package.json

@@ -40,13 +40,15 @@
     "@nestjs/serve-static": "^4.0.1",
     "@nestjs/typeorm": "^10.0.2",
     "@prisma/client": "5.12.1",
+    "@types/md5": "^2.3.5",
     "ajv": "^8.12.0",
     "bcryptjs": "^2.4.3",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.1",
     "express": "^4.19.2",
     "fluent-ffmpeg": "^2.1.2",
     "handlebars": "^4.7.8",
+    "md5": "^2.3.0",
     "mime-types": "^2.1.35",
     "multer": "1.4.5-lts.1",
     "nodemailer": "^6.9.13",

prisma/schema.prisma

@@ -139,7 +139,7 @@ model AnswerUserAttitude {
 enum AttachmentType {
   image
   video
-  udio
+  audio
   file
 }
 
@@ -445,18 +445,18 @@ model GroupTarget {
 //
 
 model MaterialBundle {
-  id            Int        @id @default(autoincrement())
+  id            Int                       @id @default(autoincrement())
   title         String
   content       String
-  creator       User       @relation(fields: [creatorId], references: [id])
-  creatorId     Int        @map("creator_id")
-  createdAt     DateTime   @default(now()) @map("created_at") @db.Timestamptz(6)
-  updatedAt     DateTime   @updatedAt() @map("updated_at") @db.Timestamptz(6)
-  rating        Float      @default(0)
-  ratingCount   Int        @default(0) @map("rating_count")
-  myRating      Float?     @map("my_rating")
-  commentsCount Int        @default(0) @map("comments_count")
-  materials     Material[]
+  creator       User                      @relation(fields: [creatorId], references: [id])
+  creatorId     Int                       @map("creator_id")
+  createdAt     DateTime                  @default(now()) @map("created_at") @db.Timestamptz(6)
+  updatedAt     DateTime                  @updatedAt() @map("updated_at") @db.Timestamptz(6)
+  rating        Float                     @default(0)
+  ratingCount   Int                       @default(0) @map("rating_count")
+  myRating      Float?                    @map("my_rating")
+  commentsCount Int                       @default(0) @map("comments_count")
+  materials     MaterialbundlesRelation[]
 
   @@map("material_bundle")
 }
@@ -473,23 +473,32 @@ enum MaterialType {
 }
 
 model Material {
-  id               Int             @id @default(autoincrement())
-  type             MaterialType
-  url              String
-  name             String
-  uploader         User            @relation(fields: [uploaderId], references: [id])
-  uploaderId       Int             @map("uploader_id")
-  createdAt        DateTime        @default(now()) @map("created_at") @db.Timestamptz(6)
-  expires          Int?
-  downloadCount    Int             @default(0) @map("download_count")
+  id              Int                       @id @default(autoincrement())
+  type            MaterialType
+  url             String
+  name            String
+  uploader        User                      @relation(fields: [uploaderId], references: [id])
+  uploaderId      Int                       @map("uploader_id")
+  createdAt       DateTime                  @default(now()) @map("created_at") @db.Timestamptz(6)
+  expires         Int?
+  downloadCount   Int                       @default(0) @map("download_count")
+  materialBundles MaterialbundlesRelation[]
   /// [metaType]
-  meta             Json            @db.Json
-  MaterialBundle   MaterialBundle? @relation(fields: [materialBundleId], references: [id])
-  materialBundleId Int?
+  meta            Json                      @db.Json
 
   @@map("material")
 }
 
+model MaterialbundlesRelation {
+  material   Material       @relation(fields: [materialId], references: [id])
+  materialId Int            @map("material_id")
+  bundle     MaterialBundle @relation(fields: [bundleId], references: [id], onDelete: Cascade)
+  bundleId   Int            @map("bundle_id")
+
+  @@id([materialId, bundleId])
+  @@map("materialbundles_relation")
+}
+
 //
 // questions.es.prisma
 //

src/attachments/attachments.error.ts

@@ -5,3 +5,12 @@ export class InvalidAttachmentTypeError extends BaseError {
     super('InvalidAttachmentTypeError', 'Invalid attachment type', 400);
   }
 }
+export class AttachmentNotFoundError extends BaseError {
+  constructor(attachmentId: number) {
+    super(
+      'AttachmentNotFoundError',
+      `Attachment ${attachmentId} Not Found`,
+      404,
+    );
+  }
+}

src/attachments/attachments.prisma

@@ -1,7 +1,7 @@
 enum AttachmentType {
   image
   video
-  udio
+  audio
   file
 }
 

src/attachments/attachments.service.ts

@@ -3,6 +3,7 @@ import { MaterialsService } from '../materials/materials.service';
 import { AttachmentType } from '@prisma/client';
 import { PrismaService } from '../common/prisma/prisma.service';
 import { attachmentDto } from './DTO/attachments.dto';
+import { AttachmentNotFoundError } from './attachments.error';
 
 @Injectable()
 export class AttachmentsService {
@@ -33,7 +34,7 @@ export class AttachmentsService {
       },
     });
     if (attachment == null) {
-      throw new Error();
+      throw new AttachmentNotFoundError(id);
     }
     return attachment;
   }

src/materialbundles/DTO/create-materialbundle.dto.ts

@@ -1,4 +1,4 @@
-import { IsArray, IsInt, IsNotEmpty, IsString } from 'class-validator';
+import { IsArray, IsInt, IsString } from 'class-validator';
 import { BaseResponseDto } from '../../common/DTO/base-response.dto';
 
 export class createMaterialBundleRequestDto {
@@ -7,7 +7,6 @@ export class createMaterialBundleRequestDto {
   @IsString()
   content: string;
   @IsArray()
-  @IsNotEmpty()
   @IsInt({ each: true })
   materials: number[];
 }

src/materialbundles/materialbundles.controller.ts

@@ -1,12 +1,16 @@
 import {
   Body,
   Controller,
+  Delete,
   Get,
   Headers,
   Param,
   ParseIntPipe,
   Patch,
   Post,
+  UseFilters,
+  UsePipes,
+  ValidationPipe,
 } from '@nestjs/common';
 import { AuthorizedAction, AuthService } from '../auth/auth.service';
 import {
@@ -17,8 +21,12 @@ import {
 import { BundleResponseDto } from './DTO/materialbundle.dto';
 import { MaterialbundlesService } from './materialbundles.service';
 import { updateMaterialBundleDto } from './DTO/update-materialbundle.dto';
+import { BaseErrorExceptionFilter } from '../common/error/error-filter';
+import { BaseResponseDto } from '../common/DTO/base-response.dto';
 
 @Controller('/material-bundles')
+@UsePipes(new ValidationPipe())
+@UseFilters(new BaseErrorExceptionFilter())
 export class MaterialbundlesController {
   constructor(
     private readonly materialbundlesService: MaterialbundlesService,
@@ -88,7 +96,7 @@ export class MaterialbundlesController {
       await this.materialbundlesService.getBundleDetail(id);
     return {
       code: 200,
-      message: ' get material bundle detail successfully',
+      message: 'get material bundle detail successfully',
       data: {
         materialBundle,
       },
@@ -99,8 +107,8 @@ export class MaterialbundlesController {
     @Param('materialBundleId', ParseIntPipe) id: number,
     @Body() { title, content, materials }: updateMaterialBundleDto,
     @Headers('Authorization') auth: string | undefined,
-  ) {
-    console.log(title, content, materials);
+  ): Promise<BaseResponseDto> {
+    //console.log(title, content, materials);
     const userId = this.authService.verify(auth).userId;
     await this.materialbundlesService.updateMaterialBundle(
       id,
@@ -109,5 +117,17 @@ export class MaterialbundlesController {
       content,
       materials,
     );
+    return {
+      code: 200,
+      message: 'Materialbundle updated successfully',
+    };
+  }
+  @Delete('/:materialBundleId')
+  async deleteMaterialBundle(
+    @Param('materialBundleId', ParseIntPipe) id: number,
+    @Headers('Authorization') auth: string | undefined,
+  ) {
+    const userId = this.authService.verify(auth).userId;
+    await this.materialbundlesService.deleteMaterialBundle(id, userId);
   }
 }

src/materialbundles/materialbundles.error.ts

@@ -0,0 +1,19 @@
+import { BaseError } from '../common/error/base-error';
+
+export class BundleNotFoundError extends BaseError {
+  constructor(bundleId: number) {
+    super('BundleNotFoundError', `Bundle ${bundleId} Not Found`, 404);
+  }
+}
+
+export class UpdateBundleDeniedError extends BaseError {
+  constructor(bundleId: number) {
+    super('UpdateBundleDeniedError', `Can Not Update Bundle ${bundleId}`, 403);
+  }
+}
+
+export class DeleteBundleDeniedError extends BaseError {
+  constructor(bundleId: number) {
+    super('DeleteBundleDeniedError', `Can Not Delete Bundle ${bundleId}`, 403);
+  }
+}