File Coverage

blib/lib/Cisco/IronPort.pm

Criterion	Covered	Total	%
statement	15	82	18.2
branch	0	20	0.0
condition	0	2	0.0
subroutine	5	12	41.6
pod	1	1	100.0
total	21	117	17.9

package Cisco::IronPort;

use strict;
use warnings;

use LWP;
use Carp qw(croak);

our $VERSION 	= '0.10';
our @RANGES	= qw (current_hour current_day current_week);
our %M_MAP	= (
		internal_user_details			=> {
							report_def_id	=> 'mga_internal_users',
							report_query_id	=> 'mga_internal_users_user_monitoring',
							sortby		=> 'internal_user'
							},
		top_users_by_clean_outgoing_messages 	=> {
							report_query_id	=> 'mga_internal_users_top_outgoing_messages',
							report_def_id	=> 'mga_internal_users',
							sortby		=> 'internal_user'
							},
		incoming_mail_summary			=> {
							report_query_id	=> 'mga_overview_incoming_mail_summary',
							report_def_id	=> 'mga_overview',
							},
		incoming_mail_details			=> {
							report_query_id	=> 'mga_incoming_mail_domain_search',
							report_def_id	=> 'mga_incoming_mail',
							sortby		=> 'sender_domain'
							},
		average_time_in_workqueue		=> {
							report_query_id	=> 'mga_system_capacity_average_time_workqueue',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		average_messages_in_workqueue		=> {
							report_query_id	=> 'mga_system_capacity_average_messages_workqueue',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		maximum_messages_in_workqueue		=> {
							report_query_id	=> 'mga_system_capacity_max_messages_workqueue',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		total_incoming_connections		=> {
							report_query_id	=> 'mga_system_capacity_total_incoming_connections',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		total_incoming_messages			=> {
							report_query_id	=> 'mga_system_capacity_total_incoming_messages',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		average_incoming_message_size		=> {
							report_query_id	=> 'mga_system_capacity_average_incoming_message_size',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		total_incoming_message_size		=> {
							report_query_id	=> 'mga_system_capacity_total_incoming_message_size',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		total_outgoing_connections		=> {
							report_query_id	=> 'mga_system_capacity_total_outgoing_connections',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		total_outgoing_messages			=> {
							report_query_id	=> 'mga_system_capacity_total_outgoing_messages',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		total_outgoing_message_size		=> {
							report_query_id	=> 'mga_system_capacity_total_outgoing_message_size',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		average_outgoing_message_size		=> {
							report_query_id	=> 'mga_system_capacity_average_outgoing_message_size',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		overall_cpu_usage			=> {
							report_query_id	=> 'mga_system_capacity_overall_cpu_usage',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		cpu_by_function				=> {
							report_query_id	=> 'mga_system_capacity_cpu_by_function',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		memory_page_swapping			=> {
							report_query_id	=> 'mga_system_capacity_swap_page_out',
							report_def_id	=> 'mga_system_capacity',
							sortby		=> 'begin_timestamp'
							},
		top_incoming_virus_types_detected	=> {
							report_def_id	=> 'mga_virus_types',
							report_query_id	=> 'mga_virus_types_top_incoming_virus_types',
							sortby		=> 'begin_timestamp'
							},
		top_outgoing_content_filter_matches	=> {
							report_def_id	=> 'mga_content_filters',
							report_query_id	=> 'mga_content_filters_top_outgoing_cf_matches',
							sortby		=> 'begin_timestamp'
							},
		top_incoming_content_filter_matches	=> {
							report_def_id	=> 'mga_content_filters',
							report_query_id	=> 'mga_content_filters_top_incoming_cf_matches',
							sortby		=> 'begin_timestamp'
							},
		incoming_content_filter_matches		=> {
							report_def_id	=> 'mga_content_filters',
							report_query_id	=> 'mga_content_filters_incoming_cf_matches',
							sortby		=> 'begin_timestamp'
							},
		outgoing_content_filter_matches		=> {
							report_def_id	=> 'mga_content_filters',
							report_query_id	=> 'mga_content_filters_outgoing_cf_matches',
							sortby		=> 'begin_timestamp'
							},
		content_filter_detail			=> {
							filter_type	=> 'outgoing',
							param		=> 'filter_name',
							report		=> 'content_filter_detail',
							report_def_id	=> 'mga_content_filter_detail',
							report_query_id	=> 'mga_content_filter_detail_content_filter_by_user',
							sortby		=> 'begin_timestamp'
							},
		outgoing_delivery_status		=> {
							report_def_id	=> 'mga_outgoing_delivery_status',
							report_query_id	=> 'mga_outgoing_delivery_status_status_table',
							sortby		=> 'destination_domain'
							}

		# profile_type=all
		# format=csv
		# report_query_id=mga_system_capacity_average_messages_workqueue
		# date_range=current_day
		# report_def_id=mga_system_capacity
		# mga_system_capacity_average_messages_workqueue'
		);

sub new {
	my($class, %args) = @_;
	my $self = bless {}, $class;
        defined $args{server}   ? $self->{server}   = $args{server}   : croak 'Constructor failed: server not defined';
        defined $args{username} ? $self->{username} = $args{username} : croak 'Constructor failed: username not defined';
        defined $args{password} ? $self->{password} = $args{password} : croak 'Constructor failed: password not defined';
	$self->{proto}		= ($args{proto} or 'https');
	$self->{ua}		= LWP::UserAgent->new ( ssl_opts => { verify_hostname => 0 } );
	$self->{uri}		= $self->{proto}.'://'.$self->{username}.':'.$self->{password}.'@'.$self->{server}.'/monitor/reports/';
	return $self
}

{
	no strict 'refs';

	foreach my $m (keys %M_MAP) {
		*{ __PACKAGE__ . '::__' . $m } = sub {
			my ($self,$args) = @_;

			return ( exists $M_MAP{$m}{param}

			? 	$self->__request("$M_MAP{$m}{report}?format=csv&date_range=$args->{date_range}"
						. "&report_query_id=$M_MAP{$m}{report_query_id}"
						. "&report_def_id=$M_MAP{$m}{report_def_id}"
						. "&filter_type=outgoing&filter_name=$args->{filter_name}")

			:	$self->__request("report?format=csv&date_range=$args->{date_range}"
						. "&report_query_id=$M_MAP{$m}{report_query_id}"
						. "&report_def_id=$M_MAP{$m}{report_def_id}&profile_type=all")
			)
		};

		foreach my $range (@RANGES) {
			my $p = ($m =~ /summary/ ? '__parse_summary' : '__parse_statistics');
			*{ __PACKAGE__ . '::' . $m . '_' . $range } = sub {
				my ($self,$args) = @_;
				$args->{date_range} = $range;
				my $f = '__'.$m;
				return $p->($self->$f($args), $M_MAP{$m}{sortby})
			};

			*{ __PACKAGE__ . '::' . $m . '_' . $range . '_raw' } = sub {
				my ($self,$args) = @_;
				$args->{date_range} = $range;
				my $f = '__'.$m;
				return $self->$f($args)
			};
		}
	}
}

sub __request {
        my($self,$uri)	= @_;
        my $res		= $self->{ua}->get($self->{uri}.$uri);
        $res->is_success and return $res->content;
        $self->{error}  = 'Unable to retrieve content: ' . $res->status_line;
        return 0
}

sub __parse_statistics {
	my ($d, $s)	= @_;
	my @d = split /\n/, $d;
	my %res;
	my @headers 	= map { s/ /_/g; s/\s*$//g; lc $_ } (split /,/, shift @d);
	my ($index)	= grep { $headers[$_] eq $s } 0..$#headers;

	foreach (@d) {
		my $c = 0;
		my @cols = split /,/;
		$cols[-1] =~ s/\s*$//;

		foreach (@cols) {
			if (not defined $res{$cols[$index]}{$headers[$c]}) {
				$res{$cols[$index]}{$headers[$c]} = $_
			}
			elsif ( $headers[$c] =~ /end_(timestamp|date)/ ) {
				$res{$cols[$index]}{$headers[$c]} = (sort { $b cmp $a } ($_, $res{$cols[$index]}{$headers[$c]}))[0]
			}
			elsif ( $headers[$c] =~ /begin_(timestamp|date)/ ) {
				$res{$cols[$index]}{$headers[$c]} = (sort { $a cmp $b } ($_, $res{$cols[$index]}{$headers[$c]}))[0]
			}
			elsif ( $headers[$c] =~ /(sender_domain|orig_value|internal_user)/ ) {
				$res{$cols[$index]}{$headers[$c]} = $_
			}
			elsif ( $headers[$c] =~ /virus_type/ ) {
				$res{$cols[$index]}{$headers[$c]} .= ",$_"
			}
			else {
				$res{$cols[$index]}{$headers[$c]} += $_
			}

			$c++
		}
	}

	return %res
}

sub __parse_summary {
	my $d = shift;
	my @d = split /\n/, $d;
	my %res;
	my @headers 	= map { s/ /_/g; s/\s*$//g; lc $_ } (split /,/, $d[0]);
	my @percent	= split /,/, $d[1]; $percent[-1] =~ s/\s*$//g;
	my @count	= split /,/, $d[2]; $count[-1] =~ s/\s*$//g;

	my $c = 0;
	foreach my $h (@headers) {
		$percent[$c] =~ s/--/100/;
		$res{$h}{'percent'}= $percent[$c];
		$res{$h}{'count'} = $count[$c];
		$c++
	}

	return %res
}

1;

__END__