FiSH-irssi-5295563/src/FiSH.c

#include "FiSH.h"

/**
 * Default key for FiSH ini file.
 */
static const char default_iniKey[] = "blowinikey";

/*
 * Load a base64 blowfish key for contact
 * If theKey is NULL, only a test is made (= IsKeySetForContact)
 * @param contactPtr
 * @param theKey
 * @return 1 if everything ok 0 if not
 */
int getContactKey(const char *contactPtr, char *theKey)
{
    struct IniValue iniValue;
    int bRet = FALSE;

    iniValue = allocateIni(contactPtr, "key", iniPath);
    getIniValue(contactPtr, "key", "", iniValue.key, iniValue.keySize, iniPath);

    // don't process, encrypted key not found in ini
    if (strlen(iniValue.key) < 16) {
        freeIni(iniValue);
        return bRet;
    }

    // encrypted key found
    if (strncmp(iniValue.key, "+OK ", 4) == 0) {
        if (theKey) {
            decrypt_string((char *)iniKey, iniValue.key + 4, theKey,
                    strlen(iniValue.key + 4));
        }
        bRet = TRUE;
    }

    freeIni(iniValue);
    return bRet;
}

/*
 * Construct a ini section key for contact
 * @param server irssi server record
 * @param contactPtr contact
 * @param iniSectionKey buffer to there the section key is generated
 * @return TRUE if everything ok FALSE if not
 */
int getIniSectionForContact(const SERVER_REC * serverRec,
        const char *contactPtr, char *iniSectionKey)
{
    char *target;
    size_t i, c;

    ZeroMemory(iniSectionKey, CONTACT_SIZE);

    if (contactPtr == NULL)
        return FALSE;

    if (iniSectionKey == NULL)
        return FALSE;

    target = g_ascii_strdown((gchar*)contactPtr, (gssize)strlen(contactPtr));

    // Allows nicks with [ ], replaces them with ( )
    for(i = 0, c = strlen(target); i < c; i++) {
        if (target[i] == '[') target[i] = '(';
        if (target[i] == ']') target[i] = ')';
    }

    if (serverRec != NULL) {
        snprintf(iniSectionKey, CONTACT_SIZE, "%s:%s", serverRec->tag,
                target);
    } else {
        snprintf(iniSectionKey, CONTACT_SIZE, "%s", target);
    }

    return TRUE;
}

/*
 * Encrypt a message and store in bf_dest (using key for target)
 * @param server
 * @param msg_ptr
 * @param target
 * @param bf_dest
 * @return 1 if everything ok 0 if not
 */
int FiSH_encrypt(const SERVER_REC * serverRec, const char *msgPtr,
        const char *target, char *bf_dest)
{
    struct IniValue iniValue;
    char contactName[CONTACT_SIZE] = "";

    if (IsNULLorEmpty(msgPtr) || bf_dest == NULL || IsNULLorEmpty(target))
        return 0;

    if (settings_get_bool("process_outgoing") == 0)
        return 0;

    if (getIniSectionForContact(serverRec, target, contactName) == FALSE)
        return 0;

    iniValue = allocateIni(contactName, "key", iniPath);

    if (getContactKey(contactName, iniValue.key) == FALSE) {
        freeIni(iniValue);
        return 0;
    }

    if (iniValue.cbc == 1) {
        strcpy(bf_dest, "+OK *");
        encrypt_string_cbc(iniValue.key, msgPtr, bf_dest + 5, strlen(msgPtr));
    } else {
        strcpy(bf_dest, "+OK ");
        encrypt_string(iniValue.key, msgPtr, bf_dest + 4, strlen(msgPtr));
    }

    freeIni(iniValue);
    return 1;
}

/*
 * Decrypt a base64 cipher text (using key for target)
 */
int FiSH_decrypt(const SERVER_REC * serverRec, char *msg_ptr,
        const char *target, GString* decrypted_msg)
{
    char contactName[CONTACT_SIZE] = "";
    struct IniValue iniValue;
    char bf_dest[1000] = "";
    char myMark[20] = "";
    int msg_len, i, mark_broken_block = 0, action_found = 0;
    int mode = 0;
    int cbc_ret = 0;

    if (IsNULLorEmpty(msg_ptr) || decrypted_msg == NULL || IsNULLorEmpty(target))
        return 0;

    if (settings_get_bool("process_incoming") == 0)
        return 0;

    if (strncmp(msg_ptr, "+OK ", 4) == 0)
        msg_ptr += 4;
    else if (strncmp(msg_ptr, "mcps ", 5) == 0)
        msg_ptr += 5;
    else
        return 0; // don't process, blowcrypt-prefix not found

    // Strip the * from the CBC mode
    if (strncmp(msg_ptr, "*", 1) == 0) {
        mode = 1;
        msg_ptr++;
    }

    msg_len = strlen(msg_ptr);

    // Verify base64 string - only for ECB
    if (mode == 0 && (strspn(msg_ptr, B64) != (size_t) msg_len))
        return 0;

    if (msg_len < 12)
        return 0;

    if (getIniSectionForContact(serverRec, target, contactName) == FALSE)
        return 0;

    iniValue = allocateIni(contactName, "key", iniPath);

    if (getContactKey(contactName, iniValue.key) == FALSE) {
        freeIni(iniValue);
        return 0;
    }

    // usually a received message does not exceed 512 chars, but we want to prevent evil buffer overflow
    if (msg_len >= (int)(sizeof(bf_dest) * 1.5))
        msg_ptr[(int)(sizeof(bf_dest) * 1.5) - 20] = '\0';

    // block-align blowcrypt strings if truncated by IRC server (each block is 12 chars long)
    // such a truncated block is destroyed and not needed anymore
    if ((mode == 0) && (msg_len != (msg_len / 12) * 12)) {
        msg_len = (msg_len / 12) * 12;
        msg_ptr[msg_len] = '\0';
        strncpy(myMark, settings_get_str("mark_broken_block"),
                sizeof(myMark));
        if (*myMark == '\0' || isNoChar(*myMark))
            mark_broken_block = 0;
        else
            mark_broken_block = 1;
    }

    if (iniValue.cbc == 1) {
        cbc_ret = decrypt_string_cbc(iniValue.key, msg_ptr, bf_dest, msg_len);
    } else {
        decrypt_string(iniValue.key, msg_ptr, bf_dest, msg_len);
    }

    if (cbc_ret == -1) {
        strncpy(myMark, settings_get_str("mark_broken_block"),
                sizeof(myMark));
        if (*myMark == '\0' || isNoChar(*myMark))
            mark_broken_block = 0;
        else
            mark_broken_block = 1;
    }

    freeIni(iniValue);

    if (*bf_dest == '\0')
        return 0; // don't process, decrypted msg is bad

    // recode message again, last time it was the encrypted message...
    if (settings_get_bool("recode") && serverRec != NULL) {
        char *recoded = recode_in(serverRec, bf_dest, target);
        if (recoded) {
            strncpy(bf_dest, recoded, sizeof(bf_dest));
            ZeroMemory(recoded, strlen(recoded));
            g_free(recoded);
        }
    }

    i = 0;
    while (bf_dest[i] != 0x0A && bf_dest[i] != 0x0D && bf_dest[i] != '\0')
        i++;
    bf_dest[i] = '\0'; // in case of wrong key, decrypted message might have control characters -> cut message

    if (strncmp(bf_dest, "\001ACTION ", 8) == 0) {
        // ACTION message found
        if (bf_dest[i - 1] == '\001')
            bf_dest[i - 1] = '\0'; // remove 0x01 control character
        action_found = 1;
    }
    // append broken-block-mark?
    if (mark_broken_block)
        strcat(bf_dest, myMark);

    // append crypt-mark?
    strncpy(myMark, settings_get_str("mark_encrypted"), sizeof(myMark));
    if (*myMark != '\0') {
        int markPos = settings_get_int("mark_position");
        if (markPos == 0 || action_found)
            strcat(bf_dest, myMark); // append mark at the end (default for ACTION messages)
        else { // prefix mark
            i = strlen(myMark);
            memmove(bf_dest + i, bf_dest, strlen(bf_dest) + 1);
            strncpy(bf_dest, myMark, i);
        }
    }

    g_string_assign(decrypted_msg, bf_dest);
    ZeroMemory(bf_dest, sizeof(bf_dest));

    return 1;
}

void decrypt_msg(SERVER_REC * server, char *msg, const char *nick,
        const char *address, const char *target)
{
    GString *decrypted;
    const char *contactPtr;

    if (msg == NULL || target == NULL || nick == NULL)
        return;

    //channel?
    if (server_ischannel(server, target)) {
        contactPtr = target;
    } else {
        contactPtr = nick;
    }

    decrypted = g_string_new("");
    if (FiSH_decrypt(server, msg, contactPtr, decrypted)) {
        if (strncmp(decrypted->str, "\001ACTION ", 8) == 0) {
            // ACTION message found
            signal_stop();
            signal_emit("message irc action", 5, server,
                    decrypted->str + 8, nick, address, target);
        }
        else {
            signal_continue(5, server, decrypted->str, nick, address, target);
        }
        ZeroMemory(decrypted->str, decrypted->len);
    }
    g_string_free(decrypted, TRUE);
}

void encrypt_msg(SERVER_REC * server, char *target, char *msg,
        char *orig_target)
{
    char bf_dest[800] = "", *plainMsg;
    char contactName[CONTACT_SIZE] = "";

    if (IsNULLorEmpty(msg) || IsNULLorEmpty(target))
        return;

    if (getIniSectionForContact(server, target, contactName) == FALSE)
        return;

    if (getContactKey(contactName, NULL) == FALSE)
        return;

    plainMsg = isPlainPrefix(msg);
    if (plainMsg) {
        signal_continue(4, server, target, plainMsg, orig_target);
        return;
    }
    // generally cut a message to a size of 512 byte, as everything above will never arrive complete anyway
    if (strlen(msg) > 512)
        msg[512] = '\0';

    if (FiSH_encrypt(server, msg, target, bf_dest) == 1) { // message was encrypted
        bf_dest[512] = '\0';
        signal_continue(4, server, target, bf_dest, orig_target);
    }
}

/*
 * format outgoing (encrypted) messages (add crypt-mark or remove plain-prefix)
 */
void format_msg(SERVER_REC * server, char *msg, char *target, char *orig_target)
{
    char contactName[CONTACT_SIZE] = "", myMark[20] = "";
    char *plainMsg;

    if (IsNULLorEmpty(msg) || IsNULLorEmpty(target))
        return;

    if (settings_get_bool("process_outgoing") == 0)
        return;

    if (getIniSectionForContact(server, target, contactName) == FALSE)
        return;

    if (getContactKey(contactName, NULL) == FALSE)
        return;

    plainMsg = isPlainPrefix(msg);
    if (plainMsg) {
        signal_continue(4, server, plainMsg, target, orig_target);
        return;
    }

    // generally cut a message to a size of 512 byte, as everything above will never arrive complete anyway
    if (strlen(msg) > 512)
        msg[512] = '\0';

    // append crypt-mark?
    strncpy(myMark, settings_get_str("mark_encrypted"), sizeof(myMark));
    if (*myMark != '\0') {
        char formattedMsg[800];
        strcpy(formattedMsg, msg);
        int markPos = settings_get_int("mark_position");
        if (markPos == 0)
            strcat(formattedMsg, myMark); //append mark at the end
        else { // prefix mark
            int i = strlen(myMark);
            memmove(formattedMsg + i, formattedMsg,
                    strlen(formattedMsg) + 1);
            strncpy(formattedMsg, myMark, i);
        }

        signal_continue(4, server, formattedMsg, target, orig_target);

        ZeroMemory(formattedMsg, sizeof(formattedMsg));
    }

    return;
}

/*
 * Decrypt NOTICE messages (and forward DH1080 key-exchange)
 */
void decrypt_notice(SERVER_REC * server, char *msg, char *nick, char *address,
        char *target)
{
    GString *decrypted;

    if (strncmp(msg, "DH1080_", 7) == 0) {
        DH1080_received(server, msg, nick, address, target);
        return;
    }

    decrypted = g_string_new("");
    if (FiSH_decrypt(server, msg, server_ischannel(server, target) ? target : nick, decrypted)) {
        signal_continue(5, server, decrypted->str, nick, address, target);
        ZeroMemory(decrypted->str, decrypted->len);
    }
    g_string_free(decrypted, TRUE);
}

void decrypt_action(SERVER_REC * server, char *msg, char *nick, char *address,
        char *target)
{
    GString *decrypted;
    if (target == NULL)
        return;

    decrypted = g_string_new("");
    if (FiSH_decrypt(server, msg, server_ischannel(server, target) ? target : nick, decrypted)) {
        signal_continue(5, server, decrypted->str, nick, address, target);
        ZeroMemory(decrypted->str, decrypted->len);
    }
    g_string_free(decrypted, TRUE);
}

void decrypt_topic(SERVER_REC * server, char *channel, char *topic, char *nick,
        char *address)
{
    GString *decrypted;

    decrypted = g_string_new("");
    if (FiSH_decrypt(server, topic, channel, decrypted)) {
        signal_continue(5, server, channel, decrypted->str, nick, address);
        ZeroMemory(decrypted->str, decrypted->len);
    }
    g_string_free(decrypted, TRUE);
}

void decrypt_changed_topic(CHANNEL_REC * chan_rec)
{
    GString *decrypted;

    decrypted = g_string_new("");
    if (FiSH_decrypt(chan_rec->server, chan_rec->topic,
                chan_rec->name, decrypted)) {
        g_free_not_null(chan_rec->topic);
        chan_rec->topic = g_strdup(decrypted->str);
        signal_continue(1, chan_rec);
        ZeroMemory(decrypted->str, decrypted->len);
    }
    g_string_free(decrypted, TRUE);
}

void raw_handler(SERVER_REC * server, char *data)
{
    GString *decrypted;
    char channel[CONTACT_SIZE], *ptr, *ptr_bak;
    int len;

    if (IsNULLorEmpty(data))
        return;

    ptr = strchr(data, ' '); // point to command
    if (ptr == NULL)
        return;
    ptr++;

    if (strncmp(ptr, "332 ", 4) != 0)
        return; // 332 = TOPIC

    ptr_bak = ptr;
    ptr = strchr(ptr, '#'); // point to #channel
    if (ptr == NULL) {
        ptr = strchr(ptr_bak, '&'); // point to &channel
        if (ptr == NULL) {
            ptr = strchr(ptr_bak, '!'); // point to !channel
            if (ptr == NULL)
                return;
        }
    }

    len = strchr(ptr, ' ') - ptr;
    if (len >= CONTACT_SIZE - 2)
        return; // channel string too long, something went wrong
    strncpy(channel, ptr, len);
    channel[len] = '\0';

    ptr = strchr(ptr, ':'); // point to topic msg start
    if (ptr == NULL)
        return;
    ptr++;

    decrypted = g_string_new("");
    if (FiSH_decrypt(server, ptr, channel, decrypted)) {
        g_string_prepend_len(decrypted, data, strlen(data) - strlen(ptr));
        signal_continue(2, server, decrypted->str);
        ZeroMemory(decrypted->str, decrypted->len);
    }
    g_string_free(decrypted, TRUE);
}

static char *mark_crypted(const char *original) {
    const char * mark = settings_get_str("mark_encrypted");
    if(mark == NULL || *mark == '\0') {
        return strdup(original);
    }

    // 0 for suffix, anything else for prefix
    const int mark_position = settings_get_int("mark_position");

    const size_t new_len = strlen(original) + strlen(mark) + 1;
    char * new = (char *) calloc(new_len, sizeof(char));

    snprintf(new, new_len, "%s%s", mark_position == 0 ? original : mark,
                                   mark_position == 0 ? mark : original);

    return new;
}

/*
 * /notice+ <nick/#channel> <notice message>
 */
void cmd_crypt_notice(const char *data, SERVER_REC * server, WI_ITEM_REC * item)
{
    char bf_dest[1000] = "", *msg;
    const char *target;
    void *free_arg = NULL;
    char *marked;

    if (data == NULL || (strlen(data) < 3))
        goto notice_error;
    if (!cmd_get_params(data, &free_arg, 1, &target))
        goto notice_error;

    msg = strchr(data, ' ');
    if (IsNULLorEmpty(target) || IsNULLorEmpty(msg))
        goto notice_error;

    msg++; // point to the notice message

    // generally refuse a notice size of more than 512 byte, as everything above will never arrive complete anyway
    if (strlen(msg) >= 512) {
        printtext(server, target, MSGLEVEL_CRAP,
                "\002FiSH:\002 /notice+ \002error\002: message argument exceeds buffer size!");
        return;
    }

    if (FiSH_encrypt(server, msg, target, bf_dest) == 0) {
        printtext(server, target, MSGLEVEL_CRAP,
                "\002FiSH:\002 /notice+ \002error\002: Encryption disabled or no key found for %s.",
                target);
        return;
    }

    bf_dest[512] = '\0';
    irc_send_cmdv((IRC_SERVER_REC *) server, "NOTICE %s :%s\n", target,
            bf_dest);

    marked = mark_crypted(msg);

    signal_emit("message irc own_notice", 3, server, marked, target);
    cmd_params_free(free_arg);
    free(marked);
    return;

notice_error:
    if (free_arg)
        cmd_params_free(free_arg);
    printtext(server, item != NULL ? window_item_get_target(item) : NULL,
            MSGLEVEL_CRAP,
            "\002FiSH:\002 Usage: /notice+ <nick/#channel> <notice message>");
}

/*
 * /me+ <action message>
 */
void cmd_crypt_action(const char *data, SERVER_REC * server, WI_ITEM_REC * item)
{
    char bf_dest[1000] = "";
    const char *target;
    char *marked;

    if (data == NULL || (strlen(data) < 2))
        goto action_error;

    if (item != NULL)
        target = window_item_get_target(item);
    else
        goto action_error;

    // generally refuse an action size of more than 512 byte, as everything above will never arrive complete anyway
    if (strlen(data) >= 512) {
        printtext(server, target, MSGLEVEL_CRAP,
                "\002FiSH:\002 /me+ \002error\002: message argument exceeds buffer size!");
        return;
    }

    if (FiSH_encrypt(server, (char *)data, target, bf_dest) == 0) {
        printtext(server, target, MSGLEVEL_CRAP,
                "\002FiSH:\002 /me+ \002error\002: Encryption disabled or no key found for %s.",
                target);
        return;
    }

    bf_dest[512] = '\0';
    irc_send_cmdv((IRC_SERVER_REC *) server,
            "PRIVMSG %s :\001ACTION %s\001\n", target, bf_dest);

    marked = mark_crypted(data);

    signal_emit("message irc own_action", 3, server, marked, target);
    free(marked);
    return;

action_error:
    printtext(server, item != NULL ? window_item_get_target(item) : NULL,
            MSGLEVEL_CRAP, "\002FiSH:\002 Usage: /me+ <action message>");
}

/*
 * Set encrypted topic for current channel, irssi syntax: /topic+ <your topic>
 */
void cmd_crypt_topic(const char *data, SERVER_REC * server, WI_ITEM_REC * item)
{
    char bf_dest[1000] = "";
    const char *target;

    if (data == 0 || *data == '\0')
        goto topic_error;
    if (item != NULL)
        target = window_item_get_target(item);
    else
        goto topic_error;

    if (!server_ischannel(server, target)) {
        printtext(server, target, MSGLEVEL_CRAP,
                "\002FiSH:\002 Please change to the channel window where you want to set the topic!");
        goto topic_error;
    }
    // generally refuse a topic size of more than 512 byte, as everything above will never arrive complete anyway
    if (strlen(data) >= 512) {
        printtext(server, target, MSGLEVEL_CRAP,
                "\002FiSH:\002 /topic+ error: topic length exceeds buffer size!");
        goto topic_error;
    }
    // encrypt a message (using key for target)
    if (FiSH_encrypt(server, (char *)data, target, bf_dest) == 0) {
        printtext(server, target, MSGLEVEL_CRAP,
                "\002FiSH:\002 /topic+ error: Encryption disabled or no key found for %s.",
                target);
        goto topic_error;
    }

    bf_dest[512] = '\0';
    irc_send_cmdv((IRC_SERVER_REC *) server, "TOPIC %s :%s\n", target,
            bf_dest);
    return;

topic_error:
    printtext(server, item != NULL ? window_item_get_target(item) : NULL,
            MSGLEVEL_CRAP,
            "\002FiSH:\002 Usage: /topic+ <your new topic>");
}

static void sig_complete_topic_plus(GList **list, WINDOW_REC *window,
        const char *word, const char *line,
        int *want_space)
{
    char *topic;

    g_return_if_fail(list != NULL);
    g_return_if_fail(word != NULL);

    if (*word == '\0' && IS_CHANNEL(window->active)) {
        topic = g_strdup(CHANNEL(window->active)->topic);
        if (topic != NULL) {
            const char *mark = settings_get_str("mark_encrypted");
            if (!IsNULLorEmpty(mark)) {
                int topic_len = strlen(topic);
                int mark_len = strlen(mark);
                if (settings_get_int("mark_position") == 0) { // suffix
                    char *p = topic + (topic_len - mark_len);
                    if (strncmp(p, mark, mark_len) == 0) {
                        *p = '\0'; // Remove mark
                    }
                }
                else { // prefix
                    if (strncmp(topic, mark, mark_len) == 0) {
                        memmove(topic, topic + mark_len, topic_len - mark_len + 1);
                    }
                }
            }

            *list = g_list_append(NULL, topic);
            signal_stop();
        }
    }
}


void cmd_helpfish(const char *arg, SERVER_REC * server, WI_ITEM_REC * item)
{
    printtext(NULL, NULL, MSGLEVEL_CRAP,
            "\n\002FiSH HELP:\002 For more information read FiSH-irssi.txt :)\n\n"
            " /topic+ <your new topic>\n"
            " /notice+ <nick/#channel> <notice message>\n"
            " /me+ <your action message>\n"
            " /setkey [-<server tag>] [<nick | #channel>] <key>\n"
            " /delkey [-<server tag>] [<nick | #channel>]\n"
            " /key|showkey [-<server tag>] [<nick | #channel>]\n"
            " /keyx [-ecb|-cbc] [<nick>]\n"
            " /setinipw <blow.ini_password>\n"
            " /unsetinipw\n"
            " /fishlogin\n");
}

int recrypt_ini_file(const char *iniPath, const char *iniPath_new,
        const char *old_iniKey)
{
    GKeyFile *config = g_key_file_new();
    GError *error = NULL;
    gsize groups_count = 0;
    int i;
    int re_enc = 0;
    int newbfKeySize;
    char *newbfKey;
    int plusOkSize;
    char *plusOk;
    int bfKeySize;
    char *bfKey;

    g_key_file_load_from_file(config, iniPath, G_KEY_FILE_NONE, &error);
    if (error != NULL) {
        g_error_free(error);
        error = NULL;
        g_key_file_free(config);
        return -1;
    }

    gchar **groups = g_key_file_get_groups(config, &groups_count);

    for (i = 0; i < groups_count; i++) {

        gsize keys_count = 0;
        gchar **keys = g_key_file_get_keys(config, groups[i], &keys_count, &error);

        if (error != NULL) {
            g_error_free(error);
            error = NULL;
            continue;
        }

        int j;

        for (j = 0; j < keys_count; j++) {
            gchar *value = g_key_file_get_value(config, groups[i], keys[j], &error);

            if (error != NULL) {
                g_error_free(error);
                error = NULL;
                continue;
            }

            if (strncmp(value, "+OK ", 4) == 0) {
                re_enc = 1;

                bfKeySize = (strlen(value) * 2) * sizeof(char);
                bfKey = (char *) calloc(bfKeySize, sizeof(char));
                decrypt_string(old_iniKey, value + 4, bfKey, strlen(value + 4));

                newbfKeySize = (strlen(bfKey) * 2)* sizeof(char);
                newbfKey = (char *) calloc(newbfKeySize, sizeof(char));
                encrypt_string(iniKey, bfKey, newbfKey, strlen(bfKey));

                plusOkSize = (strlen(newbfKey) * 2) * sizeof(char);
                plusOk = (char *) calloc(plusOkSize, sizeof(char));
                snprintf(plusOk, plusOkSize, "+OK %s", newbfKey);

                setIniValue(groups[i], keys[j], plusOk, iniPath_new);

                bzero(bfKey, bfKeySize);
                free(bfKey);
                bzero(newbfKey, newbfKeySize);
                free(newbfKey);
                bzero(plusOk, plusOkSize);
                free(plusOk);
            }

            g_free(value);
        }

        g_strfreev(keys);
    }

    g_strfreev(groups);
    g_key_file_free(config);

    remove(iniPath);
    rename(iniPath_new, iniPath);

    return re_enc;
}

void cmd_setinipw(const char *iniPW, SERVER_REC * server, WI_ITEM_REC * item)
{
    int re_enc = 0;
    char B64digest[50] = { '\0' };
    char key[32] = { '\0' };
    char hash[32] = { '\0' };
    char iniPath_new[300];
    int old_iniKeySize;
    char *old_iniKey;
    int new_iniKeySize;
    char *new_iniKey;

    old_iniKeySize = strlen(iniKey) * sizeof(char);
    old_iniKey = (char *) calloc(old_iniKeySize + 1, sizeof(char));
    strcpy(old_iniKey, iniKey);

    if (iniPW != NULL) {
        size_t pw_len = strlen(iniPW);

        new_iniKeySize = pw_len * 2 + 1;
        new_iniKey = (char *) calloc(new_iniKeySize, sizeof(char));

        if (pw_len < 1 || (size_t) pw_len > new_iniKeySize) {
            printtext(server,
                    item !=
                    NULL ? window_item_get_target(item) : NULL,
                    MSGLEVEL_CRAP,
                    "\002FiSH:\002 No parameters. Usage: /setinipw <sekure_blow.ini_password>");
            bzero(old_iniKey, old_iniKeySize);
            free(old_iniKey);
            bzero(new_iniKey, new_iniKeySize);
            free(new_iniKey);
            return;
        }

        if (strfcpy(new_iniKey, (char *)iniPW, new_iniKeySize) == NULL) {
            bzero(old_iniKey, old_iniKeySize);
            free(old_iniKey);
            bzero(new_iniKey, new_iniKeySize);
            free(new_iniKey);
            return;
        }

        ZeroMemory(iniPW, pw_len);
        pw_len = strlen(new_iniKey);

        if (pw_len < 8) {
            printtext(server,
                    item !=
                    NULL ? window_item_get_target(item) : NULL,
                    MSGLEVEL_CRAP,
                    "\002FiSH:\002 Password too short, at least 8 characters needed! Usage: /setinipw <sekure_blow.ini_password>");
            bzero(old_iniKey, old_iniKeySize);
            free(old_iniKey);
            bzero(new_iniKey, new_iniKeySize);
            free(new_iniKey);
            return;
        }

        key_from_password(new_iniKey, key);
        htob64(key, B64digest, 32);

        free(iniKey);
        iniKey = (char *) calloc(strlen(B64digest) * 2, sizeof(char));

        strcpy(iniKey, B64digest); // this is used for encrypting blow.ini

        bzero(new_iniKey, new_iniKeySize);
        free(new_iniKey);
    } else {
        strcpy(iniKey, default_iniKey); // use default blow.ini key
    }

    key_hash(key, hash);
    htob64(hash, B64digest, 32); // this is used to verify the entered password
    ZeroMemory(hash, sizeof(hash));
    ZeroMemory(key, sizeof(key));

    // Try to create blow.ini if it doesnt exist
    open(iniPath, O_CREAT | O_WRONLY | O_EXCL, S_IRUSR | S_IWUSR);

    // re-encrypt blow.ini with new password
    strcpy(iniPath_new, iniPath);
    strcat(iniPath_new, "_new");

    re_enc = recrypt_ini_file(iniPath, iniPath_new, old_iniKey);
    if (re_enc < 0) {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH ERROR:\002 Unable to write new blow.ini, probably out of disc space.");
        ZeroMemory(B64digest, sizeof(B64digest));
        bzero(old_iniKey, old_iniKeySize);
        free(old_iniKey);
        return;
    } else {
        bzero(old_iniKey, old_iniKeySize);
        free(old_iniKey);
    }

    if (setIniValue("FiSH", "ini_password_Hash", B64digest, iniPath) == -1) {
        ZeroMemory(B64digest, sizeof(B64digest));
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH ERROR:\002 Unable to write to blow.ini, probably out of space or permission denied.");
        return;
    }

    ZeroMemory(B64digest, sizeof(B64digest));

    if (re_enc) {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH: Re-encrypted blow.ini\002 with new password.");
    }

    if (iniPW != NULL) {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH:\002 blow.ini password hash saved.");
    }
}

/*
 * Change back to default blow.ini password, irssi syntax: /unsetinipw
 */
static void cmd_unsetinipw(const char *arg, SERVER_REC * server,
        WI_ITEM_REC * item)
{
    cmd_setinipw(NULL, server, item);

    if (setIniValue("FiSH", "ini_password_Hash", "\0", iniPath) == -1) {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH ERROR:\002 Unable to write to blow.ini, probably out of space or permission denied.");
        return;
    }

    printtext(server, item != NULL ? window_item_get_target(item) : NULL,
            MSGLEVEL_CRAP,
            "\002FiSH:\002 Changed back to default blow.ini password, you won't have to enter it on start-up anymore!");
}

int detect_mode(const char *key)
{
    char mode[4];
    int BLOWFISH_ECB = 0;
    int BLOWFISH_CBC = 1;

    if (strlen(key) > 4) {
        strncpy(mode, key, 3);
        mode[3] = '\0';

        if (strcmp(mode, "cbc") == 0) {
            return BLOWFISH_CBC;
        }
    }

    return BLOWFISH_ECB;
}

/**
 * Sets the key for a nick / channel in a server
 * @param data command
 * @param server irssi server record
 * @param item irssi window/item
 */
void cmd_setkey(const char *data, SERVER_REC * server, WI_ITEM_REC * item)
{
    GHashTable *optlist;
    char contactName[CONTACT_SIZE] = "";
    char *encryptedKey;
    int keySize;
    int mode = 0;

    const char *target, *key;
    void *free_arg;

    if (IsNULLorEmpty(data)) {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH:\002 No parameters. Usage: /setkey [-<server tag>] [<nick | #channel>] <key>");
        return;
    }

    if (!cmd_get_params(data, &free_arg, 2 | PARAM_FLAG_OPTIONS |
                PARAM_FLAG_UNKNOWN_OPTIONS | PARAM_FLAG_GETREST,
                "setkey", &optlist, &target, &key))
        return;

    if (*target == '\0') {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH:\002 No parameters. Usage: /setkey [-<server tag>] [<nick | #channel>] <key>");
        cmd_params_free(free_arg);
        return;
    }

    server = cmd_options_get_server("setkey", optlist, server);
    if (server == NULL || !server->connected)
        cmd_param_error(CMDERR_NOT_CONNECTED);

    if (*key == '\0') {
        // one paramter given - it's the key
        key = target;
        if (item != NULL)
            target = window_item_get_target(item);
        else {
            printtext(NULL, NULL, MSGLEVEL_CRAP,
                    "\002FiSH:\002 Please define nick/#channel. Usage: /setkey [-<server tag>] [<nick | #channel>] <key>");
            cmd_params_free(free_arg);
            return;
        }
    }

    keySize = (strlen(key) * 3) * sizeof(char);
    encryptedKey = (char *) calloc(keySize, sizeof(char));
    mode = detect_mode(key);

    if (mode == 1) {
        encrypt_key((char *)key + 4, encryptedKey);
    } else {
        encrypt_key((char *)key, encryptedKey);
    }

    if (getIniSectionForContact(server, target, contactName) == FALSE) {
        bzero(encryptedKey, keySize);
        free(encryptedKey);
        return;
    }

    if (setIniValue(contactName, "key", encryptedKey, iniPath) == -1) {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH ERROR:\002 Unable to write to blow.ini, probably out of space or permission denied.");
        cmd_params_free(free_arg);
        bzero(encryptedKey, keySize);
        free(encryptedKey);
        return;
    }

    if (mode == 1) {
        setIniValue(contactName, "cbc", "1", iniPath);
    } else {
        setIniValue(contactName, "cbc", "0", iniPath);
    }

    bzero(encryptedKey, keySize);
    free(encryptedKey);

    printtext(server, item != NULL ? window_item_get_target(item) : NULL,
            MSGLEVEL_CRAP,
            "\002FiSH:\002 Key for %s@%s (%s) successfully set!", target,
            server->tag, mode == 1 ? "CBC" : "ECB");

    cmd_params_free(free_arg);
}

void cmd_delkey(const char *data, SERVER_REC * server, WI_ITEM_REC * item)
{
    GHashTable *optlist;
    char *target;
    char contactName[CONTACT_SIZE] = "";
    void *free_arg;

    if (!cmd_get_params(data, &free_arg, 1 | PARAM_FLAG_OPTIONS |
                PARAM_FLAG_UNKNOWN_OPTIONS | PARAM_FLAG_GETREST,
                "delkey", &optlist, &target))
        return;

    if (item != NULL && IsNULLorEmpty(target))
        target = (char *)window_item_get_target(item);

    if (IsNULLorEmpty(target)) {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH:\002 No parameters. Usage: /delkey [-<server tag>] [<nick | #channel>]");
        return;
    }

    server = cmd_options_get_server("delkey", optlist, server);
    if (server == NULL || !server->connected)
        cmd_param_error(CMDERR_NOT_CONNECTED);

    target = (char *)g_strchomp(target);

    if (getIniSectionForContact(server, target, contactName) == FALSE)
        return;

    if (deleteIniValue(contactName, "key", iniPath) == 1) {
        printtext(server, item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH:\002 Key for %s@%s successfully removed!", target,
                server->tag);
    } else {
        printtext(server, item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH:\002 No key found for %s@%s", target,
                server->tag);
    }
}

void cmd_key(const char *data, SERVER_REC * server, WI_ITEM_REC * item)
{
    GHashTable *optlist;
    char *target;
    char contactName[CONTACT_SIZE] = "";
    struct IniValue iniValue;
    void *free_arg;

    if (!cmd_get_params(data, &free_arg, 1 | PARAM_FLAG_OPTIONS |
                PARAM_FLAG_UNKNOWN_OPTIONS | PARAM_FLAG_GETREST,
                "key", &optlist, &target))
        return;

    if (item != NULL && IsNULLorEmpty(target))
        target = (char *)window_item_get_target(item);

    if (IsNULLorEmpty(target)) {
        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH:\002 Please define nick/#channel. Usage: /key [-<server tag>] [<nick | #channel>]");
        return;
    }

    server = cmd_options_get_server("key", optlist, server);
    if (server == NULL || !server->connected)
        cmd_param_error(CMDERR_NOT_CONNECTED);

    target = (char *)g_strchomp(target);

    if (getIniSectionForContact(server, target, contactName) == FALSE)
        return;

    iniValue = allocateIni(contactName, "key", iniPath);

    if (getContactKey(contactName, iniValue.key) == FALSE) {
        freeIni(iniValue);

        printtext(server,
                item != NULL ? window_item_get_target(item) : NULL,
                MSGLEVEL_CRAP,
                "\002FiSH:\002 Key for %s@%s not found or invalid!",
                target, server->tag);
        return;
    }

    printtext(server, target, MSGLEVEL_CRAP,
            "\002FiSH:\002 Key for %s@%s: %s (%s)", target, server->tag,
            iniValue.key, iniValue.cbc == 1 ? "CBC" : "ECB");

    freeIni(iniValue);
}

void cmd_keyx(const char *data, SERVER_REC * server, WI_ITEM_REC * item)
{
    GHashTable *optlist = NULL;
    char *target = NULL;
    void *free_arg = NULL;
    int mode = -1;
    char contactName[CONTACT_SIZE] = "";
    struct IniValue iniValue;

    if (server == NULL) {
        printtext(NULL, NULL, MSGLEVEL_CRAP,
                "\002FiSH:\002 No connection to server.");
        goto fail;
    }

    if (!cmd_get_params(data, &free_arg, 1 | PARAM_FLAG_GETREST | PARAM_FLAG_OPTIONS,
	        "keyx", &optlist, &target))
        goto fail;

    if (g_hash_table_lookup(optlist, "ecb") != NULL) {
        mode = 0;
    }

    if (g_hash_table_lookup(optlist, "cbc") != NULL) {
        mode = 1;
    }

    if (item != NULL && IsNULLorEmpty(target))
        target = (char *)window_item_get_target(item);

    if (IsNULLorEmpty(target)) {
        printtext(NULL, NULL, MSGLEVEL_CRAP,
                "\002FiSH:\002 Please define nick/#channel. Usage: /keyx [-ecb|-cbc] <nick>");
        goto fail;
    }

    if (server_ischannel(server, target)) {
        printtext(server, target, MSGLEVEL_CRAP,
                "\002FiSH:\002 KeyXchange does not work for channels!");
        goto fail;
    }

    target = (char *)g_strchomp(target);

    if ((mode == -1) && (getIniSectionForContact(server, target, contactName))) {
        iniValue = allocateIni(contactName, "key", iniPath);
        if (iniValue.iniKeySize == 1) {
            mode = 1;
        } else {
            mode = iniValue.cbc;
        }
        freeIni(iniValue);
    }

    DH1080_gen(g_myPrivKey, g_myPubKey);

    irc_send_cmdv((IRC_SERVER_REC *) server, "NOTICE %s :%s%s%s", target,
            DH1080_INIT, g_myPubKey, mode == 1 ? CBC_SUFFIX : "");

    printtext(server, item != NULL ? window_item_get_target(item) : NULL,
            MSGLEVEL_CRAP,
            "\002FiSH:\002 Sent my DH1080 public key to %s@%s (%s), waiting for reply ...",
            target, server->tag, mode == 1 ? "CBC" : "ECB");
fail:
    if(free_arg) {
        cmd_params_free(free_arg);
    }
}

void DH1080_received(SERVER_REC * server, char *msg, char *nick, char *address,
        char *target)
{
    int msg_len;
    char hisPubKey[300];
    char contactName[CONTACT_SIZE] = "";
    char encryptedKey[KEYBUF_SIZE] = "";
    // 0 for ECB, 1 for CBC
    int mode = 0;
    const unsigned int DH1080_INIT_LEN = strlen(DH1080_INIT);
    const unsigned int DH1080_FINISH_LEN = strlen(DH1080_FINISH);
    const unsigned int CBC_SUFFIX_LEN = strlen(CBC_SUFFIX);

    if (server_ischannel(server, target) || server_ischannel(server, nick))
        return; // no KeyXchange for channels...

    msg_len = strlen(msg);

    if (msg_len < 191 || msg_len > 199)
        return;

    if (strncmp(msg, DH1080_INIT, DH1080_INIT_LEN) == 0) {

        // Check for CBC at the end
        if (strcmp(msg + msg_len - CBC_SUFFIX_LEN, " CBC") == 0) {
            mode = 1;
        }

        if (mode == 0) {
            strcpy(hisPubKey, msg + DH1080_INIT_LEN);
        } else {
            // Strip the " CBC" at the end
            strncpy(hisPubKey, msg + DH1080_INIT_LEN, msg_len - DH1080_INIT_LEN - CBC_SUFFIX_LEN);
            hisPubKey[msg_len - DH1080_INIT_LEN - CBC_SUFFIX_LEN] = '\0';
        }

        // This check only applies to ECB
        if ((mode == 0) && (strspn(hisPubKey, B64ABC) != strlen(hisPubKey)))
            return;

        if (query_find(server, nick) == NULL) { // query window not found, lets create one
            keyx_query_created = 1;
            irc_query_create(server->tag, nick, TRUE);
            keyx_query_created = 0;
        }

        printtext(server, nick, MSGLEVEL_CRAP,
                "\002FiSH:\002 Received DH1080 public key from %s@%s (%s), sending mine...",
                nick, server->tag, mode == 0 ? "ECB" : "CBC");

        DH1080_gen(g_myPrivKey, g_myPubKey);

        irc_send_cmdv((IRC_SERVER_REC *) server, "NOTICE %s :%s%s%s",
                nick, DH1080_FINISH, g_myPubKey, mode == 1 ? CBC_SUFFIX : "");

    } else if (strncmp(msg, DH1080_FINISH, DH1080_FINISH_LEN) == 0) {

        msg_len = strlen(msg);

        // Check for CBC at the end
        if (strcmp(msg + msg_len - CBC_SUFFIX_LEN, CBC_SUFFIX) == 0) {
            mode = 1;
        }

        if (mode == 0) {
            strcpy(hisPubKey, msg + DH1080_FINISH_LEN);
        } else {
            // Strip the " CBC" at the end
            strncpy(hisPubKey, msg + DH1080_FINISH_LEN, msg_len - DH1080_FINISH_LEN - CBC_SUFFIX_LEN);
            hisPubKey[msg_len - DH1080_FINISH_LEN - CBC_SUFFIX_LEN] = '\0';
        }
    } else {
        return;
    }

    if (DH1080_comp(g_myPrivKey, hisPubKey) == 0)
        return;
    signal_stop();

    encrypt_key(hisPubKey, encryptedKey);
    ZeroMemory(hisPubKey, sizeof(hisPubKey));

    if (getIniSectionForContact(server, nick, contactName) == FALSE)
        return;

    if (setIniValue(contactName, "key", encryptedKey, iniPath) == -1) {
        ZeroMemory(encryptedKey, KEYBUF_SIZE);
        printtext(server, nick, MSGLEVEL_CRAP,
                "\002FiSH ERROR:\002 Unable to write to blow.ini, probably out of space or permission denied.");
        return;
    }

    // Remember mode
    if (setIniValue(contactName, "cbc", mode == 0 ? "0" : "1", iniPath) == -1) {
        printtext(server, nick, MSGLEVEL_CRAP,
                "\002FiSH ERROR:\002 Unable to write to blow.ini, probably out of space or permission denied.");
        return;
    }

    ZeroMemory(encryptedKey, KEYBUF_SIZE);

    printtext(server, nick, MSGLEVEL_CRAP,
            "\002FiSH:\002 Key for %s@%s (%s) successfully set!", nick, server->tag, mode == 0 ? "ECB" : "CBC");
}

/*
 * Perform auto-keyXchange only for known people
 */
void do_auto_keyx(QUERY_REC * query, int automatic)
{
    char contactName[CONTACT_SIZE] = "";

    if (keyx_query_created)
        return; // query was created by FiSH

    if (settings_get_bool("auto_keyxchange") == 0)
        return;

    if (getIniSectionForContact(query->server, query->name, contactName) ==
            FALSE)
        return;

    if (getContactKey(contactName, NULL))
        cmd_keyx(query->name, query->server, NULL);
}

/*
 * Copy key for old nick to use with the new one
 */
void query_nick_changed(QUERY_REC * query, char *orignick)
{
    struct IniValue iniValue;
    char contactName[CONTACT_SIZE] = "";

    if (settings_get_bool("nicktracker") == 0)
        return;

    if (orignick == NULL || strcasecmp(orignick, query->name) == 0)
        return; // same nick, different case?

    if (getIniSectionForContact(query->server, orignick, contactName) ==
            FALSE)
        return;

    iniValue = allocateIni(contactName, "key", iniPath);

    if (getContactKey(contactName, iniValue.key) == FALSE) {
        freeIni(iniValue);
        return; // see if there is a key for the old nick
    }

    if (getIniSectionForContact(query->server, query->name, contactName) ==
            FALSE) {
        freeIni(iniValue);
        return;
    }

    if (setIniValue(contactName, "key", iniValue.key, iniPath) == -1)
        printtext(NULL, NULL, MSGLEVEL_CRAP,
                "\002FiSH ERROR:\002 Unable to write to blow.ini, probably out of space or permission denied.");

    freeIni(iniValue);
}

void calculate_password_key_and_hash(const char *a_password,
        char *a_key, char *a_hash)
{
    char key[256 / 8];
    char hash[256 / 8];

    key_from_password(a_password, key);
    htob64(key, a_key, 32);

    key_hash(key, hash);
    htob64(hash, a_hash, 32);
}

/**
 * Iterate over all channels and send the "channel topic changed" signal to it
 * If any of them is FiSHed and you have the key, the topicbar will be updated
 */
void refresh_topics()
{
    GSList *list;

    for (list = channels; list != NULL; list = g_slist_next(list)) {
        CHANNEL_REC *rec = list->data;
        signal_emit("channel topic changed", 1, rec);
    }
}

void setup_fish()
{
    signal_add_first("server sendmsg", (SIGNAL_FUNC) encrypt_msg);
    signal_add_first("message private", (SIGNAL_FUNC) decrypt_msg);
    signal_add_first("message public", (SIGNAL_FUNC) decrypt_msg);
    signal_add_first("message irc notice", (SIGNAL_FUNC) decrypt_notice);
    signal_add_first("message irc action", (SIGNAL_FUNC) decrypt_action);

    signal_add_first("message own_private", (SIGNAL_FUNC) format_msg);
    signal_add_first("message own_public", (SIGNAL_FUNC) format_msg);

    signal_add_first("channel topic changed",
            (SIGNAL_FUNC) decrypt_changed_topic);
    signal_add_first("message topic", (SIGNAL_FUNC) decrypt_topic);
    signal_add_first("server incoming", (SIGNAL_FUNC) raw_handler);

    signal_add("query created", (SIGNAL_FUNC) do_auto_keyx);
    signal_add("query nick changed", (SIGNAL_FUNC) query_nick_changed);

    signal_add("complete command topic+", (SIGNAL_FUNC) sig_complete_topic_plus);

    command_bind("topic+", NULL, (SIGNAL_FUNC) cmd_crypt_topic);
    command_bind("notice+", NULL, (SIGNAL_FUNC) cmd_crypt_notice);
    command_bind("me+", NULL, (SIGNAL_FUNC) cmd_crypt_action);
    command_bind("setkey", NULL, (SIGNAL_FUNC) cmd_setkey);
    command_bind("delkey", NULL, (SIGNAL_FUNC) cmd_delkey);
    command_bind("key", NULL, (SIGNAL_FUNC) cmd_key);
    command_bind("showkey", NULL, (SIGNAL_FUNC) cmd_key);
    command_bind("keyx", NULL, (SIGNAL_FUNC) cmd_keyx);
    command_set_options("keyx", "-ecb -cbc");
    command_bind("setinipw", NULL, (SIGNAL_FUNC) cmd_setinipw);
    command_bind("unsetinipw", NULL, (SIGNAL_FUNC) cmd_unsetinipw);

    refresh_topics();
}

void get_ini_password_hash(int password_size, char* password) {
    getIniValue("FiSH", "ini_password_Hash", "0", password,
            password_size, iniPath);
}


void authenticated_fish_setup(const char *password, void *rec) {
    char *B64digest;
    struct IniValue iniValue;

    if (strlen(password) == 0) {
        return;
    }

    if (iniUsed == 1) {
        free(iniKey);
        iniUsed = 0;
    }

    iniKey = (char *) calloc((strlen(password) * 10), sizeof(char));
    iniUsed = 1;

    iniValue = allocateIni("FiSH", "ini_password_Hash", iniPath);

    // Verify if the key really exists
    if (iniValue.iniKeySize == 1) {
        printtext(NULL, NULL, MSGLEVEL_CRAP, "\002FiSH:\002 No password set for blow.ini");
        return;
    }

    get_ini_password_hash(iniValue.keySize, iniValue.key);

    B64digest = (char *) calloc((iniValue.keySize * 2), sizeof(char));

    calculate_password_key_and_hash(password, iniKey, B64digest);

    if (strcmp(B64digest, iniValue.key) != 0) {
        bzero(B64digest, (iniValue.keySize * 2) * sizeof(char));
        free(B64digest);
        freeIni(iniValue);

        printtext(NULL, NULL, MSGLEVEL_CRAP,
                "\002FiSH:\002 Wrong blow.ini password entered... Please \002/fishlogin\002 to try again");
        return;
    }

    printtext(NULL, NULL, MSGLEVEL_CRAP,
            "\002FiSH:\002 Correct blow.ini password entered, lets go!");

    bzero(B64digest, (iniValue.keySize * 2) * sizeof(char));
    free(B64digest);
    freeIni(iniValue);

    setup_fish();
}

void cmd_fishlogin(const char *data, SERVER_REC * server, WI_ITEM_REC * item) {
    keyboard_entry_redirect((SIGNAL_FUNC) authenticated_fish_setup,
            " --> Please enter your blow.ini password: ",
            ENTRY_REDIRECT_FLAG_HIDDEN, NULL);

}

#ifdef IRSSI_ABI_VERSION
void fish_abicheck(int *version)
{
    *version = IRSSI_ABI_VERSION;
}
#endif

void fish_init(void)
{
    struct IniValue iniValue;

    printtext(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
            "FiSH " FISH_VERSION " - encryption module for irssi loaded!\n"
            "URL: https://github.com/falsovsky/FiSH-irssi\n"
            "Try /helpfish or /fishhelp for a short command overview");

    command_bind("fishhelp", NULL, (SIGNAL_FUNC) cmd_helpfish);
    command_bind("helpfish", NULL, (SIGNAL_FUNC) cmd_helpfish);
    command_bind("fishlogin", NULL, (SIGNAL_FUNC) cmd_fishlogin);

    settings_add_bool_module("fish", "fish", "process_outgoing", 1);
    settings_add_bool_module("fish", "fish", "process_incoming", 1);
    settings_add_bool_module("fish", "fish", "auto_keyxchange", 1);
    settings_add_bool_module("fish", "fish", "nicktracker", 1);
    settings_add_str_module("fish", "fish", "mark_broken_block",
            "\002&\002");
    settings_add_str_module("fish", "fish", "mark_encrypted", "\002>\002 ");
    settings_add_str_module("fish", "fish", "plain_prefix", "+p ");
    settings_add_int_module("fish", "fish", "mark_position", 1);

    if (DH1080_Init() == FALSE)
        return;

    strcpy(iniPath, get_irssi_config()); // path to irssi config file
    strcpy(strrchr(iniPath, '/'), blow_ini);

    iniValue = allocateIni("FiSH", "ini_password_Hash", iniPath);

    get_ini_password_hash(iniValue.keySize, iniValue.key);

    if (strlen(iniValue.key) != 43) {
        iniKey = (char *) calloc((strlen(default_iniKey)* 2), sizeof(char));
        iniUsed = 1;

        strcpy(iniKey, default_iniKey);
        printtext(NULL, NULL, MSGLEVEL_CRAP,
                "\002FiSH:\002 Using default password to decrypt blow.ini... Try /setinipw to set a custom password.");

        setup_fish();
    } else {
        printtext(NULL, NULL, MSGLEVEL_CRAP,
                "\002FiSH:\002 Current blow.ini is password protected.");
        cmd_fishlogin(NULL, NULL, NULL);
    }

    module_register("fish", "core");

    free(iniValue.key);
}


void fish_deinit(void)
{
    signal_remove("server sendmsg", (SIGNAL_FUNC) encrypt_msg);
    signal_remove("message private", (SIGNAL_FUNC) decrypt_msg);
    signal_remove("message public", (SIGNAL_FUNC) decrypt_msg);
    signal_remove("message irc notice", (SIGNAL_FUNC) decrypt_notice);
    signal_remove("message irc action", (SIGNAL_FUNC) decrypt_action);

    signal_remove("message own_private", (SIGNAL_FUNC) format_msg);
    signal_remove("message own_public", (SIGNAL_FUNC) format_msg);

    signal_remove("channel topic changed",
            (SIGNAL_FUNC) decrypt_changed_topic);
    signal_remove("message topic", (SIGNAL_FUNC) decrypt_topic);
    signal_remove("server incoming", (SIGNAL_FUNC) raw_handler);

    signal_remove("query created", (SIGNAL_FUNC) do_auto_keyx);
    signal_remove("query nick changed", (SIGNAL_FUNC) query_nick_changed);

    command_unbind("topic+", (SIGNAL_FUNC) cmd_crypt_topic);
    command_unbind("notice+", (SIGNAL_FUNC) cmd_crypt_notice);
    command_unbind("notfish", (SIGNAL_FUNC) cmd_crypt_notice);
    command_unbind("me+", (SIGNAL_FUNC) cmd_crypt_action);
    command_unbind("setkey", (SIGNAL_FUNC) cmd_setkey);
    command_unbind("delkey", (SIGNAL_FUNC) cmd_delkey);
    command_unbind("key", (SIGNAL_FUNC) cmd_key);
    command_unbind("showkey", (SIGNAL_FUNC) cmd_key);
    command_unbind("keyx", (SIGNAL_FUNC) cmd_keyx);
    command_unbind("setinipw", (SIGNAL_FUNC) cmd_setinipw);
    command_unbind("unsetinipw", (SIGNAL_FUNC) cmd_unsetinipw);
    command_unbind("fishlogin", (SIGNAL_FUNC) cmd_fishlogin);

    command_unbind("fishhelp", (SIGNAL_FUNC) cmd_helpfish);
    command_unbind("helpfish", (SIGNAL_FUNC) cmd_helpfish);

    DH1080_DeInit();

    if (iniUsed == 1) {
        free(iniKey);
        iniUsed = 0;
    }
}

/*
 * Removes leading and trailing blanks from string
 * @param dest destination buffer
 * @param buffer string to clean
 * @param destSize size of destination buffer
 * @return destination buffer
 */
char *strfcpy(char *dest, char *buffer, int destSize)
{
    int i = 0, k = strlen(buffer);

    if (k < 2)
        return NULL;

    while (buffer[i] == ' ')
        i++;
    while (buffer[k - 1] == ' ')
        k--;

    buffer[k] = 0;

    strncpy(dest, buffer + i, destSize);
    dest[destSize - 1] = '\0';
    return dest;
}

/**
 * Checks is the message if prefixed with the "plain_prefix" variable
 * @param msg message to check
 * @returns the string without the "plain_prefix" prefix, or NULL if not prefixed with it
 */
char *isPlainPrefix(const char *msg)
{
    char plainPrefix[20] = "";

    strncpy(plainPrefix, settings_get_str("plain_prefix"),
            sizeof(plainPrefix));
    if (*plainPrefix != '\0') {
        int i = strlen(plainPrefix);
        if (strncasecmp(msg, plainPrefix, i) == 0)
            return (char *)msg + i;
    }

    return NULL;
}