1
0
mirror of https://github.com/Tha14/toxic.git synced 2025-07-04 23:26:45 +02:00

Use new public api

This commit is contained in:
Florian Hahn
2013-08-23 23:03:44 +02:00
parent 9ab34ca5dd
commit baadd95b45
9 changed files with 195 additions and 146 deletions

View File

@ -14,16 +14,18 @@
#include <stdint.h>
#include <signal.h>
#include <locale.h>
#include <string.h>
#include <netdb.h>
#ifdef _win32
#include <direct.h>
#else
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/socket.h>
#endif
#include "Messenger.h"
#include "network.h"
#include "tox.h"
#include "configdir.h"
#include "toxic_windows.h"
@ -34,6 +36,50 @@
char *DATA_FILE = NULL;
char *SRVLIST_FILE = NULL;
static Tox *tox;
/*
resolve_addr():
address should represent IPv4 or a hostname with A record
returns a data in network byte order that can be used to set IP.i or IP_Port.ip.i
returns 0 on failure
TODO: Fix ipv6 support
*/
uint32_t resolve_addr(const char *address)
{
struct addrinfo *server = NULL;
struct addrinfo hints;
int rc;
uint32_t addr;
memset(&hints, 0, sizeof(hints));
hints.ai_family = AF_INET; // IPv4 only right now.
hints.ai_socktype = SOCK_DGRAM; // type of socket Tox uses.
rc = getaddrinfo(address, "echo", &hints, &server);
// Lookup failed.
if (rc != 0) {
return 0;
}
// IPv4 records only..
if (server->ai_family != AF_INET) {
freeaddrinfo(server);
return 0;
}
addr = ((struct sockaddr_in *)server->ai_addr)->sin_addr.s_addr;
freeaddrinfo(server);
return addr;
}
void on_window_resize(int sig)
{
endwin();
@ -68,10 +114,10 @@ static void init_term()
refresh();
}
static Messenger *init_tox()
static Tox *init_tox()
{
/* Init core */
Messenger *m = initMessenger();
Tox *m = tox_new();
/* Callbacks */
m_callback_friendrequest(m, on_request, NULL);
@ -136,11 +182,11 @@ uint32_t resolve_addr(const char *address)
#define MAXSERVERS 50
/* Connects to a random DHT server listed in the DHTservers file */
int init_connection(Messenger *m)
int init_connection(Tox *m)
{
FILE *fp = NULL;
if (DHT_isconnected(m->dht))
if (tox_isconnected(m))
return 0;
fp = fopen(SRVLIST_FILE, "r");
@ -172,7 +218,7 @@ int init_connection(Messenger *m)
if (!ip || !port || !key)
return 3;
IP_Port dht;
tox_IP_Port dht;
dht.port = htons(atoi(port));
uint32_t resolved_address = resolve_addr(ip);
@ -180,19 +226,19 @@ int init_connection(Messenger *m)
return 0;
dht.ip.i = resolved_address;
unsigned char *binary_string = hex_string_to_bin(key);
DHT_bootstrap(m->dht, dht, binary_string);
uint8_t *binary_string = hex_string_to_bin(key);
tox_bootstrap(m, dht, binary_string);
free(binary_string);
return 0;
}
static void do_tox(Messenger *m, ToxWindow *prompt)
static void do_tox(Tox *m, ToxWindow *prompt)
{
static int conn_try = 0;
static int conn_err = 0;
static bool dht_on = false;
if (!dht_on && !DHT_isconnected(m->dht) && !(conn_try++ % 100)) {
if (!dht_on && !tox_isconnected(m) && !(conn_try++ % 100)) {
if (!conn_err) {
conn_err = init_connection(m);
wprintw(prompt->window, "\nEstablishing connection...\n");
@ -200,15 +246,15 @@ static void do_tox(Messenger *m, ToxWindow *prompt)
if (conn_err)
wprintw(prompt->window, "\nAuto-connect failed with error code %d\n", conn_err);
}
} else if (!dht_on && DHT_isconnected(m->dht)) {
} else if (!dht_on && tox_isconnected(m)) {
dht_on = true;
wprintw(prompt->window, "\nDHT connected.\n");
} else if (dht_on && !DHT_isconnected(m->dht)) {
} else if (dht_on && !tox_isconnected(m)) {
dht_on = false;
wprintw(prompt->window, "\nDHT disconnected. Attempting to reconnect.\n");
}
doMessenger(m);
tox_do(m);
}
int f_loadfromfile;
@ -220,7 +266,7 @@ int f_loadfromfile;
* Return 2 opening path failed
* Return 3 fwrite failed
*/
int store_data(Messenger *m, char *path)
int store_data(Tox *m, char *path)
{
if (f_loadfromfile == 0) /*If file loading/saving is disabled*/
return 0;
@ -229,14 +275,14 @@ int store_data(Messenger *m, char *path)
size_t len;
uint8_t *buf;
len = Messenger_size(m);
len = tox_size(m);
buf = malloc(len);
if (buf == NULL) {
return 1;
}
Messenger_save(m, buf);
tox_save(m, buf);
fd = fopen(path, "w");
@ -256,7 +302,7 @@ int store_data(Messenger *m, char *path)
return 0;
}
static void load_data(Messenger *m, char *path)
static void load_data(Tox *m, char *path)
{
if (f_loadfromfile == 0) /*If file loading/saving is disabled*/
return;
@ -287,12 +333,14 @@ static void load_data(Messenger *m, char *path)
exit(1);
}
Messenger_load(m, buf, len);
tox_load(m, buf, len);
uint32_t i;
for (i = 0; i < m->numfriends; i++) {
char name[TOX_MAX_NAME_LENGTH];
while (tox_getname(m, i, (uint8_t *)name) != -1) {
on_friendadded(m, i);
i++;
}
free(buf);
@ -354,7 +402,7 @@ int main(int argc, char *argv[])
free(user_config_dir);
init_term();
Messenger *m = init_tox();
Tox *m = init_tox();
ToxWindow *prompt = init_windows(m);
if (f_loadfromfile)
@ -382,7 +430,7 @@ int main(int argc, char *argv[])
draw_active_window(m);
}
cleanupMessenger(m);
tox_kill(m);
free(DATA_FILE);
free(SRVLIST_FILE);
return 0;