IXWebSocket/test/IXWebSocketTestConnectionDisconnection.cpp

/*
 *  IXWebSocketTestConnectionDisconnection.cpp
 *  Author: Benjamin Sergeant
 *  Copyright (c) 2017 Machine Zone. All rights reserved.
 */

#include <iostream>
#include <sstream>
#include <set>
#include <ixwebsocket/IXWebSocket.h>
#include "IXTest.h"

#include "catch.hpp"

using namespace ix;

namespace
{
    const std::string WEBSOCKET_DOT_ORG_URL("wss://echo.websocket.org");
    const std::string GOOGLE_URL("wss://google.com");
    const std::string UNKNOWN_URL("wss://asdcasdcaasdcasdcasdcasdcasdcasdcasassdd.com");
}

namespace
{
    class IXWebSocketTestConnectionDisconnection
    {
        public:
            IXWebSocketTestConnectionDisconnection();
            void start(const std::string& url);
            void stop();

        private:
            ix::WebSocket _webSocket;
    };

    IXWebSocketTestConnectionDisconnection::IXWebSocketTestConnectionDisconnection()
    {
        ;
    }

    void IXWebSocketTestConnectionDisconnection::stop()
    {
        _webSocket.stop();
    }

    void IXWebSocketTestConnectionDisconnection::start(const std::string& url)
    {
        _webSocket.setUrl(url);

        std::stringstream ss;
        log(std::string("Connecting to url: ") + url);

        _webSocket.setOnMessageCallback(
            [](const ix::WebSocketMessagePtr& msg)
            {
                std::stringstream ss;
                if (msg->type == ix::WebSocketMessageType::Open)
                {
                    log("TestConnectionDisconnection: connected !");
                }
                else if (msg->type == ix::WebSocketMessageType::Close)
                {
                    log("TestConnectionDisconnection: disconnected !");
                }
                else if (msg->type == ix::WebSocketMessageType::Error)
                {
                    ss << "TestConnectionDisconnection: Error! ";
                    ss << msg->errorInfo.reason;
                    log(ss.str());
                }
                else if (msg->type == ix::WebSocketMessageType::Message)
                {
                    log("TestConnectionDisconnection: received message.!");
                }
                else if (msg->type == ix::WebSocketMessageType::Ping)
                {
                    log("TestConnectionDisconnection: received ping message.!");
                }
                else if (msg->type == ix::WebSocketMessageType::Pong)
                {
                    log("TestConnectionDisconnection: received pong message.!");
                }
                else if (msg->type == ix::WebSocketMessageType::Fragment)
                {
                    log("TestConnectionDisconnection: received fragment.!");
                }
                else
                {
                    log("Invalid ix::WebSocketMessageType");
                }
            });

        _webSocket.enableAutomaticReconnection();
        REQUIRE(_webSocket.isAutomaticReconnectionEnabled() == true);

        _webSocket.disableAutomaticReconnection();
        REQUIRE(_webSocket.isAutomaticReconnectionEnabled() == false);

        // Start the connection
        _webSocket.start();
    }
}

//
// We try to connect to different servers, and make sure there are no crashes.
// FIXME: We could do more checks (make sure that we were not able to connect to unknown servers, etc...)
//
TEST_CASE("websocket_connections", "[websocket]")
{
    SECTION("Try to connect to invalid servers.")
    {
        IXWebSocketTestConnectionDisconnection test;

        test.start(GOOGLE_URL);
        ix::msleep(1000);
        test.stop();

        test.start(UNKNOWN_URL);
        ix::msleep(1000);
        test.stop();
    }

    SECTION("Try to connect and disconnect with different timing, not enough time to succesfully connect")
    {
        IXWebSocketTestConnectionDisconnection test;
        log(std::string("50 Runs"));

        for (int i = 0; i < 50; ++i)
        {
            log(std::string("Run: ") + std::to_string(i));
            test.start(WEBSOCKET_DOT_ORG_URL);

            log(std::string("Sleeping"));
            ix::msleep(i);

            log(std::string("Stopping"));
            test.stop();
        }
    }

    // This test breaks on travis CI - Ubuntu Xenial + gcc + tsan
    // We should fix this.
    SECTION("Try to connect and disconnect with different timing, from not enough time to successfull connect")
    {
        IXWebSocketTestConnectionDisconnection test;
        log(std::string("20 Runs"));

        for (int i = 0; i < 20; ++i)
        {
            log(std::string("Run: ") + std::to_string(i));
            test.start(WEBSOCKET_DOT_ORG_URL);

            log(std::string("Sleeping"));
            ix::msleep(i*50);

            log(std::string("Stopping"));
            test.stop();
        }
    }
}