WebRTC-Example/client/webrtc.js

82 lines
2.2 KiB
JavaScript
Executable File

import { dataChannelConfig, peerConnectionConfig } from './config.js';
import { createPeerExchange } from './peer-exchange.js';
import { createHost, createGuest} from './peer.js';
var peerConnection;
var serverConnection;
async function pageReady() {
document.querySelector("button#host")
.addEventListener("click", host);
document.querySelector("button#connect")
.addEventListener("click", connect);
serverConnection = await createPeerExchange('ws://' + window.location.hostname + ':8080');
}
function host() {
const host = createHost(serverConnection, peerConnectionConfig);
host.onConnection(conn => {
console.log("Host Received Connection", conn);
conn.addEventListener('addstream', stream => {
console.log("Host received stream", stream);
document.getElementById('remoteVideo').srcObject = event.stream;
});
});
console.log("Host waiting for connections");
}
async function connect() {
var constraints = {
video: true,
audio: true,
};
const stream = await navigator.mediaDevices.getUserMedia(constraints);
const guest = createGuest(serverConnection, peerConnectionConfig);
guest.conn.addStream(stream);
console.log("Connecting");
guest.connect();
}
async function setup() {
var constraints = {
video: true,
audio: true,
};
const stream = await navigator.mediaDevices.getUserMedia(constraints);
document.getElementById('localVideo').srcObject = stream;
peerConnection = createPeer(serverConnection, peerConnectionConfig);
peerConnection.addEventListener('addstream', stream => {
document.getElementById('remoteVideo').srcObject = event.stream;
});
peerConnection.addStream(stream);
}
function extendOffer() {
console.log('Extending offer');
peerConnection.createOffer().then(createdDescription).catch(errorHandler);
}
function createdDescription(description) {
console.log('got description');
peerConnection.setLocalDescription(description).then(function() {
serverConnection.send({'sdp': peerConnection.localDescription});
}).catch(errorHandler);
}
function errorHandler(error) {
console.log(error);
}
pageReady();