// Copyright (c) 2009 Dmitry Goncharov
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)

#include <iostream>
#include <iomanip>
#include <string>
#include <boost/bind.hpp>
#include <boost/system/system_error.hpp>
#include <boost/asio/io_service.hpp>
#include <boost/asio/posix/stream_descriptor.hpp>
#include <boost/asio/posix/signal_handler.hpp>

using std::cout;
using std::cin;
using std::endl;
using std::cerr;
using std::flush;

namespace ba = boost::asio;
namespace bap = boost::asio::posix;

void on_signal(boost::system::error_code const& error, int signo)
{
    if (!error)
        cout << "signal #" << signo << " received" << endl << "# " << flush;
}

void on_stdin(boost::system::error_code const& error, char const* buf, std::size_t buflen, int* running)
{
    if (!error)
    {
        assert(buflen >= 1 && "Incorrect usage of boost::asio");
        cout << "activity on stdin: " << std::string(buf, buflen - 1) << endl << "# " << flush;
    }
    else
    {
        cout << "stdin error: " << error << endl;
        if (ba::error::eof == error)
        {
            cout << "stdin closed." << flush;
            *running = 0;
        }
    }
}

int main(int argc, char const* argv[])
{
    ba::io_service ios;

    bap::signal_handler<SIGINT> sigint(ios);
    bap::signal_handler<SIGTERM> sigterm(ios);

    bap::stream_descriptor std_in(ios, STDIN_FILENO);

    cout << "Type to watch stdin activity. Send signals to watch the program react. Use ^D to exit" << endl << "# " << flush;

    int running = 1;
    while (running)
    {
        ios.reset();

        sigint.async_wait(boost::bind(on_signal, _1, SIGINT));
        sigterm.async_wait(boost::bind(on_signal, _1, SIGTERM));

        char buf[1024];
        std_in.async_read_some(ba::buffer(buf, sizeof buf), boost::bind(on_stdin, _1, buf, _2, &running));

        ios.poll();
    }
    cout << " Bye" << endl;
}