dani/lemonldap-ng
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Redis is now supported by session explorer

Browse Source
This commit is contained in:
Xavier Guimard 2010-09-24 09:29:43 +00:00
parent 3831981423
commit 625383fd8d
1 changed files with 31 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
modules/lemonldap-ng-common/lib/Lemonldap/NG/Common/Apache/Session.pm
View File

@ -61,9 +61,7 @@ BEGIN {
}
sub Apache::Session::MySQL::get_key_from_all_sessions {
my $class = shift;
my $args = shift;
my $data = shift;
my ( $class, $args, $data ) = @_;
my $dbh =
DBI->connect( $args->{DataSource}, $args->{UserName},
@ -99,9 +97,7 @@ BEGIN {
\&Apache::Session::MySQL::get_key_from_all_sessions;
sub Apache::Session::File::get_key_from_all_sessions {
my $class = shift;
my $args = shift;
my $data = shift;
my ( $class, $args, $data ) = @_;
$args->{Directory} ||= '/tmp';
unless ( opendir DIR, $args->{Directory} ) {
@ -132,9 +128,7 @@ BEGIN {
sub Apache::Session::PHP::get_key_from_all_sessions {
require Apache::Session::Serialize::PHP;
my $class = shift;
my $args = shift;
my $data = shift;
my ( $class, $args, $data ) = @_;
my $directory = $args->{SavePath} || '/tmp';
unless ( opendir DIR, $args->{SavePath} ) {
@ -166,9 +160,7 @@ BEGIN {
}
sub Apache::Session::DB_File::get_key_from_all_sessions {
my $class = shift;
my $args = shift;
my $data = shift;
my ( $class, $args, $data ) = @_;
if ( !tied %{ $class->{dbm} } ) {
my $rv = tie %{ $class->{dbm} }, 'DB_File', $args->{FileName};
@ -195,9 +187,7 @@ BEGIN {
}
sub Apache::Session::LDAP::get_key_from_all_sessions {
my $class = shift;
my $args = shift;
my $data = shift;
my ( $class, $args, $data ) = @_;
my $ldap = Apache::Session::Store::LDAP::ldap( { args => $args } );
my $msg = $ldap->search(
@ -225,6 +215,32 @@ BEGIN {
}
return \%res;
}
sub Apache::Session::NoSQL::get_key_from_all_sessions {
require Redis;
require MIME::Base64;
my ( $class, $args, $data ) = @_;
die "Only Redis is supported" unless ( $args->{Driver} eq 'Redis' );
my $redis = Redis->new(%$args);
my @keys = $redis->keys('*');
my %res;
foreach my $k ( @keys ) {
my $v = $redis->get($k);
my $v = eval { thaw(MIME::Base64::decode_base64($redis->get($k))) };
next if($@);
if ( ref($data) eq 'CODE' ) {
$res{$k} = &$data( $v, $k );
}
elsif ($data) {
$data = [$data] unless ( ref($data) );
$res{$k}->{$_} = $v->{$_} foreach (@$data);
}
else {
$res{$k} = $v;
}
}
return \%res;
}
}
1;