diff options
author | Eric Wong <e@80x24.org> | 2021-01-21 19:46:14 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2021-01-22 16:18:01 -0400 |
commit | bf77d62faa571cdaf279df421aae85d2b447ceeb (patch) | |
tree | 9a342476340dcc9763443ceb8eb8b6010e6a584e /lib/PublicInbox/LeiOverview.pm | |
parent | 7e947c849e3ceeb89c3d27952abdb10f9252c038 (diff) | |
download | public-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.pm | 8 |
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; |