index.js

const assistenteAPI = require('./app/chatbot_api');
// const opt = require('./util/options');
const { createIssue } = require('./app/utils/send_issue');
const flow = require('./app/utils/flow');
const help = require('./app/utils/helper');
const dialogs = require('./app/utils/dialogs');
const attach = require('./app/utils/attach');
const DF = require('./app/utils/dialogFlow');
const quiz = require('./app/utils/quiz');
const timer = require('./app/utils/timer');
const { checkUserOnLabelName } = require('./app/utils/labels');
const { reloadTicket } = require('./app/utils/checkQR'); // eslint-disable-line

const incidenteCPFAux = {}; // because the file timer stops setState from working

module.exports = async function App(context) {
	try {
		await context.setState({
			politicianData: await assistenteAPI.getPoliticianData(context.event.rawEvent.recipient.id),
			sessionUser: { ...await context.getUserProfile() },
		});
		// await reloadTicket(context); await help.resumoTicket(context.state.ticketTypes.ticket_types);
		// we update context data at every interaction that's not a comment or a post
		await assistenteAPI.postRecipient(context.state.politicianData.user_id, {
			fb_id: context.session.user.id,
			name: context.state.sessionUser.name,
			origin_dialog: 'greetings',
			picture: context.state.sessionUser.profilePic,
			// session: JSON.stringify(context.state),
		});

		await timer.deleteTimers(context.session.user.id);

		if (context.event.isPostback) {
			if (context.state.onSolicitacoes) await DF.textRequestDF('sair', context.session.user.id);
			await context.setState({ lastPBpayload: context.event.postback.payload, onSolicitacoes: false, solicitacaoCounter: 0 });
			if (context.state.lastPBpayload === 'greetings' || !context.state.dialog || context.state.dialog === '') {
				await context.setState({ dialog: 'greetings' });
				// await context.setState({ dialog: 'gerarTicket1' });
			} else if (context.state.lastPBpayload.slice(0, 9) === 'cancelarT') {
				await context.setState({ dialog: 'cancelConfirmation', ticketID: context.state.lastPBpayload.replace('cancelarT', '') });
			} else if (context.state.lastPBpayload.slice(0, 9) === 'leaveTMsg') {
				await context.setState({ dialog: 'leaveTMsg', ticketID: context.state.lastPBpayload.replace('leaveTMsg', '') });
				await context.sendText(flow.leaveTMsg.text1, await attach.getQR(flow.leaveTMsg));
			} else if (context.state.lastPBpayload.slice(0, 7) === 'verTMsg') {
				await context.setState({ dialog: 'verTMsg', ticketID: context.state.lastPBpayload.replace('verTMsg', '') });
			} else {
				await context.setState({ dialog: context.state.lastPBpayload });
			}
			await assistenteAPI.logFlowChange(context.session.user.id, context.state.politicianData.user_id,
				context.event.postback.payload, context.event.postback.title);
		} else if (context.event.isQuickReply) {
			// if (context.state.onSolicitacoes) await DF.textRequestDF('sair', context.session.user.id);
			await context.setState({ lastQRpayload: context.event.quickReply.payload, onSolicitacoes: false, solicitacaoCounter: 0 });
			if (context.state.lastQRpayload.slice(0, 4) === 'quiz') {
			// await quiz.handleAnswerA(context, context.state.lastQRpayload.replace('quiz', '').replace(context.state.currentQuestion.code), '');
				await quiz.handleAnswer(context, context.state.lastQRpayload.charAt(4));
			} else if (context.state.lastQRpayload.slice(0, 13) === 'extraQuestion') {
				await quiz.answerExtraQuestion(context);
			} else if (context.state.lastQRpayload.slice(0, 7) === 'InfoRes') {
				await context.setState({ dialog: 'infoRes', infoChoice: context.state.lastQRpayload.replace('InfoRes', '') });
			} else if (context.state.lastQRpayload.slice(0, 9) === 'leaveTMsg') {
				await context.setState({ dialog: 'leaveTMsg', ticketID: context.state.lastQRpayload.replace('leaveTMsg', '') });
				await context.sendText(flow.leaveTMsg.text1, await attach.getQR(flow.leaveTMsg));
			} else if (['solicitacao2', 'solicitacao3', 'solicitacao4', 'solicitacao5', 'solicitacao6', 'solicitacao8', 'solicitacao9', 'solicitacao10'].includes(context.state.lastQRpayload)) {
				await context.setState({ ticketID: context.state.lastQRpayload.replace('solicitacao', '') });
				await context.setState({ dialog: 'solicitacao', ticketID: await parseInt(context.state.ticketID, 10) });
			} else {
				await context.setState({ dialog: context.state.lastQRpayload });
			}

			await assistenteAPI.logFlowChange(context.session.user.id, context.state.politicianData.user_id, context.state.lastQRpayload, context.state.lastQRpayload);
		} else if (context.event.isText) {
			await context.setState({ whatWasTyped: context.event.message.text });

			if (context.state.whatWasTyped === process.env.TESTEKEYWORD) {
				await context.setState({ dialog: 'testeAtendimento' });
			} else if (['solicitacao', 'askCPF', 'invalidCPF'].includes(context.state.dialog)) {
				await dialogs.checkCPF(context, 'titularCPF', 'askTitular', 'invalidCPF');
			} else if (['askMail', 'invalidMail'].includes(context.state.dialog)) {
				await dialogs.checkEmail(context, 'titularMail', 'gerarTicket', 'invalidMail');
				// -- 1
			} else if (['askRevogarCPF', 'invalidCPF'].includes(context.state.dialog)) {
				await dialogs.checkCPF(context, 'titularCPF', 'askRevogarTitular', 'invalidCPF');
			// } else if (['askRevogarName', 'invalidName'].includes(context.state.dialog)) {
			// 	await dialogs.checkFullName(context, 'titularNome', 'askRevogarMail', 'invalidName');
			// } else if (['askRevogarPhone', 'invalidPhone'].includes(context.state.dialog)) {
			// 	await dialogs.checkPhone(context, 'titularPhone', 'askRevogarMail', 'invalidPhone');
			} else if (['askRevogarMail', 'invalidMail'].includes(context.state.dialog)) {
				await dialogs.checkEmail(context, 'titularMail', 'gerarTicket1', 'invalidMail');
				// -- 7
			} else if (['incidenteAskPDF', 'incidenteCPF', 'incidenteFilesTimer'].includes(context.state.dialog)) {
				incidenteCPFAux[context.session.user.id] = await dialogs.checkCPF(context, 'titularCPF', 'incidenteTitular', 'incidenteCPF');
			} else if (['incidenteEmail', 'incidenteEmailReAsk'].includes(context.state.dialog)) {
				await dialogs.checkEmail(context, 'titularMail', 'gerarTicket7', 'incidenteEmailReAsk');
			} else if (context.state.onTextQuiz === true) {
				await context.setState({ whatWasTyped: parseInt(context.state.whatWasTyped, 10) });
				if (Number.isInteger(context.state.whatWasTyped, 10) === true) {
					await quiz.handleAnswer(context, context.state.whatWasTyped);
				} else {
					await context.sendText('Formato inválido, digite só um número, exemplo 10');
					await context.setState({ dialog: 'startQuiz' });
				}
			} else if (context.state.whatWasTyped.toLowerCase() === process.env.GET_PERFILDATA && await checkUserOnLabelName(context.session.user.id, 'admin', context.state.politicianData.fb_access_token)) {
				await dialogs.handleReset(context);
			} else if (context.state.dialog === 'leaveTMsg') {
				await context.setState({ dialog: 'newTicketMsg', ticketMsg: context.state.whatWasTyped });
			} else if (context.state.whatWasTyped === process.env.NOTIFICATION_KEY) {
				await context.setState({ wantNotification: true, notificacao: null, dialog: 'mainMenu' });
				await context.sendText('Você receberá as notificações');
			} else {
				await DF.dialogFlow(context);
			}
		} else if (context.event.isFile || context.event.isVideo || context.event.isImage) {
			if (['incidenteAskFile', 'incidenteI', 'incidenteA', 'incidenteFilesTimer'].includes(context.state.dialog)) {
				await dialogs.handleFiles(context, 'incidenteFilesTimer');
			} else if (['avançadoAskFile', 'avançadoM', 'avançadoA', 'avançadoFilesTimer'].includes(context.state.dialog)) {
				await dialogs.handleFiles(context, 'avançadoFilesTimer');
			}
		}

		switch (context.state.dialog) {
		case 'greetings':
			await context.sendImage(context.state.politicianData.chatbot_picture || flow.avatarImage)
			await context.sendText(flow.greetings.text1.replace('<USERNAME>', context.state.sessionUser.firstName));
			await attach.sendMsgFromAssistente(context, 'greetings', [flow.greetings.text2]);
			await dialogs.sendMainMenu(context, flow.mainMenu.firstTime);
			break;
		case 'mainMenu':
			await dialogs.sendMainMenu(context);
			break;
		case 'faleConosco':
			await attach.sendMsgFromAssistente(context, 'fale-conosco', []);
			await dialogs.sendMainMenu(context);
			break;
		case 'solicitacoes':
			await context.setState({ whatWasTyped: 'Quero fazer uma solicitação' });
			await DF.dialogFlow(context);
			// await context.sendText(flow.solicitacoes.text1);
			// await dialogs.solicitacoesMenu(context);
			break;
		case 'confirmaSolicitacao':
			await dialogs.confirmaSolicitacao(context);
			break;
		case 'consumidor':
			await dialogs.consumidorMenu(context);
			break;
		case 'titularNao':
			await context.sendText(flow.CPFConfirm.revogacaoNao);
			await dialogs.sendMainMenu(context);
			break;
		case 'solicitacao1': // revogar
			await attach.sendMsgFromAssistente(context, 'ticket_type_1', [flow.revogar.text1, flow.revogar.text2]);
			await context.sendText(flow.revogar.text3, await attach.getQR(flow.revogar));
			break;
		case 'revogacaoNao':
			await context.sendText(flow.revogar.revogacaoNao);
			await dialogs.sendMainMenu(context);
			break;
		case 'askRevogarCPF':
			await context.sendText(flow.revogar.askRevogarCPF + flow.askCPF.clickTheButton, await attach.getQR(flow.askCPF));
			break;
		case 'askRevogarTitular':
			await context.sendText(flow.CPFConfirm.ask.replace('<CPF>', context.state.titularCPF), await attach.getQRCPF(flow.CPFConfirm, flow.revogar.CPFNext));
			break;
		// case 'askRevogarName':
		// 	await context.sendText(flow.revogar.askRevogarName, await attach.getQR(flow.askCPF));
		// 	break;
		// case 'askRevogarPhone':
		// 	await context.sendText(flow.revogar.askRevogarPhone, await attach.getQR(flow.askCPF));
		// 	break;
		case 'askRevogarMail':
			await context.sendText(flow.revogar.askRevogarMail, await attach.getQR(flow.askCPF));
			break;
		case 'gerarTicket1': {
			await context.setState({ ticketID: '1' });
			const { id } = context.state.ticketTypes.ticket_types.find((x) => x.ticket_type_id.toString() === context.state.ticketID);
			await dialogs.createTicket(context,
				await assistenteAPI.postNewTicket(context.state.politicianData.organization_chatbot_id, context.session.user.id, id, await help.buildTicket(context.state)));
		} break;
		case 'solicitacao':
			await attach.sendMsgFromAssistente(context, `ticket_type_${context.state.ticketID}`, []);
			await context.sendText(`${flow.solicitacao.askCPF.base}${flow.solicitacao.askCPF[context.state.ticketID]} ${flow.solicitacao.clickTheButton}`, await attach.getQR(flow.solicitacao));
			await context.setState({ dialog: 'askCPF' });
			break;
		case 'askTitular':
			await context.sendText(flow.askTitular.ask.replace('<CPF>', context.state.titularCPF), await attach.getQR(flow.askTitular));
			break;
		case 'askMail':
			await context.sendText(flow.askMail.ask, await attach.getQR(flow.askMail));
			break;
		case 'gerarTicket':
			try {
				const { id } = context.state.ticketTypes.ticket_types.find((x) => x.ticket_type_id.toString() === context.state.ticketID.toString());
				await dialogs.createTicket(context,
					await assistenteAPI.postNewTicket(context.state.politicianData.organization_chatbot_id, context.session.user.id, id, await help.buildTicket(context.state)));
			} catch (error) {
				console.log('--\ncontext.state.ticketTypes.ticket_types', context.state.ticketTypes.ticket_types);
				console.log('context.state.ticketID', context.state.ticketID);
				await help.errorDetail(context, error);
			}
			break;
		case 'solicitacao7': // 'incidente'
			await context.setState({ incidenteAnonimo: false, titularFiles: [], fileTimerType: 7 });
			await attach.sendMsgFromAssistente(context, 'ticket_type_7', []);
			await context.sendText(flow.incidente.intro, await attach.getQR(flow.incidente));
			break;
		case 'incidenteA':
			await context.setState({ incidenteAnonimo: true });
			// falls throught
		case 'incidenteI':
		case 'incidenteAskFile':
			await context.setState({ titularFiles: [] }); // clean any past files
			await context.sendText(flow.incidente.askFile);
			break;
		case 'incidenteTitular':
			await context.sendText(flow.CPFConfirm.ask.replace('<CPF>', incidenteCPFAux[context.session.user.id]), await attach.getQRCPF(flow.CPFConfirm, flow.incidente.CPFNext));
			await context.setState({ titularCPF: incidenteCPFAux[context.session.user.id] }); // passing memory data to state
			delete incidenteCPFAux[context.session.user.id];
			break;
		case 'incidenteEmail':
			await context.sendText(flow.incidente.askMail, await attach.getQR(flow.askCPF));
			break;
		case 'gerarTicket7': {
			await context.setState({ ticketID: '7' });
			const { id } = context.state.ticketTypes.ticket_types.find((x) => x.ticket_type_id.toString() === context.state.ticketID);
			await dialogs.createTicket(context,
				await assistenteAPI.postNewTicket(context.state.politicianData.organization_chatbot_id, context.session.user.id, id, await help.buildTicket(context.state), '', 0, context.state.titularFiles));
		} break;
		case 'atendimentoAvançado':
			await dialogs.atendimentoAvançado(context);
			break;
		case 'sobreLGPD':
			await attach.sendMsgFromAssistente(context, 'sobre_lgpd', [flow.sobreLGPD.text1]);
			await context.typingOn();
			await context.sendVideo(flow.sobreLGPD.videoLink);
			await context.typingOff();
			await dialogs.sendMainMenu(context);
			break;
		case 'sobreDipiou':
			await attach.sendMsgFromAssistente(context, 'sobre_dipiou', [flow.sobreDipiou.text1]);
			await dialogs.sendMainMenu(context);
			break;
		case 'meuTicket':
			await dialogs.meuTicket(context);
			break;
		case 'cancelConfirmation':
			await context.setState({ currentTicket: await context.state.userTickets.tickets.find((x) => x.id.toString() === context.state.ticketID) });
			await context.sendText(flow.cancelConfirmation.confirm.replace('<TYPE>', context.state.currentTicket.type.name), await attach.getQR(flow.cancelConfirmation));
			break;
		case 'confirmaCancelamento':
			await dialogs.cancelTicket(context);
			break;
		case 'verTicketMsg':
			await dialogs.seeTicketMessages(context);
			break;
		case 'newTicketMsg':
			await dialogs.newTicketMessage(context);
			break;
		case 'createIssueDirect':
			await createIssue(context);
			break;
		case 'beginQuiz':
			await context.setState({ startedQuiz: true, typeQuiz: 'preparatory' });
			await context.sendText(flow.quiz.beginQuiz);
			// falls throught
		case 'startQuiz':
			await quiz.answerQuiz(context);
			break;
		case 'informacoes': {
			const buttons = await DF.buildInformacoesMenu(context);
			if (buttons) {
				await context.sendText(flow.informacoes.text1, buttons);
			} else {
				await context.sendText(flow.informacoes.text2, buttons);
				await timer.createInformacoesTimer(context.session.user.id, context);
			} }
			break;
		case 'infoRes': {
			const answer = context.state.infoRes[context.state.infoChoice];
			if (answer) {
				await help.sendTextAnswer(context, answer);
				await help.sendAttachment(context, answer);
			}
			await dialogs.sendMainMenu(context); }
			break;
		case 'testeAtendimento':
			await context.sendText(flow.solicitacoes.text1, await attach.getQR(flow.solicitacoes));
			break;
		case 'notificationOn':
			await assistenteAPI.updateBlacklistMA(context.session.user.id, 1);
			await assistenteAPI.logNotification(context.session.user.id, context.state.politicianData.user_id, 3);
			await context.sendText(flow.notifications.on);
			await dialogs.sendMainMenu(context);
			break;
		case 'notificationOff':
			await assistenteAPI.updateBlacklistMA(context.session.user.id, 0);
			await assistenteAPI.logNotification(context.session.user.id, context.state.politicianData.user_id, 4);
			await context.sendText(flow.notifications.off);
			await dialogs.sendMainMenu(context);
			break;
		case 'incidenteFilesTimer':
		case 'avançadoFilesTimer':
		case 'createFilesTimer':
			await timer.createFilesTimer(context.session.user.id, context); // time to wait for the uploaded files to enter as new events on facebook
			break;
		case 'end':
			// do something
			break;
		} // end switch case
	} catch (error) {
		await help.errorDetail(context, error);
	} // catch
};