Fix LAN proxy model probing

joohw · joohw · commit f2ab216877ed · 2026-06-11T09:53:17.000+08:00
diff --git a/core/cmd/cli_smoke_test.go b/core/cmd/cli_smoke_test.go
@@ -69,6 +69,11 @@ func smokeIsolatedEnv(t *testing.T) []string {
 	if runtime.GOOS == "windows" {
 		env = append(env, "USERPROFILE="+home)
 	}
+	t.Cleanup(func() {
+		cmd := exec.Command(smokeClovapiBinary(t), "proxy", "stop")
+		cmd.Env = env
+		_ = cmd.Run()
+	})
 	return env
 }
 
diff --git a/core/cmd/main.go b/core/cmd/main.go
@@ -621,6 +621,7 @@ func cmdProxyLogs() *cobra.Command {
 		Short: "List recent call log entries",
 		RunE: func(cmd *cobra.Command, args []string) error {
 			store := coreproxy.NewCallLogStore()
+			defer store.Close()
 			var entries []coreproxy.CallLogEntry
 			if strings.TrimSpace(sessionID) != "" {
 				entries = store.ListRecentSessionPage(limit, offset, sessionID)
@@ -666,6 +667,7 @@ func cmdProxyLogs() *cobra.Command {
 		Short: "List grouped call log sessions",
 		RunE: func(cmd *cobra.Command, args []string) error {
 			store := coreproxy.NewCallLogStore()
+			defer store.Close()
 			items := store.ListSessions(limit)
 			if jsonOut {
 				data, err := json.MarshalIndent(items, "", "  ")
@@ -756,7 +758,9 @@ func cmdProxyLogs() *cobra.Command {
 					return nil
 				}
 			}
-			coreproxy.NewCallLogStore().Clear()
+			store := coreproxy.NewCallLogStore()
+			defer store.Close()
+			store.Clear()
 			fmt.Println("Call logs cleared.")
 			return nil
 		},
diff --git a/core/cmd/proxy_cmd.go b/core/cmd/proxy_cmd.go
@@ -126,7 +126,7 @@ func spawnDetachedProxyServe(cfg profile.ProxyConfig) (int, error) {
 
 	host := strings.TrimSpace(cfg.Host)
 	if host == "" {
-		host = "127.0.0.1"
+		host = "0.0.0.0"
 	}
 	args := []string{"__proxy-daemon", "--host", host, "--port", strconv.Itoa(cfg.Port)}
 	cmd := exec.Command(exe, args...)
diff --git a/core/cmd/proxy_status_json.go b/core/cmd/proxy_status_json.go
@@ -45,7 +45,7 @@ func probeProxyHealthBody(cfg profile.ProxyConfig) (bool, map[string]any, int64,
 func buildProxyStatusJSON(cfg profile.ProxyConfig, includeLatency bool) proxyStatusJSON {
 	host := strings.TrimSpace(cfg.Host)
 	if host == "" {
-		host = "127.0.0.1"
+		host = "0.0.0.0"
 	}
 	port := cfg.Port
 	if port <= 0 {
diff --git a/core/internal/buildinfo/buildinfo.go b/core/internal/buildinfo/buildinfo.go
@@ -4,7 +4,7 @@ import "strings"
 
 // Set at link time via -ldflags (see .goreleaser.yaml).
 var (
-	Version = "dev0.1.114"
+	Version = "dev0.1.116"
 	Commit  = "none"
 	Date    = "unknown"
 )
diff --git a/core/internal/desktop/test.go b/core/internal/desktop/test.go
@@ -25,12 +25,12 @@ type TestResult struct {
 }
 
 func proxyConfigForTest(s *profile.Store, portOverride int) profile.ProxyConfig {
-	cfg := profile.ProxyConfig{Enabled: true, Host: "127.0.0.1", Port: 27483}
+	cfg := profile.ProxyConfig{Enabled: true, Host: "0.0.0.0", Port: 27483}
 	if s != nil {
 		cfg = s.Proxy
 	}
 	if strings.TrimSpace(cfg.Host) == "" {
-		cfg.Host = "127.0.0.1"
+		cfg.Host = "0.0.0.0"
 	}
 	if cfg.Port == 0 {
 		cfg.Port = 27483
diff --git a/core/internal/desktop/test_test.go b/core/internal/desktop/test_test.go
@@ -11,8 +11,8 @@ func TestProxyConfigForTestAppliesDefaultsAndOverride(t *testing.T) {
 		Proxy: profile.ProxyConfig{Host: "", Port: 1234},
 	}, 5678)
 
-	if cfg.Host != "127.0.0.1" {
-		t.Fatalf("Host = %q, want 127.0.0.1", cfg.Host)
+	if cfg.Host != "0.0.0.0" {
+		t.Fatalf("Host = %q, want 0.0.0.0", cfg.Host)
 	}
 	if cfg.Port != 5678 {
 		t.Fatalf("Port = %d, want 5678", cfg.Port)
diff --git a/core/internal/profile/store.go b/core/internal/profile/store.go
@@ -16,15 +16,15 @@ import (
 )
 
 func defaultProxyConfig() ProxyConfig {
-	return ProxyConfig{Enabled: true, Host: "127.0.0.1", Port: 27483}
+	return ProxyConfig{Enabled: true, Host: "0.0.0.0", Port: 27483}
 }
 
 func ensureProxyDefaults(s *Store, oldVersion int) {
 	if s == nil {
 		return
 	}
 	if strings.TrimSpace(s.Proxy.Host) == "" {
-		s.Proxy.Host = "127.0.0.1"
+		s.Proxy.Host = "0.0.0.0"
 	}
 	if s.Proxy.Port == 0 {
 		s.Proxy.Port = 27483
diff --git a/core/internal/proxy/calllog_test.go b/core/internal/proxy/calllog_test.go
@@ -20,9 +20,9 @@ func openTestCallLogStore(t *testing.T) *CallLogStore {
 
 func TestCallLogStorePushAndList(t *testing.T) {
 	store := openTestCallLogStore(t)
-	store.Push(CallLogEntry{Request: CallLogRequest{Method: "POST", URL: "/a"}})
-	store.Push(CallLogEntry{Request: CallLogRequest{Method: "GET", URL: "/b"}})
-	store.Push(CallLogEntry{Request: CallLogRequest{Method: "DELETE", URL: "/c"}})
+	store.Push(CallLogEntry{StartedAt: "2026-01-01T00:00:01Z", Request: CallLogRequest{Method: "POST", URL: "/a"}})
+	store.Push(CallLogEntry{StartedAt: "2026-01-01T00:00:02Z", Request: CallLogRequest{Method: "GET", URL: "/b"}})
+	store.Push(CallLogEntry{StartedAt: "2026-01-01T00:00:03Z", Request: CallLogRequest{Method: "DELETE", URL: "/c"}})
 
 	entries := store.ListRecent(0)
 	if len(entries) != 3 {
diff --git a/core/internal/proxy/server.go b/core/internal/proxy/server.go
@@ -61,7 +61,7 @@ type debugTransformResponse struct {
 
 func NewServer(cfg profile.ProxyConfig) *Server {
 	if strings.TrimSpace(cfg.Host) == "" {
-		cfg.Host = "127.0.0.1"
+		cfg.Host = "0.0.0.0"
 	}
 	if cfg.Port == 0 {
 		cfg.Port = 27483
diff --git a/core/internal/proxy/server_test.go b/core/internal/proxy/server_test.go
@@ -21,6 +21,7 @@ import (
 
 func newTestServer(cfg profile.ProxyConfig) *Server {
 	s := NewServer(cfg)
+	_ = s.CallLogs.Close()
 	s.CallLogs = nil
 	return s
 }
diff --git a/core/internal/proxyresolve/join_resolve_test.go b/core/internal/proxyresolve/join_resolve_test.go
@@ -24,6 +24,12 @@ func TestJoinURLDedupV1Suffix(t *testing.T) {
 	if got := proxyresolve.JoinURL("https://chatgpt.com/backend-api", "/codex/responses"); got != "https://chatgpt.com/backend-api/codex/responses" {
 		t.Fatalf("codex path mismatch: %q", got)
 	}
+	if got := proxyresolve.JoinURL("http://192.168.43.63:27483/codex", "/responses"); got != "http://192.168.43.63:27483/codex/v1/responses" {
+		t.Fatalf("chained clovapi responses route mismatch: %q", got)
+	}
+	if got := proxyresolve.JoinURL("http://192.168.43.63:27483/codex/v1", "/responses"); got != "http://192.168.43.63:27483/codex/v1/responses" {
+		t.Fatalf("chained clovapi responses route with v1 base mismatch: %q", got)
+	}
 }
 
 func TestDefaultUpstreamCodexResponsesPath(t *testing.T) {
diff --git a/core/internal/testclient/testclient.go b/core/internal/testclient/testclient.go
@@ -1,6 +1,7 @@
 package testclient
 
 import (
+	"bufio"
 	"bytes"
 	"encoding/json"
 	"errors"
@@ -302,6 +303,9 @@ func postJSONProbe(u string, headers map[string]string, payload map[string]any)
 func readProbeResponse(resp *http.Response) error {
 	defer resp.Body.Close()
 	if resp.StatusCode >= 200 && resp.StatusCode < 300 {
+		if strings.Contains(strings.ToLower(strings.TrimSpace(resp.Header.Get("Content-Type"))), "text/event-stream") {
+			return readProbeSSETerminal(resp.Body)
+		}
 		if _, err := io.Copy(io.Discard, resp.Body); err != nil {
 			return fmt.Errorf("read response: %w", err)
 		}
@@ -313,3 +317,58 @@ func readProbeResponse(resp *http.Response) error {
 	}
 	return fmt.Errorf("HTTP %s: %s", resp.Status, strings.TrimSpace(string(body)))
 }
+
+func readProbeSSETerminal(r io.Reader) error {
+	scanner := bufio.NewScanner(r)
+	scanner.Buffer(make([]byte, 0, 64*1024), 1024*1024)
+	var event string
+	for scanner.Scan() {
+		line := strings.TrimSpace(scanner.Text())
+		if line == "" {
+			event = ""
+			continue
+		}
+		if strings.HasPrefix(line, "event:") {
+			event = strings.TrimSpace(strings.TrimPrefix(line, "event:"))
+			if isProbeTerminalSSEEvent(event) {
+				return nil
+			}
+			continue
+		}
+		if strings.HasPrefix(line, "data:") {
+			data := strings.TrimSpace(strings.TrimPrefix(line, "data:"))
+			if data == "[DONE]" || isProbeTerminalSSEData(data) || isProbeTerminalSSEEvent(event) {
+				return nil
+			}
+		}
+	}
+	if err := scanner.Err(); err != nil {
+		return fmt.Errorf("read response: %w", err)
+	}
+	return nil
+}
+
+func isProbeTerminalSSEEvent(event string) bool {
+	switch strings.TrimSpace(event) {
+	case "response.completed", "message_stop":
+		return true
+	default:
+		return false
+	}
+}
+
+func isProbeTerminalSSEData(data string) bool {
+	var obj map[string]any
+	if err := json.Unmarshal([]byte(data), &obj); err != nil {
+		return false
+	}
+	if typ, _ := obj["type"].(string); isProbeTerminalSSEEvent(typ) {
+		return true
+	}
+	if status, _ := obj["status"].(string); strings.TrimSpace(status) == "completed" {
+		return true
+	}
+	resp, _ := obj["response"].(map[string]any)
+	status, _ := resp["status"].(string)
+	return strings.TrimSpace(status) == "completed"
+}
diff --git a/core/internal/testclient/testclient_test.go b/core/internal/testclient/testclient_test.go
@@ -7,6 +7,7 @@ import (
 	"net/http/httptest"
 	"strings"
 	"testing"
+	"time"
 
 	"github.com/clovapi/switcher/internal/apistyle"
 )
@@ -271,6 +272,34 @@ func TestReadProbeResponseDrainsSuccessfulBody(t *testing.T) {
 	}
 }
 
+func TestReadProbeResponseStopsAtSSETerminalEvent(t *testing.T) {
+	done := make(chan struct{})
+	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		defer close(done)
+		w.Header().Set("Content-Type", "text/event-stream")
+		if f, ok := w.(http.Flusher); ok {
+			_, _ = w.Write([]byte("event: response.completed\ndata: {\"type\":\"response.completed\"}\n\n"))
+			f.Flush()
+		}
+		<-r.Context().Done()
+	}))
+	t.Cleanup(srv.Close)
+
+	client := &http.Client{Timeout: time.Second}
+	resp, err := client.Get(srv.URL)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := readProbeResponse(resp); err != nil {
+		t.Fatal(err)
+	}
+	select {
+	case <-done:
+	case <-time.After(time.Second):
+		t.Fatal("probe did not close SSE response after terminal event")
+	}
+}
+
 type trackingReadCloser struct {
 	*strings.Reader
 	closed bool
diff --git a/electron/clovapi-proxy.js b/electron/clovapi-proxy.js
@@ -6,15 +6,10 @@ const {
 const clovapiDesktop = require("./clovapi-desktop");
 
 const DEFAULT_PORT = 27483;
-const DEFAULT_HOST = "127.0.0.1";
+const DEFAULT_HOST = "0.0.0.0";
 
 function normalizeHost(host) {
-  const raw = String(host || "").trim() || DEFAULT_HOST;
-  const lower = raw.toLowerCase();
-  if (lower === "0.0.0.0" || lower === "::" || lower === "::ffff:0.0.0.0") {
-    return DEFAULT_HOST;
-  }
-  return raw;
+  return String(host || "").trim() || DEFAULT_HOST;
 }
 
 function normalizePort(port) {
diff --git a/electron/clovapi-proxy.test.js b/electron/clovapi-proxy.test.js
@@ -7,26 +7,33 @@ const {
   buildProxyHealthArgs,
 } = require("./clovapi-proxy");
 
-test("buildProxyStartArgs — argv tokens fixed", () => {
+test("buildProxyStartArgs keeps explicit host", () => {
   const { args, host, port } = buildProxyStartArgs({ host: "127.0.0.1", port: 1234 });
   assert.deepEqual(args, ["proxy", "start", "--host", "127.0.0.1", "--port", "1234"]);
   assert.equal(host, "127.0.0.1");
   assert.equal(port, 1234);
 });
 
-test("buildProxyStopArgs — argv tokens fixed", () => {
+test("buildProxyStartArgs uses wildcard host by default", () => {
+  const { args, host, port } = buildProxyStartArgs({});
+  assert.deepEqual(args, ["proxy", "start", "--host", "0.0.0.0", "--port", "27483"]);
+  assert.equal(host, "0.0.0.0");
+  assert.equal(port, 27483);
+});
+
+test("buildProxyStopArgs keeps explicit host", () => {
   const { args, host, port } = buildProxyStopArgs({ host: "127.0.0.1", port: 1234 });
   assert.deepEqual(args, ["proxy", "stop", "--host", "127.0.0.1", "--port", "1234"]);
   assert.equal(host, "127.0.0.1");
   assert.equal(port, 1234);
 });
 
-test("buildProxyStatusArgs — includes json flag", () => {
+test("buildProxyStatusArgs includes json flag", () => {
   const { args } = buildProxyStatusArgs({ host: "127.0.0.1", port: 27483 });
   assert.deepEqual(args, ["proxy", "status", "--json", "--host", "127.0.0.1", "--port", "27483"]);
 });
 
-test("buildProxyHealthArgs — includes json flag", () => {
+test("buildProxyHealthArgs includes json flag", () => {
   const { args } = buildProxyHealthArgs({ host: "127.0.0.1", port: 27483 });
   assert.deepEqual(args, ["proxy", "health", "--json", "--host", "127.0.0.1", "--port", "27483"]);
 });
diff --git a/electron/main.js b/electron/main.js
@@ -188,7 +188,7 @@ async function readTrayProxyState() {
       managed: Boolean(status?.managed),
       external: Boolean(status?.external),
       port: Number(status?.port) || Number(cfg?.port) || 27483,
-      host: String(status?.host || cfg?.host || "127.0.0.1"),
+      host: String(status?.host || cfg?.host || "0.0.0.0"),
       baseUrl: String(status?.baseUrl || ""),
       error: String(status?.error || ""),
     };
@@ -199,7 +199,7 @@ async function readTrayProxyState() {
       managed: false,
       external: false,
       port: 27483,
-      host: "127.0.0.1",
+      host: "0.0.0.0",
       baseUrl: "",
       error: error instanceof Error ? error.message : "Failed to read proxy status",
     };
diff --git a/electron/ui/src/components/VendorDetailPanel.svelte b/electron/ui/src/components/VendorDetailPanel.svelte
diff --git a/electron/ui/src/lib/store/profile-persist.ts b/electron/ui/src/lib/store/profile-persist.ts

Original file line number	Diff line number	Diff line change
`@@ -69,6 +69,11 @@ func smokeIsolatedEnv(t *testing.T) []string {`
`69`	`69`	`if runtime.GOOS == "windows" {`
`70`	`70`	`env = append(env, "USERPROFILE="+home)`
`71`	`71`	`}`
	`72`	`+ t.Cleanup(func() {`
	`73`	`+ cmd := exec.Command(smokeClovapiBinary(t), "proxy", "stop")`
	`74`	`+ cmd.Env = env`
	`75`	`+ _ = cmd.Run()`
	`76`	`+ })`
`72`	`77`	`return env`
`73`	`78`	`}`
`74`	`79`
Original file line number	Diff line number	Diff line change
`@@ -126,7 +126,7 @@ func spawnDetachedProxyServe(cfg profile.ProxyConfig) (int, error) {`
`126`	`126`
`127`	`127`	`host := strings.TrimSpace(cfg.Host)`
`128`	`128`	`if host == "" {`
`129`		`- host = "127.0.0.1"`
	`129`	`+ host = "0.0.0.0"`
`130`	`130`	`}`
`131`	`131`	`args := []string{"__proxy-daemon", "--host", host, "--port", strconv.Itoa(cfg.Port)}`
`132`	`132`	`cmd := exec.Command(exe, args...)`
Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ func probeProxyHealthBody(cfg profile.ProxyConfig) (bool, map[string]any, int64,`
`45`	`45`	`func buildProxyStatusJSON(cfg profile.ProxyConfig, includeLatency bool) proxyStatusJSON {`
`46`	`46`	`host := strings.TrimSpace(cfg.Host)`
`47`	`47`	`if host == "" {`
`48`		`- host = "127.0.0.1"`
	`48`	`+ host = "0.0.0.0"`
`49`	`49`	`}`
`50`	`50`	`port := cfg.Port`
`51`	`51`	`if port <= 0 {`
Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,7 @@ import "strings"`
`4`	`4`
`5`	`5`	`// Set at link time via -ldflags (see .goreleaser.yaml).`
`6`	`6`	`var (`
`7`		`- Version = "dev0.1.114"`
	`7`	`+ Version = "dev0.1.116"`
`8`	`8`	`Commit = "none"`
`9`	`9`	`Date = "unknown"`
`10`	`10`	`)`
Original file line number	Diff line number	Diff line change
`@@ -25,12 +25,12 @@ type TestResult struct {`
`25`	`25`	`}`
`26`	`26`
`27`	`27`	`func proxyConfigForTest(s *profile.Store, portOverride int) profile.ProxyConfig {`
`28`		`- cfg := profile.ProxyConfig{Enabled: true, Host: "127.0.0.1", Port: 27483}`
	`28`	`+ cfg := profile.ProxyConfig{Enabled: true, Host: "0.0.0.0", Port: 27483}`
`29`	`29`	`if s != nil {`
`30`	`30`	`cfg = s.Proxy`
`31`	`31`	`}`
`32`	`32`	`if strings.TrimSpace(cfg.Host) == "" {`
`33`		`- cfg.Host = "127.0.0.1"`
	`33`	`+ cfg.Host = "0.0.0.0"`
`34`	`34`	`}`
`35`	`35`	`if cfg.Port == 0 {`
`36`	`36`	`cfg.Port = 27483`
Original file line number	Diff line number	Diff line change
`@@ -16,15 +16,15 @@ import (`
`16`	`16`	`)`
`17`	`17`
`18`	`18`	`func defaultProxyConfig() ProxyConfig {`
`19`		`- return ProxyConfig{Enabled: true, Host: "127.0.0.1", Port: 27483}`
	`19`	`+ return ProxyConfig{Enabled: true, Host: "0.0.0.0", Port: 27483}`
`20`	`20`	`}`
`21`	`21`
`22`	`22`	`func ensureProxyDefaults(s *Store, oldVersion int) {`
`23`	`23`	`if s == nil {`
`24`	`24`	`return`
`25`	`25`	`}`
`26`	`26`	`if strings.TrimSpace(s.Proxy.Host) == "" {`
`27`		`- s.Proxy.Host = "127.0.0.1"`
	`27`	`+ s.Proxy.Host = "0.0.0.0"`
`28`	`28`	`}`
`29`	`29`	`if s.Proxy.Port == 0 {`
`30`	`30`	`s.Proxy.Port = 27483`
Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ type debugTransformResponse struct {`
`61`	`61`
`62`	`62`	`func NewServer(cfg profile.ProxyConfig) *Server {`
`63`	`63`	`if strings.TrimSpace(cfg.Host) == "" {`
`64`		`- cfg.Host = "127.0.0.1"`
	`64`	`+ cfg.Host = "0.0.0.0"`
`65`	`65`	`}`
`66`	`66`	`if cfg.Port == 0 {`
`67`	`67`	`cfg.Port = 27483`