index.js

const express = require('express');
require('dotenv').config();
const bodyParser = require('body-parser');
const { TiledeskClient } = require('@tiledesk/tiledesk-client');
// const { TiledeskClient } = require('./tiledesk-client');

const app = express();
// app.use(bodyParser.json());
const mqttTest = require('./tiledesk-client/mqtt-route');
// const mqttTest = require('@tiledesk/tiledesk-client/mqtt-route');
const mqtt_route = mqttTest.router
app.use("/mqttTestRoute", mqtt_route);

mqttTest.startApp(
  {
    // CHAT_API_ENDPOINT: process.env.CHAT_API_ENDPOINT,
    // MQTT_ENDPOINT: process.env.MQTT_ENDPOINT,
    // API_ENDPOINT: process.env.API_ENDPOINT,
    LOG_STATUS: false
  }, () => {
  console.log("mqttTestRoute route successfully started.");
  var port = process.env.PORT || 3000;
  app.listen(port, function () {
    console.log('App listening on port ', port);
  });
});

app.get('/', (req, res) => {
  res.send('Hello Tiledesk nodejs APIs!')
});

app.post('/sendmessage', (req, res) => {
  const project_id = req.body.project_id
  const recipient_id = req.body.recipient_id
  const token = req.body.token
  const text = req.body.text
  
  // TiledeskClient instance is the preferred method

  const tdclient = new TiledeskClient(
    {
      projectId: project_id,
      token: token
    });

  tdclient.sendMessage(
    {
      text: text
    }, recipient_id
  );

  res.send({success: true});
})

app.post('/sendmessageraw', (req, res) => {
  const project_id = req.body.project_id
  const recipient_id = req.body.recipient_id
  const token = req.body.token
  const text = req.body.text

  // Raw is an uncommon method but it's useful
  // to have
  
  TiledeskClient.sendMessageRaw(
    "https://api.tiledesk.com/v2",
    token,
    project_id,
    {
      text: text + " raw"
    },
    recipient_id,
    function(err, res) {
      console.log("Message sent.");
    }
  );

  res.send({success: true});
})

app.post('/anonymauth', (req, res) => {
  console.log("/anonymtoken");
  const project_id = req.body.project_id

  // Or raw (uncommon method)
  
  TiledeskClient.anonymousAuthentication(
    project_id,
    function(err, response, resbody) {
      console.log("Got token", resbody);
      if (!err && resbody) {
        res.send(resbody);
      }
      else {
        res.send({success: false, err: err});
      }
    }
  );
})

app.post('/opennow', (req, res) => {
  console.log("/anonymtoken");
  const project_id = req.body.project_id
  TiledeskClient.anonymousAuthentication(
    project_id,
    function(err, response, resbody) {
      console.log("Got token", resbody);
      if (!err && resbody.user) {
         const tdclient = new TiledeskClient(
          {
            projectId: project_id,
            token: resbody.token
          });
          tdclient.openNow(function(is_open) {
            res.json({
              success: true,
              isOpen: is_open
            });
          });
      }
      else {
        res.send({success: false, err: err});
      }
    }
  );
})

app.post('/fireevent', (req, res) => {
    console.log("/fireevent");
    const project_id = req.body.project_id;
    const event = req.body.event;
    
    TiledeskClient.anonymousAuthentication(
      project_id,
      function(err, response, resbody) {
        console.log("Got token", resbody);
        if (!err && resbody.user) {
           const tdclient = new TiledeskClient(
            {
              projectId: project_id,
              token: resbody.token
            });
            // const event = {
            //     name: "faqbot.answer_not_found",
            //     attributes: {
            //         bot: {
            //             _id: bot_id,
            //             name: bot_name
            //         },
            //         message: {
            //             text: "help"
            //         }
            //     }
            // };
            tdclient.fireEvent(event, function(err, response, resbody) {
              res.json(resbody);
            });
        }
        else {
          res.send({success: false, err: err});
        }
      }
    );
  })

// app.listen(3000, () => {
//   console.log('server started');
// });