/*
 * mon_util.c - Utilities for the VICE built-in monitor.
 *
 * Written by
 *  Spiro Trikaliotis <spiro.trikaliotis@gmx.de>
 *
 * This file is part of VICE, the Versatile Commodore Emulator.
 * See README for copyright notice.
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
 *  02111-1307  USA.
 *
 */

#include "vice.h"

#include <assert.h>
#include <ctype.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>

#include "ui.h"

#include "archdep.h"
#include "charset.h"
#include "console.h"
#include "lib.h"
#include "mem.h"
#include "mon_disassemble.h"
#include "mon_util.h"
#include "monitor.h"
#include "monitor_network.h"
#include "monitor_binary.h"
#include "vicesocket.h"
#include "types.h"
#include "uimon.h"
#include "vsyncapi.h"

/*#define DEBUG_MONUTIL*/

#ifdef DEBUG_MONUTIL
#define DBG(x)  log_printf x
#else
#define DBG(x)
#endif

static char *bigbuffer = NULL;
static const unsigned int bigbuffersize = 10000;
static unsigned int bigbufferwrite = 0;
static unsigned int bigbuffermode = 0; /* 0: ascii, 1: petscii, 2: scrcode, 3: petscii (uppercase), 4: scrcode (uppercase) */

static FILE *mon_log_file = NULL;

/******************************************************************************/

int mon_log_file_open(const char *name)
{
    FILE *fp;

    if (name) {
        /* if file exists, append to existing file */
        fp = fopen(name, MODE_APPEND);
        if (fp) {
            /* close old logfile */
            mon_log_file_close();
            mon_log_file = fp;
            return 0;
        }
    }
    return -1;
}

void mon_log_file_close(void)
{
    if (mon_log_file) {
        fclose(mon_log_file);
    }
    mon_log_file = NULL;
}

static int mon_log_file_out(const char *buffer)
{
    size_t len;

    if ((mon_log_file) && (buffer)) {
        len = strlen(buffer);
        if (fwrite(buffer, 1, len, mon_log_file) == len) {
            return 0;
        }
    }
    return -1;
}

/******************************************************************************/

static void mon_buffer_alloc(void)
{
    if (!bigbuffer) {
        bigbuffer = lib_malloc(bigbuffersize + 1);
        bigbuffer[bigbuffersize] = 0;
    }
}

static int mon_buffer_flush(void)
{
    int rv = 0;

    if (bigbuffer && bigbufferwrite) {
        switch (bigbuffermode) {
            case 0:
                rv = uimon_out(bigbuffer);
                break;
            case 1:
                rv = uimon_petscii_out(bigbuffer, bigbufferwrite);
                break;
            case 2:
                rv = uimon_scrcode_out(bigbuffer, bigbufferwrite);
                break;
            case 3:
                rv = uimon_petscii_upper_out(bigbuffer, bigbufferwrite);
                break;
            case 4:
                rv = uimon_scrcode_upper_out(bigbuffer, bigbufferwrite);
                break;
        }
        bigbufferwrite = 0;
    }

    return rv;
}

/* like strncpy, but:
 * 1. always add a null character
 * 2. do not fill the rest of the buffer
 */
static void stringcopy_n(char *dest, const char *src, unsigned int len)
{
    while (*src && len--) {
        *dest++ = *src++;
    }

    *dest = 0;
}

static void mon_buffer_add(const char *buffer, unsigned int bufferlen)
{
    if (bigbufferwrite + bufferlen > bigbuffersize) {
        /* the buffer does not fit into bigbuffer, thus,
           flush the buffer! */
        mon_buffer_flush();
    }

    if (bigbufferwrite + bufferlen <= bigbuffersize) {
        stringcopy_n(&bigbuffer[bigbufferwrite], buffer, bufferlen);
        bigbufferwrite += bufferlen;

        assert(bigbufferwrite <= bigbuffersize);
    }
}

/*! \internal \brief Notify interested interfaces that the monitor opened.
*/
void mon_event_opened(void) {
    #ifdef HAVE_NETWORK
        if (monitor_is_binary()) {
            monitor_binary_event_opened();
        }
    #endif
}

/*! \internal \brief Notify interested interfaces that the monitor closed.
*/
void mon_event_closed(void) {
    #ifdef HAVE_NETWORK
        if (monitor_is_binary()) {
            monitor_binary_event_closed();
        }
    #endif
}

static int mon_out_buffered(const char *buffer, int mode, int maxlen)
{
    int rv = 0;
    int len;

    DBG(("console_log:%p console_cannot_output:%d",
         console_log, console_log ? console_log->console_cannot_output : -1));

    if (!console_log || console_log->console_cannot_output) {

        if (mode != bigbuffermode) {
            rv = mon_buffer_flush();
            bigbuffermode = mode;
        }

        mon_buffer_alloc();
        /* FIXME: convert to mode */
        if (mode == 0) {
            len = (int)strlen(buffer);
        } else {
            len = maxlen;
        }
        mon_buffer_add(buffer, (unsigned int)len);
    } else {
        /* flush buffer in old mode */
        rv = mon_buffer_flush();
        bigbuffermode = mode;
        switch (mode) {
            case 0:
                rv = uimon_out(buffer) || rv;
                break;
            case 1:
                rv = uimon_petscii_out(buffer, maxlen) || rv;
                break;
            case 2:
                rv = uimon_scrcode_out(buffer, maxlen) || rv;
                break;
            case 3:
                rv = uimon_petscii_upper_out(buffer, maxlen) || rv;
                break;
            case 4:
                rv = uimon_scrcode_upper_out(buffer, maxlen) || rv;
                break;
        }
    }

    return rv;
}

int mon_out(const char *format, ...)
{
    va_list ap;
    char *buffer;
    int rc = 0;

    va_start(ap, format);
    buffer = lib_mvsprintf(format, ap);
    va_end(ap);

#ifdef HAVE_NETWORK
    if (monitor_is_remote()) {
        rc = monitor_network_transmit(buffer, strlen(buffer));
    } else {
#endif
        rc = mon_out_buffered(buffer, 0, (int)strlen(buffer));
#ifdef HAVE_NETWORK
    }
#endif
    mon_log_file_out(buffer);

    lib_free(buffer);

    if (rc < 0) {
        monitor_abort();
    }

    return rc;
}

int mon_petscii_out(int maxlen, const char *format, ...)
{
    va_list ap;
    char *buffer;
    int rc = 0;

    va_start(ap, format);
    buffer = lib_mvsprintf(format, ap);
    va_end(ap);

#ifdef HAVE_NETWORK
    if (monitor_is_remote()) {
        int n;
        for (n = 0; n < maxlen; n++) {
            buffer[n] = charset_p_toascii(buffer[n], CONVERT_WITH_CTRLCODES);
        }
        rc = monitor_network_transmit(buffer, maxlen);
    } else {
#endif
        rc = mon_out_buffered(buffer, 1, maxlen);
#ifdef HAVE_NETWORK
    }
#endif
    mon_log_file_out(buffer);

    lib_free(buffer);

    if (rc < 0) {
        monitor_abort();
    }

    return rc;
}

int mon_petscii_upper_out(int maxlen, const char *format, ...)
{
    va_list ap;
    char *buffer;
    int rc = 0;

    va_start(ap, format);
    buffer = lib_mvsprintf(format, ap);
    va_end(ap);

#ifdef HAVE_NETWORK
    if (monitor_is_remote()) {
        int n, c;
        for (n = 0; n < maxlen; n++) {
            c = buffer[n];
            if ((c >= 0x01) && (c <= 0x1a)) {
                c += 0x60; /* upper */
            } else if ((c >= 0x41) && (c <= 0x5a)) {
                c += 0x20; /* upper */
            }
            buffer[n] = charset_p_toascii(c, CONVERT_WITH_CTRLCODES);
        }
        rc = monitor_network_transmit(buffer, maxlen);
    } else {
#endif
        rc = mon_out_buffered(buffer, 3, maxlen);
#ifdef HAVE_NETWORK
    }
#endif
    mon_log_file_out(buffer);

    lib_free(buffer);

    if (rc < 0) {
        monitor_abort();
    }

    return rc;
}

int mon_scrcode_out(int maxlen, const char *format, ...)
{
    va_list ap;
    char *buffer;
    int rc = 0;

    va_start(ap, format);
    buffer = lib_mvsprintf(format, ap);
    va_end(ap);

#ifdef HAVE_NETWORK
    if (monitor_is_remote()) {
        int n, c;
        for (n = 0; n < maxlen; n++) {
            c = charset_screencode_to_petscii(buffer[n]);
            buffer[n] = charset_p_toascii(c, CONVERT_WITH_CTRLCODES);
        }
        rc = monitor_network_transmit(buffer, maxlen);
    } else {
#endif
        rc = mon_out_buffered(buffer, 2, maxlen);
#ifdef HAVE_NETWORK
    }
#endif
    mon_log_file_out(buffer);

    lib_free(buffer);

    if (rc < 0) {
        monitor_abort();
    }

    return rc;
}

int mon_scrcode_upper_out(int maxlen, const char *format, ...)
{
    va_list ap;
    char *buffer;
    int rc = 0;

    va_start(ap, format);
    buffer = lib_mvsprintf(format, ap);
    va_end(ap);

#ifdef HAVE_NETWORK
    if (monitor_is_remote()) {
        int n, c;
        for (n = 0; n < maxlen; n++) {
            c = charset_screencode_to_petscii(buffer[n]);
            buffer[n] = charset_p_toascii(c, CONVERT_WITH_CTRLCODES);
        }
        rc = monitor_network_transmit(buffer, maxlen);
    } else {
#endif
        rc = mon_out_buffered(buffer, 4, maxlen);
#ifdef HAVE_NETWORK
    }
#endif
    mon_log_file_out(buffer);

    lib_free(buffer);

    if (rc < 0) {
        monitor_abort();
    }

    return rc;
}

char *mon_disassemble_with_label(MEMSPACE memspace, uint16_t loc, int hex,
                                 unsigned *opc_size_p, unsigned *label_p)
{
    const char *p;

    if (*label_p == 0) {
        /* process a label, if available */
        p = mon_symbol_table_lookup_name(memspace, loc);
        if (p) {
            *label_p = 1;
            *opc_size_p = 0;
            return lib_msprintf("%s:", p);
        }
    } else {
        *label_p = 0;
    }

    /* process the disassembly itself */
    p = mon_disassemble_to_string_ex(memspace, loc,
                                     mon_get_mem_val(memspace, loc),
                                     mon_get_mem_val(memspace,
                                                     (uint16_t)(loc + 1)),
                                     mon_get_mem_val(memspace,
                                                     (uint16_t)(loc + 2)),
                                     mon_get_mem_val(memspace,
                                                     (uint16_t)(loc + 3)),
                                     hex,
                                     opc_size_p);

    return lib_msprintf((hex ? "%04X: %s%10s" : "%05u: %s%10s"), loc, p, "");
}

char *mon_dump_with_label(MEMSPACE memspace, uint16_t loc, int hex, unsigned *label_p)
{
    const char *p;
    uint8_t val;

    if (*label_p == 0) {
        /* process a label, if available */
        p = mon_symbol_table_lookup_name(memspace, loc);
        if (p) {
            *label_p = 1;
            return lib_msprintf("%s:", p);
        }
    } else {
        *label_p = 0;
    }

    val = mon_get_mem_val(memspace, loc);
    return lib_msprintf((hex ? "%04X: $%02X   %03u   '%c'" : "%05u: $%02X   %03u   '%c'"), loc, val, val, isprint((unsigned char)val) ? val : ' ');
}

static char *pchCommandLine = NULL;

void mon_set_command(console_t *cons_log, char *command,
                     void (*pAfter)(void))
{
    pchCommandLine = command;

    mon_out("%s\n", command);

    if (pAfter) {
        (*pAfter)();
    }
}

char *uimon_in(const char *prompt)
{
    char *p = NULL;
#ifdef HAVE_NETWORK
    vice_network_socket_t *sockfd[3];
    int sockfd_index = 0;
#endif

    if (monitor_is_remote()) {
        if (monitor_network_transmit(prompt, strlen(prompt)) < 0) {
            return NULL;
        }
    }

    while (!p && !pchCommandLine) {
        /* as long as we don't have any return value... */

#ifdef HAVE_NETWORK
        sockfd_index = 0;
        if (!monitor_is_remote()) {
            monitor_check_remote();
        } else {
            sockfd[sockfd_index] = monitor_get_connected_socket();
            sockfd_index++;
        }

        if (!monitor_is_binary()) {
            monitor_check_binary();
        } else {
            sockfd[sockfd_index] = monitor_binary_get_connected_socket();
            sockfd_index++;
        }

        sockfd[sockfd_index] = NULL;

        if (monitor_is_remote() || monitor_is_binary()) {

            vice_network_select_multiple(sockfd);

            if (monitor_is_binary()) {
                if (!monitor_binary_get_command_line()) {
                    p = NULL;
                    break;
                }
            }

            if (monitor_is_remote()) {
                if (!monitor_network_get_command_line(&p)) {
                    mon_set_command(NULL, "x", NULL);
                    break;
                }
            }

            ui_dispatch_events();
        } else {
#endif
            /* make sure to flush the output buffer */
            mon_buffer_flush();

            /* get input from the user */
            p = uimon_get_in(&pchCommandLine, prompt);
            if (!p) {
                break;
            }
#ifdef HAVE_NETWORK
        }
#endif
    }

    if (pchCommandLine) {
        /* we have an "artificially" generated command line */
        lib_free(p);
        p = lib_strdup(pchCommandLine);
        pchCommandLine = NULL;
    }

    mon_log_file_out(prompt);
    mon_log_file_out(p);
    mon_log_file_out("\n");

    /* return the command (the one or other way...) */
    return p;
}