Function TestSetErrWithWrappedError

error_wrapping_test.go:361–410

TestSetErrWithWrappedError tests that when a hook wraps an error and sets it via cmd.SetErr(), the underlying typed error can still be detected

(t *testing.T)

// TestSetErrWithWrappedError tests that when a hook wraps an error and sets it
// via cmd.SetErr(), the underlying typed error can still be detected
func TestSetErrWithWrappedError(t *testing.T) {
	testCtx := context.Background()

	// Test with a simulated LOADING error
	// We test the mechanism directly without needing a real Redis server
	cmd := redis.NewStatusCmd(testCtx, "GET", "key")
	loadingErr := proto.ParseErrorReply([]byte("-LOADING Redis is loading the dataset in memory"))
	wrappedLoadingErr := fmt.Errorf("hook wrapper: %w", loadingErr)
	cmd.SetErr(wrappedLoadingErr)

	// Verify we can still detect the LOADING error through the wrapper
	if !redis.IsLoadingError(cmd.Err()) {
		t.Errorf("IsLoadingError failed to detect wrapped error set via SetErr: %v", cmd.Err())
	}

	// Test with MOVED error
	cmd2 := redis.NewStatusCmd(testCtx, "GET", "key")
	movedErr := proto.ParseErrorReply([]byte("-MOVED 3999 127.0.0.1:6381"))
	wrappedMovedErr := fmt.Errorf("hook wrapper: %w", movedErr)
	cmd2.SetErr(wrappedMovedErr)

	// Verify we can still detect and extract address from MOVED error
	addr, ok := redis.IsMovedError(cmd2.Err())
	if !ok {
		t.Errorf("IsMovedError failed to detect wrapped error set via SetErr: %v", cmd2.Err())
	}
	if addr != "127.0.0.1:6381" {
		t.Errorf("Address extraction failed: got %q, want %q", addr, "127.0.0.1:6381")
	}

	// Test with READONLY error
	cmd3 := redis.NewStatusCmd(testCtx, "SET", "key", "value")
	readonlyErr := proto.ParseErrorReply([]byte("-READONLY You can't write against a read only replica"))
	wrappedReadonlyErr := fmt.Errorf("custom error wrapper: %w", readonlyErr)
	cmd3.SetErr(wrappedReadonlyErr)

	// Verify we can still detect the READONLY error through the wrapper
	if !redis.IsReadOnlyError(cmd3.Err()) {
		t.Errorf("IsReadOnlyError failed to detect wrapped error set via SetErr: %v", cmd3.Err())
	}

	// Verify the error message contains both the wrapper and original error
	errMsg := cmd3.Err().Error()
	if !contains(errMsg, "custom error wrapper") {
		t.Errorf("Error message missing wrapper context: %v", errMsg)
	}
	if !contains(errMsg, "READONLY") {
		t.Errorf("Error message missing original error: %v", errMsg)
	}
}

// AppError is a custom error type for testing
type AppError struct {