File Coverage

blib/lib/RedisScript.pm

Criterion	Covered	Total	%
statement	11	37	29.7
branch	0	8	0.0
condition	0	18	0.0
subroutine	4	8	50.0
pod	0	2	0.0
total	15	73	20.5

package RedisScript;

use 5.026001;
use strict;
use warnings;
use Carp;

our $VERSION = '0.02';

my @_needed_args_for_new = qw{ redis code };


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

  ## init args
  defined $args{ $_ }
    and $self->{ $_ } = $args{ $_ }
    for @_needed_args_for_new;

  ## args validation
  croak( q{missing redis args or invalid redis object} )
    unless( defined( $self->{redis} )
            and ( UNIVERSAL::isa( $self->{redis}, q{Redis} )
                  or $self->{redis}->can( q{script_load} )
                )
          );

  $self->__init_code();

  return $self;
}

sub __init_code {
  my $self = shift;

  ## any cached hash??
  if( ! exists $self->{_sha_cache} ) {
    ## need to load script
    $self->__load_script();
    return;
  }

  ## check if script is loaded
  if( $self->{ redis }->script_exists( $self->{_sha_cache} ) ne 1 ) {
    $self->__load_script();
    return;
  }
  return;
}

sub __load_script {
  my $self = shift;

  my $sha = $self->{redis}->script_load( $self->{ code } );
  $self->{_sha_cache} = $sha;

  return;
}

sub runit {
  my $self = shift;
  my %args = @_;

  $self->__init_code();

  croak( q{need two array ref as args (keys and args)} )
    unless( ( defined( $args{keys} )
              and ( ref( $args{keys} ) eq q{ARRAY} )
            )
            and ( defined( $args{args} )
                  and ( ref( $args{args} ) eq q{ARRAY} ) )
          );

  return $self->{redis}->evalsha( $self->{_sha_cache},
                                  scalar @{ $args{keys} },
                                  @{ $args{keys} },
                                  @{ $args{args} },
                                );
}


1;
__END__