]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/WwwStream.pm
rename {pi_config} fields to {pi_cfg}
[public-inbox.git] / lib / PublicInbox / WwwStream.pm
index 23b03f0e8dc49ddf8780964a9f988fd41d99b6dc..34e124358d5e588cfae0f8f9cbfb730e33ee921c 100644 (file)
@@ -10,13 +10,13 @@ use strict;
 use parent qw(Exporter PublicInbox::GzipFilter);
 our @EXPORT_OK = qw(html_oneshot);
 use bytes (); # length
-use PublicInbox::Hval qw(ascii_html prurl);
+use PublicInbox::Hval qw(ascii_html prurl ts2str);
 our $TOR_URL = 'https://www.torproject.org/';
 our $CODE_URL = 'https://public-inbox.org/public-inbox.git';
 
 sub base_url ($) {
        my $ctx = shift;
-       my $base_url = $ctx->{-inbox}->base_url($ctx->{env});
+       my $base_url = $ctx->{ibx}->base_url($ctx->{env});
        chop $base_url; # no trailing slash for clone
        $base_url;
 }
@@ -28,14 +28,14 @@ sub init {
        bless $ctx, __PACKAGE__;
 }
 
-sub async_eml { # ->{async_eml} for async_blob_cb
+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->{-inbox};
+       my $ibx = $ctx->{ibx};
        my $desc = ascii_html($ibx->description);
        my $title = delete($ctx->{-title_html}) // $desc;
        my $upfx = $ctx->{-upfx} || '';
@@ -43,10 +43,18 @@ sub html_top ($) {
        my $color = $upfx.'_/text/color';
        my $atom = $ctx->{-atom} || $upfx.'new.atom';
        my $top = "<b>$desc</b>";
-       my $links = "<a\nhref=\"$help\">help</a> / ".
-                       "<a\nhref=\"$color\">color</a> / ".
-                       "<a\nhref=\"$atom\">Atom feed</a>";
-       if ($ibx->search) {
+       if (my $t_max = $ctx->{-t_max}) {
+               $t_max = ts2str($t_max);
+               $top = qq(<a\nhref="$upfx?t=$t_max">$top</a>);
+       # we had some kind of query, link to /$INBOX/?t=YYYYMMDDhhmmss
+       } elsif ($ctx->{qp}->{t}) {
+               $top = qq(<a\nhref="./">$top</a>);
+       }
+       my $links = qq(<a\nhref="$help">help</a> / ).
+                       qq(<a\nhref="$color">color</a> / ).
+                       qq(<a\nhref=#mirror>mirror</a> / ).
+                       qq(<a\nhref="$atom">Atom feed</a>);
+       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
@@ -68,6 +76,26 @@ sub html_top ($) {
                '</head><body>'. $top . (delete($ctx->{-html_tip}) // '');
 }
 
+sub coderepos ($) {
+       my ($ctx) = @_;
+       my $ibx = $ctx->{ibx};
+       my @ret;
+       if (defined(my $cr = $ibx->{coderepo})) {
+               my $cfg = $ctx->{www}->{pi_cfg};
+               my $env = $ctx->{env};
+               for my $cr_name (@$cr) {
+                       my $urls = $cfg->{"coderepo.$cr_name.cgiturl"};
+                       if ($urls) {
+                               $ret[0] //= <<EOF;
+code repositories for the project(s) associated with this inbox:
+EOF
+                               $ret[0] .= "\n\t".prurl($env, $_) for @$urls;
+                       }
+               }
+       }
+       @ret; # may be empty
+}
+
 sub code_footer ($) {
        my ($env) = @_;
        my $u = prurl($env, $CODE_URL);
@@ -76,8 +104,12 @@ sub code_footer ($) {
 
 sub _html_end {
        my ($ctx) = @_;
-       my $urls = 'Archives are clonable:';
-       my $ibx = $ctx->{-inbox};
+       my $urls = <<EOF;
+<a
+id=mirror>This inbox may be cloned and mirrored by anyone:</a>
+EOF
+
+       my $ibx = $ctx->{ibx};
        my $desc = ascii_html($ibx->description);
 
        my @urls;
@@ -87,12 +119,18 @@ sub _html_end {
        my %seen = ($http => 1);
        if (defined($max)) { # v2
                for my $i (0..$max) {
-                       # old parts my be deleted:
+                       # old epochs my be deleted:
                        -d "$ibx->{inboxdir}/git/$i.git" or next;
                        my $url = "$http/$i";
                        $seen{$url} = 1;
                        push @urls, "$url $dir/git/$i.git";
                }
+               my $nr = scalar(@urls);
+               if ($nr > 1) {
+                       $urls .= "\n\t# this inbox consists of $nr epochs:";
+                       $urls[0] .= "\t# oldest";
+                       $urls[-1] .= "\t# newest";
+               }
        } else { # v1
                push @urls, $http;
        }
@@ -104,44 +142,38 @@ sub _html_end {
                push @urls, $u =~ /\Ahttps?:/ ? qq(<a\nhref="$u">$u</a>) : $u;
        }
 
-       if (defined($max) || scalar(@urls) > 1) {
-               $urls .= "\n" .
-                       join("\n", map { "\tgit clone --mirror $_" } @urls);
-       } else {
-               $urls .= " git clone --mirror $urls[0]";
-       }
-       if (defined $max) {
-               my $addrs = $ibx->{address};
-               $addrs = join(' ', @$addrs) if ref($addrs) eq 'ARRAY';
-               $urls .=  <<EOF
-
+       $urls .= "\n" . join('', map { "\tgit clone --mirror $_\n" } @urls);
+       my $addrs = $ibx->{address};
+       $addrs = join(' ', @$addrs) if ref($addrs) eq 'ARRAY';
+       my $v = defined $max ? '-V2' : '-V1';
+       $urls .= <<EOF;
 
        # If you have public-inbox 1.1+ installed, you may
        # initialize and index your mirror using the following commands:
-       public-inbox-init -V2 $ibx->{name} $dir/ $http \\
+       public-inbox-init $v $ibx->{name} $dir/ $http \\
                $addrs
        public-inbox-index $dir
 EOF
-       } else { # v1
-               $urls .= "\n";
-       }
-
        my $cfg_link = ($ctx->{-upfx} // '').'_/text/config/raw';
-       $urls .= qq(\nExample <a\nhref="$cfg_link">config snippet</a> for mirrors\n);
+       $urls .= <<EOF;
+
+Example <a
+href="$cfg_link">config snippet</a> for mirrors.
+EOF
        my @nntp = map { qq(<a\nhref="$_">$_</a>) } @{$ibx->nntp_url};
        if (@nntp) {
-               $urls .= "\n";
                $urls .= @nntp == 1 ? 'Newsgroup' : 'Newsgroups are';
                $urls .= ' available over NNTP:';
                $urls .= "\n\t" . join("\n\t", @nntp) . "\n";
        }
        if ($urls =~ m!\b[^:]+://\w+\.onion/!) {
-               $urls .= "\n note: .onion URLs require Tor: ";
+               $urls .= " note: .onion URLs require Tor: ";
                $urls .= qq[<a\nhref="$TOR_URL">$TOR_URL</a>];
        }
        '<hr><pre>'.join("\n\n",
                $desc,
                $urls,
+               coderepos($ctx),
                code_footer($ctx->{env})
        ).'</pre></body></html>';
 }
@@ -152,7 +184,7 @@ sub getline {
        my $cb = $ctx->{cb} or return;
        while (defined(my $x = $cb->($ctx))) { # x = smsg or scalar non-ref
                if (ref($x)) { # smsg
-                       my $eml = $ctx->{-inbox}->smsg_eml($x) or next;
+                       my $eml = $ctx->{ibx}->smsg_eml($x) or next;
                        $ctx->{smsg} = $x;
                        return $ctx->translate($cb->($ctx, $eml));
                } else { # scalar
@@ -198,7 +230,7 @@ sub aresponse {
        my ($ctx, $code, $cb) = @_;
        my $res_hdr = [ 'Content-Type' => 'text/html; charset=UTF-8' ];
        init($ctx, $cb);
-       $ctx->psgi_response($code, $res_hdr, \&async_next, \&async_eml);
+       $ctx->psgi_response($code, $res_hdr);
 }
 
 1;