add factory design pattern for channel

Author: khanh1902

client/package.json

@@ -54,6 +54,7 @@
     "@tiptap/extension-text-align": "^2.2.4",
     "@tiptap/extension-text-style": "^2.2.4",
     "@tiptap/extension-underline": "^2.2.4",
+    "@tiptap/pm": "^2.2.4",
     "@tiptap/react": "^2.2.4",
     "@tiptap/starter-kit": "^2.2.4",
     "@xyflow/react": "^12.0.0-next.11",

server/src/channels/base.channel.ts

@@ -59,4 +59,4 @@ export class BaseChannel {
   initConversationId(userId: string) {
     return this.contactId + '-' + userId
   }
-}
+}

server/src/channels/creator.channel.ts

@@ -0,0 +1,49 @@
+import { AUTO_REGISTER_WEBHOOK } from "@/config";
+import { ChannelInfo } from "@/interfaces/channels.interface";
+import { LineChannel } from "./line.channel";
+import { MessengerChannel } from "./messenger.channel";
+import { WebChannel } from "./web.channel";
+
+export class Creator {
+    static createChannel(channel: ChannelInfo) {
+        try {
+            const { id, contactId, contactName, channelType, credentials } = channel;
+
+            switch (channelType) {
+                case 'MSG':
+                    return new MessengerChannel(
+                        id,
+                        contactId,
+                        contactName,
+                        channelType,
+                        credentials,
+                    )
+                case 'LIN':
+                    const linChannel = new LineChannel(
+                        id,
+                        contactId,
+                        contactName,
+                        channelType,
+                        credentials,
+                    )
+                    if (AUTO_REGISTER_WEBHOOK == '1') {
+                        linChannel.registerWebhook();
+                    }
+                    return linChannel
+                case 'WEB':
+                    return new WebChannel(
+                        id,
+                        contactId,
+                        contactName,
+                        channelType,
+                        credentials,
+                    )
+                default:
+                    throw new Error(`Does not support channel type ${channel.channelType}`);
+                    break;
+            }
+        } catch (err) {
+            throw err;
+        }
+    }
+}

server/src/config/index.ts

@@ -33,4 +33,5 @@ export const {
   MAIL_USER,
   MAIL_PASS,
   API_KEY,
+  AUTO_REGISTER_WEBHOOK
 } = process.env

server/src/controllers/flows.controller.ts

@@ -77,6 +77,6 @@ export class FlowController {
 
   public getFlowByContactId = catchAsync(async (req: RequestWithUser, res) => {
     const data = await this.flowService.getFlowByContactId(req.params.contactId)
-    res.status(StatusCodes.OK).json({ data })
+    res.status(StatusCodes.OK).send(data);
   })
 }

server/src/routes/flow.route.ts

@@ -50,7 +50,6 @@ export class FlowRoute implements Routes {
     //for bot get flow by contactId
     this.router.get(
       `${ENDPOINTS.FLOW.INDEX}/:contactId`,
-      authMiddleware,
       this.controller.getFlowByContactId,
     )
 

server/src/services/channels.service.ts

@@ -1,5 +1,4 @@
-import { LineChannel } from '@/channels/line.channel'
-import { MessengerChannel } from '@/channels/messenger.channel'
+import { Creator } from '@/channels/creator.channel'
 import { LOCALE_KEY } from '@/constants'
 import { db } from '@/database/db'
 import { channelTypes, channels } from '@/database/schema'
@@ -238,39 +237,12 @@ export class ChannelService {
   }
 
   initChannel(channel: ChannelInfo) {
-    const { id, contactId, contactName, channelType, credentials } = channel
-
-    logger.info(`[Init channel] ${channelType} - ${contactName} ${contactId}`)
-
-    switch (channelType) {
-      case 'MSG':
-        return new MessengerChannel(
-          id,
-          contactId,
-          contactName,
-          channelType,
-          credentials,
-        )
-      case 'LIN':
-        const linChannel = new LineChannel(
-          id,
-          contactId,
-          contactName,
-          channelType,
-          credentials,
-        )
-
-        linChannel.registerWebhook()
-
-        return linChannel
-      default:
-        logger.info(
-          `[Init channel] Does not support channel type ${channel.channelType}`,
-        )
-        break
+    try {
+      logger.info(`[Init channel] ${channel.channelType} - ${channel.contactName} ${channel.contactId}`)
+      return Creator.createChannel(channel);
+    } catch (err) {
+      logger.info(`[Init channel] ${err.message}`);
     }
-
-    return channel
   }
 
   async initChannels() {

server/src/services/flows.service.ts

@@ -20,7 +20,7 @@ export class FlowService {
   constructor(
     @Inject(LOCALE_KEY) private readonly localeService: LocaleService,
     private readonly chanelService: ChannelService,
-  ) {}
+  ) { }
 
   public async create(fields: TNewFlow) {
     const flowExisted = await db.query.flows.findFirst({
@@ -264,7 +264,7 @@ export class FlowService {
     const flow = db.query.flows.findFirst({
       where: and(
         eq(flows.deleted, false),
-        isNotNull(flows.publishAt),
+        // isNotNull(flows.publishAt),
         isNotNull(
           db
             .select({
@@ -282,6 +282,7 @@ export class FlowService {
         this.localeService.i18n().FLOW.NOT_FOUND(),
       )
     }
+    console.log(flow);
     return flow
   }
 }