8 files changed, 194 insertions, 172 deletions
diff --git a/testing/Messenger_test.c b/testing/Messenger_test.c
index a11d374b..fa5d6890 100644
--- a/testing/Messenger_test.c
+++ b/testing/Messenger_test.c
@@ -1,21 +1,21 @@
 /* Messenger test
- * 
+ *
 * This program adds a friend and accepts all friend requests with the proper message.
- * 
+ *
 * It tries sending a message to the added friend.
- * 
+ *
 * If it receives a message from a friend it replies back.
- * 
+ *
- * 
+ *
 * This is how I compile it: gcc -O2 -Wall -D VANILLA_NACL -o test ../core/Lossless_UDP.c ../core/network.c ../core/net_crypto.c ../core/Messenger.c ../core/DHT.c ../nacl/build/${HOSTNAME%.*}/lib/amd64/{cpucycles.o,libnacl.a,randombytes.o} Messenger_test.c
 *
- * 
+ *
 * Command line arguments are the ip, port and public_key of a node (for bootstrapping).
- * 
+ *
 * EX: ./test 127.0.0.1 33445 CDCFD319CE3460824B33BE58FD86B8941C9585181D8FBD7C79C5721D7C2E9F7C
- * 
+ *
 * Or the argument can be the path to the save file.
- * 
+ *
 * EX: ./test Save.bak
 *
 *  Copyright (C) 2013 Tox project All Rights Reserved.
@@ -34,7 +34,7 @@
 *
 *  You should have received a copy of the GNU General Public License
 *  along with Tox.  If not, see <http://www.gnu.org/licenses/>.
- *  
+ *
 */
 #include "../core/Messenger.h"
@@ -51,7 +51,11 @@
 #endif
-void print_request(uint8_t * public_key, uint8_t * data, uint16_t length)
+/* FIXME needed as print_request has to match the interface expected by
+ * networking_requesthandler and so cannot take a Messenger * */
+static Messenger *m;
+void print_request(uint8_t * public_key, uint8_t * data, uint16_t length, void* userdata)
 {
    printf("Friend request received from: \n");
    printf("ClientID: ");
@@ -63,7 +67,7 @@ void print_request(uint8_t * public_key, uint8_t * data, uint16_t length)
        printf("%hhX", public_key[j]);
    }
    printf("\nOf length: %u with data: %s \n", length, data);
-    
    if(length != sizeof("Install Gentoo"))
    {
        return;
@@ -72,14 +76,14 @@ void print_request(uint8_t * public_key, uint8_t * data, uint16_t length)
    //if the request contained the message of peace the person is obviously a friend so we add him.
    {
        printf("Friend request accepted.\n");
-        m_addfriend_norequest(public_key);
+        m_addfriend_norequest(m, public_key);
    }
 }
-void print_message(int friendnumber, uint8_t * string, uint16_t length)
+void print_message(Messenger *m, int friendnumber, uint8_t * string, uint16_t length, void* userdata)
 {
    printf("Message with length %u received from %u: %s \n", length, friendnumber, string);
-    m_sendmessage(friendnumber, (uint8_t*)"Test1", 6);
+    m_sendmessage(m, friendnumber, (uint8_t*)"Test1", 6);
 }
 int main(int argc, char *argv[])
@@ -88,7 +92,13 @@ int main(int argc, char *argv[])
        printf("usage %s ip port public_key (of the DHT bootstrap node)\n or\n %s Save.bak\n", argv[0], argv[0]);
        exit(0);
    }
-    initMessenger();
+    m = initMessenger();
+    if( !m ){
+        fputs("Failed to allocate messenger datastructure\n", stderr);
+        exit(0);
+    }
    if(argc > 3) {
        IP_Port bootstrap_ip_port;
        bootstrap_ip_port.port = htons(atoi(argv[2]));
@@ -100,13 +110,13 @@ int main(int argc, char *argv[])
        int read;
        uint8_t buffer[128000];
        read = fread(buffer, 1, 128000, file);
-        printf("Messenger loaded: %i\n", Messenger_load(buffer, read));
+        printf("Messenger loaded: %i\n", Messenger_load(m, buffer, read));
        fclose(file);
-        
    }
-    m_callback_friendrequest(print_request);
+    m_callback_friendrequest(m, print_request, NULL);
-    m_callback_friendmessage(print_message);
+    m_callback_friendmessage(m, print_message, NULL);
-    
    printf("OUR ID: ");
    uint32_t i;
    for(i = 0; i < 32; i++) {
@@ -114,33 +124,34 @@ int main(int argc, char *argv[])
            printf("0");
        printf("%hhX",self_public_key[i]);
    }
-    
-    setname((uint8_t *)"Anon", 5);
+    setname(m, (uint8_t *)"Anon", 5);
-    
    char temp_id[128];
    printf("\nEnter the client_id of the friend you wish to add (32 bytes HEX format):\n");
    if(scanf("%s", temp_id) != 1) {
        return 1;
    }
-    int num = m_addfriend(hex_string_to_bin(temp_id), (uint8_t*)"Install Gentoo", sizeof("Install Gentoo"));
+    int num = m_addfriend(m, hex_string_to_bin(temp_id), (uint8_t*)"Install Gentoo", sizeof("Install Gentoo"));
-    
    perror("Initialization");
    while(1) {
        uint8_t name[128];
-        getname(num, name);
+        getname(m, num, name);
        printf("%s\n", name);
-        
-        m_sendmessage(num, (uint8_t*)"Test", 5);
+        m_sendmessage(m, num, (uint8_t*)"Test", 5);
-        doMessenger();
+        doMessenger(m);
        c_sleep(30);
        FILE *file = fopen("Save.bak", "wb");
        if ( file==NULL ){return 1;}
-        uint8_t * buffer = malloc(Messenger_size());
+        uint8_t * buffer = malloc(Messenger_size(m));
-        Messenger_save(buffer);
+        Messenger_save(m, buffer);
-        size_t write_result = fwrite(buffer, 1, Messenger_size(), file);
+        size_t write_result = fwrite(buffer, 1, Messenger_size(m), file);
-        if (write_result < Messenger_size()) {return 1;}
+        if (write_result < Messenger_size(m)) {return 1;}
        free(buffer);
        fclose(file);
-    }  
+    }
+    cleanupMessenger(m);
 }
diff --git a/testing/nTox.c b/testing/nTox.c
index ee4d7de4..59d1cbf6 100644
--- a/testing/nTox.c
+++ b/testing/nTox.c
@@ -85,12 +85,12 @@ void new_lines(char *line)
 }
-void print_friendlist()
+void print_friendlist(Messenger *m)
 {
    char name[MAX_NAME_LENGTH];
    int i = 0;
    new_lines("[i] Friend List:");
-    while(getname(i, (uint8_t *)name) != -1) {
+    while(getname(m, i, (uint8_t *)name) != -1) {
        /* account for the longest name and the longest "base" string */
        char fstring[MAX_NAME_LENGTH + strlen("[i] Friend: NULL\n\tid: ")];
@@ -107,13 +107,13 @@ void print_friendlist()
        new_lines("\tno friends! D:");
 }
-char *format_message(char *message, int friendnum)
+char *format_message(Messenger *m, char *message, int friendnum)
 {
    char name[MAX_NAME_LENGTH];
    if (friendnum != -1) {
-            getname(friendnum, (uint8_t*)name);
+            getname(m, friendnum, (uint8_t*)name);
    } else {
-            getself_name((uint8_t*)name);
+            getself_name(m, (uint8_t*)name);
    }
    char *msg = malloc(100+strlen(message)+strlen(name)+1);
@@ -133,7 +133,7 @@ char *format_message(char *message, int friendnum)
    return msg;
 }
-void line_eval(char *line)
+void line_eval(Messenger *m, char *line)
 {
    if (line[0] == '/') {
        char inpt_command = line[1];
@@ -148,7 +148,7 @@ void line_eval(char *line)
                temp_id[i] = line[i+prompt_offset];
            unsigned char *bin_string = hex_string_to_bin(temp_id);
-            int num = m_addfriend(bin_string, (uint8_t*)"Install Gentoo", sizeof("Install Gentoo"));
+            int num = m_addfriend(m, bin_string, (uint8_t*)"Install Gentoo", sizeof("Install Gentoo"));
            free(bin_string);
            char numstring[100];
            switch (num) {
@@ -175,7 +175,7 @@ void line_eval(char *line)
            do_refresh();
        }
        else if (inpt_command == 'd') {
-            doMessenger();
+            doMessenger(m);
        }
        else if (inpt_command == 'm') { //message command: /m friendnumber messsage
            size_t len = strlen(line);
@@ -196,10 +196,10 @@ void line_eval(char *line)
                }
            }
            int num = atoi(numstring);
-            if (m_sendmessage(num, (uint8_t*) message, strlen(message) + 1) != 1) {
+            if (m_sendmessage(m, num, (uint8_t*) message, strlen(message) + 1) != 1) {
                new_lines("[i] could not send message");
            } else {
-                new_lines(format_message(message, -1));
+                new_lines(format_message(m, message, -1));
            }
        }
        else if (inpt_command == 'n') {
@@ -211,13 +211,13 @@ void line_eval(char *line)
                name[i-3] = line[i];
            }
            name[i-3] = 0;
-            setname(name, i - 2);
+            setname(m, name, i - 2);
            char numstring[100];
            sprintf(numstring, "[i] changed nick to %s", (char*)name);
            new_lines(numstring);
        }
        else if (inpt_command == 'l') {
-            print_friendlist();
+            print_friendlist(m);
        }
        else if (inpt_command == 's') {
            uint8_t status[MAX_STATUSMESSAGE_LENGTH];
@@ -228,7 +228,7 @@ void line_eval(char *line)
                status[i-3] = line[i];
            }
            status[i-3] = 0;
-            m_set_statusmessage(status, strlen((char*)status) + 1);
+            m_set_statusmessage(m, status, strlen((char*)status) + 1);
            char numstring[100];
            sprintf(numstring, "[i] changed status to %s", (char*)status);
            new_lines(numstring);
@@ -240,7 +240,7 @@ void line_eval(char *line)
                sprintf(numchar,"[i] you either didn't receive that request or you already accepted it");
                new_lines(numchar);
            } else {
-                int num = m_addfriend_norequest(pending_requests[numf].id);
+                int num = m_addfriend_norequest(m, pending_requests[numf].id);
                if (num != -1) {
                    pending_requests[numf].accepted = 1;
                    sprintf(numchar, "[i] friend request %u accepted", numf);
@@ -336,7 +336,7 @@ void do_refresh()
    refresh();
 }
-void print_request(uint8_t *public_key, uint8_t *data, uint16_t length)
+void print_request(uint8_t *public_key, uint8_t *data, uint16_t length, void* userdata)
 {
    new_lines("[i] received friend request with message:");
    new_lines((char *)data);
@@ -349,32 +349,32 @@ void print_request(uint8_t *public_key, uint8_t *data, uint16_t length)
    do_refresh();
 }
-void print_message(int friendnumber, uint8_t * string, uint16_t length)
+void print_message(Messenger *m, int friendnumber, uint8_t * string, uint16_t length, void* userdata)
 {
-    new_lines(format_message((char*)string, friendnumber));
+    new_lines(format_message(m, (char*)string, friendnumber));
 }
-void print_nickchange(int friendnumber, uint8_t *string, uint16_t length)
+void print_nickchange(Messenger *m, int friendnumber, uint8_t *string, uint16_t length, void* userdata)
 {
    char name[MAX_NAME_LENGTH];
-    if(getname(friendnumber, (uint8_t*)name) != -1) {
+    if(getname(m, friendnumber, (uint8_t*)name) != -1) {
        char msg[100+length];
        sprintf(msg, "[i] [%d] %s is now known as %s.", friendnumber, name, string);
        new_lines(msg);
    }
 }
-void print_statuschange(int friendnumber, uint8_t *string, uint16_t length)
+void print_statuschange(Messenger *m, int friendnumber, uint8_t *string, uint16_t length, void* userdata)
 {
    char name[MAX_NAME_LENGTH];
-    if(getname(friendnumber, (uint8_t*)name) != -1) {
+    if(getname(m, friendnumber, (uint8_t*)name) != -1) {
        char msg[100+length+strlen(name)+1];
        sprintf(msg, "[i] [%d] %s's status changed to %s.", friendnumber, name, string);
        new_lines(msg);
    }
 }
-void load_key(char *path)
+void load_key(Messenger *m, char *path)
 {
    FILE *data_file = fopen(path, "r");
    int size = 0;
@@ -390,13 +390,13 @@ void load_key(char *path)
            fputs("[!] could not read data file! exiting...\n", stderr);
            goto FILE_ERROR;
        }
-        Messenger_load(data, size);
+        Messenger_load(m, data, size);
    } else {
        //else save new keys
-        int size = Messenger_size();
+        int size = Messenger_size(m);
        uint8_t data[size];
-        Messenger_save(data);
+        Messenger_save(m, data);
        data_file = fopen(path, "w");
        if(!data_file) {
@@ -435,6 +435,7 @@ int main(int argc, char *argv[])
    int i = 0;
    char *filename = "data";
    char idstring[200] = {0};
+    Messenger *m;
    if (argc < 4) {
        printf("[!] Usage: %s [IP] [port] [public_key] <keyfile>\n", argv[0]);
@@ -458,13 +459,18 @@ int main(int argc, char *argv[])
        }
    }
-    initMessenger();
+    m = initMessenger();
-    load_key(filename);
+    if( !m ){
+        fputs("Failed to allocate Messenger datastructure", stderr);
+        exit(0);
+    }
+    load_key(m, filename);
-    m_callback_friendrequest(print_request);
+    m_callback_friendrequest(m, print_request, NULL);
-    m_callback_friendmessage(print_message);
+    m_callback_friendmessage(m, print_message, NULL);
-    m_callback_namechange(print_nickchange);
+    m_callback_namechange(m, print_nickchange, NULL);
-    m_callback_statusmessage(print_statuschange);
+    m_callback_statusmessage(m, print_statuschange, NULL);
    initscr();
    noecho();
@@ -494,7 +500,7 @@ int main(int argc, char *argv[])
            on = 1;
        }
-        doMessenger();
+        doMessenger(m);
        c_sleep(1);
        do_refresh();
@@ -504,7 +510,7 @@ int main(int argc, char *argv[])
        getmaxyx(stdscr, y, x);
        if (c == '\n') {
-            line_eval(line);
+            line_eval(m, line);
            strcpy(line, "");
        } else if (c == 8 || c == 127) {
            line[strlen(line)-1] = '\0';
@@ -512,6 +518,7 @@ int main(int argc, char *argv[])
            strcpy(line, appender(line, (char) c));
        }
    }
+    cleanupMessenger(m);
    endwin();
    return 0;
 }
diff --git a/testing/nTox.h b/testing/nTox.h
index 47c73513..fdd88fb4 100644
--- a/testing/nTox.h
+++ b/testing/nTox.h
@@ -1,5 +1,5 @@
 /* nTox.h
- * 
+ *
 *Textual frontend for Tox.
 *
 *  Copyright (C) 2013 Tox project All Rights Reserved.
@@ -18,7 +18,7 @@
 *
 *  You should have received a copy of the GNU General Public License
 *  along with Tox.  If not, see <http://www.gnu.org/licenses/>.
- *  
+ *
 */
 #ifndef NTOX_H
@@ -43,7 +43,7 @@
 #define PUB_KEY_BYTES 32
 void new_lines(char *line);
-void line_eval(char *line);
+void line_eval(Messenger *m, char *line);
 void wrap(char output[STRING_LENGTH], char input[STRING_LENGTH], int line_width) ;
 int count_lines(char *string) ;
 char *appender(char *str, const char c);
diff --git a/testing/toxic/chat.c b/testing/toxic/chat.c
index e1897230..112b20b7 100644
--- a/testing/toxic/chat.c
+++ b/testing/toxic/chat.c
@@ -29,9 +29,9 @@ extern int active_window;
 extern void del_window(ToxWindow *w, int f_num);
 extern void fix_name(uint8_t *name);
 void print_help(ChatContext *self);
-void execute(ToxWindow *self, ChatContext *ctx, char *cmd, struct tm *timeinfo);
+void execute(ToxWindow *self, ChatContext *ctx, Messenger *m, char *cmd, struct tm *timeinfo);
-static void chat_onMessage(ToxWindow *self, int num, uint8_t *msg, uint16_t len)
+static void chat_onMessage(ToxWindow *self, Messenger *m, int num, uint8_t *msg, uint16_t len)
 {
  ChatContext *ctx = (ChatContext*) self->x;
  uint8_t nick[MAX_NAME_LENGTH] = {0};
@@ -43,7 +43,7 @@ static void chat_onMessage(ToxWindow *self, int num, uint8_t *msg, uint16_t len)
  if (ctx->friendnum != num)
    return;
-  getname(num, (uint8_t*) &nick);
+  getname(m, num, (uint8_t*) &nick);
  msg[len-1] = '\0';
  nick[MAX_NAME_LENGTH-1] = '\0';
  fix_name(msg);
@@ -61,7 +61,7 @@ static void chat_onMessage(ToxWindow *self, int num, uint8_t *msg, uint16_t len)
  beep();
 }
-static void chat_onAction(ToxWindow *self, int num, uint8_t *action, uint16_t len)
+static void chat_onAction(ToxWindow *self, Messenger *m, int num, uint8_t *action, uint16_t len)
 {
  ChatContext *ctx = (ChatContext*) self->x;
  time_t now;
@@ -117,7 +117,7 @@ int string_is_empty(char *string)
  return rc;
 }
-static void chat_onKey(ToxWindow *self, int key)
+static void chat_onKey(ToxWindow *self, Messenger *m, int key)
 {
  ChatContext *ctx = (ChatContext*) self->x;
  time_t now;
@@ -155,7 +155,7 @@ static void chat_onKey(ToxWindow *self, int key)
    wmove(self->window, y2-CURS_Y_OFFSET, 0);
    wclrtobot(self->window);
    if (ctx->line[0] == '/')
-      execute(self, ctx, ctx->line, timeinfo);
+      execute(self, ctx, m, ctx->line, timeinfo);
    else {
      if (!string_is_empty(ctx->line)) {
        /* make sure the string has at least non-space character */
@@ -167,7 +167,7 @@ static void chat_onKey(ToxWindow *self, int key)
        wattroff(ctx->history, COLOR_PAIR(1));
        wprintw(ctx->history, "%s\n", ctx->line);
      }
-      if (m_sendmessage(ctx->friendnum, (uint8_t*) ctx->line, strlen(ctx->line)+1) == 0) {
+      if (m_sendmessage(m, ctx->friendnum, (uint8_t*) ctx->line, strlen(ctx->line)+1) == 0) {
        wattron(ctx->history, COLOR_PAIR(3));
        wprintw(ctx->history, " * Failed to send message.\n");
        wattroff(ctx->history, COLOR_PAIR(3));
@@ -178,7 +178,7 @@ static void chat_onKey(ToxWindow *self, int key)
  }
 }
-void execute(ToxWindow *self, ChatContext *ctx, char *cmd, struct tm *timeinfo)
+void execute(ToxWindow *self, ChatContext *ctx, Messenger *m, char *cmd, struct tm *timeinfo)
 {
  if (!strcmp(cmd, "/clear") || !strcmp(cmd, "/c")) {
    wclear(self->window);
@@ -210,14 +210,14 @@ void execute(ToxWindow *self, ChatContext *ctx, char *cmd, struct tm *timeinfo)
    wattroff(ctx->history, COLOR_PAIR(2));
    uint8_t selfname[MAX_NAME_LENGTH];
-    int len = getself_name(selfname);
+    int len = getself_name(m, selfname);
    char msg[MAX_STR_SIZE-len-4];
    snprintf(msg, sizeof(msg), "* %s %s\n", (uint8_t*) selfname, action);
    wattron(ctx->history, COLOR_PAIR(1));
    wprintw(ctx->history, msg);
    wattroff(ctx->history, COLOR_PAIR(1));
-    if (m_sendaction(ctx->friendnum, (uint8_t*) msg, strlen(msg)+1) < 0) {
+    if (m_sendaction(m, ctx->friendnum, (uint8_t*) msg, strlen(msg)+1) < 0) {
      wattron(ctx->history, COLOR_PAIR(3));
      wprintw(ctx->history, " * Failed to send action\n");
      wattroff(ctx->history, COLOR_PAIR(3));
@@ -256,13 +256,13 @@ void execute(ToxWindow *self, ChatContext *ctx, char *cmd, struct tm *timeinfo)
    msg = strchr(status, ' ');
    if (msg == NULL) {
-      m_set_userstatus(status_kind);
+      m_set_userstatus(m, status_kind);
      wprintw(ctx->history, "Status set to: %s\n", status_text);
    }
    else {
      msg++;
-      m_set_userstatus(status_kind);
+      m_set_userstatus(m, status_kind);
-      m_set_statusmessage((uint8_t*) msg, strlen(msg)+1);
+      m_set_statusmessage(m, ( uint8_t*) msg, strlen(msg)+1);
      wprintw(ctx->history, "Status set to: %s, %s\n", status_text, msg);
    }
  }
@@ -275,7 +275,7 @@ void execute(ToxWindow *self, ChatContext *ctx, char *cmd, struct tm *timeinfo)
      return;
    }
    nick++;
-    setname((uint8_t*) nick, strlen(nick)+1);
+    setname(m, (uint8_t*) nick, strlen(nick)+1);
    wprintw(ctx->history, "Nickname set to: %s\n", nick);
  }
@@ -312,7 +312,7 @@ static void chat_onDraw(ToxWindow *self)
  wrefresh(self->window);
 }
-static void chat_onInit(ToxWindow *self)
+static void chat_onInit(ToxWindow *self, Messenger *m)
 {
  int x, y;
  ChatContext *ctx = (ChatContext*) self->x;
@@ -329,7 +329,7 @@ void print_help(ChatContext *self)
  wattron(self->history, COLOR_PAIR(2) | A_BOLD);
  wprintw(self->history, "Commands:\n");
  wattroff(self->history, A_BOLD);
-  
  wprintw(self->history, "      /status <type> <message>   : Set your status\n");
  wprintw(self->history, "      /nick <nickname>           : Set your nickname\n");
  wprintw(self->history, "      /me <action>               : Do an action\n");
@@ -342,7 +342,7 @@ void print_help(ChatContext *self)
  wattroff(self->history, COLOR_PAIR(2));
 }
-ToxWindow new_chat(int friendnum)
+ToxWindow new_chat(Messenger *m, int friendnum)
 {
  ToxWindow ret;
  memset(&ret, 0, sizeof(ret));
@@ -356,7 +356,7 @@ ToxWindow new_chat(int friendnum)
  ret.onAction = &chat_onAction;
  uint8_t nick[MAX_NAME_LENGTH] = {0};
-  getname(friendnum, (uint8_t*) &nick);
+  getname(m, friendnum, (uint8_t*) &nick);
  fix_name(nick);
  snprintf(ret.title, sizeof(ret.title), "[%s (%d)]", nick, friendnum);
diff --git a/testing/toxic/friendlist.c b/testing/toxic/friendlist.c
index f2aa1cf4..56061cf9 100644
--- a/testing/toxic/friendlist.c
+++ b/testing/toxic/friendlist.c
@@ -14,7 +14,7 @@
 extern char WINDOW_STATUS[TOXWINDOWS_MAX_NUM];
 extern int add_window(ToxWindow w, int n);
-extern ToxWindow new_chat(int friendnum);
+extern ToxWindow new_chat(Messenger *m, int friendnum);
 extern int active_window;
@@ -42,7 +42,7 @@ void fix_name(uint8_t *name)
  *q = 0;
 }
-void friendlist_onMessage(ToxWindow *self, int num, uint8_t *str, uint16_t len)
+void friendlist_onMessage(ToxWindow *self, Messenger *m, int num, uint8_t *str, uint16_t len)
 {
  if (num >= num_friends)
    return;
@@ -54,7 +54,7 @@ void friendlist_onMessage(ToxWindow *self, int num, uint8_t *str, uint16_t len)
    for (i = N_DEFAULT_WINS; i < MAX_WINDOW_SLOTS; ++i) {
      if (WINDOW_STATUS[i] == -1) {
        WINDOW_STATUS[i] = num;
-        add_window(new_chat(num), i);
+        add_window(new_chat(m, num), i);
        active_window = i;
        break;
      }
@@ -82,20 +82,20 @@ void friendlist_onStatusChange(ToxWindow *self, int num, uint8_t *str, uint16_t
  fix_name(friends[num].status);
 }
-int friendlist_onFriendAdded(int num)
+int friendlist_onFriendAdded(Messenger *m, int num)
 {
  if (num_friends == MAX_FRIENDS_NUM)
    return -1;
  friends[num_friends].num = num;
-  getname(num, friends[num_friends].name);
+  getname(m, num, friends[num_friends].name);
  strcpy((char*) friends[num_friends].name, "unknown");
  strcpy((char*) friends[num_friends].status, "unknown");
  friends[num_friends++].chatwin = -1;
  return 0;
 }
-static void friendlist_onKey(ToxWindow *self, int key)
+static void friendlist_onKey(ToxWindow *self, Messenger *m, int key)
 {
  if (key == KEY_UP) {
    if (--num_selected < 0)
@@ -121,7 +121,7 @@ static void friendlist_onKey(ToxWindow *self, int key)
        if (WINDOW_STATUS[i] == -1) {
          WINDOW_STATUS[i] = num_selected;
          friends[num_selected].chatwin = num_selected;
-          add_window(new_chat(num_selected), i);
+          add_window(new_chat(m, num_selected), i);
          active_window = i;
          break;
        }
@@ -164,7 +164,7 @@ void disable_chatwin(int f_num)
  friends[f_num].chatwin = -1;
 }
-static void friendlist_onInit(ToxWindow *self) 
+static void friendlist_onInit(ToxWindow *self, Messenger *m)
 {
 }
diff --git a/testing/toxic/main.c b/testing/toxic/main.c
index 752453f2..397f9391 100644
--- a/testing/toxic/main.c
+++ b/testing/toxic/main.c
@@ -25,7 +25,7 @@
 extern ToxWindow new_prompt();
 extern ToxWindow new_friendlist();
-extern int friendlist_onFriendAdded(int num);
+extern int friendlist_onFriendAdded(Messenger *m, int num);
 extern void disable_chatwin(int f_num);
 extern int add_req(uint8_t *public_key); // XXX
 extern unsigned char *hex_string_to_bin(char hex_string[]);
@@ -40,11 +40,13 @@ char WINDOW_STATUS[MAX_WINDOW_SLOTS];
 static ToxWindow windows[MAX_WINDOW_SLOTS];
 static ToxWindow* prompt;
+static Messenger *m;
 int w_num;
 int active_window;
 /* CALLBACKS START */
-void on_request(uint8_t *public_key, uint8_t *data, uint16_t length)
+void on_request(uint8_t *public_key, uint8_t *data, uint16_t length, void* userdata)
 {
  int n = add_req(public_key);
  wprintw(prompt->window, "\nFriend request from:\n");
@@ -63,25 +65,25 @@ void on_request(uint8_t *public_key, uint8_t *data, uint16_t length)
  }
 }
-void on_message(int friendnumber, uint8_t *string, uint16_t length)
+void on_message(Messenger *m, int friendnumber, uint8_t *string, uint16_t length, void* userdata)
 {
  int i;
  for (i = 0; i < MAX_WINDOW_SLOTS; ++i) {
    if (windows[i].onMessage != NULL)
-      windows[i].onMessage(&windows[i], friendnumber, string, length);
+      windows[i].onMessage(&windows[i], m, friendnumber, string, length);
  }
 }
-void on_action(int friendnumber, uint8_t *string, uint16_t length)
+void on_action(Messenger *m, int friendnumber, uint8_t *string, uint16_t length, void* userdata)
 {
  int i;
  for (i = 0; i < MAX_WINDOW_SLOTS; ++i) {
    if (windows[i].onAction != NULL)
-      windows[i].onAction(&windows[i], friendnumber, string, length);
+      windows[i].onAction(&windows[i], m, friendnumber, string, length);
  }
 }
-void on_nickchange(int friendnumber, uint8_t *string, uint16_t length)
+void on_nickchange(Messenger *m, int friendnumber, uint8_t *string, uint16_t length, void* userdata)
 {
  wprintw(prompt->window, "\n(nickchange) %d: %s\n", friendnumber, string);
  int i;
@@ -91,7 +93,7 @@ void on_nickchange(int friendnumber, uint8_t *string, uint16_t length)
  }
 }
-void on_statuschange(int friendnumber, uint8_t *string, uint16_t length)
+void on_statuschange(Messenger *m, int friendnumber, uint8_t *string, uint16_t length, void* userdata)
 {
  wprintw(prompt->window, "\n(statuschange) %d: %s\n", friendnumber, string);
  int i;
@@ -103,7 +105,7 @@ void on_statuschange(int friendnumber, uint8_t *string, uint16_t length)
 void on_friendadded(int friendnumber)
 {
-  friendlist_onFriendAdded(friendnumber);
+  friendlist_onFriendAdded(m, friendnumber);
 }
 /* CALLBACKS END */
@@ -129,14 +131,14 @@ static void init_term()
 static void init_tox()
 {
  /* Init core */
-  initMessenger();
+  m = initMessenger();
  /* Callbacks */
-  m_callback_friendrequest(on_request);
+  m_callback_friendrequest(m, on_request, NULL);
-  m_callback_friendmessage(on_message);
+  m_callback_friendmessage(m, on_message, NULL);
-  m_callback_namechange(on_nickchange);
+  m_callback_namechange(m, on_nickchange, NULL);
-  m_callback_statusmessage(on_statuschange);
+  m_callback_statusmessage(m, on_statuschange, NULL);
-  m_callback_action(on_action);
+  m_callback_action(m, on_action, NULL);
 }
 #define MAXLINE 90    /* Approx max number of chars in a sever line (IP + port + key) */
@@ -157,8 +159,7 @@ int init_connection(void)
  char line[MAXLINE];
  int linecnt = 0;
  while (fgets(line, sizeof(line), fp) && linecnt < MAXSERVERS) {
-    int len = strlen(line);
+    if (strlen(line) > MINLINE)
-    if (len > MINLINE && len < MAXLINE)
      strcpy(servers[linecnt++], line);
  }
  if (linecnt < 1) {
@@ -211,7 +212,7 @@ int add_window(ToxWindow w, int n)
    return -1;
  windows[n] = w;
-  w.onInit(&w);
+  w.onInit(&w, m);
  w_num++;
  return n;
 }
@@ -237,7 +238,7 @@ static void init_windows()
  w_num = 0;
  int n_prompt = 0;
  int n_friendslist = 1;
-  if (add_window(new_prompt(), n_prompt) == -1 
+  if (add_window(new_prompt(), n_prompt) == -1
                        || add_window(new_friendlist(), n_friendslist) == -1) {
    fprintf(stderr, "add_window() failed.\n");
    endwin();
@@ -248,16 +249,22 @@ static void init_windows()
 static void do_tox()
 {
+  static int conn_try = 0;
  static bool dht_on = false;
-  if (!dht_on && DHT_isconnected()) {
+  if (!dht_on && !DHT_isconnected() && !(conn_try++ % 100)) {
+    init_connection();
+    wprintw(prompt->window, "\nEstablishing connection...\n");
+  }
+  else if (!dht_on && DHT_isconnected()) {
    dht_on = true;
    wprintw(prompt->window, "\nDHT connected.\n");
  }
  else if (dht_on && !DHT_isconnected()) {
    dht_on = false;
-    wprintw(prompt->window, "\nDHT disconnected.\n");
+    wprintw(prompt->window, "\nDHT disconnected. Attempting to reconnect.\n");
+    init_connection();
  }
-  doMessenger();
+  doMessenger(m);
 }
 static void load_data(char *path)
@@ -285,17 +292,17 @@ static void load_data(char *path)
      endwin();
      exit(1);
    }
-    Messenger_load(buf, len);
+    Messenger_load(m, buf, len);
  }
  else {
-    len = Messenger_size();
+    len = Messenger_size(m);
    buf = malloc(len);
    if (buf == NULL) {
      fprintf(stderr, "malloc() failed.\n");
      endwin();
      exit(1);
    }
-    Messenger_save(buf);
+    Messenger_save(m, buf);
    fd = fopen(path, "w");
    if (fd == NULL) {
@@ -329,7 +336,7 @@ static void draw_bar()
  move(LINES - 1, 0);
  attron(COLOR_PAIR(4) | A_BOLD);
-  printw(" TOXIC " TOXICVER "|"); 
+  printw(" TOXIC " TOXICVER "|");
  attroff(COLOR_PAIR(4) | A_BOLD);
  int i;
@@ -440,10 +447,6 @@ int main(int argc, char *argv[])
    load_data(DATA_FILE);
  free(DATA_FILE);
-  int connected = init_connection();
-  if (connected != 0)
-    wprintw(prompt->window, "Auto-connect failed (error code %d)\n", connected);
  if (f_flag == -1) {
    attron(COLOR_PAIR(3) | A_BOLD);
    wprintw(prompt->window, "You passed '-f' without giving an argument.\n"
@@ -473,7 +476,8 @@ int main(int argc, char *argv[])
    if (ch == '\t' || ch == KEY_BTAB)
      set_active_window(ch);
    else if (ch != ERR)
-      a->onKey(a, ch);
+      a->onKey(a, m, ch);
  }
+  cleanupMessenger(m);
  return 0;
 }
diff --git a/testing/toxic/prompt.c b/testing/toxic/prompt.c
index ab44e960..67f80fef 100644
--- a/testing/toxic/prompt.c
+++ b/testing/toxic/prompt.c
@@ -20,24 +20,24 @@ static char prompt_buf[MAX_STR_SIZE] = {0};
 static int prompt_buf_pos = 0;
 /* commands */
-void cmd_accept(ToxWindow *, char **);
+void cmd_accept(ToxWindow *, Messenger *m, char **);
-void cmd_add(ToxWindow *, char **);
+void cmd_add(ToxWindow *, Messenger *m, char **);
-void cmd_clear(ToxWindow *, char **);
+void cmd_clear(ToxWindow *, Messenger *m, char **);
-void cmd_connect(ToxWindow *, char **);
+void cmd_connect(ToxWindow *, Messenger *m, char **);
-void cmd_help(ToxWindow *, char **);
+void cmd_help(ToxWindow *, Messenger *m, char **);
-void cmd_msg(ToxWindow *, char **);
+void cmd_msg(ToxWindow *, Messenger *m, char **);
-void cmd_myid(ToxWindow *, char **);
+void cmd_myid(ToxWindow *, Messenger *m, char **);
-void cmd_nick(ToxWindow *, char **);
+void cmd_nick(ToxWindow *, Messenger *m, char **);
-void cmd_quit(ToxWindow *, char **);
+void cmd_quit(ToxWindow *, Messenger *m, char **);
-void cmd_status(ToxWindow *, char **);
+void cmd_status(ToxWindow *, Messenger *m, char **);
-void cmd_statusmsg(ToxWindow *, char **);
+void cmd_statusmsg(ToxWindow *, Messenger *m, char **);
 #define NUM_COMMANDS 13
 static struct {
  char *name;
  int numargs;
-  void (*func)(ToxWindow *, char **);
+  void (*func)(ToxWindow *, Messenger *m, char **);
 } commands[] = {
  { "accept",    1, cmd_accept    },
  { "add",       1, cmd_add       },
@@ -74,7 +74,7 @@ unsigned char *hex_string_to_bin(char hex_string[])
  return val;
 }
-void cmd_accept(ToxWindow *self, char **args)
+void cmd_accept(ToxWindow *self, Messenger *m, char **args)
 {
  int num = atoi(args[1]);
  if (num >= num_requests) {
@@ -82,7 +82,7 @@ void cmd_accept(ToxWindow *self, char **args)
    return;
  }
-  num = m_addfriend_norequest(pending_requests[num]);
+  num = m_addfriend_norequest(m, pending_requests[num]);
  if (num == -1)
    wprintw(self->window, "Failed to add friend.\n");
  else {
@@ -91,7 +91,7 @@ void cmd_accept(ToxWindow *self, char **args)
  }
 }
-void cmd_add(ToxWindow *self, char **args)
+void cmd_add(ToxWindow *self, Messenger *m, char **args)
 {
  uint8_t id_bin[KEY_SIZE_BYTES];
  char xx[3];
@@ -121,7 +121,7 @@ void cmd_add(ToxWindow *self, char **args)
    }
    id_bin[i] = x;
  }
-  int num = m_addfriend(id_bin, (uint8_t*) msg, strlen(msg)+1);
+  int num = m_addfriend(m, id_bin, (uint8_t*) msg, strlen(msg)+1);
  switch (num) {
  case FAERR_TOOLONG:
    wprintw(self->window, "Message is too long.\n");
@@ -145,12 +145,12 @@ void cmd_add(ToxWindow *self, char **args)
  }
 }
-void cmd_clear(ToxWindow *self, char **args)
+void cmd_clear(ToxWindow *self, Messenger *m, char **args)
 {
  wclear(self->window);
 }
-void cmd_connect(ToxWindow *self, char **args)
+void cmd_connect(ToxWindow *self, Messenger *m, char **args)
 {
  IP_Port dht;
  char *ip = args[1];
@@ -174,13 +174,13 @@ void cmd_connect(ToxWindow *self, char **args)
  free(binary_string);
 }
-void cmd_quit(ToxWindow *self, char **args)
+void cmd_quit(ToxWindow *self, Messenger *m, char **args)
 {
  endwin();
  exit(0);
 }
-void cmd_help(ToxWindow *self, char **args)
+void cmd_help(ToxWindow *self, Messenger *m, char **args)
 {
  wclear(self->window);
  wattron(self->window, COLOR_PAIR(2) | A_BOLD);
@@ -197,7 +197,7 @@ void cmd_help(ToxWindow *self, char **args)
  wprintw(self->window, "      quit/exit                 : Exit program\n");
  wprintw(self->window, "      help                      : Print this message again\n");
  wprintw(self->window, "      clear                     : Clear this window\n");
-  
  wattron(self->window, A_BOLD);
  wprintw(self->window, "TIP: Use the TAB key to navigate through the tabs.\n\n");
  wattroff(self->window, A_BOLD);
@@ -205,17 +205,17 @@ void cmd_help(ToxWindow *self, char **args)
  wattroff(self->window, COLOR_PAIR(2));
 }
-void cmd_msg(ToxWindow *self, char **args)
+void cmd_msg(ToxWindow *self, Messenger *m, char **args)
 {
  char *id = args[1];
  char *msg = args[2];
-  if (m_sendmessage(atoi(id), (uint8_t*) msg, strlen(msg)+1) == 0)
+  if (m_sendmessage(m, atoi(id), (uint8_t*) msg, strlen(msg)+1) == 0)
    wprintw(self->window, "Error occurred while sending message.\n");
  else
    wprintw(self->window, "Message successfully sent.\n");
 }
-void cmd_myid(ToxWindow *self, char **args)
+void cmd_myid(ToxWindow *self, Messenger *m, char **args)
 {
  char id[KEY_SIZE_BYTES*2 + 1] = {0};
  size_t i;
@@ -227,14 +227,14 @@ void cmd_myid(ToxWindow *self, char **args)
  wprintw(self->window, "Your ID: %s\n", id);
 }
-void cmd_nick(ToxWindow *self, char **args)
+void cmd_nick(ToxWindow *self, Messenger *m, char **args)
 {
  char *nick = args[1];
-  setname((uint8_t*) nick, strlen(nick)+1);
+  setname(m, (uint8_t*) nick, strlen(nick)+1);
  wprintw(self->window, "Nickname set to: %s\n", nick);
 }
-void cmd_status(ToxWindow *self, char **args)
+void cmd_status(ToxWindow *self, Messenger *m, char **args)
 {
  char *status = args[1];
  char *status_text;
@@ -260,24 +260,24 @@ void cmd_status(ToxWindow *self, char **args)
  char *msg = args[2];
  if (msg == NULL) {
-    m_set_userstatus(status_kind);
+    m_set_userstatus(m, status_kind);
    wprintw(self->window, "Status set to: %s\n", status_text);
  }
  else {
-    m_set_userstatus(status_kind);
+    m_set_userstatus(m, status_kind);
-    m_set_statusmessage((uint8_t*) msg, strlen(msg)+1);
+    m_set_statusmessage(m, (uint8_t*) msg, strlen(msg)+1);
    wprintw(self->window, "Status set to: %s, %s\n", status_text, msg);
  }
 }
-void cmd_statusmsg(ToxWindow *self, char **args)
+void cmd_statusmsg(ToxWindow *self, Messenger *m, char **args)
 {
    char *msg = args[1];
-    m_set_statusmessage((uint8_t*) msg, strlen(msg)+1);
+    m_set_statusmessage(m, (uint8_t*) msg, strlen(msg)+1);
    wprintw(self->window, "Status set to: %s\n", msg);
 }
-static void execute(ToxWindow *self, char *u_cmd)
+static void execute(ToxWindow *self, Messenger *m, char *u_cmd)
 {
  int newlines = 0;
  char cmd[MAX_STR_SIZE] = {0};
@@ -341,13 +341,13 @@ static void execute(ToxWindow *self, char *u_cmd)
          return;
        }
      }
-      /* check for excess arguments */ 
+      /* check for excess arguments */
      if (strcmp(cmdargs[0], "add") && strlen(cmdargs[j]) != 0) {
        wprintw(self->window, "Invalid command: too many arguments to %s.\n", commands[i].name);
        return;
      }
      /* pass arguments to command function */
-      (commands[i].func)(self, cmdargs);
+      (commands[i].func)(self, m, cmdargs);
      return;
    }
  }
@@ -356,7 +356,7 @@ static void execute(ToxWindow *self, char *u_cmd)
  wprintw(self->window, "Invalid command.\n");
 }
-static void prompt_onKey(ToxWindow *self, int key)
+static void prompt_onKey(ToxWindow *self, Messenger *m, int key)
 {
  /* Add printable characters to line */
  if (isprint(key)) {
@@ -380,7 +380,7 @@ static void prompt_onKey(ToxWindow *self, int key)
  /* RETURN key: execute command */
  else if (key == '\n') {
    wprintw(self->window, "\n");
-    execute(self, prompt_buf);
+    execute(self, m, prompt_buf);
    prompt_buf_pos = 0;
    prompt_buf[0] = 0;
  }
@@ -413,10 +413,10 @@ static void prompt_onDraw(ToxWindow *self)
  wrefresh(self->window);
 }
-static void prompt_onInit(ToxWindow *self)
+static void prompt_onInit(ToxWindow *self, Messenger *m)
 {
  scrollok(self->window, 1);
-  cmd_help(self, NULL);
+  cmd_help(self, m, NULL);
  wclrtoeol(self->window);
 }
diff --git a/testing/toxic/windows.h b/testing/toxic/windows.h
index c6925ce1..648243d0 100644
--- a/testing/toxic/windows.h
+++ b/testing/toxic/windows.h
@@ -9,7 +9,7 @@
 #define KEY_SIZE_BYTES 32
 /* number of permanent default windows */
-#define N_DEFAULT_WINS 2  
+#define N_DEFAULT_WINS 2
 /* maximum window slots for WINDOW_STATUS array */
 #define MAX_WINDOW_SLOTS N_DEFAULT_WINS+MAX_FRIENDS_NUM
@@ -17,14 +17,14 @@
 typedef struct ToxWindow_ ToxWindow;
 struct ToxWindow_ {
-  void(*onKey)(ToxWindow*, int);
+  void(*onKey)(ToxWindow*, Messenger*, int);
  void(*onDraw)(ToxWindow*);
-  void(*onInit)(ToxWindow*);
+  void(*onInit)(ToxWindow*, Messenger*);
  void(*onFriendRequest)(ToxWindow*, uint8_t*, uint8_t*, uint16_t);
-  void(*onMessage)(ToxWindow*, int, uint8_t*, uint16_t);
+  void(*onMessage)(ToxWindow*, Messenger*, int, uint8_t*, uint16_t);
  void(*onNickChange)(ToxWindow*, int, uint8_t*, uint16_t);
  void(*onStatusChange)(ToxWindow*, int, uint8_t*, uint16_t);
-  void(*onAction)(ToxWindow*, int, uint8_t*, uint16_t);
+  void(*onAction)(ToxWindow*, Messenger*, int, uint8_t*, uint16_t);
  char title[256];
  void* x;