Steam: work commit

- added requests queue
- code refactoring

Note: this commit may contain regress of functionality and bugs

git-svn-id: http://svn.miranda-ng.org/main/trunk@9401 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c

1 files changed, 338 insertions, 0 deletions

diff --git a/protocols/Steam/src/steam_pooling.cpp b/protocols/Steam/src/steam_pooling.cpp
new file mode 100644
index 0000000000..826187c9a4
--- /dev/null
+++ b/protocols/Steam/src/steam_pooling.cpp
@@ -0,0 +1,338 @@
+#include "common.h"

+

+void CSteamProto::PollServer(const char *token, const char *umqId, UINT32 messageId, SteamWebApi::PollApi::PollResult *pollResult)

+{

+	debugLogA("CSteamProto::PollServer: call SteamWebApi::PollApi::Poll");

+	SteamWebApi::PollApi::Poll(m_hNetlibUser, token, umqId, messageId, pollResult);

+

+	if (!pollResult->IsSuccess())

+		return;

+

+	CMStringA updatedIds;

+	for (size_t i = 0; i < pollResult->GetItemCount(); i++)

+	{

+		const SteamWebApi::PollApi::PoolItem *item = pollResult->GetAt(i);

+		switch (item->GetType())

+		{

+		case SteamWebApi::PollApi::POOL_TYPE_TYPING:

+			break;

+

+		case SteamWebApi::PollApi::POOL_TYPE_MESSAGE:

+			{

+				SteamWebApi::PollApi::Message *message = (SteamWebApi::PollApi::Message*)item;

+

+				MCONTACT hContact = FindContact(message->GetSteamId());

+				if (hContact)

+				{

+					const wchar_t *text = message->GetText();

+

+					PROTORECVEVENT recv = { 0 };

+					recv.flags = PREF_UTF;

+					recv.timestamp = message->GetTimestamp();

+					recv.szMessage = mir_utf8encodeW(text);

+

+					ProtoChainRecvMsg(hContact, &recv);

+				}

+			}

+			break;

+

+		case SteamWebApi::PollApi::POOL_TYPE_MYMESSAGE:

+			{

+				SteamWebApi::PollApi::Message *message = (SteamWebApi::PollApi::Message*)item;

+

+				MCONTACT hContact = FindContact(message->GetSteamId());

+				if (hContact)

+				{

+					const wchar_t *text = message->GetText();

+

+					AddDBEvent(hContact, EVENTTYPE_MESSAGE, time(NULL), DBEF_UTF | DBEF_SENT, lstrlen(text), (BYTE*)mir_utf8encodeW(text));

+				}

+			}

+			break;

+

+		case SteamWebApi::PollApi::POOL_TYPE_STATE:

+			{

+				SteamWebApi::PollApi::State *state = (SteamWebApi::PollApi::State*)item;

+

+				WORD status = CSteamProto::SteamToMirandaStatus(state->GetStatus());

+				const char *steamId = state->GetSteamId();

+				const wchar_t *nickname = state->GetNickname();

+

+				if (IsMe(steamId))

+				{

+					if (status == ID_STATUS_OFFLINE)

+						continue;

+

+					if (status != m_iStatus)

+					{

+						debugLogA("Change own status to %i", status);

+						WORD oldStatus = m_iStatus;

+						m_iStatus = m_iDesiredStatus = status;

+						ProtoBroadcastAck(NULL, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)oldStatus, m_iStatus);

+					}

+				}

+				/*else

+				{

+					MCONTACT hContact = FindContact(steamId);

+					if (hContact)

+						SetContactStatus(hContact, status);

+				}*/

+

+				if (updatedIds.IsEmpty())

+					updatedIds.Append(steamId);

+				else

+					updatedIds.AppendFormat(",%s", steamId);

+			}

+			break;

+

+		case SteamWebApi::PollApi::POOL_TYPE_CONTACT_ADD:

+			{

+				SteamWebApi::PollApi::Relationship *crs = (SteamWebApi::PollApi::Relationship*)item;

+

+				const char *steamId = crs->GetSteamId();

+				if (updatedIds.IsEmpty())

+					updatedIds.Append(steamId);

+				else

+					updatedIds.AppendFormat(",%s", steamId);

+			}

+			break;

+

+		case SteamWebApi::PollApi::POOL_TYPE_CONTACT_REMOVE:

+			{

+				SteamWebApi::PollApi::Relationship *crs = (SteamWebApi::PollApi::Relationship*)item;

+

+				const char *steamId = crs->GetSteamId();

+				MCONTACT hContact = FindContact(steamId);

+				if (hContact)

+					CallService(MS_DB_CONTACT_DELETE, hContact, 0);

+			}

+			break;

+

+		case SteamWebApi::PollApi::POOL_TYPE_CONTACT_REQUEST:

+			{

+				SteamWebApi::PollApi::Relationship *crs = (SteamWebApi::PollApi::Relationship*)item;

+

+				const char *steamId = crs->GetSteamId();

+				

+				MCONTACT hContact = FindContact(steamId);

+				if (!hContact)

+					hContact = AddContact(steamId, true);

+

+				RaiseAuthRequestThread((void*)hContact);

+			}

+			break;

+		}

+	}

+

+	if (!updatedIds.IsEmpty())

+		UpdateContactsThread(mir_strdup(updatedIds));

+}

+

+void CSteamProto::ParsePollData(JSONNODE *data)

+{

+	JSONNODE *node, *item = NULL;

+

+	for (size_t i = 0; i < json_size(data); i++)

+	{

+		item = json_at(data, i);

+		if (item == NULL)

+			break;

+

+		node = json_get(item, "steamid_from");

+		ptrA steamId(mir_u2a(json_as_string(node)));

+

+		node = json_get(item, "utc_timestamp");

+		time_t timestamp = atol(ptrA(mir_u2a(json_as_string(node))));

+

+		node = json_get(item, "type");

+		ptrW type(json_as_string(node));

+		if (!lstrcmpi(type, L"saytext") || !lstrcmpi(type, L"emote") ||

+			!lstrcmpi(type, L"my_saytext") || !lstrcmpi(type, L"my_emote"))

+		{

+			node = json_get(item, "text");

+			const wchar_t *text = json_as_string(node);

+

+			if (_tcsstr(type, L"my_") == NULL)

+			{

+				MCONTACT hContact = FindContact(steamId);

+				if (hContact)

+				{

+					PROTORECVEVENT recv = { 0 };

+					recv.flags = PREF_UTF;

+					recv.timestamp = timestamp;

+					recv.szMessage = mir_utf8encodeW(text);

+

+					ProtoChainRecvMsg(hContact, &recv);

+				}

+			}

+			else

+			{

+				MCONTACT hContact = FindContact(steamId);

+				if (hContact)

+					AddDBEvent(hContact, EVENTTYPE_MESSAGE, timestamp, DBEF_UTF | DBEF_SENT, lstrlen(text), (BYTE*)mir_utf8encodeW(text));

+			}

+

+			/*node = json_get(item, "text");

+			if (node != NULL) message->text = json_as_string(node);

+

+			node = json_get(item, "utc_timestamp");

+			message->timestamp = atol(ptrA(mir_u2a(json_as_string(node))));*/

+		}

+		/*else if (!lstrcmpi(type, L"typing"))

+		{

+		}*/

+		else if (!lstrcmpi(type, L"personastate"))

+		{

+			node = json_get(item, "persona_state");

+			int status = SteamToMirandaStatus(json_as_int(node));

+

+			if (IsMe(steamId))

+			{

+				if (status == ID_STATUS_OFFLINE)

+					continue;

+

+				if (status != m_iStatus)

+				{

+					debugLogA("CSteamProto::ParsePollData: Change own status to %i", status);

+					WORD oldStatus = m_iStatus;

+					m_iStatus = m_iDesiredStatus = status;

+					ProtoBroadcastAck(NULL, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)oldStatus, m_iStatus);

+				}

+			}

+			else if(!FindContact(steamId))

+			{

+				MCONTACT hContact = AddContact(steamId);

+

+				setWord(hContact, "Status", status);

+

+				node = json_get(item, "persona_name");

+				setWString(hContact, "Nick", json_as_string(node));

+			}

+

+			// todo: find difference between state changing and info changing

+		}

+		else if (!lstrcmpi(type, L"personarelationship"))

+		{

+			node = json_get(item, "persona_state");

+			int state = json_as_int(node);

+

+			switch (state)

+			{

+			case 0:

+				// removed

+				break;

+

+			case 1:

+				// ignored

+				break;

+

+			case 2:

+				{	// auth request

+					/*MCONTACT hContact = FindContact(steamId);

+					if (!hContact)

+						hContact = AddContact(steamId, true);*/

+

+					//RaiseAuthRequestThread((void*)hContact);

+

+					ptrA token(getStringA("TokenSecret"));

+

+					PushRequest(

+						new SteamWebApi::GetUserSummariesRequest(token, steamId),

+						&CSteamProto::OnAuthRequested,

+						mir_strdup(steamId));

+				}

+				break;

+

+			case 3:

+				// add to list

+				break;

+

+			default: continue;

+			}

+		}

+		/*else if (!lstrcmpi(type, L"leftconversation"))

+		{

+		}*/

+		else

+		{

+			continue;

+		}

+	}

+}

+

+void CSteamProto::PollingThread(void*)

+{

+	debugLogA("CSteamProto::PollingThread: entering");

+

+	ptrA token(getStringA("TokenSecret"));

+	ptrA umqId(getStringA("UMQID"));

+	UINT32 messageId = getDword("MessageID", 0);

+

+	//SteamWebApi::PollApi::PollResult pollResult;

+	bool breaked = false;

+	while (!isTerminated && !breaked)

+	{

+		SteamWebApi::PollRequest *request = new SteamWebApi::PollRequest(token, umqId, messageId);

+		debugLogA("CSteamProto::PollingThread: %s", request->szUrl);

+		request->szUrl = (char*)request->url.c_str();

+		request->nlc = m_pollingConnection;

+		NETLIBHTTPREQUEST *response = (NETLIBHTTPREQUEST*)CallService(MS_NETLIB_HTTPTRANSACTION, (WPARAM)m_hNetlibUser, (LPARAM)request);

+		delete request;

+

+		if (response == NULL || response->resultCode != HTTP_STATUS_OK)

+			return;

+

+		JSONNODE *root = json_parse(response->pData), *node;

+		node = json_get(root, "error");

+		ptrW error(json_as_string(node));

+

+		if (!lstrcmpi(error, L"OK"))

+		{

+

+			node = json_get(root, "messagelast");

+			messageId = json_as_int(node);

+

+			node = json_get(root, "messages");

+			root = json_as_array(node);

+

+			if (root != NULL)

+				ParsePollData(root);

+

+			m_pollingConnection = response->nlc;

+		}

+		else if (!lstrcmpi(error, L"Timeout"))

+		{

+			continue;

+		}

+		else if (!lstrcmpi(error, L"Not Logged On"))

+		{

+			if (!IsOnline())

+			{

+				// need to relogin

+				debugLogA("CSteamProto::PollingThread: not logged on");

+

+				SetStatus(ID_STATUS_OFFLINE);

+			}

+

+			breaked = true;

+		}

+		else if (lstrcmpi(error, L"Timeout"))

+		{

+			// something wrong

+			debugLogA("CSteamProto::PollingThread: error (%d)", response->resultCode);

+

+			// token has expired

+			if (response->resultCode == HTTP_STATUS_UNAUTHORIZED)

+				delSetting("TokenSecret");

+

+			breaked = true;

+		}

+

+		CallService(MS_NETLIB_FREEHTTPREQUESTSTRUCT, 0, (LPARAM)response);

+	}

+

+	setDword("MessageID", messageId);

+

+	m_hPollingThread = NULL;

+	debugLogA("CSteamProto::PollingThread: leaving");

+}
\ No newline at end of file