X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=t%2Fxcpdb-reshard.t;h=ede736c1524b5597cf0c151aa1b57b70c4ebd9a0;hb=23eab6127c62d0228a0cfcec78a267fe5e7011c7;hp=0e1fea52d152a9415f502e97b7aeeae20579d28d;hpb=e6b7a7f5f70fb89a54ff158bc6c8b564149947e5;p=public-inbox.git diff --git a/t/xcpdb-reshard.t b/t/xcpdb-reshard.t index 0e1fea52..ede736c1 100644 --- a/t/xcpdb-reshard.t +++ b/t/xcpdb-reshard.t @@ -6,11 +6,11 @@ use Test::More; use PublicInbox::TestCommon; require_mods(qw(DBD::SQLite Search::Xapian)); require_git('2.6'); -use PublicInbox::MIME; +use PublicInbox::Eml; use PublicInbox::InboxWritable; require PublicInbox::Search; -my $mime = PublicInbox::MIME->new(<<'EOF'); +my $mime = PublicInbox::Eml->new(<<'EOF'); From: a@example.com To: test@example.com Subject: this is a subject @@ -30,7 +30,7 @@ my $ibx = PublicInbox::Inbox->new({ my @xcpdb = qw(-xcpdb -q); my $nproc = 8; my $ndoc = 13; -my $im = PublicInbox::InboxWritable->new($ibx, {nproc => $nproc})->importer(1); +my $im = PublicInbox::InboxWritable->new($ibx, {nproc => $nproc})->importer; for my $i (1..$ndoc) { $mime->header_set('Message-ID', ""); ok($im->add($mime), "message $i added"); @@ -45,11 +45,12 @@ my %nums = map {; "$_->{num}" => 1 } @$orig; for my $R (qw(2 4 1 3 3)) { delete $ibx->{search}; # release old handles my $cmd = [@xcpdb, "-R$R", $ibx->{inboxdir}]; - push @$cmd, '--compact' if $R == 1; + push @$cmd, '--compact' if $R == 1 && have_xapian_compact; ok(run_script($cmd), "xcpdb -R$R"); my @new_shards = grep(m!/\d+\z!, glob("$ibx->{inboxdir}/xap*/*")); is(scalar(@new_shards), $R, 'resharded to two shards'); - my $msgs = $ibx->search->query('s:this'); + my $mset = $ibx->search->mset('s:this'); + my $msgs = $ibx->search->mset_to_smsg($ibx, $mset); is(scalar(@$msgs), $ndoc, 'got expected docs after resharding'); my %by_mid = map {; "$_->{mid}" => $_ } @$msgs; ok($by_mid{"m$_\@example.com"}, "$_ exists") for (1..$ndoc);