-# coding: utf-8
-from __future__ import unicode_literals
-
import random
import re
import string
from .common import InfoExtractor
-from ..compat import compat_HTTPError
+from ..networking.exceptions import HTTPError
from ..utils import (
+ ExtractorError,
determine_ext,
- dict_get,
int_or_none,
+ join_nonempty,
js_to_json,
+ make_archive_id,
+ orderedSet,
+ qualities,
+ str_or_none,
+ traverse_obj,
+ try_get,
urlencode_postdata,
- urljoin,
- ExtractorError,
)
-class FunimationIE(InfoExtractor):
- _VALID_URL = r'https?://(?:www\.)?funimation(?:\.com|now\.uk)/(?:[^/]+/)?shows/[^/]+/(?P<id>[^/?#&]+)'
-
+class FunimationBaseIE(InfoExtractor):
_NETRC_MACHINE = 'funimation'
+ _REGION = None
_TOKEN = None
+ def _get_region(self):
+ region_cookie = self._get_cookies('https://www.funimation.com').get('region')
+ region = region_cookie.value if region_cookie else self.get_param('geo_bypass_country')
+ return region or traverse_obj(
+ self._download_json(
+ 'https://geo-service.prd.funimationsvc.com/geo/v1/region/check', None, fatal=False,
+ note='Checking geo-location', errnote='Unable to fetch geo-location information'),
+ 'region') or 'US'
+
+ def _perform_login(self, username, password):
+ if self._TOKEN:
+ return
+ try:
+ data = self._download_json(
+ 'https://prod-api-funimationnow.dadcdigital.com/api/auth/login/',
+ None, 'Logging in', data=urlencode_postdata({
+ 'username': username,
+ 'password': password,
+ }))
+ FunimationBaseIE._TOKEN = data['token']
+ except ExtractorError as e:
+ if isinstance(e.cause, HTTPError) and e.cause.status == 401:
+ error = self._parse_json(e.cause.response.read().decode(), None)['error']
+ raise ExtractorError(error, expected=True)
+ raise
+
+
+class FunimationPageIE(FunimationBaseIE):
+ IE_NAME = 'funimation:page'
+ _VALID_URL = r'https?://(?:www\.)?funimation(?:\.com|now\.uk)/(?:(?P<lang>[^/]+)/)?(?:shows|v)/(?P<show>[^/]+)/(?P<episode>[^/?#&]+)'
+
_TESTS = [{
+ 'url': 'https://www.funimation.com/shows/attack-on-titan-junior-high/broadcast-dub-preview/',
+ 'info_dict': {
+ 'id': '210050',
+ 'ext': 'mp4',
+ 'title': 'Broadcast Dub Preview',
+ # Other metadata is tested in FunimationIE
+ },
+ 'params': {
+ 'skip_download': 'm3u8',
+ },
+ 'add_ie': ['Funimation'],
+ }, {
+ # Not available in US
'url': 'https://www.funimation.com/shows/hacksign/role-play/',
+ 'only_matching': True,
+ }, {
+ # with lang code
+ 'url': 'https://www.funimation.com/en/shows/hacksign/role-play/',
+ 'only_matching': True,
+ }, {
+ 'url': 'https://www.funimationnow.uk/shows/puzzle-dragons-x/drop-impact/simulcast/',
+ 'only_matching': True,
+ }, {
+ 'url': 'https://www.funimation.com/v/a-certain-scientific-railgun/super-powered-level-5',
+ 'only_matching': True,
+ }]
+
+ def _real_initialize(self):
+ if not self._REGION:
+ FunimationBaseIE._REGION = self._get_region()
+
+ def _real_extract(self, url):
+ locale, show, episode = self._match_valid_url(url).group('lang', 'show', 'episode')
+
+ video_id = traverse_obj(self._download_json(
+ f'https://title-api.prd.funimationsvc.com/v1/shows/{show}/episodes/{episode}',
+ f'{show}_{episode}', query={
+ 'deviceType': 'web',
+ 'region': self._REGION,
+ 'locale': locale or 'en',
+ }), ('videoList', ..., 'id'), get_all=False)
+
+ return self.url_result(f'https://www.funimation.com/player/{video_id}', FunimationIE.ie_key(), video_id)
+
+
+class FunimationIE(FunimationBaseIE):
+ _VALID_URL = r'https?://(?:www\.)?funimation\.com/player/(?P<id>\d+)'
+
+ _TESTS = [{
+ 'url': 'https://www.funimation.com/player/210051',
'info_dict': {
- 'id': '91144',
- 'display_id': 'role-play',
+ 'id': '210050',
+ 'display_id': 'broadcast-dub-preview',
'ext': 'mp4',
- 'title': '.hack//SIGN - Role Play',
- 'description': 'md5:b602bdc15eef4c9bbb201bb6e6a4a2dd',
- 'thumbnail': r're:https?://.*\.jpg',
+ 'title': 'Broadcast Dub Preview',
+ 'thumbnail': r're:https?://.*\.(?:jpg|png)',
+ 'episode': 'Broadcast Dub Preview',
+ 'episode_id': '210050',
+ 'season': 'Extras',
+ 'season_id': '166038',
+ 'season_number': 99,
+ 'series': 'Attack on Titan: Junior High',
+ 'description': '',
+ 'duration': 155,
},
'params': {
- # m3u8 download
- 'skip_download': True,
+ 'skip_download': 'm3u8',
},
}, {
- 'url': 'https://www.funimation.com/shows/attack-on-titan-junior-high/broadcast-dub-preview/',
+ 'note': 'player_id should be extracted with the relevent compat-opt',
+ 'url': 'https://www.funimation.com/player/210051',
'info_dict': {
'id': '210051',
'display_id': 'broadcast-dub-preview',
'ext': 'mp4',
- 'title': 'Attack on Titan: Junior High - Broadcast Dub Preview',
+ 'title': 'Broadcast Dub Preview',
'thumbnail': r're:https?://.*\.(?:jpg|png)',
+ 'episode': 'Broadcast Dub Preview',
+ 'episode_id': '210050',
+ 'season': 'Extras',
+ 'season_id': '166038',
+ 'season_number': 99,
+ 'series': 'Attack on Titan: Junior High',
+ 'description': '',
+ 'duration': 155,
},
'params': {
- # m3u8 download
- 'skip_download': True,
+ 'skip_download': 'm3u8',
+ 'compat_opts': ['seperate-video-versions'],
},
- }, {
- 'url': 'https://www.funimationnow.uk/shows/puzzle-dragons-x/drop-impact/simulcast/',
- 'only_matching': True,
- }, {
- # with lang code
- 'url': 'https://www.funimation.com/en/shows/hacksign/role-play/',
- 'only_matching': True,
}]
- def _login(self):
- username, password = self._get_login_info()
- if username is None:
- return
- try:
- data = self._download_json(
- 'https://prod-api-funimationnow.dadcdigital.com/api/auth/login/',
- None, 'Logging in', data=urlencode_postdata({
- 'username': username,
- 'password': password,
- }))
- self._TOKEN = data['token']
- except ExtractorError as e:
- if isinstance(e.cause, compat_HTTPError) and e.cause.code == 401:
- error = self._parse_json(e.cause.read().decode(), None)['error']
- raise ExtractorError(error, expected=True)
- raise
+ @staticmethod
+ def _get_experiences(episode):
+ for lang, lang_data in episode.get('languages', {}).items():
+ for video_data in lang_data.values():
+ for version, f in video_data.items():
+ yield lang, version.title(), f
- def _real_initialize(self):
- self._login()
+ def _get_episode(self, webpage, experience_id=None, episode_id=None, fatal=True):
+ """ Extract the episode, season and show objects given either episode/experience id """
+ show = self._parse_json(
+ self._search_regex(
+ r'show\s*=\s*({.+?})\s*;', webpage, 'show data', fatal=fatal),
+ experience_id, transform_source=js_to_json, fatal=fatal) or []
+ for season in show.get('seasons', []):
+ for episode in season.get('episodes', []):
+ if episode_id is not None:
+ if str(episode.get('episodePk')) == episode_id:
+ return episode, season, show
+ continue
+ for _, _, f in self._get_experiences(episode):
+ if f.get('experienceId') == experience_id:
+ return episode, season, show
+ if fatal:
+ raise ExtractorError('Unable to find episode information')
+ else:
+ self.report_warning('Unable to find episode information')
+ return {}, {}, {}
def _real_extract(self, url):
- display_id = self._match_id(url)
- webpage = self._download_webpage(url, display_id)
-
- def _search_kane(name):
- return self._search_regex(
- r"KANE_customdimensions\.%s\s*=\s*'([^']+)';" % name,
- webpage, name, default=None)
-
- title_data = self._parse_json(self._search_regex(
- r'TITLE_DATA\s*=\s*({[^}]+})',
- webpage, 'title data', default=''),
- display_id, js_to_json, fatal=False) or {}
-
- video_id = title_data.get('id') or self._search_regex([
- r"KANE_customdimensions.videoID\s*=\s*'(\d+)';",
- r'<iframe[^>]+src="/player/(\d+)',
- ], webpage, 'video_id', default=None)
- if not video_id:
- player_url = self._html_search_meta([
- 'al:web:url',
- 'og:video:url',
- 'og:video:secure_url',
- ], webpage, fatal=True)
- video_id = self._search_regex(r'/player/(\d+)', player_url, 'video id')
-
- title = episode = title_data.get('title') or _search_kane('videoTitle') or self._og_search_title(webpage)
- series = _search_kane('showName')
- if series:
- title = '%s - %s' % (series, title)
- description = self._html_search_meta(['description', 'og:description'], webpage, fatal=True)
- subtitles = self.extract_subtitles(url, video_id, display_id)
+ initial_experience_id = self._match_id(url)
+ webpage = self._download_webpage(
+ url, initial_experience_id, note=f'Downloading player webpage for {initial_experience_id}')
+ episode, season, show = self._get_episode(webpage, experience_id=int(initial_experience_id))
+ episode_id = str(episode['episodePk'])
+ display_id = episode.get('slug') or episode_id
+
+ formats, subtitles, thumbnails, duration = [], {}, [], 0
+ requested_languages, requested_versions = self._configuration_arg('language'), self._configuration_arg('version')
+ language_preference = qualities((requested_languages or [''])[::-1])
+ source_preference = qualities((requested_versions or ['uncut', 'simulcast'])[::-1])
+ only_initial_experience = 'seperate-video-versions' in self.get_param('compat_opts', [])
+
+ for lang, version, fmt in self._get_experiences(episode):
+ experience_id = str(fmt['experienceId'])
+ if (only_initial_experience and experience_id != initial_experience_id
+ or requested_languages and lang.lower() not in requested_languages
+ or requested_versions and version.lower() not in requested_versions):
+ continue
+ thumbnails.append({'url': fmt.get('poster')})
+ duration = max(duration, fmt.get('duration', 0))
+ format_name = f'{version} {lang} ({experience_id})'
+ self.extract_subtitles(
+ subtitles, experience_id, display_id=display_id, format_name=format_name,
+ episode=episode if experience_id == initial_experience_id else episode_id)
- try:
headers = {}
if self._TOKEN:
- headers['Authorization'] = 'Token %s' % self._TOKEN
- sources = self._download_json(
- 'https://www.funimation.com/api/showexperience/%s/' % video_id,
- video_id, headers=headers, query={
- 'pinst_id': ''.join([random.choice(string.digits + string.ascii_letters) for _ in range(8)]),
- })['items']
- except ExtractorError as e:
- if isinstance(e.cause, compat_HTTPError) and e.cause.code == 403:
- error = self._parse_json(e.cause.read(), video_id)['errors'][0]
- raise ExtractorError('%s said: %s' % (
- self.IE_NAME, error.get('detail') or error.get('title')), expected=True)
- raise
+ headers['Authorization'] = f'Token {self._TOKEN}'
+ page = self._download_json(
+ f'https://www.funimation.com/api/showexperience/{experience_id}/',
+ display_id, headers=headers, expected_status=403, query={
+ 'pinst_id': ''.join(random.choices(string.digits + string.ascii_letters, k=8)),
+ }, note=f'Downloading {format_name} JSON')
+ sources = page.get('items') or []
+ if not sources:
+ error = try_get(page, lambda x: x['errors'][0], dict)
+ if error:
+ self.report_warning('{} said: Error {} - {}'.format(
+ self.IE_NAME, error.get('code'), error.get('detail') or error.get('title')))
+ else:
+ self.report_warning('No sources found for format')
- formats = []
- for source in sources:
- source_url = source.get('src')
- if not source_url:
- continue
- source_type = source.get('videoType') or determine_ext(source_url)
- if source_type == 'm3u8':
- formats.extend(self._extract_m3u8_formats(
- source_url, video_id, 'mp4',
- m3u8_id='hls', fatal=False))
- else:
- formats.append({
- 'format_id': source_type,
- 'url': source_url,
- })
- self._sort_formats(formats)
+ current_formats = []
+ for source in sources:
+ source_url = source.get('src')
+ source_type = source.get('videoType') or determine_ext(source_url)
+ if source_type == 'm3u8':
+ current_formats.extend(self._extract_m3u8_formats(
+ source_url, display_id, 'mp4', m3u8_id='{}-{}'.format(experience_id, 'hls'), fatal=False,
+ note=f'Downloading {format_name} m3u8 information'))
+ else:
+ current_formats.append({
+ 'format_id': f'{experience_id}-{source_type}',
+ 'url': source_url,
+ })
+ for f in current_formats:
+ # TODO: Convert language to code
+ f.update({
+ 'language': lang,
+ 'format_note': version,
+ 'source_preference': source_preference(version.lower()),
+ 'language_preference': language_preference(lang.lower()),
+ })
+ formats.extend(current_formats)
+ if not formats and (requested_languages or requested_versions):
+ self.raise_no_formats(
+ 'There are no video formats matching the requested languages/versions', expected=True, video_id=display_id)
+ self._remove_duplicate_formats(formats)
return {
- 'id': video_id,
+ 'id': episode_id,
+ '_old_archive_ids': [make_archive_id(self, initial_experience_id)],
'display_id': display_id,
- 'title': title,
- 'description': description,
- 'thumbnail': self._og_search_thumbnail(webpage),
- 'series': series,
- 'season_number': int_or_none(title_data.get('seasonNum') or _search_kane('season')),
- 'episode_number': int_or_none(title_data.get('episodeNum')),
- 'episode': episode,
- 'subtitles': subtitles,
- 'season_id': title_data.get('seriesId'),
+ 'duration': duration,
+ 'title': episode['episodeTitle'],
+ 'description': episode.get('episodeSummary'),
+ 'episode': episode.get('episodeTitle'),
+ 'episode_number': int_or_none(episode.get('episodeId')),
+ 'episode_id': episode_id,
+ 'season': season.get('seasonTitle'),
+ 'season_number': int_or_none(season.get('seasonId')),
+ 'season_id': str_or_none(season.get('seasonPk')),
+ 'series': show.get('showTitle'),
'formats': formats,
+ 'thumbnails': thumbnails,
+ 'subtitles': subtitles,
+ '_format_sort_fields': ('lang', 'source'),
}
- def _get_subtitles(self, url, video_id, display_id):
- player_url = urljoin(url, '/player/' + video_id)
- player_page = self._download_webpage(player_url, display_id)
- text_tracks_json_string = self._search_regex(
- r'"textTracks": (\[{.+?}\])',
- player_page, 'subtitles data', default='')
- text_tracks = self._parse_json(
- text_tracks_json_string, display_id, js_to_json, fatal=False) or []
- subtitles = {}
- for text_track in text_tracks:
- url_element = {'url': text_track.get('src')}
- language = text_track.get('language')
- if text_track.get('type') == 'CC':
- language += '_CC'
- subtitles.setdefault(language, []).append(url_element)
+ def _get_subtitles(self, subtitles, experience_id, episode, display_id, format_name):
+ if isinstance(episode, str):
+ webpage = self._download_webpage(
+ f'https://www.funimation.com/player/{experience_id}/', display_id,
+ fatal=False, note=f'Downloading player webpage for {format_name}')
+ episode, _, _ = self._get_episode(webpage, episode_id=episode, fatal=False)
+
+ for _, version, f in self._get_experiences(episode):
+ for source in f.get('sources'):
+ for text_track in source.get('textTracks'):
+ if not text_track.get('src'):
+ continue
+ sub_type = text_track.get('type').upper()
+ sub_type = sub_type if sub_type != 'FULL' else None
+ current_sub = {
+ 'url': text_track['src'],
+ 'name': join_nonempty(version, text_track.get('label'), sub_type, delim=' '),
+ }
+ lang = join_nonempty(text_track.get('language', 'und'),
+ version if version != 'Simulcast' else None,
+ sub_type, delim='_')
+ if current_sub not in subtitles.get(lang, []):
+ subtitles.setdefault(lang, []).append(current_sub)
return subtitles
-class FunimationShowIE(FunimationIE):
+class FunimationShowIE(FunimationBaseIE):
IE_NAME = 'funimation:show'
_VALID_URL = r'(?P<url>https?://(?:www\.)?funimation(?:\.com|now\.uk)/(?P<locale>[^/]+)?/?shows/(?P<id>[^/?#&]+))/?(?:[?#]|$)'
_TESTS = [{
'url': 'https://www.funimation.com/en/shows/sk8-the-infinity',
'info_dict': {
- 'id': 1315000,
- 'title': 'SK8 the Infinity'
+ 'id': '1315000',
+ 'title': 'SK8 the Infinity',
},
'playlist_count': 13,
'params': {
# without lang code
'url': 'https://www.funimation.com/shows/ouran-high-school-host-club/',
'info_dict': {
- 'id': 39643,
- 'title': 'Ouran High School Host Club'
+ 'id': '39643',
+ 'title': 'Ouran High School Host Club',
},
'playlist_count': 26,
'params': {
},
}]
+ def _real_initialize(self):
+ if not self._REGION:
+ FunimationBaseIE._REGION = self._get_region()
+
def _real_extract(self, url):
- base_url, locale, display_id = re.match(self._VALID_URL, url).groups()
+ base_url, locale, display_id = self._match_valid_url(url).groups()
show_info = self._download_json(
- 'https://title-api.prd.funimationsvc.com/v2/shows/%s?region=US&deviceType=web&locale=%s'
- % (display_id, locale or 'en'), display_id)
- items = self._download_json(
- 'https://prod-api-funimationnow.dadcdigital.com/api/funimation/episodes/?limit=99999&title_id=%s'
- % show_info.get('id'), display_id).get('items')
- vod_items = map(lambda k: dict_get(k, ('mostRecentSvod', 'mostRecentAvod')).get('item'), items)
+ 'https://title-api.prd.funimationsvc.com/v2/shows/{}?region={}&deviceType=web&locale={}'.format(
+ display_id, self._REGION, locale or 'en'), display_id)
+ items_info = self._download_json(
+ 'https://prod-api-funimationnow.dadcdigital.com/api/funimation/episodes/?limit=99999&title_id={}'.format(
+ show_info.get('id')), display_id)
+
+ vod_items = traverse_obj(items_info, ('items', ..., lambda k, _: re.match(r'(?i)mostRecent[AS]vod', k), 'item'))
return {
'_type': 'playlist',
- 'id': show_info['id'],
+ 'id': str_or_none(show_info['id']),
'title': show_info['name'],
- 'entries': [
+ 'entries': orderedSet(
self.url_result(
- '%s/%s' % (base_url, vod_item.get('episodeSlug')), FunimationIE.ie_key(),
+ '{}/{}'.format(base_url, vod_item.get('episodeSlug')), FunimationPageIE.ie_key(),
vod_item.get('episodeId'), vod_item.get('episodeName'))
- for vod_item in sorted(vod_items, key=lambda x: x.get('episodeOrder'))],
+ for vod_item in sorted(vod_items, key=lambda x: x.get('episodeOrder', -1))),
}
projects / yt-dlp.git / blobdiff