yt_dlp/extractor/imggaming.py

   1 # coding: utf-8
   2 from __future__ import unicode_literals
   3
   4 import json
   5
   6 from .common import InfoExtractor
   7 from ..compat import compat_HTTPError
   8 from ..utils import (
   9     ExtractorError,
  10     int_or_none,
  11     str_or_none,
  12     try_get,
  13 )
  14
  15
  16 class ImgGamingBaseIE(InfoExtractor):
  17     _API_BASE = 'https://dce-frontoffice.imggaming.com/api/v2/'
  18     _API_KEY = '857a1e5d-e35e-4fdf-805b-a87b6f8364bf'
  19     _HEADERS = None
  20     _MANIFEST_HEADERS = {'Accept-Encoding': 'identity'}
  21     _REALM = None
  22     _VALID_URL_TEMPL = r'https?://(?P<domain>%s)/(?P<type>live|playlist|video)/(?P<id>\d+)(?:\?.*?\bplaylistId=(?P<playlist_id>\d+))?'
  23
  24     def _initialize_pre_login(self):
  25         self._HEADERS = {
  26             'Realm': 'dce.' + self._REALM,
  27             'x-api-key': self._API_KEY,
  28         }
  29
  30     def _perform_login(self, username, password):
  31         p_headers = self._HEADERS.copy()
  32         p_headers['Content-Type'] = 'application/json'
  33         self._HEADERS['Authorization'] = 'Bearer ' + self._download_json(
  34             self._API_BASE + 'login',
  35             None, 'Logging in', data=json.dumps({
  36                 'id': username,
  37                 'secret': password,
  38             }).encode(), headers=p_headers)['authorisationToken']
  39
  40     def _real_initialize(self):
  41         if not self._HEADERS.get('Authorization'):
  42             self.raise_login_required(method='password')
  43
  44     def _call_api(self, path, media_id):
  45         return self._download_json(
  46             self._API_BASE + path + media_id, media_id, headers=self._HEADERS)
  47
  48     def _extract_dve_api_url(self, media_id, media_type):
  49         stream_path = 'stream'
  50         if media_type == 'video':
  51             stream_path += '/vod/'
  52         else:
  53             stream_path += '?eventId='
  54         try:
  55             return self._call_api(
  56                 stream_path, media_id)['playerUrlCallback']
  57         except ExtractorError as e:
  58             if isinstance(e.cause, compat_HTTPError) and e.cause.code == 403:
  59                 raise ExtractorError(
  60                     self._parse_json(e.cause.read().decode(), media_id)['messages'][0],
  61                     expected=True)
  62             raise
  63
  64     def _real_extract(self, url):
  65         domain, media_type, media_id, playlist_id = self._match_valid_url(url).groups()
  66
  67         if playlist_id:
  68             if self._yes_playlist(playlist_id, media_id):
  69                 media_type, media_id = 'playlist', playlist_id
  70
  71         if media_type == 'playlist':
  72             playlist = self._call_api('vod/playlist/', media_id)
  73             entries = []
  74             for video in try_get(playlist, lambda x: x['videos']['vods']) or []:
  75                 video_id = str_or_none(video.get('id'))
  76                 if not video_id:
  77                     continue
  78                 entries.append(self.url_result(
  79                     'https://%s/video/%s' % (domain, video_id),
  80                     self.ie_key(), video_id))
  81             return self.playlist_result(
  82                 entries, media_id, playlist.get('title'),
  83                 playlist.get('description'))
  84
  85         dve_api_url = self._extract_dve_api_url(media_id, media_type)
  86         video_data = self._download_json(dve_api_url, media_id)
  87         is_live = media_type == 'live'
  88         if is_live:
  89             title = self._call_api('event/', media_id)['title']
  90         else:
  91             title = video_data['name']
  92
  93         formats = []
  94         for proto in ('hls', 'dash'):
  95             media_url = video_data.get(proto + 'Url') or try_get(video_data, lambda x: x[proto]['url'])
  96             if not media_url:
  97                 continue
  98             if proto == 'hls':
  99                 m3u8_formats = self._extract_m3u8_formats(
 100                     media_url, media_id, 'mp4', live=is_live,
 101                     m3u8_id='hls', fatal=False, headers=self._MANIFEST_HEADERS)
 102                 for f in m3u8_formats:
 103                     f.setdefault('http_headers', {}).update(self._MANIFEST_HEADERS)
 104                     formats.append(f)
 105             else:
 106                 formats.extend(self._extract_mpd_formats(
 107                     media_url, media_id, mpd_id='dash', fatal=False,
 108                     headers=self._MANIFEST_HEADERS))
 109         self._sort_formats(formats)
 110
 111         subtitles = {}
 112         for subtitle in video_data.get('subtitles', []):
 113             subtitle_url = subtitle.get('url')
 114             if not subtitle_url:
 115                 continue
 116             subtitles.setdefault(subtitle.get('lang', 'en_US'), []).append({
 117                 'url': subtitle_url,
 118             })
 119
 120         return {
 121             'id': media_id,
 122             'title': title,
 123             'formats': formats,
 124             'thumbnail': video_data.get('thumbnailUrl'),
 125             'description': video_data.get('description'),
 126             'duration': int_or_none(video_data.get('duration')),
 127             'tags': video_data.get('tags'),
 128             'is_live': is_live,
 129             'subtitles': subtitles,
 130         }