client.cpp

#include "message.hpp"
#include <iostream>
#include <boost/asio.hpp>

using boost::asio::ip::tcp;


void async_read(tcp::socket &socket) {
    auto buffer = std::make_shared<boost::asio::streambuf>();
    boost::asio::async_read_until(socket, *buffer, "\n",
        [&socket, buffer](boost::system::error_code ec, std::size_t length) {
            if (!ec) {
                std::istream is(buffer.get());
                std::string received;
                std::getline(is, received);
                std::cout << "Server: " << received << std::endl;
                async_read(socket); 
            }
        }
    );
}

int main(int argc, char* argv[]){
    if(argc < 2){
        std::cerr << "Provide port too as second argument" << std::endl;
        return 1;
    }
    
    boost::asio::io_context io_context;
    tcp::socket socket(io_context);
    tcp::resolver resolver(io_context);

    boost::asio::connect(socket, resolver.resolve("127.0.0.1", argv[1]));

    async_read(socket);

    std::thread t([&io_context, &socket]() {
        while (true) {
            std::string data;
            std::cout << "Enter message: ";
            std::getline(std::cin, data);
            data += "\n";

            boost::asio::post(io_context, [&, data]() {
                boost::asio::write(socket, boost::asio::buffer(data));
            });
        }
    });

    io_context.run();
    t.join();

    return 0;
}