diff options
| author | Stefan Boberg <[email protected]> | 2023-10-04 13:13:23 +0200 |
|---|---|---|
| committer | GitHub <[email protected]> | 2023-10-04 13:13:23 +0200 |
| commit | 3e8db7cd243e8be3b2d5fea2490b9ad70f765590 (patch) | |
| tree | c1533ae25b0b717dd2393960c5449aadd56807c4 /src/zenserver-test/zenserver-test.cpp | |
| parent | factored out http parser from asio into separate files (#444) (diff) | |
| download | zen-3e8db7cd243e8be3b2d5fea2490b9ad70f765590.tar.xz zen-3e8db7cd243e8be3b2d5fea2490b9ad70f765590.zip | |
removed websocket protocol support(#445)
removed websocket support since it is not used right now and is unlikely to be used in the future
Diffstat (limited to 'src/zenserver-test/zenserver-test.cpp')
| -rw-r--r-- | src/zenserver-test/zenserver-test.cpp | 52 |
1 files changed, 0 insertions, 52 deletions
diff --git a/src/zenserver-test/zenserver-test.cpp b/src/zenserver-test/zenserver-test.cpp index 2f52e3225..3fae3235f 100644 --- a/src/zenserver-test/zenserver-test.cpp +++ b/src/zenserver-test/zenserver-test.cpp @@ -21,7 +21,6 @@ #include <zencore/xxhash.h> #include <zenhttp/httpclient.h> #include <zenhttp/httpshared.h> -#include <zenhttp/websocket.h> #include <zenhttp/zenhttp.h> #include <zenutil/cache/cache.h> #include <zenutil/cache/cacherequests.h> @@ -2608,57 +2607,6 @@ TEST_CASE("http.package") CHECK_EQ(ResponsePackage, TestPackage); } -TEST_CASE("websocket.basic") -{ - if (true) - { - return; - } - - std::filesystem::path TestDir = TestEnv.CreateNewTestDir(); - const uint16_t PortNumber = 13337; - const auto MaxWaitTime = std::chrono::seconds(5); - - ZenServerInstance Inst(TestEnv); - Inst.SetTestDir(TestDir); - Inst.SpawnServer(PortNumber, "--websocket-port=8848"sv); - Inst.WaitUntilReady(); - - asio::io_context IoCtx; - IoDispatcher IoDispatcher(IoCtx); - auto WebSocket = WebSocketClient::Create(IoCtx); - - auto ConnectFuture = WebSocket->Connect({.Host = "127.0.0.1", .Port = 8848, .Endpoint = "/zen"}); - IoDispatcher.Run(); - - ConnectFuture.wait_for(MaxWaitTime); - CHECK(ConnectFuture.get()); - - for (size_t Idx = 0; Idx < 10; Idx++) - { - CbObjectWriter Request; - Request << "Method"sv - << "SayHello"sv; - - WebSocketMessage RequestMsg; - RequestMsg.SetMessageType(WebSocketMessageType::kRequest); - RequestMsg.SetBody(Request.Save()); - - auto ResponseFuture = WebSocket->SendRequest(std::move(RequestMsg)); - ResponseFuture.wait_for(MaxWaitTime); - - CbObject Response = ResponseFuture.get().Body().GetObject(); - std::string_view Message = Response["Result"].AsString(); - - CHECK(Message == "Hello Friend!!"sv); - } - - WebSocket->Disconnect(); - - IoCtx.stop(); - IoDispatcher.Stop(); -} - std::string OidAsString(const Oid& Id) { |