std::string timed_read_line(boost::asio::streambuf& buffer, boost::asio::ip::tcp::socket& sock) {
    namespace asio = boost::asio;
    using boost::system::error_code;
    
    std::condition_variable cv;
    std::mutex mut;
    error_code op_error = error_code();
    bool done = false;
    
    auto get_lock = [&] { return std::unique_lock<std::mutex>(mut); };
    
    auto read_handler = [&](error_code ec, std::size_t sz)
    {
        auto lock = get_lock();
        if (not done)
        {
            done = true;
            op_error = ec;
        }
        lock.unlock();
        cv.notify_one();
    };
    
    auto timer_handler = [&](error_code ec)
    {
        auto lock = get_lock();
        if (not done)
        {
            done = true;
            op_error = asio::error::timed_out;
        }
    };

    
    asio::async_read_until(sock, buffer, '\n', read_handler);
    asio::deadline_timer timer(sock.get_io_context(), boost::posix_time::seconds(3));
    timer.async_wait(timer_handler);
    
    auto lock = get_lock();
    cv.wait(lock, [&]{return done; });
    
    if (op_error)
    {
        throw boost::system::system_error(op_error);
    } else {
        std::istream is(std::addressof(buffer));
        std::string result;
        std::getline(is, result);
        return result;
    }
};