Merge pull request #15 from Dialogue-Bot/DIAL-18-Integrate-webhook-for-channel-Messenger

khanh1902 · web-flow · commit 47d4693872d5 · 2024-02-26T23:42:14.000+07:00
DIAL-18-Integrate-webhook-for-channel-Messenger
diff --git a/server/package-lock.json b/server/package-lock.json
diff --git a/server/package.json b/server/package.json
@@ -31,6 +31,7 @@
       "@paralleldrive/cuid2": "^2.2.2",
       "@react-email/components": "^0.0.15",
       "@react-email/render": "0.0.7",
+      "axios": "^1.6.7",
       "bcrypt": "^5.0.1",
       "bullmq": "^5.1.5",
       "class-transformer": "^0.5.1",
diff --git a/server/src/channels/base.channel.ts b/server/src/channels/base.channel.ts
@@ -0,0 +1,57 @@
+import { BOT_URL } from "@/config";
+import axios from "axios";
+
+export class BaseChannel {
+    id: string;
+    contactId: string;
+    contactName: string;
+    channelType: string;
+
+    constructor(id: string, contactId: string, contactName: string, channelType: string,) {
+        this.id = id;
+        this.contactId = contactId;
+        this.contactName = contactName;
+        this.channelType = channelType;
+
+        if (channelType && contactName && contactId) {
+            console.log(`Init channel ${channelType} - ${contactName} ${contactId}`);
+        }
+    }
+
+    public async postMessageToBot({ userId, data }) {
+        try {
+            const uId = this.initConversationId(userId);
+            await axios({
+                method: 'POST',
+                url: BOT_URL,
+                data: {
+                    conversation: {
+                        id: uId,
+                    },
+                    from: {
+                        id: userId,
+                    },
+                    recipient: {
+                        id: this.contactId,
+                    },
+                    type: 'event',
+                    name: 'payload',
+                    data,
+                    id: uId,
+                    channelId: this.channelType,
+                    serviceUrl: 'http://localhost:3000/api',
+                },
+            })
+        } catch (error) {
+            console.log(`Can not send data to bot!`, userId);
+            console.log(error.message);
+        }
+    }
+
+    initConversationId(useId: string) {
+        return this.contactId + '-' + useId
+    }
+
+    // public async verifyWebhook(req: Request, res: Response) {
+    // };
+}
diff --git a/server/src/channels/messenger.channel.ts b/server/src/channels/messenger.channel.ts
@@ -0,0 +1,42 @@
+import { Request, Response } from "express";
+import { BaseChannel } from "./base.channel";
+
+export class MessengerChannel extends BaseChannel {
+    pageToken: string;
+    webhookSecret: string;
+    messengerPostURL: string;
+    credentials: string;
+
+
+    constructor(id: string, contactId: string, contactName: string, channelType: string, credentials: string) {
+        super(id, contactId, contactName, channelType);
+
+        let parseCredentials: MessengerChannel;
+
+        this.credentials = credentials;
+
+        if (credentials && typeof credentials == 'string') parseCredentials = JSON.parse(credentials);
+
+        if (parseCredentials) {
+            this.pageToken = parseCredentials.pageToken;
+            this.webhookSecret = parseCredentials.webhookSecret;
+        }
+
+        this.channelType = channelType;
+        this.messengerPostURL = `https://graph.facebook.com/v18.0/me/messages?access_token=`;
+    }
+
+    public verifyWebhook(req: Request, res: Response) {
+        let mode = req.query['hub.mode'];
+        let token = req.query['hub.verify_token'];
+        let challenge = req.query['hub.challenge'];
+
+        if (mode === 'subscribe' && this.webhookSecret == token) {
+            console.log(`channel ${this.channelType} - ${this.contactName} ${this.contactId} webhook verified!`);
+            return challenge;
+        } else {
+            console.error(`Verification channel ${this.channelType} - ${this.contactName} ${this.contactId} failed!`);
+            return null;
+        }
+    }
+}
diff --git a/server/src/config/index.ts b/server/src/config/index.ts
@@ -27,4 +27,6 @@ export const {
    FIREBASE_CLIENT_X509_CERT_URL,
    FIREBASE_UNIVERSE_DOMAIN,
    FIREBASE_DATABASE_URL,
+   PUBLIC_DOMAIN,
+   BOT_URL,
 } = process.env;
diff --git a/server/src/constants/index.ts b/server/src/constants/index.ts
@@ -31,6 +31,10 @@ export const ENDPOINTS = {
       INDEX: '/channel',
       DELETE: '/channel/delete',
       DELETES: '/channel/deletes',
+   },
+   WEBHOOK: {
+      INDEX: '/webhook',
+      VERIFY: '/webhook/:contactId',
    }
 };
 
diff --git a/server/src/controllers/channels.controller.ts b/server/src/controllers/channels.controller.ts
@@ -1,6 +1,7 @@
 import { LOCALE_KEY } from "@/constants";
 import { PagingDTO } from "@/dtos/paging.dto";
 import { LocaleService } from "@/i18n/ctx";
+import { RequestWithUser } from "@/interfaces/auth.interface";
 import { ChannelService } from "@/services/channels.service";
 import { catchAsync } from "@/utils/catch-async";
 import { plainToClass } from "class-transformer";
@@ -11,38 +12,40 @@ export class ChannelController {
     public channelService = Container.get(ChannelService);
     public localeService = Container.get<LocaleService>(LOCALE_KEY);
 
-    public createChannel = catchAsync(async (req, res) => {
+    public createChannel = catchAsync(async (req: RequestWithUser, res) => {
+        req.body.userId = req.user?.id;
         await this.channelService.create(req.body);
         res.status(StatusCodes.OK).json({
             message: this.localeService.i18n().CHANNEL.CREATE_SUCCESS(),
         });
     });
 
-    public updateChannel = catchAsync(async (req, res) => {
+    public updateChannel = catchAsync(async (req: RequestWithUser, res) => {
+        req.body.userId = req.user?.id;
         await this.channelService.updateById(req.params.id, req.body);
         res.status(StatusCodes.OK).json({
             message: this.localeService.i18n().CHANNEL.UPDATE_SUCCESS(),
         });
     })
 
-    public deleteChannel = catchAsync(async (req, res) => {
-        await this.channelService.deleteById(req.params.id);
+    public deleteChannel = catchAsync(async (req: RequestWithUser, res) => {
+        await this.channelService.deleteById(req.params.id, req.user?.id as string);
         res.status(StatusCodes.OK).json({
             message: this.localeService.i18n().CHANNEL.DELETE_CHANNEL_SUCCESS(),
         });
     })
 
-    public deleteMultipleChannel = catchAsync(async (req, res) => {
-        await this.channelService.deleteByIds(req.body.id);
+    public deleteMultipleChannel = catchAsync(async (req: RequestWithUser, res) => {
+        await this.channelService.deleteByIds(req.body.id, req.user?.id as string);
         res.status(StatusCodes.OK).json({
             message: this.localeService.i18n().CHANNEL.DELETE_MULTIPLE_CHANNELS_SUCCESS(),
         });
     })
 
-    public getChannelsPaging = catchAsync(async (req, res) => {
+    public getAllChannels = catchAsync(async (req: RequestWithUser, res) => {
         const paging = plainToClass(PagingDTO, req.query);
 
-        const data = await this.channelService.getChannelsPaging(paging);
+        const data = await this.channelService.getAllChannels(paging, req.user?.id as string);
         res.status(StatusCodes.OK).json({ data });
     })
 }
diff --git a/server/src/controllers/webhook.controller.ts b/server/src/controllers/webhook.controller.ts
@@ -0,0 +1,18 @@
+import { LOCALE_KEY } from "@/constants";
+import { LocaleService } from "@/i18n/ctx";
+import { WebhookService } from "@/services/webhook.service";
+import { catchAsync } from "@/utils/catch-async";
+import { StatusCodes } from "http-status-codes";
+import Container from "typedi";
+
+export class WebhookController {
+    public webhookService = Container.get(WebhookService);
+    public localeService = Container.get<LocaleService>(LOCALE_KEY);
+
+
+    public verifyWebhook = catchAsync(async (req, res) => {
+        const data = await this.webhookService.verifyWebhook(req.params.contactId as string, req, res);
+
+        res.status(StatusCodes.OK).send(data);
+    });
+}
diff --git a/server/src/database/schema.ts b/server/src/database/schema.ts
@@ -59,6 +59,7 @@ export const channels = pgTable('channels', {
    active: boolean('active'),
    deleted: boolean('deleted').default(false),
    channelTypeId: text('channel_type_id').notNull(),
+   userId: text('user_id').notNull(),
    createdAt: timestamp('created_at').defaultNow(),
    updatedAt: timestamp('updated_at'),
 });
@@ -67,9 +68,19 @@ export const channelTypesRelations = relations(channelTypes, ({ many }) => ({
    channels: many(channels),
 }));
 
+export const usersRelations = relations(users, ({ many }) => ({
+   channels: many(channels),
+}));
+
 export const channelsRelations = relations(channels, ({ one }) => ({
    channelType: one(channelTypes, {
       fields: [channels.channelTypeId],
       references: [channelTypes.id],
    }),
+   User: one(users, {
+      fields: [channels.userId],
+      references: [users.id]
+   }),
 }));
+
+
diff --git a/server/src/database/seed.ts b/server/src/database/seed.ts
@@ -19,7 +19,7 @@ async function seedChannelTypes() {
 async function seedDefaultAccount() {
     try {
         const hashedPassword = await bcrypt.hash("Hello@123", 10);
-        await db.insert(users).values({email: "admin@gmail.com", password: hashedPassword, name: "admin",});
+        await db.insert(users).values({ email: "admin@gmail.com", password: hashedPassword, name: "admin", });
     } catch (error) {
         console.error(`Can't create default account`);
     }
diff --git a/server/src/dtos/channels.dto.ts b/server/src/dtos/channels.dto.ts
@@ -1,6 +1,6 @@
 import { getCurrentLocale } from '@/i18n/get-current';
 import { Transform } from "class-transformer";
-import { IsArray, IsBoolean, IsNotEmpty, IsString } from "class-validator";
+import { IsArray, IsBoolean, IsNotEmpty, IsOptional, IsString } from "class-validator";
 
 export class ChannelDTO {
     @IsString()
@@ -23,8 +23,8 @@ export class ChannelDTO {
     })
     channelTypeId: string;
 
-    @IsString()
-    credentials: string;
+    @IsOptional()
+    credentials: any;
 
     @IsBoolean()
     active: boolean | false;
@@ -34,4 +34,9 @@ export class DeleteChannelDTO {
     @IsArray()
     @Transform(({ value }) => value ?? [])
     id: string[];
+}
+
+export class MessengerDTO {
+    pageToken: string;
+    webhookSecret: string;
 }
diff --git a/server/src/dtos/paging.dto.ts b/server/src/dtos/paging.dto.ts
@@ -4,26 +4,26 @@ import { IsNumber, IsOptional, IsString } from "class-validator";
 export class PagingDTO {
     @IsNumber()
     @Type(() => Number)
-    @Transform(({ value }) => parseInt(value) ?? 1)
     @IsOptional()
-    page: number | 0;
+    @Transform(({ value }) => parseInt(value) ?? 1)
+    page: number | 1;
 
     @IsNumber()
     @Type(() => Number)
-    @Transform(({ value }) => parseInt(value) ?? 20)
     @IsOptional()
+    @Transform(({ value }) => parseInt(value) ?? 20)
     limit: number | 20;
 
     @IsString()
     @IsOptional()
     orderBy: string;
 
     @IsString()
-    @Transform(({ value }) => value ?? 'asc')
     @IsOptional()
+    @Transform(({ value }) => value ?? 'asc')
     sortType: 'asc' | 'desc';
 
     @IsString()
     @IsOptional()
-    q: string;
+    q: string | '';
 }
diff --git a/server/src/dtos/webhook.dto.ts b/server/src/dtos/webhook.dto.ts
@@ -0,0 +1,6 @@
+import { IsString } from "class-validator";
+
+export class VerifyWebhookDTO {
+    @IsString()
+    contactId: string
+}
diff --git a/server/src/i18n/get-preferred-locale.ts b/server/src/i18n/get-preferred-locale.ts
@@ -1,12 +1,12 @@
 import { Request } from 'express';
 import {
-   initAcceptLanguageHeaderDetector,
-   initRequestCookiesDetector,
+   initAcceptLanguageHeaderDetector
 } from 'typesafe-i18n/detectors';
 import { Locales } from './i18n-types';
 import { detectLocale } from './i18n-util';
 
 export const getPreferredLocale = (req: Request): Locales => {
+
    const headers = {
       get: (key: string) => (req.headers[key] as string) || null,
    };
@@ -15,7 +15,5 @@ export const getPreferredLocale = (req: Request): Locales => {
       'lang'
    );
 
-   const requestCookiesDetector = initRequestCookiesDetector(req, 'lang');
-
-   return detectLocale(acceptLanguageDetector, requestCookiesDetector);
+   return detectLocale(acceptLanguageDetector);
 };
diff --git a/server/src/interfaces/channels.interface.ts b/server/src/interfaces/channels.interface.ts
@@ -7,4 +7,24 @@ export interface ChannelExtend {
     active: boolean;
     createdAt: Date;
     updateAt: Date;
+}
+
+export interface ChannelInfo {
+    id: string;
+    contactId: string;
+    contactName: string;
+    channelType: string;
+    credentials: string;
+}
+
+export interface MessengerInfo {
+    pageToken: string;
+    webhookSecret: string
+}
+
+export interface ChannelType {
+    id: string;
+    name: string;
+    description: string;
+    deleted: boolean;
 }
diff --git a/server/src/routes/channels.route.ts b/server/src/routes/channels.route.ts
diff --git a/server/src/routes/webhook.route.ts b/server/src/routes/webhook.route.ts
diff --git a/server/src/server.ts b/server/src/server.ts
diff --git a/server/src/services/channels.service.ts b/server/src/services/channels.service.ts
diff --git a/server/src/services/webhook.service.ts b/server/src/services/webhook.service.ts

Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ async function seedChannelTypes() {`
`19`	`19`	`async function seedDefaultAccount() {`
`20`	`20`	`try {`
`21`	`21`	`const hashedPassword = await bcrypt.hash("Hello@123", 10);`
`22`		`- await db.insert(users).values({email: "[email protected]", password: hashedPassword, name: "admin",});`
	`22`	`+ await db.insert(users).values({ email: "[email protected]", password: hashedPassword, name: "admin", });`
`23`	`23`	`} catch (error) {`
`24`	`24`	console.error(`Can't create default account`);
`25`	`25`	`}`