about summary refs log tree commit homepage
path: root/lib/PublicInbox/LeiOverview.pm
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2021-01-21 19:46:14 +0000
committerEric Wong <e@80x24.org>2021-01-22 16:18:01 -0400
commitbf77d62faa571cdaf279df421aae85d2b447ceeb (patch)
tree9a342476340dcc9763443ceb8eb8b6010e6a584e /lib/PublicInbox/LeiOverview.pm
parent7e947c849e3ceeb89c3d27952abdb10f9252c038 (diff)
downloadpublic-inbox-bf77d62faa571cdaf279df421aae85d2b447ceeb.tar.gz
This isn't tested for now, so maybe it works.
Diffstat (limited to 'lib/PublicInbox/LeiOverview.pm')
-rw-r--r--lib/PublicInbox/LeiOverview.pm8
1 files changed, 3 insertions, 5 deletions
diff --git a/lib/PublicInbox/LeiOverview.pm b/lib/PublicInbox/LeiOverview.pm
index 8799f1cc..47d9eb31 100644
--- a/lib/PublicInbox/LeiOverview.pm
+++ b/lib/PublicInbox/LeiOverview.pm
@@ -224,9 +224,8 @@ sub ovv_each_smsg_cb { # runs in wq worker usually
                 my $git_dir = $git->{git_dir};
                 sub {
                         my ($smsg, $mitem) = @_;
-                        my $kw = []; # TODO get from mitem
                         $l2m->wq_do('write_mail', \@io, $git_dir,
-                                        $smsg->{blob}, $lei_ipc, $kw)
+                                        $smsg->{blob}, $lei_ipc, $smsg->{kw});
                 }
         } elsif ($l2m) {
                 my $wcb = $l2m->write_cb($lei);
@@ -235,8 +234,8 @@ sub ovv_each_smsg_cb { # runs in wq worker usually
                 my $g2m = $l2m->can('git_to_mail');
                 sub {
                         my ($smsg, $mitem) = @_;
-                        my $kw = []; # TODO get from mitem
-                        $git->cat_async($smsg->{blob}, $g2m, [ $wcb, $kw ]);
+                        $git->cat_async($smsg->{blob}, $g2m,
+                                        [ $wcb, $smsg->{kw} ]);
                 };
         } elsif ($self->{fmt} =~ /\A(concat)?json\z/ && $lei->{opt}->{pretty}) {
                 my $EOR = ($1//'') eq 'concat' ? "\n}" : "\n},";
@@ -266,7 +265,6 @@ sub ovv_each_smsg_cb { # runs in wq worker usually
                 $lei->{ovv_buf} = \(my $buf = '');
                 sub {
                         my ($smsg, $mitem) = @_;
-                        delete @$smsg{qw(tid num)};
                         $buf .= $json->encode(_unbless_smsg(@_)) . $ORS;
                         if (length($buf) > 65536) {
                                 my $lk = $self->lock_for_scope;