aboutsummaryrefslogtreecommitdiff
path: root/src/zenserver-test/zenserver-test.cpp
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2023-10-04 13:13:23 +0200
committerGitHub <[email protected]>2023-10-04 13:13:23 +0200
commit3e8db7cd243e8be3b2d5fea2490b9ad70f765590 (patch)
treec1533ae25b0b717dd2393960c5449aadd56807c4 /src/zenserver-test/zenserver-test.cpp
parentfactored out http parser from asio into separate files (#444) (diff)
downloadzen-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.cpp52
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)
{