-
-
Notifications
You must be signed in to change notification settings - Fork 143
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Implement HLS streams parsing + add safari, tv, and androidVr yt clients
- Loading branch information
Showing
20 changed files
with
738 additions
and
41 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,202 @@ | ||
| import 'package:freezed_annotation/freezed_annotation.dart'; | ||
| import 'package:http_parser/src/media_type.dart'; | ||
| import 'package:logging/logging.dart'; | ||
|
|
||
| import 'models/stream_info_provider.dart'; | ||
|
|
||
| typedef VideoInfo = ({String url, Map<String, String> params}); | ||
| typedef SegmentInfo = ({String url, double duration}); | ||
|
|
||
| @internal | ||
| class HlsManifest { | ||
| static final _logger = Logger('YoutubeExplode.HLSManifest'); | ||
| final List<VideoInfo> videos; | ||
|
|
||
| const HlsManifest(this.videos); | ||
|
|
||
| /// [hlsFile] is the content of the HLS file with lines separated by '\n' | ||
| static HlsManifest parse(String hlsFile) { | ||
| final lines = hlsFile.trim().split('\n'); | ||
| assert(lines[0] == '#EXTM3U'); | ||
| assert(lines[1] == '#EXT-X-INDEPENDENT-SEGMENTS'); | ||
| final videos = <VideoInfo>[]; | ||
| final expr = RegExp('([^,]+)=("[^"]*"|[^,]*)'); | ||
| for (var i = 2; i < lines.length; i += 1) { | ||
| final line = lines[i]; | ||
| final params = { | ||
| for (final match in expr.allMatches(line, line.indexOf(':') + 1)) | ||
| match.group(1)!: match.group(2)!, | ||
| }; | ||
| if (line.startsWith('#EXT-X-MEDIA:')) { | ||
| final url = params['URI']!; | ||
| // Trim the quotes | ||
| videos.add((url: url.substring(1, url.length - 1), params: params)); | ||
| continue; | ||
| } | ||
| if (line.startsWith('#EXT-X-STREAM-INF:')) { | ||
| final url = lines[i + 1]; | ||
| videos.add((url: url, params: params)); | ||
| i++; | ||
| continue; | ||
| } | ||
| _logger.warning('Unknown HLS line: $line'); | ||
| } | ||
| return HlsManifest(videos); | ||
| } | ||
|
|
||
| List<_StreamInfo> get streams { | ||
| final streams = <_StreamInfo>[]; | ||
| for (final video in videos) { | ||
| // The tag is the number after the /itag/ segment in the url | ||
| final videoParts = video.url.split('/'); | ||
| final itag = int.parse(videoParts[videoParts.indexOf('itag') + 1]); | ||
| // To find the file size look for the segments after the sgoap and sgovp parameters (audio + video) | ||
| // Then URL decode the value and find the clen= parameter | ||
| String? sgoap; | ||
| String? sgovp; | ||
| final sgoapIndex = videoParts.indexOf('sgoap'); | ||
| final sgovpIndex = videoParts.indexOf('sgovp'); | ||
| if (sgoapIndex != -1) { | ||
| sgoap = Uri.decodeFull(videoParts[sgoapIndex + 1]); | ||
| } | ||
| if (sgovpIndex != -1) { | ||
| sgovp = Uri.decodeFull(videoParts[sgovpIndex + 1]); | ||
| } | ||
|
|
||
| int? audioClen; | ||
| int? videoClen; | ||
| if (sgoap != null) { | ||
| audioClen = | ||
| int.parse(RegExp(r'clen=(\d+)').firstMatch(sgoap)!.group(1)!); | ||
| } | ||
| if (sgovp != null) { | ||
| videoClen = | ||
| int.parse(RegExp(r'clen=(\d+)').firstMatch(sgovp)!.group(1)!); | ||
| } | ||
|
|
||
| final bandwidth = int.tryParse(video.params['BANDWIDTH'] ?? ''); | ||
| final codecs = video.params['CODECS']?.replaceAll('"', '').split(','); | ||
| final audioCodec = codecs?.first; | ||
| final videoCodec = codecs?.last; | ||
| final resolution = video.params['RESOLUTION']?.split('x'); | ||
| final videoWidth = int.tryParse(resolution?[0] ?? ''); | ||
| final videoHeight = int.tryParse(resolution?[1] ?? ''); | ||
| final framerate = int.tryParse(video.params['FRAME-RATE'] ?? ''); | ||
|
|
||
| streams.add( | ||
| _StreamInfo( | ||
| itag, | ||
| video.url, | ||
| audioCodec, | ||
| videoCodec, | ||
| resolution != null ? '${videoWidth}x$videoHeight' : null, | ||
| videoWidth, | ||
| videoHeight, | ||
| framerate, | ||
| (audioClen ?? 0) + (videoClen ?? 0), | ||
| bandwidth ?? 0, | ||
| videoClen == null, | ||
| audioClen == null, | ||
| ), | ||
| ); | ||
| } | ||
| return streams; | ||
| } | ||
|
|
||
| static List<SegmentInfo> parseVideoSegments(String hlsFile) { | ||
| final lines = hlsFile.trim().split('\n'); | ||
| assert(lines[0] == '#EXTM3U'); | ||
| assert(lines[1] == '#EXT-X-VERSION:3'); | ||
| assert(lines[2] == '#EXT-X-PLAYLIST-TYPE:VOD'); | ||
| assert(lines[3].startsWith('#EXT-X-TARGETDURATION:')); | ||
| final segments = <SegmentInfo>[]; | ||
| for (var i = 4; i < lines.length; i += 2) { | ||
| if (lines[i] == '#EXT-X-ENDLIST') { | ||
| break; | ||
| } | ||
| final duration = double.parse( | ||
| lines[i].substring('#EXTINF:'.length, lines[i].length - 1)); | ||
| final url = lines[i + 1]; | ||
| segments.add((url: url, duration: duration)); | ||
| } | ||
| return segments; | ||
| } | ||
| } | ||
|
|
||
| /* | ||
| BANDWIDTH=202508,CODECS="mp4a.40.5,avc1.4d400c",RESOLUTION=256x144,FRAME-RATE=30,VIDEO-RANGE=SDR,CLOSED-CAPTIONS=NONE | ||
| The hls stream provide the following information: | ||
| - BANDWIDTH: bytes | ||
| - CODECS: comma separated list of codecs | ||
| - RESOLUTION: width x height | ||
| - FRAME-RATE: frames per second | ||
| from the url: | ||
| - itag | ||
| */ | ||
| class _StreamInfo extends StreamInfoProvider { | ||
| @override | ||
| final int tag; | ||
|
|
||
| @override | ||
| final String url; | ||
|
|
||
| @override | ||
| String get container => 'm3u8'; | ||
|
|
||
| @override | ||
| final String? audioCodec; | ||
|
|
||
| @override | ||
| final String? videoCodec; | ||
|
|
||
| @override | ||
| final MediaType codec; | ||
|
|
||
| @override | ||
| final String? qualityLabel; | ||
|
|
||
| @override | ||
| final int? videoWidth; | ||
|
|
||
| @override | ||
| final int? videoHeight; | ||
|
|
||
| @override | ||
| final int? framerate; | ||
|
|
||
| @override | ||
| final int contentLength; | ||
|
|
||
| @override | ||
| final int bitrate; | ||
|
|
||
| @override | ||
| final bool audioOnly; | ||
|
|
||
| @override | ||
| final bool videoOnly; | ||
|
|
||
| _StreamInfo( | ||
| this.tag, | ||
| this.url, | ||
| this.audioCodec, | ||
| this.videoCodec, | ||
| this.qualityLabel, | ||
| this.videoWidth, | ||
| this.videoHeight, | ||
| this.framerate, | ||
| this.contentLength, | ||
| this.bitrate, | ||
| this.audioOnly, | ||
| this.videoOnly, | ||
| ) : codec = MediaType('application', 'vnd.apple.mpegurl', { | ||
| 'codecs': [ | ||
| if (audioCodec != null) audioCodec, | ||
| if (videoCodec != null) videoCodec, | ||
| ].join(',') | ||
| }); | ||
|
|
||
| @override | ||
| StreamSource get source => StreamSource.hls; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,6 @@ | ||
|
|
||
| import '../../../../youtube_explode_dart.dart'; | ||
|
|
||
| mixin HlsStreamInfo on StreamInfo { | ||
| int? get audioItag => null; | ||
| } |
Oops, something went wrong.