File Coverage

blib/lib/Plack/Middleware/Debug/Redis.pm

Criterion	Covered	Total	%
statement	38	43	88.3
branch	8	18	44.4
condition	5	14	35.7
subroutine	7	8	87.5
pod	1	1	100.0
total	59	84	70.2

package Plack::Middleware::Debug::Redis;

# ABSTRACT: Extend Plack::Middleware::Debug with Redis panels

use strict;
use warnings;
use Carp ();
use Redis 1.955;
use Plack::Util::Accessor qw/instance password db reconnect every debug redis/;

our $VERSION = '0.03'; # VERSION
our $AUTHORITY = 'cpan:CHIM'; # AUTHORITY

sub redis_connect {
    my ($self, $args) = @_;

    my $croak = sub { Carp::croak $_[0] };

    my %options = (
        debug     => $self->debug     || 0,
        reconnect => $self->reconnect || 10,
        every     => $self->every     || 100,
    );

    $options{password} = $self->password if $self->password;

    my $instance = $self->_parse_instance($self->instance);

    if ($instance->{unix}) {
        $croak->("Nonexistent redis socket ($instance->{thru})!") unless -e $instance->{thru} && -S _;
    }

    $options{ $instance->{unix} ? 'sock' : 'server' } = $instance->{thru};

    $self->db($self->db || 0);

    my $_handle;
    eval { $_handle = Redis->new(%options) };
    $croak->("Cannot get redis handle: $@") if $@;

    $self->redis($_handle);
}

sub _parse_instance {
    my ($self, $instance) = @_;

    my $params = { unix => 0, thru => '127.0.0.1:6379' };

    # slightly improved piece of code from Redis.pm by Pedro Melo (cpan:MELO)
    CHANCE: {
        last CHANCE unless $instance;

        if ($instance =~ m,^(unix:)?(/.+)$,i) {
            $params->{thru} = $2;
            $params->{unix} = 1;
            last CHANCE;
        }
        if ($instance =~ m,^((tcp|inet):)?(.+)$,i) {
            my ($server, $port) = ($3, undef);
            ($server, $port)    = split /:/, $server;
            $params->{thru}     = lc($server) . ':' . (($port && ($port > 0 && $port <= 65535)) ? $port : '6379');
        }
    }

    $params;
}

1; # End of Plack::Middleware::Debug::Redis

__END__