#include "stdafx.h"

Tox_Options* CToxProto::GetToxOptions()
{
	TOX_ERR_OPTIONS_NEW error;
	Tox_Options *options = tox_options_new(&error);
	if (error != TOX_ERR_OPTIONS_NEW_OK)
	{
		debugLogA(__FUNCTION__": failed to initialize tox options (%d)", error);
		return NULL;
	}

	options->udp_enabled = getBool("EnableUDP", 1);
	options->ipv6_enabled = getBool("EnableIPv6", 0);

	if (m_hNetlibUser != NULL)
	{
		NETLIBUSERSETTINGS nlus = { sizeof(NETLIBUSERSETTINGS) };
		CallService(MS_NETLIB_GETUSERSETTINGS, (WPARAM)m_hNetlibUser, (LPARAM)&nlus);

		if (nlus.useProxy)
		{
			if (nlus.proxyType == PROXYTYPE_HTTP || nlus.proxyType == PROXYTYPE_HTTPS)
			{
				debugLogA(__FUNCTION__": setting http user proxy config");
				options->proxy_type = TOX_PROXY_TYPE_HTTP;
				mir_strcpy((char*)&options->proxy_host[0], nlus.szProxyServer);
				options->proxy_port = nlus.wProxyPort;
			}

			if (nlus.proxyType == PROXYTYPE_SOCKS4 || nlus.proxyType == PROXYTYPE_SOCKS5)
			{
				debugLogA(__FUNCTION__": setting socks user proxy config");
				options->proxy_type = TOX_PROXY_TYPE_SOCKS5;
				mir_strcpy((char*)&options->proxy_host[0], nlus.szProxyServer);
				options->proxy_port = nlus.wProxyPort;
			}
		}
	}

	if (LoadToxProfile(options))
	{
		return options;
	}
	
	tox_options_free(options);
	
	return NULL;
}

bool CToxProto::InitToxCore(CToxThread *toxThread)
{
	debugLogA(__FUNCTION__": initializing tox core");

	if (toxThread == NULL)
		return false;

	tox_callback_friend_request(toxThread->Tox(), OnFriendRequest, this);
	tox_callback_friend_message(toxThread->Tox(), OnFriendMessage, this);
	tox_callback_friend_read_receipt(toxThread->Tox(), OnReadReceipt, this);
	tox_callback_friend_typing(toxThread->Tox(), OnTypingChanged, this);
	//
	tox_callback_friend_name(toxThread->Tox(), OnFriendNameChange, this);
	tox_callback_friend_status_message(toxThread->Tox(), OnStatusMessageChanged, this);
	tox_callback_friend_status(toxThread->Tox(), OnUserStatusChanged, this);
	tox_callback_friend_connection_status(toxThread->Tox(), OnConnectionStatusChanged, this);
	// transfers
	tox_callback_file_recv_control(toxThread->Tox(), OnFileRequest, this);
	tox_callback_file_recv(toxThread->Tox(), OnFriendFile, this);
	tox_callback_file_recv_chunk(toxThread->Tox(), OnDataReceiving, this);
	tox_callback_file_chunk_request(toxThread->Tox(), OnFileSendData, this);
	// group chats
	//tox_callback_group_invite(tox, OnGroupChatInvite, this);
	// a/v
	//if (IsWinVerVistaPlus())
	//{
	//	TOXAV_ERR_NEW avInitError;
	//	toxThread->Tox()AV = toxav_new(toxThread->Tox(), &avInitError);
	//	if (initError != TOX_ERR_NEW_OK)
	//	{
	//		toxav_callback_call(toxThread->Tox()AV, OnFriendCall, this);
	//		toxav_callback_call_state(toxThread->Tox()AV, OnFriendCallState, this);
	//		toxav_callback_bit_rate_status(toxThread->Tox()AV, OnBitrateChanged, this);
	//		toxav_callback_audio_receive_frame(toxThread->Tox()AV, OnFriendAudioFrame, this);
	//		//toxav_callback_video_receive_frame(toxThread->Tox()AV, , this);
	//	}
	//}

	uint8_t data[TOX_ADDRESS_SIZE];
	tox_self_get_address(toxThread->Tox(), data);
	ToxHexAddress address(data);
	setString(TOX_SETTINGS_ID, address);

	TOX_ERR_SET_INFO error;

	/*uint8_t nick[TOX_MAX_NAME_LENGTH] = { 0 };
	tox_self_get_name(toxThread->Tox(), nick);
	setWString("Nick", ptrW(Utf8DecodeT((char*)nick)));*/

	ptrA nick(mir_utf8encodeW(ptrW(getWStringA("Nick"))));
	tox_self_set_name(toxThread->Tox(), (uint8_t*)(char*)nick, mir_strlen(nick), &error);
	if (error != TOX_ERR_SET_INFO_OK)
	{
		debugLogA(__FUNCTION__": failed to set self name (%d)", error);
		return NULL;
	}

	/*uint8_t statusMessage[TOX_MAX_STATUS_MESSAGE_LENGTH] = { 0 };
	tox_self_get_status_message(toxThread->Tox(), statusMessage);
	setWString("StatusMsg", ptrW(Utf8DecodeT((char*)statusMessage)));*/

	ptrA statusMessage(mir_utf8encodeW(ptrW(getWStringA("StatusMsg"))));
	tox_self_set_status_message(toxThread->Tox(), (uint8_t*)(char*)statusMessage, mir_strlen(statusMessage), &error);
	if (error != TOX_ERR_SET_INFO_OK)
	{
		debugLogA(__FUNCTION__": failed to set self status message (%d)", error);
		return NULL;
	}

	return true;
}

void CToxProto::UninitToxCore(CToxThread *toxThread)
{
	if (toxThread == NULL)
		return;

	CancelAllTransfers(toxThread);
	SaveToxProfile(toxThread);

	tox_callback_friend_request(toxThread->Tox(), OnFriendRequest, NULL);
	tox_callback_friend_message(toxThread->Tox(), OnFriendMessage, NULL);
	tox_callback_friend_read_receipt(toxThread->Tox(), OnReadReceipt, NULL);
	tox_callback_friend_typing(toxThread->Tox(), OnTypingChanged, NULL);
	//
	tox_callback_friend_name(toxThread->Tox(), OnFriendNameChange, NULL);
	tox_callback_friend_status_message(toxThread->Tox(), OnStatusMessageChanged, NULL);
	tox_callback_friend_status(toxThread->Tox(), OnUserStatusChanged, NULL);
	tox_callback_friend_connection_status(toxThread->Tox(), OnConnectionStatusChanged, NULL);
	// transfers
	tox_callback_file_recv_control(toxThread->Tox(), OnFileRequest, NULL);
	tox_callback_file_recv(toxThread->Tox(), OnFriendFile, NULL);
	tox_callback_file_recv_chunk(toxThread->Tox(), OnDataReceiving, NULL);
	tox_callback_file_chunk_request(toxThread->Tox(), OnFileSendData, NULL);
}