From a035fea47f413cc753545a29718e4806d292eba5 Mon Sep 17 00:00:00 2001 From: Anthony LC Date: Tue, 11 Aug 2026 16:31:48 +0200 Subject: [PATCH] =?UTF-8?q?fixup!=20=F0=9F=94=92=EF=B8=8F(yprovider)=20rea?= =?UTF-8?q?dOnly=20connections=20awareness=20propagation?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../y-provider/src/servers/hocuspocusServer.ts | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/src/frontend/servers/y-provider/src/servers/hocuspocusServer.ts b/src/frontend/servers/y-provider/src/servers/hocuspocusServer.ts index 8070ec85b..7440446fe 100644 --- a/src/frontend/servers/y-provider/src/servers/hocuspocusServer.ts +++ b/src/frontend/servers/y-provider/src/servers/hocuspocusServer.ts @@ -3,6 +3,7 @@ import { Document, MessageReceiver, MessageType, + OutgoingMessage, Server, } from '@hocuspocus/server'; import { validate as uuidValidate, version as uuidVersion } from 'uuid'; @@ -27,6 +28,16 @@ MessageReceiver.prototype.apply = function ( this.message.decoder.pos = startPos; if (type === MessageType.Awareness) { + /* + * Never apply/broadcast the update, but echo an empty one back to the + * sender so it doesn't sit silent and trip the client's 30s + * reconnect-on-no-message watchdog (close code 1005). + */ + connection.send( + new OutgoingMessage(document.name) + .createAwarenessUpdateMessage(document.awareness, []) + .toUint8Array(), + ); return type; } }