-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
OfflineVideoSource store functionality. Issue #22
Change-Id: Ib55ce40619929f7139a0651f0e0874a0bd4fc054
- Loading branch information
1 parent
e2f31dd
commit 18a843e
Showing
3 changed files
with
240 additions
and
27 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,213 @@ | ||
| /** | ||
| * Copyright 2015 Google Inc. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| * | ||
| * @fileoverview Implements an offline video source. | ||
| */ | ||
|
|
||
| goog.provide('shaka.player.OfflineVideoSource'); | ||
|
|
||
| goog.require('shaka.asserts'); | ||
| goog.require('shaka.dash.MpdProcessor'); | ||
| goog.require('shaka.dash.MpdRequest'); | ||
| goog.require('shaka.dash.mpd'); | ||
| goog.require('shaka.log'); | ||
| goog.require('shaka.media.EmeManager'); | ||
| goog.require('shaka.media.StreamInfo'); | ||
| goog.require('shaka.player.StreamVideoSource'); | ||
| goog.require('shaka.util.ContentDatabase'); | ||
| goog.require('shaka.util.TypedBind'); | ||
|
|
||
|
|
||
|
|
||
| /** | ||
| * Creates an OfflineVideoSource. | ||
| * @param {?number} groupId The unique ID of the group of streams | ||
| * in this source. | ||
| * @struct | ||
| * @constructor | ||
| * @extends {shaka.player.StreamVideoSource} | ||
| * @export | ||
| */ | ||
| shaka.player.OfflineVideoSource = function(groupId) { | ||
| shaka.player.StreamVideoSource.call(this, null); | ||
|
|
||
| /** @private {?number} */ | ||
| this.groupId_ = groupId; | ||
| }; | ||
| goog.inherits(shaka.player.OfflineVideoSource, shaka.player.StreamVideoSource); | ||
|
|
||
|
|
||
| /** | ||
| * Stores the content described by the MPD for offline playback. | ||
| * @param {string} mpdUrl The MPD URL. | ||
| * @param {string} preferredLanguage The user's preferred language tag. | ||
| * @param {?shaka.player.DashVideoSource.ContentProtectionCallback} | ||
| * interpretContentProtection A callback to interpret the ContentProtection | ||
| * elements in the MPD. | ||
| * @return {!Promise.<number>} The group ID of the stored content. | ||
| */ | ||
| shaka.player.OfflineVideoSource.prototype.store = function( | ||
| mpdUrl, preferredLanguage, interpretContentProtection) { | ||
| var mpdRequest = new shaka.dash.MpdRequest(mpdUrl); | ||
|
|
||
| return mpdRequest.send().then(shaka.util.TypedBind(this, | ||
| /** @param {!shaka.dash.mpd.Mpd} mpd */ | ||
| function(mpd) { | ||
| var mpdProcessor = | ||
| new shaka.dash.MpdProcessor(interpretContentProtection); | ||
| mpdProcessor.process(mpd); | ||
|
|
||
| this.manifestInfo = mpdProcessor.manifestInfo; | ||
| var baseClassLoad = shaka.player.StreamVideoSource.prototype.load; | ||
| return baseClassLoad.call(this, preferredLanguage); | ||
| }) | ||
| ).then(shaka.util.TypedBind(this, | ||
| function() { | ||
| var fakeVideoElement = /** @type {!HTMLVideoElement} */ ( | ||
| document.createElement('video')); | ||
| var emeManager = | ||
| new shaka.media.EmeManager(this, fakeVideoElement, this); | ||
| return emeManager.initialize(); | ||
| }) | ||
| ).then(shaka.util.TypedBind(this, | ||
| function() { | ||
| var selectedStreams = []; | ||
| // TODO (natalieharris) : Add EME support. | ||
| // TODO(story 1890046): Support multiple periods. | ||
| var duration = this.manifestInfo.periodInfos[0].duration; | ||
| if (!duration) { | ||
| shaka.log.warning('The duration of the stream being stored is null.'); | ||
| } | ||
| // Choose the first stream set from each type. | ||
| var streamSetInfos = []; | ||
| var desiredTypes = ['audio', 'video']; | ||
| // TODO (natalieharris) : Add text support. | ||
| for (var i = 0; i < desiredTypes.length; ++i) { | ||
| var type = desiredTypes[i]; | ||
| if (this.streamSetsByType[type]) { | ||
| streamSetInfos.push(this.streamSetsByType[type][0]); | ||
| } | ||
| } | ||
|
|
||
| for (var i = 0; i < streamSetInfos.length; ++i) { | ||
| var streamSetInfo = streamSetInfos[i]; | ||
| shaka.asserts.assert(streamSetInfo.streamInfos.length > 0); | ||
| var streamInfo = this.selectStreamInfo_(streamSetInfo); | ||
| selectedStreams.push(streamInfo); | ||
| } | ||
| return this.insertGroup_(selectedStreams, duration); | ||
| }) | ||
| ); | ||
| }; | ||
|
|
||
|
|
||
| /** | ||
| * Inserts a group of streams into the database. | ||
| * @param {!Array.<!shaka.media.StreamInfo>} streamInfos The streams to insert. | ||
| * @param {number} duration The duration of the entire stream. | ||
| * @return {!Promise.<number>} The unique id assigned to the group. | ||
| * @private | ||
| */ | ||
| shaka.player.OfflineVideoSource.prototype.insertGroup_ = | ||
| function(streamInfos, duration) { | ||
| var streamIds = []; | ||
| var contentDatabase = new shaka.util.ContentDatabase(null); | ||
| var p = contentDatabase.setUpDatabase(); | ||
|
|
||
| // Insert each stream into the database. | ||
| for (var i = 0; i < streamInfos.length; ++i) { | ||
| var getSegmentIndex = | ||
| shaka.media.StreamInfo.prototype.getSegmentIndex.bind(streamInfos[i]); | ||
| var insertStream = (function(i) { | ||
| return contentDatabase.insertStream( | ||
| streamInfos[i].mimeType, | ||
| streamInfos[i].codecs, | ||
| duration, | ||
| streamInfos[i].segmentIndex, | ||
| streamInfos[i].segmentInitializationData); | ||
| }).bind(this, i); | ||
|
|
||
| p = p.then(getSegmentIndex).then(insertStream).then( | ||
| /** @param {number} streamId */ | ||
| function(streamId) { | ||
| streamIds.push(streamId); | ||
| return Promise.resolve(); | ||
| }); | ||
| } | ||
| // Insert information about the group of streams into the database and close | ||
| // the connection. | ||
| p = p.then(function() { | ||
| return contentDatabase.insertGroup(streamIds); | ||
| }).then( | ||
| /** @param {number} groupId */ | ||
| function(groupId) { | ||
| contentDatabase.closeDatabaseConnection(); | ||
| return Promise.resolve(groupId); | ||
| } | ||
| ).catch( | ||
| /** @param {Error} e */ | ||
| function(e) { | ||
| contentDatabase.closeDatabaseConnection(); | ||
| return Promise.reject(e); | ||
| }); | ||
| return p; | ||
| }; | ||
|
|
||
|
|
||
| /** | ||
| * Selects which stream from a stream info set should be stored offline. | ||
| * @param {!shaka.media.StreamSetInfo} streamSetInfo The stream set to select a | ||
| * stream from. | ||
| * @return {!shaka.media.StreamInfo} | ||
| * @private | ||
| */ | ||
| shaka.player.OfflineVideoSource.prototype.selectStreamInfo_ = | ||
| function(streamSetInfo) { | ||
| shaka.asserts.assert(streamSetInfo.streamInfos.length > 0); | ||
| var selected = streamSetInfo.streamInfos[0]; | ||
|
|
||
| if (streamSetInfo.contentType == 'video') { | ||
| streamSetInfo.streamInfos.sort( | ||
| function(a, b) { return a.height - b.height }); | ||
| selected = streamSetInfo.streamInfos[0]; | ||
| for (var i = 1; i < streamSetInfo.streamInfos.length; ++i) { | ||
| // Select stream with height closest to, but not exceeding 480. | ||
| if (streamSetInfo.streamInfos[i].height > 480) { | ||
| break; | ||
| } else { | ||
| selected = streamSetInfo.streamInfos[i]; | ||
| } | ||
| } | ||
| } else if (streamSetInfo.contentType == 'audio') { | ||
| // Choose the middle stream from the available ones. If we have high, | ||
| // medium, and low quality audio, this is medium. If we only have high | ||
| // and low, this is high. | ||
| var index = Math.floor(streamSetInfo.streamInfos.length / 2); | ||
| selected = streamSetInfo.streamInfos[index]; | ||
| } | ||
| return selected; | ||
| }; | ||
|
|
||
|
|
||
| /** @override */ | ||
| shaka.player.OfflineVideoSource.prototype.destroy = function() { | ||
| // TODO (natalieharris) | ||
| }; | ||
|
|
||
|
|
||
| /** @override */ | ||
| shaka.player.OfflineVideoSource.prototype.load = function(preferredLanguage) { | ||
| // TODO (natalieharris) | ||
| }; |
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