doubango-android/tinyNET/test/test_nat.h

/* Copyright (C) 2014 Mamadou DIOP.
*
* This file is part of Open Source Doubango Framework.
*
* DOUBANGO is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* DOUBANGO is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with DOUBANGO.
*
*/
#ifndef TNET_TEST_NAT_H
#define TNET_TEST_NAT_H

#define STUN_SERVER_IP			"ns313841.ovh.net" // "numb.viagenie.ca" /* stun.ekiga.net, */
#define STUN_USERNAME			"bossiel@yahoo.fr"
#define STUN_PASSWORD			"tinynet"
#define STUN_SERVER_PORT		TNET_STUN_TCP_UDP_DEFAULT_PORT
#define STUN_SERVER_PROTO		tnet_socket_type_udp_ipv4

void test_nat_stun()
{
    tnet_socket_t *socket1 = 0, *socket2 = 0;
    struct tnet_nat_ctx_s *context = 0;

    tnet_stun_binding_id_t bind_id1, bind_id2;

    char* public_ip1 = 0, *public_ip2 = 0;
    tnet_port_t public_port1 = 0, public_port2 = 0;

    if(!(socket1 = tnet_socket_create(TNET_SOCKET_HOST_ANY, TNET_SOCKET_PORT_ANY, STUN_SERVER_PROTO))
            || !(socket2 = tnet_socket_create(TNET_SOCKET_HOST_ANY, TNET_SOCKET_PORT_ANY, STUN_SERVER_PROTO))) {
        goto bail;
    }

    context = tnet_nat_context_create(STUN_SERVER_PROTO, STUN_USERNAME, STUN_PASSWORD);

    if(tnet_nat_set_server_address(context, STUN_SERVER_IP)) {
        TSK_DEBUG_ERROR("Failed to set STUN/TURN address.");
        goto bail;
    }

    // == BIND == //
    bind_id1 = tnet_nat_stun_bind(context, socket1->fd);
    bind_id2 = tnet_nat_stun_bind(context, socket2->fd);

    if(!bind_id1 || !bind_id2) {
        TSK_DEBUG_ERROR("Failed to get public IP/port using stun");
        goto bail;
    }

    if (tnet_nat_stun_get_reflexive_address(context, bind_id1, &public_ip1, &public_port1) == 0) {
        TSK_DEBUG_INFO("Public IP1/Port1 ==> %s:%u", public_ip1, public_port1);
    }

    if (tnet_nat_stun_get_reflexive_address(context, bind_id2, &public_ip2, &public_port2) == 0) {
        TSK_DEBUG_INFO("Public IP2/Port2 ==> %s:%u", public_ip2, public_port2);
    }

    // == UNBIND == //
    tnet_nat_stun_unbind(context, bind_id1);
    tnet_nat_stun_unbind(context, bind_id2);

bail:
    TSK_OBJECT_SAFE_FREE(socket1);
    TSK_OBJECT_SAFE_FREE(socket2);

    TSK_FREE(public_ip1);
    TSK_FREE(public_ip1);

    TSK_OBJECT_SAFE_FREE(context);
}

void test_nat_turn()
{
//	tnet_socket_t *socket1 = 0, *socket2 = 0;
//	struct tnet_nat_ctx_s *context = 0;
//	tnet_turn_allocation_id_t alloc_id1, alloc_id2;
//
//	char* public_ip1 = 0, *public_ip2 = 0;
//	tnet_port_t public_port1 = 0, public_port2 = 0;
//
//	tnet_turn_channel_binding_id_t channel_id;
//
//	int ret;
//
//	if(!(socket1 = tnet_socket_create(TNET_SOCKET_HOST_ANY, TNET_SOCKET_PORT_ANY, STUN_SERVER_PROTO))
//		|| !(socket2 = tnet_socket_create(TNET_SOCKET_HOST_ANY, TNET_SOCKET_PORT_ANY, STUN_SERVER_PROTO)))
//	{
//		goto bail;
//	}
//
//	context = tnet_nat_context_create(STUN_SERVER_PROTO, STUN_USERNAME, STUN_PASSWORD);
//	((tnet_nat_context_t*)context)->enable_evenport = 0;
//	((tnet_nat_context_t*)context)->enable_fingerprint = 0;
//	((tnet_nat_context_t*)context)->enable_dontfrag = 0;
//	((tnet_nat_context_t*)context)->enable_integrity = 0;
//
//	if(tnet_nat_set_server_address(context, STUN_SERVER_IP))
//	{
//		TSK_DEBUG_ERROR("Failed to set STUN/TURN address.");
//		goto bail;
//	}
//
//	/* == ALLOC
//	*/
//	alloc_id1 = tnet_nat_turn_allocate(context, socket1->fd);
//	alloc_id2 = tnet_nat_turn_allocate(context, socket2->fd);
//	if(!TNET_TURN_IS_VALID_ALLOCATION_ID(alloc_id1) || !TNET_TURN_IS_VALID_ALLOCATION_ID(alloc_id2))
//	{
//		TSK_DEBUG_ERROR("TURN allocation failed.");
//		goto bail;
//	}
//	else
//	{
//		TSK_DEBUG_INFO("TURN allocation succeeded and id1=%llu and id2=%llu", alloc_id1, alloc_id2);
//	}
//
//	tsk_thread_sleep(2000);
//
//	/* == RETRIEVE STUN SERVER REFLEXIVE ADDRESSES
//	*/
//	if(!tnet_nat_turn_get_reflexive_address(context, alloc_id1, &public_ip1, &public_port1))
//	{
//		TSK_DEBUG_INFO("Public IP1/Port1 ==> %s:%u", public_ip1, public_port1);
//	}
//
//	if(!tnet_nat_turn_get_reflexive_address(context, alloc_id2, &public_ip2, &public_port2))
//	{
//		TSK_DEBUG_INFO("Public IP2/Port2 ==> %s:%u", public_ip2, public_port2);
//	}
//
//	/* == CREATE PERMISSION
//	*/
//	//tnet_nat_turn_add_permission(context, alloc_id1, "192.168.0.11", 300);
//
//	/* == CHANNEL BINDING
//	*/
//	{
//		/* Try to bind (channel binding) to the  socket1 to socket2 */
//		struct sockaddr_storage peer;
//		if((ret = tnet_sockaddr_init(public_ip2, public_port2, STUN_SERVER_PROTO, &peer)))
//		{
//			TSK_DEBUG_ERROR("Failed to init peer with error code %d.", ret);
//		}
//		else
//		{
//			channel_id = tnet_nat_turn_channel_bind(context, alloc_id1,&peer);
//			if(TNET_TURN_IS_VALID_CHANNEL_BINDING_ID(channel_id))
//			{
//				TSK_DEBUG_INFO("TURN channel binding succeeded.");
//
//				/* Try to send data using the newly create channel */
//				if(tnet_nat_turn_channel_senddata(context, channel_id, "Doubango", strlen("Doubango")))
//				{
//					TSK_DEBUG_ERROR("Failed to send data using channel id [%u].", channel_id);
//				}
//				else
//				{
//					TSK_DEBUG_INFO("Data successfuly sent using channel if[%u].", channel_id);
//				}
//			}
//			else
//			{
//				TSK_DEBUG_ERROR("TURN channel binding failed.");
//			}
//		}
//	}
//
//	tsk_thread_sleep(2000);
//
//	/* == UNALLOC
//	*/
//	if((ret = tnet_nat_turn_unallocate(context, alloc_id1)) || (ret = tnet_nat_turn_unallocate(context, alloc_id2)))
//	{
//		TSK_DEBUG_ERROR("TURN unallocation failed with error code: %d.", ret);
//		goto bail;
//	}
//	else
//	{
//		TSK_DEBUG_INFO("TURN unallocation succeeded.");
//	}
//
//bail:
//	TSK_OBJECT_SAFE_FREE(socket1);
//	TSK_OBJECT_SAFE_FREE(socket2);
//
//	TSK_FREE(public_ip1);
//	TSK_FREE(public_ip1);
//
//	TSK_OBJECT_SAFE_FREE(context);
}


void test_nat()
{
    test_nat_stun();
    //test_nat_turn();
    //tsk_thread_sleep(1000);
}



#endif /* TNET_TEST_NAT_H */