kapitan/IXWebSocket
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add cobra metrics publisher + server unittest

Browse Source
This commit is contained in:
Benjamin Sergeant
2019-09-05 21:57:05 -07:00
parent c0f098a578
commit 37a7b362d8
7 changed files with 247 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
test/IXCobraChatTest.cpp
View File

@ -172,7 +172,7 @@ namespace
//
void SatoriChat::run()
{
snake::AppConfig appConfig = makeSnakeServerConfig();
snake::AppConfig appConfig = makeSnakeServerConfig(8008);
// Display config on the terminal for debugging
dumpConfig(appConfig);
@ -182,16 +182,10 @@ namespace
// "chat" conf
std::string appkey("FC2F10139A2BAc53BB72D9db967b024f");
std::string endpoint("ws://localhost:8008");
std::string channel = _session;
std::string role = "_sub";
std::string secret = "66B1dA3ED5fA074EB5AE84Dd8CE3b5ba";
// appkey = "1121b8DfbB33E56dE1F82fC2A08cD1D7";
// endpoint = "ws://api-internal-cobra.addsrv.com";
// endpoint = "ws://localhost:8765";
// role = "unittest_subscriber";
// secret = "98B69bcdfc145C5fB7C2f4A5aFfe4fd3";
std::string endpoint("ws://localhost:8008");
_conn.configure(appkey, endpoint, role, secret,
ix::WebSocketPerMessageDeflateOptions(true));
@ -231,6 +225,10 @@ namespace
{
log("Unsubscription ok: " + _user + " subscription_id " + subscriptionId);
}
else if (eventType == ix::CobraConnection_EventType_Published)
{
Logger() << "Subscriber: published message acked: " << msgId;
}
}
);
@ -279,7 +277,7 @@ TEST_CASE("Cobra_chat", "[cobra_chat]")
{
SECTION("Exchange and count sent/received messages.")
{
snake::AppConfig appConfig = makeSnakeServerConfig();
snake::AppConfig appConfig = makeSnakeServerConfig(8008);
snake::SnakeServer snakeServer(appConfig);
snakeServer.run();