Frey/Shell/Log.pm

package Frey::Shell::Log;
use Moose;

extends 'Frey';
with 'Frey::Web';

use DateTime::Locale;

has log_command => (
        is => 'rw',
        isa => 'Str',
#       required => 1,
        default => 'tail /var/log/daemon.log',
);

has from_datetime => (
        is => 'rw',
        isa => 'Str',
);

has to_datetime => (
        is => 'rw',
        isa => 'Str',
);

# we don't use DateTime because it's huge overhead for every log line
my $month2nr;
{
        my @months = @{ DateTime::Locale->load('en_US')->month_abbreviations };
        warn "# months ", join(',',@months);

        foreach my $i ( 0 .. $#months ) {
                $month2nr->{ lc($months[$i]) } = $i + 1;
        }
}

sub as_sponge {
        my ($self) = @_;

        my $cmd = $self->log_command;
        warn "# cmd: $cmd";

        my @rows;

        my $from = $self->from_datetime;
        my $to   = $self->to_datetime;

        my $stats = {
                from => $from,
                to   => $to,
        };

        warn "# stats ",$self->dump( $stats );

        my $yyyy = (localtime(time))[5] + 1900;

        open(my $fh, '-|', $cmd) || die "can't open pipe to $cmd $!";
        while(<$fh>) {
                chomp;

                if ( m{^(\w\w\w)\s+(\d+)\s+(\d\d:\d\d:\d\d)\s+(.+)} ) {
                        my $message = $4;
                        my $mm = $month2nr->{lc($1)} || die "month $1 unknown";
                        my $dt = sprintf("%04d-%02d-%02d %s", $yyyy, $mm, $2, $3, $4);
                        if ( $from && $dt lt $from ) {
                                $stats->{before_from}++;
                                next;
                        }
                        if ( $to && $dt gt $to ) {
                                $stats->{after_to}++;
                                next;
                        }
                        push @rows, [ $dt, $message ];
                        $stats->{rows}++;
                } else {
                        warn "# skip $_\n";
                        $stats->{skipped}++;
                }
        }

        warn "# stats ",$self->dump( $stats );

        return {
                NAME => [ 'date', 'message' ],
                rows => [ sort { $a->[0] cmp $b->[0] } @rows ],
                stats => $stats,
                log_command => $cmd,
        }
}

1;
1	dpavlin	894	package Frey::Shell::Log;
2			use Moose;
3
4			extends 'Frey';
5			with 'Frey::Web';
6
7	dpavlin	902	use DateTime::Locale;
8	dpavlin	894
9			has log_command => (
10			is => 'rw',
11			isa => 'Str',
12	dpavlin	907	# required => 1,
13	dpavlin	894	default => 'tail /var/log/daemon.log',
14			);
15
16			has from_datetime => (
17			is => 'rw',
18			isa => 'Str',
19			);
20
21			has to_datetime => (
22			is => 'rw',
23			isa => 'Str',
24			);
25
26	dpavlin	902	# we don't use DateTime because it's huge overhead for every log line
27			my $month2nr;
28			{
29			my @months = @{ DateTime::Locale->load('en_US')->month_abbreviations };
30			warn "# months ", join(',',@months);
31
32			foreach my $i ( 0 .. $#months ) {
33			$month2nr->{ lc($months[$i]) } = $i + 1;
34			}
35			}
36
37	dpavlin	894	sub as_sponge {
38			my ($self) = @_;
39
40			my $cmd = $self->log_command;
41			warn "# cmd: $cmd";
42
43			my @rows;
44
45	dpavlin	902	my $from = $self->from_datetime;
46			my $to = $self->to_datetime;
47	dpavlin	894
48	dpavlin	899	my $stats = {
49	dpavlin	902	from => $from,
50			to => $to,
51	dpavlin	899	};
52
53			warn "# stats ",$self->dump( $stats );
54
55	dpavlin	902	my $yyyy = (localtime(time))[5] + 1900;
56
57	dpavlin	894	open(my $fh, '-\|', $cmd) \|\| die "can't open pipe to $cmd $!";
58			while(<$fh>) {
59			chomp;
60
61	dpavlin	911	if ( m{^(\w\w\w)\s+(\d+)\s+(\d\d:\d\d:\d\d)\s+(.+)} ) {
62	dpavlin	894	my $message = $4;
63	dpavlin	902	my $mm = $month2nr->{lc($1)} \|\| die "month $1 unknown";
64			my $dt = sprintf("%04d-%02d-%02d %s", $yyyy, $mm, $2, $3, $4);
65			if ( $from && $dt lt $from ) {
66	dpavlin	899	$stats->{before_from}++;
67			next;
68	dpavlin	894	}
69	dpavlin	902	if ( $to && $dt gt $to ) {
70	dpavlin	899	$stats->{after_to}++;
71			next;
72	dpavlin	894	}
73	dpavlin	902	push @rows, [ $dt, $message ];
74	dpavlin	899	$stats->{rows}++;
75	dpavlin	894	} else {
76			warn "# skip $_\n";
77	dpavlin	899	$stats->{skipped}++;
78	dpavlin	894	}
79			}
80
81	dpavlin	899	warn "# stats ",$self->dump( $stats );
82
83	dpavlin	894	return {
84			NAME => [ 'date', 'message' ],
85	dpavlin	899	rows => [ sort { $a->[0] cmp $b->[0] } @rows ],
86			stats => $stats,
87	dpavlin	936	log_command => $cmd,
88	dpavlin	894	}
89			}
90
91			1;