From 80be680e5239aaa12611f3b507f289ec3faff8ef Mon Sep 17 00:00:00 2001
From: root <root@v2202607378382480008.hotsrv.de>
Date: Sat, 11 Jul 2026 13:29:55 +0200
Subject: [PATCH] =?UTF-8?q?test:=20=E9=94=81=E5=AE=9A=20Cloud=20Web=20?=
 =?UTF-8?q?=E9=85=8D=E7=BD=AE=E5=A4=B1=E8=B4=A5=E4=B8=8D=E7=9B=91=E5=90=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dev-entrypoint/cloud-web-runtime.test.mjs | 35 +++++++++++++++++--
 1 file changed, 32 insertions(+), 3 deletions(-)

diff --git a/internal/dev-entrypoint/cloud-web-runtime.test.mjs b/internal/dev-entrypoint/cloud-web-runtime.test.mjs
index 2e9a4304..89504981 100644
--- a/internal/dev-entrypoint/cloud-web-runtime.test.mjs
+++ b/internal/dev-entrypoint/cloud-web-runtime.test.mjs
@@ -7,7 +7,7 @@ import path from "node:path";
 import test from "node:test";
 import { gzipSync } from "node:zlib";
 
-import { createCloudWebServer, isClientDisconnectError, validateCloudWebRuntimeConfig } from "./cloud-web-runtime.mjs";
+import { createCloudWebServer, isClientDisconnectError, serveCloudWeb } from "./cloud-web-runtime.mjs";
 
 test("cloud web classifies Bun client disconnect ECONNRESET as non-fatal", () => {
   const error = new Error("aborted");
@@ -16,7 +16,7 @@ test("cloud web classifies Bun client disconnect ECONNRESET as non-fatal", () =>
   assert.equal(isClientDisconnectError(new Error("database migration failed")), false);
 });
 
-test("cloud web rejects a missing refresh replay capability before listening", async () => {
+test("serveCloudWeb rejects a missing refresh replay capability without opening health or SPA routes", async () => {
   const restoreEnv = withEnv({
     HWLAB_CLOUD_WEB_DISPLAY_TIME_ZONE: "Asia/Shanghai",
     HWLAB_CLOUD_WEB_DISPLAY_TIME_LOCALE: "zh-CN",
@@ -29,8 +29,18 @@ test("cloud web rejects a missing refresh replay capability before listening", a
     HWLAB_WORKBENCH_RAW_HWLAB_EVENT_WINDOW_MAX_ENTRIES: "200",
     HWLAB_WORKBENCH_RAW_HWLAB_EVENT_WINDOW_MAX_RETAINED_BYTES: "1048576"
   });
+  delete process.env.HWLAB_WORKBENCH_KAFKA_REFRESH_REPLAY_ENABLED;
+  const port = await unusedPort();
   try {
-    await assert.rejects(validateCloudWebRuntimeConfig(), /HWLAB_WORKBENCH_KAFKA_REFRESH_REPLAY_ENABLED/u);
+    await assert.rejects(serveCloudWeb({
+      port,
+      serviceId: "hwlab-cloud-web",
+      healthPayload: () => ({ status: "ok" }),
+      sendJson() {
+        assert.fail("missing runtime configuration must fail before serving any response");
+      }
+    }), /HWLAB_WORKBENCH_KAFKA_REFRESH_REPLAY_ENABLED/u);
+    assert.equal(await canConnect(port), false, "serveCloudWeb must not bind before runtime configuration is valid");
   } finally {
     restoreEnv();
   }
@@ -1191,6 +1201,25 @@ function listen(server) {
   });
 }
 
+async function unusedPort() {
+  const server = createServer();
+  await listen(server);
+  const port = server.address().port;
+  await close(server);
+  return port;
+}
+
+function canConnect(port) {
+  return new Promise((resolve) => {
+    const socket = connect(port, "127.0.0.1");
+    socket.once("connect", () => {
+      socket.destroy();
+      resolve(true);
+    });
+    socket.once("error", () => resolve(false));
+  });
+}
+
 function close(server) {
   return new Promise((resolve, reject) => {
     server.close((error) => (error ? reject(error) : resolve()));