add verify

Author: khanh1902

server/package-lock.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",

server/package.json

@@ -1,22 +1,22 @@
-import 'reflect-metadata';
+import { CREDENTIALS, LOG_FORMAT, NODE_ENV, PORT } from '@config';
+import type { Routes } from '@interfaces/routes.interface';
+import { ErrorMiddleware } from '@middlewares/error.middleware';
+import { logger, stream } from '@utils/logger';
 import compression from 'compression';
 import cookieParser from 'cookie-parser';
 import cors from 'cors';
 import express from 'express';
 import helmet from 'helmet';
 import hpp from 'hpp';
 import morgan from 'morgan';
+import 'reflect-metadata';
 import swaggerJSDoc from 'swagger-jsdoc';
 import swaggerUi from 'swagger-ui-express';
-import { NODE_ENV, PORT, LOG_FORMAT, ORIGIN, CREDENTIALS } from '@config';
-import type { Routes } from '@interfaces/routes.interface';
-import { ErrorMiddleware } from '@middlewares/error.middleware';
-import { logger, stream } from '@utils/logger';
-import { loadAllLocales } from './i18n/i18n-util.sync';
-import { getPreferredLocale } from './i18n/get-preferred-locale';
 import Container from 'typedi';
 import { LOCALE_KEY } from './constants';
 import { LocaleService } from './i18n/ctx';
+import { getPreferredLocale } from './i18n/get-preferred-locale';
+import { loadAllLocales } from './i18n/i18n-util.sync';
 
 Container.set(LOCALE_KEY, new LocaleService('en'));
 

server/src/app.ts

@@ -0,0 +1,59 @@
+import { BOT_URL } from "@/config";
+import axios from "axios";
+import { Service } from "typedi";
+
+@Service()
+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) {
+    // };
+}

server/src/channels/base.channel.ts

@@ -0,0 +1,43 @@
+import { Request, Response } from "express";
+import { BaseChannel } from "./base.channel";
+
+export class MessengerChannel extends BaseChannel {
+    channelType: string;
+    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 (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;
+        }
+    }
+}

server/src/channels/messenger.channel.ts

@@ -27,4 +27,6 @@ export const {
    FIREBASE_CLIENT_X509_CERT_URL,
    FIREBASE_UNIVERSE_DOMAIN,
    FIREBASE_DATABASE_URL,
+   PUBLIC_DOMAIN,
+   BOT_URL,
 } = process.env;

server/src/config/index.ts

@@ -30,6 +30,10 @@ export const ENDPOINTS = {
       INDEX: '/channel',
       DELETE: '/channel/delete',
       DELETES: '/channel/deletes',
+   },
+   WEBHOOK: {
+      INDEX: '/webhook',
+      VERIFY: '/webhook/:contactId',
    }
 };
 

server/src/constants/index.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);
+    });
+}

server/src/controllers/webhook.controller.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: "[email protected]", password: hashedPassword, name: "admin",});
+        await db.insert(users).values({ email: "[email protected]", password: hashedPassword, name: "admin", });
     } catch (error) {
         console.error(`Can't create default account`);
     }

server/src/database/seed.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;
 }