Source: lib/offline/offline_scheme.js

  1. /*! @license
  2.  * Shaka Player
  3.  * Copyright 2016 Google LLC
  4.  * SPDX-License-Identifier: Apache-2.0
  5.  */
  7. goog.provide('shaka.offline.OfflineScheme');
  9. goog.require('goog.asserts');
  10. goog.require('shaka.net.NetworkingEngine');
  11. goog.require('shaka.offline.OfflineUri');
  12. goog.require('shaka.offline.StorageMuxer');
  13. goog.require('shaka.util.AbortableOperation');
  14. goog.require('shaka.util.Error');
  17. /**
  18.  * @summary A plugin that handles requests for offline content.
  19.  * @export
  20.  */
  21. shaka.offline.OfflineScheme = class {
  22.   /**
  23.    * @param {string} uri
  24.    * @param {shaka.extern.Request} request
  25.    * @param {shaka.net.NetworkingEngine.RequestType} requestType
  26.    * @param {shaka.extern.ProgressUpdated} progressUpdated Called when a
  27.    *   progress event happened.
  28.    * @return {!shaka.extern.IAbortableOperation.<shaka.extern.Response>}
  29.    * @export
  30.    */
  31.   static plugin(uri, request, requestType, progressUpdated) {
  32.     const offlineUri = shaka.offline.OfflineUri.parse(uri);
  34.     if (offlineUri && offlineUri.isManifest()) {
  35.       return shaka.offline.OfflineScheme.getManifest_(uri, request);
  36.     }
  38.     if (offlineUri && offlineUri.isSegment()) {
  39.       return shaka.offline.OfflineScheme.getSegment_(
  40.           offlineUri.key(), offlineUri, request);
  41.     }
  43.     return shaka.util.AbortableOperation.failed(
  44.         new shaka.util.Error(
  45.             shaka.util.Error.Severity.CRITICAL,
  46.             shaka.util.Error.Category.NETWORK,
  47.             shaka.util.Error.Code.MALFORMED_OFFLINE_URI,
  48.             uri));
  49.   }
  51.   /**
  52.    * @param {string} uri
  53.    * @param {shaka.extern.Request} request
  54.    * @return {!shaka.extern.IAbortableOperation.<shaka.extern.Response>}
  55.    * @private
  56.    */
  57.   static getManifest_(uri, request) {
  58.     /** @type {shaka.extern.Response} */
  59.     const response = {
  60.       uri: uri,
  61.       originalUri: uri,
  62.       data: new ArrayBuffer(0),
  63.       headers: {'content-type': 'application/x-offline-manifest'},
  64.       originalRequest: request,
  65.     };
  67.     return shaka.util.AbortableOperation.completed(response);
  68.   }
  70.   /**
  71.    * @param {number} id
  72.    * @param {!shaka.offline.OfflineUri} uri
  73.    * @param {shaka.extern.Request} request
  74.    * @return {!shaka.extern.IAbortableOperation.<shaka.extern.Response>}
  75.    * @private
  76.    */
  77.   static getSegment_(id, uri, request) {
  78.     goog.asserts.assert(
  79.         uri.isSegment(),
  80.         'Only segment uri\'s should be given to getSegment');
  82.     /** @type {!shaka.offline.StorageMuxer} */
  83.     const muxer = new shaka.offline.StorageMuxer();
  85.     return shaka.util.AbortableOperation.completed(undefined)
  86.         .chain(() => muxer.init())
  87.         .chain(() => muxer.getCell(uri.mechanism(), uri.cell()))
  88.         .chain((cell) => cell.getSegments([uri.key()]))
  89.         .chain((segments) => {
  90.           const segment = segments[0];
  92.           return {
  93.             uri: uri,
  94.             data: segment.data,
  95.             headers: {},
  96.             originalRequest: request,
  97.           };
  98.         })
  99.         .finally(() => muxer.destroy());
  100.   }
  101. };
  103. shaka.net.NetworkingEngine.registerScheme(
  104.     'offline', shaka.offline.OfflineScheme.plugin);