Function TestRedisRefreshTokenStore_Integration

store/redis_test.go:41–81

(t *testing.T)

}

func TestRedisRefreshTokenStore_Integration(t *testing.T) {
	host, port := setupRedisContainer(t)

	// Create Redis store configuration
	config := &RedisConfig{
		Addr:      fmt.Sprintf("%s:%s", host, port),
		Password:  "",
		DB:        0,
		CacheSize: 1024 * 1024, // 1MB for testing
		CacheTTL:  time.Second,
		KeyPrefix: "test-jwt:",
	}

	store, err := NewRedisRefreshTokenStore(config)
	require.NoError(t, err, "failed to create Redis store")
	defer func() {
		if closeErr := store.Close(); closeErr != nil {
			t.Logf("failed to close Redis store: %v", closeErr)
		}
	}()

	t.Run("BasicOperations", func(t *testing.T) {
		testBasicOperations(t, store)
	})

	t.Run("Expiration", func(t *testing.T) {
		testExpiration(t, store)
	})

	t.Run("Cleanup", func(t *testing.T) {
		testCleanup(t, store)
	})

	t.Run("Count", func(t *testing.T) {
		testCount(t, store)
	})

	t.Run("ClientSideCache", func(t *testing.T) {
		testClientSideCache(t, store)
	})
}

func testBasicOperations(t *testing.T, store *RedisRefreshTokenStore) {
	ctx := context.Background()