Source: lib/offline/offline_manifest_parser.js

  1. /**
  2.  * @license
  3.  * Copyright 2016 Google Inc.
  4.  *
  5.  * Licensed under the Apache License, Version 2.0 (the "License");
  6.  * you may not use this file except in compliance with the License.
  7.  * You may obtain a copy of the License at
  8.  *
  9.  *     http://www.apache.org/licenses/LICENSE-2.0
  10.  *
  11.  * Unless required by applicable law or agreed to in writing, software
  12.  * distributed under the License is distributed on an "AS IS" BASIS,
  13.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14.  * See the License for the specific language governing permissions and
  15.  * limitations under the License.
  16.  */
  18. goog.provide('shaka.offline.OfflineManifestParser');
  20. goog.require('goog.asserts');
  21. goog.require('shaka.log');
  22. goog.require('shaka.media.ManifestParser');
  23. goog.require('shaka.offline.ManifestConverter');
  24. goog.require('shaka.offline.OfflineUri');
  25. goog.require('shaka.offline.StorageMuxer');
  26. goog.require('shaka.util.Error');
  27. goog.require('shaka.util.IDestroyable');
  31. /**
  32.  * Creates a new offline manifest parser.
  33.  * @struct
  34.  * @constructor
  35.  * @implements {shakaExtern.ManifestParser}
  36.  */
  37. shaka.offline.OfflineManifestParser = function() {
  38.   /** @private {shaka.offline.OfflineUri} */
  39.   this.uri_ = null;
  40. };
  43. /** @override */
  44. shaka.offline.OfflineManifestParser.prototype.configure = function(config) {
  45.   // No-op
  46. };
  49. /** @override */
  50. shaka.offline.OfflineManifestParser.prototype.start =
  51.     function(uriString, playerInterface) {
  52.   let uri = shaka.offline.OfflineUri.parse(uriString);
  53.   this.uri_ = uri;
  55.   if (uri == null || !uri.isManifest()) {
  56.     return Promise.reject(new shaka.util.Error(
  57.         shaka.util.Error.Severity.CRITICAL,
  58.         shaka.util.Error.Category.NETWORK,
  59.         shaka.util.Error.Code.MALFORMED_OFFLINE_URI,
  60.         uri));
  61.   }
  63.   let muxer = new shaka.offline.StorageMuxer();
  64.   return shaka.util.IDestroyable.with([muxer], async () => {
  65.     await muxer.init();
  67.     let cell = await muxer.getCell(uri.mechanism(), uri.cell());
  69.     let manifests = await cell.getManifests([uri.key()]);
  70.     let manifest = manifests[0];
  72.     let converter = new shaka.offline.ManifestConverter(
  73.       uri.mechanism(), uri.cell());
  75.     return converter.fromManifestDB(manifest);
  76.   });
  77. };
  80. /** @override */
  81. shaka.offline.OfflineManifestParser.prototype.stop = function() {
  82.   return Promise.resolve();
  83. };
  86. /** @override */
  87. shaka.offline.OfflineManifestParser.prototype.update = function() {
  88.   // No-op
  89. };
  92. /** @override */
  93. shaka.offline.OfflineManifestParser.prototype.onExpirationUpdated = function(
  94.     sessionId, expiration) {
  95.   let uri = this.uri_;
  97.   goog.asserts.assert(
  98.       uri, 'Should not get update event before start has been called');
  100.   let muxer = new shaka.offline.StorageMuxer();
  101.   return shaka.util.IDestroyable.with([muxer], async () => {
  102.     await muxer.init();
  104.     let cell = await muxer.getCell(uri.mechanism(), uri.cell());
  106.     let manifests = await cell.getManifests([uri.key()]);
  107.     let manifest = manifests[0];
  109.     let foundSession = manifest.sessionIds.indexOf(sessionId) >= 0;
  110.     let newExpiration = manifest.expiration == undefined ||
  111.                         manifest.expiration > expiration;
  113.     if (foundSession && newExpiration) {
  114.       shaka.log.debug('Updating expiration for stored content');
  115.       await cell.updateManifestExpiration(uri.key(), expiration);
  116.     }
  117.   }).catch((e) => {
  118.     // Ignore errors with update.
  119.     shaka.log.error('There was an error updating', uri, e);
  120.   });
  121. };
  124. shaka.media.ManifestParser.registerParserByMime(
  125.     'application/x-offline-manifest', shaka.offline.OfflineManifestParser);