Atlas48/grungnet
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added logs for errors

Browse Source 
Co-Authored-By: nthouliss <nthouliss@users.noreply.github.com>
This commit is contained in:
Mitchell McCaffrey 2020-03-25 13:17:55 +11:00
parent 3c82d1954b
commit 1bd9613dd2
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/helpers/useSession.js
View File

@ -58,7 +58,7 @@ function useSession(onConnectionOpen, onConnectionSync) {
// Update stream refs // Update stream refs
useEffect(() => { useEffect(() => {
console.log("Syncing stream ref to stream state"); console.log("Syncing stream ref to stream state", streams);
streamsRef.current = streams; streamsRef.current = streams;
}, [streams, streamsRef]); }, [streams, streamsRef]);
@ -110,7 +110,10 @@ function useSession(onConnectionOpen, onConnectionSync) {
}); });
} }
connection.on("close", removeConnection); connection.on("close", removeConnection);
connection.on("error", removeConnection); connection.on("error", error => {
console.error("Data Connection error", error);
removeConnection();
});
} }
function handleCall(call) { function handleCall(call) {
@ -126,7 +129,14 @@ function useSession(onConnectionOpen, onConnectionSync) {
}); });
} }
call.on("close", removeStream); call.on("close", removeStream);
call.on("error", removeStream); call.on("error", error => {
console.error("Media Connection error", error);
removeStream();
});
}
function handleError(error) {
console.error("Peer error", error);
} }
if (!peer) { if (!peer) {
@ -136,10 +146,12 @@ function useSession(onConnectionOpen, onConnectionSync) {
peer.on("open", handleOpen); peer.on("open", handleOpen);
peer.on("connection", handleConnection); peer.on("connection", handleConnection);
peer.on("call", handleCall); peer.on("call", handleCall);
peer.on("error", handleError);
return () => { return () => {
peer.removeListener("open", handleOpen); peer.removeListener("open", handleOpen);
peer.removeListener("connection", handleConnection); peer.removeListener("connection", handleConnection);
peer.removeListener("call", handleCall); peer.removeListener("call", handleCall);
peer.removeListener("error", handleError);
}; };
}, [peer, peerId, connections, onConnectionOpen, onConnectionSync, streams]); }, [peer, peerId, connections, onConnectionOpen, onConnectionSync, streams]);