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

Added logging to connection

Browse Source
This commit is contained in:
Mitchell McCaffrey 2021-01-04 13:05:31 +11:00
parent a6f67320c5
commit bce5fb6154
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/network/Connection.js
View File

@ -15,11 +15,13 @@ class Connection extends SimplePeer {
this.dataChannels = {}; this.dataChannels = {};
this.on("data", this.handleData); this.on("data", this.handleData);
this.on("datachannel", this.handleDataChannel); this.on("datachannel", this.handleDataChannel);
super._debug = console.log;
} }
// Intercept the data event with decoding and chunking support // Intercept the data event with decoding and chunking support
handleData(packed) { handleData(packed) {
const unpacked = decode(packed); const unpacked = decode(packed);
console.log("data", unpacked);
// If the special property __chunked is set and true // If the special property __chunked is set and true
// The data is a partial chunk of the a larger file // The data is a partial chunk of the a larger file
// So wait until all chunks are collected and assembled // So wait until all chunks are collected and assembled
@ -62,6 +64,7 @@ class Connection extends SimplePeer {
if (packedData.byteLength > MAX_BUFFER_SIZE) { if (packedData.byteLength > MAX_BUFFER_SIZE) {
const chunks = this.chunk(packedData); const chunks = this.chunk(packedData);
for (let chunk of chunks) { for (let chunk of chunks) {
console.log("sending", chunk);
if (this.dataChannels[channel]) { if (this.dataChannels[channel]) {
// Write to the stream to allow for buffer / backpressure handling // Write to the stream to allow for buffer / backpressure handling
this.dataChannels[channel].write(encode(chunk)); this.dataChannels[channel].write(encode(chunk));
@ -95,6 +98,7 @@ class Connection extends SimplePeer {
this.dataChannels[channelName] = channel; this.dataChannels[channelName] = channel;
channel.on("data", this.handleData.bind(this)); channel.on("data", this.handleData.bind(this));
channel.on("error", (error) => { channel.on("error", (error) => {
console.error("error", error);
this.emit("error", error); this.emit("error", error);
}); });
} }