Skip to content

Commit 337db81

Browse files
committed
fix linting errors
1 parent 7410612 commit 337db81

7 files changed

Lines changed: 23 additions & 26 deletions

File tree

command/run/run.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,6 @@ func (c *command) runE(cmd *cobra.Command, _ []string) (cmdErr error) {
146146
if err != nil {
147147
return fmt.Errorf("kerberos: %w", err)
148148
}
149-
150149
}
151150

152151
if len(c.dnsConfig.Servers) > 0 {
@@ -339,7 +338,7 @@ func (c *command) configureHeadersModifiers() {
339338
}
340339
}
341340

342-
// configure upstream proxy transport - connect headers and/or Kerberos auth
341+
// Configure upstream proxy transport - connect headers and/or Kerberos auth.
343342
func (c *command) configureTransportProxy(tr *http.Transport, kerberosAdapter forwarder.KerberosAdapter) {
344343
headersToAllocate := len(c.connectHeaders)
345344

@@ -363,7 +362,6 @@ func (c *command) configureTransportProxy(tr *http.Transport, kerberosAdapter fo
363362
}
364363

365364
maps.Copy(h, kerberosHeaders)
366-
367365
}
368366

369367
return h, nil

dialvia/http.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,6 @@ func (d *HTTPProxyDialer) DialContextR(ctx context.Context, network, addr string
147147
}
148148

149149
maps.Copy(req.Header, headers)
150-
151150
}
152151

153152
if err := req.Write(pbw); err != nil {

dialvia/http_test.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ package dialvia
99
import (
1010
"bufio"
1111
"bytes"
12+
"errors"
1213
"fmt"
1314
"io"
1415
"net"
@@ -105,11 +106,11 @@ func TestHTTPProxyDialerDialContext(t *testing.T) {
105106
}
106107

107108
if req.Method != http.MethodConnect {
108-
return fmt.Errorf("HTTP CONNECT method expected")
109+
return errors.New("HTTP CONNECT method expected")
109110
}
110111

111112
if req.Header.Get("Proxy-Authorization") != "TEST-PROXY-AUTHORIZATION" {
112-
return fmt.Errorf("Proxy-Authorization header expected but not present")
113+
return errors.New("Proxy-Authorization header expected but not present")
113114
}
114115

115116
return proxyutil.NewResponse(404, nil, req).Write(conn)

http_proxy.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -205,7 +205,9 @@ func NewHTTPProxy(cfg *HTTPProxyConfig, pr PACResolver, cm *CredentialsMatcher,
205205
}
206206

207207
// NewHTTPProxyHandler is like NewHTTPProxy but returns http.Handler instead of *HTTPProxy.
208-
func NewHTTPProxyHandler(cfg *HTTPProxyConfig, pr PACResolver, cm *CredentialsMatcher, rt http.RoundTripper, log log.StructuredLogger, kerberosAdapter KerberosAdapter) (http.Handler, error) {
208+
func NewHTTPProxyHandler(cfg *HTTPProxyConfig, pr PACResolver, cm *CredentialsMatcher,
209+
rt http.RoundTripper, log log.StructuredLogger, kerberosAdapter KerberosAdapter,
210+
) (http.Handler, error) {
209211
hp, err := newHTTPProxy(cfg, pr, cm, rt, log, kerberosAdapter)
210212
if err != nil {
211213
return nil, err
@@ -354,7 +356,6 @@ func (hp *HTTPProxy) upstreamProxyURL() *url.URL {
354356
// so http.RoundTripper would not try to add custom Authorization header
355357

356358
if hp.kerberosAdapter != nil && hp.kerberosAdapter.GetConfig().AuthUpstreamProxy {
357-
358359
proxyURL.User = nil
359360
return proxyURL
360361
}
@@ -386,7 +387,6 @@ func (hp *HTTPProxy) pacProxy(r *http.Request) (*url.URL, error) {
386387
// so http.RoundTripper would not try to add custom Authorization header
387388

388389
if hp.kerberosAdapter != nil && hp.kerberosAdapter.GetConfig().AuthUpstreamProxy {
389-
390390
proxyURL.User = nil
391391
return proxyURL, nil
392392
}

internal/martian/proxy_connect.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -125,13 +125,11 @@ func (p *Proxy) connectHTTP(req *http.Request, proxyURL *url.URL) (res *http.Res
125125
if tr, ok := p.rt.(*http.Transport); ok && tr.GetProxyConnectHeader != nil {
126126
d.GetProxyConnectHeader = tr.GetProxyConnectHeader
127127
}
128-
129128
} else {
130129
d = dialvia.HTTPProxy(p.DialContext, proxyURL)
131130
if tr, ok := p.rt.(*http.Transport); ok && tr.GetProxyConnectHeader != nil {
132131
d.GetProxyConnectHeader = tr.GetProxyConnectHeader
133132
}
134-
135133
}
136134

137135
d.Timeout = p.ConnectTimeout

kerberos.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import (
1010
"bytes"
1111
"context"
1212
"encoding/base64"
13+
"errors"
1314
"fmt"
1415
"net/http"
1516
"net/url"
@@ -58,18 +59,18 @@ func NewKerberosAdapter(cnf KerberosConfig, log log.StructuredLogger) (*Kerberos
5859
// technically this should not happen as adapter should not be initialized without
5960
// proper config present, but better safe than sorry
6061
if cnf.CfgFilePath == "" {
61-
return nil, fmt.Errorf("kerberos config file (krb5.conf) not specified")
62+
return nil, errors.New("kerberos config file (krb5.conf) not specified")
6263
}
6364

6465
if cnf.KeyTabFilePath == "" {
65-
return nil, fmt.Errorf("kerberos keytab file not specified")
66+
return nil, errors.New("kerberos keytab file not specified")
6667
}
6768

6869
if cnf.UserName == "" {
69-
return nil, fmt.Errorf("kerberos username not specified")
70+
return nil, errors.New("kerberos username not specified")
7071
}
7172
if cnf.UserRealm == "" {
72-
return nil, fmt.Errorf("kerberos user realm not specified")
73+
return nil, errors.New("kerberos user realm not specified")
7374
}
7475

7576
krb5Config, err := config.Load(cnf.CfgFilePath)
@@ -112,14 +113,13 @@ func (a *KerberosClient) ConnectToKDC() error {
112113

113114
// We need to print directly to stdout as it contains a nested structured text.
114115
// Does not really matter as diagnostics mode should be used on local console only.
115-
fmt.Printf("%s", buf.String())
116+
fmt.Printf("%s", buf.String()) //nolint
116117

117118
if err != nil {
118119
return fmt.Errorf("kerberos configuration potential problems: %w", err)
119120
}
120121

121-
return fmt.Errorf("no kerberos configuration problems found. Exiting process")
122-
122+
return errors.New("no kerberos configuration problems found. Exiting process")
123123
}
124124

125125
return nil

kerberos_test.go

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -11,30 +11,31 @@ import (
1111

1212
"github.com/saucelabs/forwarder/log/slog"
1313
"github.com/stretchr/testify/assert"
14+
"github.com/stretchr/testify/require"
1415
)
1516

1617
func TestKerberosAdapterFailsWithoutConfig(t *testing.T) {
1718
cnf := KerberosConfig{}
1819

1920
_, err := NewKerberosAdapter(cnf, slog.Default())
20-
assert.NotNil(t, err)
21-
assert.ErrorContains(t, err, "kerberos config file (krb5.conf) not specified")
21+
assert.Error(t, err)
22+
require.ErrorContains(t, err, "kerberos config file (krb5.conf) not specified")
2223

2324
cnf.CfgFilePath = "/tmp/test.cfg"
2425

2526
_, err = NewKerberosAdapter(cnf, slog.Default())
26-
assert.NotNil(t, err)
27-
assert.ErrorContains(t, err, "kerberos keytab file not specified")
27+
assert.Error(t, err)
28+
require.ErrorContains(t, err, "kerberos keytab file not specified")
2829

2930
cnf.KeyTabFilePath = "/tmp/keytab"
3031

3132
_, err = NewKerberosAdapter(cnf, slog.Default())
32-
assert.NotNil(t, err)
33-
assert.ErrorContains(t, err, "kerberos username not specified")
33+
assert.Error(t, err)
34+
require.ErrorContains(t, err, "kerberos username not specified")
3435

3536
cnf.UserName = "user1"
3637

3738
_, err = NewKerberosAdapter(cnf, slog.Default())
38-
assert.NotNil(t, err)
39-
assert.ErrorContains(t, err, "kerberos user realm not specified")
39+
assert.Error(t, err)
40+
require.ErrorContains(t, err, "kerberos user realm not specified")
4041
}

0 commit comments

Comments
 (0)