feat : health check rustfs/rustfs#2096

Author: cxymds

app/(auth)/config/page.tsx

@@ -15,6 +15,7 @@ import { useMessage } from "@/lib/feedback/message"
 import { buildRoute, getLoginRoute } from "@/lib/routes"
 import logoImage from "@/assets/logo.svg"
 import { configManager } from "@/lib/config"
+import { checkServerHealth } from "@/lib/config-helpers"
 
 export default function ConfigPage() {
   return (
@@ -32,9 +33,12 @@ function ConfigPageContent() {
   const [serverHost, setServerHost] = useState(() =>
     typeof window !== "undefined" ? (localStorage.getItem("rustfs-server-host") ?? "") : "",
   )
+  const [isSaving, setIsSaving] = useState(false)
 
   const validateAndSave = async (e: React.FormEvent) => {
     e.preventDefault()
+    setIsSaving(true)
+
     try {
       if (serverHost) {
         let urlToValidate = serverHost.trim()
@@ -45,7 +49,16 @@ function ConfigPageContent() {
 
         new URL(urlToValidate)
 
-        const urlToSave = serverHost.match(/^https?:\/\//) ? serverHost : urlToValidate
+        const urlToSave = urlToValidate
+
+        const healthResult = await checkServerHealth(urlToSave)
+        if (!healthResult.healthy) {
+          message.error(
+            `${t("Unable to reach RustFS server health endpoint")}: ${healthResult.error ?? t("Request failed")}`,
+          )
+          return
+        }
+
         localStorage.setItem("rustfs-server-host", urlToSave)
 
         if (!serverHost.match(/^https?:\/\//)) {
@@ -64,6 +77,8 @@ function ConfigPageContent() {
       }, 200)
     } catch (error) {
       message.error(t("Invalid server address format") + ": " + (error as Error).message)
+    } finally {
+      setIsSaving(false)
     }
   }
 
@@ -125,15 +140,15 @@ function ConfigPageContent() {
                   </Field>
 
                   <div className="flex gap-3">
-                    <Button type="submit" className="flex-1">
+                    <Button type="submit" className="flex-1" disabled={isSaving}>
                       {t("Save Configuration")}
                     </Button>
 
-                    <Button type="button" variant="outline" onClick={resetToCurrentHost}>
+                    <Button type="button" variant="outline" onClick={resetToCurrentHost} disabled={isSaving}>
                       {t("Reset")}
                     </Button>
 
-                    <Button type="button" variant="outline" onClick={skipConfig}>
+                    <Button type="button" variant="outline" onClick={skipConfig} disabled={isSaving}>
                       {t("Skip")}
                     </Button>
                   </div>

lib/config-helpers.ts

@@ -22,13 +22,22 @@ interface HostInfo {
   serverHost: string
 }
 
+export interface ServerHealthCheckResult {
+  healthy: boolean
+  url?: string
+  status?: number
+  error?: string
+}
+
 const STORAGE_KEY = "rustfs-server-host"
 const CREDENTIALS_KEY = "auth.credentials"
 const PERMANENT_CREDENTIALS_KEY = "auth.permanent"
 const DEFAULT_REGION = "us-east-1"
 const API_PATH = "/rustfs/admin/v3"
 const VERSION_PATH = "/rustfs/console/version"
 const REQUEST_TIMEOUT = 5000
+const HEALTH_REQUEST_TIMEOUT = 5000
+const HEALTH_PATHS = ["/rustfs/console/health", "/health"] as const
 
 const isBrowser = (): boolean => typeof window !== "undefined"
 
@@ -185,6 +194,49 @@ export const fetchVersionConfigFromServer = async (serverHost: string): Promise<
   }
 }
 
+const requestHealth = async (url: string): Promise<Response> => {
+  const headResponse = await fetch(url, {
+    method: "HEAD",
+    signal: AbortSignal.timeout(HEALTH_REQUEST_TIMEOUT),
+  })
+
+  if (headResponse.status !== 405) return headResponse
+
+  return fetch(url, {
+    method: "GET",
+    signal: AbortSignal.timeout(HEALTH_REQUEST_TIMEOUT),
+  })
+}
+
+export const checkServerHealth = async (serverHost: string): Promise<ServerHealthCheckResult> => {
+  const normalizedHost = serverHost.replace(/\/+$/, "")
+  let lastError = "Unknown health check error"
+
+  for (const path of HEALTH_PATHS) {
+    const healthUrl = `${normalizedHost}${path}`
+
+    try {
+      const response = await requestHealth(healthUrl)
+      if (response.ok) {
+        return {
+          healthy: true,
+          url: healthUrl,
+          status: response.status,
+        }
+      }
+
+      lastError = `${response.status} ${response.statusText || "Health check failed"}`
+    } catch (error) {
+      lastError = error instanceof Error ? error.message : "Health check request failed"
+    }
+  }
+
+  return {
+    healthy: false,
+    error: lastError,
+  }
+}
+
 export const getServerDefaultConfig = (): ConfigResult => {
   const defaultServerHost = "http://localhost:9000"
   const config = createDefaultConfig(defaultServerHost)