add send message to bot for messenger

Author: khanh1902

server/src/channels/base.channel.ts

@@ -1,4 +1,4 @@
-import { BOT_URL } from "@/config";
+import { BOT_ENDPOINT, PUBLIC_DOMAIN } from "@/config";
 import axios from "axios";
 
 export class BaseChannel {
@@ -14,40 +14,43 @@ export class BaseChannel {
         this.channelType = channelType;
     }
 
-    public async postMessageToBot({ userId, data }) {
+    public async postMessageToBot({ userId, message = '', data }) {
+        const uid = this.initConversationId(userId);
         try {
-            const uId = this.initConversationId(userId);
-            await axios({
+            const postMsg = await axios({
                 method: 'POST',
-                url: BOT_URL,
+                url: BOT_ENDPOINT,
                 data: {
                     conversation: {
-                        id: uId,
+                        id: uid,
                     },
                     from: {
                         id: userId,
                     },
                     recipient: {
                         id: this.contactId,
                     },
-                    type: 'event',
-                    name: 'payload',
-                    data,
-                    id: uId,
+                    data: data || false,
+                    text: message,
+                    type: 'message',
+                    id: uid,
                     channelId: this.channelType,
-                    serviceUrl: 'http://localhost:3000/api',
+                    serviceUrl: PUBLIC_DOMAIN,
                 },
             })
+            if (postMsg.data.success) {
+                console.log(
+                    `[${this.channelType} - ${this.contactName} ${this.contactId}] - [Conversation ID: ${uid}] - [Send message to bot - Message: ${message}] - [Data: ${data}]`
+                )
+            }
         } catch (error) {
-            console.log(`Can not send data to bot!`, userId);
-            console.log(error.message);
+            console.log(
+                `[${this.channelType} - ${this.contactName} ${this.contactId}] - [Conversation ID: ${uid}] - [Can not send message to bot - Message: ${message}] - [Error: ${error.message}]`
+            );
         }
     }
 
-    initConversationId(useId: string) {
-        return this.contactId + '-' + useId
+    initConversationId(userId: string) {
+        return this.contactId + '-' + userId
     }
-
-    // public async verifyWebhook(req: Request, res: Response) {
-    // };
 }

server/src/channels/messenger.channel.ts

@@ -1,3 +1,4 @@
+import { Helper } from "@/utils/helper";
 import { Request, Response } from "express";
 import { BaseChannel } from "./base.channel";
 
@@ -7,7 +8,6 @@ export class MessengerChannel extends BaseChannel {
     messengerPostURL: string;
     credentials: string;
 
-
     constructor(id: string, contactId: string, contactName: string, channelType: string, credentials: string) {
         super(id, contactId, contactName, channelType);
 
@@ -36,11 +36,40 @@ export class MessengerChannel extends BaseChannel {
             return challenge;
         } else {
             console.error(`Verification channel ${this.channelType} - ${this.contactName} ${this.contactId} failed!`);
-            return null;
+            return;
         }
     }
 
     public async prepareMessage(req: Request, res: Response) {
+        const { object, entry } = req.body;
+
+        if (object != 'page' || !Array.isArray(entry)) return;
+
+        entry.forEach(pageEntry => {
+            if (!Array.isArray(pageEntry.messaging)) return;
+
+            pageEntry.messaging.forEach(async (messagingEvent) => {
+                if (messagingEvent.messaging_customer_information)
+                    return this.sendAddressToBot({
+                        userId: messagingEvent.sender.id,
+                        address: messagingEvent.messaging_customer_information.screens[0].responses,
+                    });
+
+                if (!messagingEvent.message && !messagingEvent.postback) return;
+
+                const senderId = messagingEvent.sender.id;
+                const messageText = messagingEvent.message && messagingEvent.message.text;
+                const payload = messagingEvent.postback && messagingEvent.postback.payload;
+                const quick_reply = messagingEvent.message && messagingEvent.message.quick_reply;
+
+                if (senderId == this.contactId) return; //Agent replied to user => skip
+
+                return this.postMessageToBot({ userId: senderId, message: messageText || payload, data: null });
+            });
+        });
+    }
 
+    sendAddressToBot({ userId, address }) {
+        return this.postMessageToBot({ userId, message: 'ADDRESS', data: { USER_INFORMATION: Helper.arrayToObj(address) } });
     }
 }

server/src/config/index.ts

@@ -28,5 +28,5 @@ export const {
    FIREBASE_UNIVERSE_DOMAIN,
    FIREBASE_DATABASE_URL,
    PUBLIC_DOMAIN,
-   BOT_URL,
+   BOT_ENDPOINT,
 } = process.env;

server/src/utils/helper.ts

@@ -5,5 +5,12 @@ export class Helper {
         if (!date) return null;
         return moment(date).format('DD/MM/YYYY HH:mm:ss');
     }
-}
 
+    public static arrayToObj(arr) {
+        const obj = {};
+        arr.forEach((item) => {
+            obj[item.key] = item.value;
+        });
+        return obj;
+    }
+}

server/src/utils/logger.ts

@@ -1,8 +1,8 @@
+import { LOG_DIR } from '@config';
 import { existsSync, mkdirSync } from 'node:fs';
 import { join } from 'node:path';
 import winston from 'winston';
 import WinstonDaily from 'winston-daily-rotate-file';
-import { LOG_DIR } from '@config';
 
 const colorizer = winston.format.colorize({
    colors: {
@@ -68,6 +68,18 @@ logger.add(
    })
 );
 
+['log', 'error', 'warn', 'info'].forEach((method) => {
+   const originalMethod = console[method];
+   console[method] = function () {
+      const modifiedArgs = Array.from(arguments).map((arg) => (typeof arg === 'object' ? JSON.stringify(arg) : arg));
+      originalMethod.call(console, ...modifiedArgs);
+      console[method] = function () {
+         if (method === 'log') return logger.info.apply(logger, arguments);
+         return logger[method].apply(logger, arguments);
+      };
+   };
+});
+
 const stream = {
    write: (message: string) => {
       logger.info(message.substring(0, message.lastIndexOf('\n')));