feat(chat): v2 (#114)

* feat(chat): DMs done

* feat(chat): add get messages

* fix(chat): swagger and validation

Author: MarioRaafat

package-lock.json

@@ -81,6 +81,7 @@
         "sharp": "^0.34.5",
         "socket.io": "^4.8.1",
         "swagger-ui-express": "^5.0.1",
+        "tunnel-ssh": "^5.2.0",
         "typeorm": "^0.3.26",
         "xlsx": "^0.18.5"
     },
@@ -100,6 +101,7 @@
         "@types/passport-facebook": "^3.0.3",
         "@types/passport-github2": "^1.2.9",
         "@types/supertest": "^6.0.2",
+        "@types/tunnel-ssh": "^5.0.4",
         "eslint": "^9.18.0",
         "eslint-config-prettier": "^10.0.1",
         "eslint-plugin-prettier": "^5.2.2",

package.json

@@ -44,7 +44,12 @@ export class ChatController {
     @ResponseMessage(SUCCESS_MESSAGES.CHAT_CREATED)
     @Post()
     async createChat(@Body() create_chat_dto: CreateChatDto, @GetUserId() user_id: string) {
-        return this.chat_service.createChat(user_id, create_chat_dto);
+        try {
+            return this.chat_service.createChat(user_id, create_chat_dto);
+        } catch (error) {
+            console.error('Error in ChatController.createChat:', error);
+            throw error;
+        }
     }
 
     @ApiOperation(get_chats_swagger.operation)

src/chat/chat.controller.ts

@@ -6,12 +6,13 @@ import { Chat } from './entities/chat.entity';
 import { ChatRepository } from './chat.repository';
 import { PaginationService } from '../shared/services/pagination/pagination.service';
 import { Message } from '../messages/entities/message.entity';
+import { UserRepository } from 'src/user/user.repository';
 
 @Module({
     imports: [TypeOrmModule.forFeature([Chat, Message])],
 
     controllers: [ChatController],
-    providers: [ChatService, ChatRepository, PaginationService],
+    providers: [ChatService, ChatRepository, PaginationService, UserRepository],
     exports: [ChatRepository],
 })
 export class ChatModule {}

src/chat/chat.module.ts

@@ -3,7 +3,7 @@ import { DataSource } from 'typeorm';
 import { ChatRepository } from './chat.repository';
 import { Chat } from './entities/chat.entity';
 import { PaginationService } from 'src/shared/services/pagination/pagination.service';
-import { InternalServerErrorException } from '@nestjs/common';
+import { InternalServerErrorException, NotFoundException } from '@nestjs/common';
 import { CreateChatDto, GetChatsQueryDto } from './dto';
 
 describe('ChatRepository', () => {
@@ -33,17 +33,26 @@ describe('ChatRepository', () => {
         last_message: null,
     };
 
+    let mock_data_source: any;
+
     beforeEach(async () => {
         const mock_entity_manager = {} as any;
 
+        const mock_user_repository = {
+            findOne: jest.fn(),
+        };
+
+        mock_data_source = {
+            createEntityManager: jest.fn(() => mock_entity_manager),
+            getRepository: jest.fn(() => mock_user_repository),
+        };
+
         const module: TestingModule = await Test.createTestingModule({
             providers: [
                 ChatRepository,
                 {
                     provide: DataSource,
-                    useValue: {
-                        createEntityManager: jest.fn(() => mock_entity_manager),
-                    },
+                    useValue: mock_data_source,
                 },
                 {
                     provide: PaginationService,
@@ -72,6 +81,11 @@ describe('ChatRepository', () => {
     describe('createChat', () => {
         it('should create a new chat successfully', async () => {
             const create_dto: CreateChatDto = { recipient_id: 'user-2' };
+
+            // Mock user repository to find recipient
+            const mock_user_repository = mock_data_source.getRepository();
+            mock_user_repository.findOne.mockResolvedValue({ id: 'user-2', username: 'user2' });
+
             jest.spyOn(chat_repository, 'findOne').mockResolvedValue(null);
 
             const result = await chat_repository.createChat('user-1', create_dto);
@@ -86,6 +100,11 @@ describe('ChatRepository', () => {
 
         it('should return existing chat if it exists', async () => {
             const create_dto: CreateChatDto = { recipient_id: 'user-2' };
+
+            // Mock user repository to find recipient
+            const mock_user_repository = mock_data_source.getRepository();
+            mock_user_repository.findOne.mockResolvedValue({ id: 'user-2', username: 'user2' });
+
             jest.spyOn(chat_repository, 'findOne').mockResolvedValue(mock_chat as any);
 
             const result = await chat_repository.createChat('user-1', create_dto);
@@ -94,9 +113,24 @@ describe('ChatRepository', () => {
             expect(chat_repository.create).not.toHaveBeenCalled();
         });
 
+        it('should throw NotFoundException if recipient does not exist', async () => {
+            const create_dto: CreateChatDto = { recipient_id: 'non-existent-user' };
+
+            // Mock user repository to not find recipient
+            const mock_user_repository = mock_data_source.getRepository();
+            mock_user_repository.findOne.mockResolvedValue(null);
+
+            await expect(chat_repository.createChat('user-1', create_dto)).rejects.toThrow(
+                NotFoundException
+            );
+        });
+
         it('should throw InternalServerErrorException on error', async () => {
             const create_dto: CreateChatDto = { recipient_id: 'user-2' };
-            jest.spyOn(chat_repository, 'findOne').mockRejectedValue(new Error('DB error'));
+
+            // Mock user repository to throw error
+            const mock_user_repository = mock_data_source.getRepository();
+            mock_user_repository.findOne.mockRejectedValue(new Error('DB error'));
 
             await expect(chat_repository.createChat('user-1', create_dto)).rejects.toThrow(
                 InternalServerErrorException