Function TestSearchCommandsRESP2AndRESP3Equivalence

search_resp_test.go:12–357

TestSearchCommandsRESP2AndRESP3Equivalence tests that search commands return equivalent results for both RESP2 and RESP3 protocols.

(t *testing.T)

// TestSearchCommandsRESP2AndRESP3Equivalence tests that search commands
// return equivalent results for both RESP2 and RESP3 protocols.
func TestSearchCommandsRESP2AndRESP3Equivalence(t *testing.T) {
	ctx := context.Background()

	// RESP2 client
	client2 := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Protocol: 2,
	})
	defer client2.Close()

	// RESP3 client
	client3 := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Protocol: 3,
	})
	defer client3.Close()

	// Check connection
	if err := client2.Ping(ctx).Err(); err != nil {
		t.Skipf("Redis not available: %v", err)
	}

	// Clean up before test
	client2.FTDropIndex(ctx, "test-idx")
	client2.Del(ctx, "doc1", "doc2", "doc3")

	t.Run("FTInfo", func(t *testing.T) {
		// Create index
		_, err := client2.FTCreate(ctx, "test-idx",
			&redis.FTCreateOptions{},
			&redis.FieldSchema{FieldName: "title", FieldType: redis.SearchFieldTypeText, Sortable: true},
			&redis.FieldSchema{FieldName: "score", FieldType: redis.SearchFieldTypeNumeric, Sortable: true},
		).Result()
		if err != nil {
			t.Fatalf("FTCreate failed: %v", err)
		}
		defer client2.FTDropIndex(ctx, "test-idx")

		// Add some documents
		client2.HSet(ctx, "doc1", "title", "hello world", "score", 100)
		client2.HSet(ctx, "doc2", "title", "foo bar", "score", 200)

		// Wait for indexing
		waitForIndexing(t, client2, "test-idx", 2)

		// Get FTInfo from both protocols
		info2, err := client2.FTInfo(ctx, "test-idx").Result()
		if err != nil {
			t.Fatalf("FTInfo RESP2 failed: %v", err)
		}

		info3, err := client3.FTInfo(ctx, "test-idx").Result()
		if err != nil {
			t.Fatalf("FTInfo RESP3 failed: %v", err)
		}

		// Compare key fields
		if info2.IndexName != info3.IndexName {