#include <boost/asio.hpp>
#include <boost/asio/spawn.hpp>
#include <boost/process.hpp>
#include <chrono>
#include <iostream>

void test_process()
{
  static const char* path = "./dataspit.py";
  static const char* interpreter = "python3";

  std::cout << "Hello from streamer2\n";

  namespace asio = boost::asio;
  namespace process = boost::process;
  namespace chrono = std::chrono;

  asio::io_context ioc;

  asio::spawn(ioc,
    [&ioc](asio::yield_context yield)
    {
      process::async_pipe pipe{ioc};
      auto child = process::child{process::search_path(interpreter), path,
                                  process::std_out > pipe};

      std::array<char, 4096> buffer{0};

      std::cout <<  "Buffer state: " << (int)buffer[0] << (int)buffer[1] << std::endl;
      boost::system::error_code read_ec;
      do
      {
        auto timePoint = chrono::system_clock::now();
        std::cout << timePoint.time_since_epoch().count() << ": Sleeping\n";

        std::size_t size = pipe.async_read_some(asio::buffer(buffer), yield[read_ec]);

        if (read_ec) {
            std::cerr << read_ec.message() << std::endl;
            break;
        }

        timePoint = chrono::system_clock::now();
        std::cout << timePoint.time_since_epoch().count() << ": Read " << size << " bytes\n";
        std::cout <<  "Buffer state: " << (int)buffer[0] << (int)buffer[1] << std::endl;
      }
      while (read_ec != boost::asio::error::eof);

      child.wait();
    }
  );

  ioc.run();

  std::cout << "Farewell from streamer2\n";
}

int main(int argc, char** argv)
{
  test_process();
  return 0;
}