Skip to content
代码片段 群组 项目
提交 a731dbd4 编辑于 作者: gaurav.marwal's avatar gaurav.marwal
浏览文件

Fix lint issues in workhorse authorization, cable and channel tests

上级 d95d373d
No related branches found
No related tags found
无相关合并请求
...@@ -25,7 +25,7 @@ func okHandler(w http.ResponseWriter, _ *http.Request, _ *api.Response) { ...@@ -25,7 +25,7 @@ func okHandler(w http.ResponseWriter, _ *http.Request, _ *api.Response) {
fmt.Fprint(w, "{\"status\":\"ok\"}") fmt.Fprint(w, "{\"status\":\"ok\"}")
} }
func runPreAuthorizeHandler(t *testing.T, ts *httptest.Server, suffix string, url *regexp.Regexp, apiResponse interface{}, returnCode, expectedCode int) *httptest.ResponseRecorder { func runPreAuthorizeHandler(t *testing.T, ts *httptest.Server, suffix string, url *regexp.Regexp, apiResponse interface{}, returnCode, expectedCode int) {
if ts == nil { if ts == nil {
ts = testAuthServer(t, url, nil, returnCode, apiResponse) ts = testAuthServer(t, url, nil, returnCode, apiResponse)
} }
...@@ -41,7 +41,6 @@ func runPreAuthorizeHandler(t *testing.T, ts *httptest.Server, suffix string, ur ...@@ -41,7 +41,6 @@ func runPreAuthorizeHandler(t *testing.T, ts *httptest.Server, suffix string, ur
response := httptest.NewRecorder() response := httptest.NewRecorder()
a.PreAuthorizeHandler(okHandler, suffix).ServeHTTP(response, httpRequest) a.PreAuthorizeHandler(okHandler, suffix).ServeHTTP(response, httpRequest)
require.Equal(t, expectedCode, response.Code) require.Equal(t, expectedCode, response.Code)
return response
} }
func TestPreAuthorizeHappyPath(t *testing.T) { func TestPreAuthorizeHappyPath(t *testing.T) {
......
...@@ -26,7 +26,8 @@ func TestSingleBackend(t *testing.T) { ...@@ -26,7 +26,8 @@ func TestSingleBackend(t *testing.T) {
cableURL := websocketURL(workhorse.URL, cablePath) cableURL := websocketURL(workhorse.URL, cablePath)
client, _, err := dialWebsocket(cableURL, nil) client, http, err := dialWebsocket(cableURL, nil)
defer http.Body.Close()
require.NoError(t, err) require.NoError(t, err)
defer client.Close() defer client.Close()
...@@ -41,7 +42,7 @@ func TestSingleBackend(t *testing.T) { ...@@ -41,7 +42,7 @@ func TestSingleBackend(t *testing.T) {
} }
func TestSeparateCableBackend(t *testing.T) { func TestSeparateCableBackend(t *testing.T) {
authBackendServer := testhelper.TestServerWithHandler(regexp.MustCompile(`.`), http.HandlerFunc(http.NotFound)) authBackendServer := testhelper.TestServerWithHandler(regexp.MustCompile(`.`), http.HandlerFunc(http.NotFoundHandler().ServeHTTP))
defer authBackendServer.Close() defer authBackendServer.Close()
cableServerConns, cableBackendServer := startCableServer() cableServerConns, cableBackendServer := startCableServer()
...@@ -52,7 +53,8 @@ func TestSeparateCableBackend(t *testing.T) { ...@@ -52,7 +53,8 @@ func TestSeparateCableBackend(t *testing.T) {
cableURL := websocketURL(workhorse.URL, cablePath) cableURL := websocketURL(workhorse.URL, cablePath)
client, _, err := dialWebsocket(cableURL, nil) client, http, err := dialWebsocket(cableURL, nil)
defer http.Body.Close()
require.NoError(t, err) require.NoError(t, err)
defer client.Close() defer client.Close()
......
...@@ -44,7 +44,8 @@ func TestChannelHappyPath(t *testing.T) { ...@@ -44,7 +44,8 @@ func TestChannelHappyPath(t *testing.T) {
t.Run(test.name, func(t *testing.T) { t.Run(test.name, func(t *testing.T) {
serverConns, clientURL := wireupChannel(t, test.channelPath, nil, "channel.k8s.io") serverConns, clientURL := wireupChannel(t, test.channelPath, nil, "channel.k8s.io")
client, _, err := dialWebsocket(clientURL, nil, "terminal.gitlab.com") client, http, err := dialWebsocket(clientURL, nil, "terminal.gitlab.com")
defer http.Body.Close()
require.NoError(t, err) require.NoError(t, err)
server := (<-serverConns).conn server := (<-serverConns).conn
...@@ -71,14 +72,16 @@ func TestChannelHappyPath(t *testing.T) { ...@@ -71,14 +72,16 @@ func TestChannelHappyPath(t *testing.T) {
func TestChannelBadTLS(t *testing.T) { func TestChannelBadTLS(t *testing.T) {
_, clientURL := wireupChannel(t, envTerminalPath, badCA, "channel.k8s.io") _, clientURL := wireupChannel(t, envTerminalPath, badCA, "channel.k8s.io")
_, _, err := dialWebsocket(clientURL, nil, "terminal.gitlab.com") _, http, err := dialWebsocket(clientURL, nil, "terminal.gitlab.com")
defer http.Body.Close()
require.Equal(t, websocket.ErrBadHandshake, err, "unexpected error %v", err) require.Equal(t, websocket.ErrBadHandshake, err, "unexpected error %v", err)
} }
func TestChannelSessionTimeout(t *testing.T) { func TestChannelSessionTimeout(t *testing.T) {
serverConns, clientURL := wireupChannel(t, envTerminalPath, timeout, "channel.k8s.io") serverConns, clientURL := wireupChannel(t, envTerminalPath, timeout, "channel.k8s.io")
client, _, err := dialWebsocket(clientURL, nil, "terminal.gitlab.com") client, http, err := dialWebsocket(clientURL, nil, "terminal.gitlab.com")
defer http.Body.Close()
require.NoError(t, err) require.NoError(t, err)
sc := <-serverConns sc := <-serverConns
...@@ -95,7 +98,8 @@ func TestChannelProxyForwardsHeadersFromUpstream(t *testing.T) { ...@@ -95,7 +98,8 @@ func TestChannelProxyForwardsHeadersFromUpstream(t *testing.T) {
hdr.Set("Random-Header", "Value") hdr.Set("Random-Header", "Value")
serverConns, clientURL := wireupChannel(t, envTerminalPath, setHeader(hdr), "channel.k8s.io") serverConns, clientURL := wireupChannel(t, envTerminalPath, setHeader(hdr), "channel.k8s.io")
client, _, err := dialWebsocket(clientURL, nil, "terminal.gitlab.com") client, http, err := dialWebsocket(clientURL, nil, "terminal.gitlab.com")
defer http.Body.Close()
require.NoError(t, err) require.NoError(t, err)
defer client.Close() defer client.Close()
...@@ -109,7 +113,8 @@ func TestChannelProxyForwardsXForwardedForFromClient(t *testing.T) { ...@@ -109,7 +113,8 @@ func TestChannelProxyForwardsXForwardedForFromClient(t *testing.T) {
hdr := make(http.Header) hdr := make(http.Header)
hdr.Set("X-Forwarded-For", "127.0.0.2") hdr.Set("X-Forwarded-For", "127.0.0.2")
client, _, err := dialWebsocket(clientURL, hdr, "terminal.gitlab.com") client, http, err := dialWebsocket(clientURL, hdr, "terminal.gitlab.com")
defer http.Body.Close()
require.NoError(t, err) require.NoError(t, err)
defer client.Close() defer client.Close()
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册