Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion lib/Catalyst/Plugin/Session/Store/Redis.pm
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ sub _verify_redis_connection {
my $cfg = $c->_session_plugin_config;

try {
$c->_session_redis_storage->ping;
$c->_session_redis_storage->ping or die "failed to ping";
} catch {
$c->_session_redis_storage(
Redis->new(
Expand Down
48 changes: 48 additions & 0 deletions t/ping.t
Original file line number Diff line number Diff line change
@@ -0,0 +1,48 @@
#/usr/bin/env perl
#===============================================================================
#Last Modified: 2014/09/03
#===============================================================================
use strict;
use warnings;
use Test::More;
use Redis;

unless ($ENV{SESSION_STORE_REDIS_PING} ) {
plan skip_all => 'Must set SESSION_STORE_REDIS_PING environment variable';
}
eval { require Test::RedisServer }
or plan skip_all => "Test requires 'Test::RedisServer'";
eval { require Net::EmptyPort }
or plan skip_all => "Test requires 'Net::EmptyPort'";

my $redis_server = eval { Test::RedisServer->new(
conf => {
port => Net::EmptyPort::empty_port(),
timeout => 1,
}
) }
or plan skip_all => 'redis-server is required to this test';

my %connect_info = $redis_server->connect_info;
$connect_info{server} =~ s/0\.0\.0\.0/localhost/;

{
package RedisTimeoutTest;
use Catalyst qw/Session Session::Store::Redis Session::State::Cookie/;
RedisTimeoutTest->config(
'Plugin::Session' => {
expires => 20,
redis_server => $connect_info{server},
});
RedisTimeoutTest->setup;
}

my $c = RedisTimeoutTest->new;
$c->session;
my $sid = $c->sessionid;
$c->store_session_data($sid, { key => 456});
sleep 2;
my $res = eval { $c->get_session_data($sid)->{key} } ;
$res = $@ if $@;
is (456, $res, 'reconnect');
done_testing;