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 _real_initialize(self):
  25         self._HEADERS = {
  26             'Realm': 'dce.' + self._REALM,
  27             'x-api-key': self._API_KEY,
  28         }
  29
  30         email, password = self._get_login_info()
  31         if email is None:
  32             self.raise_login_required()
  33
  34         p_headers = self._HEADERS.copy()
  35         p_headers['Content-Type'] = 'application/json'
  36         self._HEADERS['Authorization'] = 'Bearer ' + self._download_json(
  37             self._API_BASE + 'login',
  38             None, 'Logging in', data=json.dumps({
  39                 'id': email,
  40                 'secret': password,
  41             }).encode(), headers=p_headers)['authorisationToken']
  42
  43     def _call_api(self, path, media_id):
  44         return self._download_json(
  45             self._API_BASE + path + media_id, media_id, headers=self._HEADERS)
  46
  47     def _extract_dve_api_url(self, media_id, media_type):
  48         stream_path = 'stream'
  49         if media_type == 'video':
  50             stream_path += '/vod/'
  51         else:
  52             stream_path += '?eventId='
  53         try:
  54             return self._call_api(
  55                 stream_path, media_id)['playerUrlCallback']
  56         except ExtractorError as e:
  57             if isinstance(e.cause, compat_HTTPError) and e.cause.code == 403:
  58                 raise ExtractorError(
  59                     self._parse_json(e.cause.read().decode(), media_id)['messages'][0],
  60                     expected=True)
  61             raise
  62
  63     def _real_extract(self, url):
  64         domain, media_type, media_id, playlist_id = self._match_valid_url(url).groups()
  65
  66         if playlist_id:
  67             if self._yes_playlist(playlist_id, media_id):
  68                 media_type, media_id = 'playlist', playlist_id
  69
  70         if media_type == 'playlist':
  71             playlist = self._call_api('vod/playlist/', media_id)
  72             entries = []
  73             for video in try_get(playlist, lambda x: x['videos']['vods']) or []:
  74                 video_id = str_or_none(video.get('id'))
  75                 if not video_id:
  76                     continue
  77                 entries.append(self.url_result(
  78                     'https://%s/video/%s' % (domain, video_id),
  79                     self.ie_key(), video_id))
  80             return self.playlist_result(
  81                 entries, media_id, playlist.get('title'),
  82                 playlist.get('description'))
  83
  84         dve_api_url = self._extract_dve_api_url(media_id, media_type)
  85         video_data = self._download_json(dve_api_url, media_id)
  86         is_live = media_type == 'live'
  87         if is_live:
  88             title = self._call_api('event/', media_id)['title']
  89         else:
  90             title = video_data['name']
  91
  92         formats = []
  93         for proto in ('hls', 'dash'):
  94             media_url = video_data.get(proto + 'Url') or try_get(video_data, lambda x: x[proto]['url'])
  95             if not media_url:
  96                 continue
  97             if proto == 'hls':
  98                 m3u8_formats = self._extract_m3u8_formats(
  99                     media_url, media_id, 'mp4', 'm3u8' if is_live else 'm3u8_native',
 100                     m3u8_id='hls', fatal=False, headers=self._MANIFEST_HEADERS)
 101                 for f in m3u8_formats:
 102                     f.setdefault('http_headers', {}).update(self._MANIFEST_HEADERS)
 103                     formats.append(f)
 104             else:
 105                 formats.extend(self._extract_mpd_formats(
 106                     media_url, media_id, mpd_id='dash', fatal=False,
 107                     headers=self._MANIFEST_HEADERS))
 108         self._sort_formats(formats)
 109
 110         subtitles = {}
 111         for subtitle in video_data.get('subtitles', []):
 112             subtitle_url = subtitle.get('url')
 113             if not subtitle_url:
 114                 continue
 115             subtitles.setdefault(subtitle.get('lang', 'en_US'), []).append({
 116                 'url': subtitle_url,
 117             })
 118
 119         return {
 120             'id': media_id,
 121             'title': title,
 122             'formats': formats,
 123             'thumbnail': video_data.get('thumbnailUrl'),
 124             'description': video_data.get('description'),
 125             'duration': int_or_none(video_data.get('duration')),
 126             'tags': video_data.get('tags'),
 127             'is_live': is_live,
 128             'subtitles': subtitles,
 129         }