Merge pull request #74 from Dialogue-Bot/DIAL-42-implement-test-your-bot

Dial 42 implement test your bot

Author: hi02102002

server/src/constants/index.ts

@@ -64,6 +64,10 @@ export const ENDPOINTS = {
     PREDICT: '/intent/predict',
     FOR_SELECT: '/intent/for-select',
   },
+  CONVERSATION_LIVE_CHAT: {
+    INDEX: '/conversation-live-chat',
+    GET_MESSAGES: '/conversation-live-chat/:id',
+  },
 }
 
 export const LOCALE_KEY = 'lang'

server/src/controllers/conversation-live-chat.controller.ts

@@ -0,0 +1,48 @@
+import { LOCALE_KEY } from '@/constants'
+import { LocaleService } from '@/i18n/ctx'
+import { RequestWithUser } from '@/interfaces/auth.interface'
+import { ConversationLiveChatService } from '@/services/conversation-live-chat.service'
+import { MessageService } from '@/services/message.service'
+import { catchAsync } from '@/utils/catch-async'
+import { StatusCodes } from 'http-status-codes'
+import Container from 'typedi'
+
+export class ConversationLiveChatController {
+  private readonly conversationLiveChatService = Container.get(
+    ConversationLiveChatService,
+  )
+
+  private readonly localeService = Container.get<LocaleService>(LOCALE_KEY)
+
+  private readonly messageService = Container.get(MessageService)
+
+  public createConversation = catchAsync(async (req, res) => {
+    const data = await this.conversationLiveChatService.createConversation(
+      req.body,
+    )
+
+    res.status(StatusCodes.OK).json({
+      message: this.localeService
+        .i18n()
+        .CONVERSATION_LIVE_CHAT.CREATE_SUCCESS(),
+      data,
+    })
+  })
+
+  public getConversations = catchAsync(async (req: RequestWithUser, res) => {
+    const data = await this.conversationLiveChatService.getConversations(
+      req.user.id as string,
+      req.query as any,
+    )
+
+    res.status(StatusCodes.OK).json({ data })
+  })
+
+  public getMessages = catchAsync(async (req: RequestWithUser, res) => {
+    const data = await this.messageService.getMessagesByConversationId(
+      req.params.id as string,
+    )
+
+    res.status(StatusCodes.OK).json({ data })
+  })
+}

server/src/database/migrations/0010_fine_tiger_shark.sql

@@ -0,0 +1,7 @@
+ALTER TABLE "conversations" ADD COLUMN "channel_id" text;--> statement-breakpoint
+ALTER TABLE "conversations" ADD COLUMN "id" varchar(36) DEFAULT 'xr9chlw9p0c1mts5zp0ht9fg' NOT NULL;--> statement-breakpoint
+DO $$ BEGIN
+ ALTER TABLE "conversations" ADD CONSTRAINT "conversations_channel_id_channels_id_fk" FOREIGN KEY ("channel_id") REFERENCES "channels"("id") ON DELETE set null ON UPDATE no action;
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;

server/src/database/migrations/0011_left_bromley.sql

@@ -0,0 +1 @@
+ALTER TABLE "conversations" ALTER COLUMN "id" SET DEFAULT 'nsb2hhjuvcsh9gdi22rex2yw';

server/src/database/migrations/0012_aspiring_sharon_ventura.sql

@@ -0,0 +1,8 @@
+ALTER TABLE "messages" DROP CONSTRAINT "messages_conversation_id_conversations_user_id_fk";
+--> statement-breakpoint
+ALTER TABLE "conversations" ALTER COLUMN "id" SET DEFAULT 'fjcrx88jmtr9jh59nhupcmnk';--> statement-breakpoint
+DO $$ BEGIN
+ ALTER TABLE "messages" ADD CONSTRAINT "messages_conversation_id_conversations_id_fk" FOREIGN KEY ("conversation_id") REFERENCES "conversations"("id") ON DELETE cascade ON UPDATE no action;
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;