1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
| | #!perl -w
# Copyright (C) all contributors <meta@public-inbox.org>
# License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
use PublicInbox::TestCommon;
require_ok 'PublicInbox::MHreader';
use PublicInbox::IO qw(write_file);
use PublicInbox::Lock;
use PublicInbox::Eml;
use File::Path qw(remove_tree);
use autodie;
opendir my $cwdfh, '.';
my $normal = create_dir 'normal', sub {
write_file '>', 3, "Subject: replied a\n\n";
write_file '>', 4, "Subject: replied b\n\n";
write_file '>', 1, "Subject: unseen\n\n";
write_file '>', 2, "Subject: unseen flagged\n\n";
write_file '>', '.mh_sequences', <<EOM;
unseen: 1 2
flagged: 2
replied: 3 4
EOM
};
my $for_sort = create_dir 'size', sub {
for (1..3) {
my $name = 10 - $_;
write_file '>', $name, "Subject: ".($_ x $_)."\n\n";
}
};
my $stale = create_dir 'stale', sub {
write_file '>', 4, "Subject: msg 4\n\n";
write_file '>', '.mh_sequences', <<EOM;
unseen: 1 2
EOM
};
{
my $mhr = PublicInbox::MHreader->new("$normal/", $cwdfh);
$mhr->{sort} = [ '' ];
my @res;
$mhr->mh_each_eml(sub { push @res, \@_; }, [ 'bogus' ]);
is scalar(@res), 4, 'got 4 messages' or diag explain(\@res);
is_deeply [map { $_->[1] } @res], [1, 2, 3, 4],
'got messages in expected order';
is scalar(grep { $_->[4]->[0] eq 'bogus' } @res), scalar(@res),
'cb arg passed to all messages' or diag explain(\@res);
$mhr = PublicInbox::MHreader->new("$stale/", $cwdfh);
@res = ();
$mhr->mh_each_eml(sub { push @res, \@_; });
is scalar(@res), 1, 'ignored stale messages';
}
test_lei(sub {
lei_ok qw(convert -f mboxrd), $normal;
my @msgs = grep /\S/s, split /^From .[^\n]+\n/sm, $lei_out;
my @eml = map { PublicInbox::Eml->new($_) } @msgs;
my $h = 'Subject';
@eml = sort { $a->header_raw($h) cmp $b->header_raw($h) } @eml;
my @has = map { scalar $_->header_raw($h) } @eml;
is_xdeeply \@has,
[ 'replied a', 'replied b', 'unseen', 'unseen flagged' ],
'subjects sorted';
$h = 'X-Status';
@has = map { scalar $_->header_raw($h) } @eml;
is_xdeeply \@has, [ 'A', 'A', undef, 'F' ], 'answered and flagged kw';
$h = 'Status';
@has = map { scalar $_->header_raw($h) } @eml;
is_xdeeply \@has, ['RO', 'RO', 'O', 'O'], 'read and old';
lei_ok qw(import +L:normal), $normal;
lei_ok qw(q L:normal -f mboxrd);
@msgs = grep /\S/s, split /^From .[^\n]+\n/sm, $lei_out;
my @eml2 = map { PublicInbox::Eml->new($_) } @msgs;
$h = 'Subject';
@eml2 = sort { $a->header_raw($h) cmp $b->header_raw($h) } @eml2;
is_xdeeply \@eml2, \@eml, 'import preserved kw';
lei_ok 'ls-mail-sync';
is $lei_out, 'mh:'.File::Spec->rel2abs($normal)."\n",
'mail sync stored';
lei_ok qw(convert -s size -f mboxrd), "mh:$for_sort";
chomp(my @s = grep /^Subject:/, split(/^/sm, $lei_out));
s/^Subject: // for @s;
is_xdeeply \@s, [ 1, 22, 333 ], 'sorted by size';
for my $s ([], [ 'name' ], [ 'sequence' ]) {
lei_ok qw(convert -f mboxrd), "mh:$for_sort", '-s', @$s;
chomp(@s = grep /^Subject:/, split(/^/sm, $lei_out));
s/^Subject: // for @s;
my $desc = "@$s" || '(default)';
is_xdeeply \@s, [ 333, 22, 1 ], "sorted by: $desc";
}
lei_ok qw(import +L:sorttest), "MH:$for_sort";
lei_ok 'ls-mail-sync', $for_sort;
is $lei_out, 'mh:'.File::Spec->rel2abs($for_sort)."\n",
"mail sync stored with `MH' normalized to `mh'";
lei_ok qw(index), 'mh:'.$stale;
lei qw(q -f mboxrd), 's:msg 4';
like $lei_out, qr/^Subject: msg 4\nStatus: RO\n\n\n/ms,
"message retrieved after `lei index'";
lei_ok qw(convert -s none -f text), "mh:$for_sort", \'--sort=none';
# ensure sort works for _input_ when output disallows sort
my $v2out = "$ENV{HOME}/v2-out";
for my $sort (['--sort=sequence'], []) { # sequence is the default
lei_ok qw(convert), @$sort, "mh:$for_sort", '-o', "v2:$v2out";
my $g = PublicInbox::Git->new("$v2out/git/0.git");
chomp(my @l = $g->qx(qw(log --pretty=oneline --format=%s)));
is_xdeeply \@l, [1, 22, 333], 'sequence order preserved for v2';
File::Path::remove_tree $v2out;
}
});
done_testing;
|