File Coverage

blib/lib/Async/Redis/Script.pm

Criterion	Covered	Total	%
statement	14	43	32.5
branch	0	4	0.0
condition	0	10	0.0
subroutine	5	16	31.2
pod	10	11	90.9
total	29	84	34.5

package Async::Redis::Script;

use strict;
use warnings;
use 5.018;

use Future::AsyncAwait;
use Digest::SHA qw(sha1_hex);

sub new {
    my ($class, %args) = @_;

    my $script = $args{script};
    die "Script code required" unless defined $script;

    return bless {
        redis       => $args{redis},
        script      => $script,
        sha         => lc(sha1_hex($script)),
        name        => $args{name},
        num_keys    => $args{num_keys} // 'dynamic',
        description => $args{description},
    }, $class;
}

# Accessors
sub sha         { shift->{sha} }
sub script      { shift->{script} }
sub name        { shift->{name} }
sub num_keys    { shift->{num_keys} }
sub description { shift->{description} }
sub redis       { shift->{redis} }

# Preferred entry point: run with explicit keys and args arrays
# Usage: $script->run(\@keys, \@args)
async sub run {
    my ($self, $keys_aref, $args_aref) = @_;

    $keys_aref //= [];
    $args_aref //= [];

    my $numkeys = scalar @$keys_aref;
    return await $self->call_with_keys($numkeys, @$keys_aref, @$args_aref);
}

# Run on a specific connection (for pipeline/pool support)
# Usage: $script->run_on($redis, \@keys, \@args)
async sub run_on {
    my ($self, $redis, $keys_aref, $args_aref) = @_;

    $keys_aref //= [];
    $args_aref //= [];

    my $numkeys = scalar @$keys_aref;

    return await $redis->evalsha_or_eval(
        $self->{sha},
        $self->{script},
        $numkeys,
        @$keys_aref,
        @$args_aref,
    );
}

# Legacy: call with automatic key count detection
# Usage: $script->call('arg1', 'arg2')
# Assumes all args are ARGV (no KEYS)
async sub call {
    my ($self, @args) = @_;
    return await $self->call_with_keys(0, @args);
}

# Legacy: call with explicit key count
# Usage: $script->call_with_keys($numkeys, @keys, @args)
async sub call_with_keys {
    my ($self, $numkeys, @keys_and_args) = @_;

    my $redis = $self->{redis}
        or die "No Redis connection - use run_on() or pass redis to constructor";

    return await $redis->evalsha_or_eval(
        $self->{sha},
        $self->{script},
        $numkeys,
        @keys_and_args,
    );
}

1;

__END__