app.js

/**
 * Copyright 2017 IBM Corp. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the 'License'); you may not
 * use this file except in compliance with the License. You may obtain a copy of
 * the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an 'AS IS' BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */

/*eslint-env browser, node, node*/
"use strict";

require("dotenv").config({
	silent : true
});

var express = require("express"); // app server
var bodyParser = require("body-parser"); // parser for post requests
var watson = require("watson-developer-cloud"); // watson sdk
var Cloudant = require("cloudant");
var vcapServices = require("vcap_services");
var DiscoveryV1 = require('watson-developer-cloud/discovery/v1');
var vodafoneDiscoveryRequired = false;
var ideaDiscoveryRequired = false;
var airtelDiscoveryRequired = false;

// Conversation workspace id
var WORKSPACE_ID = vcapServices.WORKSPACE_ID || process.env.WORKSPACE_ID || "<workspace-id>"; 

var app = express();

// Bootstrap application settings
app.use(express.static("./public")); // load UI from public folder
app.use(bodyParser.json());

// credentials
var conversation_credentials = vcapServices.getCredentials("conversation");
var cloudant_credentials = vcapServices.getCredentials("cloudantNoSQLDB");

// Create the service wrappers
var conversation = watson.conversation({
	url : "https://gateway.watsonplatform.net/conversation/api",
	username : conversation_credentials.username || '',
	password : conversation_credentials.password || '',
	version_date : process.env.CONVERSATION_VERSION_DATE,
	version : process.env.CONVERSATION_VERSION
});

var discovery = new DiscoveryV1({
  username: process.env.DISCOVERY_USERNAME,
  password: process.env.DISCOVERY_PASSWORD,
  version_date: DiscoveryV1.VERSION_DATE_2017_04_27
});

var usersMap; // User details cache
var cloudant = Cloudant({account:cloudant_credentials.username, password:cloudant_credentials.password});
var db = cloudant.db.use(process.env.CLOUDANT_DB_NAME);

// Get the user details from database
function loadUserData() {
	usersMap = new Map();
	db.list({include_docs:true}, function (err, data) {
		if (err) {
			throw err;
		}
		for (var i = 0; i < data.rows.length; i++) {
			var userDetails = [data.rows[i].doc.name, data.rows[i].doc.mobileNumber, data.rows[i].doc.emailId, data.rows[i].doc.address];
			usersMap.set(data.rows[i].doc.userName, userDetails);
		}
	});
}

loadUserData();

// Endpoint called from the client side whenever an input is submitted in the chat window
app.post("/api/message", function(req, res) {

	var workspace = WORKSPACE_ID;
	if (!workspace || workspace === "<workspace-id>") {
		return res.json({
		  "output": {
			"text": "Your app is running but it is yet to be configured with a <b>WORKSPACE_ID</b> environment variable."
			}
		});
	}

	var userName = req.body.context.userName;

	getPerson(userName, function(err, person) {

		if(err){
			console.log("Error occurred while getting person data ::", err);
			return res.status(err.code || 500).json(err);
		}

		var payload = {
			workspace_id : workspace,
			context : {
				"name" : person.name,
				"userName" : person.userName,
				"emailId" : person.emailId,
				"address" : person.address,
				"mobileNumber" : person.mobileNumber,
			},
			input : {}
		};

		if (req.body) {
			if (req.body.input) {
				payload.input = req.body.input;
			}
			if (req.body.context) {
				payload.context = req.body.context;
				payload.context.name = person.name;
				payload.context.userName = person.userName;
				payload.context.emailId = person.emailId;
				payload.context.address = person.address;
				payload.context.mobileNumber = person.mobileNumber;
			}
		}

		callconversation(payload);

	});

	// Send the input to conversation service
	function callconversation(payload) {
		conversation.message(payload, function(err, data) {
			if (err) {
				console.log("Error occurred while invoking Conversation. ::", err);
				return res.status(err.code || 500).json(err);
			}
			if (data.context && data.context.updateEmail && data.context.updateEmail !== '') {
				updateEmail(userName, data.context.updateEmail);
				data.context.updateEmail = '';
			} else if (data.context && data.context.updateAddress && data.context.updateAddress !== '') {
				updateAddress(userName, data.context.updateAddress);
				data.context.updateAddress = '';
			}

			vodafoneDiscoveryRequired = false;
			ideaDiscoveryRequired = false;
			airtelDiscoveryRequired = false;

			//Check the intent to see if a call to Discovery is required
			if (data.intents[0] && data.intents[0].intent) {
				if (data.intents[0].intent == 'plans' ) {
					if (data.entities[0].entity == 'service_provider' && data.entities[0].value == 'Vodafone') {
						vodafoneDiscoveryRequired = true;
					} else if (data.entities[0].entity == 'service_provider' && data.entities[0].value == 'Idea') {
						ideaDiscoveryRequired = true;
					} else if (data.entities[0].entity == 'service_provider' && data.entities[0].value == 'Airtel') {
						airtelDiscoveryRequired = true;
					}
				}
			}

			if(vodafoneDiscoveryRequired){
			discovery.query({
			    environment_id: process.env.DISCOVERY_ENVIRONMENT_ID,
			    collection_id: process.env.DISCOVERY_COLLECTION_ID,
			    query: 'enriched_text.entities.text:Vodafone Plan',
					passages: 'true'
			  }, function(err, response) {
			        if (err) {
			          console.error(err);
			        } else {
			          console.log(JSON.stringify(response, null, 2));
								var disResponse = response.passages[0].passage_text;
								data.output.text = disResponse;
								return res.json(data);
			        }
			   });
			} else if (ideaDiscoveryRequired) {
				discovery.query({
				    environment_id: process.env.DISCOVERY_ENVIRONMENT_ID,
				    collection_id: process.env.DISCOVERY_COLLECTION_ID,
				    query: 'enriched_text.entities.text:Idea plan',
						passages: 'true'
				  }, function(err, response) {
				        if (err) {
				          console.error(err);
				        } else {
				          console.log(JSON.stringify(response, null, 2));
									var disResponse = response.passages[0].passage_text;
									data.output.text = disResponse;
									return res.json(data);
				        }
				   });

			} else if (airtelDiscoveryRequired) {
				discovery.query({
				    environment_id: process.env.DISCOVERY_ENVIRONMENT_ID,
				    collection_id: process.env.DISCOVERY_COLLECTION_ID,
				    query: 'enriched_text.entities.text:Airtel Plan',
						passages: 'true'
				  }, function(err, response) {
				        if (err) {
				          console.error(err);
				        } else {
				          console.log(JSON.stringify(response, null, 2));
									var disResponse = response.passages[0].passage_text;
									data.output.text = disResponse;
									return res.json(data);
				        }
				   });
			}
			else{
			return res.json(data);
		  }

		});
	}

});

// Update the email address
function updateEmail(username, email) {
	db.find({selector:{userName:username}}, function(err, result) {
	  if (err) {
	    throw err;
	  }
	  var user = {
			"_id": result.docs[0]._id,
	    "_rev" : result.docs[0]._rev,
			"userName" : result.docs[0].userName,
			"name" : result.docs[0].name,
	    "emailId": email,
			"mobileNumber" : result.docs[0].mobileNumber,
			"address" : result.docs[0].address
	  };
	  db.insert(user, function(err, body) {
			if (err) {
				throw err;
			}
			usersMap = null;
			loadUserData();
		});
	});
}

// Update the address
function updateAddress(username, address) {
	db.find({selector:{userName:username}}, function(err, result) {
	  if (err) {
	    throw err;
	  }
	  var user = {
			"_id": result.docs[0]._id,
	    "_rev" : result.docs[0]._rev,
			"userName" : result.docs[0].userName,
			"name" : result.docs[0].name,
	    "emailId": result.docs[0].emailId,
			"mobileNumber" : result.docs[0].mobileNumber,
			"address" : address
	  };
	  db.insert(user, function(err, body) {
			if (err) {
				throw err;
			}
			usersMap = null;
			loadUserData();
		});
	});
}

// Endpoint called from the client side to validate the entered username
 app.post("/api/validate", function(req, res) {
	 var userName = req.body.input.userName;
	 var output = {};
	 getPerson(userName, function(err, person) {
		 if (err) {
			 console.log("Error occurred while getting person data ::", err);
			 return res.status(err.code || 500).json(err);
		 }
		 if (person) {
			 output = {
				 "valid": "yes"
			 };
		 } else {
			 output = {
				 "valid": "no"
			 };
		 }
		 return res.json(output);
	});
});

//Get the details from Cloudant db
function getPerson(userName, callback) {
	var person = {};
	if (usersMap !== undefined && usersMap !== null) {
		if (usersMap.has(userName)) {
			var userDetails = usersMap.get(userName);
			person = {
				"userName": userName,
				"name": userDetails[0],
				"mobileNumber": userDetails[1],
				"emailId": userDetails[2],
				"address": userDetails[3]
			};
		} else {
			person = null;
		}
		callback(null, person);
	} else {
		loadUserData();
	}
	return;
}

module.exports = app;