echoclient.cpp File Reference

#include "core/SNodeC.h"
#include "web/http/legacy/in/Client.h"
#include "web/http/tls/in/Client.h"

Include dependency graph for echoclient.cpp:

Go to the source code of this file.

Functions
int	main (int argc, char *argv[])

Function Documentation

main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 54 of file echoclient.cpp.

                                 {
    core::SNodeC::init(argc, argv);
 
    {
        using LegacyClient = web::http::legacy::in::Client;
        using MasterRequest = LegacyClient::MasterRequest;
        using Request = LegacyClient::Request;
        using Response = LegacyClient::Response;
        using LegacySocketAddress = LegacyClient::SocketAddress;
 
        const LegacyClient legacyClient(
            "legacy",
            [](const std::shared_ptr<MasterRequest>& req) {
                const std::string connectionName = req->getSocketContext()->getSocketConnection()->getConnectionName();
 
                VLOG(1) << connectionName << ": OnRequestBegin";
 
                req->set("Sec-WebSocket-Protocol", "subprotocol, echo");
 
                req->upgrade(
                    "/ws",
                    "websocket",
                    [connectionName](bool success) {
                        VLOG(1) << connectionName << ": HTTP Upgrade (http -> websocket) start " << (success ? "success" : "failed");
                    },
                    [connectionName]([[maybe_unused]] const std::shared_ptr<Request>& req,
                                     const std::shared_ptr<Response>& res,
                                     [[maybe_unused]] bool success) {
                        VLOG(1) << connectionName << ": Upgrade success:";
 
                        VLOG(1) << connectionName << ":   Requested: " << req->header("upgrade");
                        VLOG(1) << connectionName << ":    Selected: " << res->get("upgrade");
                    },
                    [connectionName](const std::shared_ptr<Request>&, const std::string& message) {
                        VLOG(1) << connectionName << ": Request parse error: " << message;
                    });
            },
            []([[maybe_unused]] const std::shared_ptr<MasterRequest>& req) {
                const std::string connectionName = req->getSocketContext()->getSocketConnection()->getConnectionName();
 
                VLOG(1) << connectionName << ": OnRequestEnd";
            });
 
        legacyClient.connect([instanceName = legacyClient.getConfig().getInstanceName()](const LegacySocketAddress& socketAddress,
                                                                                         const core::socket::State& state) {
            switch (state) {
                case core::socket::State::OK:
                    VLOG(1) << instanceName << " connected to '" << socketAddress.toString() << "'";
                    break;
                case core::socket::State::DISABLED:
                    VLOG(1) << instanceName << " disabled";
                    break;
                case core::socket::State::ERROR:
                    VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
                    break;
                case core::socket::State::FATAL:
                    VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
                    break;
            }
        }); // Connection:keep-alive\r\n\r\n"
 
        using TlsClient = web::http::tls::in::Client;
        using MasterRequest = TlsClient::MasterRequest;
        using Request = TlsClient::Request;
        using Response = TlsClient::Response;
        using TLSSocketAddress = TlsClient::SocketAddress;
 
        const TlsClient tlsClient(
            "tls",
            [](const std::shared_ptr<MasterRequest>& req) {
                const std::string connectionName = req->getSocketContext()->getSocketConnection()->getConnectionName();
 
                VLOG(1) << connectionName << ": OnRequestBegin";
 
                req->set("Sec-WebSocket-Protocol", "subprotocol, echo");
 
                req->upgrade(
                    "/ws",
                    "websocket",
                    [connectionName](bool success) {
                        VLOG(1) << connectionName << ": HTTP Upgrade (http -> websocket) start " << (success ? "success" : "failed");
                    },
                    [connectionName]([[maybe_unused]] const std::shared_ptr<Request>& req,
                                     [[maybe_unused]] const std::shared_ptr<Response>& res,
                                     [[maybe_unused]] bool success) {
                    },
                    [connectionName](const std::shared_ptr<Request>&, const std::string& message) {
                        VLOG(1) << connectionName << ": Request parse error: " << message;
                    });
            },
            []([[maybe_unused]] const std::shared_ptr<MasterRequest>& req) {
                const std::string connectionName = req->getSocketContext()->getSocketConnection()->getConnectionName();
 
                VLOG(1) << connectionName << ": OnRequestEnd";
            });
 
        tlsClient.connect([instanceName = tlsClient.getConfig().getInstanceName()](const TLSSocketAddress& socketAddress,
                                                                                   const core::socket::State& state) {
            switch (state) {
                case core::socket::State::OK:
                    VLOG(1) << instanceName << " connected to '" << socketAddress.toString() << "'";
                    break;
                case core::socket::State::DISABLED:
                    VLOG(1) << instanceName << " disabled";
                    break;
                case core::socket::State::ERROR:
                    VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
                    break;
                case core::socket::State::FATAL:
                    VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
                    break;
            }
        }); // Connection:keep-alive\r\n\r\n"
    }
 
    return core::SNodeC::start();
}

References web::http::client::Client< SocketClientT >::Client(), core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::connect(), core::socket::State::DISABLED, core::socket::State::ERROR, core::socket::State::FATAL, web::http::client::Response::get(), core::socket::Socket< ConfigT >::getConfig(), core::socket::stream::SocketConnection::getConnectionName(), net::config::ConfigInstance::getInstanceName(), core::socket::stream::SocketContext::getSocketConnection(), web::http::client::Request::getSocketContext(), web::http::client::Request::header(), core::SNodeC::init(), core::socket::State::OK, web::http::client::Request::set(), core::SNodeC::start(), net::in::SocketAddress::toString(), web::http::client::MasterRequest::upgrade(), and core::socket::State::what().

Here is the call graph for this function: