Function TestMovedAndAskErrorsWithHookWrapping

error_wrapping_test.go:98–148

TestMovedAndAskErrorsWithHookWrapping tests MOVED and ASK errors with wrapping

(t *testing.T)

// TestMovedAndAskErrorsWithHookWrapping tests MOVED and ASK errors with wrapping
func TestMovedAndAskErrorsWithHookWrapping(t *testing.T) {
	tests := []struct {
		name         string
		errorMsg     string
		expectedAddr string
		isMoved      bool
	}{
		{
			name:         "MOVED error",
			errorMsg:     "MOVED 3999 127.0.0.1:6381",
			expectedAddr: "127.0.0.1:6381",
			isMoved:      true,
		},
		{
			name:         "ASK error",
			errorMsg:     "ASK 3999 192.168.1.100:6380",
			expectedAddr: "192.168.1.100:6380",
			isMoved:      false,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			// Create the error
			parsedErr := proto.ParseErrorReply([]byte("-" + tt.errorMsg))

			// Wrap it in hooks
			wrappedErr := fmt.Errorf("hook wrapper: %w", parsedErr)
			doubleWrappedErr := fmt.Errorf("another hook: %w", wrappedErr)

			// Test address extraction from wrapped error
			if tt.isMoved {
				addr, ok := redis.IsMovedError(doubleWrappedErr)
				if !ok {
					t.Errorf("IsMovedError failed to detect wrapped MOVED error")
				}
				if addr != tt.expectedAddr {
					t.Errorf("Address mismatch: got %q, want %q", addr, tt.expectedAddr)
				}
			} else {
				addr, ok := redis.IsAskError(doubleWrappedErr)
				if !ok {
					t.Errorf("IsAskError failed to detect wrapped ASK error")
				}
				if addr != tt.expectedAddr {
					t.Errorf("Address mismatch: got %q, want %q", addr, tt.expectedAddr)
				}
			}
		})
	}
}

// TestBackwardCompatibilityWithStringChecks verifies that old string-based
// error checking still works for backward compatibility