123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318 |
- /*
- * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved.
- *
- * Use of this source code is governed by a BSD-style license
- * that can be found in the LICENSE file in the root of the source
- * tree.
- */
- /* eslint-env node */
- 'use strict';
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.shimAddTransceiver = shimAddTransceiver;
- exports.shimCreateAnswer = shimCreateAnswer;
- exports.shimCreateOffer = shimCreateOffer;
- Object.defineProperty(exports, "shimGetDisplayMedia", {
- enumerable: true,
- get: function get() {
- return _getdisplaymedia.shimGetDisplayMedia;
- }
- });
- exports.shimGetParameters = shimGetParameters;
- Object.defineProperty(exports, "shimGetUserMedia", {
- enumerable: true,
- get: function get() {
- return _getusermedia.shimGetUserMedia;
- }
- });
- exports.shimOnTrack = shimOnTrack;
- exports.shimPeerConnection = shimPeerConnection;
- exports.shimRTCDataChannel = shimRTCDataChannel;
- exports.shimReceiverGetStats = shimReceiverGetStats;
- exports.shimRemoveStream = shimRemoveStream;
- exports.shimSenderGetStats = shimSenderGetStats;
- var utils = _interopRequireWildcard(require("../utils"));
- var _getusermedia = require("./getusermedia");
- var _getdisplaymedia = require("./getdisplaymedia");
- function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function _getRequireWildcardCache(nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); }
- function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || _typeof(obj) !== "object" && typeof obj !== "function") { return { "default": obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj["default"] = obj; if (cache) { cache.set(obj, newObj); } return newObj; }
- function _toConsumableArray(arr) { return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _unsupportedIterableToArray(arr) || _nonIterableSpread(); }
- function _nonIterableSpread() { throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method."); }
- function _unsupportedIterableToArray(o, minLen) { if (!o) return; if (typeof o === "string") return _arrayLikeToArray(o, minLen); var n = Object.prototype.toString.call(o).slice(8, -1); if (n === "Object" && o.constructor) n = o.constructor.name; if (n === "Map" || n === "Set") return Array.from(o); if (n === "Arguments" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return _arrayLikeToArray(o, minLen); }
- function _iterableToArray(iter) { if (typeof Symbol !== "undefined" && iter[Symbol.iterator] != null || iter["@@iterator"] != null) return Array.from(iter); }
- function _arrayWithoutHoles(arr) { if (Array.isArray(arr)) return _arrayLikeToArray(arr); }
- function _arrayLikeToArray(arr, len) { if (len == null || len > arr.length) len = arr.length; for (var i = 0, arr2 = new Array(len); i < len; i++) arr2[i] = arr[i]; return arr2; }
- function _defineProperty(obj, key, value) { key = _toPropertyKey(key); if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }
- function _toPropertyKey(arg) { var key = _toPrimitive(arg, "string"); return _typeof(key) === "symbol" ? key : String(key); }
- function _toPrimitive(input, hint) { if (_typeof(input) !== "object" || input === null) return input; var prim = input[Symbol.toPrimitive]; if (prim !== undefined) { var res = prim.call(input, hint || "default"); if (_typeof(res) !== "object") return res; throw new TypeError("@@toPrimitive must return a primitive value."); } return (hint === "string" ? String : Number)(input); }
- function _typeof(obj) { "@babel/helpers - typeof"; return _typeof = "function" == typeof Symbol && "symbol" == typeof Symbol.iterator ? function (obj) { return typeof obj; } : function (obj) { return obj && "function" == typeof Symbol && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }, _typeof(obj); }
- function shimOnTrack(window) {
- if (_typeof(window) === 'object' && window.RTCTrackEvent && 'receiver' in window.RTCTrackEvent.prototype && !('transceiver' in window.RTCTrackEvent.prototype)) {
- Object.defineProperty(window.RTCTrackEvent.prototype, 'transceiver', {
- get: function get() {
- return {
- receiver: this.receiver
- };
- }
- });
- }
- }
- function shimPeerConnection(window, browserDetails) {
- if (_typeof(window) !== 'object' || !(window.RTCPeerConnection || window.mozRTCPeerConnection)) {
- return; // probably media.peerconnection.enabled=false in about:config
- }
- if (!window.RTCPeerConnection && window.mozRTCPeerConnection) {
- // very basic support for old versions.
- window.RTCPeerConnection = window.mozRTCPeerConnection;
- }
- if (browserDetails.version < 53) {
- // shim away need for obsolete RTCIceCandidate/RTCSessionDescription.
- ['setLocalDescription', 'setRemoteDescription', 'addIceCandidate'].forEach(function (method) {
- var nativeMethod = window.RTCPeerConnection.prototype[method];
- var methodObj = _defineProperty({}, method, function () {
- arguments[0] = new (method === 'addIceCandidate' ? window.RTCIceCandidate : window.RTCSessionDescription)(arguments[0]);
- return nativeMethod.apply(this, arguments);
- });
- window.RTCPeerConnection.prototype[method] = methodObj[method];
- });
- }
- var modernStatsTypes = {
- inboundrtp: 'inbound-rtp',
- outboundrtp: 'outbound-rtp',
- candidatepair: 'candidate-pair',
- localcandidate: 'local-candidate',
- remotecandidate: 'remote-candidate'
- };
- var nativeGetStats = window.RTCPeerConnection.prototype.getStats;
- window.RTCPeerConnection.prototype.getStats = function getStats() {
- var _arguments = Array.prototype.slice.call(arguments),
- selector = _arguments[0],
- onSucc = _arguments[1],
- onErr = _arguments[2];
- return nativeGetStats.apply(this, [selector || null]).then(function (stats) {
- if (browserDetails.version < 53 && !onSucc) {
- // Shim only promise getStats with spec-hyphens in type names
- // Leave callback version alone; misc old uses of forEach before Map
- try {
- stats.forEach(function (stat) {
- stat.type = modernStatsTypes[stat.type] || stat.type;
- });
- } catch (e) {
- if (e.name !== 'TypeError') {
- throw e;
- }
- // Avoid TypeError: "type" is read-only, in old versions. 34-43ish
- stats.forEach(function (stat, i) {
- stats.set(i, Object.assign({}, stat, {
- type: modernStatsTypes[stat.type] || stat.type
- }));
- });
- }
- }
- return stats;
- }).then(onSucc, onErr);
- };
- }
- function shimSenderGetStats(window) {
- if (!(_typeof(window) === 'object' && window.RTCPeerConnection && window.RTCRtpSender)) {
- return;
- }
- if (window.RTCRtpSender && 'getStats' in window.RTCRtpSender.prototype) {
- return;
- }
- var origGetSenders = window.RTCPeerConnection.prototype.getSenders;
- if (origGetSenders) {
- window.RTCPeerConnection.prototype.getSenders = function getSenders() {
- var _this = this;
- var senders = origGetSenders.apply(this, []);
- senders.forEach(function (sender) {
- return sender._pc = _this;
- });
- return senders;
- };
- }
- var origAddTrack = window.RTCPeerConnection.prototype.addTrack;
- if (origAddTrack) {
- window.RTCPeerConnection.prototype.addTrack = function addTrack() {
- var sender = origAddTrack.apply(this, arguments);
- sender._pc = this;
- return sender;
- };
- }
- window.RTCRtpSender.prototype.getStats = function getStats() {
- return this.track ? this._pc.getStats(this.track) : Promise.resolve(new Map());
- };
- }
- function shimReceiverGetStats(window) {
- if (!(_typeof(window) === 'object' && window.RTCPeerConnection && window.RTCRtpSender)) {
- return;
- }
- if (window.RTCRtpSender && 'getStats' in window.RTCRtpReceiver.prototype) {
- return;
- }
- var origGetReceivers = window.RTCPeerConnection.prototype.getReceivers;
- if (origGetReceivers) {
- window.RTCPeerConnection.prototype.getReceivers = function getReceivers() {
- var _this2 = this;
- var receivers = origGetReceivers.apply(this, []);
- receivers.forEach(function (receiver) {
- return receiver._pc = _this2;
- });
- return receivers;
- };
- }
- utils.wrapPeerConnectionEvent(window, 'track', function (e) {
- e.receiver._pc = e.srcElement;
- return e;
- });
- window.RTCRtpReceiver.prototype.getStats = function getStats() {
- return this._pc.getStats(this.track);
- };
- }
- function shimRemoveStream(window) {
- if (!window.RTCPeerConnection || 'removeStream' in window.RTCPeerConnection.prototype) {
- return;
- }
- window.RTCPeerConnection.prototype.removeStream = function removeStream(stream) {
- var _this3 = this;
- utils.deprecated('removeStream', 'removeTrack');
- this.getSenders().forEach(function (sender) {
- if (sender.track && stream.getTracks().includes(sender.track)) {
- _this3.removeTrack(sender);
- }
- });
- };
- }
- function shimRTCDataChannel(window) {
- // rename DataChannel to RTCDataChannel (native fix in FF60):
- // https://bugzilla.mozilla.org/show_bug.cgi?id=1173851
- if (window.DataChannel && !window.RTCDataChannel) {
- window.RTCDataChannel = window.DataChannel;
- }
- }
- function shimAddTransceiver(window) {
- // https://github.com/webrtcHacks/adapter/issues/998#issuecomment-516921647
- // Firefox ignores the init sendEncodings options passed to addTransceiver
- // https://bugzilla.mozilla.org/show_bug.cgi?id=1396918
- if (!(_typeof(window) === 'object' && window.RTCPeerConnection)) {
- return;
- }
- var origAddTransceiver = window.RTCPeerConnection.prototype.addTransceiver;
- if (origAddTransceiver) {
- window.RTCPeerConnection.prototype.addTransceiver = function addTransceiver() {
- this.setParametersPromises = [];
- // WebIDL input coercion and validation
- var sendEncodings = arguments[1] && arguments[1].sendEncodings;
- if (sendEncodings === undefined) {
- sendEncodings = [];
- }
- sendEncodings = _toConsumableArray(sendEncodings);
- var shouldPerformCheck = sendEncodings.length > 0;
- if (shouldPerformCheck) {
- // If sendEncodings params are provided, validate grammar
- sendEncodings.forEach(function (encodingParam) {
- if ('rid' in encodingParam) {
- var ridRegex = /^[a-z0-9]{0,16}$/i;
- if (!ridRegex.test(encodingParam.rid)) {
- throw new TypeError('Invalid RID value provided.');
- }
- }
- if ('scaleResolutionDownBy' in encodingParam) {
- if (!(parseFloat(encodingParam.scaleResolutionDownBy) >= 1.0)) {
- throw new RangeError('scale_resolution_down_by must be >= 1.0');
- }
- }
- if ('maxFramerate' in encodingParam) {
- if (!(parseFloat(encodingParam.maxFramerate) >= 0)) {
- throw new RangeError('max_framerate must be >= 0.0');
- }
- }
- });
- }
- var transceiver = origAddTransceiver.apply(this, arguments);
- if (shouldPerformCheck) {
- // Check if the init options were applied. If not we do this in an
- // asynchronous way and save the promise reference in a global object.
- // This is an ugly hack, but at the same time is way more robust than
- // checking the sender parameters before and after the createOffer
- // Also note that after the createoffer we are not 100% sure that
- // the params were asynchronously applied so we might miss the
- // opportunity to recreate offer.
- var sender = transceiver.sender;
- var params = sender.getParameters();
- if (!('encodings' in params) ||
- // Avoid being fooled by patched getParameters() below.
- params.encodings.length === 1 && Object.keys(params.encodings[0]).length === 0) {
- params.encodings = sendEncodings;
- sender.sendEncodings = sendEncodings;
- this.setParametersPromises.push(sender.setParameters(params).then(function () {
- delete sender.sendEncodings;
- })["catch"](function () {
- delete sender.sendEncodings;
- }));
- }
- }
- return transceiver;
- };
- }
- }
- function shimGetParameters(window) {
- if (!(_typeof(window) === 'object' && window.RTCRtpSender)) {
- return;
- }
- var origGetParameters = window.RTCRtpSender.prototype.getParameters;
- if (origGetParameters) {
- window.RTCRtpSender.prototype.getParameters = function getParameters() {
- var params = origGetParameters.apply(this, arguments);
- if (!('encodings' in params)) {
- params.encodings = [].concat(this.sendEncodings || [{}]);
- }
- return params;
- };
- }
- }
- function shimCreateOffer(window) {
- // https://github.com/webrtcHacks/adapter/issues/998#issuecomment-516921647
- // Firefox ignores the init sendEncodings options passed to addTransceiver
- // https://bugzilla.mozilla.org/show_bug.cgi?id=1396918
- if (!(_typeof(window) === 'object' && window.RTCPeerConnection)) {
- return;
- }
- var origCreateOffer = window.RTCPeerConnection.prototype.createOffer;
- window.RTCPeerConnection.prototype.createOffer = function createOffer() {
- var _arguments2 = arguments,
- _this4 = this;
- if (this.setParametersPromises && this.setParametersPromises.length) {
- return Promise.all(this.setParametersPromises).then(function () {
- return origCreateOffer.apply(_this4, _arguments2);
- })["finally"](function () {
- _this4.setParametersPromises = [];
- });
- }
- return origCreateOffer.apply(this, arguments);
- };
- }
- function shimCreateAnswer(window) {
- // https://github.com/webrtcHacks/adapter/issues/998#issuecomment-516921647
- // Firefox ignores the init sendEncodings options passed to addTransceiver
- // https://bugzilla.mozilla.org/show_bug.cgi?id=1396918
- if (!(_typeof(window) === 'object' && window.RTCPeerConnection)) {
- return;
- }
- var origCreateAnswer = window.RTCPeerConnection.prototype.createAnswer;
- window.RTCPeerConnection.prototype.createAnswer = function createAnswer() {
- var _arguments3 = arguments,
- _this5 = this;
- if (this.setParametersPromises && this.setParametersPromises.length) {
- return Promise.all(this.setParametersPromises).then(function () {
- return origCreateAnswer.apply(_this5, _arguments3);
- })["finally"](function () {
- _this5.setParametersPromises = [];
- });
- }
- return origCreateAnswer.apply(this, arguments);
- };
- }
|