#include "irc_log.h"
#include "log.h"

#include <string.h>

// XXX: fix this err_t crap
#define LIB_ERR_H
#include <evsql.h>

/**
 * The core irc_log state
 */
static struct irc_log_ctx {
    /** The nexus this module is loaded for */
    struct nexus *nexus;

    /** The database connection */
    struct evsql *db;

} _ctx;

static void on_chan_msg (struct irc_chan *chan, const struct irc_nm *source, const char *message, void *arg)
{
    struct irc_log_ctx *ctx = arg;

    (void) ctx;

    // log it! :P
    log_debug("%s: %s: %s", source ? source->nickname : "???", irc_chan_name(chan), message);
}

static struct irc_chan_callbacks _chan_callbacks = {
    .on_msg         = on_chan_msg,
};

void* irc_log_init (struct modules *modules, struct error_info *err)
{
    struct irc_log_ctx *ctx;

    (void) modules;
    (void) err;
        
    // XXX: static pointer
    ctx = &_ctx;

    // initialize
    memset(ctx, 0, sizeof(*ctx));

    // store
    ctx->nexus = modules->nexus;

    // ok
    return ctx;
}

err_t irc_log_conf (void *mod_ctx, const char *name, char *value, struct error_info *err)
{
    struct irc_log_ctx *ctx = mod_ctx;

    if (strcmp(name, "db_info") == 0) {
        log_info("connect to database: %s", value);

        if ((ctx->db = evsql_new_pq(ctx->nexus->ev_base, value, NULL, NULL)) == NULL)
           return ERR_EVSQL_NEW_PQ;

    } else if (strcmp(name, "channel") == 0) {
        const char *network = strsep(&value, "/");
        const char *channel = value;

        struct irc_chan *chan;
        
        // kill missing tokens
        if (!network || !channel) 
            RETURN_SET_ERROR_STR(err, ERR_MODULE_CONF, "invalid '<network>/<channel>' value");

        // get the channel?
        if ((chan = irc_client_get_chan(ctx->nexus->client, network, channel)) == NULL)
            RETURN_SET_ERROR_STR(err, ERR_MODULE_CONF, "unknown channel name");

        // add channel callbacks
        if ((ERROR_CODE(err) = irc_chan_add_callbacks(chan, &_chan_callbacks, ctx)))
            return ERROR_CODE(err);

    } else {
        return -1;

    }

    // ok
    return SUCCESS;
}