X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=t%2Fsearch-thr-index.t;h=62745dbce1d5122db18164999addb4902e43812e;hb=refs%2Fheads%2Fmaster;hp=6a5fd91901c140463d5eaef20da3ec19f31ba8a3;hpb=95bdac7f09c69036efed537a4d03d5bdd2ae4eb6;p=public-inbox.git diff --git a/t/search-thr-index.t b/t/search-thr-index.t index 6a5fd919..62745dbc 100644 --- a/t/search-thr-index.t +++ b/t/search-thr-index.t @@ -1,19 +1,21 @@ -# Copyright (C) 2017-2020 all contributors +#!perl -w +# Copyright (C) 2017-2021 all contributors # License: AGPL-3.0+ use strict; -use warnings; -use bytes (); # only for bytes::length +use v5.10.1; use Test::More; use PublicInbox::TestCommon; use PublicInbox::MID qw(mids); -use Email::MIME; +use PublicInbox::Eml; require_mods(qw(DBD::SQLite Search::Xapian)); require PublicInbox::SearchIdx; +require PublicInbox::Smsg; require PublicInbox::Inbox; +use PublicInbox::Import; my ($tmpdir, $for_destroy) = tmpdir(); my $git_dir = "$tmpdir/a.git"; -is(0, system(qw(git init -q --bare), $git_dir), "git init (main)"); +PublicInbox::Import::init_bare($git_dir); my $ibx = PublicInbox::Inbox->new({inboxdir => $git_dir}); my $rw = PublicInbox::SearchIdx->new($ibx, 1); ok($rw, "search indexer created"); @@ -40,21 +42,27 @@ my @mids; foreach (reverse split(/\n\n/, $data)) { $_ .= "\n"; - my $mime = Email::MIME->new(\$_); + my $mime = PublicInbox::Eml->new(\$_); $mime->header_set('From' => 'bw@g'); $mime->header_set('To' => 'git@vger.kernel.org'); - my $bytes = bytes::length($mime->as_string); + my $bytes = length($mime->as_string); my $mid = mids($mime->header_obj)->[0]; - my $doc_id = $rw->add_message($mime, $bytes, ++$num, 'ignored', $mid); + my $smsg = bless { + bytes => $bytes, + num => ++$num, + mid => $mid, + blob => '', + }, 'PublicInbox::Smsg'; + my $doc_id = $rw->add_message($mime, $smsg); push @mids, $mid; ok($doc_id, 'message added: '. $mid); } my $prev; my %tids; -my $dbh = $rw->{over}->connect; +my $dbh = $rw->{oidx}->dbh; foreach my $mid (@mids) { - my $msgs = $rw->{over}->get_thread($mid); + my $msgs = $rw->{oidx}->get_thread($mid); is(3, scalar(@$msgs), "got all messages from $mid"); foreach my $m (@$msgs) { my $tid = $dbh->selectrow_array(<<'', undef, $m->{num}); @@ -70,23 +78,29 @@ $rw->commit_txn_lazy; $xdb = $rw->begin_txn_lazy; { - my $mime = Email::MIME->new(<<''); + my $mime = PublicInbox::Eml->new(<<''); Subject: [RFC 00/14] Message-Id: <1-bw@g> From: bw@g To: git@vger.kernel.org - my $dbh = $rw->{over}->connect; + my $dbh = $rw->{oidx}->dbh; my ($id, $prev); - my $reidx = $rw->{over}->next_by_mid('1-bw@g', \$id, \$prev); + my $reidx = $rw->{oidx}->next_by_mid('1-bw@g', \$id, \$prev); ok(defined $reidx); my $num = $reidx->{num}; my $tid0 = $dbh->selectrow_array(<<'', undef, $num); SELECT tid FROM over WHERE num = ? LIMIT 1 - my $bytes = bytes::length($mime->as_string); + my $bytes = length($mime->as_string); my $mid = mids($mime->header_obj)->[0]; - my $doc_id = $rw->add_message($mime, $bytes, $num, 'ignored', $mid); + my $smsg = bless { + bytes => $bytes, + num => $num, + mid => $mid, + blob => '', + }, 'PublicInbox::Smsg'; + my $doc_id = $rw->add_message($mime, $smsg); ok($doc_id, 'message reindexed'. $mid); is($doc_id, $num, "article number unchanged: $num");