feat: add more logging

packages/cojson/src/PeerState.ts

@@ -128,6 +128,9 @@ export class PeerState {
     this.processing = true;
 
     let msg: SyncMessage | undefined;
+
+    logger.info("[queue] Processing queue ${msg?.sessions?.sessionId}");
+
     while ((msg = this.queue.pull())) {
       if (this.closed) {
         break;

packages/cojson/src/streamUtils.ts

@@ -1,6 +1,7 @@
 import { Channel } from "queueueue";
 import { Peer, PeerID, SyncMessage } from "./sync.js";
 export { Channel } from "queueueue";
+import { logger } from "./logger.js";
 
 export function connectedPeers(
   peer1id: PeerID,
@@ -18,6 +19,10 @@ export function connectedPeers(
   const [from1to2Rx, from1to2Tx] = newQueuePair();
   const [from2to1Rx, from2to1Tx] = newQueuePair();
 
+  logger.info(
+    "A channel was opened for consumer with id: ${peer1id} and producer with id: ${peer2id}",
+  );
+
   const peer2AsPeer: Peer = {
     id: peer2id,
     incoming: from2to1Rx,

packages/cojson/src/sync.ts

@@ -361,6 +361,9 @@ export class SyncManager {
   }
 
   trySendToPeer(peer: PeerState, msg: SyncMessage) {
+    logger.info(
+      "[queue] Pushing coval ${msg.id} from session ${msg.sessions.sessionID} of ${peer.id} to the queue",
+    );
     return peer.pushOutgoingMessage(msg);
   }