Skip to content

Commit

Permalink
TestPAUSE: add a means to force rewrite_indexes
Browse files Browse the repository at this point in the history
  • Loading branch information
rjbs committed Apr 28, 2024
1 parent 292eabd commit 3862fbb
Showing 1 changed file with 31 additions and 15 deletions.
46 changes: 31 additions & 15 deletions t/lib/PAUSE/TestPAUSE.pm
Original file line number Diff line number Diff line change
Expand Up @@ -313,9 +313,8 @@ sub with_our_config {
$code->($self);
}

sub test_reindex {
my ($self, $arg) = @_;
$arg //= {};
sub _take_pause_action {
my ($self, $action) = @_;

$self->with_our_config(sub {
my $self = shift;
Expand Down Expand Up @@ -349,18 +348,7 @@ sub test_reindex {

die "stray mail in test mail trap before reindex" if @stray_mail;

if ($arg->{pick}) {
my $dbh = PAUSE::dbh();
$dbh->do("DELETE FROM distmtimes WHERE dist = ?", undef, $_)
for @{ $arg->{pick} };
}

PAUSE::mldistwatch->new({
sleep => 0,
($arg->{pick} ? (pick => $arg->{pick}) : ()),
})->reindex;

$arg->{after}->($self->tmpdir) if $arg->{after};
$action->();

my @deliveries = Email::Sender::Simple->default_transport->deliveries;

Expand All @@ -376,6 +364,34 @@ sub test_reindex {
});
}

sub rewrite_indexes {
my ($self) = @_;
my $action = sub {
PAUSE::mldistwatch->new({ sleep => 0 })->rewrite_indexes;
};

return $self->_take_pause_action($action);
}

sub test_reindex {
my ($self, $arg) = @_;
$arg //= {};
my $action = sub {
if ($arg->{pick}) {
my $dbh = PAUSE::dbh();
$dbh->do("DELETE FROM distmtimes WHERE dist = ?", undef, $_)
for @{ $arg->{pick} };
}

PAUSE::mldistwatch->new({
sleep => 0,
($arg->{pick} ? (pick => $arg->{pick}) : ()),
})->reindex;
};

return $self->_take_pause_action($action);
}

has _file_index => (
is => 'ro',
default => sub { {} },
Expand Down

0 comments on commit 3862fbb

Please sign in to comment.