ReconnectingWebSocket drops messages the server sends right after the handshake
Los mantenedores suelen responder en 2 días
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 3/5
- Tiempo estimado
- 1-2 días
- Aptitud para principiantes
- 72/100
- Tipo de issue
- Error
- Claridad
- Bien especificado
- Estado de actividad
- Activo
- Stack tecnológico
- node.js, typescript
- Área
- backend, networking, testing
Línea de trabajo
Start with src/websocket/reconnectingWebSocket.ts and src/api/coderApi.ts, tracing when the socket opens and when connect() registers listeners. Add a test where the server sends a message immediately on connection, as described in the issue. Done means the first message reaches subscribers on initial connect and reconnect; run the relevant WebSocket tests.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
Found in review of #1128.
Problem
ReconnectingWebSocket.connect() (src/websocket/reconnectingWebSocket.ts) attaches its message listener to the underlying socket only after await this.#socketFactory() resolves. The factory, createOneWayWebSocket in src/api/coderApi.ts, resolves through waitForOpen on the open event.
The server can send its first frame in the same chunk as the handshake. ws emits it on a process.nextTick, which runs before the awaited promise resumes connect(). So that message reaches no listener, and subscribers never see it. The stream logger attached in attachStreamLogger is registered before open, so it still logs the message; only delivery is lost.
This happens on the first connect and on every reconnect.
Impact
Any stream whose server writes right after the handshake can lose its first message. For example, watchAgentMetadata can show nothing until the agent's next metadata update. I haven't checked each stream: the workspace watch, build logs and agent logs may lose their first event or backlog the same way. The SSE fallback (SseConnection) isn't checked either.
Repro
A plain ws 8.22.0 client against a server that sends one message on connection. The client resolves a promise on open, awaits it, then adds its message listener, mirroring connect():
listener after awaited open: 20/20 dropped
listener before open: 0/20 dropped
Script
import { WebSocket, WebSocketServer } from "ws";
const server = new WebSocketServer({ port: 0 });
server.on("connection", (socket) => socket.send("initial"));
await new Promise((resolve) => server.once("listening", resolve));
const url = `ws://127.0.0.1:${server.address().port}`;
async function attempt(listenFirst) {
const socket = new WebSocket(url);
let received = false;
const onMessage = () => (received = true);
if (listenFirst) socket.on("message", onMessage);
await new Promise((resolve, reject) => {
socket.once("open", resolve);
socket.once("error", reject);
});
if (!listenFirst) socket.on("message", onMessage);
await new Promise((resolve) => setTimeout(resolve, 100));
socket.terminate();
return received;
}
for (const listenFirst of [false, true]) {
let dropped = 0;
for (let i = 0; i < 20; i++) if (!(await attempt(listenFirst))) dropped++;
console.log(`${listenFirst ? "before" : "after awaited"} open: ${dropped}/20 dropped`);
}
server.close();
Fix
Attach the message (and other) listeners before the socket opens. For example, have the factory return the socket unopened and let connect() wait for open after registering its listeners, or have OneWayWebSocket buffer messages until a listener is attached. Add a test where the server sends a message as soon as the connection opens.
- Lenguaje dominante
- TypeScript
- Estrellas
- 132
- Forks
- 48
- Merge medio
- 2 d 5 h
- PR fusionados (30 d)
- 19
Preparar el entorno
Inicia el contenedor de desarrollo del proyecto en tu navegador, con tu propia cuenta de GitHub.
- Sin Dockerfile ni archivo de Docker Compose
- Sin plantilla de pull request
- Leer la guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de coder/vscode-coder
-
bug tech-debt
Dificultad 3/5 1-2 días Aptitud para principiantes 68/100
coder/vscode-coder#1140 · 1 comentario ·
Los mantenedores suelen responder en 2 días
-
Split commands.ts by topicAbiertoImprovement tech-debt vs-code
Dificultad 4/5 3-5 días Aptitud para principiantes 48/100
coder/vscode-coder#1135 · 1 comentario ·
Los mantenedores suelen responder en 2 días
-
Migrate CI setup to pnpm/setupPosiblemente ocupada @EhabY la tomó hace 20 días. Abiertotech-debt
coder/vscode-coder#1119 · 1 comentario · 1 asignado ·
Los mantenedores suelen responder en 2 días
-
Design the VS Code Workspaces panelPosiblemente ocupada @chrifro la tomó hace 23 días. Abierto
coder/vscode-coder#1113 · 3 comentarios · 1 asignado ·
Los mantenedores suelen responder en 2 días
-
bug upstream
Dificultad 4/5 3-5 días Aptitud para principiantes 42/100
coder/vscode-coder#1087 · 1 comentario ·
Los mantenedores suelen responder en 2 días
Todos los issues de coder/vscode-coder
Issues similares
-
Dificultad 1/5 1-3 horas Aptitud para principiantes 84/100
Los mantenedores suelen responder en 1 día
-
core
Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100
vectorize-io/hindsight#5457 ·
Los mantenedores suelen responder en 1 día
-
beginner friendly community contributions-welcome good first issue hacktoberfest help wanted testing up-for-grabs
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
Los mantenedores suelen responder en 1 día
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 85/100
lukilabs/beautiful-mermaid#160 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 66/100
rescript-lang/rescript-lang.org#1420 ·
Los mantenedores suelen responder en 2 días