From a67d724c1ef3fef7c591a1cf7447cc2c512488ed Mon Sep 17 00:00:00 2001
From: Ian Jackson <ijackson@chiark.greenend.org.uk>
Date: Wed, 15 Apr 2015 18:06:33 +0100
Subject: Provide ftpmasterapi archive query method

---
 dgit | 63 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 62 insertions(+), 1 deletion(-)

diff --git a/dgit b/dgit
index a73fffd..661670c 100755
--- a/dgit
+++ b/dgit
@@ -790,7 +790,7 @@ sub pool_dsc_subpath ($$) {
     return "/pool/$component/$prefix/$package/".dscfn($vsn);
 }
 
-#---------- `ftpmaster-api' archive query method (nascent) ----------
+#---------- `ftpmasterapi' archive query method (nascent) ----------
 
 sub archive_api_query_cmd ($) {
     my ($subpath) = @_;
@@ -813,6 +813,67 @@ sub archive_api_query_cmd ($) {
     return @cmd;
 }
 
+sub api_query ($$) {
+    use JSON;
+    my ($data, $subpath) = @_;
+    badcfg "ftpmasterapi archive query method takes no data part"
+	if length $data;
+    my @cmd = archive_api_query_cmd($subpath);
+    my $json = cmdoutput @cmd;
+    return decode_json($json);
+}
+
+sub canonicalise_suite_ftpmasterapi () {
+    my ($proto,$data) = @_;
+    my $suites = api_query($data, 'suites');
+    my @matched;
+    foreach my $entry (@$suites) {
+	next unless grep { 
+	    my $v = $entry->{$_};
+	    defined $v && $v eq $isuite;
+	} qw(codename name);
+	push @matched, $entry;
+    }
+    fail "unknown suite $isuite" unless @matched;
+    my $cn;
+    eval {
+	@matched==1 or die "multiple matches for suite $isuite\n";
+	$cn = "$matched[0]{codename}";
+	defined $cn or die "suite $isuite info has no codename\n";
+	$cn =~ m/^$suite_re$/ or die "suite $isuite maps to bad codename\n";
+    };
+    die "bad ftpmaster api response: $@\n".Dumper(\@matched)
+	if length $@;
+    return $cn;
+}
+
+sub archive_query_ftpmasterapi () {
+    my ($proto,$data) = @_;
+    my $info = api_query($data, "dsc_in_suite/$isuite/$package");
+    my @rows;
+    my $digester = Digest::SHA->new(256);
+    foreach my $entry (@$info) {
+	eval {
+	    my $vsn = "$entry->{version}";
+	    my ($ok,$msg) = version_check $vsn;
+	    die "bad version: $msg\n" unless $ok;
+	    my $component = "$entry->{component}";
+	    $component =~ m/^$component_re$/ or die "bad component";
+	    my $filename = "$entry->{filename}";
+	    $filename && $filename !~ m#[^-+:._0-9a-zA-Z/]|^[/.]|/[/.]#
+		or die "bad filename";
+	    my $sha256sum = "$entry->{sha256sum}";
+	    $sha256sum =~ m/^[0-9a-f]+$/ or die "bad sha256sum";
+	    push @rows, [ $vsn, "/pool/$component/$filename",
+			  $digester, $sha256sum ];
+	};
+	die "bad ftpmaster api response: $@\n".Dumper($entry)
+	    if length $@;
+    }
+    @rows = sort { -version_compare($a->[0],$b->[0]) } @rows;
+    return @rows;
+}
+
 #---------- `madison' archive query method ----------
 
 sub archive_query_madison {
-- 
cgit v1.2.3