7 from .common
import InfoExtractor
8 from ..compat
import compat_str
20 class ViuBaseIE(InfoExtractor
):
21 def _call_api(self
, path
, *args
, headers
={}, **kwargs
):
22 response
= self
._download
_json
(
23 f
'https://www.viu.com/api/{path}', *args
, **kwargs
,
24 headers
={**self.geo_verification_headers(), **headers}
)['response']
25 if response
.get('status') != 'success':
26 raise ExtractorError(f
'{self.IE_NAME} said: {response["message"]}', expected
=True)
30 class ViuIE(ViuBaseIE
):
31 _VALID_URL
= r
'(?:viu:|https?://[^/]+\.viu\.com/[a-z]{2}/media/)(?P<id>\d+)'
33 'url': 'https://www.viu.com/en/media/1116705532?containerId=playlist-22168059',
37 'title': 'Citizen Khan - Ep 1',
38 'description': 'md5:d7ea1604f49e5ba79c212c551ce2110e',
41 'skip_download': 'm3u8 download',
43 'skip': 'Geo-restricted to India',
45 'url': 'https://www.viu.com/en/media/1130599965',
49 'title': 'Jealousy Incarnate - Episode 1',
50 'description': 'md5:d3d82375cab969415d2720b6894361e9',
53 'skip_download': 'm3u8 download',
55 'skip': 'Geo-restricted to Indonesia',
57 'url': 'https://india.viu.com/en/media/1126286865',
58 'only_matching': True,
61 def _real_extract(self
, url
):
62 video_id
= self
._match
_id
(url
)
64 video_data
= self
._call
_api
(
65 'clip/load', video_id
, 'Downloading video data', query
={
66 'appid': 'viu_desktop',
71 title
= video_data
['title']
74 url_path
= video_data
.get('urlpathd') or video_data
.get('urlpath')
75 tdirforwhole
= video_data
.get('tdirforwhole')
76 # #EXT-X-BYTERANGE is not supported by native hls downloader
78 # FIXME: It is supported in yt-dlp
79 # hls_file = video_data.get('hlsfile')
80 hls_file
= video_data
.get('jwhlsfile')
81 if url_path
and tdirforwhole
and hls_file
:
82 m3u8_url
= '%s/%s/%s' % (url_path
, tdirforwhole
, hls_file
)
85 # r'(/hlsc_)[a-z]+(\d+\.m3u8)',
86 # r'\1whe\2', video_data['href'])
87 m3u8_url
= video_data
['href']
88 formats
, subtitles
= self
._extract
_m
3u8_formats
_and
_subtitles
(m3u8_url
, video_id
, 'mp4')
89 self
._sort
_formats
(formats
)
91 for key
, value
in video_data
.items():
92 mobj
= re
.match(r
'^subtitle_(?P<lang>[^_]+)_(?P<ext>(vtt|srt))', key
)
95 subtitles
.setdefault(mobj
.group('lang'), []).append({
97 'ext': mobj
.group('ext')
103 'description': video_data
.get('description'),
104 'series': video_data
.get('moviealbumshowname'),
106 'episode_number': int_or_none(video_data
.get('episodeno')),
107 'duration': int_or_none(video_data
.get('duration')),
109 'subtitles': subtitles
,
113 class ViuPlaylistIE(ViuBaseIE
):
114 IE_NAME
= 'viu:playlist'
115 _VALID_URL
= r
'https?://www\.viu\.com/[^/]+/listing/playlist-(?P<id>\d+)'
117 'url': 'https://www.viu.com/en/listing/playlist-22461380',
120 'title': 'The Good Wife',
122 'playlist_count': 16,
123 'skip': 'Geo-restricted to Indonesia',
126 def _real_extract(self
, url
):
127 playlist_id
= self
._match
_id
(url
)
128 playlist_data
= self
._call
_api
(
129 'container/load', playlist_id
,
130 'Downloading playlist info', query
={
131 'appid': 'viu_desktop',
133 'id': 'playlist-' + playlist_id
137 for item
in playlist_data
.get('item', []):
138 item_id
= item
.get('id')
141 item_id
= compat_str(item_id
)
142 entries
.append(self
.url_result(
143 'viu:' + item_id
, 'Viu', item_id
))
145 return self
.playlist_result(
146 entries
, playlist_id
, playlist_data
.get('title'))
149 class ViuOTTIE(InfoExtractor
):
151 _NETRC_MACHINE
= 'viu'
152 _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+)'
154 'url': 'http://www.viu.com/ott/sg/en-us/vod/3421/The%20Prime%20Minister%20and%20I',
158 'title': 'A New Beginning',
159 'description': 'md5:1e7486a619b6399b25ba6a41c0fe5b2c',
162 'skip_download': 'm3u8 download',
165 'skip': 'Geo-restricted to Singapore',
167 'url': 'http://www.viu.com/ott/hk/zh-hk/vod/7123/%E5%A4%A7%E4%BA%BA%E5%A5%B3%E5%AD%90',
171 'title': '這就是我的生活之道',
172 'description': 'md5:4eb0d8b08cf04fcdc6bbbeb16043434f',
175 'skip_download': 'm3u8 download',
178 'skip': 'Geo-restricted to Hong Kong',
180 'url': 'https://www.viu.com/ott/hk/zh-hk/vod/68776/%E6%99%82%E5%B0%9A%E5%AA%BD%E5%92%AA',
181 'playlist_count': 12,
187 'skip_download': 'm3u8 download',
190 'skip': 'Geo-restricted to Hong Kong',
208 def _detect_error(self
, response
):
209 code
= try_get(response
, lambda x
: x
['status']['code'])
210 if code
and code
> 0:
211 message
= try_get(response
, lambda x
: x
['status']['message'])
212 raise ExtractorError(f
'{self.IE_NAME} said: {message} ({code})', expected
=True)
213 return response
.get('data') or {}
215 def _login(self
, country_code
, video_id
):
216 if self
._user
_token
is None:
217 username
, password
= self
._get
_login
_info
()
221 'Authorization': f
'Bearer {self._auth_codes[country_code]}',
222 'Content-Type': 'application/json'
224 data
= self
._download
_json
(
225 'https://api-gateway-global.viu.com/api/account/validate',
226 video_id
, 'Validating email address', headers
=headers
,
228 'principal': username
,
231 if not data
.get('exists'):
232 raise ExtractorError('Invalid email address')
234 data
= self
._download
_json
(
235 'https://api-gateway-global.viu.com/api/auth/login',
236 video_id
, 'Logging in', headers
=headers
,
239 'password': password
,
242 self
._detect
_error
(data
)
243 self
._user
_token
= data
.get('identity')
244 # need to update with valid user's token else will throw an error again
245 self
._auth
_codes
[country_code
] = data
.get('token')
246 return self
._user
_token
248 def _get_token(self
, country_code
, video_id
):
249 rand
= ''.join(random
.choice('0123456789') for _
in range(10))
250 return self
._download
_json
(
251 f
'https://api-gateway-global.viu.com/api/auth/token?v={rand}000', video_id
,
252 headers
={'Content-Type': 'application/json'}
, note
='Getting bearer token',
254 'countryCode': country_code
.upper(),
255 'platform': 'browser',
256 'platformFlagLabel': 'web',
258 'uuid': str(uuid
.uuid4()),
260 }).encode('utf-8'))['token']
262 def _real_extract(self
, url
):
263 url
, idata
= unsmuggle_url(url
, {})
264 country_code
, lang_code
, video_id
= self
._match
_valid
_url
(url
).groups()
267 'r': 'vod/ajax-detail',
268 'platform_flag_label': 'web',
269 'product_id': video_id
,
272 area_id
= self
._AREA
_ID
.get(country_code
.upper())
274 query
['area_id'] = area_id
276 product_data
= self
._download
_json
(
277 f
'http://www.viu.com/ott/{country_code}/index.php', video_id
,
278 'Downloading video info', query
=query
)['data']
280 video_data
= product_data
.get('current_product')
282 self
.raise_geo_restricted()
284 series_id
= video_data
.get('series_id')
285 if self
._yes
_playlist
(series_id
, video_id
, idata
):
286 series
= product_data
.get('series') or {}
287 product
= series
.get('product')
290 for entry
in sorted(product
, key
=lambda x
: int_or_none(x
.get('number', 0))):
291 item_id
= entry
.get('product_id')
294 entries
.append(self
.url_result(
295 smuggle_url(f
'http://www.viu.com/ott/{country_code}/{lang_code}/vod/{item_id}/',
296 {'force_noplaylist': True}
),
297 ViuOTTIE
, str(item_id
), entry
.get('synopsis', '').strip()))
299 return self
.playlist_result(entries
, series_id
, series
.get('name'), series
.get('description'))
301 duration_limit
= False
303 'ccs_product_id': video_data
['ccs_product_id'],
304 'language_flag_id': self
._LANGUAGE
_FLAG
.get(lang_code
.lower()) or '3',
307 def download_playback():
308 stream_data
= self
._download
_json
(
309 'https://api-gateway-global.viu.com/api/playback/distribute',
310 video_id
=video_id
, query
=query
, fatal
=False, note
='Downloading stream info',
312 'Authorization': f
'Bearer {self._auth_codes[country_code]}',
316 return self
._detect
_error
(stream_data
).get('stream')
318 if not self
._auth
_codes
.get(country_code
):
319 self
._auth
_codes
[country_code
] = self
._get
_token
(country_code
, video_id
)
323 stream_data
= download_playback()
324 except (ExtractorError
, KeyError):
325 token
= self
._login
(country_code
, video_id
)
326 if token
is not None:
327 query
['identity'] = token
329 # The content is Preview or for VIP only.
330 # We can try to bypass the duration which is limited to 3mins only
331 duration_limit
, query
['duration'] = True, '180'
333 stream_data
= download_playback()
334 except (ExtractorError
, KeyError):
335 if token
is not None:
337 self
.raise_login_required(method
='password')
339 raise ExtractorError('Cannot get stream info', expected
=True)
342 for vid_format
, stream_url
in (stream_data
.get('url') or {}).items():
343 height
= int(self
._search
_regex
(r
's(\d+)p', vid_format
, 'height', default
=None))
345 # bypass preview duration limit
347 old_stream_url
= urllib
.parse
.urlparse(stream_url
)
348 query
= dict(urllib
.parse
.parse_qsl(old_stream_url
.query
, keep_blank_values
=True))
350 'duration': video_data
.get('time_duration') or '9999999',
351 'duration_start': '0',
353 stream_url
= old_stream_url
._replace
(query
=urllib
.parse
.urlencode(query
)).geturl()
356 'format_id': vid_format
,
360 'filesize': try_get(stream_data
, lambda x
: x
['size'][vid_format
], int)
362 self
._sort
_formats
(formats
)
365 for sub
in video_data
.get('subtitle') or []:
366 sub_url
= sub
.get('url')
369 subtitles
.setdefault(sub
.get('name'), []).append({
374 title
= strip_or_none(video_data
.get('synopsis'))
378 'description': video_data
.get('description'),
379 'series': try_get(product_data
, lambda x
: x
['series']['name']),
381 'episode_number': int_or_none(video_data
.get('number')),
382 'duration': int_or_none(stream_data
.get('duration')),
383 'thumbnail': url_or_none(video_data
.get('cover_image_url')),
385 'subtitles': subtitles
,