diff --git a/src/lib/SystemQuery.mjs b/src/lib/SystemQuery.mjs index c11a132..5ec0d80 100644 --- a/src/lib/SystemQuery.mjs +++ b/src/lib/SystemQuery.mjs @@ -156,11 +156,11 @@ class SystemQuery extends EventEmitter { let peers_seen = []; while(peers_seen.length < this.agent.connected_peers.length) { - l.info(`peers_seen:`, peers_seen, `connected peers:`, this.agent.connected_peers.map(peer => peer.id)); + // l.info(`peers_seen:`, peers_seen, `connected peers:`, this.agent.connected_peers.map(peer => peer.id)); let next = await queue.dequeue(this.config.net.table_timeout * 1000); if(typeof next === "undefined") // We timed out break; - l.log(`fetch table DEBUG`, next); + // l.log(`fetch table DEBUG`, next); if(!peers_seen.includes(next.peer.id)) peers_seen.push(next.peer.id); yield next; diff --git a/src/lib/agent/subsystems/http/ServerSentEventStream.mjs b/src/lib/agent/subsystems/http/ServerSentEventStream.mjs index 00c9aac..7b1ad27 100644 --- a/src/lib/agent/subsystems/http/ServerSentEventStream.mjs +++ b/src/lib/agent/subsystems/http/ServerSentEventStream.mjs @@ -15,7 +15,7 @@ class ServerSentEventStream { } write(event_name, data) { - // l.log(`event #${this.next_id} ${event_name}: ${data}`); + l.log(`event #${this.next_id} ${event_name}: ${data}`); this.response.write(`id: ${this.next_id++}\n`); this.response.write(`event: ${event_name}\n`); this.response.write(`data: ${data}\n\n`);