123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280 |
- /*
- * Copyright (c) 2015 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.
- */
- /* global TimelineDataSeries, TimelineGraphView */
- 'use strict';
- var audio2 = document.querySelector('audio#audio2');
- var callButton = document.querySelector('button#callButton');
- var hangupButton = document.querySelector('button#hangupButton');
- var codecSelector = document.querySelector('select#codec');
- hangupButton.disabled = true;
- callButton.onclick = call;
- hangupButton.onclick = hangup;
- var pc1;
- var pc2;
- var localStream;
- var bitrateGraph;
- var bitrateSeries;
- var packetGraph;
- var packetSeries;
- var lastResult;
- var offerOptions = {
- offerToReceiveAudio: 1,
- offerToReceiveVideo: 0,
- voiceActivityDetection: false
- };
- function gotStream(stream) {
- trace('Received local stream');
- localStream = stream;
- var audioTracks = localStream.getAudioTracks();
- if (audioTracks.length > 0) {
- trace('Using Audio device: ' + audioTracks[0].label);
- }
- pc1.addStream(localStream);
- trace('Adding Local Stream to peer connection');
- pc1.createOffer(gotDescription1, onCreateSessionDescriptionError,
- offerOptions);
- bitrateSeries = new TimelineDataSeries();
- bitrateGraph = new TimelineGraphView('bitrateGraph', 'bitrateCanvas');
- bitrateGraph.updateEndDate();
- packetSeries = new TimelineDataSeries();
- packetGraph = new TimelineGraphView('packetGraph', 'packetCanvas');
- packetGraph.updateEndDate();
- }
- function onCreateSessionDescriptionError(error) {
- trace('Failed to create session description: ' + error.toString());
- }
- function call() {
- callButton.disabled = true;
- hangupButton.disabled = false;
- codecSelector.disabled = true;
- trace('Starting call');
- var servers = null;
- var pcConstraints = {
- 'optional': []
- };
- pc1 = new RTCPeerConnection(servers, pcConstraints);
- trace('Created local peer connection object pc1');
- pc1.onicecandidate = iceCallback1;
- pc2 = new RTCPeerConnection(servers, pcConstraints);
- trace('Created remote peer connection object pc2');
- pc2.onicecandidate = iceCallback2;
- pc2.onaddstream = gotRemoteStream;
- trace('Requesting local stream');
- navigator.mediaDevices.getUserMedia({
- audio: true,
- video: false
- })
- .then(gotStream)
- .catch(function(e) {
- alert('getUserMedia() error: ' + e.name);
- });
- }
- function gotDescription1(desc) {
- desc.sdp = forceChosenAudioCodec(desc.sdp);
- trace('Offer from pc1 \n' + desc.sdp);
- pc1.setLocalDescription(desc, function() {
- pc2.setRemoteDescription(desc, function() {
- // Since the 'remote' side has no media stream we need
- // to pass in the right constraints in order for it to
- // accept the incoming offer of audio.
- pc2.createAnswer(gotDescription2, onCreateSessionDescriptionError);
- }, onSetSessionDescriptionError);
- }, onSetSessionDescriptionError);
- }
- function gotDescription2(desc) {
- desc.sdp = forceChosenAudioCodec(desc.sdp);
- pc2.setLocalDescription(desc, function() {
- trace('Answer from pc2 \n' + desc.sdp);
- pc1.setRemoteDescription(desc, function() {
- }, onSetSessionDescriptionError);
- }, onSetSessionDescriptionError);
- }
- function hangup() {
- trace('Ending call');
- localStream.getTracks().forEach(function(track) {
- track.stop();
- });
- pc1.close();
- pc2.close();
- pc1 = null;
- pc2 = null;
- hangupButton.disabled = true;
- callButton.disabled = false;
- codecSelector.disabled = false;
- }
- function gotRemoteStream(e) {
- audio2.srcObject = e.stream;
- trace('Received remote stream');
- }
- function iceCallback1(event) {
- if (event.candidate) {
- pc2.addIceCandidate(new RTCIceCandidate(event.candidate),
- onAddIceCandidateSuccess, onAddIceCandidateError);
- trace('Local ICE candidate: \n' + event.candidate.candidate);
- }
- }
- function iceCallback2(event) {
- if (event.candidate) {
- pc1.addIceCandidate(new RTCIceCandidate(event.candidate),
- onAddIceCandidateSuccess, onAddIceCandidateError);
- trace('Remote ICE candidate: \n ' + event.candidate.candidate);
- }
- }
- function onAddIceCandidateSuccess() {
- trace('AddIceCandidate success.');
- }
- function onAddIceCandidateError(error) {
- trace('Failed to add ICE Candidate: ' + error.toString());
- }
- function onSetSessionDescriptionError(error) {
- trace('Failed to set session description: ' + error.toString());
- }
- function forceChosenAudioCodec(sdp) {
- return maybePreferCodec(sdp, 'audio', 'send', codecSelector.value);
- }
- // Copied from AppRTC's sdputils.js:
- // Sets |codec| as the default |type| codec if it's present.
- // The format of |codec| is 'NAME/RATE', e.g. 'opus/48000'.
- function maybePreferCodec(sdp, type, dir, codec) {
- var str = type + ' ' + dir + ' codec';
- if (codec === '') {
- trace('No preference on ' + str + '.');
- return sdp;
- }
- trace('Prefer ' + str + ': ' + codec);
- var sdpLines = sdp.split('\r\n');
- // Search for m line.
- var mLineIndex = findLine(sdpLines, 'm=', type);
- if (mLineIndex === null) {
- return sdp;
- }
- // If the codec is available, set it as the default in m line.
- var codecIndex = findLine(sdpLines, 'a=rtpmap', codec);
- console.log('codecIndex', codecIndex);
- if (codecIndex) {
- var payload = getCodecPayloadType(sdpLines[codecIndex]);
- if (payload) {
- sdpLines[mLineIndex] = setDefaultCodec(sdpLines[mLineIndex], payload);
- }
- }
- sdp = sdpLines.join('\r\n');
- return sdp;
- }
- // Find the line in sdpLines that starts with |prefix|, and, if specified,
- // contains |substr| (case-insensitive search).
- function findLine(sdpLines, prefix, substr) {
- return findLineInRange(sdpLines, 0, -1, prefix, substr);
- }
- // Find the line in sdpLines[startLine...endLine - 1] that starts with |prefix|
- // and, if specified, contains |substr| (case-insensitive search).
- function findLineInRange(sdpLines, startLine, endLine, prefix, substr) {
- var realEndLine = endLine !== -1 ? endLine : sdpLines.length;
- for (var i = startLine; i < realEndLine; ++i) {
- if (sdpLines[i].indexOf(prefix) === 0) {
- if (!substr ||
- sdpLines[i].toLowerCase().indexOf(substr.toLowerCase()) !== -1) {
- return i;
- }
- }
- }
- return null;
- }
- // Gets the codec payload type from an a=rtpmap:X line.
- function getCodecPayloadType(sdpLine) {
- var pattern = new RegExp('a=rtpmap:(\\d+) \\w+\\/\\d+');
- var result = sdpLine.match(pattern);
- return (result && result.length === 2) ? result[1] : null;
- }
- // Returns a new m= line with the specified codec as the first one.
- function setDefaultCodec(mLine, payload) {
- var elements = mLine.split(' ');
- // Just copy the first three parameters; codec order starts on fourth.
- var newLine = elements.slice(0, 3);
- // Put target payload first and copy in the rest.
- newLine.push(payload);
- for (var i = 3; i < elements.length; i++) {
- if (elements[i] !== payload) {
- newLine.push(elements[i]);
- }
- }
- return newLine.join(' ');
- }
- // query getStats every second
- window.setInterval(function() {
- if (!window.pc1) {
- return;
- }
- window.pc1.getStats(null).then(function(res) {
- Object.keys(res).forEach(function(key) {
- var report = res[key];
- var bytes;
- var packets;
- var now = report.timestamp;
- if ((report.type === 'outboundrtp') ||
- (report.type === 'outbound-rtp') ||
- (report.type === 'ssrc' && report.bytesSent)) {
- bytes = report.bytesSent;
- packets = report.packetsSent;
- if (lastResult && lastResult[report.id]) {
- // calculate bitrate
- var bitrate = 8 * (bytes - lastResult[report.id].bytesSent) /
- (now - lastResult[report.id].timestamp);
- // append to chart
- bitrateSeries.addPoint(now, bitrate);
- bitrateGraph.setDataSeries([bitrateSeries]);
- bitrateGraph.updateEndDate();
- // calculate number of packets and append to chart
- packetSeries.addPoint(now, packets -
- lastResult[report.id].packetsSent);
- packetGraph.setDataSeries([packetSeries]);
- packetGraph.updateEndDate();
- }
- }
- });
- lastResult = res;
- });
- }, 1000);
|