Added HttpServerRequest::RequestContentType()

2 files changed, 54 insertions, 9 deletions

diff --git a/zencore/httpserver.cpp b/zencore/httpserver.cpp
index 22cba4d75..1bfe224f8 100644
--- a/zencore/httpserver.cpp
+++ b/zencore/httpserver.cpp
@@ -929,6 +929,46 @@ HttpSysServer::RemoveEndpoint(const char* UrlPath, HttpService& Service)
 
 //////////////////////////////////////////////////////////////////////////
 
+using namespace std::literals;
+
+static constinit uint32_t HashBinary			   = HashStringDjb2("application/octet-stream"sv);
+static constinit uint32_t HashJson				   = HashStringDjb2("application/json"sv);
+static constinit uint32_t HashText				   = HashStringDjb2("text/plain"sv);
+static constinit uint32_t HashCompactBinary		   = HashStringDjb2("application/x-ue-cb"sv);
+static constinit uint32_t HashCompactBinaryPackage = HashStringDjb2("application/x-ue-cbpkg"sv);
+
+HttpContentType
+MapContentType(const std::string_view& ContentTypeString)
+{
+	if (!ContentTypeString.empty())
+	{
+		const uint32_t CtHash = HashStringDjb2(ContentTypeString);
+
+		if (CtHash == HashBinary)
+		{
+			return HttpContentType::kBinary;
+		}
+		else if (CtHash == HashCompactBinary)
+		{
+			return HttpContentType::kCbObject;
+		}
+		else if (CtHash == HashCompactBinaryPackage)
+		{
+			return HttpContentType::kCbPackage;
+		}
+		else if (CtHash == HashJson)
+		{
+			return HttpContentType::kJSON;
+		}
+		else if (CtHash == HashText)
+		{
+			return HttpContentType::kText;
+		}
+	}
+
+	return HttpContentType::kUnknownContentType;
+}
+
 class HttpSysServerRequest : public HttpServerRequest
 {
 public:
@@ -1000,10 +1040,12 @@ public:
 				break;
 		}
 
-		auto&			 clh = HttpRequestPtr->Headers.KnownHeaders[HttpHeaderContentLength];
-		std::string_view cl(clh.pRawValue, clh.RawValueLength);
-
+		const HTTP_KNOWN_HEADER& clh = HttpRequestPtr->Headers.KnownHeaders[HttpHeaderContentLength];
+		std::string_view		 cl(clh.pRawValue, clh.RawValueLength);
 		std::from_chars(cl.data(), cl.data() + cl.size(), m_ContentLength);
+
+		const HTTP_KNOWN_HEADER& CtHdr = HttpRequestPtr->Headers.KnownHeaders[HttpHeaderContentType];
+		m_ContentType				   = MapContentType({CtHdr.pRawValue, CtHdr.RawValueLength});
 	}
 
 	~HttpSysServerRequest() {}
diff --git a/zencore/include/zencore/httpserver.h b/zencore/include/zencore/httpserver.h
index d07eba339..8f762c2e4 100644
--- a/zencore/include/zencore/httpserver.h
+++ b/zencore/include/zencore/httpserver.h
@@ -167,7 +167,8 @@ enum class HttpContentType
 	kText,
 	kJSON,
 	kCbObject,
-	kCbPackage
+	kCbPackage,
+	kUnknownContentType
 };
 
 /** HTTP Server Request
@@ -209,7 +210,8 @@ public:
 
 	QueryParams GetQueryParams();
 
-	inline HttpVerb RequestVerb() const { return m_Verb; }
+	inline HttpVerb		   RequestVerb() const { return m_Verb; }
+	inline HttpContentType RequestContentType() { return m_ContentType; }
 
 	const char*		HeaderAccept() const;
 	const char*		HeaderAcceptEncoding() const;
@@ -248,6 +250,7 @@ protected:
 	bool						 m_SuppressBody	 = false;
 	HttpVerb					 m_Verb			 = HttpVerb::kGet;
 	uint64_t					 m_ContentLength = ~0ull;
+	HttpContentType				 m_ContentType	 = HttpContentType::kBinary;
 	ExtendableStringBuilder<256> m_Uri;
 	ExtendableStringBuilder<256> m_QueryString;
 };
@@ -263,9 +266,9 @@ private:
 
 /**
  * Base class for implementing an HTTP "service"
- * 
+ *
  * A service exposes one or more endpoints with a certain URI prefix
- * 
+ *
  */
 
 class HttpService
@@ -340,10 +343,10 @@ HttpRouterRequest::GetCapture(int Index) const
 //////////////////////////////////////////////////////////////////////////
 
 /** HTTP request router helper
- * 
+ *
  * This helper class allows a service implementer to register one or more
  * endpoints using pattern matching (currently using regex matching)
- * 
+ *
  */
 
 class HttpRequestRouter