Function tgBotNotify

tools/sendNotify.js:461–520

(text, desp)

}

function tgBotNotify(text, desp) {
    return new Promise((resolve) => {
        const {
            TG_BOT_TOKEN,
            TG_USER_ID,
            TG_PROXY_HOST,
            TG_PROXY_PORT,
            TG_API_HOST,
            TG_PROXY_AUTH,
        } = push_config;
        if (TG_BOT_TOKEN && TG_USER_ID) {
            let options = {
                url: `${TG_API_HOST}/bot${TG_BOT_TOKEN}/sendMessage`,
                json: {
                    chat_id: `${TG_USER_ID}`,
                    text: `${text}\n\n${desp}`,
                    disable_web_page_preview: true,
                },
                headers: {
                    'Content-Type': 'application/json',
                },
                timeout,
            };
            if (TG_PROXY_HOST && TG_PROXY_PORT) {
                let proxyHost = TG_PROXY_HOST;
                if (TG_PROXY_AUTH && !TG_PROXY_HOST.includes('@')) {
                    proxyHost = `${TG_PROXY_AUTH}@${TG_PROXY_HOST}`;
                }
                let agent;
                agent = new ProxyAgent({
                    uri: `http://${proxyHost}:${TG_PROXY_PORT}`,
                });
                options.dispatcher = agent;
            }
            $.post(options, (err, resp, data) => {
                try {
                    if (err) {
                        console.log('Telegram 发送通知消息失败😞\n', err);
                    } else {
                        if (data.ok) {
                            console.log('Telegram 发送通知消息成功🎉。\n');
                        } else if (data.error_code === 400) {
                            console.log(
                                '请主动给bot发送一条消息并检查接收用户ID是否正确。\n',
                            );
                        } else if (data.error_code === 401) {
                            console.log('Telegram bot token 填写错误。\n');
                        }
                    }
                } catch (e) {
                    $.logErr(e, resp);
                } finally {
                    resolve(data);
                }
            });
        } else {
            resolve();
        }