src/wandac.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

#include "control_connection.hpp"

#include <boost/asio.hpp>

#include <filesystem>
#include <iostream>
#include <memory>

namespace
{
struct commander : wanda::control_connection::listener, std::enable_shared_from_this<commander>
{
    commander(boost::asio::io_service &service, std::filesystem::path socket)
        : m_endpoint{socket.string()},
          m_socket{service}
    {
    }

    void start()
    {
        m_socket.async_connect(m_endpoint, [&](auto const &error) {
            if (error)
            {
                std::cerr << "[commander::start] error occured: " << error.message() << '\n';
            }
            else
            {
                m_connection = wanda::make_control_connection(std::move(m_socket));
                m_connection->start();
                send("C:HELLO:1.0.0\n");
                m_connection->close();
            }
        });
    }

    void send(std::string message)
    {
        if (m_connection)
        {
            std::clog << "[commander::send] sending message: " << message;
            m_connection->send(std::move(message));
        }
    }

    void on_error(wanda::control_connection::pointer connection, boost::system::error_code error) override
    {
        std::cerr << "[commander::on_error] error occured: " << error.message() << '\n';
    }

  private:
    wanda::control_connection::protocol::endpoint m_endpoint;
    wanda::control_connection::protocol::socket m_socket;
    wanda::control_connection::pointer m_connection;
};
} // namespace

int main()
{
    auto service = boost::asio::io_service{};
    auto command_processor = commander{service, std::filesystem::path{".wanda_interface"}};

    command_processor.start();

    service.run();
}