# Copyright (C) 2020 all contributors
# License: AGPL-3.0+
# generates manifest.js.gz for grokmirror(1)
package PublicInbox::ManifestJsGz;
use strict;
use v5.10.1;
use parent qw(PublicInbox::WwwListing);
use bytes (); # length
use PublicInbox::Config;
use IO::Compress::Gzip qw(gzip);
use HTTP::Date qw(time2str);
our $json = PublicInbox::Config::json();
# called by WwwListing
sub url_regexp {
my ($ctx) = @_;
# grokmirror uses relative paths, so it's domain-dependent
# SUPER calls PublicInbox::WwwListing::url_regexp
$ctx->SUPER::url_regexp('publicInbox.grokManifest', 'match=domain');
}
sub inject_entry ($$$;$) {
my ($ctx, $url_path, $ent, $git_dir) = @_;
$ctx->{-abs2urlpath}->{$git_dir // delete $ent->{git_dir}} = $url_path;
my $modified = $ent->{modified};
$ctx->{-mtime} = $modified if $modified > ($ctx->{-mtime} // 0);
$ctx->{manifest}->{$url_path} = $ent;
}
sub manifest_add ($$;$$) {
my ($ctx, $ibx, $epoch, $default_desc) = @_;
my $url_path = "/$ibx->{name}";
my $git;
if (defined $epoch) {
$url_path .= "/git/$epoch.git";
$git = $ibx->git_epoch($epoch) or return;
} else {
$git = $ibx->git;
}
my $ent = $git->manifest_entry($epoch, $default_desc) or return;
inject_entry($ctx, $url_path, $ent, $git->{git_dir});
}
sub slow_manifest_add ($$) {
my ($ctx, $ibx) = @_;
eval {
if (defined(my $max = $ibx->max_git_epoch)) {
my $desc = $ibx->description;
for my $epoch (0..$max) {
manifest_add($ctx, $ibx, $epoch, $desc);
}
} else {
manifest_add($ctx, $ibx);
}
};
}
sub eidx_manifest_add ($$$) {
my ($ctx, $ALL, $ibx) = @_;
if (my $data = $ALL->misc->inbox_data($ibx)) {
$data = $json->decode($data);
delete $data->{''}; # private
while (my ($url_path, $ent) = each %$data) {
inject_entry($ctx, $url_path, $ent);
}
} else {
warn "E: `${\$ibx->eidx_key}' not indexed by $ALL->{topdir}\n";
}
}
sub ibx_entry {
my ($ctx, $ibx) = @_;
my $ALL = $ctx->{www}->{pi_cfg}->ALL;
if ($ALL) {
eidx_manifest_add($ctx, $ALL, $ibx);
} else {
slow_manifest_add($ctx, $ibx);
}
warn "E: $@" if $@;
}
sub hide_key { 'manifest' }
# overrides WwwListing->psgi_triple
sub psgi_triple {
my ($ctx) = @_;
my $abs2urlpath = delete($ctx->{-abs2urlpath}) // {};
my $manifest = delete($ctx->{manifest}) // {};
while (my ($url_path, $repo) = each %$manifest) {
defined(my $abs = $repo->{reference}) or next;
$repo->{reference} = $abs2urlpath->{$abs};
}
$manifest = $json->encode($manifest);
gzip(\$manifest => \(my $out));
[ 200, [ qw(Content-Type application/gzip),
'Last-Modified', time2str($ctx->{-mtime}),
'Content-Length', bytes::length($out) ], [ $out ] ]
}
sub per_inbox {
my ($ctx) = @_;
# only one inbox, slow is probably OK
slow_manifest_add($ctx, $ctx->{ibx});
psgi_triple($ctx);
}
1;