fix: WS peer UDS routing for bi-directional cross-machine mesh

Remote peers connected via WebSocket no longer trigger futile UDS
socket connections. Added hasRemotePeer() check — peers with an
active WS connection skip push.connect() and route via WS-first.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

Author: varun369

CHANGELOG.md

@@ -5,6 +5,11 @@ All notable changes to SLM Mesh will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.3.3] - 2026-05-22
+
+### Fixed
+- **WebSocket peer routing bug** — Remote peers connected via WS no longer trigger futile UDS socket connections. The broker now checks `hasRemotePeer()` before attempting UDS, and routes messages via WS for remote peers (WS-first, UDS fallback). Fixes bi-directional cross-machine messaging.
+
 ## [1.3.2] - 2026-05-22
 
 ### Added

package.json

@@ -1,6 +1,6 @@
 {
   "name": "slm-mesh",
-  "version": "1.3.2",
+  "version": "1.3.3",
   "description": "Peer-to-peer communication for AI coding agents — by Qualixar, powered by SuperLocalMemory",
   "author": "Varun Pratap Bhardwaj",
   "license": "Elastic-2.0",

src/broker/handlers.ts

@@ -247,7 +247,7 @@ export function createHandlers(deps: HandlerDeps) {
 
     stmtInsertPeer.run(peerId, name, pid, projectPath, gitRoot, gitBranch, agentType, udsPath);
 
-    if (udsPath) {
+    if (udsPath && !wsServer?.hasRemotePeer(peerId)) {
       push.connect(peerId, udsPath);
     }
 
@@ -368,7 +368,10 @@ export function createHandlers(deps: HandlerDeps) {
           payload: { messageId: msgId, fromPeer, text: payload },
           timestamp: ts,
         };
-        const delivered = push.send(peer.id, notification) || (wsServer?.sendToPeer(peer.id, notification) ?? false);
+        // Try WS first if this is a remote peer, fall back to UDS
+        const delivered = (wsServer?.hasRemotePeer(peer.id) && wsServer?.sendToPeer(peer.id, notification))
+          || push.send(peer.id, notification)
+          || (wsServer?.sendToPeer(peer.id, notification) ?? false);
         /* v8 ignore next 3 -- requires active push connection for broadcast */
         if (delivered) {
           stmtMarkDelivered.run(msgId);
@@ -426,7 +429,10 @@ export function createHandlers(deps: HandlerDeps) {
       payload: { messageId, fromPeer, text: payload },
       timestamp: ts,
     };
-    const delivered = push.send(toPeer, notification) || (wsServer?.sendToPeer(toPeer, notification) ?? false);
+    // Try WS first if this is a remote peer, fall back to UDS
+    const delivered = (wsServer?.hasRemotePeer(toPeer) && wsServer?.sendToPeer(toPeer, notification))
+      || push.send(toPeer, notification)
+      || (wsServer?.sendToPeer(toPeer, notification) ?? false);
     if (delivered) {
       stmtMarkDelivered.run(messageId);
     }

src/broker/push/ws-server.ts

@@ -15,6 +15,7 @@ export interface WsServer {
   stop(): Promise<void>;
   broadcast(data: unknown): void;
   sendToPeer(peerId: string, data: unknown): boolean;
+  hasRemotePeer(peerId: string): boolean;
   readonly clientCount: number;
 }
 
@@ -153,11 +154,16 @@ export function createWsServer(
     }
   }
 
+  function hasRemotePeer(peerId: string): boolean {
+    return _peerMap.has(peerId);
+  }
+
   return {
     start,
     stop,
     broadcast,
     sendToPeer,
+    hasRemotePeer,
     get clientCount(): number {
       return clients.size;
     },

src/config.ts

@@ -46,7 +46,7 @@ export interface MeshConfig {
   readonly walCheckpointIntervalMs: number;
 }
 
-export const VERSION = '1.3.2';
+export const VERSION = '1.3.3';
 export const PRODUCT_NAME = 'SLM Mesh';
 export const BRANDING = `${PRODUCT_NAME} v${VERSION} | Part of the Qualixar research initiative`;