mqtt::mqttcli::SocketContextFactory Class Reference

#include <SocketContextFactory.h>

Inheritance diagram for mqtt::mqttcli::SocketContextFactory:

Collaboration diagram for mqtt::mqttcli::SocketContextFactory:

Public Member Functions
	SocketContextFactory ()=default
core::socket::stream::SocketContext *	create (core::socket::stream::SocketConnection *socketConnection) final

Detailed Description

Definition at line 53 of file SocketContextFactory.h.

Constructor & Destructor Documentation

SocketContextFactory()

mqtt::mqttcli::SocketContextFactory::SocketContextFactory ( )

default

Member Function Documentation

create()

core::socket::stream::SocketContext * mqtt::mqttcli::SocketContextFactory::create ( core::socket::stream::SocketConnection * socketConnection )

final

Definition at line 62 of file SocketContextFactory.cpp.

                                                                                                                  {
        const CLI::App* sessionApp = socketConnection->getConfigInstance()->getSection("session", true, true);
        const CLI::App* subApp = socketConnection->getConfigInstance()->getSection("sub", true, true);
        const CLI::App* pubApp = socketConnection->getConfigInstance()->getSection("pub", true, true);
 
        subApp = (subApp != nullptr && (*subApp)["--topic"]->count() > 0) ? subApp : nullptr;
        pubApp = (pubApp != nullptr && (*pubApp)["--topic"]->count() > 0 && (*pubApp)["--message"]->count() > 0) ? pubApp : nullptr;
 
        core::socket::stream::SocketContext* socketContext = nullptr;
 
        if (subApp != nullptr || pubApp != nullptr) {
            socketContext = new iot::mqtt::SocketContext(
                socketConnection,
                new ::mqtt::mqttcli::lib::Mqtt(socketConnection->getConnectionName(),
                                               sessionApp != nullptr ? sessionApp->get_option("--client-id")->as<std::string>() : "",
                                               sessionApp != nullptr ? sessionApp->get_option("--qos")->as<uint8_t>() : 0,
                                               sessionApp != nullptr ? sessionApp->get_option("--keep-alive")->as<uint16_t>() : 60,
                                               sessionApp != nullptr ? !sessionApp->get_option("--retain-session")->as<bool>() : true,
                                               sessionApp != nullptr ? sessionApp->get_option("--will-topic")->as<std::string>() : "",
                                               sessionApp != nullptr ? sessionApp->get_option("--will-message")->as<std::string>() : "",
                                               sessionApp != nullptr ? sessionApp->get_option("--will-qos")->as<uint8_t>() : 0,
                                               sessionApp != nullptr ? sessionApp->get_option("--will-retain")->as<bool>() : false,
                                               sessionApp != nullptr ? sessionApp->get_option("--username")->as<std::string>() : "",
                                               sessionApp != nullptr ? sessionApp->get_option("--password")->as<std::string>() : "",
                                               subApp != nullptr ? subApp->get_option("--topic")->as<std::list<std::string>>()
                                                                 : std::list<std::string>(),
                                               pubApp != nullptr ? pubApp->get_option("--topic")->as<std::string>() : "",
                                               pubApp != nullptr ? pubApp->get_option("--message")->as<std::string>() : "",
                                               pubApp != nullptr ? pubApp->get_option("--retain")->as<bool>() : false));
        } else {
            VLOG(0) << "[" << Color::Code::FG_RED << "Error" << Color::Code::FG_DEFAULT << "] " << socketConnection->getConnectionName()
                    << ": one of 'sub' or 'pub' is required";
        }
 
        return socketContext;
    }

References mqtt::mqttcli::lib::Mqtt::Mqtt().

Here is the call graph for this function:

---

The documentation for this class was generated from the following files:

• mqttcli/SocketContextFactory.h
• mqttcli/SocketContextFactory.cpp