143 lines
4.1 KiB
HTML
143 lines
4.1 KiB
HTML
|
<!DOCTYPE html>
|
||
|
|
<html>
|
||
|
|
<head>
|
||
|
|
<title>PeerConnection Rehydration Demo</title>
|
||
|
|
<style>
|
||
|
|
video {
|
||
|
|
border:5px solid black;
|
||
|
|
width:320px;
|
||
|
|
height:240px;
|
||
|
|
}
|
||
|
|
</style>
|
||
|
|
</head>
|
||
|
|
<body>
|
||
|
|
<video id="vid1" autoplay></video>
|
||
|
|
<video id="vid2" autoplay></video>
|
||
|
|
<br>
|
||
|
|
<button id="btn1" onclick="start()">Start</button>
|
||
|
|
<button id="btn2" onclick="call()">Call</button>
|
||
|
|
<button id="btn3" onclick="rehydrate()">Rehydrate</button>
|
||
|
|
<button id="btn4" onclick="stop()">Hang Up</button>
|
||
|
|
<script>
|
||
|
|
//var vid1 = document.getElementById("vid1");
|
||
|
|
//var vid2 = document.getElementById("vid2");
|
||
|
|
btn2.disabled = true;
|
||
|
|
btn3.disabled = true;
|
||
|
|
btn4.disabled = true;
|
||
|
|
var pc1,pc2;
|
||
|
|
var localstream;
|
||
|
|
|
||
|
|
function trace(txt) {
|
||
|
|
// This function is used for logging.
|
||
|
|
console.log(txt);
|
||
|
|
}
|
||
|
|
|
||
|
|
function start() {
|
||
|
|
btn1.disabled = true;
|
||
|
|
navigator.webkitGetUserMedia({audio:true, video:true}, gotStream, function() {});
|
||
|
|
}
|
||
|
|
|
||
|
|
function gotStream(stream){
|
||
|
|
trace("Received local stream");
|
||
|
|
vid1.src = webkitURL.createObjectURL(stream);
|
||
|
|
localstream = stream;
|
||
|
|
btn2.disabled = false;
|
||
|
|
}
|
||
|
|
|
||
|
|
function call() {
|
||
|
|
btn2.disabled = true;
|
||
|
|
btn3.disabled = false;
|
||
|
|
btn4.disabled = false;
|
||
|
|
trace("Starting Call");
|
||
|
|
if (localstream.videoTracks.length > 0)
|
||
|
|
trace('Using Video device: ' + localstream.videoTracks[0].label); // Prints audio & video device names
|
||
|
|
if (localstream.audioTracks.length > 0)
|
||
|
|
trace('Using Audio device: ' + localstream.audioTracks[0].label);
|
||
|
|
|
||
|
|
pc1 = new webkitPeerConnection00(null,iceCallback1);
|
||
|
|
trace("Created local peer connection object pc1");
|
||
|
|
pc2 = new webkitPeerConnection00(null,iceCallback2);
|
||
|
|
trace("Created remote peer connection object pc2");
|
||
|
|
pc2.onaddstream = gotRemoteStream;
|
||
|
|
|
||
|
|
pc1.addStream(localstream);
|
||
|
|
trace("Adding Local Stream to peer connection");
|
||
|
|
var offer = pc1.createOffer(null);
|
||
|
|
trace("Created offer");
|
||
|
|
pc1.setLocalDescription(pc1.SDP_OFFER, offer);
|
||
|
|
trace("SetLocalDesc1");
|
||
|
|
pc2.setRemoteDescription(pc2.SDP_OFFER, offer);
|
||
|
|
trace("SetRemoteDesc2");
|
||
|
|
var answer = pc2.createAnswer(offer.toSdp(), {has_audio:true, has_video:true});;
|
||
|
|
trace("CreatedAnswer");
|
||
|
|
pc2.setLocalDescription(pc2.SDP_ANSWER, answer);
|
||
|
|
trace("SetLocalDesc2");
|
||
|
|
pc1.setRemoteDescription(pc1.SDP_ANSWER, answer);
|
||
|
|
trace("SetRemoteDesc1");
|
||
|
|
pc1.startIce(); // Start finding local ice candidates. Once it finds candidates it will call icecallback
|
||
|
|
pc2.startIce(); //Starts finding remote ice candidates. Once it finds candidates it will call iceCallback2
|
||
|
|
trace("Start ICE for both local & remote");
|
||
|
|
}
|
||
|
|
|
||
|
|
function rehydrate() {
|
||
|
|
var oldLocal = pc2.localDescription;
|
||
|
|
// need to munge a=crypto
|
||
|
|
pc2 = null;
|
||
|
|
trace("Destroyed remote peer connection object pc2");
|
||
|
|
pc2 = new webkitPeerConnection00(null, iceCallback3);
|
||
|
|
trace("Created new remote peer connection object pc2");
|
||
|
|
pc2.onaddstream = gotRemoteStream;
|
||
|
|
pc2.setLocalDescription(pc2.SDP_OFFER, oldLocal);
|
||
|
|
pc1.setRemoteDescription(pc1.SDP_OFFER, oldLocal);
|
||
|
|
var answer = pc1.createAnswer(oldLocal.toSdp(), {has_audio:true, has_video:true});
|
||
|
|
pc1.setLocalDescription(pc1.SDP_ANSWER, answer);
|
||
|
|
pc2.setRemoteDescription(pc2.SDP_ANSWER, answer);
|
||
|
|
pc2.startIce();
|
||
|
|
trace("Inited new remote peer connection object pc2");
|
||
|
|
}
|
||
|
|
|
||
|
|
function stop() {
|
||
|
|
trace("Ending Call" + "\n\n");
|
||
|
|
pc1.close();
|
||
|
|
pc2.close();
|
||
|
|
pc1=null;
|
||
|
|
pc2=null;
|
||
|
|
btn2.disabled = false;
|
||
|
|
btn3.disabled = true;
|
||
|
|
btn4.disabled = true;
|
||
|
|
}
|
||
|
|
|
||
|
|
function gotRemoteStream(e){
|
||
|
|
vid2.src = webkitURL.createObjectURL(e.stream);
|
||
|
|
trace("Received Remote Stream");
|
||
|
|
}
|
||
|
|
|
||
|
|
function iceCallback1(candidate,bMore){
|
||
|
|
if (candidate) {
|
||
|
|
pc2.processIceMessage(candidate);
|
||
|
|
trace("Local ice candidate: " + candidate.toSdp());
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
function iceCallback2(candidate,bMore){
|
||
|
|
if (candidate) {
|
||
|
|
pc1.processIceMessage(candidate);
|
||
|
|
trace("Remote ice candidate: " + candidate.toSdp());
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
function iceCallback3(candidate,bMore){
|
||
|
|
if (candidate) {
|
||
|
|
var str = candidate.toSdp();
|
||
|
|
str = str.replace("generation 0", "generation 1");
|
||
|
|
var mungedCandidate = new IceCandidate(candidate.label, str);
|
||
|
|
trace("Remote ice candidate: " + mungedCandidate.toSdp());
|
||
|
|
pc1.processIceMessage(mungedCandidate);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
</script>
|
||
|
|
</body>
|
||
|
|
</html>
|
||
|
|
|
||
|
|
|