MigrateRepos/decentralized-video-chat
1
0
Fork 0
mirror of https://github.com/ianramzy/decentralized-video-chat.git synced 2024-11-14 22:29:20 +08:00
Code Issues Releases Wiki Activity

Merge pull request #3 from questo-ai/disconnect_handling

Browse Source 
Added graceful disconnect handling
This commit is contained in:
Arya Vohra 2020-05-31 20:16:46 +08:00 committed by GitHub
commit d4cfda9032
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 22 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
public/js/chat.js
View File

@ -206,7 +206,16 @@ var VideoChat = {
logIt("connected"); logIt("connected");
break; break;
case "disconnected": case "disconnected":
logIt("disconnected"); logIt("disconnected - UUID " + uuid);
VideoChat.remoteVideoWrapper.removeChild(document.querySelectorAll(`[uuid="${uuid}"]`)[0]);
VideoChat.connected.delete(uuid);
VideoChat.peerConnections.delete(uuid);
dataChannel.delete(uuid);
if (VideoChat.peerConnections.size === 0) {
displayWaitingCaption();
}
break;
case "failed": case "failed":
logIt("failed"); logIt("failed");
// VideoChat.socket.connect // VideoChat.socket.connect
@ -343,6 +352,7 @@ var VideoChat = {
node.setAttribute("autoplay", ""); node.setAttribute("autoplay", "");
node.setAttribute("playsinline", ""); node.setAttribute("playsinline", "");
node.setAttribute("id", "remote-video"); node.setAttribute("id", "remote-video");
node.setAttribute("uuid", uuid);
VideoChat.remoteVideoWrapper.appendChild(node); VideoChat.remoteVideoWrapper.appendChild(node);
// Update remote video source // Update remote video source
VideoChat.remoteVideoWrapper.lastChild.srcObject = event.stream; VideoChat.remoteVideoWrapper.lastChild.srcObject = event.stream;
@ -905,7 +915,15 @@ function togglePictureInPicture() {
); );
} }
} }
//Picture in picture
// Helper function for displaying waiting caption
function displayWaitingCaption() {
// Set caption text on start
captionText.text("Waiting for other user to join...").fadeIn();
// Reposition captions on start
rePositionCaptions();
}
function startUp() { function startUp() {
// Try and detect in-app browsers and redirect // Try and detect in-app browsers and redirect
@ -999,11 +1017,7 @@ function startUp() {
}, },
}); });
// Set caption text on start displayWaitingCaption();
captionText.text("Waiting for other user to join...").fadeIn();
// Reposition captions on start
rePositionCaptions();
// On change media devices refresh page and switch to system default // On change media devices refresh page and switch to system default
navigator.mediaDevices.ondevicechange = () => window.location.reload(); navigator.mediaDevices.ondevicechange = () => window.location.reload();

1
server.js
View File

@ -8,7 +8,6 @@ var twillioAccountSID =
var twilio = require("twilio")(twillioAccountSID, twillioAuthToken); var twilio = require("twilio")(twillioAccountSID, twillioAuthToken);
var express = require("express"); var express = require("express");
var app = express(); var app = express();
const fs = require("fs");
var http = require("http").createServer(app); var http = require("http").createServer(app);
var io = require("socket.io")(http); var io = require("socket.io")(http);
var path = require("path"); var path = require("path");