#include <stddef.h>

#include <stdint.h>

#include <sys/types.h>

#include <sys/stat.h>

#include <fcntl.h>

#include "config.h"

#include "recvbuff.h"

#include "ntpd.h"

const char *Version = "libntpq 0.3beta";

int listen_to_virtual_ips = TRUE;

int mdnstries = 5;

char const *progname = "fuzz_ntpd_receive";

#ifdef HAVE_WORKING_FORK

int    waitsync_fd_to_close = -1;    /* -w/--wait-sync */

int    daemon_pipe[2] = { -1, -1 };

#endif

static int initialized = 0;

int sockfd;

uint8_t itf_index;

void fuzz_itf_selecter(void * data, interface_info_t * itf) {

    endpt **ep = (endpt **)data;

    if (itf_index == 0) {

        *ep = itf->ep;

    }

    itf_index--;

}

int LLVMFuzzerTestOneInput(const uint8_t* Data, size_t Size) {

    struct recvbuf rbufp;

    struct sockaddr_in addr;

    // Initialize the address to prevent an assertion failure in restrictions()

    addr.sin_family = AF_INET;

    addr.sin_port = htons(123);

    addr.sin_addr.s_addr = htonl(0x7f000001);

    rbufp.recv_srcadr.sa4 = addr;

    //memcpy(&rbufp.recv_srcadr, &addr, sizeof(struct sockaddr_in));

    if (initialized == 0) {

        sockfd = open("/dev/null", O_RDWR );

        //adds interfaces

        init_io();

        init_auth();

        init_util();

        init_restrict();

        init_mon();

        init_timer();

        init_lib();

        init_request();

        init_control();

        init_peer();

        init_proto();

        init_loopfilter();

        io_open_sockets();

        initialized = 1;

    }

    if (Size < sizeof(l_fp)) {

        return 0;

    }

    memcpy(&rbufp.recv_time, Data, sizeof(l_fp));

    Data += sizeof(l_fp);

    Size -= sizeof(l_fp);

    if (Size < 1) {

        return 0;

    }

    itf_index = Data[0];

    rbufp.dstadr = NULL;

    interface_enumerate(fuzz_itf_selecter, &rbufp.dstadr);

    if (rbufp.dstadr == NULL) {

        return 0;

    }

    Data++;

    Size--;

    if (Size > RX_BUFF_SIZE) {

        Size = RX_BUFF_SIZE;

    }

    rbufp.recv_length = Size;

    memcpy(rbufp.recv_buffer, Data, Size);

    rbufp.msg_flags = 0;

    rbufp.used = 0;

    rbufp.link = NULL;

    rbufp.fd = sockfd;

    receive(&rbufp);

    return 0;

}