new api integration

controllers/connection.controller.js

+const {  WebhookResponses } = require('../config/db.config');
+var request = require('request');
+
+
+async function createConnection(req, res) {
+    try {
+        if (req.params.mobile_number) {
+            let mobile_number = req.params.mobile_number;
+            let random_num = Math.floor(Math.random() * 90000) + 10000;
+            let identifier = `${mobile_number}-${random_num}`;
+            let dataString = '{"uri":"whatsappsandbox://'+mobile_number+'@whatsapp.com","name":"'+identifier+'"}';
+            let options = {
+                url: 'https://apiv2.unificationengine.com/v2/connection/add',
+                method: 'POST',
+                body: dataString,
+                auth: {
+                'user': 'a913b40f-aa55-49ef-ae23-bbd4d1baec94',
+                'pass': '025fd444-62b4-4c44-b097-28ef2bde4f6e'
+                }
+            };
+            request(options, function (error, response, body) {
+                let respo = JSON.parse(body);
+                if (respo.status && respo.status == 200) {
+                    WebhookResponses.create({identifier: identifier, mobile_number: mobile_number, status:"created"})
+                    .then(user => res.json({status: 200,info: 'OK', identifier: identifier}))
+                    .catch(function (err) {
+                        console.log(err);
+                        res.status(500).send({msg:"something went wrong!"});
+                    });
+                } else res.status(500).send({error: true, message:respo});
+            });
+        } else throw "bad request";
+    } catch (err) {
+        console.log(err);
+        res.status(500).send({error: true, message:err});
+    }
+}
+module.exports = {
+    createConnection
+};
\ No newline at end of file

controllers/message.controller.js

+const {  WebhookResponses } = require('../config/db.config');
+var request = require('request');
+
+
+async function sentMessage(req, res) {
+    try {
+        if (req.body.mobile_number) {
+            let mobile_number = req.body.mobile_number;
+            let identifier = req.body.identifier;
+            let message = req.body.message;
+            var dataString = '{"message": {"receivers": [{"name":"name","address":"'+mobile_number+'" ,"Connector":"'+identifier+'", "type":"individual"}],"parts": [{"id":"1","contentType":"text/plain","data":"'+message+'" ,"size": 5,"type":"body","sort":0}]}}';
+            let options = {
+                url: 'https://apiv2.unificationengine.com/v2/message/send',
+                method: 'POST',
+                body: dataString,
+                auth: {
+                'user': 'a913b40f-aa55-49ef-ae23-bbd4d1baec94',
+                'pass': '025fd444-62b4-4c44-b097-28ef2bde4f6e'
+                }
+            };
+            WebhookResponses.update(
+                { message: message, status: "pending" },{ where: {identifier: identifier} }
+            ).then(count => {
+                console.log(count);
+            });
+            request(options, function (error, response, body) {
+                let respo = JSON.parse(body);
+                if (respo.Status) {
+                    WebhookResponses.update(
+                    { sent_response: respo, status: "sent" },{ where: {identifier: identifier} }
+                    ).then(count => {
+                        console.log(count);
+                    });
+                   res.send({error: false, message:respo});
+                } else res.status(500).send({error: true, message:respo});
+            });
+        } else throw "bad request";
+    } catch (err) {
+        console.log(err);
+        res.status(500).send({error: true, message:err});
+    }
+}
+module.exports = {
+    sentMessage
+};
\ No newline at end of file

controllers/webhook.controller.js

@@ -3,12 +3,14 @@ const {  WebhookResponses } = require('../config/db.config');
 async function saveResponse(req, res) {
     try {
         let response = req.body;
-        WebhookResponses.create({response: response})
-        .then(user => res.json({status: 200,info: 'OK'}))
-        .catch(function (err) {
-            console.log(err);
+        console.log(response);
+        if (response.data && response.data.connectionname) {
+            WebhookResponses.update(
+                { response: response, status: "success" },{ where: {identifier: response.data.connectionname} }
+            ).then(count => {
                 res.send({status: 200,info: 'OK'});
             });
+        }
     } catch (err) {
         console.log(err);
        // res.status(400).send({error: true, message:err});

models/webhook_response.js

@@ -5,7 +5,12 @@ module.exports = (sequelize, type) => {
           primaryKey: true,
           autoIncrement: true
         },
+        message: type.STRING,
         response: type.JSON,
+        sent_response: type.JSON,
+        mobile_number: type.STRING,
+        status: type.STRING, 
+        identifier: type.STRING,
         created_at: {
           type: 'TIMESTAMP',
           defaultValue: sequelize.literal('CURRENT_TIMESTAMP'),

package.json

@@ -7,12 +7,15 @@
     "start": "nodemon server"
   },
   "dependencies": {
+    "axios": "^0.19.2",
     "body-parser": "^1.19.0",
     "cors": "^2.8.5",
+    "db-migrate": "^0.11.11",
     "dotenv": "^8.2.0",
     "express": "^4.16.4",
     "http-errors": "~1.6.3",
     "mysql2": "^2.1.0",
+    "node-libcurl": "^2.1.3",
     "nodemon": "^2.0.3",
     "precache": "0.0.0",
     "sequelize": "^5.21.6"

routes/index.js

 var express = require('express');
 const webhookCtrl = require("../controllers/webhook.controller");
+const connectionCtrl = require("../controllers/connection.controller");
+const messageCtrl = require("../controllers/message.controller");
 var router = express.Router();
 
 router.get("/check", (req, res) => {
@@ -8,5 +10,8 @@ router.get("/check", (req, res) => {
   
 /* GET home page. */
 router.post('/webhook', webhookCtrl.saveResponse);
+router.get('/create-connection/:mobile_number', connectionCtrl.createConnection);
+router.post('/sent-message', messageCtrl.sentMessage);
+
 
 module.exports = router;