Use upstream apply with Horde

1 files changed, 12 insertions, 8 deletions

diff --git a/zenserver/compute/apply.h b/zenserver/compute/apply.h
index 86b262213..15cda4750 100644
--- a/zenserver/compute/apply.h
+++ b/zenserver/compute/apply.h
@@ -14,6 +14,7 @@ namespace zen {
 
 class CasStore;
 class CidStore;
+class UpstreamApply;
 
 /**
  * Lambda style compute function service
@@ -28,14 +29,15 @@ public:
 	virtual void		HandleRequest(HttpServerRequest& Request) override;
 
 private:
-	spdlog::logger&		  Log() { return m_Log; }
-	spdlog::logger&		  m_Log;
-	HttpRequestRouter	  m_Router;
-	CasStore&			  m_CasStore;
-	CidStore&			  m_CidStore;
-	std::filesystem::path m_SandboxPath;
-	std::filesystem::path m_FunctionPath;
-	std::atomic<int>	  m_SandboxCount{0};
+	spdlog::logger&				   Log() { return m_Log; }
+	spdlog::logger&				   m_Log;
+	HttpRequestRouter			   m_Router;
+	CasStore&					   m_CasStore;
+	CidStore&					   m_CidStore;
+	std::filesystem::path		   m_SandboxPath;
+	std::filesystem::path		   m_FunctionPath;
+	std::atomic<int>			   m_SandboxCount{0};
+	std::unique_ptr<UpstreamApply> m_UpstreamApply;
 
 	struct WorkerDesc
 	{
@@ -44,6 +46,8 @@ private:
 
 	[[nodiscard]] std::filesystem::path CreateNewSandbox();
 	[[nodiscard]] CbPackage				ExecAction(const WorkerDesc& Worker, CbObject Action);
+	[[nodiscard]] CbObject				ExecActionUpstream(const WorkerDesc& Worker, CbObject Action);
+	[[nodiscard]] HttpResponseCode		ExecActionUpstreamResult(const IoHash& WorkerId, const IoHash& ActionId, CbPackage& Package);
 
 	RwLock								   m_WorkerLock;
 	std::unordered_map<IoHash, WorkerDesc> m_WorkerMap;