File Coverage

lib/Flux/Log.pm

Criterion	Covered	Total	%
statement	13	15	86.6
branch			n/a
condition			n/a
subroutine	5	5	100.0
pod			n/a
total	18	20	90.0

package Flux::Log;
{
  $Flux::Log::VERSION = '1.00';
}

# ABSTRACT: storage implemented as log.


use Moo;
extends 'Flux::File';
with 'Flux::Storage::Role::ClientList';

use Type::Params qw(validate);
use Types::Standard qw(Str Dict HashRef);

use File::Basename qw(basename);

use Flux::Log::In;
use Flux::Log::Types qw(ClientName);

has '+reopen' => (
    default => sub { 1 },
);

sub description {
    my $self = shift;
    return "log: ".$self->file;
}

has 'client_dir' => (
    is => 'lazy',
    isa => Str,
    default => sub {
        my $self = shift;
        my $dir = $self->file.".pos";
        unless (-d $dir) {
            mkdir $dir or die "mkdir failed: $!";
        }
        return $dir;
    },
);

sub in {
    my $self = shift;
    my ($client_or_params) = validate(\@_, ClientName | Dict[pos => Str]);

    if (ref $client_or_params) {
        return Flux::Log::In->new({
            log => $self->file,
            unrotate => $client_or_params,
        });

    }
    else {
        return Flux::Log::In->new({
            log => $self->file,
            unrotate => {
                pos => $self->client_dir."/".$client_or_params
            }
        });
    }
}

sub client_names {
    my $self = shift;
    my @files = glob $self->client_dir.'/*';
    return map { basename $_ } @files;
}


1;

__END__