]>
jfr.im git - yt-dlp.git/blob - yt_dlp/extractor/sonyliv.py
9 from .common
import InfoExtractor
10 from ..networking
.exceptions
import HTTPError
17 from ..utils
.traversal
import traverse_obj
20 class SonyLIVIE(InfoExtractor
):
24 https?://(?:www\.)?sonyliv\.com/(?:s(?:how|port)s/[^/]+|movies|clip|trailer|music-videos)/[^/?#&]+-
29 'url': 'https://www.sonyliv.com/shows/bachelors-delight-1700000113/achaari-cheese-toast-1000022678?watch=true',
31 'title': 'Achaari Cheese Toast',
34 'upload_date': '20200411',
35 'description': 'md5:3957fa31d9309bf336ceb3f37ad5b7cb',
36 'timestamp': 1586632091,
39 'series': 'Bachelors Delight',
44 'skip_download': True,
47 'url': 'https://www.sonyliv.com/movies/tahalka-1000050121?watch=true',
48 'only_matching': True,
50 'url': 'https://www.sonyliv.com/clip/jigarbaaz-1000098925',
51 'only_matching': True,
53 'url': 'https://www.sonyliv.com/trailer/sandwiched-forever-1000100286?watch=true',
54 'only_matching': True,
56 'url': 'https://www.sonyliv.com/sports/india-tour-of-australia-2020-21-1700000286/cricket-hls-day-3-1st-test-aus-vs-ind-19-dec-2020-1000100959?watch=true',
57 'only_matching': True,
59 'url': 'https://www.sonyliv.com/music-videos/yeh-un-dinon-ki-baat-hai-1000018779',
60 'only_matching': True,
62 _GEO_COUNTRIES
= ['IN']
64 _LOGIN_HINT
= 'Use "--username <mobile_number>" to login using OTP or "--username token --password <auth_token>" to login using auth token.'
65 _NETRC_MACHINE
= 'sonyliv'
67 def _get_device_id(self
):
68 e
= int(time
.time() * 1000)
69 t
= list('xxxxxxxxxxxx4xxxyxxxxxxxxxxxxxxx')
70 for i
, c
in enumerate(t
):
71 n
= int((e
+ 16 * random
.random()) % 16) |
0
72 e
= math
.floor(e
/ 16)
76 t
[i
] = '{:x}'.format(3 & n |
8)
77 return ''.join(t
) + '-' + str(int(time
.time() * 1000))
79 def _perform_login(self
, username
, password
):
80 self
._HEADERS
['device_id'] = self
._get
_device
_id
()
81 self
._HEADERS
['content-type'] = 'application/json'
83 if username
.lower() == 'token' and try_call(lambda: jwt_decode_hs256(password
)):
84 self
._HEADERS
['authorization'] = password
87 elif len(username
) != 10 or not username
.isdigit():
88 raise ExtractorError(f
'Invalid username/password; {self._LOGIN_HINT}')
91 otp_request_json
= self
._download
_json
(
92 'https://apiv2.sonyliv.com/AGL/1.6/A/ENG/WEB/IN/HR/CREATEOTP-V2',
93 None, note
='Sending OTP', headers
=self
._HEADERS
, data
=json
.dumps({
94 'mobileNumber': username
,
95 'channelPartnerID': 'MSMIND',
97 'timestamp': datetime
.datetime
.now().strftime('%Y-%m-%dT%H:%M:%S.%MZ'),
99 'loginType': 'REGISTERORSIGNIN',
100 'isMobileMandatory': True,
102 if otp_request_json
['resultCode'] == 'KO':
103 raise ExtractorError(otp_request_json
['message'], expected
=True)
105 otp_verify_json
= self
._download
_json
(
106 'https://apiv2.sonyliv.com/AGL/2.0/A/ENG/WEB/IN/HR/CONFIRMOTP-V2',
107 None, note
='Verifying OTP', headers
=self
._HEADERS
, data
=json
.dumps({
108 'channelPartnerID': 'MSMIND',
109 'mobileNumber': username
,
111 'otp': self
._get
_tfa
_info
('OTP'),
113 'ageConfirmation': True,
114 'timestamp': datetime
.datetime
.now().strftime('%Y-%m-%dT%H:%M:%S.%MZ'),
115 'isMobileMandatory': True,
117 if otp_verify_json
['resultCode'] == 'KO':
118 raise ExtractorError(otp_request_json
['message'], expected
=True)
119 self
._HEADERS
['authorization'] = otp_verify_json
['resultObj']['accessToken']
121 def _call_api(self
, version
, path
, video_id
):
123 return self
._download
_json
(
124 'https://apiv2.sonyliv.com/AGL/%s/A/ENG/WEB/%s' % (version
, path
),
125 video_id
, headers
=self
._HEADERS
)['resultObj']
126 except ExtractorError
as e
:
127 if isinstance(e
.cause
, HTTPError
) and e
.cause
.status
== 406 and self
._parse
_json
(
128 e
.cause
.response
.read().decode(), video_id
)['message'] == 'Please subscribe to watch this content':
129 self
.raise_login_required(self
._LOGIN
_HINT
, method
=None)
130 if isinstance(e
.cause
, HTTPError
) and e
.cause
.status
== 403:
131 message
= self
._parse
_json
(
132 e
.cause
.response
.read().decode(), video_id
)['message']
133 if message
== 'Geoblocked Country':
134 self
.raise_geo_restricted(countries
=self
._GEO
_COUNTRIES
)
135 raise ExtractorError(message
)
138 def _initialize_pre_login(self
):
139 self
._HEADERS
['security_token'] = self
._call
_api
('1.4', 'ALL/GETTOKEN', None)
141 def _real_extract(self
, url
):
142 video_id
= self
._match
_id
(url
)
143 content
= self
._call
_api
(
144 '1.5', 'IN/CONTENT/VIDEOURL/VOD/' + video_id
, video_id
)
145 if not self
.get_param('allow_unplayable_formats') and content
.get('isEncrypted'):
146 self
.report_drm(video_id
)
147 dash_url
= content
['videoURL']
149 'x-playback-session-id': '%s-%d' % (uuid
.uuid4().hex, time
.time() * 1000)
151 formats
= self
._extract
_mpd
_formats
(
152 dash_url
, video_id
, mpd_id
='dash', headers
=headers
, fatal
=False)
153 formats
.extend(self
._extract
_m
3u8_formats
(
154 dash_url
.replace('.mpd', '.m3u8').replace('/DASH/', '/HLS/'),
155 video_id
, 'mp4', m3u8_id
='hls', headers
=headers
, fatal
=False))
157 f
.setdefault('http_headers', {}).update(headers
)
159 metadata
= self
._call
_api
(
160 '1.6', 'IN/DETAIL/' + video_id
, video_id
)['containers'][0]['metadata']
161 title
= metadata
['episodeTitle']
163 for sub
in content
.get('subtitle', []):
164 sub_url
= sub
.get('subtitleUrl')
167 subtitles
.setdefault(sub
.get('subtitleLanguageName', 'ENG'), []).append({
174 'thumbnail': content
.get('posterURL'),
175 'description': metadata
.get('longDescription') or metadata
.get('shortDescription'),
176 'timestamp': int_or_none(metadata
.get('creationDate'), 1000),
177 'duration': int_or_none(metadata
.get('duration')),
178 'season_number': int_or_none(metadata
.get('season')),
179 'series': metadata
.get('title'),
180 'episode_number': int_or_none(metadata
.get('episodeNumber')),
181 'release_year': int_or_none(metadata
.get('year')),
182 'subtitles': subtitles
,
186 class SonyLIVSeriesIE(InfoExtractor
):
187 _VALID_URL
= r
'https?://(?:www\.)?sonyliv\.com/shows/[^/?#&]+-(?P<id>\d{10})/?(?:$|[?#])'
189 'url': 'https://www.sonyliv.com/shows/adaalat-1700000091',
190 'playlist_mincount': 452,
195 'url': 'https://www.sonyliv.com/shows/beyhadh-1700000007/',
196 'playlist_mincount': 358,
201 _API_BASE
= 'https://apiv2.sonyliv.com/AGL'
203 def _entries(self
, show_id
):
205 'Accept': 'application/json, text/plain, */*',
206 'Referer': 'https://www.sonyliv.com',
208 headers
['security_token'] = self
._download
_json
(
209 f
'{self._API_BASE}/1.4/A/ENG/WEB/ALL/GETTOKEN', show_id
,
210 'Downloading security token', headers
=headers
)['resultObj']
211 seasons
= traverse_obj(self
._download
_json
(
212 f
'{self._API_BASE}/1.9/R/ENG/WEB/IN/DL/DETAIL/{show_id}', show_id
,
213 'Downloading series JSON', headers
=headers
, query
={
214 'kids_safe': 'false',
217 }), ('resultObj', 'containers', 0, 'containers', lambda _
, v
: int_or_none(v
['id'])))
218 for season
in seasons
:
219 season_id
= str(season
['id'])
220 note
= traverse_obj(season
, ('metadata', 'title', {str}
)) or 'season'
222 for page_num
in itertools
.count(1):
223 episodes
= traverse_obj(self
._download
_json
(
224 f
'{self._API_BASE}/1.4/R/ENG/WEB/IN/CONTENT/DETAIL/BUNDLE/{season_id}',
225 season_id
, f
'Downloading {note} page {page_num} JSON', headers
=headers
, query
={
227 'to': str(cursor
+ 99),
228 'orderBy': 'episodeNumber',
230 }), ('resultObj', 'containers', 0, 'containers', lambda _
, v
: int_or_none(v
['id'])))
233 for episode
in episodes
:
234 video_id
= str(episode
['id'])
235 yield self
.url_result(f
'sonyliv:{video_id}', SonyLIVIE
, video_id
)
238 def _real_extract(self
, url
):
239 show_id
= self
._match
_id
(url
)
240 return self
.playlist_result(self
._entries
(show_id
), playlist_id
=show_id
)