lint: enable noctx and deduplicate touched code

Adds noctx to the enabled golangci-lint set and threads context through the HTTP, SQL, exec and net APIs it flags.

- Tests use t.Context() with the *Context / WithContext variants.

- Production code passes ctx where it is already in scope, uses context.Background() for genuine background work (DB schema migrations, sqlite Ping at startup, fire-and-forget audio playback) and adds //nolint:noctx for the few intentionally non-context-bound calls (tea.ExecProcess-driven interactive shells/editors and the explicit kill+WaitDelay flow in the shell tool).

While here, factor out the patterns that ended up duplicated:

- pkg/sqliteutil.CheckpointAndClose, used by the three RAG strategy databases.

- pkg/skills.httpGet, used by both cache.go and remote.go.

- pkg/sound.runDetached, used by all platform-specific play funcs.

- pkg/tools/mcp listenTCPRetry test helper, used in three places.

- pkg/tui handlers split into newInteractiveShellCmd + a single execCmd wrapper carrying the only //nolint:noctx (was four).

No behavior change.

Assisted-By: docker-agent

Author: dgageot

.golangci.yml

@@ -41,6 +41,7 @@ linters:
     - mirror
     - modernize
     - nakedret
+    - noctx
     - nolintlint
     - nosprintfhostport
     - nilnesserr

e2e/api_test.go

@@ -47,7 +47,9 @@ func TestCagentAPI_ListSessions(t *testing.T) {
 				},
 			}
 
-			resp, err := client.Get("http://localhost/api/sessions")
+			req, err := http.NewRequestWithContext(t.Context(), http.MethodGet, "http://localhost/api/sessions", http.NoBody)
+			require.NoError(t, err)
+			resp, err := client.Do(req)
 			require.NoError(t, err)
 			defer resp.Body.Close()
 

pkg/fake/proxy_test.go

@@ -61,7 +61,7 @@ func TestAPIKeyHeaderUpdater(t *testing.T) {
 		t.Run(tt.name, func(t *testing.T) {
 			t.Setenv(tt.envKey, tt.envValue)
 
-			req, err := http.NewRequest(http.MethodPost, "https://example.com", http.NoBody)
+			req, err := http.NewRequestWithContext(t.Context(), http.MethodPost, "https://example.com", http.NoBody)
 			require.NoError(t, err)
 
 			APIKeyHeaderUpdater(tt.host, req)
@@ -72,7 +72,7 @@ func TestAPIKeyHeaderUpdater(t *testing.T) {
 }
 
 func TestAPIKeyHeaderUpdater_UnknownHost(t *testing.T) {
-	req, err := http.NewRequest(http.MethodPost, "https://example.com", http.NoBody)
+	req, err := http.NewRequestWithContext(t.Context(), http.MethodPost, "https://example.com", http.NoBody)
 	require.NoError(t, err)
 
 	APIKeyHeaderUpdater("https://unknown.host.com", req)
@@ -222,7 +222,7 @@ func TestStreamCopy_ContextCancellation(t *testing.T) {
 
 	// Create an echo context with a request that has a cancelable context
 	e := echo.New()
-	req := httptest.NewRequest(http.MethodGet, "/", http.NoBody)
+	req := httptest.NewRequestWithContext(t.Context(), http.MethodGet, "/", http.NoBody)
 	rec := &readerFromRecorder{httptest.NewRecorder()}
 	ctx, cancel := context.WithCancel(t.Context())
 	req = req.WithContext(ctx)
@@ -258,7 +258,7 @@ func TestStreamCopy_NormalCompletion(t *testing.T) {
 
 	// Create an echo context with a wrapped recorder
 	e := echo.New()
-	req := httptest.NewRequest(http.MethodGet, "/", http.NoBody)
+	req := httptest.NewRequestWithContext(t.Context(), http.MethodGet, "/", http.NoBody)
 	rec := &readerFromRecorder{httptest.NewRecorder()}
 	c := e.NewContext(req, rec)
 
@@ -279,7 +279,7 @@ func TestSimulatedStreamCopy_SSEEvents(t *testing.T) {
 
 	// Create an echo context
 	e := echo.New()
-	req := httptest.NewRequest(http.MethodGet, "/", http.NoBody)
+	req := httptest.NewRequestWithContext(t.Context(), http.MethodGet, "/", http.NoBody)
 	rec := httptest.NewRecorder()
 	c := e.NewContext(req, rec)
 
@@ -340,7 +340,7 @@ func TestSimulatedStreamCopy_ContextCancellation(t *testing.T) {
 	}
 
 	e := echo.New()
-	req := httptest.NewRequest(http.MethodGet, "/", http.NoBody)
+	req := httptest.NewRequestWithContext(t.Context(), http.MethodGet, "/", http.NoBody)
 	rec := httptest.NewRecorder()
 	ctx, cancel := context.WithCancel(t.Context())
 	req = req.WithContext(ctx)

pkg/httpclient/client_test.go

@@ -76,7 +76,7 @@ func doRequest(t *testing.T, opts ...Opt) http.Header {
 	defer srv.Close()
 
 	client := NewHTTPClient(t.Context(), opts...)
-	req, err := http.NewRequest(http.MethodGet, srv.URL, http.NoBody)
+	req, err := http.NewRequestWithContext(t.Context(), http.MethodGet, srv.URL, http.NoBody)
 	require.NoError(t, err)
 
 	resp, err := client.Do(req)

pkg/model/provider/anthropic/wrap_test.go

@@ -17,7 +17,8 @@ import (
 
 // makeTestAnthropicError creates an *anthropic.Error with the given status code and
 // optional Retry-After header value for testing.
-func makeTestAnthropicError(statusCode int, retryAfterValue string) *anthropic.Error {
+func makeTestAnthropicError(t *testing.T, statusCode int, retryAfterValue string) *anthropic.Error {
+	t.Helper()
 	header := http.Header{}
 	if retryAfterValue != "" {
 		header.Set("Retry-After", retryAfterValue)
@@ -26,7 +27,7 @@ func makeTestAnthropicError(statusCode int, retryAfterValue string) *anthropic.E
 	resp.StatusCode = statusCode
 	resp.Header = header
 	// anthropic.Error.Error() dereferences Request, so we must provide a non-nil one.
-	req, _ := http.NewRequest(http.MethodPost, "https://api.anthropic.com/v1/messages", http.NoBody)
+	req, _ := http.NewRequestWithContext(t.Context(), http.MethodPost, "https://api.anthropic.com/v1/messages", http.NoBody)
 	return &anthropic.Error{
 		StatusCode: statusCode,
 		Response:   resp,
@@ -53,7 +54,7 @@ func TestWrapAnthropicError(t *testing.T) {
 
 	t.Run("429 without Retry-After wraps with zero RetryAfter", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestAnthropicError(429, "")
+		apiErr := makeTestAnthropicError(t, 429, "")
 		result := wrapAnthropicError(apiErr)
 		var se *modelerrors.StatusError
 		require.ErrorAs(t, result, &se)
@@ -65,7 +66,7 @@ func TestWrapAnthropicError(t *testing.T) {
 
 	t.Run("429 with Retry-After header sets RetryAfter", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestAnthropicError(429, "20")
+		apiErr := makeTestAnthropicError(t, 429, "20")
 		result := wrapAnthropicError(apiErr)
 		var se *modelerrors.StatusError
 		require.ErrorAs(t, result, &se)
@@ -75,7 +76,7 @@ func TestWrapAnthropicError(t *testing.T) {
 
 	t.Run("500 wraps with correct status code", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestAnthropicError(500, "")
+		apiErr := makeTestAnthropicError(t, 500, "")
 		result := wrapAnthropicError(apiErr)
 		var se *modelerrors.StatusError
 		require.ErrorAs(t, result, &se)
@@ -85,7 +86,7 @@ func TestWrapAnthropicError(t *testing.T) {
 
 	t.Run("wrapped error is classified correctly by ClassifyModelError", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestAnthropicError(429, "15")
+		apiErr := makeTestAnthropicError(t, 429, "15")
 		result := wrapAnthropicError(apiErr)
 		retryable, rateLimited, retryAfter := modelerrors.ClassifyModelError(result)
 		assert.False(t, retryable)
@@ -95,7 +96,7 @@ func TestWrapAnthropicError(t *testing.T) {
 
 	t.Run("wrapped in fmt.Errorf still classified correctly", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestAnthropicError(429, "5")
+		apiErr := makeTestAnthropicError(t, 429, "5")
 		wrapped := fmt.Errorf("stream error: %w", wrapAnthropicError(apiErr))
 		retryable, rateLimited, retryAfter := modelerrors.ClassifyModelError(wrapped)
 		assert.False(t, retryable)

pkg/model/provider/bedrock/client_test.go

@@ -247,7 +247,9 @@ func TestBearerTokenTransport(t *testing.T) {
 
 	// Make a request through the transport
 	client := &http.Client{Transport: transport}
-	resp, err := client.Get(server.URL)
+	req, err := http.NewRequestWithContext(t.Context(), http.MethodGet, server.URL, http.NoBody)
+	require.NoError(t, err)
+	resp, err := client.Do(req)
 	require.NoError(t, err)
 	defer resp.Body.Close()
 

pkg/model/provider/oaistream/adapter_test.go

@@ -21,7 +21,9 @@ func newTestStream(t *testing.T, sseData string) *ssestream.Stream[openai.ChatCo
 	}))
 	t.Cleanup(srv.Close)
 
-	resp, err := http.Get(srv.URL) //nolint:gosec,bodyclose // body is closed by the stream
+	req, err := http.NewRequestWithContext(t.Context(), http.MethodGet, srv.URL, http.NoBody)
+	require.NoError(t, err)
+	resp, err := http.DefaultClient.Do(req) //nolint:bodyclose // body is closed by the stream
 	require.NoError(t, err)
 	return ssestream.NewStream[openai.ChatCompletionChunk](ssestream.NewDecoder(resp), nil)
 }

pkg/model/provider/oaistream/wrap_test.go

@@ -17,7 +17,8 @@ import (
 
 // makeTestOpenAIError creates an *openai.Error with the given status code and
 // optional Retry-After header value for testing.
-func makeTestOpenAIError(statusCode int, retryAfterValue string) *openaisdk.Error {
+func makeTestOpenAIError(t *testing.T, statusCode int, retryAfterValue string) *openaisdk.Error {
+	t.Helper()
 	header := http.Header{}
 	if retryAfterValue != "" {
 		header.Set("Retry-After", retryAfterValue)
@@ -26,7 +27,7 @@ func makeTestOpenAIError(statusCode int, retryAfterValue string) *openaisdk.Erro
 	resp.StatusCode = statusCode
 	resp.Header = header
 	// openai.Error.Error() dereferences Request, so we must provide a non-nil one.
-	req, _ := http.NewRequest(http.MethodPost, "https://api.openai.com/v1/chat/completions", http.NoBody)
+	req, _ := http.NewRequestWithContext(t.Context(), http.MethodPost, "https://api.openai.com/v1/chat/completions", http.NoBody)
 	return &openaisdk.Error{
 		StatusCode: statusCode,
 		Response:   resp,
@@ -53,7 +54,7 @@ func TestWrapOpenAIError(t *testing.T) {
 
 	t.Run("429 without Retry-After wraps with zero RetryAfter", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestOpenAIError(429, "")
+		apiErr := makeTestOpenAIError(t, 429, "")
 		result := WrapOpenAIError(apiErr)
 		var se *modelerrors.StatusError
 		require.ErrorAs(t, result, &se)
@@ -65,7 +66,7 @@ func TestWrapOpenAIError(t *testing.T) {
 
 	t.Run("429 with Retry-After header sets RetryAfter", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestOpenAIError(429, "30")
+		apiErr := makeTestOpenAIError(t, 429, "30")
 		result := WrapOpenAIError(apiErr)
 		var se *modelerrors.StatusError
 		require.ErrorAs(t, result, &se)
@@ -75,7 +76,7 @@ func TestWrapOpenAIError(t *testing.T) {
 
 	t.Run("500 wraps with correct status code", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestOpenAIError(500, "")
+		apiErr := makeTestOpenAIError(t, 500, "")
 		result := WrapOpenAIError(apiErr)
 		var se *modelerrors.StatusError
 		require.ErrorAs(t, result, &se)
@@ -84,7 +85,7 @@ func TestWrapOpenAIError(t *testing.T) {
 
 	t.Run("wrapped error is classified correctly by ClassifyModelError", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestOpenAIError(429, "10")
+		apiErr := makeTestOpenAIError(t, 429, "10")
 		result := WrapOpenAIError(apiErr)
 		retryable, rateLimited, retryAfter := modelerrors.ClassifyModelError(result)
 		assert.False(t, retryable)
@@ -94,7 +95,7 @@ func TestWrapOpenAIError(t *testing.T) {
 
 	t.Run("wrapped in fmt.Errorf still classified correctly", func(t *testing.T) {
 		t.Parallel()
-		apiErr := makeTestOpenAIError(500, "")
+		apiErr := makeTestOpenAIError(t, 500, "")
 		wrapped := fmt.Errorf("stream error: %w", WrapOpenAIError(apiErr))
 		retryable, rateLimited, _ := modelerrors.ClassifyModelError(wrapped)
 		assert.True(t, retryable)

pkg/rag/strategy/bm25_database.go

@@ -81,7 +81,7 @@ func (d *bm25DB) createSchema() error {
 		d.metadataTable,
 		d.tablePrefix, d.metadataTable)
 
-	_, err := d.db.Exec(schema)
+	_, err := d.db.ExecContext(context.Background(), schema)
 	return err
 }
 
@@ -208,10 +208,7 @@ func (d *bm25DB) DeleteFileMetadata(ctx context.Context, sourcePath string) erro
 }
 
 func (d *bm25DB) Close() error {
-	if _, err := d.db.Exec("PRAGMA wal_checkpoint(TRUNCATE)"); err != nil {
-		slog.Warn("Failed to checkpoint WAL before close", "error", err)
-	}
-	return d.db.Close()
+	return sqliteutil.CheckpointAndClose(d.db)
 }
 
 // ensureDir creates the parent directory for a file path if it doesn't exist

pkg/rag/strategy/chunked_embeddings_database.go

@@ -77,7 +77,7 @@ func (d *chunkedVectorDB) createSchema() error {
 	);
 	`, d.filesTable, d.tablePrefix, d.filesTable, d.chunksTable, d.filesTable)
 
-	_, err := d.db.Exec(schema)
+	_, err := d.db.ExecContext(context.Background(), schema)
 	return err
 }
 
@@ -244,8 +244,5 @@ func (d *chunkedVectorDB) DeleteFileMetadata(ctx context.Context, sourcePath str
 }
 
 func (d *chunkedVectorDB) Close() error {
-	if _, err := d.db.Exec("PRAGMA wal_checkpoint(TRUNCATE)"); err != nil {
-		slog.Warn("Failed to checkpoint WAL before close", "error", err)
-	}
-	return d.db.Close()
+	return sqliteutil.CheckpointAndClose(d.db)
 }