workspace shares (#84)

Feature: New 'workspaces' service which allows a user to share a local folder via zenserver. A workspace can have mulitple workspace shares and they provie an HTTP API that is compatible with the project oplog HTTP API. Workspaces and shares are preserved between runs. Workspaces feature is disabled by default - enable with --workspaces-enabled option when launching zenserver.

1 files changed, 72 insertions, 0 deletions

diff --git a/src/zenserver/workspaces/httpworkspaces.h b/src/zenserver/workspaces/httpworkspaces.h
new file mode 100644
index 000000000..cfd23e7ba
--- /dev/null
+++ b/src/zenserver/workspaces/httpworkspaces.h
@@ -0,0 +1,72 @@
+// Copyright Epic Games, Inc. All Rights Reserved.
+
+#pragma once
+
+#include <zencore/stats.h>
+#include <zenhttp/httpserver.h>
+#include <zenhttp/httpstats.h>
+
+namespace zen {
+
+class Workspaces;
+
+struct FileServeConfig
+{
+	std::filesystem::path SystemRootDir;
+};
+
+class HttpWorkspacesService final : public HttpService, public IHttpStatsProvider
+{
+public:
+	HttpWorkspacesService(HttpStatsService& StatsService, const FileServeConfig& Cfg, Workspaces& Workspaces);
+	virtual ~HttpWorkspacesService();
+
+	virtual const char* BaseUri() const override;
+	virtual void		HandleRequest(HttpServerRequest& Request) override;
+
+	virtual void HandleStatsRequest(HttpServerRequest& Request) override;
+
+private:
+	struct WorkspacesStats
+	{
+		std::atomic_uint64_t WorkspaceReadCount{};
+		std::atomic_uint64_t WorkspaceWriteCount{};
+		std::atomic_uint64_t WorkspaceDeleteCount{};
+		std::atomic_uint64_t WorkspaceShareReadCount{};
+		std::atomic_uint64_t WorkspaceShareWriteCount{};
+		std::atomic_uint64_t WorkspaceShareDeleteCount{};
+		std::atomic_uint64_t WorkspaceShareFilesReadCount{};
+		std::atomic_uint64_t WorkspaceShareEntriesReadCount{};
+		std::atomic_uint64_t WorkspaceShareBatchReadCount{};
+		std::atomic_uint64_t WorkspaceShareChunkHitCount{};
+		std::atomic_uint64_t WorkspaceShareChunkMissCount{};
+		std::atomic_uint64_t RequestCount{};
+		std::atomic_uint64_t BadRequestCount{};
+	};
+
+	inline LoggerRef Log() { return m_Log; }
+
+	LoggerRef m_Log;
+
+	void				  Initialize();
+	std::filesystem::path GetStatePath() const;
+	void				  ReadState();
+	void				  WriteState();
+
+	void FilesRequest(HttpRouterRequest& Req);
+	void ChunkInfoRequest(HttpRouterRequest& Req);
+	void BatchRequest(HttpRouterRequest& Req);
+	void EntriesRequest(HttpRouterRequest& Req);
+	void ChunkRequest(HttpRouterRequest& Req);
+	void ShareRequest(HttpRouterRequest& Req);
+	void WorkspaceRequest(HttpRouterRequest& Req);
+
+	HttpStatsService&		 m_StatsService;
+	const FileServeConfig	 m_Config;
+	HttpRequestRouter		 m_Router;
+	Workspaces&				 m_Workspaces;
+	WorkspacesStats			 m_WorkspacesStats;
+	metrics::OperationTiming m_HttpRequests;
+};
+
+}  // namespace zen