]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/WwwStream.pm
No ext_urls
[public-inbox.git] / lib / PublicInbox / WwwStream.pm
index 115e04407f1c022624ee22040e6ea6c06a0b1fc7..880639b73d99fc6c8d8c82c63ae50b1b89a25f48 100644 (file)
@@ -18,7 +18,7 @@ https://public-inbox.org/public-inbox.git) ];
 
 sub base_url ($) {
        my $ctx = shift;
-       my $base_url = $ctx->{ibx}->base_url($ctx->{env});
+       my $base_url = ($ctx->{ibx} // $ctx->{git})->base_url($ctx->{env});
        chop $base_url; # no trailing slash for clone
        $base_url;
 }
@@ -38,9 +38,60 @@ sub async_eml { # for async_blob_cb
        $ctx->write($ctx->{cb}->($ctx, $eml));
 }
 
+sub html_repo_top ($) {
+       my ($ctx) = @_;
+       my $git = $ctx->{git};
+       my $desc = ascii_html($git->description);
+       my $title = delete($ctx->{-title_html}) // $desc;
+       my $upfx = $ctx->{-upfx} // '';
+       my $atom = $ctx->{-atom} // (substr($upfx, -1) eq '/' ?
+                                       "${upfx}atom/" : "$upfx/atom/");
+       my $top = ascii_html($git->{nick});
+       $top = qq(<a\nhref="$upfx">$top</a>) if length($upfx);
+       $top .= <<EOM;
+  <a href='$upfx#readme'>about</a> / <a
+href='$upfx#heads'>heads</a> / <a
+href='$upfx#tags'>tags</a>
+<b>$desc</b>
+EOM
+       my @url = PublicInbox::ViewVCS::ibx_url_for($ctx);
+       if (@url) {
+               $ctx->{-has_srch} = 1;
+               my $base_url = base_url($ctx);
+               my ($pfx, $sfx) = ($base_url =~ m!\A(https?://[^/]+/)(.*)\z!i);
+               my $iupfx = '../' x (($sfx =~ tr!/!/!) + 1);
+               $pfx = ascii_html($pfx);
+               $pfx = qr/\A\Q$pfx\E/i;
+               my $tmp = $top;
+               $top = '';
+               my ($s, $u, $same_host);
+               my $q_val = delete($ctx->{-q_value_html}) // '';
+               $q_val = qq(\nvalue="$q_val") if $q_val ne '';
+               for (@url) {
+                       $u = $s = ascii_html($_);
+                       substr($u, 0, 0, $iupfx) if $u !~ m!://!;
+                       $s =~ s!$pfx!!;
+                       $s =~ s!/\z!!;
+                       $top .= qq{<form\naction="$u"><pre>$tmp} .
+                               qq{<input\nname=q type=text$q_val />} .
+                               qq{<input type=submit\n} .
+                               qq{value="search mail in `$s&#39;"/>} .
+                               q{</pre></form>};
+                       $tmp = '';
+               }
+       } else {
+               $top = "<pre>$top</pre>";
+       }
+       "<html><head><title>$title</title>" .
+               qq(<link\nrel=alternate\ntitle="Atom feed"\n).
+               qq(href="$atom"\ntype="application/atom+xml"/>) .
+               $ctx->{www}->style($upfx) .
+               '</head><body>'.$top;
+}
+
 sub html_top ($) {
        my ($ctx) = @_;
-       my $ibx = $ctx->{ibx};
+       my $ibx = $ctx->{ibx} // return html_repo_top($ctx);
        my $desc = ascii_html($ibx->description);
        my $title = delete($ctx->{-title_html}) // $desc;
        my $upfx = $ctx->{-upfx} || '';
@@ -57,11 +108,7 @@ sub html_top ($) {
        }
        my $code = $ibx->{coderepo} ? qq( / <a\nhref=#code>code</a>) : '';
        # id=mirror must exist for legacy bookmarks
-       my $links = qq(<a\nhref="${upfx}_/text/help/">help</a> / ).
-                       qq(<a\nhref="${upfx}_/text/color/">color</a> / ).
-                       qq(<a\nid=mirror) .
-                       qq(\nhref="${upfx}_/text/mirror/">mirror</a>$code / ).
-                       qq(<a\nhref="$atom">Atom feed</a>);
+       my $links = 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 '';
@@ -84,38 +131,37 @@ sub html_top ($) {
                '</head><body>'. $top . (delete($ctx->{-html_tip}) // '');
 }
 
+sub inboxes { () } # TODO
+
 sub coderepos ($) {
        my ($ctx) = @_;
+       $ctx->{ibx} // return inboxes($ctx);
        my $cr = $ctx->{ibx}->{coderepo} // return ();
-       my $cfg = $ctx->{www}->{pi_cfg};
        my $upfx = ($ctx->{-upfx} // ''). '../';
        my $pfx = $ctx->{base_url} //= $ctx->base_url;
        my $up = $upfx =~ tr!/!/!;
        $pfx =~ s!/[^/]+\z!/! for (1..$up);
-       my @ret = ('<a id=code>' .
+       $pfx .= '/' if substr($pfx, -1, 1) ne '/';
+       my $buf = '<a id=code>' .
                'Code repositories for project(s) associated with this '.
-               $ctx->{ibx}->thing_type . "\n");
-       for my $cr_name (@$cr) {
-               my $urls = $cfg->get_all("coderepo.$cr_name.cgiturl");
-               if ($urls) {
-                       for (@$urls) {
-                               my $u = m!\A(?:[a-z\+]+:)?//! ? $_ : $pfx.$_;
-                               $u = ascii_html(prurl($ctx->{env}, $u));
-                               $ret[0] .= qq(\n\t<a\nhref="$u">$u</a>);
-                       }
-               } else {
-                       $ret[0] .= qq[\n\t$cr_name.git (no URL configured)];
+               $ctx->{ibx}->thing_type . "\n";
+       for my $git (@{$ctx->{www}->{pi_cfg}->repo_objs($ctx->{ibx})}) {
+               for ($git->pub_urls($ctx->{env})) {
+                       my $u = m!\A(?:[a-z\+]+:)?//!i ? $_ : $pfx.$_;
+                       $u = ascii_html(prurl($ctx->{env}, $u));
+                       $buf .= qq(\n\t<a\nhref="$u">$u</a>);
                }
        }
-       @ret; # may be empty, this sub is called as an arg for join()
+       ($buf);
 }
 
 sub _html_end {
+       return '</body></html>';
        my ($ctx) = @_;
        my $upfx = $ctx->{-upfx} || '';
        my $m = "${upfx}_/text/mirror/";
-       my $x;
-       if ($ctx->{ibx}->can('cloneurl')) {
+       my $x = '';
+       if ($ctx->{ibx} && $ctx->{ibx}->can('cloneurl')) {
                $x = <<EOF;
 This is a public inbox, see <a
 href="$m">mirroring instructions</a>
@@ -139,12 +185,15 @@ as well as URLs for IMAP folder(s).
 EOM
                        }
                }
-       } else {
+       } elsif ($ctx->{ibx}) { # extindex
                $x = <<EOF;
 This is an external index of several public inboxes,
 see <a href="$m">mirroring instructions</a> on how to clone and mirror
 all data and code used by this external index.
 EOF
+       } elsif ($ctx->{git}) { # coderepo
+               $x = join('', map { "git clone $_\n" }
+                       @{$ctx->{git}->cloneurl($ctx->{env})});
        }
        chomp $x;
        '<hr><pre>'.join("\n\n", coderepos($ctx), $x).'</pre></body></html>'
@@ -167,12 +216,12 @@ sub getline {
        $ctx->zflush(_html_end($ctx));
 }
 
-sub html_done ($$) {
-       my ($ctx, $code) = @_;
-       my $bdy = $ctx->zflush(_html_end($ctx));
+sub html_done ($;@) {
+       my $ctx = $_[0];
+       my $bdy = $ctx->zflush(@_[1..$#_], _html_end($ctx));
        my $res_hdr = delete $ctx->{-res_hdr};
        push @$res_hdr, 'Content-Length', length($bdy);
-       [ $code, $res_hdr, [ $bdy ] ]
+       [ 200, $res_hdr, [ $bdy ] ]
 }
 
 sub html_oneshot ($$;@) {
@@ -181,11 +230,12 @@ sub html_oneshot ($$;@) {
                'Content-Length' => undef ];
        bless $ctx, __PACKAGE__;
        $ctx->{gz} = PublicInbox::GzipFilter::gz_or_noop($res_hdr, $ctx->{env});
+       my @top;
        $ctx->{base_url} // do {
-               $ctx->zmore(html_top($ctx));
+               @top = html_top($ctx);
                $ctx->{base_url} = base_url($ctx);
        };
-       my $bdy = $ctx->zflush(@_[2..$#_], _html_end($ctx));
+       my $bdy = $ctx->zflush(@top, @_[2..$#_], _html_end($ctx));
        $res_hdr->[3] = length($bdy);
        [ $code, $res_hdr, [ $bdy ] ]
 }
@@ -205,9 +255,9 @@ sub async_next ($) {
 }
 
 sub aresponse {
-       my ($ctx, $code, $cb) = @_;
+       my ($ctx, $cb) = @_;
        init($ctx, $cb);
-       $ctx->psgi_response($code, delete $ctx->{-res_hdr});
+       $ctx->psgi_response(200, delete $ctx->{-res_hdr});
 }
 
 sub html_init {
@@ -216,7 +266,12 @@ sub html_init {
        my $h = $ctx->{-res_hdr} = ['Content-Type', 'text/html; charset=UTF-8'];
        $ctx->{gz} = PublicInbox::GzipFilter::gz_or_noop($h, $ctx->{env});
        bless $ctx, __PACKAGE__;
-       $ctx->zmore(html_top($ctx));
+       print { $ctx->zfh } html_top($ctx);
+}
+
+sub DESTROY {
+       my ($ctx) = @_;
+       $ctx->{git}->cleanup if $ctx->{git} && $ctx->{git}->{-tmp};
 }
 
 1;