artem/yt-dlp
1
0
Fork 0
mirror of https://github.com/yt-dlp/yt-dlp.git synced 2026-06-12 13:54:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

[ie/iwara] Fix extractors (#16014)

Browse Source 
Closes #13672, Closes #16009, Closes #16146
Authored by: vpertys
This commit is contained in:
vpertys 2026-06-10 03:59:42 +07:00 committed by GitHub
parent a75d66ae2c
commit 1a1481e89b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 25 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
yt_dlp/extractor/iwara.py
View File

@ -29,6 +29,12 @@ class IwaraBaseIE(InfoExtractor):
self.to_screen(f'{token_type} token has expired') self.to_screen(f'{token_type} token has expired')
return True return True
def _call_api(self, path, video_id, **kwargs):
impersonate = kwargs.pop('impersonate', True)
return self._download_json(
f'https://api.iwara.tv/{path}', video_id,
impersonate=impersonate, **kwargs)
def _get_user_token(self): def _get_user_token(self):
username, password = self._get_login_info() username, password = self._get_login_info()
if not username or not password: if not username or not password:
@ -36,8 +42,8 @@ class IwaraBaseIE(InfoExtractor):
user_token = IwaraBaseIE._USERTOKEN or self.cache.load(self._NETRC_MACHINE, username) user_token = IwaraBaseIE._USERTOKEN or self.cache.load(self._NETRC_MACHINE, username)
if not user_token or self._is_token_expired(user_token, 'User'): if not user_token or self._is_token_expired(user_token, 'User'):
response = self._download_json( response = self._call_api(
'https://api.iwara.tv/user/login', None, note='Logging in', 'user/login', None, note='Logging in',
headers={'Content-Type': 'application/json'}, data=json.dumps({ headers={'Content-Type': 'application/json'}, data=json.dumps({
'email': username, 'email': username,
'password': password, 'password': password,
@ -60,8 +66,8 @@ class IwaraBaseIE(InfoExtractor):
return # user has not passed credentials return # user has not passed credentials
if not IwaraBaseIE._MEDIATOKEN or self._is_token_expired(IwaraBaseIE._MEDIATOKEN, 'Media'): if not IwaraBaseIE._MEDIATOKEN or self._is_token_expired(IwaraBaseIE._MEDIATOKEN, 'Media'):
IwaraBaseIE._MEDIATOKEN = self._download_json( IwaraBaseIE._MEDIATOKEN = self._call_api(
'https://api.iwara.tv/user/token', None, note='Fetching media token', 'user/token', None, note='Fetching media token',
data=b'', headers={ data=b'', headers={
'Authorization': f'Bearer {IwaraBaseIE._USERTOKEN}', 'Authorization': f'Bearer {IwaraBaseIE._USERTOKEN}',
'Content-Type': 'application/json', 'Content-Type': 'application/json',
@ -147,11 +153,11 @@ class IwaraIE(IwaraBaseIE):
q = urllib.parse.parse_qs(up.query) q = urllib.parse.parse_qs(up.query)
paths = up.path.rstrip('/').split('/') paths = up.path.rstrip('/').split('/')
# https://github.com/yt-dlp/yt-dlp/issues/6549#issuecomment-1473771047 # https://github.com/yt-dlp/yt-dlp/issues/6549#issuecomment-1473771047
x_version = hashlib.sha1('_'.join((paths[-1], q['expires'][0], '5nFp9kmbNnHdAFhaqMvt')).encode()).hexdigest() x_version = hashlib.sha1('_'.join((paths[-1], q['expires'][0], 'mSvL05GfEmeEmsEYfGCnVpEjYgTJraJN')).encode()).hexdigest()
preference = qualities(['preview', '360', '540', 'Source']) preference = qualities(['preview', '360', '540', 'Source'])
files = self._download_json(fileurl, video_id, headers={'X-Version': x_version}) files = self._download_json(fileurl, video_id, headers={'X-Version': x_version}, impersonate=True)
for fmt in files: for fmt in files:
yield traverse_obj(fmt, { yield traverse_obj(fmt, {
'format_id': 'name', 'format_id': 'name',
@ -164,8 +170,8 @@ class IwaraIE(IwaraBaseIE):
def _real_extract(self, url): def _real_extract(self, url):
video_id = self._match_id(url) video_id = self._match_id(url)
username, _ = self._get_login_info() username, _ = self._get_login_info()
video_data = self._download_json( video_data = self._call_api(
f'https://api.iwara.tv/video/{video_id}', video_id, f'video/{video_id}', video_id,
expected_status=lambda x: True, headers=self._get_media_token()) expected_status=lambda x: True, headers=self._get_media_token())
errmsg = video_data.get('message') errmsg = video_data.get('message')
# at this point we can actually get uploaded user info, but do we need it? # at this point we can actually get uploaded user info, but do we need it?
@ -237,8 +243,8 @@ class IwaraUserIE(IwaraBaseIE):
}] }]
def _entries(self, playlist_id, user_id, page): def _entries(self, playlist_id, user_id, page):
videos = self._download_json( videos = self._call_api(
'https://api.iwara.tv/videos', playlist_id, 'videos', playlist_id,
note=f'Downloading page {page}', note=f'Downloading page {page}',
query={ query={
'page': page, 'page': page,
@ -251,8 +257,8 @@ class IwaraUserIE(IwaraBaseIE):
def _real_extract(self, url): def _real_extract(self, url):
playlist_id = self._match_id(url) playlist_id = self._match_id(url)
user_info = self._download_json( user_info = self._call_api(
f'https://api.iwara.tv/profile/{playlist_id}', playlist_id, f'profile/{playlist_id}', playlist_id,
note='Requesting user info') note='Requesting user info')
user_id = traverse_obj(user_info, ('user', 'id')) user_id = traverse_obj(user_info, ('user', 'id'))
@ -277,8 +283,8 @@ class IwaraPlaylistIE(IwaraBaseIE):
}] }]
def _entries(self, playlist_id, first_page, page): def _entries(self, playlist_id, first_page, page):
videos = self._download_json( videos = self._call_api(
'https://api.iwara.tv/videos', playlist_id, f'Downloading page {page}', 'videos', playlist_id, note=f'Downloading page {page}',
query={'page': page, 'limit': self._PER_PAGE}, query={'page': page, 'limit': self._PER_PAGE},
headers=self._get_media_token()) if page else first_page headers=self._get_media_token()) if page else first_page
for x in traverse_obj(videos, ('results', ..., 'id')): for x in traverse_obj(videos, ('results', ..., 'id')):
@ -286,9 +292,11 @@ class IwaraPlaylistIE(IwaraBaseIE):
def _real_extract(self, url): def _real_extract(self, url):
playlist_id = self._match_id(url) playlist_id = self._match_id(url)
page_0 = self._download_json( page_0 = self._call_api(
f'https://api.iwara.tv/playlist/{playlist_id}?page=0&limit={self._PER_PAGE}', playlist_id, f'playlist/{playlist_id}', playlist_id,
note='Requesting playlist info', headers=self._get_media_token()) note='Requesting playlist info',
query={'page': 0, 'limit': self._PER_PAGE},
headers=self._get_media_token())
return self.playlist_result( return self.playlist_result(
OnDemandPagedList( OnDemandPagedList(