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

Fix data channel support for data request replys and added token channel support

Browse Source
This commit is contained in:
Mitchell McCaffrey 2020-07-17 15:39:45 +10:00
parent cd8f0f8900
commit f25261d70b
2 changed files with 8 additions and 8 deletions

4
src/helpers/Session.js

@ -119,8 +119,8 @@ class Session extends EventEmitter {
}
const peer = { id, connection, initiator, sync };
function sendPeer(id, data) {
peer.connection.send({ id, data });
function sendPeer(id, data, channel) {
peer.connection.send({ id, data }, channel);
}
function handleSignal(signal) {

12
src/network/NetworkedMapAndTokens.js

@ -61,11 +61,11 @@ function NetworkedMapAndTokens({ session }) {
setCurrentMapState(newMapState);
setCurrentMap(newMap);
session.send("map", null, "map");
session.send("mapState", newMapState, "map");
session.send("mapState", newMapState);
session.send("map", getMapDataToSend(newMap), "map");
const tokensToSend = getMapTokensToSend(newMapState);
for (let token of tokensToSend) {
session.send("token", token);
session.send("token", token, "token");
}
}
@ -225,11 +225,11 @@ function NetworkedMapAndTokens({ session }) {
reply("mapState", currentMapState);
const tokensToSend = getMapTokensToSend(currentMapState);
for (let token of tokensToSend) {
reply("token", token);
reply("token", token, "token");
}
}
if (currentMap) {
reply("map", getMapDataToSend(currentMap));
reply("map", getMapDataToSend(currentMap), "map");
}
}
if (id === "map") {
@ -298,13 +298,13 @@ function NetworkedMapAndTokens({ session }) {
!cachedToken ||
cachedToken.lastModified !== newToken.lastModified
) {
reply("tokenRequest", newToken.id);
reply("tokenRequest", newToken.id, "token");
}
}
}
if (id === "tokenRequest") {
const token = getToken(data);
reply("tokenResponse", token);
reply("tokenResponse", token, "token");
}
if (id === "tokenResponse") {
const newToken = data;