Legacy Dev Forum Posts

const platformClient = require('purecloud-platform-client-v2');
var WebSocketClient = require('websocket').client;
const client = platformClient.ApiClient.instance;
let apiInstance = new platformClient.UsersApi();
let apiInstanceForArchitect = new platformClient.ArchitectApi();


require('dotenv').config();

// Get client credentials from environment variables
const CLIENT_ID = process.env.GENESYS_CLOUD_CLIENT_ID;
const CLIENT_SECRET = process.env.GENESYS_CLOUD_CLIENT_SECRET;
const ORG_REGION = process.env.GENESYS_CLOUD_REGION; // eg. us_east_1


const environment = platformClient.PureCloudRegionHosts[ORG_REGION];
if (environment) client.setEnvironment(environment);


const websocketClient = new WebSocketClient();

// API instances
const notificationsApi = new platformClient.NotificationsApi();

// Additional configuration variables
const queueId = 'ab9700bf-c33d-459b-8e36-ef2c31ea26f8';
const subscriptionTopic = `v2.routing.queues.${queueId}.conversations`;

// Define the callbacks for the websocket listener
websocketClient.on('connect', connection => {
	var conversationIdForCheck;
	var agentTrue = false;
	console.log('WebSocket client connected and listening...');
	connection.on('message', message => {
		let data = JSON.parse(message.utf8Data);
		let topic = data.topicName;
		let eventBody = data.eventBody;

		if (topic == subscriptionTopic) {
			let conversation = eventBody;
			let customer = conversation.participants
				.filter(p => p.purpose == 'customer')[0];
			let agent = conversation.participants
				.filter(p => p.purpose == 'agent')[0];

			if (agent && agent.connectedTime) {
				console.log("agentTrue", agentTrue);
				if (agent && (agentTrue == false) && !agent.endTime) {
					agentTrue = true;
					conversationIdForCheck = conversation.id;
					console.log(`Agent ${agent.userId} has accepted conversation with ${customer.id}`);
               //getting agent's email using userId. Because I stored Oauth 2 access token in my data table for the specific user. Oauth 2 access token only can be used to send DTMF digits.
					getUser(agent.userId).then(data => {
						getAccessToken(data).then(result => {
							console.log("getAccessToken result", result);
							sendDTMF(agent.id, conversation.id, result);
						})
					})
				}
				else if (conversationIdForCheck == conversation.id) {
					console.log("-------------Same conversation------------");
				}
				else if (conversationIdForCheck != conversation.id) {
					console.log("-------------New conversation------------");
					agentTrue = false;
				}
				else {
					console.log("-------------Last------------");
				}
			}
			else {
				console.log("---------Second time-------------");
			}
		}
		// For heartbeats
		if (topic == 'channel.metadata') {
			console.log(eventBody.message);
		}
	});
});

async function getUser(agentUserId) {

	var userEmail;
	let userId = agentUserId; // String | User ID
	let opts = {
		"state": "active" // String | Search for a user with this state
	};

	await apiInstance.getUser(userId, opts)
		.then((data) => {
			//console.log(`getUser success! data: ${JSON.stringify(data, null, 2)}`);
			userEmail = data.email;
			console.log("email", userEmail);

		})
		.catch((err) => {
			console.log("There was a failure calling getUser");
			console.error(err);
		});

	return userEmail;
}

async function getAccessToken(userMail) {

	var user_access_token;
	console.log("-----------------------Inside token--------------------")
	let datatableId = "5d9ea952-f03b-4de0-8c72-b17adaf9fa22"; // String | id of datatable
	let rowId = userMail; // String | The key for the row
	let opts = {
		"showbrief": false // Boolean | if true returns just the key field for the row
	};
	await apiInstanceForArchitect.getFlowsDatatableRow(datatableId, rowId, opts)
		.then((data) => {
			//console.log(`getFlowsDatatableRow success! data: ${JSON.stringify(data, null, 2)}`);
			user_access_token = data.access_token;
		})
		.catch((err) => {
			console.log("There was a failure calling getFlowsDatatableRow");
			console.error(err);
		});
	// Returns a specific row for the datatable


	return user_access_token;
}

async function sendDTMF(participantId, conversationId, oauthToken) {
	const platformClientDtmf = require('purecloud-platform-client-v2');
	const clientDtmf = platformClientDtmf.ApiClient.instance;

	clientDtmf.setEnvironment(platformClientDtmf.PureCloudRegionHosts.us_west_2);

	console.log("OauthToken", oauthToken);
	clientDtmf.setAccessToken(oauthToken);
	let apiInstanceConversation = new platformClientDtmf.ConversationsApi();

	let opts = {

		"body": {
			"digits": "22"
		}

	};
	await apiInstanceConversation.postConversationParticipantDigits(conversationId, participantId, opts)
		.then(() => {
			console.log("postConversationParticipantDigits returned successfully.");
		})
		.catch((err) => {
			console.log("There was a failure calling postConversationParticipantDigits");
			console.error(err);
		});

	// Sends DTMF to the participant

}


websocketClient.on('connectFailed', function (error) {
	console.log('Connect Error: ' + error.toString());
});

// Set environment

// Log in with Client Credentials
client.loginClientCredentialsGrant(CLIENT_ID, CLIENT_SECRET)
	.then((result) => {
		console.log("result", result);
		client.setAccessToken(result.accessToken);
		console.log('Authentication successful');


		return notificationsApi.postNotificationsChannels()
	})
	.then(data => {
		console.log('Channel created');


		let websocketUri = data.connectUri;
		let channelId = data.id;
		websocketClient.connect(websocketUri);

		// Add the subscription for queue events
		let topic = [{ id: subscriptionTopic }];
		return notificationsApi.postNotificationsChannelSubscriptions(channelId, topic);
	})
	.then(data => {
		console.log('Subscribed to Queue');

	})
	.catch(e => console.error(e));


// NOTE: This next line is a simple way to make sure the app runs 'forever'
// In production you'd want the actual code running as a process/service
setInterval(() => { }, 1 << 30);