1 files changed, 87 insertions, 1 deletions
diff --git a/src/zenhttp/httpsys.cpp b/src/zenhttp/httpsys.cpp
index c7ed0bb2f..8401dcf83 100644
--- a/src/zenhttp/httpsys.cpp
+++ b/src/zenhttp/httpsys.cpp
@@ -16,6 +16,86 @@
 #include <zenhttp/httpshared.h>
 
 #if ZEN_WITH_HTTPSYS
+#	define _WINSOCKAPI_
+#	include <zencore/windows.h>
+#	include <zencore/workthreadpool.h>
+#	include "iothreadpool.h"
+
+#	include <http.h>
+
+namespace spdlog {
+class logger;
+}
+
+namespace zen {
+
+/**
+ * @brief Windows implementation of HTTP server based on http.sys
+ *
+ * This requires elevation to function
+ */
+class HttpSysServer : public HttpServer
+{
+	friend class HttpSysTransaction;
+
+public:
+	explicit HttpSysServer(const HttpSysConfig& Config);
+	~HttpSysServer();
+
+	// HttpServer interface implementation
+
+	virtual int	 Initialize(int BasePort) override;
+	virtual void Run(bool TestMode) override;
+	virtual void RequestExit() override;
+	virtual void RegisterService(HttpService& Service) override;
+	virtual void Close() override;
+
+	WorkerThreadPool& WorkPool();
+
+	inline bool IsOk() const { return m_IsOk; }
+	inline bool IsAsyncResponseEnabled() const { return m_IsAsyncResponseEnabled; }
+
+private:
+	int	 InitializeServer(int BasePort);
+	void Cleanup();
+
+	void StartServer();
+	void OnHandlingNewRequest();
+	void IssueNewRequestMaybe();
+
+	void RegisterService(const char* Endpoint, HttpService& Service);
+	void UnregisterService(const char* Endpoint, HttpService& Service);
+
+private:
+	spdlog::logger& m_Log;
+	spdlog::logger& m_RequestLog;
+	spdlog::logger& Log() { return m_Log; }
+
+	bool m_IsOk					   = false;
+	bool m_IsHttpInitialized	   = false;
+	bool m_IsRequestLoggingEnabled = false;
+	bool m_IsAsyncResponseEnabled  = true;
+
+	WinIoThreadPool	  m_ThreadPool;
+	RwLock			  m_AsyncWorkPoolInitLock;
+	WorkerThreadPool* m_AsyncWorkPool = nullptr;
+
+	std::vector<std::wstring> m_BaseUris;  // eg: http://*:nnnn/
+	HTTP_SERVER_SESSION_ID	  m_HttpSessionId	   = 0;
+	HTTP_URL_GROUP_ID		  m_HttpUrlGroupId	   = 0;
+	HANDLE					  m_RequestQueueHandle = 0;
+	std::atomic_int32_t		  m_PendingRequests{0};
+	std::atomic_int32_t		  m_IsShuttingDown{0};
+	int32_t					  m_MinPendingRequests = 16;
+	int32_t					  m_MaxPendingRequests = 128;
+	Event					  m_ShutdownEvent;
+	const HttpSysConfig		  m_InitialConfig;
+};
+
+}  // namespace zen
+#endif
+
+#if ZEN_WITH_HTTPSYS
 
 #	include <conio.h>
 #	include <mstcpip.h>
@@ -809,7 +889,7 @@ HttpAsyncWorkRequest::AsyncWorkItem::Execute()
 					\/     \/                 \/
 */
 
-HttpSysServer::HttpSysServer(const Config& Config)
+HttpSysServer::HttpSysServer(const HttpSysConfig& Config)
 : m_Log(logging::Get("http"))
 , m_RequestLog(logging::Get("http_requests"))
 , m_IsRequestLoggingEnabled(Config.IsRequestLoggingEnabled)
@@ -1868,5 +1948,11 @@ HttpSysServer::RegisterService(HttpService& Service)
 	RegisterService(Service.BaseUri(), Service);
 }
 
+Ref<HttpServer>
+CreateHttpSysServer(HttpSysConfig Config)
+{
+	return Ref<HttpServer>(new HttpSysServer(Config));
+}
+
 }  // namespace zen
 #endif