// This file is part of CAF, the C++ Actor Framework. See the file LICENSE in
// the main distribution directory for license terms and copyright or visit
// https://github.com/actor-framework/actor-framework/blob/master/LICENSE.

#define CAF_SUITE pipe_socket

#include "caf/net/pipe_socket.hpp"

#include "caf/net/test/host_fixture.hpp"
#include "caf/test/dsl.hpp"

#include "caf/byte.hpp"
#include "caf/byte_buffer.hpp"

using namespace caf;
using namespace caf::net;

CAF_TEST_FIXTURE_SCOPE(pipe_socket_tests, host_fixture)

CAF_TEST(send and receive) {
  byte_buffer send_buf{byte(1), byte(2), byte(3), byte(4),
                       byte(5), byte(6), byte(7), byte(8)};
  byte_buffer receive_buf;
  receive_buf.resize(100);
  pipe_socket rd_sock;
  pipe_socket wr_sock;
  std::tie(rd_sock, wr_sock) = unbox(make_pipe());
  CAF_CHECK_EQUAL(static_cast<size_t>(write(wr_sock, send_buf)),
                  send_buf.size());
  CAF_CHECK_EQUAL(static_cast<size_t>(read(rd_sock, receive_buf)),
                  send_buf.size());
  CAF_CHECK(std::equal(send_buf.begin(), send_buf.end(), receive_buf.begin()));
}

CAF_TEST_FIXTURE_SCOPE_END()