File Coverage

blib/lib/Async/Redis/Error/Redis.pm

Criterion	Covered	Total	%
statement	27	33	81.8
branch	3	6	50.0
condition	7	20	35.0
subroutine	13	16	81.2
pod	12	12	100.0
total	62	87	71.2

package Async::Redis::Error::Redis;

use strict;
use warnings;
use 5.018;

use parent 'Async::Redis::Error';

sub type { shift->{type} }

# Parse error type from Redis error message
# Redis errors are formatted as: "ERRORTYPE message text"
sub from_message {
    my ($class, $message) = @_;

    my $type = 'ERR';  # default
    if ($message =~ /^([A-Z]+)\s/) {
        $type = $1;
    }

    return $class->new(
        message => $message,
        type    => $type,
    );
}

# Predicate methods for common error types
sub is_wrongtype { uc(shift->{type} // '') eq 'WRONGTYPE' }
sub is_oom       { uc(shift->{type} // '') eq 'OOM' }
sub is_busy      { uc(shift->{type} // '') eq 'BUSY' }
sub is_noscript  { uc(shift->{type} // '') eq 'NOSCRIPT' }
sub is_readonly  { uc(shift->{type} // '') eq 'READONLY' }
sub is_loading   { uc(shift->{type} // '') eq 'LOADING' }
sub is_noauth    { uc(shift->{type} // '') eq 'NOAUTH' }
sub is_noperm    { uc(shift->{type} // '') eq 'NOPERM' }

# Fatal errors should not be retried
sub is_fatal {
    my $self = shift;
    my $type = uc($self->{type} // '');

    # These are deterministic failures - retrying won't help
    return 1 if $type =~ /^(WRONGTYPE|OOM|NOSCRIPT|NOAUTH|NOPERM|ERR)$/;

    return 0;
}

# Transient errors may succeed on retry
sub is_transient {
    my $self = shift;
    my $type = uc($self->{type} // '');

    # These may succeed if retried after a delay
    return 1 if $type =~ /^(BUSY|LOADING|READONLY|CLUSTERDOWN)$/;

    return 0;
}

1;

__END__