From 226a24aac45af8f626404ed649c1e0f3cec12691 Mon Sep 17 00:00:00 2001
From: Giorgi Zankaidze <giorgi.zankaidze@optio.ai>
Date: Mon, 8 Dec 2025 22:38:17 +0400
Subject: [PATCH 1/7] feat: add implementation guide

---
 DAY3-4-IMPLEMENTATION-GUIDE.md | 554 +++++++++++++++++++++++++++++++++
 1 file changed, 554 insertions(+)
 create mode 100644 DAY3-4-IMPLEMENTATION-GUIDE.md

diff --git a/DAY3-4-IMPLEMENTATION-GUIDE.md b/DAY3-4-IMPLEMENTATION-GUIDE.md
new file mode 100644
index 0000000..b140778
--- /dev/null
+++ b/DAY3-4-IMPLEMENTATION-GUIDE.md
@@ -0,0 +1,554 @@
+# Day 3-4: Database & Video Entity - Implementation Guide
+
+## Overview
+
+This guide provides step-by-step instructions for implementing the database schema and video entity with status tracking for the StreamForge project.
+
+**Estimated Time**: 4-6 hours  
+**Prerequisites**: 
+- Docker and docker-compose installed
+- PostgreSQL container running
+- TypeORM and related dependencies installed (already done)
+
+---
+
+## Step 1: Verify Prerequisites
+
+### 1.1 Check Database Container is Running
+
+```bash
+docker-compose up -d postgres
+docker ps | grep streamforge-postgres
+```
+
+Expected output: Container should be running and healthy.
+
+### 1.2 Verify Dependencies
+
+Check that these packages are installed in `package.json`:
+- `@nestjs/typeorm` (v11.0.0)
+- `typeorm` (v0.3.28)
+- `pg` (v8.16.3)
+
+If missing, install them:
+```bash
+npm install @nestjs/typeorm typeorm pg
+```
+
+---
+
+## Step 2: Configure TypeORM in App Module
+
+### 2.1 Update `apps/api/src/app/app.module.ts`
+
+Add TypeORM configuration to connect to PostgreSQL:
+
+**Current state**: Only has ConfigModule imported.
+
+**What to add**:
+1. Import `TypeOrmModule` from `@nestjs/typeorm`
+2. Import `ConfigService` from `@nestjs/config`
+3. Add `TypeOrmModule.forRootAsync()` to imports array
+4. Use `ConfigService` to inject database configuration from `configuration.ts`
+
+**Implementation**:
+
+```typescript
+import { Module } from '@nestjs/common';
+import { ConfigModule, ConfigService } from '@nestjs/config';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { AppController } from './app.controller';
+import { AppService } from './app.service';
+import configuration from '../config/configuration';
+
+@Module({
+  imports: [
+    ConfigModule.forRoot({
+      isGlobal: true,
+      load: [configuration],
+      envFilePath: ['.env'],
+    }),
+    TypeOrmModule.forRootAsync({
+      imports: [ConfigModule],
+      useFactory: (configService: ConfigService) => ({
+        type: 'postgres',
+        host: configService.get<string>('database.host'),
+        port: configService.get<number>('database.port'),
+        username: configService.get<string>('database.username'),
+        password: configService.get<string>('database.password'),
+        database: configService.get<string>('database.database'),
+        synchronize: configService.get<boolean>('database.synchronize'),
+        logging: configService.get<boolean>('database.logging'),
+        autoLoadEntities: true, // Automatically load entities
+      }),
+      inject: [ConfigService],
+    }),
+  ],
+  controllers: [AppController],
+  providers: [AppService],
+})
+export class AppModule {}
+```
+
+**Key points**:
+- `forRootAsync` allows async configuration using ConfigService
+- `autoLoadEntities: true` automatically discovers and loads entity files
+- Database config values come from `configuration.ts` which reads from environment variables
+
+---
+
+## Step 3: Create Video Entity
+
+### 3.1 Create Directory Structure
+
+```bash
+mkdir -p apps/api/src/app/videos/entities
+```
+
+### 3.2 Create `apps/api/src/app/videos/entities/video.entity.ts`
+
+Create the Video entity with all required fields and status enum:
+
+```typescript
+import {
+  Entity,
+  PrimaryGeneratedColumn,
+  Column,
+  CreateDateColumn,
+  UpdateDateColumn,
+} from 'typeorm';
+
+export enum VideoStatus {
+  UPLOADING = 'UPLOADING',
+  UPLOADED = 'UPLOADED',
+  QUEUED = 'QUEUED',
+  PROCESSING = 'PROCESSING',
+  COMPLETED = 'COMPLETED',
+  FAILED = 'FAILED',
+}
+
+@Entity('videos')
+export class Video {
+  @PrimaryGeneratedColumn('uuid')
+  id: string;
+
+  @Column({ type: 'varchar', length: 255 })
+  originalFilename: string;
+
+  @Column({ type: 'varchar', length: 500 })
+  s3Key: string;
+
+  @Column({
+    type: 'enum',
+    enum: VideoStatus,
+    default: VideoStatus.UPLOADING,
+  })
+  status: VideoStatus;
+
+  @Column({ type: 'varchar', length: 100 })
+  mimeType: string;
+
+  @CreateDateColumn()
+  createdAt: Date;
+
+  @UpdateDateColumn()
+  updatedAt: Date;
+}
+```
+
+**Field explanations**:
+- `id`: UUID primary key, auto-generated
+- `originalFilename`: Original name of uploaded file (max 255 chars)
+- `s3Key`: MinIO object key/path where file is stored (max 500 chars)
+- `status`: Enum tracking video processing state
+- `mimeType`: MIME type of the video file (e.g., 'video/mp4')
+- `createdAt`: Auto-generated timestamp on creation
+- `updatedAt`: Auto-updated timestamp on modification
+
+**Status enum flow**:
+1. `UPLOADING` - File is being uploaded
+2. `UPLOADED` - Upload complete, ready for queue
+3. `QUEUED` - Job added to RabbitMQ queue
+4. `PROCESSING` - Worker is transcoding
+5. `COMPLETED` - Transcoding finished successfully
+6. `FAILED` - Error occurred at any stage
+
+---
+
+## Step 4: Create Videos Module
+
+### 4.1 Create `apps/api/src/app/videos/videos.module.ts`
+
+```typescript
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { Video } from './entities/video.entity';
+import { VideosService } from './videos.service';
+
+@Module({
+  imports: [TypeOrmModule.forFeature([Video])],
+  providers: [VideosService],
+  exports: [VideosService],
+})
+export class VideosModule {}
+```
+
+**Key points**:
+- `TypeOrmModule.forFeature([Video])` registers Video repository for this module
+- `exports: [VideosService]` makes service available to other modules
+- This follows NestJS feature module pattern
+
+---
+
+## Step 5: Create Videos Service
+
+### 5.1 Create `apps/api/src/app/videos/videos.service.ts`
+
+Implement basic CRUD operations:
+
+```typescript
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+import { Video, VideoStatus } from './entities/video.entity';
+
+@Injectable()
+export class VideosService {
+  constructor(
+    @InjectRepository(Video)
+    private videoRepository: Repository<Video>,
+  ) {}
+
+  /**
+   * Create a new video record
+   */
+  async create(
+    originalFilename: string,
+    s3Key: string,
+    mimeType: string,
+    status: VideoStatus = VideoStatus.UPLOADING,
+  ): Promise<Video> {
+    const video = this.videoRepository.create({
+      originalFilename,
+      s3Key,
+      mimeType,
+      status,
+    });
+    return await this.videoRepository.save(video);
+  }
+
+  /**
+   * Find video by ID
+   */
+  async findOne(id: string): Promise<Video | null> {
+    return await this.videoRepository.findOne({ where: { id } });
+  }
+
+  /**
+   * Get all videos
+   */
+  async findAll(): Promise<Video[]> {
+    return await this.videoRepository.find({
+      order: { createdAt: 'DESC' },
+    });
+  }
+
+  /**
+   * Update video record
+   */
+  async update(id: string, updateData: Partial<Video>): Promise<Video> {
+    await this.videoRepository.update(id, updateData);
+    const updated = await this.findOne(id);
+    if (!updated) {
+      throw new Error(`Video with ID ${id} not found`);
+    }
+    return updated;
+  }
+
+  /**
+   * Update video status
+   */
+  async updateStatus(id: string, status: VideoStatus): Promise<Video> {
+    return await this.update(id, { status });
+  }
+
+  /**
+   * Delete video record
+   */
+  async remove(id: string): Promise<void> {
+    await this.videoRepository.delete(id);
+  }
+}
+```
+
+**Method explanations**:
+- `create()`: Creates new video record with initial data
+- `findOne()`: Retrieves single video by UUID
+- `findAll()`: Gets all videos, ordered by creation date (newest first)
+- `update()`: Updates any video fields
+- `updateStatus()`: Convenience method to update status only
+- `remove()`: Deletes video record (doesn't delete file from MinIO)
+
+---
+
+## Step 6: Register Videos Module in App Module
+
+### 6.1 Update `apps/api/src/app/app.module.ts`
+
+Add VideosModule to imports:
+
+```typescript
+import { Module } from '@nestjs/common';
+import { ConfigModule, ConfigService } from '@nestjs/config';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { AppController } from './app.controller';
+import { AppService } from './app.service';
+import { VideosModule } from './videos/videos.module';
+import configuration from '../config/configuration';
+
+@Module({
+  imports: [
+    ConfigModule.forRoot({
+      isGlobal: true,
+      load: [configuration],
+      envFilePath: ['.env'],
+    }),
+    TypeOrmModule.forRootAsync({
+      // ... TypeORM config from Step 2
+    }),
+    VideosModule, // Add this line
+  ],
+  controllers: [AppController],
+  providers: [AppService],
+})
+export class AppModule {}
+```
+
+---
+
+## Step 7: Testing the Implementation
+
+### 7.1 Start the Application
+
+```bash
+nx serve api
+# or
+npm run start:dev
+```
+
+**Expected behavior**:
+- Application should start without errors
+- TypeORM should connect to PostgreSQL
+- You should see database connection logs (if logging is enabled)
+- Table `videos` should be automatically created (if synchronize is true)
+
+### 7.2 Verify Database Connection
+
+Check PostgreSQL logs:
+```bash
+docker logs streamforge-postgres
+```
+
+You should see connection attempts from the NestJS app.
+
+### 7.3 Test Creating a Video Record
+
+Create a simple test script or use the NestJS REPL:
+
+**Option A: Create a test endpoint temporarily**
+
+Add to `apps/api/src/app/app.controller.ts`:
+
+```typescript
+import { Controller, Get, Post, Body } from '@nestjs/common';
+import { AppService } from './app.service';
+import { VideosService } from './videos/videos.service';
+import { VideoStatus } from './videos/entities/video.entity';
+
+@Controller()
+export class AppController {
+  constructor(
+    private readonly appService: AppService,
+    private readonly videosService: VideosService, // Add this
+  ) {}
+
+  @Get()
+  getHello(): string {
+    return this.appService.getHello();
+  }
+
+  // Temporary test endpoint
+  @Post('test-video')
+  async testCreateVideo() {
+    const video = await this.videosService.create(
+      'test-video.mp4',
+      'raw-videos/test-uuid.mp4',
+      'video/mp4',
+      VideoStatus.UPLOADED,
+    );
+    return video;
+  }
+
+  @Get('test-videos')
+  async testGetVideos() {
+    return await this.videosService.findAll();
+  }
+}
+```
+
+Don't forget to import VideosService in `app.module.ts`:
+
+```typescript
+import { VideosModule } from './videos/videos.module';
+
+@Module({
+  imports: [
+    // ... other imports
+    VideosModule,
+  ],
+  // ...
+})
+```
+
+**Option B: Use database client**
+
+Connect to PostgreSQL and verify:
+```bash
+docker exec -it streamforge-postgres psql -U postgres -d streamforge
+```
+
+Then run:
+```sql
+SELECT * FROM videos;
+```
+
+### 7.4 Test CRUD Operations
+
+1. **Create**: POST to `/test-video` endpoint
+2. **Read**: GET `/test-videos` to see all videos
+3. **Update**: Test status update in code
+4. **Delete**: Test removal in code
+
+---
+
+## Step 8: Verify Database Schema
+
+### 8.1 Check Table Structure
+
+Connect to PostgreSQL:
+```bash
+docker exec -it streamforge-postgres psql -U postgres -d streamforge
+```
+
+Run:
+```sql
+\d videos
+```
+
+**Expected columns**:
+- `id` (uuid, primary key)
+- `originalFilename` (varchar)
+- `s3Key` (varchar)
+- `status` (enum)
+- `mimeType` (varchar)
+- `createdAt` (timestamp)
+- `updatedAt` (timestamp)
+
+### 8.2 Verify Enum Values
+
+```sql
+SELECT unnest(enum_range(NULL::videos_status_enum));
+```
+
+Should show: UPLOADING, UPLOADED, QUEUED, PROCESSING, COMPLETED, FAILED
+
+---
+
+## Troubleshooting
+
+### Issue: "Cannot connect to database"
+
+**Solutions**:
+1. Verify PostgreSQL container is running: `docker ps`
+2. Check database credentials in `.env` or `configuration.ts`
+3. Ensure network connectivity: `docker network ls`
+4. Check PostgreSQL logs: `docker logs streamforge-postgres`
+
+### Issue: "Entity metadata not found"
+
+**Solutions**:
+1. Verify `autoLoadEntities: true` in TypeORM config
+2. Check entity file path matches module structure
+3. Ensure entity is exported correctly
+4. Restart the application
+
+### Issue: "Table does not exist"
+
+**Solutions**:
+1. Verify `synchronize: true` in development mode
+2. Manually create migration if needed
+3. Check database name matches configuration
+
+### Issue: "Enum type does not exist"
+
+**Solutions**:
+1. TypeORM should create enum automatically with synchronize
+2. If not, manually create: `CREATE TYPE video_status AS ENUM (...);`
+3. Restart application to trigger schema sync
+
+---
+
+## Success Criteria
+
+By the end of this implementation, you should have:
+
+- [x] TypeORM connected to PostgreSQL successfully
+- [x] `videos` table created in database
+- [x] Video entity with all required fields
+- [x] Status enum with all 6 states
+- [x] VideosModule and VideosService created
+- [x] Basic CRUD operations working
+- [x] Can create a video record via service
+- [x] Can query video records from database
+
+---
+
+## Next Steps
+
+After completing this guide, you're ready for:
+- **Day 5-6**: MinIO Storage Service
+- The videos service will be used to track uploaded files
+- Status updates will be integrated with transcoding pipeline
+
+---
+
+## File Structure Summary
+
+```
+apps/api/src/app/
+├── app.module.ts (modified - added TypeORM and VideosModule)
+├── videos/
+│   ├── entities/
+│   │   └── video.entity.ts (new)
+│   ├── videos.module.ts (new)
+│   └── videos.service.ts (new)
+└── ...
+```
+
+---
+
+## Additional Notes
+
+- **TypeORM Synchronize**: In development, `synchronize: true` auto-creates/updates tables. In production, use migrations instead.
+- **UUID Generation**: TypeORM automatically generates UUIDs for `@PrimaryGeneratedColumn('uuid')`
+- **Timestamps**: `@CreateDateColumn` and `@UpdateDateColumn` are automatically managed by TypeORM
+- **Repository Pattern**: Using `@InjectRepository` provides type-safe database operations
+
+---
+
+## References
+
+- [NestJS TypeORM Documentation](https://docs.nestjs.com/techniques/database)
+- [TypeORM Entities](https://typeorm.io/entities)
+- [TypeORM Decorators](https://typeorm.io/decorator-reference)
+

From dc42fc4af1f6f664cd2e3b448c9de9a5c91967cc Mon Sep 17 00:00:00 2001
From: Giorgi Zankaidze <giorgi.zankaidze@optio.ai>
Date: Tue, 9 Dec 2025 19:34:31 +0400
Subject: [PATCH 2/7] feat: integrate TypeORM and add video management
 endpoints

---
 apps/api/src/app/app.controller.ts            | 27 ++++++-
 apps/api/src/app/app.module.ts                | 22 +++++-
 .../src/app/videos/entities/video.entity.ts   | 45 ++++++++++++
 apps/api/src/app/videos/videos.module.ts      | 12 +++
 apps/api/src/app/videos/videos.service.ts     | 73 +++++++++++++++++++
 5 files changed, 175 insertions(+), 4 deletions(-)
 create mode 100644 apps/api/src/app/videos/entities/video.entity.ts
 create mode 100644 apps/api/src/app/videos/videos.module.ts
 create mode 100644 apps/api/src/app/videos/videos.service.ts

diff --git a/apps/api/src/app/app.controller.ts b/apps/api/src/app/app.controller.ts
index 593311e..795f13b 100644
--- a/apps/api/src/app/app.controller.ts
+++ b/apps/api/src/app/app.controller.ts
@@ -1,11 +1,16 @@
-import { Controller, Get, Logger } from '@nestjs/common';
+import { Controller, Get, Post, Logger } from '@nestjs/common';
 import { AppService } from './app.service';
+import { VideosService } from './videos/videos.service';
+import { VideoStatus } from './videos/entities/video.entity';
 
 @Controller()
 export class AppController {
   logger = new Logger(AppController.name);
 
-  constructor(private readonly appService: AppService) {
+  constructor(
+    private readonly appService: AppService,
+    private readonly videosService: VideosService,
+  ) {
     this.logger.log(`AppController constructor`);
   }
 
@@ -13,4 +18,22 @@ export class AppController {
   getData() {
     return this.appService.getData();
   }
+
+  // Temporary test endpoint - Create a video record
+  @Post('test-video')
+  async testCreateVideo() {
+    const video = await this.videosService.create(
+      'test-video.mp4',
+      'raw-videos/test-uuid.mp4',
+      'video/mp4',
+      VideoStatus.UPLOADED,
+    );
+    return video;
+  }
+
+  // Temporary test endpoint - Get all videos
+  @Get('test-videos')
+  async testGetVideos() {
+    return await this.videosService.findAll();
+  }
 }
diff --git a/apps/api/src/app/app.module.ts b/apps/api/src/app/app.module.ts
index 91b383d..370b773 100644
--- a/apps/api/src/app/app.module.ts
+++ b/apps/api/src/app/app.module.ts
@@ -1,8 +1,10 @@
 import { Module } from '@nestjs/common';
-import { ConfigModule } from '@nestjs/config';
+import { ConfigModule, ConfigService } from '@nestjs/config';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import configuration from '../config/configuration';
 import { AppController } from './app.controller';
 import { AppService } from './app.service';
-import configuration from '../config/configuration';
+import { VideosModule } from './videos/videos.module';
 
 @Module({
   imports: [
@@ -11,6 +13,22 @@ import configuration from '../config/configuration';
       load: [configuration],
       envFilePath: ['.env'],
     }),
+    TypeOrmModule.forRootAsync({
+      imports: [ConfigModule],
+      useFactory: (configService: ConfigService) => ({
+        type: 'postgres',
+        host: configService.get<string>('database.host'),
+        port: configService.get<number>('database.port'),
+        username: configService.get<string>('database.username'),
+        password: configService.get<string>('database.password'),
+        database: configService.get<string>('database.database'),
+        synchronize: configService.get<boolean>('database.synchronize'),
+        logging: configService.get<boolean>('database.logging'),
+        autoLoadEntities: true, // Automatically load entities
+      }),
+      inject: [ConfigService],
+    }),
+    VideosModule,
   ],
   controllers: [AppController],
   providers: [AppService],
diff --git a/apps/api/src/app/videos/entities/video.entity.ts b/apps/api/src/app/videos/entities/video.entity.ts
new file mode 100644
index 0000000..09e33fd
--- /dev/null
+++ b/apps/api/src/app/videos/entities/video.entity.ts
@@ -0,0 +1,45 @@
+import {
+    Column,
+    CreateDateColumn,
+    Entity,
+    PrimaryGeneratedColumn,
+    UpdateDateColumn,
+} from 'typeorm';
+
+export enum VideoStatus {
+  UPLOADING = 'UPLOADING',
+  UPLOADED = 'UPLOADED',
+  QUEUED = 'QUEUED',
+  PROCESSING = 'PROCESSING',
+  COMPLETED = 'COMPLETED',
+  FAILED = 'FAILED',
+}
+
+@Entity('videos')
+export class Video {
+  @PrimaryGeneratedColumn('uuid')
+  id: string;
+
+  @Column({ type: 'varchar', length: 255 })
+  originalFilename: string;
+
+  @Column({ type: 'varchar', length: 500 })
+  s3Key: string;
+
+  @Column({
+    type: 'enum',
+    enum: VideoStatus,
+    default: VideoStatus.UPLOADING,
+  })
+  status: VideoStatus;
+
+  @Column({ type: 'varchar', length: 100 })
+  mimeType: string;
+
+  @CreateDateColumn()
+  createdAt: Date;
+
+  @UpdateDateColumn()
+  updatedAt: Date;
+}
+
diff --git a/apps/api/src/app/videos/videos.module.ts b/apps/api/src/app/videos/videos.module.ts
new file mode 100644
index 0000000..a6d8233
--- /dev/null
+++ b/apps/api/src/app/videos/videos.module.ts
@@ -0,0 +1,12 @@
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { Video } from './entities/video.entity';
+import { VideosService } from './videos.service';
+
+@Module({
+  imports: [TypeOrmModule.forFeature([Video])],
+  providers: [VideosService],
+  exports: [VideosService],
+})
+export class VideosModule {}
+
diff --git a/apps/api/src/app/videos/videos.service.ts b/apps/api/src/app/videos/videos.service.ts
new file mode 100644
index 0000000..c7658c4
--- /dev/null
+++ b/apps/api/src/app/videos/videos.service.ts
@@ -0,0 +1,73 @@
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+import { Video, VideoStatus } from './entities/video.entity';
+
+@Injectable()
+export class VideosService {
+  constructor(
+    @InjectRepository(Video)
+    private videoRepository: Repository<Video>,
+  ) {}
+
+  /**
+   * Create a new video record
+   */
+  async create(
+    originalFilename: string,
+    s3Key: string,
+    mimeType: string,
+    status: VideoStatus = VideoStatus.UPLOADING,
+  ): Promise<Video> {
+    const video = this.videoRepository.create({
+      originalFilename,
+      s3Key,
+      mimeType,
+      status,
+    });
+    return await this.videoRepository.save(video);
+  }
+
+  /**
+   * Find video by ID
+   */
+  async findOne(id: string): Promise<Video | null> {
+    return await this.videoRepository.findOne({ where: { id } });
+  }
+
+  /**
+   * Get all videos
+   */
+  async findAll(): Promise<Video[]> {
+    return await this.videoRepository.find({
+      order: { createdAt: 'DESC' },
+    });
+  }
+
+  /**
+   * Update video record
+   */
+  async update(id: string, updateData: Partial<Video>): Promise<Video> {
+    await this.videoRepository.update(id, updateData);
+    const updated = await this.findOne(id);
+    if (!updated) {
+      throw new Error(`Video with ID ${id} not found`);
+    }
+    return updated;
+  }
+
+  /**
+   * Update video status
+   */
+  async updateStatus(id: string, status: VideoStatus): Promise<Video> {
+    return await this.update(id, { status });
+  }
+
+  /**
+   * Delete video record
+   */
+  async remove(id: string): Promise<void> {
+    await this.videoRepository.delete(id);
+  }
+}
+

From 79d0e4539311a7a8d00cdae0b6a9215c59bc6701 Mon Sep 17 00:00:00 2001
From: Giorgi Zankaidze <giorgi.zankaidze@optio.ai>
Date: Wed, 10 Dec 2025 11:20:12 +0400
Subject: [PATCH 3/7] fix

---
 apps/api/src/app/app.controller.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/apps/api/src/app/app.controller.ts b/apps/api/src/app/app.controller.ts
index 795f13b..200c7cf 100644
--- a/apps/api/src/app/app.controller.ts
+++ b/apps/api/src/app/app.controller.ts
@@ -1,7 +1,7 @@
-import { Controller, Get, Post, Logger } from '@nestjs/common';
+import { Controller, Get, Logger, Post } from '@nestjs/common';
 import { AppService } from './app.service';
-import { VideosService } from './videos/videos.service';
 import { VideoStatus } from './videos/entities/video.entity';
+import { VideosService } from './videos/videos.service';
 
 @Controller()
 export class AppController {

From 34bd476f9ff75c7988193e18dfffc5d0f32ee0d6 Mon Sep 17 00:00:00 2001
From: Giorgi Zankaidze <giorgi.zankaidze@optio.ai>
Date: Wed, 10 Dec 2025 20:21:22 +0400
Subject: [PATCH 4/7] feat: swagger

---
 apps/api/src/app/app.controller.ts            | 64 ++++++++++---
 .../src/app/videos/dto/create-video.dto.ts    | 36 ++++++++
 .../src/app/videos/entities/video.entity.ts   | 43 +++++++--
 apps/api/src/main.ts                          | 17 ++++
 package-lock.json                             | 89 ++++++++++++++++++-
 package.json                                  |  1 +
 6 files changed, 234 insertions(+), 16 deletions(-)
 create mode 100644 apps/api/src/app/videos/dto/create-video.dto.ts

diff --git a/apps/api/src/app/app.controller.ts b/apps/api/src/app/app.controller.ts
index 200c7cf..79e7f90 100644
--- a/apps/api/src/app/app.controller.ts
+++ b/apps/api/src/app/app.controller.ts
@@ -1,8 +1,24 @@
-import { Controller, Get, Logger, Post } from '@nestjs/common';
+import {
+    Body,
+    Controller,
+    Get,
+    HttpCode,
+    HttpStatus,
+    Logger,
+    Post,
+} from '@nestjs/common';
+import {
+    ApiCreatedResponse,
+    ApiOkResponse,
+    ApiOperation,
+    ApiTags,
+} from '@nestjs/swagger';
 import { AppService } from './app.service';
-import { VideoStatus } from './videos/entities/video.entity';
+import { CreateVideoDto } from './videos/dto/create-video.dto';
+import { Video } from './videos/entities/video.entity';
 import { VideosService } from './videos/videos.service';
 
+@ApiTags('test')
 @Controller()
 export class AppController {
   logger = new Logger(AppController.name);
@@ -15,25 +31,53 @@ export class AppController {
   }
 
   @Get()
+  @ApiOperation({ summary: 'Get API welcome message' })
+  @ApiOkResponse({
+    description: 'Returns a welcome message',
+    schema: {
+      type: 'object',
+      properties: {
+        message: {
+          type: 'string',
+          example: 'Hello API',
+        },
+      },
+    },
+  })
   getData() {
     return this.appService.getData();
   }
 
-  // Temporary test endpoint - Create a video record
   @Post('test-video')
-  async testCreateVideo() {
+  @ApiOperation({
+    summary: 'Create a test video record',
+    description: 'Creates a new video record in the database for testing purposes',
+  })
+  @ApiCreatedResponse({
+    description: 'Video record created successfully',
+    type: Video,
+  })
+  @HttpCode(HttpStatus.CREATED)
+  async testCreateVideo(@Body() createVideoDto: CreateVideoDto): Promise<Video> {
     const video = await this.videosService.create(
-      'test-video.mp4',
-      'raw-videos/test-uuid.mp4',
-      'video/mp4',
-      VideoStatus.UPLOADED,
+      createVideoDto.originalFilename,
+      createVideoDto.s3Key,
+      createVideoDto.mimeType,
+      createVideoDto.status,
     );
     return video;
   }
 
-  // Temporary test endpoint - Get all videos
   @Get('test-videos')
-  async testGetVideos() {
+  @ApiOperation({
+    summary: 'Get all video records',
+    description: 'Retrieves all video records from the database',
+  })
+  @ApiOkResponse({
+    description: 'List of all video records',
+    type: [Video],
+  })
+  async testGetVideos(): Promise<Video[]> {
     return await this.videosService.findAll();
   }
 }
diff --git a/apps/api/src/app/videos/dto/create-video.dto.ts b/apps/api/src/app/videos/dto/create-video.dto.ts
new file mode 100644
index 0000000..d68ffde
--- /dev/null
+++ b/apps/api/src/app/videos/dto/create-video.dto.ts
@@ -0,0 +1,36 @@
+import { ApiProperty } from '@nestjs/swagger';
+import { VideoStatus } from '../entities/video.entity';
+
+export class CreateVideoDto {
+  @ApiProperty({
+    description: 'Original filename of the video',
+    example: 'my-video.mp4',
+    maxLength: 255,
+  })
+  originalFilename: string;
+
+  @ApiProperty({
+    description: 'S3/MinIO object key where the video will be stored',
+    example: 'raw-videos/test-uuid.mp4',
+    maxLength: 500,
+  })
+  s3Key: string;
+
+  @ApiProperty({
+    description: 'MIME type of the video file',
+    example: 'video/mp4',
+    maxLength: 100,
+  })
+  mimeType: string;
+
+  @ApiProperty({
+    description: 'Initial status of the video',
+    enum: VideoStatus,
+    example: VideoStatus.UPLOADED,
+    required: false,
+    default: VideoStatus.UPLOADING,
+  })
+  status?: VideoStatus;
+}
+
+
diff --git a/apps/api/src/app/videos/entities/video.entity.ts b/apps/api/src/app/videos/entities/video.entity.ts
index 09e33fd..e196fdd 100644
--- a/apps/api/src/app/videos/entities/video.entity.ts
+++ b/apps/api/src/app/videos/entities/video.entity.ts
@@ -1,9 +1,10 @@
+import { ApiProperty } from '@nestjs/swagger';
 import {
-    Column,
-    CreateDateColumn,
-    Entity,
-    PrimaryGeneratedColumn,
-    UpdateDateColumn,
+  Column,
+  CreateDateColumn,
+  Entity,
+  PrimaryGeneratedColumn,
+  UpdateDateColumn,
 } from 'typeorm';
 
 export enum VideoStatus {
@@ -17,15 +18,34 @@ export enum VideoStatus {
 
 @Entity('videos')
 export class Video {
+  @ApiProperty({
+    description: 'Unique identifier for the video',
+    example: '123e4567-e89b-12d3-a456-426614174000',
+  })
   @PrimaryGeneratedColumn('uuid')
   id: string;
 
+  @ApiProperty({
+    description: 'Original filename of the uploaded video',
+    example: 'my-video.mp4',
+    maxLength: 255,
+  })
   @Column({ type: 'varchar', length: 255 })
   originalFilename: string;
 
+  @ApiProperty({
+    description: 'S3/MinIO object key where the video is stored',
+    example: 'raw-videos/123e4567-e89b-12d3-a456-426614174000.mp4',
+    maxLength: 500,
+  })
   @Column({ type: 'varchar', length: 500 })
   s3Key: string;
 
+  @ApiProperty({
+    description: 'Current processing status of the video',
+    enum: VideoStatus,
+    example: VideoStatus.UPLOADED,
+  })
   @Column({
     type: 'enum',
     enum: VideoStatus,
@@ -33,12 +53,25 @@ export class Video {
   })
   status: VideoStatus;
 
+  @ApiProperty({
+    description: 'MIME type of the video file',
+    example: 'video/mp4',
+    maxLength: 100,
+  })
   @Column({ type: 'varchar', length: 100 })
   mimeType: string;
 
+  @ApiProperty({
+    description: 'Timestamp when the video record was created',
+    example: '2024-01-01T00:00:00.000Z',
+  })
   @CreateDateColumn()
   createdAt: Date;
 
+  @ApiProperty({
+    description: 'Timestamp when the video record was last updated',
+    example: '2024-01-01T00:00:00.000Z',
+  })
   @UpdateDateColumn()
   updatedAt: Date;
 }
diff --git a/apps/api/src/main.ts b/apps/api/src/main.ts
index ee84ced..666b2ad 100644
--- a/apps/api/src/main.ts
+++ b/apps/api/src/main.ts
@@ -5,17 +5,34 @@
 
 import { Logger } from '@nestjs/common';
 import { NestFactory } from '@nestjs/core';
+import { DocumentBuilder, SwaggerModule } from '@nestjs/swagger';
 import { AppModule } from './app/app.module';
 
 async function bootstrap() {
   const app = await NestFactory.create(AppModule);
   const globalPrefix = 'api';
   app.setGlobalPrefix(globalPrefix);
+
+  // Swagger configuration
+  const config = new DocumentBuilder()
+    .setTitle('StreamForge API')
+    .setDescription('Video transcoding service API documentation')
+    .setVersion('1.0')
+    .addTag('videos', 'Video management endpoints')
+    .addTag('test', 'Test endpoints for development')
+    .build();
+
+  const document = SwaggerModule.createDocument(app, config);
+  SwaggerModule.setup('api/docs', app, document);
+
   const port = process.env.PORT || 3000;
   await app.listen(port);
   Logger.log(
     `🚀 Application is running on: http://localhost:${port}/${globalPrefix}`
   );
+  Logger.log(
+    `📚 Swagger documentation available at: http://localhost:${port}/api/docs`
+  );
 }
 
 bootstrap();
diff --git a/package-lock.json b/package-lock.json
index bca796a..c2f74f9 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -13,6 +13,7 @@
         "@nestjs/config": "^4.0.2",
         "@nestjs/core": "^11.0.0",
         "@nestjs/platform-express": "^11.0.0",
+        "@nestjs/swagger": "^11.2.3",
         "@nestjs/typeorm": "^11.0.0",
         "amqplib": "^0.10.9",
         "axios": "^1.6.0",
@@ -2997,6 +2998,12 @@
         "node": ">=8"
       }
     },
+    "node_modules/@microsoft/tsdoc": {
+      "version": "0.16.0",
+      "resolved": "https://registry.npmjs.org/@microsoft/tsdoc/-/tsdoc-0.16.0.tgz",
+      "integrity": "sha512-xgAyonlVVS+q7Vc7qLW0UrJU7rSFcETRWsqdXZtjzRU8dF+6CkozTK4V4y1LwOX7j8r/vHphjDeMeGI4tNGeGA==",
+      "license": "MIT"
+    },
     "node_modules/@napi-rs/wasm-runtime": {
       "version": "0.2.4",
       "resolved": "https://registry.npmjs.org/@napi-rs/wasm-runtime/-/wasm-runtime-0.2.4.tgz",
@@ -3113,6 +3120,26 @@
         }
       }
     },
+    "node_modules/@nestjs/mapped-types": {
+      "version": "2.1.0",
+      "resolved": "https://registry.npmjs.org/@nestjs/mapped-types/-/mapped-types-2.1.0.tgz",
+      "integrity": "sha512-W+n+rM69XsFdwORF11UqJahn4J3xi4g/ZEOlJNL6KoW5ygWSmBB2p0S2BZ4FQeS/NDH72e6xIcu35SfJnE8bXw==",
+      "license": "MIT",
+      "peerDependencies": {
+        "@nestjs/common": "^10.0.0 || ^11.0.0",
+        "class-transformer": "^0.4.0 || ^0.5.0",
+        "class-validator": "^0.13.0 || ^0.14.0",
+        "reflect-metadata": "^0.1.12 || ^0.2.0"
+      },
+      "peerDependenciesMeta": {
+        "class-transformer": {
+          "optional": true
+        },
+        "class-validator": {
+          "optional": true
+        }
+      }
+    },
     "node_modules/@nestjs/platform-express": {
       "version": "11.1.9",
       "resolved": "https://registry.npmjs.org/@nestjs/platform-express/-/platform-express-11.1.9.tgz",
@@ -3152,6 +3179,51 @@
         "typescript": ">=4.8.2"
       }
     },
+    "node_modules/@nestjs/swagger": {
+      "version": "11.2.3",
+      "resolved": "https://registry.npmjs.org/@nestjs/swagger/-/swagger-11.2.3.tgz",
+      "integrity": "sha512-a0xFfjeqk69uHIUpP8u0ryn4cKuHdra2Ug96L858i0N200Hxho+n3j+TlQXyOF4EstLSGjTfxI1Xb2E1lUxeNg==",
+      "license": "MIT",
+      "dependencies": {
+        "@microsoft/tsdoc": "0.16.0",
+        "@nestjs/mapped-types": "2.1.0",
+        "js-yaml": "4.1.1",
+        "lodash": "4.17.21",
+        "path-to-regexp": "8.3.0",
+        "swagger-ui-dist": "5.30.2"
+      },
+      "peerDependencies": {
+        "@fastify/static": "^8.0.0",
+        "@nestjs/common": "^11.0.1",
+        "@nestjs/core": "^11.0.1",
+        "class-transformer": "*",
+        "class-validator": "*",
+        "reflect-metadata": "^0.1.12 || ^0.2.0"
+      },
+      "peerDependenciesMeta": {
+        "@fastify/static": {
+          "optional": true
+        },
+        "class-transformer": {
+          "optional": true
+        },
+        "class-validator": {
+          "optional": true
+        }
+      }
+    },
+    "node_modules/@nestjs/swagger/node_modules/js-yaml": {
+      "version": "4.1.1",
+      "resolved": "https://registry.npmjs.org/js-yaml/-/js-yaml-4.1.1.tgz",
+      "integrity": "sha512-qQKT4zQxXl8lLwBtHMWwaTcGfFOZviOJet3Oy/xmGk2gZH677CJM9EvtfdSkgWcATZhj/55JZ0rmy3myCT5lsA==",
+      "license": "MIT",
+      "dependencies": {
+        "argparse": "^2.0.1"
+      },
+      "bin": {
+        "js-yaml": "bin/js-yaml.js"
+      }
+    },
     "node_modules/@nestjs/testing": {
       "version": "11.1.9",
       "resolved": "https://registry.npmjs.org/@nestjs/testing/-/testing-11.1.9.tgz",
@@ -4013,6 +4085,13 @@
         "url": "https://opencollective.com/pkgr"
       }
     },
+    "node_modules/@scarf/scarf": {
+      "version": "1.4.0",
+      "resolved": "https://registry.npmjs.org/@scarf/scarf/-/scarf-1.4.0.tgz",
+      "integrity": "sha512-xxeapPiUXdZAE3che6f3xogoJPeZgig6omHEy1rIY5WVsB3H2BHNnZH+gHG6x91SCWyQCzWGsuL2Hh3ClO5/qQ==",
+      "hasInstallScript": true,
+      "license": "Apache-2.0"
+    },
     "node_modules/@sinclair/typebox": {
       "version": "0.34.41",
       "resolved": "https://registry.npmjs.org/@sinclair/typebox/-/typebox-0.34.41.tgz",
@@ -5901,7 +5980,6 @@
       "version": "2.0.1",
       "resolved": "https://registry.npmjs.org/argparse/-/argparse-2.0.1.tgz",
       "integrity": "sha512-8+9WqebbFzpX9OR+Wa6O29asIogeRMzcGtAINdpMHHyAg10f05aSFVBbcEqGf/PXw1EjAZ+q2/bEBg3DvurK3Q==",
-      "dev": true,
       "license": "Python-2.0"
     },
     "node_modules/array-flatten": {
@@ -15684,6 +15762,15 @@
         "url": "https://opencollective.com/svgo"
       }
     },
+    "node_modules/swagger-ui-dist": {
+      "version": "5.30.2",
+      "resolved": "https://registry.npmjs.org/swagger-ui-dist/-/swagger-ui-dist-5.30.2.tgz",
+      "integrity": "sha512-HWCg1DTNE/Nmapt+0m2EPXFwNKNeKK4PwMjkwveN/zn1cV2Kxi9SURd+m0SpdcSgWEK/O64sf8bzXdtUhigtHA==",
+      "license": "Apache-2.0",
+      "dependencies": {
+        "@scarf/scarf": "=1.4.0"
+      }
+    },
     "node_modules/sync-child-process": {
       "version": "1.0.2",
       "resolved": "https://registry.npmjs.org/sync-child-process/-/sync-child-process-1.0.2.tgz",
diff --git a/package.json b/package.json
index 6f9dccc..ff86cd7 100644
--- a/package.json
+++ b/package.json
@@ -9,6 +9,7 @@
     "@nestjs/config": "^4.0.2",
     "@nestjs/core": "^11.0.0",
     "@nestjs/platform-express": "^11.0.0",
+    "@nestjs/swagger": "^11.2.3",
     "@nestjs/typeorm": "^11.0.0",
     "amqplib": "^0.10.9",
     "axios": "^1.6.0",

From 00de1e9e388037b937dc7f5cc755956fc83dd102 Mon Sep 17 00:00:00 2001
From: Giorgi Zankaidze <giorgi.zankaidze@optio.ai>
Date: Wed, 10 Dec 2025 21:40:07 +0400
Subject: [PATCH 5/7] d

---
 apps/api/src/app/videos/dto/create-video.dto.ts | 1 -
 1 file changed, 1 deletion(-)

diff --git a/apps/api/src/app/videos/dto/create-video.dto.ts b/apps/api/src/app/videos/dto/create-video.dto.ts
index d68ffde..b25d689 100644
--- a/apps/api/src/app/videos/dto/create-video.dto.ts
+++ b/apps/api/src/app/videos/dto/create-video.dto.ts
@@ -33,4 +33,3 @@ export class CreateVideoDto {
   status?: VideoStatus;
 }
 
-

From b745dd738d21677a994e307e3ea090cf03eaa944 Mon Sep 17 00:00:00 2001
From: Giorgi Zankaidze <giorgi.zankaidze@optio.ai>
Date: Wed, 10 Dec 2025 22:00:28 +0400
Subject: [PATCH 6/7] feat: add swagger

---
 apps/api/src/app/app.controller.ts            | 92 ++++++++++++++-----
 .../src/app/videos/dto/upload-video.dto.ts    | 12 +++
 apps/api/src/app/videos/videos.service.ts     | 45 +++++++--
 package-lock.json                             | 11 +++
 package.json                                  |  1 +
 5 files changed, 134 insertions(+), 27 deletions(-)
 create mode 100644 apps/api/src/app/videos/dto/upload-video.dto.ts

diff --git a/apps/api/src/app/app.controller.ts b/apps/api/src/app/app.controller.ts
index 79e7f90..ab9a01d 100644
--- a/apps/api/src/app/app.controller.ts
+++ b/apps/api/src/app/app.controller.ts
@@ -1,23 +1,37 @@
 import {
-    Body,
-    Controller,
-    Get,
-    HttpCode,
-    HttpStatus,
-    Logger,
-    Post,
+  Controller,
+  Get,
+  HttpCode,
+  HttpStatus,
+  Logger,
+  Post,
+  UploadedFile,
+  UseInterceptors,
 } from '@nestjs/common';
+import { FileInterceptor } from '@nestjs/platform-express';
 import {
-    ApiCreatedResponse,
-    ApiOkResponse,
-    ApiOperation,
-    ApiTags,
+  ApiBody,
+  ApiConsumes,
+  ApiCreatedResponse,
+  ApiOkResponse,
+  ApiOperation,
+  ApiTags,
 } from '@nestjs/swagger';
+import { v4 as uuidv4 } from 'uuid';
 import { AppService } from './app.service';
-import { CreateVideoDto } from './videos/dto/create-video.dto';
-import { Video } from './videos/entities/video.entity';
+import { UploadVideoDto } from './videos/dto/upload-video.dto';
+import { Video, VideoStatus } from './videos/entities/video.entity';
 import { VideosService } from './videos/videos.service';
 
+interface UploadedFileInterface {
+  fieldname: string;
+  originalname: string;
+  encoding: string;
+  mimetype: string;
+  size: number;
+  buffer: Buffer;
+}
+
 @ApiTags('test')
 @Controller()
 export class AppController {
@@ -49,22 +63,58 @@ export class AppController {
   }
 
   @Post('test-video')
+  @UseInterceptors(FileInterceptor('file'))
   @ApiOperation({
-    summary: 'Create a test video record',
-    description: 'Creates a new video record in the database for testing purposes',
+    summary: 'Upload a video file',
+    description:
+      'Uploads a video file and creates a video record in the database. The file will be stored in MinIO and metadata saved to PostgreSQL.',
+  })
+  @ApiConsumes('multipart/form-data')
+  @ApiBody({
+    description: 'Video file to upload',
+    type: UploadVideoDto,
+    schema: {
+      type: 'object',
+      required: ['file'],
+      properties: {
+        file: {
+          type: 'string',
+          format: 'binary',
+          description: 'Video file (supports: mp4, mov, avi, mkv, webm, etc.)',
+          example: 'my-video.mp4',
+        },
+      },
+    },
   })
   @ApiCreatedResponse({
-    description: 'Video record created successfully',
+    description: 'Video uploaded and record created successfully',
     type: Video,
   })
   @HttpCode(HttpStatus.CREATED)
-  async testCreateVideo(@Body() createVideoDto: CreateVideoDto): Promise<Video> {
+  async testCreateVideo(
+    @UploadedFile() file: UploadedFileInterface,
+  ): Promise<Video> {
+    if (!file) {
+      throw new Error('No file uploaded');
+    }
+
+    this.logger.log(
+      `Received file upload: filename=${file.originalname}, mimetype=${file.mimetype}, size=${file.size}`,
+    );
+
+    // Generate a unique S3 key (placeholder until MinIO is implemented)
+    const fileExtension = file.originalname.split('.').pop();
+    const s3Key = `raw-videos/${uuidv4()}.${fileExtension}`;
+
+    // Create video record
     const video = await this.videosService.create(
-      createVideoDto.originalFilename,
-      createVideoDto.s3Key,
-      createVideoDto.mimeType,
-      createVideoDto.status,
+      file.originalname,
+      s3Key,
+      file.mimetype,
+      VideoStatus.UPLOADED,
     );
+
+    this.logger.log(`Video record created: id=${video.id}`);
     return video;
   }
 
diff --git a/apps/api/src/app/videos/dto/upload-video.dto.ts b/apps/api/src/app/videos/dto/upload-video.dto.ts
new file mode 100644
index 0000000..5db5aa1
--- /dev/null
+++ b/apps/api/src/app/videos/dto/upload-video.dto.ts
@@ -0,0 +1,12 @@
+import { ApiProperty } from '@nestjs/swagger';
+
+export class UploadVideoDto {
+  @ApiProperty({
+    type: 'string',
+    format: 'binary',
+    description: 'Video file to upload (supports: mp4, mov, avi, mkv, webm, etc.)',
+    example: 'video.mp4',
+  })
+  file: string | Buffer; // File upload - will be handled by multer or busboy
+}
+
diff --git a/apps/api/src/app/videos/videos.service.ts b/apps/api/src/app/videos/videos.service.ts
index c7658c4..405d092 100644
--- a/apps/api/src/app/videos/videos.service.ts
+++ b/apps/api/src/app/videos/videos.service.ts
@@ -1,10 +1,12 @@
-import { Injectable } from '@nestjs/common';
+import { Injectable, Logger } from '@nestjs/common';
 import { InjectRepository } from '@nestjs/typeorm';
 import { Repository } from 'typeorm';
 import { Video, VideoStatus } from './entities/video.entity';
 
 @Injectable()
 export class VideosService {
+  private readonly logger = new Logger(VideosService.name);
+
   constructor(
     @InjectRepository(Video)
     private videoRepository: Repository<Video>,
@@ -19,40 +21,60 @@ export class VideosService {
     mimeType: string,
     status: VideoStatus = VideoStatus.UPLOADING,
   ): Promise<Video> {
+    this.logger.log(
+      `Creating video record: filename=${originalFilename}, s3Key=${s3Key}, status=${status}`,
+    );
     const video = this.videoRepository.create({
       originalFilename,
       s3Key,
       mimeType,
       status,
     });
-    return await this.videoRepository.save(video);
+    const savedVideo = await this.videoRepository.save(video);
+    this.logger.log(`Video record created successfully: id=${savedVideo.id}`);
+    return savedVideo;
   }
 
   /**
    * Find video by ID
    */
   async findOne(id: string): Promise<Video | null> {
-    return await this.videoRepository.findOne({ where: { id } });
+    this.logger.log(`Finding video by ID: ${id}`);
+    const video = await this.videoRepository.findOne({ where: { id } });
+    if (video) {
+      this.logger.log(`Video found: id=${id}, filename=${video.originalFilename}`);
+    } else {
+      this.logger.warn(`Video not found: id=${id}`);
+    }
+    return video;
   }
 
   /**
    * Get all videos
    */
   async findAll(): Promise<Video[]> {
-    return await this.videoRepository.find({
+    this.logger.log('Fetching all videos');
+    const videos = await this.videoRepository.find({
       order: { createdAt: 'DESC' },
     });
+    this.logger.log(`Found ${videos.length} video(s)`);
+    return videos;
   }
 
   /**
    * Update video record
    */
   async update(id: string, updateData: Partial<Video>): Promise<Video> {
+    this.logger.log(
+      `Updating video: id=${id}, fields=${JSON.stringify(Object.keys(updateData))}`,
+    );
     await this.videoRepository.update(id, updateData);
     const updated = await this.findOne(id);
     if (!updated) {
+      this.logger.error(`Video update failed: id=${id} not found`);
       throw new Error(`Video with ID ${id} not found`);
     }
+    this.logger.log(`Video updated successfully: id=${id}`);
     return updated;
   }
 
@@ -60,14 +82,25 @@ export class VideosService {
    * Update video status
    */
   async updateStatus(id: string, status: VideoStatus): Promise<Video> {
-    return await this.update(id, { status });
+    this.logger.log(`Updating video status: id=${id}, newStatus=${status}`);
+    const updated = await this.update(id, { status });
+    this.logger.log(
+      `Video status updated: id=${id}, status=${updated.status}`,
+    );
+    return updated;
   }
 
   /**
    * Delete video record
    */
   async remove(id: string): Promise<void> {
-    await this.videoRepository.delete(id);
+    this.logger.log(`Deleting video: id=${id}`);
+    const result = await this.videoRepository.delete(id);
+    if (result.affected && result.affected > 0) {
+      this.logger.log(`Video deleted successfully: id=${id}`);
+    } else {
+      this.logger.warn(`Video deletion failed: id=${id} not found`);
+    }
   }
 }
 
diff --git a/package-lock.json b/package-lock.json
index c2f74f9..a3a9b06 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -45,6 +45,7 @@
         "@types/amqplib": "^0.10.8",
         "@types/busboy": "^1.5.4",
         "@types/jest": "^30.0.0",
+        "@types/multer": "^2.0.0",
         "@types/node": "20.19.9",
         "@types/uuid": "^10.0.0",
         "eslint": "^9.8.0",
@@ -4740,6 +4741,16 @@
       "dev": true,
       "license": "MIT"
     },
+    "node_modules/@types/multer": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/@types/multer/-/multer-2.0.0.tgz",
+      "integrity": "sha512-C3Z9v9Evij2yST3RSBktxP9STm6OdMc5uR1xF1SGr98uv8dUlAL2hqwrZ3GVB3uyMyiegnscEK6PGtYvNrjTjw==",
+      "dev": true,
+      "license": "MIT",
+      "dependencies": {
+        "@types/express": "*"
+      }
+    },
     "node_modules/@types/node": {
       "version": "20.19.9",
       "resolved": "https://registry.npmjs.org/@types/node/-/node-20.19.9.tgz",
diff --git a/package.json b/package.json
index ff86cd7..2ae8d54 100644
--- a/package.json
+++ b/package.json
@@ -41,6 +41,7 @@
     "@types/amqplib": "^0.10.8",
     "@types/busboy": "^1.5.4",
     "@types/jest": "^30.0.0",
+    "@types/multer": "^2.0.0",
     "@types/node": "20.19.9",
     "@types/uuid": "^10.0.0",
     "eslint": "^9.8.0",

From 7ee97237a59bc52cadfa0770d3b12d61c880d93f Mon Sep 17 00:00:00 2001
From: Giorgi Zankaidze <giorgi.zankaidze@optio.ai>
Date: Wed, 10 Dec 2025 22:50:46 +0400
Subject: [PATCH 7/7] add tests

---
 apps/api/src/app/app.controller.spec.ts | 20 +++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/apps/api/src/app/app.controller.spec.ts b/apps/api/src/app/app.controller.spec.ts
index f27e3af..e0b8e9f 100644
--- a/apps/api/src/app/app.controller.spec.ts
+++ b/apps/api/src/app/app.controller.spec.ts
@@ -1,15 +1,33 @@
 import { Test, TestingModule } from '@nestjs/testing';
 import { AppController } from './app.controller';
 import { AppService } from './app.service';
+import { VideosService } from './videos/videos.service';
+
+// Mock uuid
+jest.mock('uuid', () => ({
+  v4: jest.fn(() => 'test-uuid-123'),
+}));
 
 describe('AppController', () => {
   let app: TestingModule;
+  let videosService: VideosService;
 
   beforeAll(async () => {
     app = await Test.createTestingModule({
       controllers: [AppController],
-      providers: [AppService],
+      providers: [
+        AppService,
+        {
+          provide: VideosService,
+          useValue: {
+            create: jest.fn(),
+            findAll: jest.fn(),
+          },
+        },
+      ],
     }).compile();
+
+    videosService = app.get<VideosService>(VideosService);
   });
 
   describe('getData', () => {