_BASE_URL = 'https://www.crunchyroll.com'
_API_BASE = 'https://api.crunchyroll.com'
_NETRC_MACHINE = 'crunchyroll'
+ _REFRESH_TOKEN = None
_AUTH_HEADERS = None
+ _AUTH_EXPIRY = None
_API_ENDPOINT = None
- _BASIC_AUTH = None
+ _BASIC_AUTH = 'Basic ' + base64.b64encode(':'.join((
+ 't-kdgp2h8c3jub8fn0fq',
+ 'yfLDfMfrYvKXh4JXS1LEI2cCqu1v5Wan',
+ )).encode()).decode()
_IS_PREMIUM = None
- _CLIENT_ID = ('cr_web', 'noaihdevm_6iyg0a8l0q')
_LOCALE_LOOKUP = {
'ar': 'ar-SA',
'de': 'de-DE',
'hi': 'hi-IN',
}
- @property
- def is_logged_in(self):
- return bool(self._get_cookies(self._BASE_URL).get('etp_rt'))
+ def _set_auth_info(self, response):
+ CrunchyrollBaseIE._IS_PREMIUM = 'cr_premium' in traverse_obj(response, ('access_token', {jwt_decode_hs256}, 'benefits', ...))
+ CrunchyrollBaseIE._AUTH_HEADERS = {'Authorization': response['token_type'] + ' ' + response['access_token']}
+ CrunchyrollBaseIE._AUTH_EXPIRY = time_seconds(seconds=traverse_obj(response, ('expires_in', {float_or_none}), default=300) - 10)
+
+ def _request_token(self, headers, data, note='Requesting token', errnote='Failed to request token'):
+ try: # TODO: Add impersonation support here
+ return self._download_json(
+ f'{self._BASE_URL}/auth/v1/token', None, note=note, errnote=errnote,
+ headers=headers, data=urlencode_postdata(data))
+ except ExtractorError as error:
+ if not isinstance(error.cause, HTTPError) or error.cause.status != 403:
+ raise
+ raise ExtractorError(
+ 'Request blocked by Cloudflare; navigate to Crunchyroll in your browser, '
+ 'then pass the fresh cookies (with --cookies-from-browser or --cookies) '
+ 'and your browser\'s User-Agent (with --user-agent)', expected=True)
def _perform_login(self, username, password):
- if self.is_logged_in:
+ if not CrunchyrollBaseIE._REFRESH_TOKEN:
+ CrunchyrollBaseIE._REFRESH_TOKEN = self.cache.load(self._NETRC_MACHINE, username)
+ if CrunchyrollBaseIE._REFRESH_TOKEN:
return
- upsell_response = self._download_json(
- f'{self._API_BASE}/get_upsell_data.0.json', None, 'Getting session id',
- query={
- 'sess_id': 1,
- 'device_id': 'whatvalueshouldbeforweb',
- 'device_type': 'com.crunchyroll.static',
- 'access_token': 'giKq5eY27ny3cqz',
- 'referer': f'{self._BASE_URL}/welcome/login'
- })
- if upsell_response['code'] != 'ok':
- raise ExtractorError('Could not get session id')
- session_id = upsell_response['data']['session_id']
-
- login_response = self._download_json(
- f'{self._API_BASE}/login.1.json', None, 'Logging in',
- data=urlencode_postdata({
- 'account': username,
- 'password': password,
- 'session_id': session_id
- }))
- if login_response['code'] != 'ok':
- raise ExtractorError('Login failed. Server message: %s' % login_response['message'], expected=True)
- if not self.is_logged_in:
- raise ExtractorError('Login succeeded but did not set etp_rt cookie')
+ try:
+ login_response = self._request_token(
+ headers={'Authorization': self._BASIC_AUTH}, data={
+ 'username': username,
+ 'password': password,
+ 'grant_type': 'password',
+ 'scope': 'offline_access',
+ }, note='Logging in', errnote='Failed to log in')
+ except ExtractorError as error:
+ if isinstance(error.cause, HTTPError) and error.cause.status == 401:
+ raise ExtractorError('Invalid username and/or password', expected=True)
+ raise
+
+ CrunchyrollBaseIE._REFRESH_TOKEN = login_response['refresh_token']
+ self.cache.store(self._NETRC_MACHINE, username, CrunchyrollBaseIE._REFRESH_TOKEN)
+ self._set_auth_info(login_response)
def _update_auth(self):
- if CrunchyrollBaseIE._AUTH_HEADERS and CrunchyrollBaseIE._AUTH_REFRESH > time_seconds():
+ if CrunchyrollBaseIE._AUTH_HEADERS and CrunchyrollBaseIE._AUTH_EXPIRY > time_seconds():
return
- if not CrunchyrollBaseIE._BASIC_AUTH:
- cx_api_param = self._CLIENT_ID[self.is_logged_in]
- self.write_debug(f'Using cxApiParam={cx_api_param}')
- CrunchyrollBaseIE._BASIC_AUTH = 'Basic ' + base64.b64encode(f'{cx_api_param}:'.encode()).decode()
-
- auth_headers = {'Authorization': CrunchyrollBaseIE._BASIC_AUTH}
- if self.is_logged_in:
- grant_type = 'etp_rt_cookie'
+ auth_headers = {'Authorization': self._BASIC_AUTH}
+ if CrunchyrollBaseIE._REFRESH_TOKEN:
+ data = {
+ 'refresh_token': CrunchyrollBaseIE._REFRESH_TOKEN,
+ 'grant_type': 'refresh_token',
+ 'scope': 'offline_access',
+ }
else:
- grant_type = 'client_id'
+ data = {'grant_type': 'client_id'}
auth_headers['ETP-Anonymous-ID'] = uuid.uuid4()
try:
- auth_response = self._download_json(
- f'{self._BASE_URL}/auth/v1/token', None, note=f'Authenticating with grant_type={grant_type}',
- headers=auth_headers, data=f'grant_type={grant_type}'.encode())
+ auth_response = self._request_token(auth_headers, data)
except ExtractorError as error:
- if isinstance(error.cause, HTTPError) and error.cause.status == 403:
- raise ExtractorError(
- 'Request blocked by Cloudflare; navigate to Crunchyroll in your browser, '
- 'then pass the fresh cookies (with --cookies-from-browser or --cookies) '
- 'and your browser\'s User-Agent (with --user-agent)', expected=True)
- raise
+ username, password = self._get_login_info()
+ if not username or not isinstance(error.cause, HTTPError) or error.cause.status != 400:
+ raise
+ self.to_screen('Refresh token has expired. Re-logging in')
+ CrunchyrollBaseIE._REFRESH_TOKEN = None
+ self.cache.store(self._NETRC_MACHINE, username, None)
+ self._perform_login(username, password)
+ return
- CrunchyrollBaseIE._IS_PREMIUM = 'cr_premium' in traverse_obj(auth_response, ('access_token', {jwt_decode_hs256}, 'benefits', ...))
- CrunchyrollBaseIE._AUTH_HEADERS = {'Authorization': auth_response['token_type'] + ' ' + auth_response['access_token']}
- CrunchyrollBaseIE._AUTH_REFRESH = time_seconds(seconds=traverse_obj(auth_response, ('expires_in', {float_or_none}), default=300) - 10)
+ self._set_auth_info(auth_response)
def _locale_from_language(self, language):
config_locale = self._configuration_arg('metadata', ie_key=CrunchyrollBetaIE, casesense=True)
self._update_auth()
stream_response = self._download_json(
f'https://cr-play-service.prd.crunchyrollsvc.com/v1/{identifier}/console/switch/play',
- display_id, note='Downloading stream info', headers=CrunchyrollBaseIE._AUTH_HEADERS)
+ display_id, note='Downloading stream info', errnote='Failed to download stream info',
+ headers=CrunchyrollBaseIE._AUTH_HEADERS)
available_formats = {'': ('', '', stream_response['url'])}
for hardsub_lang, stream in traverse_obj(stream_response, ('hardSubs', {dict.items}, lambda _, v: v[1]['url'])):
if not self._IS_PREMIUM and traverse_obj(response, (f'{object_type}_metadata', 'is_premium_only')):
message = f'This {object_type} is for premium members only'
- if self.is_logged_in:
+ if CrunchyrollBaseIE._REFRESH_TOKEN:
raise ExtractorError(message, expected=True)
- self.raise_login_required(message)
+ self.raise_login_required(message, method='password')
result['formats'], result['subtitles'] = self._extract_stream(internal_id)
if not self._IS_PREMIUM and response.get('isPremiumOnly'):
message = f'This {response.get("type") or "media"} is for premium members only'
- if self.is_logged_in:
+ if CrunchyrollBaseIE._REFRESH_TOKEN:
raise ExtractorError(message, expected=True)
- self.raise_login_required(message)
+ self.raise_login_required(message, method='password')
result = self._transform_music_response(response)
result['formats'], _ = self._extract_stream(f'music/{internal_id}', internal_id)
projects / yt-dlp.git / commitdiff
