From c57a2009754f9778cc59cdb048cdb5e29496cb5e Mon Sep 17 00:00:00 2001
From: Helmut Grohne <helmut@subdivi.de>
Date: Fri, 31 Dec 2021 15:49:14 +0100
Subject: multiarchimport.py: use dedup.utils.iterate_packages

---
 multiarchimport.py | 26 ++++++++++++--------------
 1 file changed, 12 insertions(+), 14 deletions(-)

diff --git a/multiarchimport.py b/multiarchimport.py
index 5eefe4b..af9d1c1 100755
--- a/multiarchimport.py
+++ b/multiarchimport.py
@@ -20,7 +20,7 @@ from debian.debian_support import version_compare
 
 from dedup.debpkg import DebExtractor
 from dedup.hashing import hash_file
-from dedup.utils import fetchiter, open_compressed_mirror_url
+from dedup.utils import fetchiter, iterate_packages
 
 def release_architectures(mirror):
     with closing(urlopen("%s/dists/testing/Release" % mirror)) as f:
@@ -63,19 +63,17 @@ def gather_pkgmeta(pkg):
 
 def process_list(mirror, architecture):
     pkgs = dict()
-    url = "%s/dists/sid/main/binary-%s/Packages" % (mirror, architecture)
-    with closing(open_compressed_mirror_url(url)) as pkglist:
-        for pkg in deb822.Packages.iter_paragraphs(pkglist):
-            if pkg["architecture"] != architecture:
-                continue # e.g. Arch: all
-            try:
-                otherver = pkgs[pkg["package"]]["version"]
-            except KeyError:
-                pass
-            else:
-                if version_compare(otherver, pkg["version"]) > 0:
-                    continue
-            pkgs[pkg["package"]] = gather_pkgmeta(pkg)
+    for pkg in iterate_packages(mirror, architecture):
+        if pkg["architecture"] != architecture:
+            continue # e.g. Arch: all
+        try:
+            otherver = pkgs[pkg["package"]]["version"]
+        except KeyError:
+            pass
+        else:
+            if version_compare(otherver, pkg["version"]) > 0:
+                continue
+        pkgs[pkg["package"]] = gather_pkgmeta(pkg)
     return pkgs
 
 def process_one_list(item):
-- 
cgit v1.2.3