PublicMirrors/you-get
1
0
Fork 0
mirror of https://github.com/soimort/you-get.git synced 2025-02-03 08:43:58 +03:00
Code Issues Actions Packages Projects Releases 1 Wiki Activity

[Douyutv]Update api

Browse Source 
Thanks #1299 @cnbeining #1235 @hellofwy
This commit is contained in:
steven7851 2016-07-29 13:35:05 +08:00 committed by GitHub
parent 0922307896
commit 6689f45469
1 changed files with 22 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/you_get/extractors/douyutv.py
View File

@ -6,27 +6,44 @@ from ..common import *
import json import json
import hashlib import hashlib
import time import time
import random
import string
import requests
def douyutv_download(url, output_dir = '.', merge = True, info_only = False, **kwargs): def douyutv_download(url, output_dir = '.', merge = True, info_only = False, **kwargs):
room_id = url[url.rfind('/')+1:] room_id = url[url.rfind('/')+1:]
#Thanks to @yan12125 for providing decoding method!!
suffix = 'room/%s?aid=android&client_sys=android&time=%d' % (room_id, int(time.time())) json_request_url = "http://m.douyu.com/html5/live?roomId=%s" % room_id
sign = hashlib.md5((suffix + '1231').encode('ascii')).hexdigest()
json_request_url = "http://www.douyu.com/api/v1/%s&auth=%s" % (suffix, sign)
content = get_html(json_request_url) content = get_html(json_request_url)
data = json.loads(content)['data'] data = json.loads(content)['data']
server_status = data.get('error',0) server_status = data.get('error',0)
if server_status is not 0: if server_status is not 0:
raise ValueError("Server returned error:%s" % server_status) raise ValueError("Server returned error:%s" % server_status)
title = data.get('room_name') title = data.get('room_name')
show_status = data.get('show_status') show_status = data.get('show_status')
if show_status is not "1": if show_status is not "1":
raise ValueError("The live stream is not online! (Errno:%s)" % server_status) raise ValueError("The live stream is not online! (Errno:%s)" % server_status)
tt = int(time.time() / 60)
did = ''.join([random.choice(string.ascii_uppercase + string.digits) for n in range(32)])
sign = hashlib.md5((room_id + did + 'A12Svb&%1UUmf@hC' + "%d" % tt).encode("utf-8")).hexdigest()
json_request_url = "http://www.douyu.com/lapi/live/getPlay/%s" % room_id
payload = {'cdn': 'ws', 'rate': '0', 'tt': tt, 'did': did, 'sign': sign}
r = requests.post(json_request_url, data=payload)
content = r.json()
data = content['data']
server_status = data.get('error',0)
if server_status is not 0:
raise ValueError("Server returned error:%s" % server_status)
real_url = data.get('rtmp_url')+'/'+data.get('rtmp_live') real_url = data.get('rtmp_url')+'/'+data.get('rtmp_live')
print_info(site_info, title, 'flv', float('inf')) print_info(site_info, title, 'flv', float('inf'))
if not info_only: if not info_only:
download_urls([real_url], title, 'flv', None, output_dir, merge = merge) download_url_ffmpeg(real_url, title, 'flv', None, output_dir, merge = merge)
site_info = "douyu.com" site_info = "douyu.com"
download = douyutv_download download = douyutv_download