refactor(backend): remove placeholders left by removed features

Follow-up to the two placeholder-context functions: the same Cindy,
plugin-host and overdraft commits left more of the same kind.

Billing (openai_gateway_usage.go) is back to upstream's shape: no unused
account/tokens parameters, no error return that was nil on every path,
no duplicated channel-pricing branch. Result structs lose fields that
were only written or never assigned. Runtime-block code loses a
condition that was always false and a fallback no caller could reach.
Functions with no production caller go with their tests. Blank
parameters whose reason is gone are dropped from their signatures;
wire_gen.go is regenerated.

Kept on purpose: blank parameters required by an interface, a callback
or wire ordering, and signatures kept identical to upstream.

No request changes what it sends, bills or fails on.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

Author: Codex

backend/cmd/server/wire_gen.go

@@ -30,7 +30,7 @@ func TestImportPolicyPlansEachItemByIdentityMatches(t *testing.T) {
 	}
 	request.Phase = "finalize"
 	raw, _ := json.Marshal(request)
-	if _, err := New().Invoke(context.Background(), extensionv1.Invocation{Capability: extensionv1.CapabilityAdmin, Operation: "import.plan", Payload: raw}); err == nil {
+	if _, err := New().Invoke(context.Background(), extensionv1.Invocation{Operation: "import.plan", Payload: raw}); err == nil {
 		t.Fatal("incomplete prepared phase was accepted")
 	}
 }

backend/internal/accounttools/policy/import_test.go

@@ -14,20 +14,6 @@ import (
 type Module struct{}
 
 func New() *Module { return &Module{} }
-func (m *Module) ValidateConfig(_ context.Context, raw json.RawMessage) (json.RawMessage, error) {
-	var fields map[string]json.RawMessage
-	if json.Unmarshal(raw, &fields) != nil || fields == nil || len(fields) != 0 {
-		return nil, errors.New("account tools has no additional configuration")
-	}
-	return json.RawMessage(`{}`), nil
-}
-func (m *Module) ApplyConfig(ctx context.Context, raw json.RawMessage) error {
-	_, err := m.ValidateConfig(ctx, raw)
-	return err
-}
-func (m *Module) Status(context.Context) (json.RawMessage, error) {
-	return json.Marshal(map[string]any{"taxonomy": true, "reasoning_selection": true, "text_prompt": true})
-}
 
 func failure(code, message string, status int) extensionv1.Result {
 	return extensionv1.Result{Code: code, Message: message, HTTPStatus: status}
@@ -46,9 +32,6 @@ func (m *Module) Invoke(ctx context.Context, in extensionv1.Invocation) (extensi
 	if err := ctx.Err(); err != nil {
 		return extensionv1.Result{}, err
 	}
-	if in.Capability != extensionv1.CapabilityAdmin {
-		return extensionv1.Result{}, errors.New("unsupported account tools capability")
-	}
 	var output any = map[string]bool{"valid": true}
 	switch in.Operation {
 	case "import.plan":
@@ -68,9 +51,6 @@ func (m *Module) Invoke(ctx context.Context, in extensionv1.Invocation) (extensi
 		if !request.ValidUTF8 || request.Characters < 0 || request.Characters > 8192 {
 			return failure("ACCOUNT_TEST_PROMPT_INVALID", "test prompt must be valid UTF-8 and at most 8192 characters", 400), nil
 		}
-	case "tools.describe":
-		raw, err := m.Status(ctx)
-		return extensionv1.Result{Payload: raw}, err
 	case "taxonomy.name":
 		var request extensionv1.TaxonomyName
 		if json.Unmarshal(in.Payload, &request) != nil {

backend/internal/accounttools/policy/module.go

@@ -21,7 +21,7 @@ func TestTaxonomyPoliciesRejectAmbiguityAndInvalidAssignments(t *testing.T) {
 		{"taxonomy.assignment", `{"tag_ids":[-1]}`, "ACCOUNT_TAG_ID_INVALID"},
 		{"taxonomy.assignment", `{"tag_ids":[1,1,2]}`, ""},
 	} {
-		out, err := New().Invoke(context.Background(), extensionv1.Invocation{Capability: extensionv1.CapabilityAdmin, Operation: tc.operation, Payload: json.RawMessage(tc.payload)})
+		out, err := New().Invoke(context.Background(), extensionv1.Invocation{Operation: tc.operation, Payload: json.RawMessage(tc.payload)})
 		if err != nil || out.Code != tc.code {
 			t.Fatalf("%s: %v %+v", tc.operation, err, out)
 		}
@@ -34,7 +34,7 @@ func TestReasoningSelectionValidatesTheSuppliedWireCapabilities(t *testing.T) {
 		valid        bool
 	}{{"default", "ultra", true}, {"text", "ultra", true}, {"compact", "ultra", false}, {"default", " high ", false}, {"default", "high", false}, {"default", "", true}} {
 		raw, _ := json.Marshal(extensionv1.ReasoningSelection{Mode: tc.mode, Effort: tc.effort, Levels: []string{"ultra"}})
-		out, err := New().Invoke(context.Background(), extensionv1.Invocation{Capability: extensionv1.CapabilityAdmin, Operation: "test.reasoning", Payload: raw})
+		out, err := New().Invoke(context.Background(), extensionv1.Invocation{Operation: "test.reasoning", Payload: raw})
 		if err != nil || (out.Code == "") != tc.valid {
 			t.Fatalf("%s/%s: %v %+v", tc.mode, tc.effort, err, out)
 		}

backend/internal/accounttools/policy/module_test.go

@@ -53,7 +53,7 @@ func TestAccountHandlerTrafficTelemetryFollowsTelemetrySwitch(t *testing.T) {
 			stub.getAccountResult = &service.Account{ID: 18, Platform: service.PlatformOpenAI, Type: service.AccountTypeAPIKey, Concurrency: 3, Credentials: map[string]any{"api_key": "never-return-secret"}}
 			cache := &stubAccountTrafficObserveCache{snapshot: map[service.AccountTrafficProtocol]service.AccountTrafficObserveState{service.AccountTrafficProtocolHTTP: {Started: 3, Completed2xx: 2}}}
 			handler := NewAccountHandler(stub, nil, nil, nil, nil, nil, nil, nil, nil, nil, nil, nil, nil, nil)
-			handler.SetAccountTrafficObserver(service.NewAccountTrafficObserver(cache, nil))
+			handler.SetAccountTrafficObserver(service.NewAccountTrafficObserver(cache))
 			router := gin.New()
 			router.GET("/accounts/:id/traffic-telemetry", handler.GetTrafficTelemetry)
 			recorder := httptest.NewRecorder()
@@ -91,7 +91,7 @@ func TestAccountHandlerGetTrafficTelemetryReturnsSnapshot(t *testing.T) {
 			service.AccountTrafficProtocolHTTP: {Started: 3, Completed2xx: 2, Upstream429: 1, PeakInFlight: 2, RequestsLast60s: 1},
 			service.AccountTrafficProtocolWS:   {},
 		},
-	}, nil))
+	}))
 	router := gin.New()
 	router.GET("/accounts/:id/traffic-telemetry", handler.GetTrafficTelemetry)
 

backend/internal/handler/admin/account_handler_traffic_telemetry_test.go

@@ -431,7 +431,7 @@ func (h *OpenAIGatewayHandler) handleGrokMedia(c *gin.Context, endpoint service.
 		if slotResult != openAISlotAcquireOK {
 			if retryingSameAccount && lastFailoverErr != nil && h.failoverAfterSameAccountSlotFailure(
 				c, account, grokMediaScheduleModel(account, routingModel, nil), lastFailoverErr, failedAccountIDs,
-				&switchCount, maxAccountSwitches, &oauth429FailoverState, streamStarted,
+				&switchCount, maxAccountSwitches, &oauth429FailoverState,
 				"grok_media", reqLog, !endpoint.IsVideoLookupRequest(),
 				func() { h.handleFailoverExhausted(c, lastFailoverErr, streamStarted) },
 			) {

backend/internal/handler/grok_media.go

@@ -201,7 +201,7 @@ func (h *OpenAIGatewayHandler) AlphaSearch(c *gin.Context) {
 		if slotResult != openAISlotAcquireOK {
 			if retryingSameAccount && lastFailoverErr != nil && h.failoverAfterSameAccountSlotFailure(
 				c, account, account.GetMappedModel(requestedModel), lastFailoverErr, failedAccountIDs,
-				&switchCount, h.maxAccountSwitches, &oauth429FailoverState, streamStarted,
+				&switchCount, h.maxAccountSwitches, &oauth429FailoverState,
 				"alpha_search", reqLog, true,
 				func() { h.handleFailoverExhausted(c, lastFailoverErr, streamStarted) },
 			) {

backend/internal/handler/openai_alpha_search.go

@@ -269,7 +269,7 @@ func (h *OpenAIGatewayHandler) ChatCompletions(c *gin.Context) {
 		if slotResult != openAISlotAcquireOK {
 			if retryingSameAccount && lastFailoverErr != nil && h.failoverAfterSameAccountSlotFailure(
 				c, account, account.GetMappedModel(routingModel), lastFailoverErr, failedAccountIDs,
-				&switchCount, maxAccountSwitches, &oauth429FailoverState, streamStarted,
+				&switchCount, maxAccountSwitches, &oauth429FailoverState,
 				"chat_completions", reqLog, true,
 				func() { h.handleFailoverExhausted(c, lastFailoverErr, streamStarted) },
 			) {

backend/internal/handler/openai_chat_completions.go

@@ -160,7 +160,7 @@ func (h *OpenAIGatewayHandler) CodexModels(c *gin.Context) {
 		if slotResult != openAISlotAcquireOK {
 			if retryingSameAccount && lastFailoverErr != nil && h.failoverAfterSameAccountSlotFailure(
 				c, account, "", lastFailoverErr, failedAccountIDs,
-				&switchCount, maxAccountSwitches, &oauth429FailoverState, false,
+				&switchCount, maxAccountSwitches, &oauth429FailoverState,
 				"codex_models", nil, true,
 				func() {
 					h.errorResponse(c, infraerrors.Code(lastUpstreamErr), "upstream_error", infraerrors.Message(lastUpstreamErr))

backend/internal/handler/openai_codex_models_handler.go

@@ -18,7 +18,7 @@ func TestWriteCountTokensFailoverErrorPreservesModelNotSupported(t *testing.T) {
 	writeCountTokensFailoverError(ctx, &service.UpstreamFailoverError{
 		StatusCode: http.StatusBadRequest,
 		Reason:     service.GatewayFailureReason("upstream_400_model_not_supported"),
-	}, nil)
+	})
 
 	var envelope map[string]any
 	require.NoError(t, json.Unmarshal(recorder.Body.Bytes(), &envelope))