File Coverage

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

Criterion	Covered	Total	%
statement	21	33	63.6
branch	0	8	0.0
condition	0	9	0.0
subroutine	7	8	87.5
pod			n/a
total	28	58	48.2

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);
use Moo::Role 2;
with 'Dancer2::Plugin::Role::Shutdown';

our $VERSION = '0.001';    # 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__