#ifdef HAVE_CONFIG_H #include "config.h" #endif #include #include #include #include #include #include #include #include "../toxcore/tox.h" #ifdef __WIN32__ #define c_sleep(x) Sleep(1*x) #else #include #define c_sleep(x) usleep(1000*x) #endif void accept_friend_request(uint8_t *public_key, uint8_t *data, uint16_t length, void *userdata) { Tox *t = userdata; if (length == 7 && memcmp("Gentoo", data, 7) == 0) { tox_add_friend_norequest(t, public_key); } } uint32_t messages_received; void print_message(Tox *m, int friendnumber, uint8_t *string, uint16_t length, void *userdata) { if (*((uint32_t *)userdata) != 974536) return; if (length == sizeof("Install Gentoo") && memcmp(string, "Install Gentoo", sizeof("Install Gentoo")) == 0) ++messages_received; } uint32_t name_changes; void print_nickchange(Tox *m, int friendnumber, uint8_t *string, uint16_t length, void *userdata) { if (*((uint32_t *)userdata) != 974536) return; if (length == sizeof("Gentoo") && memcmp(string, "Gentoo", sizeof("Gentoo")) == 0) ++name_changes; } START_TEST(test_few_clients) { long long unsigned int cur_time = time(NULL); Tox *tox1 = tox_new(TOX_ENABLE_IPV6_DEFAULT); Tox *tox2 = tox_new(TOX_ENABLE_IPV6_DEFAULT); Tox *tox3 = tox_new(TOX_ENABLE_IPV6_DEFAULT); ck_assert_msg(tox1 || tox2 || tox3, "Failed to create 3 tox instances"); tox_callback_friend_request(tox2, accept_friend_request, tox2); uint8_t address[TOX_FRIEND_ADDRESS_SIZE]; tox_get_address(tox2, address); int test = tox_add_friend(tox3, address, "Gentoo", 7); ck_assert_msg(test == 0, "Failed to add friend error code: %i", test); uint8_t off = 1; while (1) { tox_do(tox1); tox_do(tox2); tox_do(tox3); if (tox_isconnected(tox1) && tox_isconnected(tox2) && tox_isconnected(tox3) && off) { printf("Toxes are online, took %llu seconds\n", time(NULL) - cur_time); off = 0; } if (tox_get_friend_connection_status(tox2, 0) == 1 && tox_get_friend_connection_status(tox3, 0) == 1) break; c_sleep(50); } printf("tox clients connected\n"); uint32_t to_compare = 974536; tox_callback_friend_message(tox3, print_message, &to_compare); tox_send_message(tox2, 0, "Install Gentoo", sizeof("Install Gentoo")); while (1) { messages_received = 0; tox_do(tox1); tox_do(tox2); tox_do(tox3); if (messages_received) break; c_sleep(50); } printf("tox clients messaging succeeded\n"); tox_callback_name_change(tox3, print_nickchange, &to_compare); tox_set_name(tox2, "Gentoo", sizeof("Gentoo")); while (1) { name_changes = 0; tox_do(tox1); tox_do(tox2); tox_do(tox3); if (name_changes) break; c_sleep(50); } uint8_t temp_name[sizeof("Gentoo")]; tox_get_name(tox3, 0, temp_name); ck_assert_msg(memcmp(temp_name, "Gentoo", sizeof("Gentoo")) == 0, "Name not correct"); printf("test_few_clients succeeded, took %llu seconds\n", time(NULL) - cur_time); } END_TEST #define NUM_TOXES 66 #define NUM_FRIENDS 20 START_TEST(test_many_clients) { long long unsigned int cur_time = time(NULL); Tox *toxes[NUM_TOXES]; uint32_t i, j; for (i = 0; i < NUM_TOXES; ++i) { toxes[i] = tox_new(TOX_ENABLE_IPV6_DEFAULT); ck_assert_msg(toxes[i] != 0, "Failed to create tox instances %u", i); tox_callback_friend_request(toxes[i], accept_friend_request, toxes[i]); } struct { uint16_t tox1; uint16_t tox2; } pairs[NUM_FRIENDS]; uint8_t address[TOX_FRIEND_ADDRESS_SIZE]; for (i = 0; i < NUM_FRIENDS; ++i) { loop_top: pairs[i].tox1 = rand() % NUM_TOXES; pairs[i].tox2 = (pairs[i].tox1 + rand() % (NUM_TOXES - 1) + 1) % NUM_TOXES; tox_get_address(toxes[pairs[i].tox1], address); int test = tox_add_friend(toxes[pairs[i].tox2], address, "Gentoo", 7); if (test == TOX_FAERR_ALREADYSENT) { goto loop_top; } ck_assert_msg(test >= 0, "Failed to add friend error code: %i", test); } while (1) { uint16_t counter = 0; for (i = 0; i < NUM_TOXES; ++i) { for (j = 0; j < tox_count_friendlist(toxes[i]); ++j) if (tox_get_friend_connection_status(toxes[i], j) == 1) ++counter; } if (counter == NUM_FRIENDS * 2) { break; } for (i = 0; i < NUM_TOXES; ++i) { tox_do(toxes[i]); } c_sleep(50); } printf("test_many_clients succeeded, took %llu seconds\n", time(NULL) - cur_time); } END_TEST #define DEFTESTCASE(NAME) \ TCase *tc_##NAME = tcase_create(#NAME); \ tcase_add_test(tc_##NAME, test_##NAME); \ suite_add_tcase(s, tc_##NAME); #define DEFTESTCASE_SLOW(NAME, TIMEOUT) \ DEFTESTCASE(NAME) \ tcase_set_timeout(tc_##NAME, TIMEOUT); Suite *tox_suite(void) { Suite *s = suite_create("Tox"); DEFTESTCASE_SLOW(few_clients, 30); DEFTESTCASE_SLOW(many_clients, 240); return s; } int main(int argc, char *argv[]) { srand((unsigned int) time(NULL)); Suite *tox = tox_suite(); SRunner *test_runner = srunner_create(tox); int number_failed = 0; srunner_run_all(test_runner, CK_NORMAL); number_failed = srunner_ntests_failed(test_runner); srunner_free(test_runner); return number_failed; }