/*
 * msiinfo - MSI inspection tool
 *
 * Copyright 2012 Red Hat, Inc.
 *
 * Author: Paolo Bonzini <pbonzini@redhat.com>
 *
 * This library 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 library 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
 */

#include "config.h"
#include "libmsi.h"

#include <glib.h>
#include <stdio.h>
#include <assert.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <limits.h>

static const char *program_name;

struct Command {
    const char *cmd;
    const char *desc;
    const char *usage;
    const char *opts;
    const char *help;
    int (*func)(struct Command *cmd, int argc, char **argv);
};

static struct Command cmds[];

static char *get_basename(char *path)
{
    char *p;
    if (!path || !*path) {
        return ".";
    }
    p = path + strlen(path);
    while (p > path && *p != '/' && *p != '\\') {
        p--;
    }
    if (p > path) {
        p++;
    }
    return p;
}

static void usage(FILE *out)
{
    int i;

    fprintf(out, "Usage: %s SUBCOMMAND COMMAND-OPTIONS...\n\n", program_name);
    fprintf(out, "Options:\n");
    fprintf(out, "  -h, --help        Show program usage\n");
    fprintf(out, "  -v, --version     Display program version\n\n");
    fprintf(out, "Available subcommands:\n");
    for (i = 0; cmds[i].cmd; i++) {
        if (cmds[i].desc) {
            fprintf(out, "  %-18s%s\n", cmds[i].cmd, cmds[i].desc);
        }
    }
    exit (out == stderr);
}

static void cmd_usage(FILE *out, struct Command *cmd)
{
    fprintf(out, "%s %s %s\n\n%s.\n", program_name, cmd->cmd, cmd->opts,
            cmd->desc);

    if (cmd->help) {
        fprintf(out, "\n%s\n", cmd->help);
    }
    exit (out == stderr);
}

static void print_libmsi_error(LibmsiResult r)
{
    switch (r)
    {
    case LIBMSI_RESULT_SUCCESS:
        abort();
    case LIBMSI_RESULT_CONTINUE:
        fprintf(stderr, "%s: internal error (continue)\n", program_name);
        exit(1);
    case LIBMSI_RESULT_MORE_DATA:
        fprintf(stderr, "%s: internal error (more data)\n", program_name);
        exit(1);
    case LIBMSI_RESULT_INVALID_HANDLE:
        fprintf(stderr, "%s: internal error (invalid handle)\n", program_name);
        exit(1);
    case LIBMSI_RESULT_NOT_ENOUGH_MEMORY:
    case LIBMSI_RESULT_OUTOFMEMORY:
        fprintf(stderr, "%s: out of memory\n", program_name);
        exit(1);
    case LIBMSI_RESULT_INVALID_DATA:
        fprintf(stderr, "%s: invalid data\n", program_name);
        exit(1);
    case LIBMSI_RESULT_INVALID_PARAMETER:
        fprintf(stderr, "%s: invalid parameter\n", program_name);
        exit(1);
    case LIBMSI_RESULT_OPEN_FAILED:
        fprintf(stderr, "%s: open failed\n", program_name);
        exit(1);
    case LIBMSI_RESULT_CALL_NOT_IMPLEMENTED:
        fprintf(stderr, "%s: not implemented\n", program_name);
        exit(1);
    case LIBMSI_RESULT_NO_MORE_ITEMS:
    case LIBMSI_RESULT_NOT_FOUND:
        fprintf(stderr, "%s: not found\n", program_name);
        exit(1);
    case LIBMSI_RESULT_UNKNOWN_PROPERTY:
        fprintf(stderr, "%s: unknown property\n", program_name);
        exit(1);
    case LIBMSI_RESULT_BAD_QUERY_SYNTAX:
        fprintf(stderr, "%s: bad query syntax\n", program_name);
        exit(1);
    case LIBMSI_RESULT_INVALID_FIELD:
        fprintf(stderr, "%s: invalid field\n", program_name);
        exit(1);
    case LIBMSI_RESULT_FUNCTION_FAILED:
        fprintf(stderr, "%s: internal error (function failed)\n", program_name);
        exit(1);
    case LIBMSI_RESULT_INVALID_TABLE:
        fprintf(stderr, "%s: invalid table\n", program_name);
        exit(1);
    case LIBMSI_RESULT_DATATYPE_MISMATCH:
        fprintf(stderr, "%s: datatype mismatch\n", program_name);
        exit(1);
    case LIBMSI_RESULT_INVALID_DATATYPE:
        fprintf(stderr, "%s: invalid datatype\n", program_name);
        exit(1);
    }
}

static struct Command *find_cmd(const char *s)
{
    int i;

    for (i = 0; cmds[i].cmd; i++) {
        if (!strcmp(s, cmds[i].cmd)) {
            return &cmds[i];
        }
    }

    fprintf(stderr, "%s: Unrecognized command '%s'\n", program_name, s);
    return NULL;
}

static LibmsiResult print_strings_from_query(LibmsiQuery *query)
{
    LibmsiRecord *rec = NULL;
    LibmsiResult r;
    char name[PATH_MAX];

    while ((r = libmsi_query_fetch(query, &rec)) == LIBMSI_RESULT_SUCCESS) {
        unsigned size = PATH_MAX;
        r = libmsi_record_get_string(rec, 1, name, &size);
        if (r) {
            print_libmsi_error(r);
        }

        puts(name);
        libmsi_unref(rec);
    }

    if (r == LIBMSI_RESULT_NO_MORE_ITEMS) {
        r = LIBMSI_RESULT_SUCCESS;
    }
    return r;
}

static int cmd_streams(struct Command *cmd, int argc, char **argv)
{
    LibmsiDatabase *db = NULL;
    LibmsiQuery *query = NULL;
    LibmsiResult r;

    if (argc != 2) {
        cmd_usage(stderr, cmd);
    }

    r = libmsi_database_open(argv[1], LIBMSI_DB_OPEN_READONLY, &db);
    if (r) {
        print_libmsi_error(r);
    }

    r = libmsi_database_open_query(db, "SELECT `Name` FROM `_Streams`", &query);
    if (r) {
        print_libmsi_error(r);
    }

    r = libmsi_query_execute(query, NULL);
    if (r) {
        print_libmsi_error(r);
    }

    r = print_strings_from_query(query);
    if (r) {
        print_libmsi_error(r);
    }

    libmsi_unref(query);
    libmsi_unref(db);
}

static int cmd_tables(struct Command *cmd, int argc, char **argv)
{
    LibmsiDatabase *db = NULL;
    LibmsiQuery *query = NULL;
    LibmsiResult r;

    if (argc != 2) {
        cmd_usage(stderr, cmd);
    }

    r = libmsi_database_open(argv[1], LIBMSI_DB_OPEN_READONLY, &db);
    if (r) {
        print_libmsi_error(r);
    }

    r = libmsi_database_open_query(db, "SELECT `Name` FROM `_Tables`", &query);
    if (r) {
        print_libmsi_error(r);
    }

    r = libmsi_query_execute(query, NULL);
    if (r) {
        print_libmsi_error(r);
    }

    r = print_strings_from_query(query);
    if (r) {
        print_libmsi_error(r);
    }

    libmsi_unref(query);
    libmsi_unref(db);
}

static void print_suminfo(LibmsiSummaryInfo *si, int prop, const char *name)
{
    unsigned type;
    int val;
    uint64_t valtime;
    char *buf;
    unsigned sz;
    unsigned r;
    time_t t;

    sz = 0;
    r = libmsi_summary_info_get_property(si, prop, &type, &val, &valtime, NULL, &sz);
    if (r && r != LIBMSI_RESULT_MORE_DATA) {
        print_libmsi_error(r);
    }

    switch (type) {
    case LIBMSI_PROPERTY_TYPE_INT:
        printf ("%s: %d (%x)\n", name, val, val);
        break;

    case LIBMSI_PROPERTY_TYPE_STRING:
        buf = g_malloc(++sz);
        r = libmsi_summary_info_get_property(si, prop, NULL, NULL, NULL, buf, &sz);
        if (r) {
            print_libmsi_error(r);
        }
        printf ("%s: %s\n", name, buf);
	free(buf);
        break;

    case LIBMSI_PROPERTY_TYPE_FILETIME:
        /* Convert nanoseconds since 1601 to seconds since Unix epoch.  */
        t = (valtime / 10000000) - (uint64_t) 134774 * 86400;
        printf ("%s: %s", name, ctime(&t));
        break;

    case LIBMSI_PROPERTY_TYPE_EMPTY:
	break;

    default:
	abort();
    }
}

static int cmd_suminfo(struct Command *cmd, int argc, char **argv)
{
    LibmsiDatabase *db = NULL;
    LibmsiSummaryInfo *si = NULL;
    LibmsiResult r;

    if (argc != 2) {
        cmd_usage(stderr, cmd);
    }

    r = libmsi_database_open(argv[1], LIBMSI_DB_OPEN_READONLY, &db);
    if (r) {
        print_libmsi_error(r);
    }

    r = libmsi_database_get_summary_info(db, 0, &si);
    if (r) {
        print_libmsi_error(r);
    }

    print_suminfo(si, MSI_PID_TITLE, "Title");
    print_suminfo(si, MSI_PID_SUBJECT, "Subject");
    print_suminfo(si, MSI_PID_AUTHOR, "Author");
    print_suminfo(si, MSI_PID_KEYWORDS, "Keywords");
    print_suminfo(si, MSI_PID_COMMENTS, "Comments");
    print_suminfo(si, MSI_PID_TEMPLATE, "Template");
    print_suminfo(si, MSI_PID_LASTAUTHOR, "Last author");
    print_suminfo(si, MSI_PID_REVNUMBER, "Revision number");
    print_suminfo(si, MSI_PID_EDITTIME, "Edittime");
    print_suminfo(si, MSI_PID_LASTPRINTED, "Last printed");
    print_suminfo(si, MSI_PID_CREATE_DTM, "Created");
    print_suminfo(si, MSI_PID_LASTSAVE_DTM, "Last saved");
    print_suminfo(si, MSI_PID_MSIVERSION, "Version");
    print_suminfo(si, MSI_PID_MSISOURCE, "Source");
    print_suminfo(si, MSI_PID_MSIRESTRICT, "Restrict");
    print_suminfo(si, MSI_PID_THUMBNAIL, "Thumbnail");
    print_suminfo(si, MSI_PID_APPNAME, "Application");
    print_suminfo(si, MSI_PID_SECURITY, "Security");

    libmsi_unref(db);
    libmsi_unref(si);
}

static void full_write(int fd, char *buf, size_t sz)
{
    while (sz > 0) {
        ssize_t rc = write(fd, buf, sz);
        if (rc < 0) {
            perror("write");
            exit(1);
        }
        buf += rc;
        sz -= rc;
    }
}

static int cmd_extract(struct Command *cmd, int argc, char **argv)
{
    LibmsiDatabase *db = NULL;
    LibmsiQuery *query = NULL;
    LibmsiRecord *rec = NULL;
    LibmsiResult r;
    char *buf;
    unsigned size, bufsize;

    if (argc != 3) {
        cmd_usage(stderr, cmd);
    }

    r = libmsi_database_open(argv[1], LIBMSI_DB_OPEN_READONLY, &db);
    if (r) {
        print_libmsi_error(r);
    }

    r = libmsi_database_open_query(db, "SELECT `Data` FROM `_Streams` WHERE `Name` = ?", &query);
    if (r) {
        print_libmsi_error(r);
    }

    rec = libmsi_record_create(1);
    libmsi_record_set_string(rec, 1, argv[2]);
    r = libmsi_query_execute(query, rec);
    libmsi_unref(rec);
    if (r) {
        print_libmsi_error(r);
    }

    r = libmsi_query_fetch(query, &rec);
    if (r) {
        print_libmsi_error(r);
    }

    r = libmsi_record_save_stream(rec, 1, NULL, &size);
    if (r) {
        print_libmsi_error(r);
    }

    bufsize = (size > 1048576 ? 1048576 : size);
    buf = g_malloc(bufsize);

#if O_BINARY
    _setmode(STDOUT_FILENO, O_BINARY);
#endif

    while (size > 0) {
        r = libmsi_record_save_stream(rec, 1, buf, &bufsize);
        assert(size >= bufsize);
        full_write(STDOUT_FILENO, buf, bufsize);
        size -= bufsize;
    }

    libmsi_unref(rec);
    libmsi_unref(query);
    libmsi_unref(db);
}

static unsigned export_create_table(const char *table, 
                                    LibmsiRecord *names,
                                    LibmsiRecord *types,
                                    LibmsiRecord *keys)
{
    int num_columns = libmsi_record_get_field_count(names);
    int num_keys = libmsi_record_get_field_count(keys);
    int i, len;
    unsigned r;
    char type[30], name[100], size[20], extra[30];
    unsigned sz;


    printf("CREATE TABLE `%s` (", table);
    for (i = 1; i <= num_columns; i++)
    {
        sz = sizeof(name);
        r = libmsi_record_get_string(names, i, name, &sz);
        if (r) {
            return r;
        }

        sz = sizeof(type);
        r = libmsi_record_get_string(types, i, type, &sz);
        if (r) {
            return r;
        }

        if (i > 1) {
            printf(", ");
        }

        extra[0] = '\0';
        if (islower(type[0])) {
            strcat(extra, " NOT NULL");
        }

        switch (type[0])
        {
            case 'l': case 'L':
                strcat(extra, " LOCALIZABLE");
                /* fall through */
            case 's': case 'S':
                strcpy(size, type+1);
                sprintf(type, "CHAR(%s)", size);
                break;
            case 'i': case 'I':
                len = atol(type + 1);
                if (len <= 2)
                    strcpy(type, "INT");
                else if (len == 4)
                    strcpy(type, "LONG");
                else
                    abort();
                break;
            case 'v': case 'V':
                strcpy(type, "OBJECT");
                break;
            default:
                abort();
        }

        printf("`%s` %s%s", name, type, extra);
    }
    for (i = 1; i <= num_keys; i++)
    {
        sz = sizeof(name);
        r = libmsi_record_get_string(names, i, name, &sz);
        if (r) {
            return r;
        }

        printf("%s `%s`", (i > 1 ? "," : " PRIMARY KEY"), name);
    }
    printf(")\n");
    return r;
}

static void print_quoted_string(const char *s)
{
    putchar('\'');
    for (; *s; s++) {
        switch (*s) {
        case '\n': putchar('\\'); putchar('n'); break;
        case '\r': putchar('\\'); putchar('r'); break;
        case '\\': putchar('\\'); putchar('\\'); break;
        case '\'': putchar('\\'); putchar('\''); break;
        default: putchar(*s);
        }
    }
    putchar('\'');
}

static unsigned export_insert(const char *table, 
                              LibmsiRecord *names,
                              LibmsiRecord *types,
                              LibmsiRecord *vals)
{
    int num_columns = libmsi_record_get_field_count(names);
    int i;
    unsigned r;
    char type[30], name[100];
    unsigned sz;
    char *s;

    printf("INSERT INTO `%s` (", table);
    for (i = 1; i <= num_columns; i++)
    {
        sz = sizeof(name);
        r = libmsi_record_get_string(names, i, name, &sz);
        if (r) {
            return r;
        }

        if (i > 1) {
            printf(", ");
        }

        printf("`%s`", name);
    }
    printf(") VALUES (");
    for (i = 1; i <= num_columns; i++)
    {
        if (i > 1) {
            printf(", ");
        }

        if (libmsi_record_is_null(vals, i)) {
            printf("NULL");
            continue;
        }

        sz = sizeof(type);
        r = libmsi_record_get_string(types, i, type, &sz);
        if (r) {
            return r;
        }

        switch (type[0])
        {
            case 'l': case 'L':
            case 's': case 'S':
                sz = INT_MAX;
                r = libmsi_record_get_string(vals, i, NULL, &sz);
                if (r) {
                    return r;
                }

                s = g_malloc(++sz);
                libmsi_record_get_string(vals, i, s, &sz);
                print_quoted_string(s);
                g_free(s);
                break;

            case 'i': case 'I':
                printf("%d", libmsi_record_get_integer(vals, i));
                break;
            case 'v': case 'V':
                printf("''", s);
                break;
            default:
                abort();
        }
    }
    printf(")\n");
    return r;
}

static unsigned export_sql( LibmsiDatabase *db, const char *table)
{
    LibmsiRecord *name = NULL;
    LibmsiRecord *type = NULL;
    LibmsiRecord *keys = NULL;
    LibmsiRecord *rec = NULL;
    LibmsiQuery *query = NULL;
    unsigned r;
    char *sql;

    sql = g_strdup_printf("select * from `%s`", table);
    r = libmsi_database_open_query(db, sql, &query);
    if (r) {
        return r;
    }

    /* write out row 1, the column names */
    r = libmsi_query_get_column_info(query, LIBMSI_COL_INFO_NAMES, &name);
    if (r) {
        goto done;
    }

    /* write out row 2, the column types */
    r = libmsi_query_get_column_info(query, LIBMSI_COL_INFO_TYPES, &type);
    if (r) {
        goto done;
    }

    /* write out row 3, the table name + keys */
    r = libmsi_database_get_primary_keys( db, table, &keys );
    if (r) {
        goto done;
    }

    r = export_create_table(table, name, type, keys);
    if (r) {
        goto done;
    }

    /* write out row 4 onwards, the data */
    while ((r = libmsi_query_fetch(query, &rec)) == LIBMSI_RESULT_SUCCESS) {
        unsigned size = PATH_MAX;
        r = export_insert(table, name, type, rec);
        libmsi_unref(rec);
        if (r) {
            break;
        }
    }

    if (r == LIBMSI_RESULT_NO_MORE_ITEMS) {
        r = LIBMSI_RESULT_SUCCESS;
    }

done:
    libmsi_unref(name);
    libmsi_unref(type);
    libmsi_unref(keys);
    libmsi_unref(query);
    return r;
}

static int cmd_export(struct Command *cmd, int argc, char **argv)
{
    LibmsiDatabase *db = NULL;
    LibmsiResult r;
    bool sql = false;

    if (!strcmp(argv[1], "-s")) {
        sql = true;
        argc--;
        argv++;
    }

    if (argc != 3) {
        cmd_usage(stderr, cmd);
    }

    r = libmsi_database_open(argv[1], LIBMSI_DB_OPEN_READONLY, &db);
    if (r) {
        print_libmsi_error(r);
    }

    if (sql) {
        r = export_sql(db, argv[2]);
    } else {
#if O_BINARY
        _setmode(STDOUT_FILENO, O_BINARY);
#endif
        r = libmsi_database_export(db, argv[2], STDOUT_FILENO);
    }

    if (r) {
        print_libmsi_error(r);
    }

    libmsi_unref(db);
}

static int cmd_version(struct Command *cmd, int argc, char **argv)
{
    printf("%s (%s) version %s\n", program_name, PACKAGE, VERSION);
    return 0;
}

static int cmd_help(struct Command *cmd, int argc, char **argv)
{
    if (argc > 1) {
        cmd = find_cmd(argv[1]);
        if (cmd && cmd->desc) {
            cmd_usage(stdout, cmd);
        }
    }

    usage(stdout);
}

static struct Command cmds[] = {
    {
        .cmd = "help",
        .opts = "[SUBCOMMAND]",
        .desc = "Show program or subcommand usage",
        .func = cmd_help,
    },
    {
        .cmd = "streams",
        .opts = "FILE",
        .desc = "List streams in a .msi file",
        .func = cmd_streams,
    },
    {
        .cmd = "tables",
        .opts = "FILE",
        .desc = "List tables in a .msi file",
        .func = cmd_tables,
    },
    {
        .cmd = "extract",
        .opts = "FILE STREAM",
        .desc = "Extract a binary stream from an .msi file",
        .func = cmd_extract,
    },
    {
        .cmd = "export",
        .opts = "[-s] FILE TABLE\n\nOptions:\n"
                "  -s                Format output as an SQL query",
        .desc = "Export a table in text form from an .msi file",
        .func = cmd_export,
    },
    {
        .cmd = "suminfo",
        .opts = "FILE",
        .desc = "Print summary information",
        .func = cmd_suminfo,
    },
    {
        .cmd = "-h",
        .func = cmd_help,
    },
    {
        .cmd = "--help",
        .func = cmd_help,
    },
    {
        .cmd = "-v",
        .func = cmd_version
    },
    {
        .cmd = "--version",
        .func = cmd_version
    },
    { NULL },
};

int main(int argc, char **argv)
{
    struct Command *cmd = NULL;

    g_type_init();
    program_name = get_basename(argv[0]);

    if (argc == 1) {
        usage(stderr);
    }

    cmd = find_cmd(argv[1]);
    if (!cmd) {
        fprintf(stderr, "%s: Unrecognized command\n", program_name);
        usage(stderr);
    }

    return cmd->func(cmd, argc - 1, argv + 1);
}