2 from __future__
import unicode_literals
10 from .common
import InfoExtractor
11 from ..compat
import compat_str
23 class ViuBaseIE(InfoExtractor
):
24 def _call_api(self
, path
, *args
, headers
={}, **kwargs
):
25 response
= self
._download
_json
(
26 f
'https://www.viu.com/api/{path}', *args
, **kwargs
,
27 headers
={**self.geo_verification_headers(), **headers}
)['response']
28 if response
.get('status') != 'success':
29 raise ExtractorError(f
'{self.IE_NAME} said: {response["message"]}', expected
=True)
33 class ViuIE(ViuBaseIE
):
34 _VALID_URL
= r
'(?:viu:|https?://[^/]+\.viu\.com/[a-z]{2}/media/)(?P<id>\d+)'
36 'url': 'https://www.viu.com/en/media/1116705532?containerId=playlist-22168059',
40 'title': 'Citizen Khan - Ep 1',
41 'description': 'md5:d7ea1604f49e5ba79c212c551ce2110e',
44 'skip_download': 'm3u8 download',
46 'skip': 'Geo-restricted to India',
48 'url': 'https://www.viu.com/en/media/1130599965',
52 'title': 'Jealousy Incarnate - Episode 1',
53 'description': 'md5:d3d82375cab969415d2720b6894361e9',
56 'skip_download': 'm3u8 download',
58 'skip': 'Geo-restricted to Indonesia',
60 'url': 'https://india.viu.com/en/media/1126286865',
61 'only_matching': True,
64 def _real_extract(self
, url
):
65 video_id
= self
._match
_id
(url
)
67 video_data
= self
._call
_api
(
68 'clip/load', video_id
, 'Downloading video data', query
={
69 'appid': 'viu_desktop',
74 title
= video_data
['title']
77 url_path
= video_data
.get('urlpathd') or video_data
.get('urlpath')
78 tdirforwhole
= video_data
.get('tdirforwhole')
79 # #EXT-X-BYTERANGE is not supported by native hls downloader
81 # FIXME: It is supported in yt-dlp
82 # hls_file = video_data.get('hlsfile')
83 hls_file
= video_data
.get('jwhlsfile')
84 if url_path
and tdirforwhole
and hls_file
:
85 m3u8_url
= '%s/%s/%s' % (url_path
, tdirforwhole
, hls_file
)
88 # r'(/hlsc_)[a-z]+(\d+\.m3u8)',
89 # r'\1whe\2', video_data['href'])
90 m3u8_url
= video_data
['href']
91 formats
, subtitles
= self
._extract
_m
3u8_formats
_and
_subtitles
(m3u8_url
, video_id
, 'mp4')
92 self
._sort
_formats
(formats
)
94 for key
, value
in video_data
.items():
95 mobj
= re
.match(r
'^subtitle_(?P<lang>[^_]+)_(?P<ext>(vtt|srt))', key
)
98 subtitles
.setdefault(mobj
.group('lang'), []).append({
100 'ext': mobj
.group('ext')
106 'description': video_data
.get('description'),
107 'series': video_data
.get('moviealbumshowname'),
109 'episode_number': int_or_none(video_data
.get('episodeno')),
110 'duration': int_or_none(video_data
.get('duration')),
112 'subtitles': subtitles
,
116 class ViuPlaylistIE(ViuBaseIE
):
117 IE_NAME
= 'viu:playlist'
118 _VALID_URL
= r
'https?://www\.viu\.com/[^/]+/listing/playlist-(?P<id>\d+)'
120 'url': 'https://www.viu.com/en/listing/playlist-22461380',
123 'title': 'The Good Wife',
125 'playlist_count': 16,
126 'skip': 'Geo-restricted to Indonesia',
129 def _real_extract(self
, url
):
130 playlist_id
= self
._match
_id
(url
)
131 playlist_data
= self
._call
_api
(
132 'container/load', playlist_id
,
133 'Downloading playlist info', query
={
134 'appid': 'viu_desktop',
136 'id': 'playlist-' + playlist_id
140 for item
in playlist_data
.get('item', []):
141 item_id
= item
.get('id')
144 item_id
= compat_str(item_id
)
145 entries
.append(self
.url_result(
146 'viu:' + item_id
, 'Viu', item_id
))
148 return self
.playlist_result(
149 entries
, playlist_id
, playlist_data
.get('title'))
152 class ViuOTTIE(InfoExtractor
):
154 _NETRC_MACHINE
= 'viu'
155 _VALID_URL
= r
'https?://(?:www\.)?viu\.com/ott/(?P<country_code>[a-z]{2})/(?P<lang_code>[a-z]{2}-[a-z]{2})/vod/(?P<id>\d+)'
157 'url': 'http://www.viu.com/ott/sg/en-us/vod/3421/The%20Prime%20Minister%20and%20I',
161 'title': 'A New Beginning',
162 'description': 'md5:1e7486a619b6399b25ba6a41c0fe5b2c',
165 'skip_download': 'm3u8 download',
168 'skip': 'Geo-restricted to Singapore',
170 'url': 'http://www.viu.com/ott/hk/zh-hk/vod/7123/%E5%A4%A7%E4%BA%BA%E5%A5%B3%E5%AD%90',
174 'title': '這就是我的生活之道',
175 'description': 'md5:4eb0d8b08cf04fcdc6bbbeb16043434f',
178 'skip_download': 'm3u8 download',
181 'skip': 'Geo-restricted to Hong Kong',
183 'url': 'https://www.viu.com/ott/hk/zh-hk/vod/68776/%E6%99%82%E5%B0%9A%E5%AA%BD%E5%92%AA',
184 'playlist_count': 12,
190 'skip_download': 'm3u8 download',
193 'skip': 'Geo-restricted to Hong Kong',
211 def _detect_error(self
, response
):
212 code
= try_get(response
, lambda x
: x
['status']['code'])
213 if code
and code
> 0:
214 message
= try_get(response
, lambda x
: x
['status']['message'])
215 raise ExtractorError(f
'{self.IE_NAME} said: {message} ({code})', expected
=True)
216 return response
.get('data') or {}
218 def _login(self
, country_code
, video_id
):
219 if self
._user
_token
is None:
220 username
, password
= self
._get
_login
_info
()
224 'Authorization': f
'Bearer {self._auth_codes[country_code]}',
225 'Content-Type': 'application/json'
227 data
= self
._download
_json
(
228 'https://api-gateway-global.viu.com/api/account/validate',
229 video_id
, 'Validating email address', headers
=headers
,
231 'principal': username
,
234 if not data
.get('exists'):
235 raise ExtractorError('Invalid email address')
237 data
= self
._download
_json
(
238 'https://api-gateway-global.viu.com/api/auth/login',
239 video_id
, 'Logging in', headers
=headers
,
242 'password': password
,
245 self
._detect
_error
(data
)
246 self
._user
_token
= data
.get('identity')
247 # need to update with valid user's token else will throw an error again
248 self
._auth
_codes
[country_code
] = data
.get('token')
249 return self
._user
_token
251 def _get_token(self
, country_code
, video_id
):
252 rand
= ''.join(random
.choice('0123456789') for _
in range(10))
253 return self
._download
_json
(
254 f
'https://api-gateway-global.viu.com/api/auth/token?v={rand}000', video_id
,
255 headers
={'Content-Type': 'application/json'}
, note
='Getting bearer token',
257 'countryCode': country_code
.upper(),
258 'platform': 'browser',
259 'platformFlagLabel': 'web',
261 'uuid': str(uuid
.uuid4()),
263 }).encode('utf-8'))['token']
265 def _real_extract(self
, url
):
266 url
, idata
= unsmuggle_url(url
, {})
267 country_code
, lang_code
, video_id
= self
._match
_valid
_url
(url
).groups()
270 'r': 'vod/ajax-detail',
271 'platform_flag_label': 'web',
272 'product_id': video_id
,
275 area_id
= self
._AREA
_ID
.get(country_code
.upper())
277 query
['area_id'] = area_id
279 product_data
= self
._download
_json
(
280 f
'http://www.viu.com/ott/{country_code}/index.php', video_id
,
281 'Downloading video info', query
=query
)['data']
283 video_data
= product_data
.get('current_product')
285 self
.raise_geo_restricted()
287 series_id
= video_data
.get('series_id')
288 if self
._yes
_playlist
(series_id
, video_id
, idata
):
289 series
= product_data
.get('series') or {}
290 product
= series
.get('product')
293 for entry
in sorted(product
, key
=lambda x
: int_or_none(x
.get('number', 0))):
294 item_id
= entry
.get('product_id')
297 entries
.append(self
.url_result(
298 smuggle_url(f
'http://www.viu.com/ott/{country_code}/{lang_code}/vod/{item_id}/',
299 {'force_noplaylist': True}
),
300 ViuOTTIE
, str(item_id
), entry
.get('synopsis', '').strip()))
302 return self
.playlist_result(entries
, series_id
, series
.get('name'), series
.get('description'))
304 duration_limit
= False
306 'ccs_product_id': video_data
['ccs_product_id'],
307 'language_flag_id': self
._LANGUAGE
_FLAG
.get(lang_code
.lower()) or '3',
310 def download_playback():
311 stream_data
= self
._download
_json
(
312 'https://api-gateway-global.viu.com/api/playback/distribute',
313 video_id
=video_id
, query
=query
, fatal
=False, note
='Downloading stream info',
315 'Authorization': f
'Bearer {self._auth_codes[country_code]}',
319 return self
._detect
_error
(stream_data
).get('stream')
321 if not self
._auth
_codes
.get(country_code
):
322 self
._auth
_codes
[country_code
] = self
._get
_token
(country_code
, video_id
)
326 stream_data
= download_playback()
327 except (ExtractorError
, KeyError):
328 token
= self
._login
(country_code
, video_id
)
329 if token
is not None:
330 query
['identity'] = token
332 # preview is limited to 3min for non-members. But we can try to bypass it
333 duration_limit
, query
['duration'] = True, '180'
335 stream_data
= download_playback()
336 except (ExtractorError
, KeyError):
337 if token
is not None:
339 self
.raise_login_required(method
='password')
341 raise ExtractorError('Cannot get stream info', expected
=True)
344 for vid_format
, stream_url
in (stream_data
.get('url') or {}).items():
345 height
= int(self
._search
_regex
(r
's(\d+)p', vid_format
, 'height', default
=None))
347 # bypass preview duration limit
349 stream_url
= urllib
.parse
.urlparse(stream_url
)
351 'duration': video_data
.get('time_duration') or '9999999',
352 'duration_start': '0',
354 stream_url
= stream_url
._replace
(query
=urllib
.parse
.urlencode(dict(
355 urllib
.parse
.parse_qsl(stream_url
.query
, keep_blank_values
=True)))).geturl()
358 'format_id': vid_format
,
362 'filesize': try_get(stream_data
, lambda x
: x
['size'][vid_format
], int)
364 self
._sort
_formats
(formats
)
367 for sub
in video_data
.get('subtitle') or []:
368 sub_url
= sub
.get('url')
371 subtitles
.setdefault(sub
.get('name'), []).append({
376 title
= strip_or_none(video_data
.get('synopsis'))
380 'description': video_data
.get('description'),
381 'series': try_get(product_data
, lambda x
: x
['series']['name']),
383 'episode_number': int_or_none(video_data
.get('number')),
384 'duration': int_or_none(stream_data
.get('duration')),
385 'thumbnail': url_or_none(video_data
.get('cover_image_url')),
387 'subtitles': subtitles
,