diff --git a/app.go b/app.go index e0240d3c16..a8306bbc34 100644 --- a/app.go +++ b/app.go @@ -14,6 +14,7 @@ import ( "encoding/xml" "errors" "fmt" + "io" "net" "net/http" "net/http/httputil" @@ -864,13 +865,33 @@ func (app *App) Hooks() *Hooks { return app.hooks } +// TestConfig is a struct holding Test settings +type TestConfig struct { + // Timeout defines the maximum duration a + // test can run before timing out. + // Default: time.Second + Timeout time.Duration + + // FailOnTimeout specifies whether the test + // should return a timeout error if the HTTP response + // exceeds the Timeout duration. + // Default: true + FailOnTimeout bool +} + // Test is used for internal debugging by passing a *http.Request. -// Timeout is optional and defaults to 1s, -1 will disable it completely. -func (app *App) Test(req *http.Request, timeout ...time.Duration) (*http.Response, error) { - // Set timeout - to := 1 * time.Second - if len(timeout) > 0 { - to = timeout[0] +// Config is optional and defaults to a 1s error on timeout, +// -1 timeout will disable it completely. +func (app *App) Test(req *http.Request, config ...TestConfig) (*http.Response, error) { + // Default config + cfg := TestConfig{ + Timeout: time.Second, + FailOnTimeout: true, + } + + // Override config if provided + if len(config) > 0 { + cfg = config[0] } // Add Content-Length if not provided with body @@ -909,12 +930,15 @@ func (app *App) Test(req *http.Request, timeout ...time.Duration) (*http.Respons }() // Wait for callback - if to >= 0 { + if cfg.Timeout >= 0 { // With timeout select { case err = <-channel: - case <-time.After(to): - return nil, fmt.Errorf("test: timeout error after %s", to) + case <-time.After(cfg.Timeout): + conn.Close() //nolint:errcheck, revive // It is fine to ignore the error here + if cfg.FailOnTimeout { + return nil, fmt.Errorf("test: timeout error after %s", cfg.Timeout) + } } } else { // Without timeout @@ -932,6 +956,9 @@ func (app *App) Test(req *http.Request, timeout ...time.Duration) (*http.Respons // Convert raw http response to *http.Response res, err := http.ReadResponse(buffer, req) if err != nil { + if errors.Is(err, io.ErrUnexpectedEOF) { + return nil, errors.New("test: got empty response") + } return nil, fmt.Errorf("failed to read response: %w", err) } diff --git a/app_test.go b/app_test.go index 6b493de1eb..db790430d0 100644 --- a/app_test.go +++ b/app_test.go @@ -1124,7 +1124,10 @@ func Test_Test_Timeout(t *testing.T) { app.Get("/", testEmptyHandler) - resp, err := app.Test(httptest.NewRequest(MethodGet, "/", nil), -1) + resp, err := app.Test(httptest.NewRequest(MethodGet, "/", nil), TestConfig{ + Timeout: -1, + FailOnTimeout: false, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") @@ -1133,7 +1136,10 @@ func Test_Test_Timeout(t *testing.T) { return nil }) - _, err = app.Test(httptest.NewRequest(MethodGet, "/timeout", nil), 20*time.Millisecond) + _, err = app.Test(httptest.NewRequest(MethodGet, "/timeout", nil), TestConfig{ + Timeout: 20 * time.Millisecond, + FailOnTimeout: true, + }) require.Error(t, err, "app.Test(req)") } @@ -1432,7 +1438,10 @@ func Test_App_Test_no_timeout_infinitely(t *testing.T) { }) req := httptest.NewRequest(MethodGet, "/", nil) - _, err = app.Test(req, -1) + _, err = app.Test(req, TestConfig{ + Timeout: -1, + FailOnTimeout: true, + }) }() tk := time.NewTimer(5 * time.Second) @@ -1460,10 +1469,29 @@ func Test_App_Test_timeout(t *testing.T) { return nil }) - _, err := app.Test(httptest.NewRequest(MethodGet, "/", nil), 100*time.Millisecond) + _, err := app.Test(httptest.NewRequest(MethodGet, "/", nil), TestConfig{ + Timeout: 100 * time.Millisecond, + FailOnTimeout: true, + }) require.Equal(t, errors.New("test: timeout error after 100ms"), err) } +func Test_App_Test_timeout_empty_response(t *testing.T) { + t.Parallel() + + app := New() + app.Get("/", func(_ Ctx) error { + time.Sleep(1 * time.Second) + return nil + }) + + _, err := app.Test(httptest.NewRequest(MethodGet, "/", nil), TestConfig{ + Timeout: 100 * time.Millisecond, + FailOnTimeout: false, + }) + require.Equal(t, errors.New("test: got empty response"), err) +} + func Test_App_SetTLSHandler(t *testing.T) { t.Parallel() tlsHandler := &TLSHandler{clientHelloInfo: &tls.ClientHelloInfo{ diff --git a/ctx_test.go b/ctx_test.go index a94e4cb42b..60bb1e547b 100644 --- a/ctx_test.go +++ b/ctx_test.go @@ -3142,7 +3142,10 @@ func Test_Static_Compress(t *testing.T) { req := httptest.NewRequest(MethodGet, "/file", nil) req.Header.Set("Accept-Encoding", algo) - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") diff --git a/docs/api/app.md b/docs/api/app.md index ef9c2ea08d..822d997988 100644 --- a/docs/api/app.md +++ b/docs/api/app.md @@ -537,10 +537,10 @@ func (app *App) SetTLSHandler(tlsHandler *TLSHandler) ## Test -Testing your application is done with the **Test** method. Use this method for creating `_test.go` files or when you need to debug your routing logic. The default timeout is `1s` if you want to disable a timeout altogether, pass `-1` as a second argument. +Testing your application is done with the **Test** method. Use this method for creating `_test.go` files or when you need to debug your routing logic. The default timeout is `1s`. If you want to disable a timeout altogether, pass a `TestConfig` struct with `Timeout: -1`. ```go title="Signature" -func (app *App) Test(req *http.Request, msTimeout ...int) (*http.Response, error) +func (app *App) Test(req *http.Request, config ...TestConfig) (*http.Response, error) ``` ```go title="Examples" @@ -566,6 +566,32 @@ if resp.StatusCode == fiber.StatusOK { } ``` +If not provided, TestConfig is set to the following defaults: + +```go title="Default TestConfig" +config := fiber.TestConfig{ + Timeout: time.Second(), + FailOnTimeout: true, +} +``` + +:::caution + +This is **not** the same as supplying an empty `TestConfig{}` to +`app.Test(), but rather be the equivalent of supplying: + +```go title="Empty TestConfig" +cfg := fiber.TestConfig{ + Timeout: 0, + FailOnTimeout: false, +} +``` + +This would make a Test that instantly times out, +which would always result in a "test: empty response" error. + +::: + ## Hooks Hooks is a method to return [hooks](./hooks.md) property. diff --git a/helpers.go b/helpers.go index 90621b1c42..526074032a 100644 --- a/helpers.go +++ b/helpers.go @@ -613,13 +613,36 @@ func isNoCache(cacheControl string) bool { } type testConn struct { - r bytes.Buffer - w bytes.Buffer + r bytes.Buffer + w bytes.Buffer + isClosed bool + sync.Mutex } -func (c *testConn) Read(b []byte) (int, error) { return c.r.Read(b) } //nolint:wrapcheck // This must not be wrapped -func (c *testConn) Write(b []byte) (int, error) { return c.w.Write(b) } //nolint:wrapcheck // This must not be wrapped -func (*testConn) Close() error { return nil } +func (c *testConn) Read(b []byte) (int, error) { + c.Lock() + defer c.Unlock() + + return c.r.Read(b) //nolint:wrapcheck // This must not be wrapped +} + +func (c *testConn) Write(b []byte) (int, error) { + c.Lock() + defer c.Unlock() + + if c.isClosed { + return 0, errors.New("testConn is closed") + } + return c.w.Write(b) //nolint:wrapcheck // This must not be wrapped +} + +func (c *testConn) Close() error { + c.Lock() + defer c.Unlock() + + c.isClosed = true + return nil +} func (*testConn) LocalAddr() net.Addr { return &net.TCPAddr{Port: 0, Zone: "", IP: net.IPv4zero} } func (*testConn) RemoteAddr() net.Addr { return &net.TCPAddr{Port: 0, Zone: "", IP: net.IPv4zero} } diff --git a/helpers_test.go b/helpers_test.go index ddee434098..28a5df2ae7 100644 --- a/helpers_test.go +++ b/helpers_test.go @@ -514,6 +514,48 @@ func Test_Utils_TestConn_Deadline(t *testing.T) { require.NoError(t, conn.SetWriteDeadline(time.Time{})) } +func Test_Utils_TestConn_ReadWrite(t *testing.T) { + t.Parallel() + conn := &testConn{} + + // Verify read of request + _, err := conn.r.Write([]byte("Request")) + require.NoError(t, err) + + req := make([]byte, 7) + _, err = conn.Read(req) + require.NoError(t, err) + require.Equal(t, []byte("Request"), req) + + // Verify write of response + _, err = conn.Write([]byte("Response")) + require.NoError(t, err) + + res := make([]byte, 8) + _, err = conn.w.Read(res) + require.NoError(t, err) + require.Equal(t, []byte("Response"), res) +} + +func Test_Utils_TestConn_Closed_Write(t *testing.T) { + t.Parallel() + conn := &testConn{} + + // Verify write of response + _, err := conn.Write([]byte("Response 1\n")) + require.NoError(t, err) + + // Close early, write should fail + conn.Close() //nolint:errcheck, revive // It is fine to ignore the error here + _, err = conn.Write([]byte("Response 2\n")) + require.Error(t, err) + + res := make([]byte, 11) + _, err = conn.w.Read(res) + require.NoError(t, err) + require.Equal(t, []byte("Response 1\n"), res) +} + func Test_Utils_IsNoCache(t *testing.T) { t.Parallel() testCases := []struct { diff --git a/middleware/compress/compress_test.go b/middleware/compress/compress_test.go index f258ba4460..4e46e3edec 100644 --- a/middleware/compress/compress_test.go +++ b/middleware/compress/compress_test.go @@ -39,7 +39,10 @@ func Test_Compress_Gzip(t *testing.T) { req := httptest.NewRequest(fiber.MethodGet, "/", nil) req.Header.Set("Accept-Encoding", "gzip") - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") require.Equal(t, "gzip", resp.Header.Get(fiber.HeaderContentEncoding)) @@ -72,7 +75,10 @@ func Test_Compress_Different_Level(t *testing.T) { req := httptest.NewRequest(fiber.MethodGet, "/", nil) req.Header.Set("Accept-Encoding", algo) - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") require.Equal(t, algo, resp.Header.Get(fiber.HeaderContentEncoding)) @@ -99,7 +105,10 @@ func Test_Compress_Deflate(t *testing.T) { req := httptest.NewRequest(fiber.MethodGet, "/", nil) req.Header.Set("Accept-Encoding", "deflate") - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") require.Equal(t, "deflate", resp.Header.Get(fiber.HeaderContentEncoding)) @@ -123,7 +132,10 @@ func Test_Compress_Brotli(t *testing.T) { req := httptest.NewRequest(fiber.MethodGet, "/", nil) req.Header.Set("Accept-Encoding", "br") - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") require.Equal(t, "br", resp.Header.Get(fiber.HeaderContentEncoding)) @@ -147,7 +159,10 @@ func Test_Compress_Zstd(t *testing.T) { req := httptest.NewRequest(fiber.MethodGet, "/", nil) req.Header.Set("Accept-Encoding", "zstd") - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") require.Equal(t, "zstd", resp.Header.Get(fiber.HeaderContentEncoding)) @@ -171,7 +186,10 @@ func Test_Compress_Disabled(t *testing.T) { req := httptest.NewRequest(fiber.MethodGet, "/", nil) req.Header.Set("Accept-Encoding", "br") - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") require.Equal(t, "", resp.Header.Get(fiber.HeaderContentEncoding)) diff --git a/middleware/idempotency/idempotency_test.go b/middleware/idempotency/idempotency_test.go index 91394ca26a..56b10d9c03 100644 --- a/middleware/idempotency/idempotency_test.go +++ b/middleware/idempotency/idempotency_test.go @@ -82,7 +82,10 @@ func Test_Idempotency(t *testing.T) { if idempotencyKey != "" { req.Header.Set("X-Idempotency-Key", idempotencyKey) } - resp, err := app.Test(req, 15*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 15 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) body, err := io.ReadAll(resp.Body) require.NoError(t, err) diff --git a/middleware/keyauth/keyauth_test.go b/middleware/keyauth/keyauth_test.go index 9da675fe8f..60d71cafa1 100644 --- a/middleware/keyauth/keyauth_test.go +++ b/middleware/keyauth/keyauth_test.go @@ -104,7 +104,10 @@ func Test_AuthSources(t *testing.T) { req.URL.Path = r } - res, err := app.Test(req, -1) + res, err := app.Test(req, fiber.TestConfig{ + Timeout: -1, + FailOnTimeout: false, + }) require.NoError(t, err, test.description) @@ -209,7 +212,10 @@ func TestMultipleKeyLookup(t *testing.T) { q.Add("key", CorrectKey) req.URL.RawQuery = q.Encode() - res, err := app.Test(req, -1) + res, err := app.Test(req, fiber.TestConfig{ + Timeout: -1, + FailOnTimeout: false, + }) require.NoError(t, err) @@ -226,7 +232,10 @@ func TestMultipleKeyLookup(t *testing.T) { // construct a second request without proper key req, err = http.NewRequestWithContext(context.Background(), fiber.MethodGet, "/foo", nil) require.NoError(t, err) - res, err = app.Test(req, -1) + res, err = app.Test(req, fiber.TestConfig{ + Timeout: -1, + FailOnTimeout: false, + }) require.NoError(t, err) errBody, err := io.ReadAll(res.Body) require.NoError(t, err) @@ -350,7 +359,10 @@ func Test_MultipleKeyAuth(t *testing.T) { req.Header.Set("key", test.APIKey) } - res, err := app.Test(req, -1) + res, err := app.Test(req, fiber.TestConfig{ + Timeout: -1, + FailOnTimeout: false, + }) require.NoError(t, err, test.description) diff --git a/middleware/logger/logger_test.go b/middleware/logger/logger_test.go index 0bc06531c9..570b046ae0 100644 --- a/middleware/logger/logger_test.go +++ b/middleware/logger/logger_test.go @@ -300,7 +300,10 @@ func Test_Logger_WithLatency(t *testing.T) { sleepDuration = 1 * tu.div // Create a new HTTP request to the test route - resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), 3*time.Second) + resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), fiber.TestConfig{ + Timeout: 3 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusOK, resp.StatusCode) @@ -342,7 +345,10 @@ func Test_Logger_WithLatency_DefaultFormat(t *testing.T) { sleepDuration = 1 * tu.div // Create a new HTTP request to the test route - resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), 2*time.Second) + resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusOK, resp.StatusCode) diff --git a/middleware/pprof/pprof_test.go b/middleware/pprof/pprof_test.go index 7a279d488d..e163804a6b 100644 --- a/middleware/pprof/pprof_test.go +++ b/middleware/pprof/pprof_test.go @@ -105,7 +105,10 @@ func Test_Pprof_Subs(t *testing.T) { if sub == "profile" { target += "?seconds=1" } - resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, target, nil), 5*time.Second) + resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, target, nil), fiber.TestConfig{ + Timeout: 5 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, 200, resp.StatusCode) }) @@ -132,7 +135,10 @@ func Test_Pprof_Subs_WithPrefix(t *testing.T) { if sub == "profile" { target += "?seconds=1" } - resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, target, nil), 5*time.Second) + resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, target, nil), fiber.TestConfig{ + Timeout: 5 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, 200, resp.StatusCode) }) diff --git a/middleware/proxy/proxy_test.go b/middleware/proxy/proxy_test.go index 713488a52b..de2b7701cf 100644 --- a/middleware/proxy/proxy_test.go +++ b/middleware/proxy/proxy_test.go @@ -110,7 +110,10 @@ func Test_Proxy(t *testing.T) { return c.SendStatus(fiber.StatusTeapot) }) - resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), 2*time.Second) + resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusTeapot, resp.StatusCode) @@ -172,7 +175,10 @@ func Test_Proxy_Balancer_IPv6_Upstream(t *testing.T) { return c.SendStatus(fiber.StatusTeapot) }) - resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), 2*time.Second) + resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusTeapot, resp.StatusCode) @@ -195,7 +201,10 @@ func Test_Proxy_Balancer_IPv6_Upstream_With_DialDualStack(t *testing.T) { return c.SendStatus(fiber.StatusTeapot) }) - resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), 2*time.Second) + resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusTeapot, resp.StatusCode) @@ -221,7 +230,10 @@ func Test_Proxy_Balancer_IPv4_Upstream_With_DialDualStack(t *testing.T) { return c.SendStatus(fiber.StatusTeapot) }) - resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), 2*time.Second) + resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusTeapot, resp.StatusCode) @@ -399,7 +411,10 @@ func Test_Proxy_Timeout_Slow_Server(t *testing.T) { Timeout: 600 * time.Millisecond, })) - resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), 2*time.Second) + resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusOK, resp.StatusCode) @@ -423,7 +438,10 @@ func Test_Proxy_With_Timeout(t *testing.T) { Timeout: 100 * time.Millisecond, })) - resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), 2*time.Second) + resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusInternalServerError, resp.StatusCode) @@ -521,7 +539,10 @@ func Test_Proxy_DoRedirects_RestoreOriginalURL(t *testing.T) { return DoRedirects(c, "http://google.com", 1) }) - resp, err1 := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), 2*time.Second) + resp, err1 := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err1) _, err := io.ReadAll(resp.Body) require.NoError(t, err) @@ -559,7 +580,10 @@ func Test_Proxy_DoTimeout_RestoreOriginalURL(t *testing.T) { return DoTimeout(c, "http://"+addr, time.Second) }) - resp, err1 := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), 2*time.Second) + resp, err1 := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err1) body, err := io.ReadAll(resp.Body) require.NoError(t, err) @@ -580,7 +604,10 @@ func Test_Proxy_DoTimeout_Timeout(t *testing.T) { return DoTimeout(c, "http://"+addr, time.Second) }) - resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), 2*time.Second) + resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) body, err := io.ReadAll(resp.Body) require.NoError(t, err) @@ -624,7 +651,10 @@ func Test_Proxy_DoDeadline_PastDeadline(t *testing.T) { return DoDeadline(c, "http://"+addr, time.Now().Add(2*time.Second)) }) - _, err1 := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), 1*time.Second) + _, err1 := app.Test(httptest.NewRequest(fiber.MethodGet, "/test", nil), fiber.TestConfig{ + Timeout: 1 * time.Second, + FailOnTimeout: true, + }) require.Equal(t, errors.New("test: timeout error after 1s"), err1) } @@ -717,7 +747,10 @@ func Test_ProxyBalancer_Custom_Client(t *testing.T) { return c.SendStatus(fiber.StatusTeapot) }) - resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), 2*time.Second) + resp, err := target.Test(httptest.NewRequest(fiber.MethodGet, "/", nil), fiber.TestConfig{ + Timeout: 2 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err) require.Equal(t, fiber.StatusTeapot, resp.StatusCode) diff --git a/middleware/static/static_test.go b/middleware/static/static_test.go index 4d736b0c43..231332ef77 100644 --- a/middleware/static/static_test.go +++ b/middleware/static/static_test.go @@ -738,7 +738,10 @@ func Test_Static_Compress(t *testing.T) { // request non-compressable file (less than 200 bytes), Content Lengh will remain the same req := httptest.NewRequest(fiber.MethodGet, "/css/style.css", nil) req.Header.Set("Accept-Encoding", algo) - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") @@ -748,7 +751,10 @@ func Test_Static_Compress(t *testing.T) { // request compressable file, ContentLenght will change req = httptest.NewRequest(fiber.MethodGet, "/index.html", nil) req.Header.Set("Accept-Encoding", algo) - resp, err = app.Test(req, 10*time.Second) + resp, err = app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") @@ -769,7 +775,10 @@ func Test_Static_Compress_WithoutEncoding(t *testing.T) { // request compressable file without encoding req := httptest.NewRequest(fiber.MethodGet, "/index.html", nil) - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") @@ -792,7 +801,10 @@ func Test_Static_Compress_WithoutEncoding(t *testing.T) { req = httptest.NewRequest(fiber.MethodGet, "/"+fileName, nil) req.Header.Set("Accept-Encoding", algo) - resp, err = app.Test(req, 10*time.Second) + resp, err = app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code") @@ -833,7 +845,10 @@ func Test_Static_Compress_WithFileSuffixes(t *testing.T) { req := httptest.NewRequest(fiber.MethodGet, "/"+fileName, nil) req.Header.Set("Accept-Encoding", algo) - resp, err := app.Test(req, 10*time.Second) + resp, err := app.Test(req, fiber.TestConfig{ + Timeout: 10 * time.Second, + FailOnTimeout: true, + }) require.NoError(t, err, "app.Test(req)") require.Equal(t, 200, resp.StatusCode, "Status code")