File Coverage

blib/lib/App/OverWatch/EventLog.pm

Criterion	Covered	Total	%
statement	7	9	77.7
branch			n/a
condition			n/a
subroutine	3	3	100.0
pod			n/a
total	10	12	83.3

package App::OverWatch::EventLog;
# ABSTRACT: EventLog base class

use strict;
use warnings;

use App::OverWatch::DB;
use App::OverWatch::Event;

use Module::Load qw( load );

sub new {
    my $class = shift;
    my $rh_options = shift || {};

    my $DB = $rh_options->{db} // die "Require 'db'";

    my $type = $DB->type();

    my $subclass = $class . '::' . $type;
    load($subclass);

    my $self = bless( {}, $subclass );

    $self->{DB} = $DB;

    return $self;
}

my @EventTypes = qw( START PROGRESS END POINT );

sub create_event {
    my $self    = shift;
    my $rh_args = shift;

    my $system    = $rh_args->{system}    // die "Error: require 'system'";
    my $subsystem = $rh_args->{subsystem} // die "Error: require 'subsystem'";
    my $worker    = $rh_args->{worker}    // die "Error: require 'worker'";
    my $type      = $rh_args->{type}      // die "Error: require 'type'";
    my $data      = $rh_args->{data}      // '';

    die "Error: Bad type '$type'"
        if (grep { /^$type$/ } @EventTypes == 0);

    my $sql =<<"SQL";
INSERT INTO
    events ( system, subsystem, worker, eventtype, ctime, data )
VALUES
    ( ?, ?, ?, ?, NOW(), ? )
SQL

    my $ret = $self->{DB}->dbix_run( $sql, $system, $subsystem, $worker,
                                     $type, $data );
    return $ret;
}

sub get_events {
    my $self = shift;
    my $rh_args = shift;

    my $sql =<<"SQL";
SELECT
    *
FROM
    events
SQL

    my $sth = $self->{DB}->dbix_select( $sql );
    return undef if (!defined($sth));

    my @events;
    while ( my $rh_row = $sth->fetchrow_hashref() ) {
        my $Event = App::OverWatch::Event->new($rh_row);
        push(@events, $Event);
    }
    return \@events;
}

1;

__END__