Source: lib/net/http_xhr_plugin.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.net.HttpXHRPlugin');
  20. goog.require('goog.asserts');
  21. goog.require('shaka.net.HttpPluginUtils');
  22. goog.require('shaka.net.NetworkingEngine');
  23. goog.require('shaka.util.AbortableOperation');
  24. goog.require('shaka.util.Error');
  27. /**
  28.  * @namespace
  29.  * @summary A networking plugin to handle http and https URIs via XHR.
  30.  * @param {string} uri
  31.  * @param {shakaExtern.Request} request
  32.  * @param {shaka.net.NetworkingEngine.RequestType} requestType
  33.  * @return {!shakaExtern.IAbortableOperation.<shakaExtern.Response>}
  34.  * @export
  35.  */
  36. shaka.net.HttpXHRPlugin = function(uri, request, requestType) {
  37.   let xhr = new shaka.net.HttpXHRPlugin.xhr_();
  39.   let promise = new Promise(function(resolve, reject) {
  40.     xhr.open(request.method, uri, true);
  41.     xhr.responseType = 'arraybuffer';
  42.     xhr.timeout = request.retryParameters.timeout;
  43.     xhr.withCredentials = request.allowCrossSiteCredentials;
  45.     xhr.onabort = function() {
  46.       reject(new shaka.util.Error(
  47.           shaka.util.Error.Severity.RECOVERABLE,
  48.           shaka.util.Error.Category.NETWORK,
  49.           shaka.util.Error.Code.OPERATION_ABORTED,
  50.           uri, requestType));
  51.     };
  52.     xhr.onload = function(event) {
  53.       let target = event.target;
  54.       goog.asserts.assert(target, 'XHR onload has no target!');
  55.       // Since IE and Edge incorrectly return the header with a leading new line
  56.       // character ('\n'), we trim the header here.
  57.       let headers = target.getAllResponseHeaders().trim().split('\r\n').reduce(
  58.           function(all, part) {
  59.             /** @type {!Array.<string>} */
  60.             let header = part.split(': ');
  61.             all[header[0].toLowerCase()] = header.slice(1).join(': ');
  62.             return all;
  63.           },
  64.           {});
  66.       try {
  67.         let response = shaka.net.HttpPluginUtils.makeResponse(headers,
  68.           target.response, target.status, uri, target.responseURL,
  69.           requestType);
  70.         resolve(response);
  71.       } catch (error) {
  72.         goog.asserts.assert(error instanceof shaka.util.Error,
  73.             'Wrong error type!');
  74.         reject(error);
  75.       }
  76.     };
  77.     xhr.onerror = function(event) {
  78.       reject(new shaka.util.Error(
  79.           shaka.util.Error.Severity.RECOVERABLE,
  80.           shaka.util.Error.Category.NETWORK,
  81.           shaka.util.Error.Code.HTTP_ERROR,
  82.           uri, event, requestType));
  83.     };
  84.     xhr.ontimeout = function(event) {
  85.       reject(new shaka.util.Error(
  86.           shaka.util.Error.Severity.RECOVERABLE,
  87.           shaka.util.Error.Category.NETWORK,
  88.           shaka.util.Error.Code.TIMEOUT,
  89.           uri, requestType));
  90.     };
  92.     for (let key in request.headers) {
  93.       // The Fetch API automatically normalizes outgoing header keys to
  94.       // lowercase. For consistency's sake, do it here too.
  95.       let lowercasedKey = key.toLowerCase();
  96.       xhr.setRequestHeader(lowercasedKey, request.headers[key]);
  97.     }
  98.     xhr.send(request.body);
  99.   });
  101.   return new shaka.util.AbortableOperation(
  102.     promise,
  103.     () => {
  104.       xhr.abort();
  105.       return Promise.resolve();
  106.     });
  107. };
  110. /**
  111.  * Overridden in unit tests, but compiled out in production.
  112.  *
  113.  * @const {function(new: XMLHttpRequest)}
  114.  * @private
  115.  */
  116. shaka.net.HttpXHRPlugin.xhr_ = window.XMLHttpRequest;
  119. shaka.net.NetworkingEngine.registerScheme('http', shaka.net.HttpXHRPlugin,
  120.     shaka.net.NetworkingEngine.PluginPriority.FALLBACK);
  121. shaka.net.NetworkingEngine.registerScheme('https', shaka.net.HttpXHRPlugin,
  122.     shaka.net.NetworkingEngine.PluginPriority.FALLBACK);