diff options
Diffstat (limited to 'zenserver/testing/httptest.cpp')
| -rw-r--r-- | zenserver/testing/httptest.cpp | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/zenserver/testing/httptest.cpp b/zenserver/testing/httptest.cpp index 230d5d6c5..41a4f064b 100644 --- a/zenserver/testing/httptest.cpp +++ b/zenserver/testing/httptest.cpp @@ -136,6 +136,33 @@ HttpTestingService::HandlePackageRequest(HttpServerRequest& HttpServiceRequest) return (InsertResult.first->second = new PackageHandler(*this, RequestId)).Get(); } +bool +HttpTestingService::HandleMessage(WebSocketId SocketId, const CbPackage& Msg) +{ + using namespace std::literals; + + CbObject Request = Msg.GetObject(); + + CbObjectView Header = Request["Header"sv].AsObjectView(); + std::string_view Method = Header["Method"].AsString(); + const uint64_t CorrelationId = Header["CorrelationId"].AsUInt64(); + + if (Method != "TestHelloZen"sv) + { + return false; + } + + CbObjectWriter Response; + Response.BeginObject("Header"); + Response << "CorrelationId"sv << CorrelationId; + Response.EndObject(); + Response.AddString("Result"sv, "Hello Friend!!"); + + PublishMessage(SocketId, Response.Save()); + + return true; +} + ////////////////////////////////////////////////////////////////////////// HttpTestingService::PackageHandler::PackageHandler(HttpTestingService& Svc, uint32_t RequestId) : m_Svc(Svc), m_RequestId(RequestId) |