From 049da6c538c952f938af4544a07c688b89c26a17 Mon Sep 17 00:00:00 2001 From: ivan Date: Tue, 5 Oct 2004 16:28:28 +0000 Subject: RADIUS session viewing --- httemplate/elements/header.html | 4 +- httemplate/index.html | 8 +- httemplate/search/sqlradius.cgi | 249 +++++++++++++++++++++++++++++++++++++++ httemplate/search/sqlradius.html | 70 +++++++++++ httemplate/view/svc_acct.cgi | 8 +- 5 files changed, 334 insertions(+), 5 deletions(-) create mode 100644 httemplate/search/sqlradius.cgi create mode 100644 httemplate/search/sqlradius.html (limited to 'httemplate') diff --git a/httemplate/elements/header.html b/httemplate/elements/header.html index 1d7bf09ab..10e4e40f1 100644 --- a/httemplate/elements/header.html +++ b/httemplate/elements/header.html @@ -1,6 +1,7 @@ <% - my($title, $menubar) = @_; + my($title, $menubar) = ( shift, shift ); my $etc = @_ ? shift : ''; #$etc is for things like onLoad= etc. + my $head = @_ ? shift : ''; #$head is for things that go in the section %> @@ -10,6 +11,7 @@ + <%= $head %> > diff --git a/httemplate/index.html b/httemplate/index.html index 4534d3a41..08d8f9058 100644 --- a/httemplate/index.html +++ b/httemplate/index.html @@ -113,6 +113,7 @@ Reports
+ RADIUS sessions

Auditing pre-Freeside services with no customer record

unlinked accounts (by service number) (by username) (by uid) @@ -151,8 +152,11 @@ Sysadmin
- View active NAS ports -
View pending job queue + + View pending job queue
Batch import customers from CSV file
Batch import charges from CSV file
Download database dump diff --git a/httemplate/search/sqlradius.cgi b/httemplate/search/sqlradius.cgi new file mode 100644 index 000000000..3c5046bea --- /dev/null +++ b/httemplate/search/sqlradius.cgi @@ -0,0 +1,249 @@ +<%= include( '/elements/header.html', 'RADIUS Sessions', + include('/elements/menubar.html', + 'Main menu' => $p, # popurl(2), + ), + + ) +%> + +<% + ### + # parse cgi params + ### + + #sort of false laziness w/cust_pay.cgi + my $beginning = ''; + my $ending = ''; + if ( $cgi->param('beginning') + && $cgi->param('beginning') =~ /^([ 0-9\-\/]{0,10})$/ ) { + $beginning = str2time($1); + } + if ( $cgi->param('ending') + && $cgi->param('ending') =~ /^([ 0-9\-\/]{0,10})$/ ) { + $ending = str2time($1) + 86399; + } + if ( $cgi->param('begin') && $cgi->param('begin') =~ /^(\d+)$/ ) { + $beginning = $1; + } + if ( $cgi->param('end') && $cgi->param('end') =~ /^(\d+)$/ ) { + $ending = $1; + } + + my $cgi_svc_acct = ''; + if ( $cgi->param('svcnum') =~ /^(\d+)$/ ) { + $cgi_svc_acct = qsearchs( 'svc_acct', { 'svcnum' => $1 } ); + } elsif ( $cgi->param('username') =~ /^([^@]+)\@([^@]+)$/ ) { + my %search = { 'username' => $1 }; + my $svc_domain = qsearchs('svc_domain', { 'domain' => $2 } ); + if ( $svc_domain ) { + $search{'domsvc'} = $svc_domain->svcnum; + } else { + delete $search{'username'}; + } + $cgi_svc_acct = qsearchs( 'svc_acct', \%search ) + if keys %search; + } elsif ( $cgi->param('username') =~ /^(.+)$/ ) { + $cgi_svc_acct = qsearchs( 'svc_acct', { 'username' => $1 } ); + } + + my $ip = ''; + if ( $cgi->param('ip') =~ /^((\d+\.){3}\d+)$/ ) { + $ip = $1; + } + + ### + # field formatting subroutines + ### + + my %user2svc_acct = (); + my $user_format = sub { + my ( $user, $session, $part_export ) = @_; + + my $svc_acct = ''; + if ( exists $user2svc_acct{$user} ) { + $svc_acct = $user2svc_acct{$user}; + } else { + my %search = (); + if ( $part_export->exporrtype eq 'sqlradius_withdomain' ) { + my $domain; + if ( $user =~ /^([^@]+)\@([^@]+)$/ ) { + $search{'username'} = $1; + $domain = $2; + } else { + $search{'username'} = $user; + $domain = $session->{'realm'}; + } + my $svc_domain = qsearchs('svc_domain', { 'domain' => $domain } ); + if ( $svc_domain ) { + $search{'domsvc'} = $svc_domain->svcnum; + } else { + delete $search{'username'}; + } + } elsif ( $part_export->exporttype eq 'sqlradius' ) { + $search{'username'} = $user; + } else { + die "guru meditation #420"; + } + if ( keys %search ) { + my @svc_acct = + grep { qsearchs( 'export_svc', { + 'exportnum' => $part_export->exportnum, + 'svcpart' => $_->cust_svc->svcpart, + } ) + } qsearch( 'svc_acct', \%search ); + if ( @svc_acct ) { + warn 'multiple svc_acct records for user $user found; '. + 'using first arbitrarily' + if scalar(@svc_acct) > 1; + $user2svc_acct{$user} = $svc_acct = shift @svc_acct; + } + } + } + + if ( $svc_acct ) { + my $svcnum = $svc_acct->svcnum; + qq($user); + } else { + "$user"; + } + + }; + + my $customer_format = sub { + my( $unused, $session ) = @_; + return ' ' unless exists $user2svc_acct{$session->{'username'}}; + my $svc_acct = $user2svc_acct{$session->{'username'}}; + my $cust_pkg = $svc_acct->cust_svc->cust_pkg; + return ' ' unless $cust_pkg; + my $cust_main = $cust_pkg->cust_main; + + qq!'. + $cust_pkg->cust_main->name. ''; + }; + + my $time_format = sub { + my $time = shift; + $time > 0 + ? time2str('%T%P %a %b %o %Y', $time ) + : ' '; + }; + + my $duration_format = sub { + my $seconds = shift; + my $hour = int($seconds/3600); + my $min = int( ($seconds%3600) / 60 ); + my $sec = $seconds%60; + ''. + '
'. + ( $hour ? "$hourh" : ' ' ). + ' '. + ( ( $hour || $min ) ? "$minm" : ' ' ). + ' '. + "$secs". + '
'; + }; + + my $octets_format = sub { + my $octets = shift; + my $megs = $octets / 1048576; + sprintf('%.3f megs', $megs); + #my $gigs = $octets / 1073741824 + #sprintf('%.3f gigabytes', $gigs); + }; + + ### + # the fields + ### + + tie my %fields, 'Tie::IxHash', + 'username' => { + name => 'User', + attrib => 'UserName', + fmt => $user_format, + }, + 'realm' => { + name => 'Realm', + attrib => 'Realm', + }, + 'dummy' => { + name => 'Customer', + attrib => '', + fmt => $customer_format, + }, + 'framedipaddress' => { + name => 'IP Address', + attrib => 'Framed-IP-Address', + fmt => sub { my $ip = shift; + length($ip) ? $ip : ' '; + }, + }, + 'acctstarttime' => { + name => 'Start time', + attrib => 'Acct-Start-Time', + fmt => $time_format, + }, + 'acctstoptime' => { + name => 'End time', + attrib => 'Acct-Stop-Time', + fmt => $time_format, + }, + 'acctsessiontime' => { + name => 'Duration', + attrib => 'Acct-Session-Time', + fmt => $duration_format, + }, + 'acctinputoctets' => { + name => 'Upload', # (from user)', + attrib => 'Acct-Input-Octets', + fmt => $octets_format, + }, + 'acctoutputoctets' => { + name => 'Download', # (to user)', + attrib => 'Acct-Output-Octets', + fmt => $octets_format, + }, + ; + $fields{$_}->{fmt} ||= sub { length($_[0]) ? shift : ' '; } + foreach keys %fields; + + ### + # and finally, display the thing + ### + + foreach my $part_export ( map $_->rebless, + qsearch( 'part_export', { 'exporttype' => 'sqlradius' } ), + qsearch( 'part_export', { 'exporttype' => 'sqlradius_withdomain' } ) + ) { + %user2svc_acct = (); +%> + +<%= $part_export->exporttype %> to <%= $part_export->machine %>
+<%= include( '/elements/table.html' ) %> + + <% foreach my $field ( keys %fields ) { %> + + <%= $fields{$field}->{name} %>
+ <%= $fields{$field}->{attrib} %> + + <% } %> + +<% foreach my $session ( + @{ $part_export->usage_sessions( $beginning, $ending, $cgi_svc_acct, $ip ) } +) { %> + + <% foreach my $field ( keys %fields ) { %> + + <%= &{ $fields{$field}->{fmt} }( $session->{$field}, + $session, + $part_export, + ) + %> + + <% } %> + +<% } %> + + +

+ +<% } %> diff --git a/httemplate/search/sqlradius.html b/httemplate/search/sqlradius.html new file mode 100644 index 000000000..48a3d8680 --- /dev/null +++ b/httemplate/search/sqlradius.html @@ -0,0 +1,70 @@ +<%= include( '/elements/header.html', 'Search RADIUS sessions', '', '', ' + + + + +') %> +
+<% #include( '/elements/table.html' ) %> +<%= ntable('#cccccc') %> + + Username: + + + + + (leave blank to show all users) + + + IP address: + + + + + (leave blank to show all IPs) + + + From: + + + + + + + + m/d/y + + + To: + + + + + + + + m/d/y +
(leave one or both dates blank for an open-ended search) + + + +
+
+ + + + diff --git a/httemplate/view/svc_acct.cgi b/httemplate/view/svc_acct.cgi index be58e4e1d..1322a69fd 100755 --- a/httemplate/view/svc_acct.cgi +++ b/httemplate/view/svc_acct.cgi @@ -93,8 +93,9 @@ if ( $part_svc->part_export('sqlradius') } if ( $cust_pkg ) { - print ' since last bill ('. time2str("%C", $last_bill). ') - '. - $plandata{recur_included_hours}. ' total hours in plan
'; + print ' since last bill ('. time2str("%C", $last_bill). ')'. + print ' - '. $plandata{recur_included_hours}. ' total hours in plan
' + if length($plandata{recur_included_hours}); } else { print ' (no billing cycle available for unaudited account)
'; } @@ -102,6 +103,9 @@ if ( $part_svc->part_export('sqlradius') print 'Input: '. sprintf("%.3f", $input). ' megabytes
'; print 'Output: '. sprintf("%.3f", $output). ' megabytes
'; + my $href = qq!all sessions!; + print '
'; } -- cgit v1.2.1