/*
 * Copyright (c) 2023-2024 Ian Marco Moffett and the Osmora Team.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * 1. Redistributions of source code must retain the above copyright notice,
 *    this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the name of Hyra nor the names of its
 *    contributors may be used to endorse or promote products derived from
 *    this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */

#include <sys/filedesc.h>
#include <sys/proc.h>
#include <sys/sched.h>
#include <sys/errno.h>
#include <sys/system.h>
#include <sys/syslog.h>
#include <sys/vnode.h>
#include <vm/dynalloc.h>
#include <dev/vcons/vcons.h>
#include <assert.h>
#include <string.h>

/*
 * This function is a helper for write(). It creates
 * a buffer and copies write data to it.
 *
 * @td: Current thread.
 * @data: Data to copy.
 * @buf_out: Pointer to buffer that will store data.
 * @count: Number of bytes.
 */
static int
make_write_buf(struct proc *td, const void *data, char **buf_out, size_t count)
{
    const size_t MAX_COUNT = 0x7FFFF000;
    char *buf = NULL;

    if (count > MAX_COUNT) {
        return -EINVAL;
    }

    buf = dynalloc(count);

    if (buf == NULL) {
        return -ENOMEM;
    }

    __assert(buf_out != NULL);
    *buf_out = buf;

    memset(buf, 0, count);

    if (td->is_user) {
        /*
         * A user process called us, so we want to be careful
         * and use copyin()
         */
        copyin((uintptr_t)data, buf, count);
    } else {
        /* Can just memcpy() here */
        memcpy(buf, (char *)data, count);
    }

    return 0;
}

/*
 * Helper function for write()
 */
static ssize_t
do_write(struct vnode *vp, const char *buf, size_t count)
{
    struct vops *vops = vp->vops;
    int status;

    __assert(vops != NULL);

    /* Can we call the write operation? */
    if (vops->write == NULL) {
        return -EACCES;
    }

    /* Attempt a write */
    if ((status = vops->write(vp, buf, count)) < 0) {
        return status;
    }

    return count;
}

/*
 * Allocate a file descriptor.
 *
 * @td: Thread to allocate from, NULL for current thread.
 */
struct filedesc *
fd_alloc(struct proc *td)
{
    struct filedesc *fd;

    if (td == NULL) {
        td = this_td();
        __assert(td != NULL);
    }

    for (size_t i = 0; i < PROC_MAX_FDS; ++i) {
        if (td->fds[i] != NULL) {
            continue;
        }

        fd = dynalloc(sizeof(struct filedesc));
        memset(fd, 0, sizeof(struct filedesc));

        if (fd == NULL) {
            return NULL;
        }

        fd->fdno = i;
        td->fds[i] = fd;
        return fd;
    }

    return NULL;
}

/*
 * Fetch a file descriptor from a file descriptor
 * number.
 *
 * @td: Thread to fetch from, NULL for current thread.
 * @fdno: File descriptor to fetch
 */
struct filedesc *
fd_from_fdnum(const struct proc *td, int fdno)
{
    if (td == NULL) {
        td = this_td();
        __assert(td != NULL);
    }

    if (fdno < 0 || fdno > PROC_MAX_FDS) {
        return NULL;
    }

    for (size_t i = 0; i < PROC_MAX_FDS; ++i) {
        if (i == fdno && td->fds[i] != NULL) {
            return td->fds[i];
        }
    }

    return NULL;
}

/*
 * Close a file descriptor from its fd number.
 *
 * @td: Thread to fetch from, NULL for current thread.
 * @fdno: File descriptor number to close.
 */
void
fd_close_fdnum(struct proc *td, int fdno)
{
    struct filedesc *fd;

    if (td == NULL) {
        td = this_td();
        __assert(td != NULL);
    }

    fd = fd_from_fdnum(td, fdno);
    if (fd == NULL) {
        return;
    }

    dynfree(fd);
    td->fds[fdno] = NULL;
}

ssize_t
write(int fd, const void *buf, size_t count)
{
    struct proc *td = this_td();
    struct filedesc *desc = NULL;
    struct vnode *vp = NULL;
    char *in_buf = NULL;

    ssize_t ret = count;
    int status;

    /*
     * Create our write buffer... Memory will be allocated
     * and data copied.
     */
    if ((status = make_write_buf(td, buf, &in_buf, count)) != 0) {
        return status;
    }

    /* Is this stdout/stderr? */
    if (fd == 1 || fd == 2) {
        /* TODO: Update this when we have PTYs */
        vcons_putstr(&g_syslog_screen, in_buf, count);
        return count;
    }

    desc = fd_from_fdnum(td, fd);

    /* Does this file descriptor exist */
    if (desc == NULL) {
        ret = -EBADF;
        goto cleanup;
    }

    /* Do we have a vnode? */
    if (desc->vnode == NULL) {
        ret = -EACCES;
        goto cleanup;
    }

    vp = desc->vnode;
    status = do_write(vp, in_buf, count);

    if (status < 0) {
        ret = status;
        goto cleanup;
    }
cleanup:
    dynfree(in_buf);
    return ret;
}

/*
 * arg0: int fd
 * arg1: const void *buf
 * arg2: count
 */
uint64_t
sys_write(struct syscall_args *args)
{
    return write(args->arg0, (void *)args->arg1, args->arg2);
}