X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=t%2Fthread-cycle.t;h=484ea443c9b1fabc30d2c2bbfb164aa026e2c0e3;hb=refs%2Ftags%2Fv1.6.1;hp=7d85909f1f9a534186707f3d84fe7b404fe55d15;hpb=3d41aa23f35501ca92aab8aa42980fa73f7fa74f;p=public-inbox.git diff --git a/t/thread-cycle.t b/t/thread-cycle.t index 7d85909f..484ea443 100644 --- a/t/thread-cycle.t +++ b/t/thread-cycle.t @@ -1,28 +1,37 @@ -# Copyright (C) 2016-2018 all contributors +# Copyright (C) 2016-2020 all contributors # License: AGPL-3.0+ use strict; use warnings; use Test::More; +use PublicInbox::TestCommon; +require_mods 'Email::Simple'; use_ok('PublicInbox::SearchThread'); -use Email::Simple; my $mt = eval { require Mail::Thread; no warnings 'once'; $Mail::Thread::nosubject = 1; $Mail::Thread::noprune = 1; }; -my @check; -my @msgs = map { - my $msg = $_; - $msg->{references} =~ s/\s+/ /sg if $msg->{references}; - my $simple = Email::Simple->create(header => [ - 'Message-Id' => "<$msg->{mid}>", - 'References' => $msg->{references}, - ]); - push @check, $simple; - bless $msg, 'PublicInbox::SearchMsg' -} ( +sub make_objs { + my @simples; + my $n = 0; + my @msgs = map { + my $msg = $_; + $msg->{ds} ||= ++$n; + $msg->{references} =~ s/\s+/ /sg if $msg->{references}; + $msg->{blob} = '0'x40; # any dummy value will do, here + my $simple = Email::Simple->create(header => [ + 'Message-ID' => "<$msg->{mid}>", + 'References' => $msg->{references}, + ]); + push @simples, $simple; + bless $msg, 'PublicInbox::Smsg' + } @_; + (\@simples, \@msgs); +} + +my ($simples, $smsgs) = make_objs( # data from t/testbox-6 in Mail::Thread 2.55: { mid => '20021124145312.GA1759@nlin.net' }, { mid => 'slrnau448m.7l4.markj+0111@cloaked.freeserve.co.uk', @@ -50,23 +59,42 @@ my @msgs = map { } ); -my $st = thread_to_s(\@msgs); +my $st = thread_to_s($smsgs); SKIP: { skip 'Mail::Thread missing', 1 unless $mt; - $mt = Mail::Thread->new(@check); - $mt->thread; - $mt->order(sub { sort { $a->messageid cmp $b->messageid } @_ }); - my $check = ''; + check_mt($st, $simples, 'Mail::Thread output matches'); +} - my @q = map { (0, $_) } $mt->rootset; - while (@q) { - my $level = shift @q; - my $node = shift @q or next; - $check .= (" "x$level) . $node->messageid . "\n"; - unshift @q, $level + 1, $node->child, $level, $node->next; +my @backwards = ( + { mid => 1, references => '<2> <3> <4>' }, + { mid => 4, references => '<2> <3>' }, + { mid => 5, references => '<6> <7> <8> <3> <2>' }, + { mid => 9, references => '<6> <3>' }, + { mid => 10, references => '<8> <7> <6>' }, + { mid => 2, references => '<6> <7> <8> <3>' }, + { mid => 3, references => '<6> <7> <8>' }, + { mid => 6, references => '<8> <7>' }, + { mid => 7, references => '<8>' }, + { mid => 8, references => '' } +); + +($simples, $smsgs) = make_objs(@backwards); +my $backward = thread_to_s($smsgs); +SKIP: { + skip 'Mail::Thread missing', 1 unless $mt; + check_mt($backward, $simples, 'matches Mail::Thread backwards'); +} +($simples, $smsgs) = make_objs(reverse @backwards); +my $forward = thread_to_s($smsgs); +unless ('Mail::Thread sorts by Date') { + SKIP: { + skip 'Mail::Thread missing', 1 unless $mt; + check_mt($forward, $simples, 'matches Mail::Thread forwards'); } - is($check, $st, 'Mail::Thread output matches'); +} +if ('sorting by Date') { + is("\n".$backward, "\n".$forward, 'forward and backward matches'); } done_testing(); @@ -74,15 +102,31 @@ done_testing(); sub thread_to_s { my ($msgs) = @_; my $rootset = PublicInbox::SearchThread::thread($msgs, sub { - [ sort { $a->{id} cmp $b->{id} } @{$_[0]} ] }); + [ sort { $a->{mid} cmp $b->{mid} } @{$_[0]} ] }); my $st = ''; my @q = map { (0, $_) } @$rootset; while (@q) { my $level = shift @q; my $node = shift @q or next; - $st .= (" "x$level). "$node->{id}\n"; + $st .= (" "x$level). "$node->{mid}\n"; my $cl = $level + 1; unshift @q, map { ($cl, $_) } @{$node->{children}}; } $st; } + +sub check_mt { + my ($st, $simples, $msg) = @_; + my $mt = Mail::Thread->new(@$simples); + $mt->thread; + $mt->order(sub { sort { $a->messageid cmp $b->messageid } @_ }); + my $check = ''; + my @q = map { (0, $_) } $mt->rootset; + while (@q) { + my $level = shift @q; + my $node = shift @q or next; + $check .= (" "x$level) . $node->messageid . "\n"; + unshift @q, $level + 1, $node->child, $level, $node->next; + } + is("\n".$check, "\n".$st, $msg); +}