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

Added a sync option when connecting to peers

Browse Source 
Optimises the user join time by not sending the image data multiple times
This commit is contained in:
Mitchell McCaffrey 2020-04-06 14:33:22 +10:00
parent bdc1a7c14d
commit ac9189c606
2 changed files with 19 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/helpers/useSession.js
View File

@ -14,7 +14,7 @@ function useSession(partyId, onPeerConnected, onPeerDisconnected, onPeerData) {
const [peers, setPeers] = useState({});
useEffect(() => {
function addPeer(id, initiator) {
function addPeer(id, initiator, sync) {
const peer = new Peer({ initiator, trickle: false });
peer.on("signal", (signal) => {
@ -23,6 +23,9 @@ function useSession(partyId, onPeerConnected, onPeerDisconnected, onPeerData) {
peer.on("connect", () => {
onPeerConnected && onPeerConnected({ id, peer, initiator });
if (sync) {
peer.send({ id: "sync" });
}
});
peer.on("dataComplete", (data) => {
@ -45,7 +48,7 @@ function useSession(partyId, onPeerConnected, onPeerDisconnected, onPeerData) {
}
function handlePartyMemberJoined(id) {
addPeer(id, false);
addPeer(id, false, false);
}
function handlePartyMemberLeft(id) {
@ -56,8 +59,10 @@ function useSession(partyId, onPeerConnected, onPeerDisconnected, onPeerData) {
}
function handleJoinedParty(otherIds) {
for (let id of otherIds) {
addPeer(id, true);
for (let [index, id] of otherIds.entries()) {
// Send a sync request to the first member of the party
const sync = index === 0;
addPeer(id, true, sync);
}
}

18
src/routes/Game.js
View File

@ -70,17 +70,19 @@ function Game() {
}
}
function handlePeerConnected({ peer, initiator }) {
if (!initiator) {
if (mapSource) {
peer.send({ id: "map", data: mapDataRef.current });
}
peer.send({ id: "tokenEdit", data: mapTokens });
}
function handlePeerConnected({ peer }) {
peer.send({ id: "nickname", data: { [socket.id]: nickname } });
}
function handlePeerData({ data }) {
function handlePeerData({ data, peer }) {
if (data.id === "sync") {
if (mapSource) {
peer.send({ id: "map", data: mapDataRef.current });
}
if (mapTokens) {
peer.send({ id: "tokenEdit", data: mapTokens });
}
}
if (data.id === "map") {
const blob = new Blob([data.data.file]);
mapDataRef.current = { ...data.data, file: blob };