Shaka Player 파헤치기 - HLS 매니페스트 파서#

1// hls_parser.js — start()
2async start(uri, playerInterface) {
3  this.playerInterface_ = playerInterface;
4  this.lowLatencyMode_ = playerInterface.isLowLatencyMode();
5
6  const response = await this.requestManifest_([uri]).promise;
7
8  // 리다이렉트까지 반영된 최종 마스터 플레이리스트 URI를 기록
9  this.masterPlaylistUri_ = response.uri;
10
11  await this.parseManifest_(response.data); // 실제 작업은 전부 여기
12
13  goog.asserts.assert(this.manifest_, 'Manifest should be non-null');
14  return this.manifest_;
15}

1// hls_parser.js — parseManifest_ (발췌)
2const playlist = this.manifestTextParser_.parsePlaylist(data);
3
4// 처음에는 VOD인지 LIVE인지 모른다. 일단 static(VOD)으로 만들어 두고
5// 나중에 라이브로 판명되면 바꾼다.
6this.presentationTimeline_ = new shaka.media.PresentationTimeline(
7    /* presentationStartTime= */ null, /* delay= */ 0);
8this.presentationTimeline_.setStatic(true);
9
10this.manifest_ = {
11  presentationTimeline: this.presentationTimeline_,
12  variants, textStreams, imageStreams,
13  chapterStreams: [], offlineSessionIds: [],
14  type: shaka.media.ManifestParser.HLS,
15  periodCount: 1, // HLS엔 Period 개념이 없으므로 항상 1
16  // ...
17};
18
19if (playlist.type == shaka.hls.PlaylistType.MEDIA) {
20  // 미디어 플레이리스트를 직접 받은 경우 → 단일 variant
21} else {
22  // 마스터 플레이리스트 → 태그를 이름별로 수집
23  this.parseMasterVariables_(variablesTags);
24  const mediaTags   = Utils.filterTagsByName(playlist.tags, 'EXT-X-MEDIA');
25  const variantTags = Utils.filterTagsByName(playlist.tags, 'EXT-X-STREAM-INF');
26  const imageTags   = Utils.filterTagsByName(playlist.tags, 'EXT-X-IMAGE-STREAM-INF');
27  const iFrameTags  = Utils.filterTagsByName(playlist.tags, 'EXT-X-I-FRAME-STREAM-INF');
28  const sessionKeyTags = Utils.filterTagsByName(playlist.tags, 'EXT-X-SESSION-KEY');
29  // EXT-X-SESSION-DATA, EXT-X-CONTENT-STEERING ...
30
31  variants    = await this.createVariantsForTags_(variantTags, sessionKeyTags, mediaTags, ...);
32  textStreams = this.parseTexts_(mediaTags);
33  [imageStreams] = await Promise.all([this.parseImages_(imageTags, iFrameTags), this.parseChapters_()]);
34}

1// hls_parser.js — createStreamInfo_ (발췌)
2// This stream is lazy-loaded inside the createSegmentIndex function.
3// So we start out with a stream object that does not contain the actual
4// segment index, then download when createSegmentIndex is called.
5const stream = this.makeStreamObject_(streamId, codecs, type, ...);
6
7const streamInfo = {
8  stream, type, redirectUris: [], getUris: () => {},
9  // 아래 값들은 lazy-load 이후에 채워진다:
10  minTimestamp: 0, maxTimestamp: 0,
11  hasEndList: false, canBlockReload: false,
12  // ...
13};

1// hls_parser.js — createStreamInfo_ 내부 downloadSegmentIndex (발췌)
2const downloadSegmentIndex = async (pendingRequest) => {
3  // 비로소 이 variant의 미디어 플레이리스트를 네트워크에서 받아 와
4  const realStreamInfo = await this.convertParsedPlaylistIntoStreamInfo_(
5      streamId, mediaVariables, playlist, getUris, codecs, type, ...);
6  // 받은 정보로 비어 있던 streamInfo를 채운다
7  streamInfo.minTimestamp = realStreamInfo.minTimestamp;
8  streamInfo.hasEndList   = realStreamInfo.hasEndList;
9  // ...
10};

1// preload_manager.js — shouldCreateSegmentIndexBeforeDrmEngineInitialization_
2// HLS는 DRM 정보가 보통 미디어 플레이리스트 안에 있어,
3// 그것을 내려받아야(= 세그먼트 인덱스를 만들어야) 진짜 정보를 알 수 있다
4if (this.manifest_.type == shaka.media.ManifestParser.HLS) {
5  return true;
6}

1// hls_parser.js — EXT-X-KEY 태그 처리 (발췌)
2for (const tag of tags) {
3  if (tag.name == 'EXT-X-KEY') {
4    const method = tag.getRequiredAttrValue('METHOD'); // SAMPLE-AES, AES-128, NONE ...
5    if (this.isAesMethod_(method) && tag.id < mapTag.id) {
6      aesKey = this.parseAESDrmTag_(tag, playlist, getUris, variables);
7    } else {
8      encrypted = method != 'NONE';
9    }
10  }
11}

1// hls_parser.js — 미디어 플레이리스트를 파싱한 뒤
2if (this.isDynamic_() && !wasDynamic) {
3  // 라이브로 판명되었으니, 타임라인을 라이브로 전환한다
4  this.changePresentationTimelineToLive_(playlist);
5}

1// hls_parser.js — update() (발췌)
2const stillDynamic = activeStreamInfos.some((s) => s.hasEndList == false);
3if (activeStreamInfos.length && !stillDynamic) {
4  // 모든 스트림이 끝났다 → VOD로 전환
5  this.setPresentationType_(shaka.hls.HlsParser.PresentationType_.VOD);
6  this.determineDuration_();
7}

1// hls_parser.js — update() (발췌)
2const activeStreamInfos = streamInfos.filter(
3    (s) => !s.stream.isAudioMuxedInVideo && s.stream.segmentIndex);
4
5for (const streamInfo of activeStreamInfos) {
6  updates.push(this.updateStream_(streamInfo)); // 스트림별로 미디어 플레이리스트 reload
7}
8await Promise.all(updates);

1// hls_parser.js — updateStream_ (발췌)
2if (streamInfo.canBlockReload) {
3  if (streamInfo.nextMediaSequence >= 0) {
4    // LL-HLS: 서버가 다음 세그먼트를 만들 때까지 응답을 보류하게 한다
5    params.set('_HLS_msn', String(streamInfo.nextMediaSequence));
6  }
7  if (streamInfo.nextPart >= 0) {
8    params.set('_HLS_part', String(streamInfo.nextPart));
9  }
10}
11if (streamInfo.canSkipDateRanges) {
12  // 델타 업데이트: 오래된 세그먼트를 생략하고 EXT-X-SKIP으로 대체
13  params.set('_HLS_skip', 'v2');
14}

1// 두 파서 모두 이 모양의 객체를 반환한다
2this.manifest_ = {
3  presentationTimeline,
4  variants,        // 재생 가능한 트랙 조합
5  textStreams,     // 자막
6  imageStreams,
7  type,            // DASH | HLS
8  // ...
9};