Integração com n8n

rtenorioh · May 9, 2023 · 1beb8c6 · 1beb8c6
1 parent f36e6c6
commit 1beb8c6
Show file tree

Hide file tree

Showing 8 changed files with 86 additions and 0 deletions.
diff --git a/backend/package.json b/backend/package.json
@@ -36,6 +36,7 @@
     "pino-pretty": "^10.0.0",
     "qrcode-terminal": "^0.12.0",
     "reflect-metadata": "^0.1.13",
+    "request": "^2.88.2",
     "sequelize": "^5.22.3",
     "sequelize-cli": "^5.5.1",
     "sequelize-typescript": "^1.1.0",

diff --git a/backend/src/database/seeds/20230507221800-create-n8n-integrations.ts b/backend/src/database/seeds/20230507221800-create-n8n-integrations.ts
@@ -0,0 +1,22 @@
+import { QueryInterface } from "sequelize";
+
+module.exports = {
+  up: (queryInterface: QueryInterface) => {
+    return queryInterface.bulkInsert(
+      "Integrations",
+      [
+        {
+          key: "urlApiN8N",
+          value: "",
+          createdAt: new Date(),
+          updatedAt: new Date()
+        }
+      ],
+      {}
+    );
+  },
+
+  down: (queryInterface: QueryInterface) => {
+    return queryInterface.bulkDelete("Integrations", {});
+  }
+};
diff --git a/backend/src/services/WbotServices/wbotMessageListener.ts b/backend/src/services/WbotServices/wbotMessageListener.ts
@@ -16,6 +16,7 @@ import Contact from "../../models/Contact";
 import Ticket from "../../models/Ticket";
 import Message from "../../models/Message";
 import Settings from "../../models/Setting";
+import Integration from "../../models/Integration";
 
 import { getIO } from "../../libs/socket";
 import CreateMessageService from "../MessageServices/CreateMessageService";
@@ -29,6 +30,8 @@ import UpdateTicketService from "../TicketServices/UpdateTicketService";
 import CreateContactService from "../ContactServices/CreateContactService";
 import formatBody from "../../helpers/Mustache";
 
+const request = require("request");
+
 interface Session extends Client {
   id?: number;
 }
@@ -350,6 +353,27 @@ const handleMessage = async (
     return;
   }
 
+  const Integrationdb = await Integration.findOne({
+    where: { key: "urlApiN8N" }
+  });
+
+  if (Integrationdb?.value) {
+    const options = {
+      method: "POST",
+      url: Integrationdb?.value,
+      headers: {
+        "Content-Type": "application/json"
+      },
+      json: msg
+    };
+    try {
+      const response = await request(options);
+      console.log(response.body);
+    } catch (error) {
+      throw new Error(error);
+    }
+  }
+
   // IGNORAR MENSAGENS DE GRUPO
   const Settingdb = await Settings.findOne({
     where: { key: "CheckMsgIsGroup" }

diff --git a/docs/CHANGELOG.md b/docs/CHANGELOG.md
@@ -1,5 +1,13 @@
 # Changelog
 
+### 07/05/2023
+
+- []()
+
+### 05/05/2023
+
+- [Número do cliente trucado para Atendente com verificação individual](https://github.com/rtenorioh/Press-Ticket/commit/f36e6c6f8ae2a3cd29a0defdc14a8a79a726cbcb).
+
 ### 04/05/2023
 
 - [Integração com ChatGPT](https://github.com/rtenorioh/Press-Ticket/commit/6b5d22895917a0901a5a8e62f5b40a7acfeeece8); e

diff --git a/frontend/src/pages/Integrations/index.js b/frontend/src/pages/Integrations/index.js
@@ -123,6 +123,25 @@ const Integrations = () => {
 					</Paper>
 				</Paper>
 
+				<Paper className={classes.paper1}>
+					<Typography align="center" variant="body1">
+						{i18n.t("integrations.integrations.n8n.title")}
+					</Typography>
+					<Paper elevation={4} className={classes.paper}>
+						<TextField
+							style={{ width: "100%" }}
+							id="urlApiN8N"
+							name="urlApiN8N"
+							margin="dense"
+							label={i18n.t("integrations.integrations.n8n.urlApiN8N")}
+							variant="outlined"
+							value={integrations && integrations.length > 0 && getIntegrationValue("urlApiN8N")}
+							onChange={handleChangeIntegration}
+							fullWidth
+						/>
+					</Paper>
+				</Paper>
+
 			</Container>
 		</div>
 	);

diff --git a/frontend/src/translate/languages/en.js b/frontend/src/translate/languages/en.js
@@ -494,6 +494,10 @@ const messages = {
             title: "OpenAI",
             organization: "Organization ID",
             apikey: "KEY"
+          },
+          n8n: {
+            title: "N8N",
+            urlApiN8N: "URL API N8N"
           }
         },
       },

diff --git a/frontend/src/translate/languages/es.js b/frontend/src/translate/languages/es.js
@@ -494,6 +494,10 @@ const messages = {
             title: "OpenAI",
             organization: "Organization ID",
             apikey: "KEY"
+          },
+          n8n: {
+            title: "N8N",
+            urlApiN8N: "URL API N8N"
           }
         },
       },

diff --git a/frontend/src/translate/languages/pt.js b/frontend/src/translate/languages/pt.js
@@ -495,6 +495,10 @@ const messages = {
             title: "OpenAI",
             organization: "Organization ID",
             apikey: "KEY"
+          },
+          n8n: {
+            title: "N8N",
+            urlApiN8N: "URL API N8N"
           }
         },
       },