/* Copyright (C) The libssh2 project and its contributors.
 *
 * SPDX-License-Identifier: BSD-3-Clause
 */
#include <assert.h>
#include <errno.h>
#include <stdbool.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <unistd.h>
#include <libssh2.h>
#include "testinput.h"

#define FUZZ_ASSERT(COND)                                                     \
    do {                                                                      \
        if(!(COND))                                                           \
        {                                                                     \
            fprintf(stderr, "Assertion failed: " #COND "\n%s",                \
                    strerror(errno));                                         \
            assert((COND));                                                   \
        }                                                                     \
    } while(0)

extern "C" int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size)
{
    int socket_fds[2] = {-1, -1};
    ssize_t written;
    int rc;
    LIBSSH2_SESSION *session = NULL;
    int handshake_completed = 0;

    rc = libssh2_init(0);

    if(rc) {
        fprintf(stderr, "libssh2 initialization failed (%d)\n", rc);
        goto EXIT_LABEL;
    }

    /* Create a socket pair so data can be sent in. */
    rc = socketpair(AF_UNIX, SOCK_STREAM, 0, socket_fds);
    FUZZ_ASSERT(rc == 0);

    written = send(socket_fds[1], data, size, 0);

    if(written != (ssize_t)size) {
        /* Handle whatever error case we're in. */
        fprintf(stderr, "send() of %zu bytes returned %zu (%d)\n",
                size,
                written,
                errno);
        goto EXIT_LABEL;
    }

    rc = shutdown(socket_fds[1], SHUT_WR);
    if(rc) {
        fprintf(stderr, "socket shutdown failed (%d)\n", rc);
        goto EXIT_LABEL;
    }

    /* Create a session and start the handshake using the fuzz data
       passed in. */
    session = libssh2_session_init();
    if(session) {
        libssh2_session_set_blocking(session, 1);
    }
    else {
        goto EXIT_LABEL;
    }

    if(libssh2_session_handshake(session, socket_fds[0])) {
        goto EXIT_LABEL;
    }

    /* If we get here the handshake actually completed. */
    handshake_completed = 1;

EXIT_LABEL:

    if(session) {
        if(handshake_completed) {
            libssh2_session_disconnect(session,
                                       "Normal Shutdown, "
                                       "Thank you for playing");
        }

        libssh2_session_free(session);
    }

    libssh2_exit();

    close(socket_fds[0]);
    close(socket_fds[1]);

    return 0;
}