#include <chrono>
#include <cmath>
#include <fmt/core.h>
#include <thread>

#if !defined(_MSC_VER)
#include <unistd.h>
#endif

#include "ipc/api.hpp"

int
main(int /* argc */, char** /* argv */)
{
    using fmt::format;
    using fmt::print;
    using ipc::Ipc;
    using namespace std::chrono_literals;

    int verbose = 0;

    // custom name
#if defined(_WIN32)
    auto name = format("custom_fifo_ipc_{}", getpid());
#else
    auto name = format("/tmp/custom_fifo_ipc_{}", getpid());
#endif
    print("\n{}\n\n", name);
    ipc::init(name, 0600);

    std::thread server_thread([name, verbose] {
        print("[server] pre-start\n");
        std::this_thread::sleep_for(1s);

        auto server = Ipc(name, true, verbose);
        print("[server] start\n");

        int value;
        double result;
        while (1) {
            {
                server.read(value);
                print("[server] read int({})\n", value);
            }

            {
                // result = value * value;
                result = std::sqrt(value);
                server.write(result);
                print("[server] write double({:.2e})\n", result);
            }
        }
    });

    print("[client] pre-start\n");
    auto client = Ipc(name, false, verbose);
    print("[client] start\n");

    double answer;
    auto hline = "\n------------------------\n";
    for (int i = 2; i <= 5; ++i) {
        std::this_thread::sleep_for(500ms);
        print(hline);

        {
            client.write(i);
            print("[client] write int({})\n", i);
        }

        {
            client.read(answer);
            print("[client] read double({:.2e})\n", answer);
        }
    }

    print(hline);
    print("[client] finish the work\n\n");

    return 0;
}