File Coverage

blib/lib/Redis/AOF/Tail/File.pm

Criterion	Covered	Total	%
statement	48	48	100.0
branch	8	10	80.0
condition	6	6	100.0
subroutine	6	6	100.0
pod	2	2	100.0
total	70	72	97.2

package Redis::AOF::Tail::File;

use 5.008008;
use strict;
use warnings;
use File::Tail::Lite;

our $VERSION = '0.04';

sub new {
    my $pkg  = shift;
    my $self = {@_};
    bless $self, $pkg;

    return 0 unless -e $self->{aof_filename};

    $self->{ARRAY_REDIS_AOF} = ();

    if ( $self->{seekpos} ) {
        $self->{FILE_TAIL_FH} = new File::Tail::Lite(
            filename => $self->{aof_filename},
            seekpos  => $self->{seekpos}
        );
    }
    else {
        $self->{FILE_TAIL_FH} = $self->{FILE_TAIL_FH} = new File::Tail::Lite(
            filename => $self->{aof_filename},
            seekpos  => 'start'
        );
    }
    return $self;
}

sub read_command {
    my $self = shift;
    return 0 unless $self->{FILE_TAIL_FH};

    while ( my ( $pos, $line ) = $self->{FILE_TAIL_FH}->readline() ) {
        $line =~ s/\s//g;
        push @{ $self->{ARRAY_REDIS_AOF} }, $line;
        while ( defined ${ $self->{ARRAY_REDIS_AOF} }[0]
            and ${ $self->{ARRAY_REDIS_AOF} }[0] !~ /^\*\d/ )
        {
            shift @{ $self->{ARRAY_REDIS_AOF} };
        }
        my ($cmd_num) = ${ $self->{ARRAY_REDIS_AOF} }[0] =~ /^\*(\d{1,2})/
          if ${ $self->{ARRAY_REDIS_AOF} }[0];

        next
          if ( !$cmd_num
            or scalar @{ $self->{ARRAY_REDIS_AOF} } < $cmd_num * 2 + 1 )
          ;    # Wait for the complete command

        shift @{ $self->{ARRAY_REDIS_AOF} };
        my $cmd = "";
        for ( 1 .. $cmd_num ) {
            shift @{ $self->{ARRAY_REDIS_AOF} };
            $cmd .= shift @{ $self->{ARRAY_REDIS_AOF} };
            $cmd .= ' ';
        }
        $cmd = substr( $cmd, 0, -1 );
        return ( $pos, $cmd );
    }
}

1;
__END__