aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--youtube/util.py8
-rw-r--r--youtube/watch.py53
-rw-r--r--youtube/yt_data_extract/__init__.py3
3 files changed, 63 insertions, 1 deletions
diff --git a/youtube/util.py b/youtube/util.py
index f209060..a5bd874 100644
--- a/youtube/util.py
+++ b/youtube/util.py
@@ -195,6 +195,14 @@ def fetch_url(url, headers=(), timeout=15, report_text=None, data=None, cookieja
return content, response
return content
+def head(url, use_tor=False, report_text=None):
+ pool = get_pool(use_tor and settings.route_tor)
+ start_time = time.time()
+ response = pool.request('HEAD', url)
+ if report_text:
+ print(report_text, ' Latency:', round(time.time() - start_time,3))
+ return response
+
mobile_user_agent = 'Mozilla/5.0 (Linux; Android 7.0; Redmi Note 4 Build/NRD90M) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/69.0.3497.100 Mobile Safari/537.36'
mobile_ua = (('User-Agent', mobile_user_agent),)
desktop_user_agent = 'Mozilla/5.0 (Windows NT 6.1; rv:52.0) Gecko/20100101 Firefox/52.0'
diff --git a/youtube/watch.py b/youtube/watch.py
index 388a8e1..ceca4cd 100644
--- a/youtube/watch.py
+++ b/youtube/watch.py
@@ -12,6 +12,8 @@ import os
import math
import traceback
import urllib
+import re
+import urllib3.exceptions
try:
with open(os.path.join(settings.data_dir, 'decrypt_function_cache.json'), 'r') as f:
@@ -232,6 +234,57 @@ def extract_info(video_id):
decryption_error = 'Error decrypting url signatures: ' + decryption_error
info['playability_error'] = decryption_error
+ # check for 403
+ if settings.route_tor and info['formats'] and info['formats'][0]['url']:
+ response = util.head(info['formats'][0]['url'],
+ report_text='Checked for URL access')
+ if response.status == 403:
+ print(('Access denied (403) for video urls.'
+ ' Retrieving urls from Invidious...'))
+ try:
+ video_info = util.fetch_url(
+ 'https://invidio.us/api/v1/videos/'
+ + video_id
+ + '?fields=adaptiveFormats,formatStreams',
+ report_text='Retrieved urls from Invidious',
+ debug_name='invidious_urls')
+ except (urllib3.exceptions.HTTPError) as e:
+ traceback.print_exc()
+ playability_error = ('Access denied (403) for video urls.'
+ + ' Failed to use Invidious to get the urls: '
+ + str(e))
+ if info['playability_error']:
+ info['playability_error'] += '\n' + playability_error
+ else:
+ info['playability_error'] = playability_error
+
+ return info
+
+ video_info = json.loads(video_info.decode('utf-8'))
+ info['formats'] = []
+ for fmt in (video_info['adaptiveFormats']
+ + video_info['formatStreams']):
+ # adjust keys to match our conventions
+ fmt['file_size'] = fmt.get('clen')
+ fmt['ext'] = fmt.get('container')
+ if 'resolution' in fmt:
+ fmt['height'] = int(fmt['resolution'].rstrip('p'))
+
+ # update with information from _formats table such as ext
+ itag = fmt.get('itag')
+ fmt.update(yt_data_extract._formats.get(itag, {}))
+
+ # extract acodec, vcodec, and ext
+ # (need for 'ext' because 'container' not always present)
+ yt_data_extract.update_format_with_type_info(fmt, fmt)
+
+ # ensure keys are present
+ for key in ('ext', 'audio_bitrate', 'acodec', 'vcodec',
+ 'width', 'height', 'audio_sample_rate', 'fps'):
+ if key not in fmt:
+ fmt[key] = None
+
+ info['formats'].append(fmt)
return info
def video_quality_string(format):
diff --git a/youtube/yt_data_extract/__init__.py b/youtube/yt_data_extract/__init__.py
index 898141e..3378b8d 100644
--- a/youtube/yt_data_extract/__init__.py
+++ b/youtube/yt_data_extract/__init__.py
@@ -8,4 +8,5 @@ from .everything_else import (extract_channel_info, extract_search_info,
from .watch_extraction import (extract_watch_info, get_caption_url,
update_with_age_restricted_info, requires_decryption,
- extract_decryption_function, decrypt_signatures)
+ extract_decryption_function, decrypt_signatures, _formats,
+ update_format_with_type_info)