Wire rate limit transport logger for throttling visibility

Log proactive waits and retry backoff so operators can see when the
server is slowing down to avoid GitHub API rate limit lockouts.

Author: root

internal/ghmcp/server.go

@@ -63,9 +63,10 @@ func createGitHubClients(cfg github.MCPServerConfig, apiHost utils.APIHostResolv
 
 	// Construct REST client
 	rateLimitState := transport.NewRateLimitState()
+	rateLimitLogger := cfg.Logger.With("component", "rate_limit")
 
 	restUATransport := &transport.UserAgentTransport{
-		Transport: transport.WrapWithRateLimit(http.DefaultTransport, rateLimitState),
+		Transport: transport.WrapWithRateLimit(http.DefaultTransport, rateLimitState, rateLimitLogger),
 		Agent:     fmt.Sprintf("github-mcp-server/%s", cfg.Version),
 	}
 	restClient, err := gogithub.NewClient(
@@ -82,7 +83,7 @@ func createGitHubClients(cfg github.MCPServerConfig, apiHost utils.APIHostResolv
 	gqlHTTPClient := &http.Client{
 		Transport: &transport.BearerAuthTransport{
 			Transport: &transport.GraphQLFeaturesTransport{
-				Transport: transport.WrapWithRateLimit(http.DefaultTransport, rateLimitState),
+				Transport: transport.WrapWithRateLimit(http.DefaultTransport, rateLimitState, rateLimitLogger),
 			},
 			Token: cfg.Token,
 		},

pkg/github/dependencies.go

@@ -323,10 +323,11 @@ func (d *RequestDeps) GetClient(ctx context.Context) (*gogithub.Client, error) {
 	}
 
 	// Construct REST client
+	rateLimitLogger := d.obsv.Logger().With("component", "rate_limit")
 	restClient, err := gogithub.NewClient(
 		gogithub.WithHTTPClient(&http.Client{
 			Transport: &transport.UserAgentTransport{
-				Transport: transport.WrapWithRateLimit(http.DefaultTransport, d.rateLimits.Get(token)),
+				Transport: transport.WrapWithRateLimit(http.DefaultTransport, d.rateLimits.Get(token), rateLimitLogger),
 				Agent:     fmt.Sprintf("github-mcp-server/%s", d.version),
 			},
 		}),
@@ -352,10 +353,11 @@ func (d *RequestDeps) GetGQLClient(ctx context.Context) (*githubv4.Client, error
 	// We use NewEnterpriseClient unconditionally since we already parsed the API host
 	// Wrap transport with GraphQLFeaturesTransport to inject feature flags from context,
 	// matching the transport chain used by the remote server.
+	rateLimitLogger := d.obsv.Logger().With("component", "rate_limit")
 	gqlHTTPClient := &http.Client{
 		Transport: &transport.BearerAuthTransport{
 			Transport: &transport.GraphQLFeaturesTransport{
-				Transport: transport.WrapWithRateLimit(http.DefaultTransport, d.rateLimits.Get(token)),
+				Transport: transport.WrapWithRateLimit(http.DefaultTransport, d.rateLimits.Get(token), rateLimitLogger),
 			},
 			Token: token,
 		},

pkg/http/transport/rate_limit.go

@@ -55,7 +55,7 @@ type RateLimitTransport struct {
 	Logger       *slog.Logger
 }
 
-func WrapWithRateLimit(base http.RoundTripper, state *RateLimitState) http.RoundTripper {
+func WrapWithRateLimit(base http.RoundTripper, state *RateLimitState, logger *slog.Logger) http.RoundTripper {
 	if state == nil {
 		state = NewRateLimitState()
 	}
@@ -66,6 +66,7 @@ func WrapWithRateLimit(base http.RoundTripper, state *RateLimitState) http.Round
 		MinInterval:  DefaultMinRequestInterval,
 		MinRemaining: DefaultMinRateLimitRemaining,
 		MaxRetries:   DefaultMaxRateLimitRetries,
+		Logger:       logger,
 	}
 }
 

pkg/http/transport/rate_limit_test.go

@@ -27,7 +27,7 @@ func TestRateLimitTransport_UpdatesStateFromHeaders(t *testing.T) {
 	t.Cleanup(server.Close)
 
 	state := NewRateLimitState()
-	client := &http.Client{Transport: WrapWithRateLimit(server.Client().Transport, state)}
+	client := &http.Client{Transport: WrapWithRateLimit(server.Client().Transport, state, nil)}
 
 	resp, err := client.Get(server.URL)
 	require.NoError(t, err)