Add integration with dialogflow

backend/package.json

@@ -6,7 +6,7 @@
   "scripts": {
     "build": "tsc",
     "watch": "tsc -w",
-    "start": "nodemon dist/server.js",
+    "start": "nodemon --ignore dialogflow/ dist/server.js",
     "dev:server": "ts-node-dev --respawn --transpile-only --ignore node_modules src/server.ts",
     "pretest": "NODE_ENV=test sequelize db:migrate && NODE_ENV=test sequelize db:seed:all",
     "test": "NODE_ENV=test jest",
@@ -15,8 +15,10 @@
   "author": "",
   "license": "MIT",
   "dependencies": {
+    "@google-cloud/dialogflow": "^4.6.0",
     "@sentry/node": "^5.29.2",
     "@types/pino": "^6.3.4",
+    "actions-on-google": "^3.0.0",
     "bcryptjs": "^2.4.3",
     "cookie-parser": "^1.4.5",
     "cors": "^2.8.5",

backend/src/controllers/ContactController.ts

@@ -13,6 +13,8 @@ import CheckIsValidContact from "../services/WbotServices/CheckIsValidContact";
 import GetProfilePicUrl from "../services/WbotServices/GetProfilePicUrl";
 import AppError from "../errors/AppError";
 import GetContactService from "../services/ContactServices/GetContactService";
+import ToggleUseQueuesContactService from "../services/ContactServices/ToggleUseQueuesContactService";
+import ToggleUseDialogflowContactService from "../services/ContactServices/ToggleUseDialogflowContactService";
 
 type IndexQuery = {
   searchParam: string;
@@ -32,6 +34,7 @@ interface ContactData {
   name: string;
   number: string;
   email?: string;
+  useDialogflow: boolean;
   extraInfo?: ExtraInfo[];
 }
 
@@ -83,11 +86,14 @@ export const store = async (req: Request, res: Response): Promise<Response> => {
   let number = validNumber
   let email = newContact.email
   let extraInfo = newContact.extraInfo
+  let useDialogflow = newContact.useDialogflow
+
 
   const contact = await CreateContactService({
     name,
     number,
     email,
+    useDialogflow,
     extraInfo,
     profilePicUrl
   });
@@ -144,6 +150,40 @@ export const update = async (
   return res.status(200).json(contact);
 };
 
+export const toggleUseQueue = async (
+  req: Request,
+  res: Response
+): Promise<Response> => {
+  const { contactId } = req.params;
+
+  const contact = await ToggleUseQueuesContactService({ contactId });
+
+  const io = getIO();
+  io.emit("contact", {
+    action: "update",
+    contact
+  });
+
+  return res.status(200).json(contact);
+};
+
+export const toggleUseDialogflow = async (
+  req: Request,
+  res: Response
+): Promise<Response> => {
+  const { contactId } = req.params;
+
+  const contact = await ToggleUseDialogflowContactService({ contactId });
+
+  const io = getIO();
+  io.emit("contact", {
+    action: "update",
+    contact
+  });
+
+  return res.status(200).json(contact);
+};
+
 export const remove = async (
   req: Request,
   res: Response

backend/src/controllers/DialogflowController.ts

@@ -0,0 +1,85 @@
+import { Request, Response } from "express";
+import { getIO } from "../libs/socket";
+import CreateDialogflowService from "../services/DialogflowServices/CreateDialogflowService";
+import DeleteDialogflowService from "../services/DialogflowServices/DeleteDialogflowService";
+import ListDialogflowsService from "../services/DialogflowServices/ListDialogflowService";
+import ShowDialogflowService from "../services/DialogflowServices/ShowDialogflowService";
+import TestSessionDialogflowService from "../services/DialogflowServices/TestSessionDialogflowService";
+import UpdateDialogflowService from "../services/DialogflowServices/UpdateDialogflowService";
+
+export const index = async (req: Request, res: Response): Promise<Response> => {
+  const dialogflows = await ListDialogflowsService();
+
+  return res.status(200).json(dialogflows);
+};
+
+export const store = async (req: Request, res: Response): Promise<Response> => {
+  const { name, projectName, jsonContent, language } = req.body;
+
+  const dialogflow = await CreateDialogflowService({ name, projectName, jsonContent, language });
+
+  const io = getIO();
+  io.emit("dialogflow", {
+    action: "update",
+    dialogflow
+  });
+
+  return res.status(200).json(dialogflow);
+};
+
+export const show = async (req: Request, res: Response): Promise<Response> => {
+  const { dialogflowId } = req.params;
+
+  const dialogflow = await ShowDialogflowService(dialogflowId);
+
+  return res.status(200).json(dialogflow);
+};
+
+export const update = async (
+  req: Request,
+  res: Response
+): Promise<Response> => {
+  const { dialogflowId } = req.params;
+  const dialogflowData = req.body;
+
+  const dialogflow = await UpdateDialogflowService({dialogflowData, dialogflowId });
+
+  const io = getIO();
+  io.emit("dialogflow", {
+    action: "update",
+    dialogflow
+  });
+
+  return res.status(201).json(dialogflow);
+};
+
+export const remove = async (
+  req: Request,
+  res: Response
+): Promise<Response> => {
+  const { dialogflowId } = req.params;
+
+  await DeleteDialogflowService(dialogflowId);
+
+  const io = getIO();
+  io.emit("dialogflow", {
+    action: "delete",
+    dialogflowId: +dialogflowId
+  });
+
+  return res.status(200).send();
+};
+
+export const testSession = async (req: Request, res: Response): Promise<Response> => {
+  const { projectName, jsonContent, language } = req.body;
+
+  const response = await TestSessionDialogflowService({ projectName, jsonContent, language });
+
+  const io = getIO();
+  io.emit("dialogflow", {
+    action: "testSession",
+    response
+  });
+
+  return res.status(200).json(response);
+};

backend/src/database/index.ts

@@ -10,6 +10,7 @@ import Queue from "../models/Queue";
 import WhatsappQueue from "../models/WhatsappQueue";
 import UserQueue from "../models/UserQueue";
 import QuickAnswer from "../models/QuickAnswer";
+import Dialogflow from "../models/Dialogflow";
 
 // eslint-disable-next-line
 const dbConfig = require("../config/database");
@@ -25,6 +26,7 @@ const models = [
   Whatsapp,
   ContactCustomField,
   Setting,
+  Dialogflow,
   Queue,
   WhatsappQueue,
   UserQueue,

backend/src/database/migrations/20220218095931-create-dialogflow.ts

@@ -0,0 +1,44 @@
+import { QueryInterface, DataTypes } from "sequelize";
+
+module.exports = {
+  up: (queryInterface: QueryInterface) => {
+    return queryInterface.createTable("Dialogflows", {
+      id: {
+        type: DataTypes.INTEGER,
+        autoIncrement: true,
+        primaryKey: true,
+        allowNull: false
+      },
+      name: {
+        type: DataTypes.STRING,
+        allowNull: false,
+        unique: true
+      },
+      projectName: {
+        type: DataTypes.STRING,
+        allowNull: false,
+        unique: true
+      },
+      jsonContent: {
+        type: DataTypes.TEXT,
+        allowNull: false,
+      },
+      language: {
+        type: DataTypes.STRING,
+        allowNull: false,
+      },
+      createdAt: {
+        type: DataTypes.DATE,
+        allowNull: false
+      },
+      updatedAt: {
+        type: DataTypes.DATE,
+        allowNull: false
+      }
+    });
+  },
+
+  down: (queryInterface: QueryInterface) => {
+    return queryInterface.dropTable("Dialogflows");
+  }
+};

backend/src/database/migrations/20220218095932-add-dialogflow-to-queues.ts

@@ -0,0 +1,16 @@
+import { QueryInterface, DataTypes } from "sequelize";
+
+module.exports = {
+  up: (queryInterface: QueryInterface) => {
+    return queryInterface.addColumn("Queues", "dialogflowId", {
+      type: DataTypes.INTEGER,
+      references: { model: "Dialogflows", key: "id" },
+      onUpdate: "CASCADE",
+      onDelete: "SET NULL"
+    });
+  },
+
+  down: (queryInterface: QueryInterface) => {
+    return queryInterface.removeColumn("Queues", "dialogflowId");
+  }
+};

backend/src/database/migrations/20220218095933-add-use-dialogflow-to-contacts.ts

@@ -0,0 +1,15 @@
+import { QueryInterface, DataTypes } from "sequelize";
+
+module.exports = {
+  up: (queryInterface: QueryInterface) => {
+    return queryInterface.addColumn("Contacts", "useDialogflow", {
+      type: DataTypes.BOOLEAN,
+      allowNull: false,
+      defaultValue: true
+    });
+  },
+
+  down: (queryInterface: QueryInterface) => {
+    return queryInterface.removeColumn("Contacts", "useDialogflow");
+  }
+};

backend/src/database/migrations/20220218095934-add-use-queues-to-contacts.ts

@@ -0,0 +1,15 @@
+import { QueryInterface, DataTypes } from "sequelize";
+
+module.exports = {
+  up: (queryInterface: QueryInterface) => {
+    return queryInterface.addColumn("Contacts", "useQueues", {
+      type: DataTypes.BOOLEAN,
+      allowNull: false,
+      defaultValue: true
+    });
+  },
+
+  down: (queryInterface: QueryInterface) => {
+    return queryInterface.removeColumn("Contacts", "useQueues");
+  }
+};

backend/src/models/Contact.ts

@@ -41,6 +41,14 @@ class Contact extends Model<Contact> {
   @Column
   isGroup: boolean;
 
+  @Default(true)
+  @Column
+  useQueues: boolean;
+
+  @Default(true)
+  @Column
+  useDialogflow: boolean;
+
   @CreatedAt
   createdAt: Date;
 

backend/src/models/Dialogflow.ts

@@ -0,0 +1,45 @@
+import {
+    Table,
+    Column,
+    CreatedAt,
+    UpdatedAt,
+    Model,
+    DataType,
+    PrimaryKey,
+    HasMany,
+    AutoIncrement
+} from "sequelize-typescript";
+import Queue from "./Queue";
+
+@Table
+class Dialogflow extends Model<Dialogflow> {
+    @PrimaryKey
+    @AutoIncrement
+    @Column
+    id: number;
+
+    @Column(DataType.TEXT)
+    name: string;
+
+    @Column(DataType.TEXT)
+    projectName: string;
+
+    @Column(DataType.TEXT)
+    jsonContent: string;
+
+    @Column(DataType.TEXT)
+    language: string;
+
+    @CreatedAt
+    @Column(DataType.DATE(6))
+    createdAt: Date;
+
+    @UpdatedAt
+    @Column(DataType.DATE(6))
+    updatedAt: Date;
+
+    @HasMany(() => Queue)
+    queues: Queue[]
+}
+
+export default Dialogflow;

backend/src/models/Queue.ts

@@ -8,13 +8,16 @@ import {
   AutoIncrement,
   AllowNull,
   Unique,
-  BelongsToMany
+  BelongsToMany,
+  BelongsTo,
+  ForeignKey
 } from "sequelize-typescript";
 import User from "./User";
 import UserQueue from "./UserQueue";
 
 import Whatsapp from "./Whatsapp";
 import WhatsappQueue from "./WhatsappQueue";
+import Dialogflow from "./Dialogflow";
 
 @Table
 class Queue extends Model<Queue> {
@@ -36,6 +39,13 @@ class Queue extends Model<Queue> {
   @Column
   greetingMessage: string;
 
+  @ForeignKey(() => Dialogflow)
+  @Column
+  dialogflowId: number;
+
+  @BelongsTo(() => Dialogflow)
+  dialogflow: Dialogflow;
+
   @CreatedAt
   createdAt: Date;
 

backend/src/routes/contactRoutes.ts

@@ -22,6 +22,10 @@ contactRoutes.post("/contact", isAuth, ContactController.getContact);
 
 contactRoutes.put("/contacts/:contactId", isAuth, ContactController.update);
 
+contactRoutes.put("/contacts/toggleUseQueues/:contactId", isAuth, ContactController.toggleUseQueue);
+
+contactRoutes.put("/contacts/toggleUseDialogflow/:contactId", isAuth, ContactController.toggleUseDialogflow);
+
 contactRoutes.delete("/contacts/:contactId", isAuth, ContactController.remove);
 
 export default contactRoutes;