File Coverage

blib/lib/XAS/Logmon/Input/Tail.pm

Criterion	Covered	Total	%
statement	9	49	18.3
branch	2	8	25.0
condition	0	3	0.0
subroutine	3	7	42.8
pod	1	1	100.0
total	15	68	22.0

package XAS::Logmon::Input::Tail;

our $VERSION = '0.01';

my $mixin;

BEGIN {
    $mixin = 'XAS::Logmon::Input::Tail::Default';
    $mixin = 'XAS::Logmon::Input::Tail::Linux' if ($^O eq 'linux');
    $mixin = 'XAS::Logmon::Input::Tail::Win32' if ($^O eq 'MSWin32');
}

use Fcntl ':seek';

use XAS::Class
  debug      => 0,
  version    => $VERSION,
  base       => 'XAS::Base',
  mixin      => $mixin,
  utils      => 'dotid trim',
  accessors  => 'notifier statefile',
  filesystem => 'File',
  vars => {
    PARAMS => {
      -filename => { isa => 'Badger::Filesystem::File' },
    }
  }
;

#use Data::Dumper;

# ----------------------------------------------------------------------
# Public Methods
# ----------------------------------------------------------------------

# ----------------------------------------------------------------------
# Private Methods
# ----------------------------------------------------------------------

sub _do_tail {
    my $self = shift;

    my $pos = $self->_file_position();
    $self->log->debug("_do_tail - pos = $pos");

    my $fh = $self->filename->open('r');
    $fh->seek($pos, SEEK_SET);

    while (my $line = $fh->getline()) {

        push(@{$self->{'buffer'}}, trim($line));

    }

    $pos = $fh->tell();
    $self->_write_state($pos);

    $fh->close();

    $self->log->debug("_do_tail - pos = $pos");

}

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

    my $state;
    my @lines;
    my $pos = 0;
    my @stat = $self->filename->stat;

    if ($self->statefile->exists) {

        @lines = $self->statefile->read;
        foreach my $line (@lines) {

            my ($key, $value) = split('\s*=\s*', $line);
            chop $value;
            $state->{$key} = $value;

        }

        if (($stat[0] eq $state->{'device'}) and
            ($stat[1] eq $state->{'inode'})) {

            $pos = $state->{'position'};

        }

    } else {

        $self->_write_state($pos);

    }

    return $pos;

}

sub _write_state {
    my $self = shift;
    my $pos  = shift;

    my @stat = $self->filename->stat;
    my $fh   = $self->statefile->open('w');

    $fh->printf("inode = %s\n", $stat[1]);
    $fh->printf("device = %s\n", $stat[0]);
    $fh->printf("position = %s\n", $pos);

    $fh->close;

}

sub init {
    my $class = shift;

    my $self = $class->SUPER::init(@_);

    $self->{'buffer'} = [];
    $self->{'statefile'} = File($self->filename->volume, $self->filename->directory, '.' . $self->filename->basename . '.logmon');

    $self->init_notifier();

    return $self;

}

1;

__END__