From e99b2ef058a20ad3f47eb4771660eee9fe45d5a6 Mon Sep 17 00:00:00 2001
From: Simon Quigley <simon@tsimonq2.net>
Date: Mon, 16 Dec 2024 11:06:19 -0600
Subject: [PATCH] Add source_package_publishing_history::getPublishedBinaries()

---
 src/source_package_publishing_history.cpp | 23 +++++++++++++++++++++++
 src/source_package_publishing_history.h   |  2 ++
 2 files changed, 25 insertions(+)

diff --git a/src/source_package_publishing_history.cpp b/src/source_package_publishing_history.cpp
index be391a7..6b4ae3c 100644
--- a/src/source_package_publishing_history.cpp
+++ b/src/source_package_publishing_history.cpp
@@ -14,6 +14,7 @@
 // along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
 #include "source_package_publishing_history.h"
+#include "binary_package_publishing_history.h"
 #include "build.h"
 #include "launchpad.h"
 #include <iostream>
@@ -91,3 +92,25 @@ const std::optional<class distro_series> source_package_publishing_history::getD
     }
     return std::nullopt;
 }
+
+std::generator<binary_package_publishing_history> source_package_publishing_history::getPublishedBinaries(bool active_binaries_only) const {
+    std::map<std::string,std::string> params;
+    params["ws.op"] = "getPublishedBinaries";
+    if (active_binaries_only) params["active_binaries_only"] = "true";
+
+    auto response=lp->api_get(self_link, params);
+    if(!response) co_return;
+    auto data = nlohmann::json::parse(response.value());
+    while (true) {
+        if (data.contains("entries") && data["entries"].is_array()) {
+            for (auto &e : data["entries"]) {
+                auto bpph = binary_package_publishing_history::parse(e.dump());
+                if (bpph) { bpph->set_lp(lp); co_yield bpph.value(); }
+            }
+        }
+        if(!data.contains("next_collection_link")||data["next_collection_link"].is_null()||data["next_collection_link"]=="")break;
+        response=lp->api_get(data["next_collection_link"].get<std::string>());
+        if(!response)break;
+        data=nlohmann::json::parse(response.value());
+    }
+}
diff --git a/src/source_package_publishing_history.h b/src/source_package_publishing_history.h
index 4799c1b..e381170 100644
--- a/src/source_package_publishing_history.h
+++ b/src/source_package_publishing_history.h
@@ -20,6 +20,7 @@
 #include <optional>
 #include <generator>
 #include "distro_series.h"
+#include "binary_package_publishing_history.h"
 
 class launchpad;
 class build;
@@ -42,6 +43,7 @@ public:
 
     std::generator<build> getBuilds() const;
     std::optional<class distro_series> distro_series = getDistroSeries();
+    std::generator<binary_package_publishing_history> getPublishedBinaries(bool active_binaries_only = false) const;
 
     std::string distro_series_link;
     std::string self_link;