bilibili.py

import sys
from imp import reload
import configloader
import os
import hashlib
import datetime
import time
import requests
import rsa
import base64
import uuid
from urllib import parse
from printer import Printer
import aiohttp
import asyncio

reload(sys)


def CurrentTime():
    currenttime = int(time.mktime(datetime.datetime.now().timetuple()))
    return str(currenttime)


class bilibili():
    instance = None

    def __new__(cls, *args, **kw):
        if not cls.instance:
            cls.instance = super(bilibili, cls).__new__(cls, *args, **kw)
            fileDir = os.path.dirname(os.path.realpath('__file__'))
            file_bilibili = fileDir + "/conf/bilibili.conf"
            cls.instance.dic_bilibili = configloader.load_bilibili(
                file_bilibili)
            cls.instance.bili_session = None
            cls.instance.black_status = False
        return cls.instance

    @property
    def bili_section(self):
        if self.bili_session is None:
            self.bili_session = aiohttp.ClientSession()
            # print(0)
        return self.bili_session

    @staticmethod
    def load_session(dic):
        inst = bilibili.instance
        for i in dic.keys():
            inst.dic_bilibili[i] = dic[i]
            if i == 'cookie':
                inst.dic_bilibili['pcheaders']['cookie'] = dic[i]
                inst.dic_bilibili['appheaders']['cookie'] = dic[i]

    def calc_sign(self, str, app_secret=None):
        str += app_secret or self.dic_bilibili['app_secret']
        hash = hashlib.md5()
        hash.update(str.encode('utf-8'))
        sign = hash.hexdigest()
        return sign

    def cnn_captcha(self, img):
        url = "http://106.75.36.27:19951/captcha/v1"
        img = str(img, encoding='utf-8')
        json = {"image": img}
        ressponse = requests.post(url, json=json)
        captcha = ressponse.json()
        Printer().printer(
            f"此次登录出现验证码,识别结果为{captcha['message']}", "Info", "green")
        return captcha['message']

    def calc_name_passw(self, key, Hash, username, password):
        pubkey = rsa.PublicKey.load_pkcs1_openssl_pem(key.encode())
        password = base64.b64encode(rsa.encrypt(
            (Hash + password).encode('utf-8'), pubkey))
        password = parse.quote_plus(password)
        username = parse.quote_plus(username)
        return username, password

    async def reset_black_status(self):
        struct_time = time.localtime(time.time())
        sleep_min = 40 if 1 <= struct_time.tm_hour <= 17 else 20
        Printer().printer(f"当前处于小黑屋，休眠 {sleep_min} min", "Info", "green")
        await asyncio.sleep(sleep_min * 60)
        Printer().printer(f"黑屋休眠结束，尝试进行抽奖", "Info", "green")
        self.black_status = False

    async def replay_request(self, response):
        json_response = await response.json(content_type=None)
        if json_response['code'] == 1024:
            Printer().printer(f'b站炸了,暂停所有请求5s后重试,请耐心等待', "Error", "red")
            await asyncio.sleep(5)
            return True
        elif json_response['code'] in [503, -509]:
            Printer().printer(f'『{json_response["message"]}』5s后重试', "Error", "red")
            await asyncio.sleep(5)
            return True
        elif json_response['code'] == -403 and json_response.get("msg") == '访问被拒绝':
            self.black_status = True
            asyncio.ensure_future(self.reset_black_status())
            return False
        else:
            return False

    async def bili_section_request(self, method, url, replay=True, **kwargs):
        while True:
            try:
                response = await self.bili_section.request(method, url, **kwargs)
                if response.status in [403, 412]:
                    if replay:
                        Printer().printer(f'<{response.status} {response.reason}>，60s后重试: {url}', "Error", "red")
                        await asyncio.sleep(60)
                        continue
                    else:
                        Printer().printer(f'<{response.status} {response.reason}>，放弃抽奖', "Error", "red")
                        break
                elif response.status == 404:
                    Printer().printer(f'<{response.status} {response.reason}>，接口疑似已失效，请联系开发者', "Error", "red")
                    return None
                tag = await self.replay_request(response)
                if tag:
                    continue
                return response
            except:
                # print('当前网络不好，正在重试，请反馈开发者!!!!')
                # print(sys.exc_info()[0], sys.exc_info()[1])
                await asyncio.sleep(1)
                continue

    async def bili_section_post(self, url, **kwargs):
        return await self.bili_section_request('POST', url, **kwargs)

    async def bili_section_get(self, url, **kwargs):
        return await self.bili_section_request('GET', url, **kwargs)

    # 1:900兑换
    async def request_doublegain_coin2silver(self):
        # url: "/exchange/coin2silver",
        data = {'coin': 10}
        url = "https://api.live.bilibili.com/exchange/coin2silver"
        response = await self.bili_section_post(url, data=data, headers=self.dic_bilibili['pcheaders'])
        return response

    # 1:450兑换
    async def coin2silver_web(self, num):
        url = "https://api.live.bilibili.com/pay/v1/Exchange/coin2silver"
        data = {
            "num": int(num),
            "platform": 'pc',
            "csrf_token": self.dic_bilibili['csrf'],
            "csrf": self.dic_bilibili['csrf']
        }
        response = await self.bili_section_post(url, data=data, headers=self.dic_bilibili['pcheaders'])
        return response

    async def post_watching_history(self, room_id):
        data = {
            "room_id": room_id,
            "platform": 'pc',
            "csrf_token": self.dic_bilibili['csrf'],
            "csrf": self.dic_bilibili['csrf']
        }
        url = "https://api.live.bilibili.com/room/v1/Room/room_entry_action"
        response = await self.bili_section_post(url, data=data, headers=self.dic_bilibili['pcheaders'])
        return response

    async def silver2coin_web(self):
        url = "https://api.live.bilibili.com/exchange/silver2coin"
        data = {
            "csrf_token": self.dic_bilibili['csrf'],
            "csrf": self.dic_bilibili['csrf']
        }
        response = await self.bili_section_post(url, data=data, headers=self.dic_bilibili['pcheaders'])
        return response

    async def silver2coin_app(self):
        temp_params = 'access_key=' + self.dic_bilibili['access_key'] + '&actionKey=' + self.dic_bilibili[
            'actionKey'] + '&appkey=' + self.dic_bilibili['appkey'] + '&build=' + self.dic_bilibili[
                          'build'] + '&device=' + self.dic_bilibili['device'] + '&mobi_app=' + self.dic_bilibili[
                          'mobi_app'] + '&platform=' + self.dic_bilibili['platform'] + '&ts=' + CurrentTime()
        sign = self.calc_sign(temp_params)
        app_url = "https://api.live.bilibili.com/AppExchange/silver2coin?" + \
                  temp_params + "&sign=" + sign
        response1 = await self.bili_section_post(app_url, headers=self.dic_bilibili['appheaders'])
        return response1

    async def request_check_room(self, roomid):
        url = "https://api.live.bilibili.com/room/v1/Room/room_init?id=" + \
              str(roomid)
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    async def request_fetch_bag_list(self):
        url = "https://api.live.bilibili.com/gift/v2/gift/bag_list"
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    async def request_check_taskinfo(self):
        url = 'https://api.live.bilibili.com/i/api/taskInfo'
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    async def request_send_gift_web(self, giftid, giftnum, bagid, ruid, biz_id):
        url = "https://api.live.bilibili.com/gift/v2/live/bag_send"
        data = {
            'uid': self.dic_bilibili['uid'],
            'gift_id': giftid,
            'ruid': ruid,
            'gift_num': giftnum,
            'bag_id': bagid,
            'platform': 'pc',
            'biz_code': 'live',
            'biz_id': biz_id,
            'rnd': CurrentTime(),
            'storm_beat_id': '0',
            'metadata': '',
            'price': '0',
            'csrf_token': self.dic_bilibili['csrf']
        }
        response = await self.bili_section_post(url, headers=self.dic_bilibili['pcheaders'], data=data)
        return response

    async def request_fetch_user_info(self):
        url = "https://api.live.bilibili.com/live_user/v1/UserInfo/live_info"
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    async def request_fetch_user_infor_ios(self):
        # 长串请求起作用的就这几个破玩意儿
        url = 'https://api.live.bilibili.com/mobile/getUser?access_key={}&platform=ios'.format(
            self.dic_bilibili['access_key'])
        response = await self.bili_section_get(url)
        return response

    async def request_fetch_liveuser_info(self, real_roomid):
        url = 'https://api.live.bilibili.com/live_user/v1/UserInfo/get_anchor_in_room?roomid={}'.format(
            real_roomid)
        response = await self.bili_section_get(url)
        return response

    def request_load_img(self, url):
        return requests.get(url)

    async def request_fetchmedal(self):
        url = 'https://api.live.bilibili.com/i/api/medal?page=1&pageSize=168'
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    def request_getkey(self):
        url = 'https://passport.bilibili.com/api/oauth2/getKey'
        temp_params = 'appkey=' + self.dic_bilibili['appkey']
        sign = self.calc_sign(temp_params)
        params = {'appkey': self.dic_bilibili['appkey'], 'sign': sign}
        response = requests.post(url, data=params)
        return response

    async def get_gift_of_events_web(self, text1, text2, raffleid):
        headers = {
            'Accept': 'application/json, text/plain, */*',
            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.94 Safari/537.36',
            'cookie': self.dic_bilibili['cookie'],
            'referer': text2
        }
        pc_url = 'https://api.live.bilibili.com/activity/v1/Raffle/join?roomid=' + str(
            text1) + '&raffleId=' + str(raffleid)
        pc_response = await self.bili_section_get(pc_url, headers=headers)
        return pc_response

    async def get_gift_of_events_app(self, text1, raffleid):
        headers = {
            'Accept': 'application/json, text/plain, */*',
            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.94 Safari/537.36',
            'cookie': self.dic_bilibili['cookie'],
            # 'referer': text2
        }
        temp_params = 'access_key=' + self.dic_bilibili['access_key'] + '&actionKey=' + self.dic_bilibili[
            'actionKey'] + '&appkey=' + self.dic_bilibili['appkey'] + '&build=' + self.dic_bilibili[
                          'build'] + '&device=' + self.dic_bilibili['device'] + '&event_type=' + str(
            raffleid) + '&mobi_app=' + self.dic_bilibili['mobi_app'] + '&platform=' + self.dic_bilibili[
                          'platform'] + '&room_id=' + str(
            text1) + '&ts=' + CurrentTime()
        params = temp_params + self.dic_bilibili['app_secret']
        sign = self.calc_sign(temp_params)
        true_url = 'https://api.live.bilibili.com/YunYing/roomEvent?' + \
                   temp_params + '&sign=' + sign
        response1 = await self.bili_section_get(true_url, params=params, headers=headers)
        return response1

    async def get_gift_of_TV(self, type, real_roomid, raffleid):
        url = "https://api.live.bilibili.com/xlive/lottery-interface/v5/smalltv/join"
        data = {
            "roomid": real_roomid,
            "id": raffleid,
            "type": type,
            "csrf_token": self.dic_bilibili['csrf'],
            "csrf": self.dic_bilibili['csrf'],
            "visit_id": "8u0aig7b8100"
        }
        response2 = await self.bili_section_post(url, replay=False, data=data, headers=self.dic_bilibili['pcheaders'])
        return response2

    async def get_gift_of_captain(self, roomid, id):
        join_url = "https://api.live.bilibili.com/xlive/lottery-interface/v3/guard/join"
        payload = {"roomid": roomid, "id": id, "type": "guard",
                   "csrf_token": self.dic_bilibili['csrf']}
        response2 = await self.bili_section_post(join_url, replay=False, data=payload,
                                                 headers=self.dic_bilibili['pcheaders'])
        return response2

    async def get_gift_of_pk(self, roomid, id):
        join_url = "https://api.live.bilibili.com/xlive/lottery-interface/v1/pk/join"
        payload = {"roomid": roomid, "id": id, "csrf": self.dic_bilibili['csrf'],
                   "csrf_token": self.dic_bilibili['csrf']}
        response2 = await self.bili_section_post(join_url, replay=False, data=payload,
                                                 headers=self.dic_bilibili['pcheaders'])
        return response2

    async def get_giftlist_of_events(self, text1):
        headers = {
            'Accept': 'application/json, text/plain, */*',
            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.94 Safari/537.36',
            'Accept-Language': 'zh-CN,zh;q=0.9',
            'accept-encoding': 'gzip, async deflate',
            'Host': 'api.live.bilibili.com',
        }
        # url = f'{base_url}/activity/v1/Raffle/check?roomid={text1}'
        temp_params = 'access_key=' + self.dic_bilibili['access_key'] + '&actionKey=' + self.dic_bilibili[
            'actionKey'] + '&appkey=' + self.dic_bilibili['appkey'] + '&build=' + self.dic_bilibili[
                          'build'] + '&device=' + self.dic_bilibili['device'] + '&mobi_app=' + self.dic_bilibili[
                          'mobi_app'] + '&platform=' + self.dic_bilibili[
                          'platform'] + '&roomid=' + str(
            text1) + '&ts=' + CurrentTime()
        sign = self.calc_sign(temp_params)
        url = "https://api.live.bilibili.com/activity/v1/Common/mobileRoomInfo?" + \
              temp_params + "&sign=" + sign
        response = await bilibili.instance.bili_section_get(url, headers=self.dic_bilibili['appheaders'])
        # url = 'https://api.live.bilibili.com/activity/v1/Raffle/check?roomid=' + str(text1)
        # response = await self.bili_section_get(url, headers=headers)
        return response

    async def get_giftlist_of_TV(self, real_roomid):
        url = "https://api.live.bilibili.com/xlive/lottery-interface/v1/lottery/Check?roomid=" + \
              str(real_roomid)
        headers = {
            "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36",
        }
        response = await self.bili_section_get(url, headers=headers)
        return response

    async def get_giftlist_of_captain(self, roomid):
        true_url = 'https://api.live.bilibili.com/lottery/v1/lottery/guard_check?roomid=' + \
                   str(roomid)
        headers = {
            "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q = 0.8",
            "Accept-Encoding": "gzip,async deflate,br",
            "Accept-Language": "zh-CN",
            "DNT": "1",
            "Cookie": "LIVE_BUVID=AUTO7715232653604550",
            "Connection": "keep-alive",
            "Cache-Control": "max-age =0",
            "Host": "api.live.bilibili.com",
            "Upgrade-Insecure-Requests": "1",
            "User-Agent": 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10.13; rv:59.0) Gecko/20100101 Firefox/59.0'
        }
        response1 = await self.bili_section_get(true_url, headers=headers)
        return response1

    async def get_lotterylist_of_pk(self, roomid):
        url = 'http://api.live.bilibili.com/xlive/lottery-interface/v1/pk/check?roomid=' + str(roomid)
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    def get_giftids_raffle(self, str):
        return self.dic_bilibili['giftids_raffle'][str]

    def get_giftids_raffle_keys(self):
        return self.dic_bilibili['giftids_raffle'].keys()

    async def get_activity_result(self, activity_roomid, activity_raffleid):
        url = "https://api.live.bilibili.com/activity/v1/Raffle/notice?roomid=" + str(
            activity_roomid) + "&raffleId=" + str(activity_raffleid)
        headers = {
            'Accept': 'application/json, text/plain, */*',
            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.94 Safari/537.36',
            'Accept-Language': 'zh-CN,zh;q=0.9',
            'accept-encoding': 'gzip, async deflate',
            'Host': 'api.live.bilibili.com',
            'cookie': self.dic_bilibili['cookie'],
        }
        response = await self.bili_section_get(url, headers=headers)
        return response

    async def get_TV_result(self, TV_roomid, TV_raffleid):
        url = "https://api.live.bilibili.com/gift/v3/smalltv/notice?raffleId=" + \
              str(TV_raffleid)
        headers = {
            'Accept': 'application/json, text/plain, */*',
            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.94 Safari/537.36',
            'Accept-Language': 'zh-CN,zh;q=0.9',
            'accept-encoding': 'gzip, async deflate',
            'Host': 'api.live.bilibili.com',
            'cookie': self.dic_bilibili['cookie'],
        }
        response = await self.bili_section_get(url, headers=headers)
        return response

    async def pcpost_heartbeat(self):
        url = 'https://api.live.bilibili.com/User/userOnlineHeart'
        data = {
            "csrf_token": self.dic_bilibili['csrf'],
            "csrf": self.dic_bilibili['csrf']
        }
        response = await self.bili_section_post(url, data=data, headers=self.dic_bilibili['pcheaders'])
        return response

    # 发送app心跳包
    async def apppost_heartbeat(self):
        time = CurrentTime()
        temp_params = 'access_key=' + self.dic_bilibili['access_key'] + '&actionKey=' + self.dic_bilibili[
            'actionKey'] + '&appkey=' + self.dic_bilibili['appkey'] + '&build=' + self.dic_bilibili[
                          'build'] + '&device=' + self.dic_bilibili['device'] + '&mobi_app=' + self.dic_bilibili[
                          'mobi_app'] + '&platform=' + self.dic_bilibili['platform'] + '&ts=' + time
        sign = self.calc_sign(temp_params)
        url = 'https://api.live.bilibili.com/mobile/userOnlineHeart?' + \
              temp_params + '&sign=' + sign
        payload = {'roomid': 23058, 'scale': 'xhdpi'}
        response = await self.bili_section_post(url, data=payload, headers=self.dic_bilibili['appheaders'])
        return response

    # 心跳礼物
    async def heart_gift(self):
        url = "https://api.live.bilibili.com/gift/v2/live/heart_gift_receive?roomid=3&area_v2_id=34"
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    async def get_room_info(self, roomid):
        url = f"https://api.live.bilibili.com/xlive/web-room/v1/index/getInfoByRoom?room_id={roomid}"
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'], timeout=3)
        return response

    async def pk_list(self):
        url = "http://118.25.108.153:8080/pk"
        headers = {
            "User-Agent": "bilibili-live-tools/" + str(self.dic_bilibili['uid'])
        }
        response = requests.get(url, headers=headers, timeout=10)
        return response

    async def get_lotterylist(self, i):
        url = "https://api.live.bilibili.com/lottery/v1/box/getStatus?aid=" + \
              str(i)
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    async def get_gift_of_lottery(self, i, g):
        url1 = 'https://api.live.bilibili.com/xlive/lottery-interface/v2/Box/draw?aid=' + \
               str(i) + '&number=' + str(g + 1)
        response1 = await self.bili_section_get(url1, headers=self.dic_bilibili['pcheaders'])
        return response1

    async def get_winner_info(self, i, g):
        url2 = 'https://api.live.bilibili.com/lottery/v1/box/getWinnerGroupInfo?aid=' + \
               str(i) + '&number=' + str(g + 1)
        response2 = await self.bili_section_get(url2, headers=self.dic_bilibili['pcheaders'])
        return response2

    async def get_time_about_silver(self):
        time = CurrentTime()
        temp_params = 'access_key=' + self.dic_bilibili['access_key'] + '&actionKey=' + self.dic_bilibili[
            'actionKey'] + '&appkey=' + self.dic_bilibili['appkey'] + '&build=' + self.dic_bilibili[
                          'build'] + '&device=' + self.dic_bilibili['device'] + '&mobi_app=' + self.dic_bilibili[
                          'mobi_app'] + '&platform=' + self.dic_bilibili['platform'] + '&ts=' + time
        sign = self.calc_sign(temp_params)
        GetTask_url = 'https://api.live.bilibili.com/mobile/freeSilverCurrentTask?' + \
                      temp_params + '&sign=' + sign
        response = await self.bili_section_get(GetTask_url, headers=self.dic_bilibili['appheaders'])
        return response

    async def get_silver(self, timestart, timeend):
        time = CurrentTime()
        temp_params = 'access_key=' + self.dic_bilibili['access_key'] + '&actionKey=' + self.dic_bilibili[
            'actionKey'] + '&appkey=' + self.dic_bilibili['appkey'] + '&build=' + self.dic_bilibili[
                          'build'] + '&device=' + self.dic_bilibili['device'] + '&mobi_app=' + self.dic_bilibili[
                          'mobi_app'] + '&platform=' + self.dic_bilibili[
                          'platform'] + '&time_end=' + timeend + '&time_start=' + timestart + '&ts=' + time
        sign = self.calc_sign(temp_params)
        url = 'https://api.live.bilibili.com/mobile/freeSilverAward?' + \
              temp_params + '&sign=' + sign
        response = await self.bili_section_get(url, headers=self.dic_bilibili['appheaders'])
        return response

    async def get_dailybag(self):
        url = 'https://api.live.bilibili.com/gift/v2/live/receive_daily_bag'
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    async def get_dosign(self):
        url = 'https://api.live.bilibili.com/sign/doSign'
        response = await self.bili_section_get(url, headers=self.dic_bilibili['pcheaders'])
        return response

    async def get_grouplist(self):
        url = "https://api.vc.bilibili.com/link_group/v1/member/my_groups"
        pcheaders = self.dic_bilibili['pcheaders'].copy()
        pcheaders['Host'] = "api.vc.bilibili.com"
        response = await self.bili_section_get(url, headers=pcheaders)
        return response

    async def assign_group(self, i1, i2):
        temp_params = "_device=" + self.dic_bilibili[
            'device'] + "&_hwid=SX1NL0wuHCsaKRt4BHhIfRguTXxOfj5WN1BkBTdLfhstTn9NfUouFiUV&access_key=" + \
                      self.dic_bilibili['access_key'] + "&appkey=" + self.dic_bilibili['appkey'] + "&build=" + \
                      self.dic_bilibili['build'] + "&group_id=" + str(i1) + "&mobi_app=" + self.dic_bilibili[
                          'mobi_app'] + "&owner_id=" + str(i2) + "&platform=" + self.dic_bilibili[
                          'platform'] + "&src=xiaomi&trace_id=20171224024300024&ts=" + CurrentTime() + "&version=5.20.1.520001"
        sign = self.calc_sign(temp_params)
        url = "https://api.vc.bilibili.com/link_setting/v1/link_setting/sign_in?" + \
              temp_params + "&sign=" + sign
        appheaders = self.dic_bilibili['appheaders'].copy()
        appheaders['Host'] = "api.vc.bilibili.com"
        response = await self.bili_section_get(url, headers=appheaders)
        return response

    async def gift_list(self):
        url = "https://api.live.bilibili.com/gift/v2/live/room_gift_list?roomid=2721650&area_v2_id=86"
        res = await self.bili_section_get(url)
        return res

    async def check_activity_exist(self):
        url = "https://api.live.bilibili.com/activity/v1/Common/roomInfo?roomid=128666&ruid=18174739"
        response = await self.bili_section_get(url)
        return response

    async def query_guard(self, name):
        search_url = "https://search.bilibili.com/api/search?search_type=live_user&keyword=" + \
                     str(name) + "&page=1"
        response = await self.bili_section_get(search_url)
        return response

    async def check_room_state(self, roomid):
        init_url = "https://api.live.bilibili.com/room/v1/Room/room_init?id=" + \
                   str(roomid)
        response = await self.bili_section_get(init_url)
        json_response = await response.json(content_type=None)
        state = json_response['data']['live_status']
        return state

    async def check_room_info(self, roomid):
        url = "https://api.live.bilibili.com/room/v1/Room/get_info?room_id=" + \
              str(roomid)
        response = await self.bili_section_get(url)
        return response

    async def req_area_list(self):
        url = "http://api.live.bilibili.com/room/v1/Area/getList"
        response = await self.bili_section_get(url)
        return response

    async def heart_beat_e(self, room_id):
        response = await self.get_room_info(room_id)
        json_response = await response.json(content_type=None)
        parent_area_id = json_response['data']['room_info']['parent_area_id']
        area_id = json_response['data']['room_info']['area_id']

        url = 'https://live-trace.bilibili.com/xlive/data-interface/v1/x25Kn/E'
        headers = {
            'Content-Type': 'application/x-www-form-urlencoded',
            'Origin': 'https://live.bilibili.com',
            'Referer': f'https://live.bilibili.com/{room_id}',
            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/77.0.3865.90 Safari/537.36',
            'Cookie': self.dic_bilibili['cookie'],
        }
        payload = {
            'id': [parent_area_id, area_id, 0, room_id],
            'device': f'["{self.calc_sign(str(uuid.uuid4()))}","{uuid.uuid4()}"]',
            'ts': int(time.time()) * 1000,
            'is_patch': 0,
            'heart_beat': [],
            'ua': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.163 Safari/537.36',
            'csrf_token': self.dic_bilibili['csrf'],
            'csrf': self.dic_bilibili['csrf'],
            'visit_id': ''
        }
        data = parse.urlencode(payload)
        # {"code":0,"message":"0","ttl":1,"data":{"timestamp":1595342828,"heartbeat_interval":300,"secret_key":"seacasdgyijfhofiuxoannn","secret_rule":[2,5,1,4],"patch_status":2}}
        response = await self.bili_section_post(url, headers=headers, data=data)
        response = await response.json(content_type=None)
        payload['ets'] = response['data']['timestamp']
        payload['secret_key'] = response['data']['secret_key']
        payload['heartbeat_interval'] = response['data']['heartbeat_interval']
        payload['secret_rule'] = response['data']['secret_rule']
        return payload

    async def heart_beat_x(self, index, payload, room_id):
        response = await self.get_room_info(room_id)
        json_response = await response.json(content_type=None)
        parent_area_id = json_response['data']['room_info']['parent_area_id']
        area_id = json_response['data']['room_info']['area_id']
        url = 'https://live-trace.bilibili.com/xlive/data-interface/v1/x25Kn/X'
        headers = {
            'Content-Type': 'application/x-www-form-urlencoded',
            'Origin': 'https://live.bilibili.com',
            'Referer': f'https://live.bilibili.com/{room_id}',
            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/77.0.3865.90 Safari/537.36',
            'Cookie': self.dic_bilibili['cookie'],
        }
        s_data = {
            "t": {
                'id': [parent_area_id, area_id, index, room_id],
                "device": payload['device'],  # LIVE_BUVID
                "ets": payload['ets'],
                "benchmark": payload['secret_key'],
                "time": payload['heartbeat_interval'],
                "ts": int(time.time()) * 1000,
                "ua": payload['ua']
            },
            "r": payload['secret_rule']
        }
        t = s_data['t']
        payload = {
            's': self.generate_s(s_data),
            'id': t['id'],
            'device': t['device'],
            'ets': t['ets'],
            'benchmark': t['benchmark'],
            'time': t['time'],
            'ts': t['ts'],
            "ua": t['ua'],
            'csrf_token': self.dic_bilibili['csrf'],
            'csrf': self.dic_bilibili['csrf'],
            'visit_id': '',
        }
        payload = parse.urlencode(payload)
        # {"code":0,"message":"0","ttl":1,"data":{"heartbeat_interval":300,"timestamp":1595346846,"secret_rule":[2,5,1,4],"secret_key":"seacasdgyijfhofiuxoannn"}}
        response = await self.bili_section_post(url, headers=headers, data=payload)
        return response

    # 加密s
    def generate_s(self, data):
        url = 'http://127.0.0.1:3000/enc'
        response = requests.post(url, json=data).json()
        return response['s']