Source: lib/net/http_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.HttpPlugin');
  20. goog.require('goog.asserts');
  21. goog.require('shaka.log');
  22. goog.require('shaka.net.NetworkingEngine');
  23. goog.require('shaka.util.Error');
  24. goog.require('shaka.util.StringUtils');
  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.  * @return {!Promise.<shakaExtern.Response>}
  33.  * @export
  34.  */
  35. shaka.net.HttpPlugin = function(uri, request) {
  36.   return new Promise(function(resolve, reject) {
  37.     var xhr = new XMLHttpRequest();
  39.     xhr.open(request.method, uri, true);
  40.     xhr.responseType = 'arraybuffer';
  41.     xhr.timeout = request.retryParameters.timeout;
  42.     xhr.withCredentials = request.allowCrossSiteCredentials;
  44.     xhr.onload = function(event) {
  45.       var target = event.target;
  46.       goog.asserts.assert(target, 'XHR onload has no target!');
  48.       var headers = target.getAllResponseHeaders().split('\r\n').reduce(
  49.           function(all, part) {
  50.             var header = part.split(': ');
  51.             all[header[0].toLowerCase()] = header.slice(1).join(': ');
  52.             return all;
  53.           },
  54.           {});
  55.       if (target.status >= 200 && target.status <= 299 &&
  56.           target.status != 202) {
  57.         // Most 2xx HTTP codes are success cases.
  58.         if (target.responseURL) {
  59.           uri = target.responseURL;
  60.         }
  61.         /** @type {shakaExtern.Response} */
  62.         var response = {
  63.           uri: uri,
  64.           data: target.response,
  65.           headers: headers,
  66.           fromCache: !!headers['x-shaka-from-cache']
  67.         };
  68.         resolve(response);
  69.       } else {
  70.         var responseText = null;
  71.         try {
  72.           responseText = shaka.util.StringUtils.fromBytesAutoDetect(
  73.               target.response);
  74.         } catch (exception) {}
  75.         shaka.log.debug('HTTP error text:', responseText);
  77.         var severity = target.status == 401 || target.status == 403 ?
  78.             shaka.util.Error.Severity.CRITICAL :
  79.             shaka.util.Error.Severity.RECOVERABLE;
  80.         reject(new shaka.util.Error(
  81.             severity,
  82.             shaka.util.Error.Category.NETWORK,
  83.             shaka.util.Error.Code.BAD_HTTP_STATUS,
  84.             uri,
  85.             target.status,
  86.             responseText,
  87.             headers));
  88.       }
  89.     };
  90.     xhr.onerror = function(event) {
  91.       reject(new shaka.util.Error(
  92.           shaka.util.Error.Severity.RECOVERABLE,
  93.           shaka.util.Error.Category.NETWORK,
  94.           shaka.util.Error.Code.HTTP_ERROR,
  95.           uri));
  96.     };
  97.     xhr.ontimeout = function(event) {
  98.       reject(new shaka.util.Error(
  99.           shaka.util.Error.Severity.RECOVERABLE,
  100.           shaka.util.Error.Category.NETWORK,
  101.           shaka.util.Error.Code.TIMEOUT,
  102.           uri));
  103.     };
  105.     for (var k in request.headers) {
  106.       xhr.setRequestHeader(k, request.headers[k]);
  107.     }
  108.     xhr.send(request.body);
  109.   });
  110. };
  113. shaka.net.NetworkingEngine.registerScheme('http', shaka.net.HttpPlugin);
  114. shaka.net.NetworkingEngine.registerScheme('https', shaka.net.HttpPlugin);