changes from copilot

Author: taskbot

cmd/thv/app/proxy_stdio.go

@@ -61,7 +61,10 @@ func proxyStdioCmdFunc(cmd *cobra.Command, args []string) error {
 	logger.Infof("Starting stdio proxy for server=%q on %s:%d -> %s",
 		serverName, host, port, stdioWorkloadName)
 
-	bridge := transport.NewStdioBridge(stdioWorkload.URL)
+	bridge, err := transport.NewStdioBridge(stdioWorkload.URL)
+	if err != nil {
+		return fmt.Errorf("failed to create stdio bridge: %w", err)
+	}
 	bridge.Start(ctx)
 
 	// Consume until interrupt

docs/cli/thv_proxy_stdio.md

@@ -58,8 +58,6 @@ func (b *StdioBridge) loop(ctx context.Context) {
 			go b.runStreamableWriter(ctx)
 		} else { // legacy SSE
 			b.postURL = b.baseURL // reset
-			const legacyWorkerCount = 2
-			b.wg.Add(legacyWorkerCount)
 			go b.runLegacyReader(ctx)
 			go b.runLegacyWriter(ctx)
 		}
@@ -126,7 +124,11 @@ func (b *StdioBridge) handleInitializeResponse(resp *http.Response) {
 // Streamable HTTP handlers
 func (b *StdioBridge) runStreamableReader(ctx context.Context) {
 	defer b.wg.Done()
-	req, _ := http.NewRequestWithContext(ctx, "GET", b.baseURL.String(), nil)
+	req, err := http.NewRequestWithContext(ctx, "GET", b.baseURL.String(), nil)
+	if err != nil {
+		logger.Errorf("Failed to create GET request: %v", err)
+		return
+	}
 	req.Header.Set("Accept", "text/event-stream")
 	copyHeaders(req.Header, b.headers)
 	resp, err := http.DefaultClient.Do(req)