telegram_glpi/lib/utils.js

const he = require('he');
const html = require('html-to-text');
const fs = require('fs');
const cns = require('./const.js');

const dir = __dirname;
const conf = JSON.parse(fs.readFileSync(dir + "/../data/conf.json"));
const glpiUrl = conf.glpiConfig.apiurl.replace("apirest.php", "");

exports.htmlToText = async (text) => {
    try{
        let temp = html.convert(he.decode(text), {preserveNewlines: true});
        textArray = temp.split('\n');
        for(let i in textArray){
            if(textArray[i].indexOf("[/front/document.send.php?docid=") >= 0){
                delete textArray[i-1];
                delete textArray[i];
            }
        }
        // text.replace(/(\.\s)+/g, '. ');
        let messageText = '';
        for(let k in textArray){
            if(textArray[k][0] != '>' && textArray[k].trim() && textArray[k].indexOf('ts@krtech.ru писал') == -1 && textArray[k].indexOf('cellpadding="0"') == -1){
                messageText += textArray[k].trim().replace(/[<>]/g, '') + ' ';
            }
        }
        return messageText.replace(/\[.*?\]/g, '');
    }catch(e){
        fs.appendFileSync(dir + "/../logs/logs.txt", e.stack + "\n\n");
    }
}

exports.parseMessageText = async (ticket, ticketAuthor, color) => {
    try{
        let messageText = `${color} <b>ЗАЯВКА  <a href="${glpiUrl}front/ticket.form.php?id=${ticket.id}">№${ticket.id}</a></b>\n\n`;
        if(ticket.users_id_recipient == conf.glpiConfig.user_id){
            let text = html.convert(he.decode(ticket.content), {preserveNewlines: true});
            let halfText = text.split("\nОписание: ");
            let headers = halfText[0].split("\n");
            for(let i = 0; i < headers.length; i++){
                messageText += `<b>${headers[i].split(": ")[0]}: </b>${headers[i].split(": ")[1]}\n`;
            }
            messageText += `<b>Описание: </b>${halfText[1]}`;
        }else{
            let text = await this.htmlToText(ticket.content);
            messageText += `<b>Автор заявки: </b>${ticketAuthor}\n`;
            messageText += `<b>Проблема: </b>${ticket.name}\n<b>Описание: </b>`;
            messageText += text;
            if(messageText.length > 600){
                messageText = `${messageText.substring(0, 500)} + '\n\n<b><a href="${glpiUrl}front/ticket.form.php?id=${ticket.id}">Читать дальше</a></b>`;
            }
        }  
        return messageText;
    }catch(e){
        fs.appendFileSync(dir + "/../logs/logs.txt", e.stack + "\n\n");
    }    
}

exports.createThread = async (bot, messageData, ticketId, title) => {
    try{
        let td = messageData.data[ticketId];
        let thread = await bot.telegram.createForumTopic(conf.supportChatId, title, {
            icon_custom_emoji_id: '5357315181649076022'
        });
        let status = td.status;
        messageData.data[ticketId].threadId = thread.message_thread_id;
        let inKeyboard = await this.getKeyboardFromStatus(status);
        await this.editMessageMarkup(bot, td.messageId, inKeyboard);
        let msg = await bot.telegram.copyMessage(conf.supportChatId, conf.supportChatId, td.messageId, {
            parse_mode: 'HTML',
            disable_notification: true,
            message_thread_id: thread.message_thread_id,
            reply_markup: { inline_keyboard: inKeyboard }
        });
        await bot.telegram.pinChatMessage(conf.supportChatId, msg.message_id, { disable_notification: true });
        messageData.data[ticketId].pinMessageId = msg.message_id;
        fs.writeFileSync(dir + "/../data/messageData.json", JSON.stringify(messageData, null, 3));
    }catch(e){
        fs.appendFileSync(dir + "/../logs/logs.txt", e.stack + "\n\n");
    }
}

exports.closeThread = async (bot, messageData, ticketId) => {
	await bot.telegram.deleteForumTopic(conf.supportChatId, messageData.data[ticketId].threadId);
    delete messageData.data[ticketId].threadId;
    delete messageData.data[ticketId].pinMessageId;
	let jsonData = JSON.stringify(messageData, null, 3);
	fs.writeFileSync(dir + "/../data/messageData.json", jsonData);
}

exports.getTicketColor = async (status) => {
    switch(status){
        case 1: color = '🟢'; break;
        case 2: color = '🔵'; break;
        case 3: color = '🔵'; break;
        case 4: color = '🟠'; break;
        case 6: color = '⚫'; break;
        default: color = '⚫';
    }  
    return color;
}

exports.getKeyboardFromStatus = async (status) => {
    let keyboard = cns.inlineKeyboards.open;
    if(status == 5 || status == 6){
        keyboard = cns.inlineKeyboards.close;
    }
    return keyboard;
}

exports.editMessageText = async (bot, messageId, messageText, keyboard) => {
    try{
        await bot.telegram.editMessageText(conf.supportChatId, messageId, undefined, messageText, {
            parse_mode: 'HTML',
            reply_markup: {inline_keyboard: keyboard}
        });
	}catch(e){
		//fs.appendFileSync(dir + "/../logs/logs.txt", e.stack + "\n\n");
	}
}

exports.editMessageMarkup = async (bot, messageId, keyboard) => {
    try{
        await bot.telegram.editMessageReplyMarkup(conf.supportChatId, messageId, undefined, {inline_keyboard: keyboard});
	}catch(e){
		//fs.appendFileSync(dir + "/../logs/logs.txt", e.stack + "\n\n");
	}
}

exports.sleep = async (ms) => {
	return new Promise((resolve) => {
	  setTimeout(resolve, ms);
	});
}