Fix: Mock channel cleanup errors, mock cleanup improvements and CRDT operation issues

Author: bgn-dev

client/src/__tests__/integration/crdt-webrtc.test.js

@@ -101,7 +101,8 @@ describe('CRDT + WebRTC Integration', () => {
           setTimeout(() => {
             bobManager.onMessage('alice', msg);
           }, 10);
-        })
+        }),
+        close: jest.fn()
       };
 
       bobPeer.channel = { 
@@ -111,7 +112,8 @@ describe('CRDT + WebRTC Integration', () => {
           setTimeout(() => {
             aliceManager.onMessage('bob', msg);
           }, 10);
-        })
+        }),
+        close: jest.fn()
       };
 
       // Alice types "Hello"
@@ -177,14 +179,16 @@ describe('CRDT + WebRTC Integration', () => {
         readyState: 'open', 
         send: jest.fn((msg) => {
           setTimeout(() => bobManager.onMessage('alice', msg), 10);
-        })
+        }),
+        close: jest.fn()
       };
 
       bobPeer.channel = { 
         readyState: 'open', 
         send: jest.fn((msg) => {
           setTimeout(() => aliceManager.onMessage('bob', msg), 10);
-        })
+        }),
+        close: jest.fn()
       };
 
       // Alice builds "ABC" sequentially
@@ -235,7 +239,8 @@ describe('CRDT + WebRTC Integration', () => {
           if (networkUp) {
             setTimeout(() => bobManager.onMessage('alice', msg), 10);
           }
-        })
+        }),
+        close: jest.fn()
       };
 
       bobPeer.channel = { 
@@ -244,7 +249,8 @@ describe('CRDT + WebRTC Integration', () => {
           if (networkUp) {
             setTimeout(() => aliceManager.onMessage('bob', msg), 10);
           }
-        })
+        }),
+        close: jest.fn()
       };
 
       // Alice types while connected
@@ -313,7 +319,8 @@ describe('CRDT + WebRTC Integration', () => {
           if (messageCount % 2 === 0) {
             setTimeout(() => bobManager.onMessage('alice', msg), 10);
           }
-        })
+        }),
+        close: jest.fn()
       };
 
       // Send multiple operations - some at root to be independent
@@ -396,7 +403,8 @@ describe('CRDT + WebRTC Integration', () => {
             readyState: 'open', 
             send: jest.fn((msg) => {
               setTimeout(() => broadcastToAll(manager, msg), 10);
-            })
+            }),
+            close: jest.fn()
           };
         });
       });

client/src/__tests__/unit/crdt/crdt-validation.test.js

@@ -209,6 +209,7 @@ describe('CRDT Property Validation (Will Pass After Fix)', () => {
     test('handles empty operations gracefully', () => {
       const doc = new PeritextDocument('user1');
 
+      // This should trigger a console.warn for "Unknown operation type: undefined" - this is expected
       const invalidOp = {};
       const result = doc.applyOperation(invalidOp);
 

client/src/__tests__/unit/webrtc/webrtc-manager.test.js

@@ -157,8 +157,8 @@ describe('WebRTCManager - Basic Functionality', () => {
       // Mock data channels as open
       const peer1 = manager.peers.get('peer1');
       const peer2 = manager.peers.get('peer2');
-      peer1.channel = { readyState: 'open', send: jest.fn() };
-      peer2.channel = { readyState: 'open', send: jest.fn() };
+      peer1.channel = { readyState: 'open', send: jest.fn(), close: jest.fn() };
+      peer2.channel = { readyState: 'open', send: jest.fn(), close: jest.fn() };
 
       const message = 'test message';
       manager.broadcastMessage(message);
@@ -173,8 +173,8 @@ describe('WebRTCManager - Basic Functionality', () => {
 
       const peer1 = manager.peers.get('peer1');
       const peer2 = manager.peers.get('peer2');
-      peer1.channel = { readyState: 'open', send: jest.fn() };
-      peer2.channel = { readyState: 'closed', send: jest.fn() };
+      peer1.channel = { readyState: 'open', send: jest.fn(), close: jest.fn() };
+      peer2.channel = { readyState: 'closed', send: jest.fn(), close: jest.fn() };
 
       manager.broadcastMessage('test');