LotteryAutoScript/lib/check.js

const { log, delay, infiniteNumber, judge } = require('./utils')
const { sendNotify } = require('./helper/notify')
const config = require('./data/config')
const global_var = require('./data/global_var')
const bili = require('./net/bili')

/**
 * 是否中奖
 * @param {number} num
 * @param {string} [note]
 */
async function isMe(num, note = "无") {
    let desp = '';
    const
        { notice_key_words, update_session_wait, get_session_wait, check_session_pages } = config,
        { at: unread_at_num, reply: unread_reply_num } = await bili.getUnreadNum(),
        unread_session_num = await bili.getUnreadSessionNum(),
        { follow_unread, unfollow_unread } = unread_session_num || { unfollow_unread: 0, follow_unread: 0 };
    if (unread_at_num) {
        log.info('中奖检测', '<-- 正在检查at');
        const MyAtInfo = await bili.getMyAtInfo();
        MyAtInfo
            .slice(0, unread_at_num)
            .forEach(({ at_time, up_uname, business, source_content, url }) => {
                desp += '## [at]检测结果\n\n'
                desp += '----------------------------------------------------------------\n\n'
                desp += `发生时间: ${new Date(at_time * 1000).toLocaleString()}\n\n`
                desp += `用户: ${up_uname}\n\n`
                desp += `在${business}中@了你(https://space.bilibili.com/${global_var.get("myUID")})\n\n`
                desp += `原内容为: ${source_content}\n\n`
                desp += `[直达链接](${url})\n\n`
                desp += '----------------------------------------------------------------\n\n'
            });
        log.info('中奖检测', '--> OK');
    }
    if (unread_reply_num) {
        log.info('中奖检测', '<-- 正在检查回复');
        const replys = await bili.getReplyMsg();
        replys
            .slice(0, unread_reply_num)
            .forEach(({ nickname, uri, source, timestamp }) => {
                if (judge(source, notice_key_words)) {
                    desp += '## 回复检测结果\n\n'
                    desp += '----------------------------------------------------------------\n\n'
                    desp += `发生时间: ${new Date(timestamp * 1000).toLocaleString()}\n\n`
                    desp += `用户: ${nickname}\n\n`
                    desp += `回复你(https://space.bilibili.com/${global_var.get("myUID")})说:\n${source}\n\n`
                    desp += `[直达链接](${uri})\n\n`
                    desp += '----------------------------------------------------------------\n\n'
                }
            })
        log.info('中奖检测', '--> OK');
    }
    if (follow_unread + unfollow_unread > 0) {
        const check = async (type) => {
            let session_t = '';
            let MySession = await bili.getSessionInfo(type)
            log.info("准备检查私信", check_session_pages + "页")
            for (const index of infiniteNumber()) {
                for (const Session of MySession.data) {
                    const { sender_uid, session_ts, timestamp, unread_count, talker_id, msg_seqno } = Session;
                    session_t = session_ts;
                    if (unread_count) {
                        const content = await bili.fetch_session_msgs(talker_id, unread_count);
                        if (judge(content, notice_key_words)) {
                            desp += '## 私信检测结果\n\n'
                            desp += '----------------------------------------------------------------\n\n'
                            desp += `发生时间: ${new Date(timestamp * 1000).toLocaleString()}\n\n`
                            desp += `用户: ${sender_uid}\n\n`
                            desp += `私信你(https://space.bilibili.com/${global_var.get("myUID")})说:\n${content}\n\n`
                            desp += `[直达链接](https://message.bilibili.com/#/whisper/mid${sender_uid})\n\n`
                            desp += '----------------------------------------------------------------\n\n'
                        }
                        await bili.updateSessionStatus(talker_id, type, msg_seqno);
                        await delay(update_session_wait);
                    }
                }
                if (MySession.has_more && index < check_session_pages) {
                    await delay(get_session_wait);
                    MySession = await bili.getSessionInfo(type, session_t)
                } else {
                    break
                }
            }
        }
        if (follow_unread) {
            log.info('中奖检测', '<-- 正在检查已关注者的私信')
            await check(1)
        }
        if (unfollow_unread) {
            log.info('中奖检测', '<-- 正在检查未关注者的私信')
            await check(2)
        }
        log.info('中奖检测', '--> OK');
    }
    if (desp) {
        desp += `帐号备注: ${note}\n\n`;
        desp += '中奖了别忘给脚本(https://github.com/shanmiteko/LotteryAutoScript)点一个Star哦, 赞助一两块也不是不可以_(:з」∠)_\n\n'
        log.info('可能中奖了', desp);
        await sendNotify(`帐号${num}可能中奖了`, desp);
    } else {
        log.info('中奖检测', "暂未中奖");
    }
    return;
}


module.exports = { isMe };