const Base = require('./Base');
const BiliAPI = require('./BiliAPI');
const eventBus = require('./eventBus');
const Public = require('./Public');
const GlobalVar = require("./GlobalVar.json");
const config = require("./config");
const MyStorage = require('./MyStorage');

/**
 * 监视器
 */
class Monitor extends Public {
    /**
     * @constructor
     * @param {number | string} param
     */
    constructor(param) {
        super();
        typeof param === 'number' ? this.UID = param : this.tag_name = param;
        this.tagid = 0; /* tagid初始化为默认分组 */
        this.attentionList = ''; /* 转为字符串的所有关注的up主uid */
        this.isAttentionErr = false;
    }
    /**
     * 初始化
     */
    async init() {
        if (config.model === '00') { Base.tooltip.log('已关闭所有转发行为'); return; }
        if (GlobalVar.Lottery.length === 0) { Base.tooltip.log('抽奖信息为空'); return; }
        this.tagid = await BiliAPI.checkMyPartition(); /* 检查关注分区 */
        this.attentionList = await BiliAPI.getAttentionList(GlobalVar.myUID); /* 获取关注列表 */
        await this.startLottery();
    }
    /**
     * 启动
     * @returns {Promise<boolean>}
     */
    async startLottery() {
        const allLottery = await this.filterLotteryInfo();
        let status = 0;
        if (allLottery.length) {
            let dyids = [];
            for (const Lottery of allLottery) {
                status = await this.go(Lottery);
                if (!status) break
                dyids.push(Lottery.dyid);
            }
            if (dyids.length) MyStorage.updateDyid(dyids.toString())
            Base.tooltip.log('开始转发下一组动态');
        } else {
            status = 1;
            Base.tooltip.log('无未转发抽奖');
        }
        status ?
            eventBus.emit('Turn_on_the_Monitor') : eventBus.emit('Turn_off_the_Monitor');
    }
    /**
     * 抽奖配置
     * @typedef {object} LotteryOptions
     * @property {number[]} uid 用户标识
     * @property {string} dyid 动态标识
     * @property {number} type 动态类型
     * @property {string} relay_chat 动态类型
     * @property {string} ctrl 定位@
     * @property {string} rid 评论类型
     */
    /**
     * @returns {Promise<LotteryOptions[] | []>}
     */
    async filterLotteryInfo() {
        const self = this,
            protoLotteryInfo = typeof self.UID === 'number' ? await self.getLotteryInfoByUID(self.UID) : await self.getLotteryInfoByTag(self.tag_name);
        if (protoLotteryInfo === null) return [];
        let alllotteryinfo = [];
        const { model, chatmodel, maxday: _maxday, minfollower, only_followed, blockword, blacklist } = config;
        const maxday = _maxday === '-1' || _maxday === '' ? Infinity : (Number(_maxday) * 86400);
        for (const info of protoLotteryInfo) {
            const { lottery_info_type, uids, uname, dyid, official_verify, ctrl, befilter, rid, des, type, hasOfficialLottery } = info;
            /**判断是转发源动态还是现动态 */
            const uid = lottery_info_type === 'tag' ? uids[0] : uids[1];
            const now_ts_10 = Date.now() / 1000;
            let onelotteryinfo = {};
            let isLottery = false;
            let isSendChat = false;
            let isBlock = false;
            let ts = 0;
            const description = typeof des === 'string' ? des : '';
            for (let index = 0; index < blockword.length; index++) {
                const word = blockword[index];
                const reg = new RegExp(word);
                isBlock = reg.test(description) ? true : false;
                if (isBlock) break;
            }
            if (isBlock) continue;
            const hasAt = /(?:@|艾特)[^@|(艾特)]*?好友/.test(description);
            const haslottery = /[抽奖]/.test(description);
            const hasGuanZhuan = /[转关].*[转关]/.test(description);
            if (hasOfficialLottery && model[0] === '1') {
                const oneLNotice = await BiliAPI.getLotteryNotice(dyid);
                ts = oneLNotice.ts;
                isLottery = ts > now_ts_10 && ts < now_ts_10 + maxday;
                isSendChat = chatmodel[0] === '1';
            } else if (!hasOfficialLottery && model[1] === '1') {
                if (!haslottery) continue;
                ts = Base.getLotteryNotice(description).ts;
                if (!official_verify) {
                    const followerNum = await BiliAPI.getUserInfo(uid);
                    if (followerNum < Number(minfollower)) continue;
                    isLottery = hasGuanZhuan && !befilter && (ts === 0 || (ts > now_ts_10 && ts < now_ts_10 + maxday));
                } else {
                    isLottery = ts === 0 || (ts > now_ts_10 && ts < now_ts_10 + maxday);
                }
                isSendChat = chatmodel[1] === '1';
            }
            if (isLottery) {
                /* 判断是否关注过 */
                const isFollowed = (new RegExp(uid)).test(self.attentionList);
                if ((this.isAttentionErr || only_followed === '1') && !isFollowed) continue;
                /* 判断是否转发过 */
                const isRelay = await MyStorage.searchDyid(dyid);
                /* 获取黑名单并去重合并 */
                const { blacklist: remote_blacklist } = GlobalVar.remoteconfig;
                const new_blacklist = remote_blacklist ?
                    Array.from(new Set([...blacklist.split(','), ...remote_blacklist.split(',')])).toString() : blacklist;
                /* 进行判断 */
                if ((new RegExp(dyid + '|' + uid)).test(new_blacklist)) continue;
                onelotteryinfo.uid = [] /**初始化待关注列表 */
                if (!isFollowed) onelotteryinfo.uid.push(uid);
                if (!isRelay) {
                    onelotteryinfo.dyid = dyid;
                    let RandomStr = Base.getRandomStr(config.relay);
                    let new_ctrl = [];
                    if (hasAt) {
                        /**如要修改请手动填写 */
                        const _at = [
                            ['转发抽奖娘', 294887687],
                            ['你的工具人老公', 100680137]
                        ];
                        _at.forEach(it => {
                            new_ctrl.push({
                                data: String(it[1]),
                                location: RandomStr.length,
                                length: it[0].length + 1,
                                type: 1
                            })
                            RandomStr += '@' + it[0]
                        })
                    }
                    if (type === 1) {
                        /* 转发内容长度+'//'+'@'+用户名+':'+源内容 */
                        const addlength = RandomStr.length + 2 + uname.length + 1 + 1;
                        onelotteryinfo.relay_chat = RandomStr + `//@${uname}:` + des;
                        new_ctrl.push({
                            data: String(uid),
                            location: RandomStr.length + 2,
                            length: uname.length + 1,
                            type: 1
                        })
                        ctrl.map(item => {
                            item.location += addlength;
                            return item;
                        }).forEach(it => new_ctrl.push(it))
                        if (!(new RegExp(uids[1])).test(self.attentionList))
                            onelotteryinfo.uid.push(uids[1]);
                    } else {
                        onelotteryinfo.relay_chat = RandomStr;
                    }
                    onelotteryinfo.ctrl = JSON.stringify(new_ctrl);
                }
                /* 根据动态的类型决定评论的类型 */
                onelotteryinfo.type = type === 2 ?
                    11 : type === 4 || type === 1 ?
                        17 : type === 8 ?
                            1 : 0;
                /* 是否评论 */
                if (isSendChat) onelotteryinfo.rid = rid;
                if (onelotteryinfo.dyid) alllotteryinfo.push(onelotteryinfo);
            }
        }
        return alllotteryinfo;
    }
    /**
     * 关注转发评论
     * @param {LotteryOptions} option
     * @returns {Promise<number>} sucess:1 err:0
     */
    async go(option) {
        const { uid, dyid, type, rid, relay_chat, ctrl } = option;
        if (typeof rid === 'string' && type !== 0) {
            const send = () => BiliAPI.sendChat(rid, Base.getRandomStr(config.chat), type);
            let [status, times] = [0, 0];
            do {
                if (times > 0) Base.tooltip.log('等一会儿再发送评论');
                times++;
                status = await send();
                if (status === 0) await Base.delay(5000 * 2 ** (times - 1))
            } while (status === 0 && times < 9);
            if (status === 0) return status;
        }
        if (!this.isAttentionErr) {
            uid.forEach(async (one_uid) => {
                if (typeof one_uid === 'number') {
                    if (await BiliAPI.autoAttention(uid) === 0) {
                        this.isAttentionErr = true;
                        return
                    }
                    await Base.delay(5000);
                    if (await BiliAPI.movePartition(uid, this.tagid) === 0) {
                        this.isAttentionErr = true;
                        return
                    }
                }
            })
        }
        if (this.isAttentionErr && uid.length !== 0) return 0;
        if (await BiliAPI.autolike(dyid) === 0) return 0;
        if (await BiliAPI.autoRelay(GlobalVar.myUID, dyid, relay_chat, ctrl) === 0) return 0;
        await Base.delay(Number(config.wait) + Math.floor(Math.random() * 60000 - 30000));
        return 1
    }
}

module.exports = Monitor;