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

Improve connection and sync handling

Browse Source
This commit is contained in:
Nicola 2020-03-24 22:46:29 +11:00
parent 15d43e101e
commit 86f82c1247
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/helpers/useSession.js
View File

@ -113,6 +113,13 @@ function useSession(onConnectionOpen, onConnectionSync) {
};
}, [peer, peerId, connections, onConnectionOpen, onConnectionSync, streams]);
function call(connectionId) {
const call = peer.call(connectionId, streams[peerId]);
call.on("stream", stream => {
addStream(stream, connectionId);
});
}
function sync(connectionIds) {
for (let connectionId of connectionIds) {
if (connectionId in connections) {
@ -122,10 +129,7 @@ function useSession(onConnectionOpen, onConnectionSync) {
metadata: { sync: false }
});
addConnection(connection, false);
const call = peer.call(connectionId, streams[peerId]);
call.on("stream", stream => {
addStream(stream, connectionId);
});
call(connectionId);
}
}
@ -136,6 +140,7 @@ function useSession(onConnectionOpen, onConnectionSync) {
const connection = peer.connect(connectionId, {
metadata: { sync: true }
});
addConnection(connection, false);
connection.on("open", () => {
connection.on("data", data => {
if (data.id === "sync") {
@ -147,12 +152,7 @@ function useSession(onConnectionOpen, onConnectionSync) {
}
});
const call = peer.call(connectionId, streams[peerId]);
call.on("stream", remoteStream => {
addStream(remoteStream, connectionId);
});
addConnection(connection, false);
call(connectionId);
}
return { peer, peerId, streams, connections, connectTo };