Skip to content

Commit e1765bc

Browse files
pawbanapawbana
committed
chore: lint fixes part 4
1 parent e63a56f commit e1765bc

File tree

22 files changed

+110
-110
lines changed

22 files changed

+110
-110
lines changed

‎circuitbreaker/circuitbreaker.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ func (p *ProviderCircuitBreakers) openErrorResponse() []byte {
7777
func (p *ProviderCircuitBreakers) Get(endpoint, model string) *gobreaker.CircuitBreaker[struct{}] {
7878
key := endpoint + ":" + model
7979
if v, ok := p.breakers.Load(key); ok {
80-
return v.(*gobreaker.CircuitBreaker[struct{}])
80+
return v.(*gobreaker.CircuitBreaker[struct{}]) //nolint:forcetypeassert // sync.Map always stores this type
8181
}
8282

8383
settings := gobreaker.Settings{
@@ -97,7 +97,7 @@ func (p *ProviderCircuitBreakers) Get(endpoint, model string) *gobreaker.Circuit
9797

9898
cb := gobreaker.NewCircuitBreaker[struct{}](settings)
9999
actual, _ := p.breakers.LoadOrStore(key, cb)
100-
return actual.(*gobreaker.CircuitBreaker[struct{}])
100+
return actual.(*gobreaker.CircuitBreaker[struct{}]) //nolint:forcetypeassert // sync.Map always stores this type
101101
}
102102

103103
// statusCapturingWriter wraps http.ResponseWriter to capture the status code.

‎intercept/apidump/apidump.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ func (d *dumper) dumpRequest(req *http.Request) error {
110110
buf.Write(prettyBody)
111111
buf.WriteByte('\n')
112112

113-
return os.WriteFile(dumpPath, buf.Bytes(), 0o644)
113+
return os.WriteFile(dumpPath, buf.Bytes(), 0o600)
114114
}
115115

116116
func (d *dumper) dumpResponse(resp *http.Response) error {
@@ -133,7 +133,7 @@ func (d *dumper) dumpResponse(resp *http.Response) error {
133133

134134
if resp.Body == nil {
135135
// No body, just write headers
136-
return os.WriteFile(dumpPath, headerBuf.Bytes(), 0o644)
136+
return os.WriteFile(dumpPath, headerBuf.Bytes(), 0o600)
137137
}
138138

139139
// Wrap the response body to capture it as it streams

‎intercept/chatcompletions/base.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,9 +80,9 @@ func (i *interceptionBase) Credential() intercept.CredentialInfo {
8080
return i.credential
8181
}
8282

83-
func (i *interceptionBase) Setup(logger slog.Logger, recorder recorder.Recorder, mcpProxy mcp.ServerProxier) {
83+
func (i *interceptionBase) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier) {
8484
i.logger = logger
85-
i.recorder = recorder
85+
i.recorder = rec
8686
i.mcpProxy = mcpProxy
8787
}
8888

‎intercept/chatcompletions/blocking.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,8 @@ func NewBlockingInterceptor(
5151
}}
5252
}
5353

54-
func (i *BlockingInterception) Setup(logger slog.Logger, recorder recorder.Recorder, mcpProxy mcp.ServerProxier) {
55-
i.interceptionBase.Setup(logger.Named("blocking"), recorder, mcpProxy)
54+
func (i *BlockingInterception) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier) {
55+
i.interceptionBase.Setup(logger.Named("blocking"), rec, mcpProxy)
5656
}
5757

5858
func (*BlockingInterception) Streaming() bool {

‎intercept/chatcompletions/streaming.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,8 +55,8 @@ func NewStreamingInterceptor(
5555
}}
5656
}
5757

58-
func (i *StreamingInterception) Setup(logger slog.Logger, recorder recorder.Recorder, mcpProxy mcp.ServerProxier) {
59-
i.interceptionBase.Setup(logger.Named("streaming"), recorder, mcpProxy)
58+
func (i *StreamingInterception) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier) {
59+
i.interceptionBase.Setup(logger.Named("streaming"), rec, mcpProxy)
6060
}
6161

6262
func (*StreamingInterception) Streaming() bool {

‎intercept/interceptor.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ type Interceptor interface {
1717
ID() uuid.UUID
1818
// Setup injects some required dependencies. This MUST be called before using the interceptor
1919
// to process requests.
20-
Setup(logger slog.Logger, recorder recorder.Recorder, mcpProxy mcp.ServerProxier)
20+
Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier)
2121
// Model returns the model in use for this [Interceptor].
2222
Model() string
2323
// ProcessRequest handles the HTTP request.

‎intercept/messages/base.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,9 +92,9 @@ func (i *interceptionBase) Credential() intercept.CredentialInfo {
9292
return i.credential
9393
}
9494

95-
func (i *interceptionBase) Setup(logger slog.Logger, recorder recorder.Recorder, mcpProxy mcp.ServerProxier) {
95+
func (i *interceptionBase) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier) {
9696
i.logger = logger
97-
i.recorder = recorder
97+
i.recorder = rec
9898
i.mcpProxy = mcpProxy
9999
}
100100

‎intercept/messages/blocking.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,8 @@ func NewBlockingInterceptor(
5454
}}
5555
}
5656

57-
func (i *BlockingInterception) Setup(logger slog.Logger, recorder recorder.Recorder, mcpProxy mcp.ServerProxier) {
58-
i.interceptionBase.Setup(logger.Named("blocking"), recorder, mcpProxy)
57+
func (i *BlockingInterception) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier) {
58+
i.interceptionBase.Setup(logger.Named("blocking"), rec, mcpProxy)
5959
}
6060

6161
func (i *BlockingInterception) TraceAttributes(r *http.Request) []attribute.KeyValue {

‎intercept/messages/streaming.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,8 +59,8 @@ func NewStreamingInterceptor(
5959
}}
6060
}
6161

62-
func (i *StreamingInterception) Setup(logger slog.Logger, recorder recorder.Recorder, mcpProxy mcp.ServerProxier) {
63-
i.interceptionBase.Setup(logger.Named("streaming"), recorder, mcpProxy)
62+
func (i *StreamingInterception) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier) {
63+
i.interceptionBase.Setup(logger.Named("streaming"), rec, mcpProxy)
6464
}
6565

6666
func (*StreamingInterception) Streaming() bool {

‎intercept/responses/base.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,9 +89,9 @@ func (i *responsesInterceptionBase) Credential() intercept.CredentialInfo {
8989
return i.credential
9090
}
9191

92-
func (i *responsesInterceptionBase) Setup(logger slog.Logger, recorder recorder.Recorder, mcpProxy mcp.ServerProxier) {
92+
func (i *responsesInterceptionBase) Setup(logger slog.Logger, rec recorder.Recorder, mcpProxy mcp.ServerProxier) {
9393
i.logger = logger.With(slog.F("model", i.Model()))
94-
i.recorder = recorder
94+
i.recorder = rec
9595
i.mcpProxy = mcpProxy
9696
}
9797

0 commit comments

Comments
 (0)