t/cursor.t - metacpan.org

#!/usr/bin/perl

use strict;
use warnings;

package Log::Unrotate::Cursor::test;

use strict;
use warnings;
use lib qw(lib);

use File::stat;
use Test::More tests => 122;
use Test::NoWarnings;
use t::Utils;

my $time = time;
my $posfile = 'tfiles/cursor.pos';

BEGIN {
    *CORE::GLOBAL::time = sub() { return $time };
    use_ok('Log::Unrotate::Cursor::File');
}

sub cursor (;$) {
    my ($opts) = @_;
    $opts ||= {};
    my $file = delete $opts->{file} || $posfile;
    my $no_clean = delete $opts->{no_clean};

    unlink $file unless $no_clean;

    return Log::Unrotate::Cursor::File->new(
        $file, {
            lock => 'none',
            %$opts,
        },
    );
}

sub default_pos (;$) {
    my ($opts) = @_;
    $opts ||= {};

    return {
        Position => 100,
        LogFile => 'tfiles/log.log',
        Inode => 123,
        LastLine => 'some line',
        CommitTime => time - 4,
        %$opts,
    };
}

sub fields {
    return qw/Position LogFile Inode LastLine CommitTime/;
}

# locks are tested in t/new.t

# do not write same position no matter what the commit time is
{
    my $c = cursor({rollback_period => 3});
    my $time = time;

    my $def_pos = default_pos({CommitTime => $time});
    $c->commit($def_pos);
    is (defined($c->read), 1, 'position written');
    is ($c->rollback, 0, 'cannot rollback - was just one position');
    my $st = stat($posfile) || die "Cannot take stat $posfile!";
    my $mtime = $st->mtime;
    sleep(1);

    $def_pos = default_pos({CommitTime => $time});
    $c->commit($def_pos);
    is ($c->rollback, 0, 'cannot rollback - just one position still');
    $st = stat($posfile) || die "Cannot take stat $posfile!";
    my $new_mtime = $st->mtime;
    is ($new_mtime, $mtime, 'file was not changed');

    $def_pos = default_pos({CommitTime => $time + 1});
    $c->commit($def_pos);
    $st = stat($posfile) || die "Cannot take stat $posfile!";
    $new_mtime = $st->mtime;
    is ($new_mtime, $mtime, 'file was not changed');

    $def_pos = default_pos({Position => 101, CommitTime => $time + 1});
    $c->commit($def_pos);
    my $read_pos = $c->read;
    is ($read_pos->{Position}, 101, 'position written');
    is ($c->rollback, 1, 'rollback OK - finally changed');
}

# read empty (2)
{
    unlink 'tfiles/cursor.pos';
    my $c = cursor();
    my $pos = $c->read();
    is($pos, undef, "Read before commits");

    $pos = $c->read();
    is($pos, undef, "Reread cursor before commits");
}

# commit & clean & read (1)
{
    my $c = cursor();
    $c->commit(default_pos());
    $c->clean();

    my $pos = $c->read();
    is($pos, undef, "Read after clean");
}

# commit & read (7)
{
    my $c = cursor();
    my $def_pos = default_pos();
    $c->commit($def_pos);

    my $pos = $c->read();

    ok(defined $pos, "Read commited position");
    for my $field (fields()) {
        is($pos->{$field}, $def_pos->{$field}, "Read commited '$field' value");
    }
    my @extra_fields = ();
    for my $field (keys %$pos) {
        push @extra_fields, $field
            unless (grep { $field eq $_ } fields());
    }
    is(scalar @extra_fields, 0, "No extra fields in position")
        or diag "Extra fields: @extra_fields";
}

# commit & read buggy (7)
{
    my $c = cursor({rollback_period => 5});
    my $def_pos = {
        Position => 100,
        LogFile => "'position:120'",
        Inode => 123,
        CommitTime => 456,
        LastLine => "position:130 logfile:some.log committime:678 inode:901 lastline:other line",
        SomeField => "some value",
    };
    $c->commit($def_pos);

    my $pos = $c->read();

    ok(defined $pos, "Read commited position");
    for my $field (fields()) {
        is($pos->{$field}, $def_pos->{$field}, "Read commited '$field' value");
    }
    my @extra_fields = ();
    for my $field (keys %$pos) {
        push @extra_fields, $field
            unless (grep { $field eq $_ } fields());
    }
    is(scalar @extra_fields, 0, "No extra fields in position")
        or diag "Extra fields: @extra_fields";
}

# commit & read rollbackable (7)
{
    my $c = cursor({rollback_period => 5});
    my $def_pos = default_pos();
    $c->commit($def_pos);

    my $pos = $c->read();

    ok(defined $pos, "Read commited position");
    for my $field (fields()) {
        is($pos->{$field}, $def_pos->{$field}, "Read commited '$field' value");
    }
    my @extra_fields = ();
    for my $field (keys %$pos) {
        push @extra_fields, $field
            unless (grep { $field eq $_ } fields());
    }
    is(scalar @extra_fields, 0, "No extra fields in position")
        or diag "Extra fields: @extra_fields";
}

# 2 commits (6)
{
    my $c = cursor();

    my $def_pos = default_pos();
    $c->commit($def_pos);

    my $other_pos = default_pos({
        Position => 110,
        LastLine => 'some other line',
        CommitTime => time - 2,
    });
    $c->commit($other_pos);

    my $pos = $c->read();
    ok(defined $pos, "Read commited position");
    for my $field (fields()) {
        is($pos->{$field}, $other_pos->{$field}, "Read commited '$field' value");
    }
}

# rollback unrollbackable (4)
{
    my $c = cursor();

    $c->commit(default_pos);
    is($c->read()->{Position}, 100, "Position after first commit");

    $c->commit(default_pos({
        Position => 110,
        CommitTime => time - 3,
    }));
    is($c->read()->{Position}, 110, "Position after second commit");

    my $res = $c->rollback();
    is($res, 0, "Rollback failed");
    is($c->read()->{Position}, 110, "Position after failed rollback");
}

# rollback after clean (6)
{
    my $c = cursor({rollback_period => 5});

    $c->commit(default_pos);
    is($c->read()->{Position}, 100, "Position after first commit");

    $c->commit(default_pos({
        Position => 110,
        CommitTime => time - 3,
    }));
    is($c->read()->{Position}, 110, "Position after second commit");

    $c->clean();
    is($c->read(), undef, 'Position after clean');

    my $res = $c->rollback();
    is($res, 0, "Rollback failed");
    is($c->read(), undef, "Position after clean and failed rollback");
}

# rollback to previous commit (19)
{
    my $c = cursor({rollback_period => 5});

    my $pos1 = default_pos;
    my $pos2 = default_pos({
        Position => 110,
        CommitTime => time - 3,
    });

    $c->commit($pos1);
    is($c->read()->{Position}, 100, "Position after first commit");

    $c->commit($pos2);
    is($c->read()->{Position}, 110, "Position after second commit");

    my $pos = $c->read();
    for my $field (fields()) {
        is($pos->{$field}, $pos2->{$field}, "Read commited '$field' value");
    }

    my $res = $c->rollback();
    is($res, 1, "Rollback done");
    $pos = $c->read();
    for my $field (fields()) {
        is($pos->{$field}, $pos1->{$field}, "Read commited '$field' value");
    }

    $res = $c->rollback();
    is($res, 0, "Rollback failed");
    $pos = $c->read();
    for my $field (fields()) {
        is($pos->{$field}, $pos1->{$field}, "Read commited '$field' value");
    }
}

# rollback and new commit (11)
{
    my $c = cursor({rollback_period => 5});

    $c->commit(default_pos);
    is($c->read()->{Position}, 100, "Position after first commit");

    $c->commit(default_pos({
        Position => 110,
        CommitTime => time - 3,
    }));
    is($c->read()->{Position}, 110, "Position after second commit");

    my $res = $c->rollback();
    is($res, 1, "Rollback done");
    is($c->read()->{Position}, 100, "Position after rollback");

    $res = $c->rollback();
    is($res, 0, "Rollback failed");
    is($c->read()->{Position}, 100, "Position after failed rollback");

    $c->commit(default_pos({
        Position => 120,
        CommitTime => time - 2,
    }));
    is($c->read()->{Position}, 120, "Position after recommit");

    $res = $c->rollback();
    is($res, 1, "Rollback done");
    is($c->read()->{Position}, 100, "Position after new rollback");

    $res = $c->rollback();
    is($res, 0, "Rollback failed");
    is($c->read()->{Position}, 100, "Position after failed rollback");
}

# rollback points updatesi - all in 5 seconds (8)
{
    my $c = cursor({rollback_period => 5});

    $c->commit(default_pos);
    is($c->read()->{Position}, 100, "Position after 1st commit");

    $c->commit(default_pos({
        Position => 120,
        CommitTime => time - 3,
    }));
    is($c->read()->{Position}, 120, "Position after 2nd commit");

    $c->commit(default_pos({
        Position => 130,
        CommitTime => time - 2,
    }));
    is($c->read()->{Position}, 130, "Position after 3rd commit");

    $c->commit(default_pos({
        Position => 140,
        CommitTime => time - 1,
    }));
    is($c->read()->{Position}, 140, "Position after 4th commit");

    my $res = $c->rollback();
    is($res, 1, "Rollback done");
    is($c->read()->{Position}, 100, "Position after rollback");

    $res = $c->rollback();
    is($res, 0, "Rollback failed");
    is($c->read()->{Position}, 100, "Position after failed rollback");

}

# rollback points updates - 2 rollback points - short and long (10)
{
    my $c = cursor({rollback_period => 5});

    $c->commit(default_pos({
        Position => 20,
        CommitTime => time - 8,
    }));
    is($c->read()->{Position}, 20, "Position after 1st commit");

    $c->commit(default_pos({
        Position => 30,
        CommitTime => time - 7,
    }));
    is($c->read()->{Position}, 30, "Position after 2nd commit");

    $c->commit(default_pos({
        Position => 80,
        CommitTime => time - 2,
    }));
    is($c->read()->{Position}, 80, "Position after 3rd commit");

    $c->commit(default_pos({
        Position => 90,
        CommitTime => time - 1,
    }));
    is($c->read()->{Position}, 90, "Position after 4th commit");

    my $res = $c->rollback();
    is($res, 1, "Rollback done");
    is($c->read()->{Position}, 80, "Position after rollback");

    $res = $c->rollback();
    is($res, 1, "Rollback done");
    is($c->read()->{Position}, 30, "Position after rollback");

    $res = $c->rollback();
    is($res, 0, "Rollback failed");
    is($c->read()->{Position}, 30, "Position after failed rollback");

}

# rollback points updates - with sleeps (26)
{
    my $c1 = cursor({rollback_period => 1, file => 'tfiles/c1.pos',});
    my $c3 = cursor({rollback_period => 3, file => 'tfiles/c3.pos',});
    my $c5 = cursor({rollback_period => 5, file => 'tfiles/c5.pos',});
    my $c9 = cursor({rollback_period => 9, file => 'tfiles/c9.pos',});
    my $c11 = cursor({rollback_period => 11, file => 'tfiles/c11.pos',});

    for my $i (0 .. 5) {
        for my $c ($c1, $c3, $c5, $c9, $c11) {
            $c->commit(default_pos({
                Position => $i * 20,
                CommitTime => time,
            }));
        }
        $time += 2 unless $i == 5;
    }

    my $res = $c1->rollback();
    is($res, 1, "Rollback done");
    is($c1->read()->{Position}, 80, "c1 Position after rollback");

    $res = $c1->rollback();
    is($res, 0, "Rollback failed");
    is($c1->read()->{Position}, 80, "c1 Position after failed rollback");

    $res = $c3->rollback();
    is($res, 1, "Rollback done");
    is($c3->read()->{Position}, 80, "c3 Position after rollback");

    $res = $c3->rollback();
    is($res, 1, "Rollback done");
    is($c3->read()->{Position}, 60, "c3 Position after second rollback");

    $res = $c3->rollback();
    is($res, 0, "Rollback failed");
    is($c3->read()->{Position}, 60, "c3 Position after failed rollback");

    $res = $c5->rollback();
    is($res, 1, "Rollback done");
    is($c5->read()->{Position}, 80, "c5 Position after rollback");

    $res = $c5->rollback();
    is($res, 1, "Rollback done");
    is($c5->read()->{Position}, 40, "c5 Position after second rollback");

    $res = $c5->rollback();
    is($res, 0, "Rollback failed");
    is($c5->read()->{Position}, 40, "c5 Position after failed rollback");

    $res = $c9->rollback();
    is($res, 1, "Rollback done");
    is($c9->read()->{Position}, 80, "c9 Position after rollback");

    $res = $c9->rollback();
    is($res, 1, "Rollback done");
    is($c9->read()->{Position}, 0, "c9 Position after second rollback");

    $res = $c9->rollback();
    is($res, 0, "Rollback failed");
    is($c9->read()->{Position}, 0, "c9 Position after failed rollback");

    $res = $c11->rollback();
    is($res, 1, "Rollback done");
    is($c11->read()->{Position}, 0, "c11 Position after rollback");

    $res = $c11->rollback();
    is($res, 0, "Rollback failed");
    is($c11->read()->{Position}, 0, "c11 Position after failed rollback");
}
	Global
`s`	Focus search bar
`?`	Bring up this help dialog
	GitHub
`g` `p`	Go to pull requests
`g` `i`	go to github issues (only if github is preferred repository)
	POD
`g` `a`	Go to author
`g` `c`	Go to changes
`g` `i`	Go to issues
`g` `d`	Go to dist
`g` `r`	Go to repository/SCM
`g` `s`	Go to source
`g` `b`	Go to file browse
	Search terms
module: (e.g. module:Plugin)
distribution: (e.g. distribution:Dancer auth)
author: (e.g. author:SONGMU Redis)
version: (e.g. version:1.00)