+ def _yield_dmc_formats(self, api_data, video_id):
+ dmc_data = traverse_obj(api_data, ('media', 'delivery', 'movie'))
+ audios = traverse_obj(dmc_data, ('audios', ..., {dict}))
+ videos = traverse_obj(dmc_data, ('videos', ..., {dict}))
+ protocols = traverse_obj(dmc_data, ('session', 'protocols', ..., {str}))
+ if not all((audios, videos, protocols)):
+ return
+
+ for audio_quality, video_quality, protocol in itertools.product(audios, videos, protocols):
+ if fmt := self._extract_format_for_quality(video_id, audio_quality, video_quality, protocol):
+ yield fmt
+
+ def _yield_dms_formats(self, api_data, video_id):
+ fmt_filter = lambda _, v: v['isAvailable'] and v['id']
+ videos = traverse_obj(api_data, ('media', 'domand', 'videos', fmt_filter))
+ audios = traverse_obj(api_data, ('media', 'domand', 'audios', fmt_filter))
+ access_key = traverse_obj(api_data, ('media', 'domand', 'accessRightKey', {str}))
+ track_id = traverse_obj(api_data, ('client', 'watchTrackId', {str}))
+ if not all((videos, audios, access_key, track_id)):
+ return
+
+ dms_m3u8_url = self._download_json(
+ f'https://nvapi.nicovideo.jp/v1/watch/{video_id}/access-rights/hls', video_id,
+ data=json.dumps({
+ 'outputs': list(itertools.product((v['id'] for v in videos), (a['id'] for a in audios)))
+ }).encode(), query={'actionTrackId': track_id}, headers={
+ 'x-access-right-key': access_key,
+ 'x-frontend-id': 6,
+ 'x-frontend-version': 0,
+ 'x-request-with': 'https://www.nicovideo.jp',
+ })['data']['contentUrl']
+ # Getting all audio formats results in duplicate video formats which we filter out later
+ dms_fmts = self._extract_m3u8_formats(dms_m3u8_url, video_id)
+
+ # m3u8 extraction does not provide audio bitrates, so extract from the API data and fix
+ for audio_fmt in traverse_obj(dms_fmts, lambda _, v: v['vcodec'] == 'none'):
+ yield {
+ **audio_fmt,
+ **traverse_obj(audios, (lambda _, v: audio_fmt['format_id'].startswith(v['id']), {
+ 'format_id': ('id', {str}),
+ 'abr': ('bitRate', {functools.partial(float_or_none, scale=1000)}),
+ 'asr': ('samplingRate', {int_or_none}),
+ }), get_all=False),
+ 'acodec': 'aac',
+ 'ext': 'm4a',
+ }
+
+ # Sort before removing dupes to keep the format dicts with the lowest tbr
+ video_fmts = sorted((fmt for fmt in dms_fmts if fmt['vcodec'] != 'none'), key=lambda f: f['tbr'])
+ self._remove_duplicate_formats(video_fmts)
+ # Calculate the true vbr/tbr by subtracting the lowest abr
+ min_abr = min(traverse_obj(audios, (..., 'bitRate', {float_or_none})), default=0) / 1000
+ for video_fmt in video_fmts:
+ video_fmt['tbr'] -= min_abr
+ video_fmt['format_id'] = f'video-{video_fmt["tbr"]:.0f}'
+ yield video_fmt
+