Test_CacheRespectsUpstreamAgeForFreshness() — fiber Function Reference

Architecture documentation for the Test_CacheRespectsUpstreamAgeForFreshness() function in cache_test.go from the fiber codebase.

Function go FiberMiddleware Caching

Entity Profile

FiberMiddleware→ Caching→ Test_CacheRespectsUpstreamAgeForFreshness() — fiber Function Reference

Dependency Diagram

graph TD
  3bce2fa1_621c_c32e_f46e_8781d203912b["Test_CacheRespectsUpstreamAgeForFreshness()"]
  8453a087_9678_fe96_1b20_2d125b6f8656["cache_test.go"]
  3bce2fa1_621c_c32e_f46e_8781d203912b -->|defined in| 8453a087_9678_fe96_1b20_2d125b6f8656
  style 3bce2fa1_621c_c32e_f46e_8781d203912b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

middleware/cache/cache_test.go lines 2678–2756

func Test_CacheRespectsUpstreamAgeForFreshness(t *testing.T) {
	t.Parallel()

	t.Run("skipsCachingWhenAgeExhaustsFreshness", func(t *testing.T) {
		t.Parallel()

		app := fiber.New()
		app.Use(New(Config{
			KeyGenerator: func(c fiber.Ctx) string {
				return c.Path() + "|age-exhausted"
			},
		}))

		var count int
		app.Get("/", func(c fiber.Ctx) error {
			count++
			c.Set(fiber.HeaderCacheControl, "public, max-age=2")
			c.Set(fiber.HeaderAge, "2")
			return c.SendString(strconv.Itoa(count))
		})

		resp, err := app.Test(httptest.NewRequest(fiber.MethodGet, "/", http.NoBody))
		require.NoError(t, err)
		require.Equal(t, cacheUnreachable, resp.Header.Get("X-Cache"))
		body, err := io.ReadAll(resp.Body)
		require.NoError(t, err)
		require.Equal(t, "1", string(body))

		resp, err = app.Test(httptest.NewRequest(fiber.MethodGet, "/", http.NoBody))
		require.NoError(t, err)
		require.Equal(t, cacheUnreachable, resp.Header.Get("X-Cache"))
		body, err = io.ReadAll(resp.Body)
		require.NoError(t, err)
		require.Equal(t, "2", string(body))
	})

	t.Run("expiresAfterRemainingLifetime", func(t *testing.T) {
		t.Parallel()

		app := fiber.New()
		app.Use(New(Config{
			KeyGenerator: func(c fiber.Ctx) string {
				return c.Path() + "|age-remaining"
			},
		}))

		var count int
		app.Get("/", func(c fiber.Ctx) error {
			count++
			c.Set(fiber.HeaderCacheControl, "public, max-age=2")
			c.Set(fiber.HeaderAge, "1")
			return c.SendString(strconv.Itoa(count))
		})

		req := httptest.NewRequest(fiber.MethodGet, "/", http.NoBody)
		resp, err := app.Test(req)
		require.NoError(t, err)
		require.Equal(t, cacheMiss, resp.Header.Get("X-Cache"))
		body, err := io.ReadAll(resp.Body)
		require.NoError(t, err)
		require.Equal(t, "1", string(body))

		resp, err = app.Test(httptest.NewRequest(fiber.MethodGet, "/", http.NoBody))
		require.NoError(t, err)
		require.Equal(t, cacheHit, resp.Header.Get("X-Cache"))
		body, err = io.ReadAll(resp.Body)
		require.NoError(t, err)
		require.Equal(t, "1", string(body))

		time.Sleep(1500 * time.Millisecond)

		resp, err = app.Test(httptest.NewRequest(fiber.MethodGet, "/", http.NoBody))
		require.NoError(t, err)
		require.Equal(t, cacheMiss, resp.Header.Get("X-Cache"))
		body, err = io.ReadAll(resp.Body)
		require.NoError(t, err)
		require.Equal(t, "2", string(body))
	})
}