sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-10-28 15:29:09 +01:00
Code Issues Packages Projects Releases Wiki Activity

make linter happy

Browse Source 
Signed-off-by: Dmitri Dolguikh <dmitri.external@netbird.io>
This commit is contained in:
Dmitri Dolguikh
2026-09-09 18:23:16 +02:00
parent d7b9dd44ab
commit f2bb2f9470
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
util/wsproxy/server/ws_conn_adapter_test.go
+7 -6
View File
@@ -43,7 +43,7 @@ func TestAdapterHandlingConnectionClosures(t *testing.T) {
proxy := New(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { proxy := New(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
buf, _ := io.ReadAll(r.Body) buf, _ := io.ReadAll(r.Body)
defer r.Body.Close() defer r.Body.Close()
w.Write([]byte("echo: " + string(buf))) w.Write([]byte("echo: " + string(buf))) //nolint:errcheck
})) }))
handler, ok := proxy.Handler().(*proxyHandler) handler, ok := proxy.Handler().(*proxyHandler)
@@ -55,7 +55,7 @@ func TestAdapterHandlingConnectionClosures(t *testing.T) {
httpServer := http.Server{ httpServer := http.Server{
Handler: handler, Handler: handler,
} }
go httpServer.Serve(l) go httpServer.Serve(l) //nolint:errcheck
t.Cleanup(func() { httpServer.Close() }) t.Cleanup(func() { httpServer.Close() })
clientconn, _, err := websocket.Dial(context.Background(), "http://whatever", &websocket.DialOptions{HTTPClient: &http.Client{ clientconn, _, err := websocket.Dial(context.Background(), "http://whatever", &websocket.DialOptions{HTTPClient: &http.Client{
@@ -66,7 +66,7 @@ func TestAdapterHandlingConnectionClosures(t *testing.T) {
}}}) }}})
assert.NoError(t, err) assert.NoError(t, err)
clientCtx, cancel := context.WithCancel(context.Background()) clientCtx, cancel := context.WithCancel(context.Background()) //nolint:govet
h2client := &http.Client{ h2client := &http.Client{
Transport: &http2.Transport{ Transport: &http2.Transport{
AllowHTTP: true, AllowHTTP: true,
@@ -83,6 +83,7 @@ func TestAdapterHandlingConnectionClosures(t *testing.T) {
assert.NoError(t, err) assert.NoError(t, err)
body, err := io.ReadAll(resp.Body) body, err := io.ReadAll(resp.Body)
t.Cleanup(func() { resp.Body.Close() })
assert.NoError(t, err) assert.NoError(t, err)
assert.Equal(t, "echo: g'day", string(body)) assert.Equal(t, "echo: g'day", string(body))
@@ -102,7 +103,7 @@ func TestAdapterHandlingConnectionClosures(t *testing.T) {
assert.EventuallyWithT(t, func(c *assert.CollectT) { assert.EventuallyWithT(t, func(c *assert.CollectT) {
assert.True(c, handler.conn.Load().IsClosed()) assert.True(c, handler.conn.Load().IsClosed())
}, 3*time.Second, 100*time.Millisecond) }, 3*time.Second, 100*time.Millisecond)
}) }) //nolint:govet
} }
} }
@@ -117,7 +118,7 @@ func TestAdapterHandlingHttpConnection_NoHeadersSent(t *testing.T) {
proxy := New(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { proxy := New(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
buf, _ := io.ReadAll(r.Body) buf, _ := io.ReadAll(r.Body)
defer r.Body.Close() defer r.Body.Close() //nolint:errcheck
w.Write([]byte("echo: " + string(buf))) w.Write([]byte("echo: " + string(buf)))
})) }))
@@ -130,7 +131,7 @@ func TestAdapterHandlingHttpConnection_NoHeadersSent(t *testing.T) {
httpServer := http.Server{ httpServer := http.Server{
Handler: handler, Handler: handler,
} }
go httpServer.Serve(l) go httpServer.Serve(l) //nolint:errcheck
clientconn, _, err := websocket.Dial(context.Background(), "http://whatever", &websocket.DialOptions{HTTPClient: &http.Client{ clientconn, _, err := websocket.Dial(context.Background(), "http://whatever", &websocket.DialOptions{HTTPClient: &http.Client{
Transport: &http.Transport{ Transport: &http.Transport{