Function getTestValkey

lib/valkeycache/cache_test.go:33–76

nolint: exhaustruct // No need to use every option of 3rd party struct.

(t testing.TB)

// nolint: exhaustruct // No need to use every option of 3rd party struct.
func getTestValkey(t testing.TB) *ValkeyDataCache[string, []byte] {
	ctx := context.Background()
	repoRoot, err := filepath.Abs(filepath.Join(".", "..", ".."))
	if err != nil {
		t.Error(err)
	}
	req := testcontainers.ContainerRequest{
		FromDockerfile: testcontainers.FromDockerfile{
			Dockerfile: filepath.Join(".dev", "valkey", "Dockerfile"),
			Context:    repoRoot,
		},
		ExposedPorts: []string{"6379/tcp"},
		WaitingFor:   wait.ForLog("Ready to accept connections"),
		Name:         "webstatus-dev-test-valkey",
	}
	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
		ContainerRequest: req,
		Started:          true,
	})
	if err != nil {
		t.Error(err)
	}

	mappedPort, err := container.MappedPort(ctx, "6379")
	if err != nil {
		t.Error(err)
	}

	cache, err := NewValkeyDataCache[string, []byte](
		"testPrefix",
		"localhost",
		mappedPort.Port(),
		getDefatulTTL(),
	)
	if err != nil {
		t.Error(err)
	}

	t.Cleanup(func() {
		cache.client.Close()
	})

	return cache
}

func TestValkeyDataCache(t *testing.T) {
	cache := getTestValkey(t)