X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=t%2Fv2mda.t;h=8f2f335d96b8d834cfe5ffd38df13dfc6599595a;hb=2f8d15b1170b137a0512a4f3163b236a5dcbf0b8;hp=0cd852b1908b97240e00bddf1a8ff84384997769;hpb=f3264939f276965e82f0264b209b0c2e62bab39e;p=public-inbox.git diff --git a/t/v2mda.t b/t/v2mda.t index 0cd852b1..8f2f335d 100644 --- a/t/v2mda.t +++ b/t/v2mda.t @@ -1,39 +1,34 @@ -# Copyright (C) 2018-2019 all contributors +#!perl -w +# Copyright (C) all contributors # License: AGPL-3.0+ +use v5.10.1; use strict; -use warnings; use Test::More; -use PublicInbox::MIME; -use File::Temp qw/tempdir/; use Fcntl qw(SEEK_SET); use Cwd; -require './t/common.perl'; +use PublicInbox::TestCommon; +use PublicInbox::Eml; require_git(2.6); my $V = 2; -foreach my $mod (qw(DBD::SQLite Search::Xapian)) { - eval "require $mod"; - plan skip_all => "$mod missing for v2mda.t" if $@; -} +require_mods(qw(DBD::SQLite Search::Xapian)); use_ok 'PublicInbox::V2Writable'; -my $tmpdir = tempdir('pi-v2mda-XXXXXX', TMPDIR => 1, CLEANUP => 1); +my ($tmpdir, $for_destroy) = tmpdir(); my $ibx = { inboxdir => "$tmpdir/inbox", name => 'test-v2writable', address => [ 'test@example.com' ], }; -my $mime = PublicInbox::MIME->create( - header => [ - From => 'a@example.com', - To => 'test@example.com', - Subject => 'this is a subject', - Date => 'Fri, 02 Oct 1993 00:00:00 +0000', - 'Message-ID' => '', - 'List-ID' => '', - ], - body => "hello world\n", -); +my $mime = PublicInbox::Eml->new(<<'EOF'); +From: a@example.com +To: test@example.com +Subject: this is a subject +Date: Fri, 02 Oct 1993 00:00:00 +0000 +Message-ID: +List-ID: +hello world +EOF my $main_bin = getcwd()."/t/main-bin"; my $fail_bin = getcwd()."/t/fail-bin"; local $ENV{PI_DIR} = "$tmpdir/foo"; @@ -52,14 +47,10 @@ local $ENV{ORIGINAL_RECIPIENT} = 'test@example.com'; ok(run_script(['-mda'], undef, $rdr), 'mda delivered a message'); $ibx = PublicInbox::Inbox->new($ibx); - -if ($V == 1) { - ok(run_script([ '-index', "$tmpdir/inbox" ]), 'v1 indexed'); -} -my $msgs = $ibx->search->query(''); +my $msgs = $ibx->over->recent; is(scalar(@$msgs), 1, 'only got one message'); -my $saved = $ibx->smsg_mime($msgs->[0]); -is($saved->{mime}->as_string, $mime->as_string, 'injected message'); +my $eml = $ibx->smsg_eml($msgs->[0]); +is($eml->as_string, $mime->as_string, 'injected message'); { my @new = glob("$faildir/new/*"); @@ -70,19 +61,19 @@ is($saved->{mime}->as_string, $mime->as_string, 'injected message'); ok(run_script(['-mda'], undef, $rdr), 'mda did not die on "spam"'); @new = glob("$faildir/new/*"); is(scalar(@new), 1, 'got a message in faildir'); - $msgs = $ibx->search->reopen->query(''); + $msgs = $ibx->over->recent; is(scalar(@$msgs), 1, 'no new message'); my $config = "$ENV{PI_DIR}/config"; ok(-f $config, 'config exists'); my $k = 'publicinboxmda.spamcheck'; - is(system('git', 'config', "--file=$config", $k, 'none'), 0, + is(xsys('git', 'config', "--file=$config", $k, 'none'), 0, 'disabled spamcheck for mda'); ok(run_script(['-mda'], undef, $rdr), 'mda did not die'); my @again = glob("$faildir/new/*"); is_deeply(\@again, \@new, 'no new message in faildir'); - $msgs = $ibx->search->reopen->query(''); + $msgs = $ibx->over->recent; is(scalar(@$msgs), 2, 'new message added OK'); } @@ -91,11 +82,18 @@ is($saved->{mime}->as_string, $mime->as_string, 'injected message'); open my $fh, '<', $patch or die "failed to open $patch: $!\n"; $rdr->{0} = \(do { local $/; <$fh> }); ok(run_script(['-mda'], undef, $rdr), 'mda delivered a patch'); - my $post = $ibx->search->reopen->query('dfpost:6e006fd7'); - is(scalar(@$post), 1, 'got one result for dfpost'); - my $pre = $ibx->search->query('dfpre:090d998'); - is(scalar(@$pre), 1, 'got one result for dfpre'); + my $post = $ibx->search->reopen->mset('dfpost:6e006fd7'); + is($post->size, 1, 'got one result for dfpost'); + my $pre = $ibx->search->mset('dfpre:090d998'); + is($pre->size, 1, 'got one result for dfpre'); + $pre = $ibx->search->mset_to_smsg($ibx, $pre); + $post = $ibx->search->mset_to_smsg($ibx, $post); is($post->[0]->{blob}, $pre->[0]->{blob}, 'same message in both cases'); + + # git patch-id --stable search->mset("patchid:$patchid"); + is($mset->size, 1, 'patchid search works'); } done_testing();