yaclty/zhibo-url
1
0
Fork 0
mirror of https://github.com/wbt5/real-url.git synced 2025-08-02 15:44:49 +08:00
Code Issues Releases Wiki Activity

新增网易LOOK直播弹幕

Browse Source
This commit is contained in:
wbt5 2020-07-25 16:53:02 +08:00
parent ca1da4aeb7
commit b0b8edeb49
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
danmu/danmaku/__init__.py
View File

@ -17,6 +17,7 @@ from .longzhu import LongZhu
from .pps import QiXiu from .pps import QiXiu
from .qf import QF from .qf import QF
from .laifeng import LaiFeng from .laifeng import LaiFeng
from .look import Look
__all__ = ['DanmakuClient'] __all__ = ['DanmakuClient']
@ -48,7 +49,8 @@ class DanmakuClient:
'longzhu.com': LongZhu, 'longzhu.com': LongZhu,
'pps.tv': QiXiu, 'pps.tv': QiXiu,
'qf.56.com': QF, 'qf.56.com': QF,
'laifeng.com': LaiFeng}.items(): 'laifeng.com': LaiFeng,
'look.163.com': Look}.items():
if re.match(r'^(?:http[s]?://)?.*?%s/(.+?)$' % u, url): if re.match(r'^(?:http[s]?://)?.*?%s/(.+?)$' % u, url):
self.__site = s self.__site = s
self.__u = u self.__u = u
@ -63,7 +65,7 @@ class DanmakuClient:
self.__ws = await self.__hs.ws_connect(ws_url) self.__ws = await self.__hs.ws_connect(ws_url)
if reg_datas: if reg_datas:
for reg_data in reg_datas: for reg_data in reg_datas:
if self.__u == 'qf.56.com' or self.__u == 'laifeng.com': if self.__u == 'qf.56.com' or self.__u == 'laifeng.com' or self.__u == 'look.163.com':
await self.__ws.send_str(reg_data) await self.__ws.send_str(reg_data)
else: else:
await self.__ws.send_bytes(reg_data) await self.__ws.send_bytes(reg_data)
@ -72,7 +74,7 @@ class DanmakuClient:
while not self.__stop and self.__site.heartbeat: while not self.__stop and self.__site.heartbeat:
await asyncio.sleep(self.__site.heartbeatInterval) await asyncio.sleep(self.__site.heartbeatInterval)
try: try:
if self.__u == 'qf.56.com' or self.__u == 'laifeng.com': if self.__u == 'qf.56.com' or self.__u == 'laifeng.com' or self.__u == 'look.163.com':
await self.__ws.send_str(self.__site.heartbeat) await self.__ws.send_str(self.__site.heartbeat)
else: else:
await self.__ws.send_bytes(self.__site.heartbeat) await self.__ws.send_bytes(self.__site.heartbeat)