fix: standardize response body closure and improve code formatting in SSE and registry handling

Author: Code2Life

internal/agent/sse.go

@@ -11,11 +11,11 @@ import (
 )
 
 const (
-	sseEndpoint       = "https://sse.tensor-fusion.ai/stream"
-	sseReconnectMin   = 1 * time.Second
-	sseReconnectMax   = 30 * time.Second
-	sseDebounceDelay  = 500 * time.Millisecond
-	sseTopicHeader    = "x-sse-topic"
+	sseEndpoint      = "https://sse.tensor-fusion.ai/stream"
+	sseReconnectMin  = 1 * time.Second
+	sseReconnectMax  = 30 * time.Second
+	sseDebounceDelay = 500 * time.Millisecond
+	sseTopicHeader   = "x-sse-topic"
 )
 
 // sseConfigListener connects to the SSE endpoint and triggers config re-fetch on new events.
@@ -70,7 +70,7 @@ func (a *Agent) listenSSE() error {
 	if err != nil {
 		return err
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 
 	if resp.StatusCode != http.StatusOK {
 		klog.Warningf("SSE endpoint returned status %d", resp.StatusCode)

internal/api/types.go

@@ -141,7 +141,7 @@ type AgentStatusRequest struct {
 type AgentStatusResponse struct {
 	Success          bool                `json:"success"`
 	ConfigVersion    int                 `json:"config_version"`
-	License          *License            `json:"license,omitempty"` // null if no regeneration needed
+	License          *License            `json:"license,omitempty"`            // null if no regeneration needed
 	WorkerShareCodes map[string][]string `json:"worker_share_codes,omitempty"` // workerID -> []shareCode
 }
 

internal/studio/registry.go

@@ -196,7 +196,7 @@ func getRegistryToken(ctx context.Context, registry, repo, username, password st
 	if err != nil {
 		return "", fmt.Errorf("token request failed: %w", err)
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 
 	if resp.StatusCode != http.StatusOK {
 		return "", fmt.Errorf("token endpoint returned %d", resp.StatusCode)
@@ -263,7 +263,7 @@ func ListRemoteTags(ctx context.Context, image string, limit int) ([]string, err
 	if err != nil {
 		return nil, fmt.Errorf("registry request failed: %w", err)
 	}
-	defer resp.Body.Close()
+	defer func() { _ = resp.Body.Close() }()
 
 	if resp.StatusCode == http.StatusUnauthorized {
 		return nil, fmt.Errorf("authentication required for %s/%s — run 'docker login %s'", registry, repo, registry)