// SPDX-License-Identifier: MPL-2.0

#define _GNU_SOURCE

#include "../network/test.h"
#include <signal.h>
#include <string.h>
#include <sys/poll.h>
#include <unistd.h>

FN_SETUP()
{
	signal(SIGPIPE, SIG_IGN);
}
END_SETUP()

FN_TEST(close_without_data_then_read)
{
	int fildes[2];
	char buf[8] = { 0 };

	CHECK(pipe(fildes));

	TEST_SUCC(close(fildes[1]));

	TEST_RES(read(fildes[0], buf, sizeof(buf)), _ret == 0);
	TEST_ERRNO(write(fildes[0], buf, sizeof(buf)), EBADF);

	TEST_RES(read(fildes[0], buf, 0), _ret == 0);
	TEST_ERRNO(write(fildes[0], buf, 0), EBADF);

	TEST_SUCC(close(fildes[0]));
}
END_TEST()

FN_TEST(close_without_data_then_write)
{
	int fildes[2];
	char buf[8] = { 0 };

	CHECK(pipe(fildes));

	TEST_SUCC(close(fildes[0]));

	TEST_ERRNO(read(fildes[1], buf, sizeof(buf)), EBADF);
	TEST_ERRNO(write(fildes[1], buf, sizeof(buf)), EPIPE);

	TEST_ERRNO(read(fildes[1], buf, 0), EBADF);
	TEST_RES(write(fildes[1], buf, 0), _ret == 0);

	TEST_SUCC(close(fildes[1]));
}
END_TEST()

FN_TEST(close_with_data_then_read)
{
	int fildes[2];
	char buf[8] = { 0 };

	CHECK(pipe(fildes));

	TEST_RES(write(fildes[1], "hello", 5), _ret == 5);
	TEST_SUCC(close(fildes[1]));

	TEST_RES(read(fildes[0], buf, 2),
		 _ret == 2 && strncmp(buf, "he", 2) == 0);
	TEST_RES(read(fildes[0], buf, sizeof(buf)),
		 _ret == 3 && strncmp(buf, "llo", 3) == 0);

	TEST_RES(read(fildes[0], buf, sizeof(buf)), _ret == 0);
	TEST_ERRNO(write(fildes[0], buf, sizeof(buf)), EBADF);

	TEST_RES(read(fildes[0], buf, 0), _ret == 0);
	TEST_ERRNO(write(fildes[0], buf, 0), EBADF);

	TEST_SUCC(close(fildes[0]));
}
END_TEST()

FN_TEST(close_with_data_then_write)
{
	int fildes[2];
	char buf[8] = { 0 };

	CHECK(pipe(fildes));

	TEST_RES(write(fildes[1], "hello", 5), _ret == 5);
	TEST_SUCC(close(fildes[0]));

	TEST_ERRNO(read(fildes[1], buf, sizeof(buf)), EBADF);
	TEST_ERRNO(write(fildes[1], buf, sizeof(buf)), EPIPE);

	TEST_ERRNO(read(fildes[1], buf, 0), EBADF);
	TEST_RES(write(fildes[1], buf, 0), _ret == 0);

	TEST_SUCC(close(fildes[1]));
}
END_TEST()

#define POLL_MASK (POLLIN | POLLOUT | POLLHUP | POLLERR)

FN_TEST(poll_basic)
{
	int fildes[2];
	char buf[8];
	struct pollfd pfd = { .events = POLL_MASK };

	CHECK(pipe(fildes));

	pfd.fd = fildes[0];
	TEST_RES(poll(&pfd, 1, 0), (pfd.revents & POLL_MASK) == 0);

	pfd.fd = fildes[1];
	TEST_RES(poll(&pfd, 1, 0), (pfd.revents & POLL_MASK) == POLLOUT);

	TEST_RES(write(fildes[1], "hello", 5), _ret == 5);

	pfd.fd = fildes[0];
	TEST_RES(poll(&pfd, 1, 0), (pfd.revents & POLL_MASK) == POLLIN);

	pfd.fd = fildes[1];
	TEST_RES(poll(&pfd, 1, 0), (pfd.revents & POLL_MASK) == POLLOUT);

	TEST_RES(read(fildes[0], buf, sizeof(buf)), _ret == 5);

	pfd.fd = fildes[0];
	TEST_RES(poll(&pfd, 1, 0), (pfd.revents & POLL_MASK) == 0);

	pfd.fd = fildes[1];
	TEST_RES(poll(&pfd, 1, 0), (pfd.revents & POLL_MASK) == POLLOUT);

	TEST_SUCC(close(fildes[0]));
	TEST_SUCC(close(fildes[1]));
}
END_TEST()

FN_TEST(close_first_then_poll)
{
	int fildes[2];
	struct pollfd pfd = { .events = POLLIN | POLLOUT };

	CHECK(pipe(fildes));

	TEST_RES(write(fildes[1], "hello", 5), _ret == 5);
	TEST_SUCC(close(fildes[0]));

	pfd.fd = fildes[1];
	TEST_RES(poll(&pfd, 1, 0),
		 (pfd.revents & POLL_MASK) == (POLLOUT | POLLERR));

	TEST_SUCC(close(fildes[1]));
}
END_TEST()

FN_TEST(close_second_then_poll)
{
	int fildes[2];
	char buf[8];
	struct pollfd pfd = { .events = POLLIN | POLLOUT };

	CHECK(pipe(fildes));

	TEST_RES(write(fildes[1], "hello", 5), _ret == 5);
	TEST_SUCC(close(fildes[1]));

	pfd.fd = fildes[0];
	TEST_RES(poll(&pfd, 1, 0),
		 (pfd.revents & POLL_MASK) == (POLLIN | POLLHUP));

	TEST_RES(read(fildes[0], buf, sizeof(buf)),
		 _ret == 5 && strncmp(buf, "hello", 5) == 0);

	pfd.fd = fildes[0];
	TEST_RES(poll(&pfd, 1, 0), (pfd.revents & POLL_MASK) == POLLHUP);

	TEST_SUCC(close(fildes[0]));
}
END_TEST()