From abfee5ce706e8a56cb46db1c4f3b71e5f8e4c8d3 Mon Sep 17 00:00:00 2001
From: Dan Engelbrecht <dan.engelbrecht@epicgames.com>
Date: Sat, 11 Apr 2026 12:36:11 +0200
Subject: hub deprovision all (#938)

* implement "deprovision all" for hub
---
 src/zenserver/hub/httphubservice.cpp | 80 ++++++++++++++++++++++++++++++++++++
 1 file changed, 80 insertions(+)

(limited to 'src/zenserver/hub/httphubservice.cpp')

diff --git a/src/zenserver/hub/httphubservice.cpp b/src/zenserver/hub/httphubservice.cpp
index e6a900066..e4b0c28d0 100644
--- a/src/zenserver/hub/httphubservice.cpp
+++ b/src/zenserver/hub/httphubservice.cpp
@@ -120,6 +120,11 @@ HttpHubService::HttpHubService(Hub& Hub, HttpProxyHandler& Proxy, HttpStatsServi
 		},
 		HttpVerb::kGet);
 
+	m_Router.RegisterRoute(
+		"deprovision",
+		[this](HttpRouterRequest& Req) { HandleDeprovisionAll(Req.ServerRequest()); },
+		HttpVerb::kPost);
+
 	m_Router.RegisterRoute(
 		"modules/{moduleid}",
 		[this](HttpRouterRequest& Req) {
@@ -370,6 +375,81 @@ HttpHubService::GetActivityCounter()
 	return m_HttpRequests.Count();
 }
 
+void
+HttpHubService::HandleDeprovisionAll(HttpServerRequest& Request)
+{
+	std::vector<std::string> ModulesToDeprovision;
+	m_Hub.EnumerateModules([&ModulesToDeprovision](std::string_view ModuleId, const Hub::InstanceInfo& InstanceInfo) {
+		if (InstanceInfo.State == HubInstanceState::Provisioned || InstanceInfo.State == HubInstanceState::Hibernated)
+		{
+			ModulesToDeprovision.push_back(std::string(ModuleId));
+		}
+	});
+
+	if (ModulesToDeprovision.empty())
+	{
+		return Request.WriteResponse(HttpResponseCode::OK);
+	}
+	std::vector<std::string> Rejected;
+	std::vector<std::string> Accepted;
+	std::vector<std::string> Completed;
+	for (const std::string& ModuleId : ModulesToDeprovision)
+	{
+		Hub::Response Response = m_Hub.Deprovision(ModuleId);
+		switch (Response.ResponseCode)
+		{
+			case Hub::EResponseCode::NotFound:
+				// Ignore
+				break;
+			case Hub::EResponseCode::Rejected:
+				Rejected.push_back(ModuleId);
+				break;
+			case Hub::EResponseCode::Accepted:
+				Accepted.push_back(ModuleId);
+				break;
+			case Hub::EResponseCode::Completed:
+				Completed.push_back(ModuleId);
+				break;
+		}
+	}
+	if (Rejected.empty() && Accepted.empty() && Completed.empty())
+	{
+		return Request.WriteResponse(HttpResponseCode::OK);
+	}
+	HttpResponseCode Response = HttpResponseCode::OK;
+	CbObjectWriter	 Writer;
+	if (!Completed.empty())
+	{
+		Writer.BeginArray("Completed");
+		for (const std::string& ModuleId : Completed)
+		{
+			Writer.AddString(ModuleId);
+		}
+		Writer.EndArray();	// Completed
+	}
+	if (!Accepted.empty())
+	{
+		Writer.BeginArray("Accepted");
+		for (const std::string& ModuleId : Accepted)
+		{
+			Writer.AddString(ModuleId);
+		}
+		Writer.EndArray();	// Accepted
+		Response = HttpResponseCode::Accepted;
+	}
+	if (!Rejected.empty())
+	{
+		Writer.BeginArray("Rejected");
+		for (const std::string& ModuleId : Rejected)
+		{
+			Writer.AddString(ModuleId);
+		}
+		Writer.EndArray();	// Rejected
+		Response = HttpResponseCode::Conflict;
+	}
+	Request.WriteResponse(Response, Writer.Save());
+}
+
 void
 HttpHubService::HandleModuleGet(HttpServerRequest& Request, std::string_view ModuleId)
 {
-- 
cgit v1.2.3