Genshin-bots/StarRailUID
1
0
Fork 0
mirror of https://github.com/baiqwerdvd/StarRailUID.git synced 2025-05-05 03:03:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复事件循环未关闭问题 (#41)

Browse Source
This commit is contained in:
RBAmeto 2023-05-19 09:31:50 +08:00 committed by GitHub
parent ab70f84a46
commit f8428cd82d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
StarRailUID/utils/mys_api.py
View File

@ -6,6 +6,7 @@ import asyncio
from string import digits, ascii_letters from string import digits, ascii_letters
from typing import Dict, Union, Optional, cast from typing import Dict, Union, Optional, cast
from gsuid_core.logger import logger
from gsuid_core.utils.api.mys_api import _MysApi from gsuid_core.utils.api.mys_api import _MysApi
from gsuid_core.utils.api.mys.models import MysSign, SignInfo, SignList from gsuid_core.utils.api.mys.models import MysSign, SignInfo, SignList
from gsuid_core.utils.api.mys.tools import ( from gsuid_core.utils.api.mys.tools import (
@ -42,7 +43,14 @@ class MysApi(_MysApi):
def __init__(self, *args, **kwargs): def __init__(self, *args, **kwargs):
super().__init__(*args, **kwargs) super().__init__(*args, **kwargs)
asyncio.run(self.get_fp()) loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
try:
device_fp = loop.run_until_complete(self.get_fp())
self._HEADER['x-rpc-device_fp'] = device_fp
finally:
loop.run_until_complete(loop.shutdown_asyncgens())
loop.close()
self._HEADER['x-rpc-device_id'] = self.device_id self._HEADER['x-rpc-device_id'] = self.device_id
self._HEADER['x-rpc-page'] = '3.1.3_#/rpg' self._HEADER['x-rpc-page'] = '3.1.3_#/rpg'
self._HEADER['x-rpc-challenge_game'] = '6' self._HEADER['x-rpc-challenge_game'] = '6'
@ -316,16 +324,14 @@ class MysApi(_MysApi):
header=HEADER, header=HEADER,
data=body, data=body,
) )
if res["retcode"] != 0: if not isinstance(res, Dict):
print("获取fp连接失败") logger.error(f"获取fp连接失败{res}")
print(res) return random_hex(13).lower()
self._HEADER['x-rpc-device_fp'] = random_hex(13).lower()
elif res["data"]["code"] != 200: elif res["data"]["code"] != 200:
print("获取fp参数不正确") logger.error(f"获取fp参数不正确{res['data']['msg']}")
print(res["data"]["msg"]) return random_hex(13).lower()
self._HEADER['x-rpc-device_fp'] = random_hex(13).lower()
else: else:
self._HEADER['x-rpc-device_fp'] = res["data"]["device_fp"] return res["data"]["device_fp"]
mys_api = MysApi() mys_api = MysApi()