chore: log actor override

Signed-off-by: Danny Kopping <danny@coder.com>

Author: dannykopping

bridge.go

@@ -179,9 +179,15 @@ func newInterceptionProcessor(p provider.Provider, cbs *circuitbreaker.ProviderC
 			if ownerID := r.Header.Get("X-Coder-Owner-Id"); ownerID != "" {
 				existingActor := aibcontext.ActorFromContext(ctx)
 				var md recorder.Metadata
+				var previousActorID string
 				if existingActor != nil {
 					md = existingActor.Metadata
+					previousActorID = existingActor.ID
 				}
+				logger.Debug(ctx, "overriding initiator with X-Coder-Owner-Id",
+					slog.F("previous_actor_id", previousActorID),
+					slog.F("new_actor_id", ownerID),
+				)
 				ctx = aibcontext.AsActor(ctx, ownerID, md)
 				r = r.WithContext(ctx)
 			}

internal/integrationtest/bridge_test.go

@@ -12,6 +12,8 @@ import (
 	"testing"
 	"time"
 
+	"cdr.dev/slog/v3"
+	"cdr.dev/slog/v3/sloggers/sloghuman"
 	"github.com/anthropics/anthropic-sdk-go"
 	"github.com/anthropics/anthropic-sdk-go/packages/ssestream"
 	"github.com/anthropics/anthropic-sdk-go/shared/constant"
@@ -2093,12 +2095,14 @@ func TestCoderAgentsInitiatorOverride(t *testing.T) {
 		userAgent       string
 		ownerIDHeader   string
 		expectInitiator string
+		expectLogOverride bool
 	}{
 		{
-			name:            "coder_agents_with_owner_id",
-			userAgent:       "coder-agents/v2.24.0 (linux/amd64)",
-			ownerIDHeader:   overrideActorID,
-			expectInitiator: overrideActorID,
+			name:              "coder_agents_with_owner_id",
+			userAgent:         "coder-agents/v2.24.0 (linux/amd64)",
+			ownerIDHeader:     overrideActorID,
+			expectInitiator:   overrideActorID,
+			expectLogOverride: true,
 		},
 		{
 			name:            "coder_agents_without_owner_id",
@@ -2124,7 +2128,9 @@ func TestCoderAgentsInitiatorOverride(t *testing.T) {
 			fix := fixtures.Parse(t, fixtures.AntSimple)
 			upstream := newMockUpstream(t, ctx, newFixtureResponse(fix))
 
-			bridgeServer := newBridgeTestServer(t, ctx, upstream.URL)
+			var logBuf bytes.Buffer
+			logger := slog.Make(sloghuman.Sink(&logBuf)).Leveled(slog.LevelDebug)
+			bridgeServer := newBridgeTestServer(t, ctx, upstream.URL, withLogger(logger))
 
 			headers := http.Header{"User-Agent": {tc.userAgent}}
 			if tc.ownerIDHeader != "" {
@@ -2139,6 +2145,15 @@ func TestCoderAgentsInitiatorOverride(t *testing.T) {
 			interceptions := bridgeServer.Recorder.RecordedInterceptions()
 			require.Len(t, interceptions, 1)
 			require.Equal(t, tc.expectInitiator, interceptions[0].InitiatorID)
+
+			logOutput := logBuf.String()
+			if tc.expectLogOverride {
+				assert.Contains(t, logOutput, "overriding initiator with X-Coder-Owner-Id")
+				assert.Contains(t, logOutput, defaultActorID)
+				assert.Contains(t, logOutput, overrideActorID)
+			} else {
+				assert.NotContains(t, logOutput, "overriding initiator with X-Coder-Owner-Id")
+			}
 		})
 	}
 }

internal/integrationtest/setupbridge.go

@@ -49,6 +49,7 @@ type bridgeConfig struct {
 	userID           string
 	metadata         recorder.Metadata
 	logger           slog.Logger
+	loggerSet        bool
 }
 
 // bridgeTestServer wraps an httptest.Server running a RequestBridge.
@@ -117,6 +118,11 @@ func withMCP(p mcp.ServerProxier) bridgeOption {
 	return func(c *bridgeConfig) { c.mcpProxy = p }
 }
 
+// withLogger overrides the default test logger.
+func withLogger(l slog.Logger) bridgeOption {
+	return func(c *bridgeConfig) { c.logger = l; c.loggerSet = true }
+}
+
 // withActor sets the actor ID and metadata for the BaseContext.
 func withActor(id string, md recorder.Metadata) bridgeOption {
 	return func(c *bridgeConfig) { c.userID = id; c.metadata = md }
@@ -146,7 +152,9 @@ func newBridgeTestServer(
 	if cfg.tracer == nil {
 		cfg.tracer = defaultTracer
 	}
-	cfg.logger = newLogger(t)
+	if !cfg.loggerSet {
+		cfg.logger = newLogger(t)
+	}
 	if cfg.mcpProxy == nil {
 		cfg.mcpProxy = newNoopMCPManager()
 	}