# Copyright (C) 2016-2021 all contributors
# License: AGPL-3.0+
#
# HTML body stream for which yields getline+close methods for
# generic PSGI servers and callbacks for public-inbox-httpd.
#
# See PublicInbox::GzipFilter parent class for more info.
package PublicInbox::WwwStream;
use strict;
use v5.10.1;
use parent qw(Exporter PublicInbox::GzipFilter);
our @EXPORT_OK = qw(html_oneshot);
use PublicInbox::Hval qw(ascii_html prurl ts2str);
our $CODE_URL = [ qw(
http://7fh6tueqddpjyxjmgtdiueylzoqt6pt7hec3pukyptlmohoowvhde4yd.onion/public-inbox.git
https://public-inbox.org/public-inbox.git) ];
sub base_url ($) {
my $ctx = shift;
my $base_url = $ctx->{ibx}->base_url($ctx->{env});
chop $base_url; # no trailing slash for clone
$base_url;
}
sub init {
my ($ctx, $cb) = @_;
$ctx->{cb} = $cb;
$ctx->{base_url} = base_url($ctx);
bless $ctx, __PACKAGE__;
}
sub async_eml { # for async_blob_cb
my ($ctx, $eml) = @_;
$ctx->{http_out}->write($ctx->translate($ctx->{cb}->($ctx, $eml)));
}
sub html_top ($) {
my ($ctx) = @_;
my $ibx = $ctx->{ibx};
my $desc = ascii_html($ibx->description);
my $title = delete($ctx->{-title_html}) // $desc;
my $upfx = $ctx->{-upfx} || '';
my $atom = $ctx->{-atom} || $upfx.'new.atom';
my $top = "$desc";
if (my $t_max = $ctx->{-t_max}) {
$t_max = ts2str($t_max);
$top = qq($top);
# we had some kind of query, link to /$INBOX/?t=YYYYMMDDhhmmss
} elsif ($ctx->{qp}->{t}) {
$top = qq($top);
}
my $code = $ibx->{coderepo} ? qq( / code) : '';
# id=mirror must exist for legacy bookmarks
my $links = qq(help / ).
qq(color / ).
qq(mirror$code / ).
qq(Atom feed);
if ($ibx->isrch) {
my $q_val = delete($ctx->{-q_value_html}) // '';
$q_val = qq(\nvalue="$q_val") if $q_val ne '';
# XXX gross, for SearchView.pm
my $extra = delete($ctx->{-extra_form_html}) // '';
my $action = $upfx eq '' ? './' : $upfx;
$top = qq{}
} else {
$top = '
' . $top . "\n" . $links . '
';
}
"$title" .
qq() .
$ctx->{www}->style($upfx) .
''. $top . (delete($ctx->{-html_tip}) // '');
}
sub coderepos ($) {
my ($ctx) = @_;
my $cr = $ctx->{ibx}->{coderepo} // return ();
my $cfg = $ctx->{www}->{pi_cfg};
my $upfx = ($ctx->{-upfx} // ''). '../';
my @ret;
for my $cr_name (@$cr) {
$ret[0] //= <code repositories for project(s) associated with this inbox:
EOF
my $urls = $cfg->get_all("coderepo.$cr_name.cgiturl");
if ($urls) {
for (@$urls) {
# relative or absolute URL?, prefix relative
# "foo.git" with appropriate number of "../"
my $u = m!\A(?:[a-z\+]+:)?//! ? $_ : $upfx.$_;
$u = ascii_html(prurl($ctx->{env}, $u));
$ret[0] .= qq(\n\t$u);
}
} else {
$ret[0] .= qq[\n\t$cr_name.git (no URL configured)];
}
}
@ret; # may be empty, this sub is called as an arg for join()
}
sub _html_end {
my ($ctx) = @_;
my @cr = coderepos($ctx);
scalar(@cr) ?
'