File Coverage

blib/lib/Dancer2/Plugin/Shutdown/Redis.pm

Criterion	Covered	Total	%
statement	18	30	60.0
branch	0	8	0.0
condition	0	9	0.0
subroutine	6	7	85.7
pod			n/a
total	24	54	44.4

use strictures 2;

package Dancer2::Plugin::Shutdown::Redis;

# ABSTRACT: Graceful shutdown your Dancer2 application with Redis propagation

use Dancer2::Plugin;
use Scalar::Util qw(blessed);
use Redis;
use Carp qw(croak);
use Tie::Redis::Candy 1.001 qw(redis_hash);
with 'Dancer2::Plugin::Role::Shutdown';

our $VERSION = '0.002'; # VERSION

has _redis => (
    is => 'rw',
);

sub _shutdown_redis {
    my $self = shift;
    return $self->_redis unless @_;
    my ($redis, $key) = @_;
    croak "you have specify a key" unless $key;
    if (blessed $redis and ($redis->isa('Redis') or $redis->isa('Test::Mock::Redis'))) {
        $self->_redis($redis);
    } elsif (defined $redis and not ref $redis) {
        $self->_redis(Redis->new(server => $redis));
    } else {
        croak("Not a Redis instance: $redis");
    }
    my $shared = redis_hash($self->_redis, $key, %{ $self->shared });
    $self->_set_shared($shared);
    return $self->_redis;
}


register shutdown_at => \&_shutdown_at;


register shutdown_session_validator => sub {
    shift->validator(@_)
}, { is_global => 1 };


register shutdown_redis => sub {
    shift->_shutdown_redis(@_)
}, { is_global => 1 };

on_plugin_import {
    my $self = shift;
    $self->app->add_hook(
        Dancer2::Core::Hook->new(
            name => 'before',
            code => sub { $self->before_hook(@_) },
        )
    );
};

register_plugin;

1;

__END__