aboutsummaryrefslogtreecommitdiffstats
path: root/hypervideo_dl/extractor/trovo.py
diff options
context:
space:
mode:
Diffstat (limited to 'hypervideo_dl/extractor/trovo.py')
-rw-r--r--hypervideo_dl/extractor/trovo.py73
1 files changed, 71 insertions, 2 deletions
diff --git a/hypervideo_dl/extractor/trovo.py b/hypervideo_dl/extractor/trovo.py
index de0107a..ec55f41 100644
--- a/hypervideo_dl/extractor/trovo.py
+++ b/hypervideo_dl/extractor/trovo.py
@@ -1,6 +1,7 @@
# coding: utf-8
from __future__ import unicode_literals
+import itertools
import json
from .common import InfoExtractor
@@ -14,6 +15,7 @@ from ..utils import (
class TrovoBaseIE(InfoExtractor):
_VALID_URL_BASE = r'https?://(?:www\.)?trovo\.live/'
+ _HEADERS = {'Origin': 'https://trovo.live'}
def _extract_streamer_info(self, data):
streamer_info = data.get('streamerInfo') or {}
@@ -35,7 +37,7 @@ class TrovoIE(TrovoBaseIE):
'query': '''{
getLiveInfo(params: {userName: "%s"}) {
isLive
- programInfo {
+ programInfo {
coverUrl
id
streamInfo {
@@ -68,6 +70,7 @@ class TrovoIE(TrovoBaseIE):
'format_id': format_id,
'height': int_or_none(format_id[:-1]) if format_id else None,
'url': play_url,
+ 'http_headers': self._HEADERS,
})
self._sort_formats(formats)
@@ -153,7 +156,7 @@ class TrovoVodIE(TrovoBaseIE):
'protocol': 'm3u8_native',
'tbr': int_or_none(play_info.get('bitrate')),
'url': play_url,
- 'http_headers': {'Origin': 'https://trovo.live'},
+ 'http_headers': self._HEADERS,
})
self._sort_formats(formats)
@@ -192,3 +195,69 @@ class TrovoVodIE(TrovoBaseIE):
}
info.update(self._extract_streamer_info(vod_detail_info))
return info
+
+
+class TrovoChannelBaseIE(InfoExtractor):
+ def _get_vod_json(self, page, uid):
+ raise NotImplementedError('This method must be implemented by subclasses')
+
+ def _entries(self, uid):
+ for page in itertools.count(1):
+ vod_json = self._get_vod_json(page, uid)
+ vods = vod_json.get('vodInfos', [])
+ for vod in vods:
+ yield self.url_result(
+ 'https://trovo.live/%s/%s' % (self._TYPE, vod.get('vid')),
+ ie=TrovoVodIE.ie_key())
+ has_more = vod_json['hasMore']
+ if not has_more:
+ break
+
+ def _real_extract(self, url):
+ id = self._match_id(url)
+ uid = str(self._download_json('https://gql.trovo.live/', id, query={
+ 'query': '{getLiveInfo(params:{userName:"%s"}){streamerInfo{uid}}}' % id
+ })['data']['getLiveInfo']['streamerInfo']['uid'])
+ return self.playlist_result(self._entries(uid), playlist_id=uid)
+
+
+class TrovoChannelVodIE(TrovoChannelBaseIE):
+ _VALID_URL = r'trovovod:(?P<id>[^\s]+)'
+ IE_DESC = 'All VODs of a trovo.live channel, "trovovod" keyword'
+
+ _TESTS = [{
+ 'url': 'trovovod:OneTappedYou',
+ 'playlist_mincount': 24,
+ 'info_dict': {
+ 'id': '100719456',
+ },
+ }]
+
+ _QUERY = '{getChannelLtvVideoInfos(params:{pageSize:99,currPage:%d,channelID:%s}){hasMore,vodInfos{vid}}}'
+ _TYPE = 'video'
+
+ def _get_vod_json(self, page, uid):
+ return self._download_json('https://gql.trovo.live/', uid, query={
+ 'query': self._QUERY % (page, uid)
+ })['data']['getChannelLtvVideoInfos']
+
+
+class TrovoChannelClipIE(TrovoChannelBaseIE):
+ _VALID_URL = r'trovoclip:(?P<id>[^\s]+)'
+ IE_DESC = 'All Clips of a trovo.live channel, "trovoclip" keyword'
+
+ _TESTS = [{
+ 'url': 'trovoclip:OneTappedYou',
+ 'playlist_mincount': 29,
+ 'info_dict': {
+ 'id': '100719456',
+ },
+ }]
+
+ _QUERY = '{getChannelClipVideoInfos(params:{pageSize:99,currPage:%d,channelID:%s,albumType:VOD_CLIP_ALBUM_TYPE_LATEST}){hasMore,vodInfos{vid}}}'
+ _TYPE = 'clip'
+
+ def _get_vod_json(self, page, uid):
+ return self._download_json('https://gql.trovo.live/', uid, query={
+ 'query': self._QUERY % (page, uid)
+ })['data']['getChannelClipVideoInfos']