/*
Copyright (c) 2015 Miranda NG project (http://miranda-ng.org)

This program 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 version 2
of the License.

This program 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 General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "common.h"

void CSkypeProto::ParsePollData(JSONNODE *data)
{
	debugLogA("CSkypeProto::ParsePollData");
	JSONNODE *node = json_get(data, "eventMessages");
	if (node != NULL)
	{
		JSONNODE *messages = json_as_array(node);
		for (size_t i = 0; i < json_size(messages); i++)
		{
			JSONNODE *message = json_at(messages, i);
			JSONNODE *resType = json_get(message, "resourceType");
			ptrA resourceType(mir_t2a(ptrT(json_as_string(resType))));
			JSONNODE *resource = json_get(message, "resource");

			if (!mir_strcmpi(resourceType, "NewMessage"))
			{
				ProcessNewMessageRes(resource);
			}
			else if (!mir_strcmpi(resourceType, "UserPresence"))
			{
				ProcessUserPresenceRes(resource);
			}
			else if (!mir_strcmpi(resourceType, "EndpointPresence"))
			{
				ProcessEndpointPresenceRes(resource);
			}
			else if (!mir_strcmpi(resourceType, "ConversationUpdate"))
			{
				ProcessConversationUpdateRes(resource);
			} 
			else if (!mir_strcmpi(resourceType, "ThreadUpdate"))
			{
				ProcessThreadUpdateRes(resource);
			}
		}
	}
}

void CSkypeProto::PollingThread(void*)
{
	debugLogA(__FUNCTION__": entering");

	int errors = 0;
	isTerminated = false;
	while (!isTerminated && errors < POLLING_ERRORS_LIMIT)
	{
		PollRequest *request = new PollRequest(RegToken, Server);
		request->nlc = m_pollingConnection;
		NETLIBHTTPREQUEST *response = request->Send(m_hNetlibUser);

		if (response == NULL)
		{
			errors++;
			delete request;
			continue;
		}

		if (response->resultCode != 200)
		{
			errors++;
		}

		if (response->pData)
		{
			JSONROOT root(response->pData);
			JSONNODE *eventMsgs = json_get(root, "eventMessages");
			JSONNODE *errorCode = json_get(root, "errorCode");

			if (eventMsgs != NULL)
				ParsePollData(root);

			else if (errorCode != NULL)
			{
				errors++;
				debugLogA(__FUNCTION__": polling error %d", json_as_int(errorCode));
				if (json_as_int(errorCode) == 729)
				{
					SendRequest(new CreateEndpointRequest(TokenSecret), &CSkypeProto::OnEndpointCreated);
					CallService(MS_NETLIB_FREEHTTPREQUESTSTRUCT, 0, (LPARAM)response);
					delete request;
					break;
				}
			}
		}
		m_pollingConnection = response->nlc;
		CallService(MS_NETLIB_FREEHTTPREQUESTSTRUCT, 0, (LPARAM)response);
		delete request;
	}
	
	if (!isTerminated)
	{
		debugLogA(__FUNCTION__": unexpected termination; switching protocol to offline");
		SetStatus(ID_STATUS_OFFLINE);
	}
	m_hPollingThread = NULL;
	m_pollingConnection = NULL;
	debugLogA(__FUNCTION__": leaving");
}