/**
 *  $Id: database.c 108 2008-04-17 01:01:52Z mbroeker $
 * $URL: http://localhost/svn/c/mcbot/trunk/src/database.c $
 *
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <gdbm.h>

#include <database.h>
#include "common.h"

char *db_insert (char *file_name, char *name, char *msg, int mode)
{
    GDBM_FILE dbf;
    datum key;
    datum content;
    int ret;

    if ((dbf = gdbm_open (file_name, 512, GDBM_WRCREAT, 0644, 0)) == NULL)
        return "db_insert error";

    key.dptr = name;
    key.dsize = strlen (name) + 1;

    content.dptr = msg;
    content.dsize = strlen (msg) + 1;

    if (mode)
        ret = gdbm_store (dbf, key, content, GDBM_REPLACE);
    else
        ret = gdbm_store (dbf, key, content, GDBM_INSERT);

    gdbm_close (dbf);

    if (!ret)
        return "Key added";

    return "error: key not added";
}

char *db_remove (char *file_name, char *name)
{
    GDBM_FILE dbf;
    datum key;
    int ret;

    if ((dbf = gdbm_open (file_name, 512, GDBM_WRITER, 0, 0)) == NULL)
        return "db_remove error";

    key.dptr = name;
    key.dsize = strlen (name) + 1;

    ret = gdbm_delete (dbf, key);

    gdbm_close (dbf);

    if (!ret)
        return "Key removed";
    return "error: key not removed";
}

char *db_lookup (char *file_name, char *entry)
{
    GDBM_FILE dbf;
    datum content;
    datum key;
    static char msg[DEFAULT_BUF_SIZE] = { 0 };

    if ((dbf = gdbm_open (file_name, 512, GDBM_READER, 0, 0)) == NULL)
        return "db_lookup error";

    key.dptr = entry;
    key.dsize = strlen (entry) + 1;

    content = gdbm_fetch (dbf, key);
    if (content.dptr != NULL) {
        snprintf (msg, sizeof (msg), "%s", content.dptr);
        free (content.dptr);
    } else
        snprintf (msg, sizeof (msg), "I haven't heard anything about %s.", entry);

    gdbm_close (dbf);
    return msg;
}

char *db_elements (char *file_name)
{
    GDBM_FILE dbf;
    datum key, nextkey;
    int count;
    static char msg[81] = { 0 };

    if ((dbf = gdbm_open (file_name, 512, GDBM_READER, 0, 0)) == NULL)
        return "db_lookup error";

    key = gdbm_firstkey (dbf);

    count = 0;
    while (key.dptr != NULL) {
        nextkey = gdbm_nextkey (dbf, key);
        free (key.dptr);
        key = nextkey;
        count++;
    }

    gdbm_close (dbf);
    snprintf (msg, sizeof (msg), "I am holding %d %s in my database.", count, (count > 0) ? "rows" : "row");
    return msg;
}

char *db_list (char *file_name)
{
    GDBM_FILE dbf;
    datum content;
    datum key, nextkey;
    static char msg[81] = { 0 };
    int count;

    if ((dbf = gdbm_open (file_name, 512, GDBM_READER, 0, 0)) == NULL)
        return "db_list error";

    key = gdbm_firstkey (dbf);

    count = 0;
    while (key.dptr != NULL) {
        content = gdbm_fetch (dbf, key);
        printf ("%11s: %s\n", key.dptr, content.dptr);
        if (content.dptr != NULL)
            free (content.dptr);
        nextkey = gdbm_nextkey (dbf, key);
        free (key.dptr);
        key = nextkey;
        count++;
    }

    gdbm_close (dbf);
    snprintf (msg, sizeof (msg), "I am holding %d %s in my database.", count, (count > 0) ? "rows" : "row");
    return msg;
}

char *db_vaccuum (char *file_name)
{
    GDBM_FILE dbf;
    static char msg[81] = { 0 };

    if ((dbf = gdbm_open (file_name, 512, GDBM_WRITER, 0, 0)) == NULL)
        return "db_vaccuum error";

    gdbm_reorganize (dbf);

    gdbm_close (dbf);
    snprintf (msg, sizeof (msg), "I reorganized the database.");
    return msg;
}