server.js

////////////////////////////////////////////////////
////////  			RedisLab and HTTP SERVER     ///////
///////            version 0.5.0            ///////
//////////////////////////////////////////////////

'use strict';
const config 	=       require('./config');
const order =         require('./models/orders');
const express =       require('express');
const path  =         require('path');
const banterfile =    require('./texts');
const countries =     require('./countries/country')
const Redis =         require('ioredis');
const fs =            require("fs");
const XLSX =          require("xls-to-json");

const app =  express();
const server =        require('http').Server(app);
const port = process.env.PORT || 3002;

////////////////////////////////////////////////
let redisPort =     config.redis.port;
let redisHost =     config.redis.host;
let redisPassword = config.redis.password;

let redis = new Redis({
 port: redisPort,
 host: redisHost
});

let pub = new Redis({
 port: redisPort,
 host: redisHost

});

// cli command line
let action = process.argv[2];

/////////////////////// arrays with additional data to decorate the text messages ////////////////

let img = ['1', '2', '3', '4', '5', '6', '7', '8', 'chatbot', 'helpbot', 'smartbot']

let orders = []
let requests = [
  "i am looking for ",
  "please ship me 12 ",
  "how much for ",
  "what is the price of ",
  "are you carrying ",
  "what is the cost to ship ",
  "i would like to order ",
  "please replenish my prior order ",
  "how do i place an order for ",
  "ship 6 of ",
  "email catalogue at joe@gmail.com for ",
  " send to pat@xiollc.com the pricing for ",
  " you can reach me at bot@hotmail.com for  status on ",
  "urgently need status at me@geo.org for "
]

// if the order.json file does not exist import the test spreadsheet with 8000+ order items
// to save json file set output to products/products.json -- else set to null
// Delete the order collection in session db on monglab if json file removed here

if (!fs.existsSync("products/orders.json")) {

  XLSX({
    input: "products/samplesales.xls",
    output: "products/orders.json",
    sheet: "Orders"
  }, function(err, result) {
    if(err) {
      console.error(err);
    } else {
      console.log(result[0]['customername'])
      console.log(result[0]['salesamt'])
      // this creates the order collection in session on mongodb
      // used by microplex microservices for ai interactions
      result.filter((item) => {
        order.save((item), () => {
          // do nothing on callback
        })
      })

    }
  })
}

switch (action) {
  case "banter":
    banter()
    break;

  case "product":
    product();
    break;

  default:
    console.log('Error ' + '' + action + ' not recognized')
    break;
}

// subscribe to a channel
redis.subscribe(action, function (err, count) {
			console.log("Subscribed to " + count + " channel")
  });
// listen for orders
redis.subscribe('orders', function (err, count) {
  	 console.log("Subscribed to " + count + " channel")
  });

// log message when detected on redis channel
redis.on('message', function (channel, message) {
    console.log("Channel> " + channel + " Message> " + message);
  });

// publish messages randomly -- test runner for chaotic platform
// add a country name and avatar chosen randomly from arrays
// Note that the target in the config file refers to the host and port where the
// static assets reside which is chaotic dash
function streambanter() {
  let msgObj = banterfile[Math.floor(Math.random() * banterfile.length)];
  msgObj.flagURL = config.target + "/img/flags/" + countries[Math.floor(Math.random() * countries.length)].name + ".png"
  msgObj.avatarURL = config.target + "/img/avatars/" + img[Math.floor(Math.random() * img.length)] + ".jpg"
  let sendMsg = JSON.stringify(msgObj)
  pub.publish(action, sendMsg);

}

function banter() {
  setInterval(function() {
  console.log('bantering');
  streambanter()
}, 5000)};


// create a test file using banter file as base, randomly updated with requests
// This serves as the basis for deeper testing on the chaotic platform

function prepproducts(cb) {
  let id = 0
  let msgObj = {}
  let productObj = {}
  let productarray = banterfile.filter((msg) => {
    id++
    //productObj = productfile[Math.floor(Math.random() * productfile.length)];
    //    msgObj.text = productObj.text
    msg.id = id
    msg.name = orders[Math.floor(Math.random() * orders.length)].customername
    msg.text = requests[Math.floor(Math.random() * requests.length)] + orders[Math.floor(Math.random() * orders.length)].productname
    return msg
  })
  cb(productarray)
}

const streamrequests = (arr) => {
  let sendObj = arr[Math.floor(Math.random() * arr.length)];
  sendObj.flagURL = config.target + "/img/flags/" + countries[Math.floor(Math.random() * countries.length)].name + ".png"
  sendObj.avatarURL = config.target + "/img/avatars/" + img[Math.floor(Math.random() * img.length)] + ".jpg"
  var sendMsg = JSON.stringify(sendObj)
  pub.publish(action, sendMsg);

}
const streamorders = (arr) => {
  let sendObj = arr[Math.floor(Math.random() * arr.length)];
  var sendMsg = JSON.stringify(sendObj)
  pub.publish('orders', sendMsg);

}

function product() {
  if (fs.existsSync("products/orders.json")) {
    orders = JSON.parse(fs.readFileSync("products/orders.json", {encoding: 'utf8'}))
    prepproducts (function(arr) {
      setInterval(function() {
        streamrequests(arr)
      }, 5000)
  //    setInterval(function() {
  //      streamorders(orders)
  //    }, 10000)
    })
  }
};


// server spins up and listed for the cli command
server.listen(port, function() {
  console.log("Listening on port " + port)
})