From 79196304c48ae785000d391a4a42d3ad2685b61c Mon Sep 17 00:00:00 2001
From: Codex <codex@openai.com>
Date: Sat, 23 May 2026 20:03:01 +0800
Subject: [PATCH] Delay peer user sync until queued run starts

---
 .../server/src/services/hermes/run-chat/index.ts     | 12 ------------
 1 file changed, 12 deletions(-)

diff --git a/packages/server/src/services/hermes/run-chat/index.ts b/packages/server/src/services/hermes/run-chat/index.ts
index 135cbd6..aae2dc3 100644
--- a/packages/server/src/services/hermes/run-chat/index.ts
+++ b/packages/server/src/services/hermes/run-chat/index.ts
@@ -19,7 +19,6 @@ import { handleBridgeRun } from './handle-bridge-run'
 import { handleAbort } from './abort'
 import { getOrCreateSession } from './compression'
 import { handleSessionCommand, isSessionCommand, parseSessionCommand } from './session-command'
-import { contentBlocksToString } from './content-blocks'
 import type { ContentBlock, QueuedRun, SessionState } from './types'
 import { authenticateUserToken, isAuthEnabled, type AuthenticatedUser } from '../../../middleware/user-auth'
 import { userCanAccessProfile } from '../../../db/hermes/users-store'
@@ -159,17 +158,6 @@ export class ChatRunSocket {
             source,
             originSocketId: socket.id,
           })
-          socket.to(`session:${data.session_id}`).emit('run.peer_user_message', {
-            event: 'run.peer_user_message',
-            session_id: data.session_id,
-            message: {
-              id: queueId,
-              role: 'user',
-              content: contentBlocksToString(data.input),
-              timestamp: Math.floor(Date.now() / 1000),
-              queued: true,
-            },
-          })
           this.nsp.to(`session:${data.session_id}`).emit('run.queued', {
             event: 'run.queued',
             session_id: data.session_id,