#include <stdlib.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

#include "faux/str.h"
#include "faux/async.h"
#include "faux/testc_helpers.h"

static bool_t stall_cb(faux_async_t *async, size_t len, void *user_data)
{
	bool_t *o_flag = (bool_t *)user_data;

	if (!o_flag)
		return BOOL_FALSE;
	*o_flag = BOOL_TRUE;
	printf("Stall callback %lu\n", len);

	async = async;

	return BOOL_TRUE;
}

int testc_faux_async(void)
{
	const size_t len = 9000000l;
	char *src_file = NULL;
	int ret = -1; // Pessimistic return value
	char *src_fn = NULL;
	char *dst_fn = NULL;
	unsigned int i = 0;
	unsigned char counter = 0;
	int fd = -1;
	faux_async_t *out = NULL;
	bool_t o_flag = BOOL_FALSE;

	// Prepare files
	src_file = faux_zmalloc(len);
	for (i = 0; i < len; i++) {
		src_file[i] = counter;
		counter++;
	}
	src_fn = faux_testc_tmpfile_deploy(src_file, len);

	dst_fn = faux_str_sprintf("%s/dst", getenv(FAUX_TESTC_TMPDIR_ENV));
	fd = open(dst_fn, O_WRONLY | O_CREAT | O_TRUNC, 0600);
	out = faux_async_new(fd);
	faux_async_set_stall_cb(out, stall_cb, &o_flag);
	faux_async_set_overflow(out, len + 1);
	if (faux_async_write(out, src_file, len) < 0) {
		fprintf(stderr, "faux_async_write() error\n");
		goto parse_error;
	}

	while (o_flag) {
		o_flag = BOOL_FALSE;
		faux_async_out(out);
	}

	if (faux_testc_file_cmp(dst_fn, src_fn) != 0) {
		fprintf(stderr, "Destination file %s is not equal to source %s\n",
			dst_fn, src_fn);
		goto parse_error;
	}

	ret = 0; // success

parse_error:
	faux_async_free(out);
	faux_str_free(dst_fn);
	faux_str_free(src_fn);

	return ret;
}