91 lines
2.5 KiB
Perl
91 lines
2.5 KiB
Perl
# Status plugin
|
|
#
|
|
# this plugin adds /portalStatus entrypoint which display session count
|
|
# by category
|
|
|
|
package Lemonldap::NG::Portal::Plugins::Status;
|
|
|
|
use strict;
|
|
use Mouse;
|
|
use JSON qw(from_json);
|
|
use MIME::Base64;
|
|
use IO::Socket::INET;
|
|
|
|
our $VERSION = '2.0.0';
|
|
|
|
extends 'Lemonldap::NG::Portal::Main::Plugin';
|
|
|
|
# INITIALIZATION
|
|
|
|
sub init {
|
|
my ($self) = @_;
|
|
$self->addUnauthRoute( portalStatus => 'status', ['GET'] );
|
|
$self->addAuthRoute( portalStatus => 'status', ['GET'] );
|
|
return 1;
|
|
}
|
|
|
|
sub status {
|
|
my ( $self, $req ) = @_;
|
|
my $res = {};
|
|
if ( my $p = $self->p->HANDLER->tsv->{statusPipe} ) {
|
|
my ( $args, $buf );
|
|
my $out = $self->p->HANDLER->tsv->{statusOut};
|
|
if ( $ENV{LLNGSTATUSHOST} ) {
|
|
foreach ( 64322 .. 64331 ) {
|
|
if ( $out =
|
|
IO::Socket::INET->new( Proto => 'udp', LocalPort => $_ ) )
|
|
{
|
|
$args = " host="
|
|
. ( $ENV{LLNGSTATUSCLIENT} || 'localhost' ) . ":$_";
|
|
last;
|
|
}
|
|
}
|
|
}
|
|
unless ($out) {
|
|
return $self->p->sendError( $req, 'No status connection' );
|
|
}
|
|
|
|
$p->print("STATUS json=1$args\n");
|
|
while ( $_ = $out->getline ) {
|
|
last if (/^END$/);
|
|
$buf .= $_;
|
|
}
|
|
if ($buf) {
|
|
eval { $res = from_json( $buf, { allow_nonref => 1 } ) };
|
|
if ($@) {
|
|
$self->logger->error("JSON error: $@");
|
|
$self->logger->error("JSON: $buf");
|
|
}
|
|
foreach (qw(total average)) {
|
|
if ( $res->{$_} ) {
|
|
foreach my $k ( keys %{ $res->{$_} } ) {
|
|
delete $res->{$_}->{$k} unless ( $k =~ /^PORTAL/ );
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
foreach my $type (qw(global persistent cas saml oidc)) {
|
|
if ( $self->conf->{"${type}Storage"} ) {
|
|
my %modOpts = (
|
|
%{ $self->conf->{"${type}StorageOptions"} },
|
|
backend => $self->conf->{"${type}Storage"}
|
|
);
|
|
eval {
|
|
my $sessions = Lemonldap::NG::Common::Apache::Session->searchOn(
|
|
\%modOpts,
|
|
_session_kind => 'SSO',
|
|
'_session_id'
|
|
);
|
|
if (%$sessions) {
|
|
my @s = keys %$sessions;
|
|
$res->{storage}->{$type} = @s;
|
|
}
|
|
};
|
|
}
|
|
}
|
|
return $self->p->sendJSONresponse( $req, $res );
|
|
}
|
|
|
|
1;
|