Function closeWebSocket

src/node/acp/serverConnection.ts:347–386

(websocket: WebSocket)

}

async function closeWebSocket(websocket: WebSocket): Promise<void> {
  if (websocket.readyState === WebSocket.CLOSED) {
    return;
  }

  await new Promise<void>((resolve) => {
    let finished = false;

    const finish = () => {
      if (finished) {
        return;
      }

      finished = true;
      clearTimeout(timeout);
      websocket.off("close", finish);
      websocket.off("error", finish);
      resolve();
    };

    const timeout = setTimeout(() => {
      try {
        websocket.terminate();
      } catch {
        // Best effort - socket may already be closing.
      }

      finish();
    }, 1000);

    websocket.once("close", finish);
    websocket.once("error", finish);

    try {
      websocket.close();
    } catch {
      finish();
    }
  });
}