#include "skype_proto.h"
#include <sstream>

#define LI_STRING        0
#define LI_LIST          1
#define LI_NUMBER        2

SettingItem CSkypeProto::setting[] = {
  {LPGENT("Nick"),			"Nick",			DBVT_WCHAR,	LI_STRING},
  {LPGENT("First name"),	"FirstName",	DBVT_WCHAR,	LI_STRING},
  {LPGENT("Last name"),		"LastName",		DBVT_WCHAR,	LI_STRING},
  {LPGENT("Gender"),		"Gender",		DBVT_BYTE,	LI_LIST},

  {LPGENT("Mood"),			"XStatusMsg",	DBVT_WCHAR,	LI_STRING},

  {LPGENT("Mobile phone"),	"Cellular",		DBVT_WCHAR,	LI_NUMBER},
  {LPGENT("Home phone"),	"Phone",		DBVT_WCHAR,	LI_NUMBER},
  {LPGENT("Office phone"),	"CompanyPhone",	DBVT_WCHAR,	LI_NUMBER},

  {LPGENT("E-mail 1"),		"e-mail0",		DBVT_WCHAR,	LI_STRING},
  {LPGENT("E-mail 2"),		"e-mail1",		DBVT_WCHAR,	LI_STRING},
  {LPGENT("E-mail 3"),		"e-mail2",		DBVT_WCHAR,	LI_STRING},

  {LPGENT("Time zone"),		"Timezone",		DBVT_BYTE,	LI_LIST},
  {LPGENT("Country"),		"Country",		DBVT_WCHAR,	LI_LIST},
  {LPGENT("State"),			"State",		DBVT_WCHAR,	LI_STRING},
  {LPGENT("City"),			"City",			DBVT_WCHAR,	LI_STRING},  

  {LPGENT("Birth day"),		"BirthDay",		DBVT_BYTE,	LI_NUMBER},
  {LPGENT("Birth month"),	"BirthMonth",	DBVT_BYTE,	LI_NUMBER},
  {LPGENT("Birth year"),	"BirthYear",	DBVT_WORD,	LI_NUMBER},

  {LPGENT("Language 1"),	"Language1",	DBVT_WCHAR,	LI_LIST},
  {LPGENT("Language 2"),	"Language2",	DBVT_WCHAR,	LI_LIST},
  {LPGENT("Language 3"),	"Language3",	DBVT_WCHAR,	LI_LIST},

  {LPGENT("About"),			"About",		DBVT_WCHAR,	LI_STRING},
  {LPGENT("Homepage"),		"Homepage",		DBVT_WCHAR,	LI_STRING}
};

void CSkypeProto::UpdateProfileAvatar(SEObject *obj, HANDLE hContact)
{
	uint newTS = hContact ? obj->GetUintProp(Contact::P_AVATAR_TIMESTAMP) : obj->GetUintProp(Account::P_AVATAR_TIMESTAMP);
	DWORD oldTS = ::db_get_dw(hContact, this->m_szModuleName, "AvatarTS", 0);
	
	wchar_t *path = this->GetContactAvatarFilePath(hContact);
	SEBinary data = hContact ? obj->GetBinProp(Contact::P_AVATAR_IMAGE) : obj->GetBinProp(Account::P_AVATAR_IMAGE);

	bool hasNewAvatar = newTS > oldTS;
	bool isAvatarEmpty = data.size() == 0;
	bool isAvatarFileExists = ::PathFileExists(path) > 0;
	if ( !isAvatarEmpty)
	{
		if (hasNewAvatar || !isAvatarFileExists)
		{
			FILE *fp = ::_wfopen(path, L"wb");
			if (fp)
			{
				::fwrite(data.data(), sizeof(char), data.size(), fp);
				::fclose(fp);

				::db_set_dw(hContact, this->m_szModuleName, "AvatarTS", newTS);

				if (hContact)
				{
					PROTO_AVATAR_INFORMATIONW pai = {0};
					pai.cbSize = sizeof(pai);
					pai.format = PA_FORMAT_JPEG;
					pai.hContact = hContact;
					::wcscpy(pai.filename, path);
						
					this->SendBroadcast(hContact, ACKTYPE_AVATAR, ACKRESULT_SUCCESS, (HANDLE)&pai, 0);
				}
				else
				{
					::mir_md5_byte_t digest[16];
					::mir_md5_hash((BYTE*)data.data(), (int)data.size(), digest);
					::db_set_blob(hContact, this->m_szModuleName, "AvatarHash", digest, 16);

					::CallService(MS_AV_SETMYAVATART, (WPARAM)m_szModuleName, (LPARAM)path);
				}
			}
		}
	}
	else if (isAvatarFileExists)
	{
		::_wremove(path);
		this->SendBroadcast(hContact, ACKTYPE_AVATAR, ACKRESULT_SUCCESS, NULL, 0);
	}

	delete [] path;
}

void CSkypeProto::UpdateProfileAboutText(SEObject *obj, HANDLE hContact)
{
	wchar_t *aboutText = hContact ? ::mir_utf8decodeW(obj->GetStrProp(Contact::P_ABOUT)) : ::mir_utf8decodeW(obj->GetStrProp(Account::P_ABOUT));
	if ( !::wcslen(aboutText))
		::db_unset(hContact, this->m_szModuleName, "About");
	else
		::db_set_ws(hContact, this->m_szModuleName, "About", aboutText);
	::mir_free(aboutText);
}

void CSkypeProto::UpdateProfileBirthday(SEObject *obj, HANDLE hContact)
{
	uint data = hContact ? obj->GetUintProp(Contact::P_BIRTHDAY) : obj->GetUintProp(Account::P_BIRTHDAY);
	if (data > 0)
	{
		TCHAR date[9];
		_itot_s(data, date, 10);

		INT day, month, year;
		_stscanf(date, _T("%04d%02d%02d"), &year, &month, &day);

		::db_set_b(hContact, this->m_szModuleName, "BirthDay", day);
		::db_set_b(hContact, this->m_szModuleName, "BirthMonth", month);
		::db_set_w(hContact, this->m_szModuleName, "BirthYear", year);

		SYSTEMTIME sToday = {0};
		GetLocalTime(&sToday);
		int nAge = sToday.wYear - year;
		if (sToday.wMonth < month || (sToday.wMonth == month && sToday.wDay < day))
			nAge--;
		if (nAge)
			::db_set_w(hContact, this->m_szModuleName, "Age", ( WORD )nAge );
	}
	else
	{
		::db_unset(hContact, this->m_szModuleName, "BirthDay");
		::db_unset(hContact, this->m_szModuleName, "BirthMonth");
		::db_unset(hContact, this->m_szModuleName, "BirthYear");
		::db_unset(hContact, this->m_szModuleName, "Age");
	}
}

void CSkypeProto::UpdateProfileCity(SEObject *obj, HANDLE hContact)
{
	wchar_t *city = hContact ? ::mir_utf8decodeW(obj->GetStrProp(Contact::P_CITY)) : ::mir_utf8decodeW(obj->GetStrProp(Account::P_CITY));
	if ( !::wcslen(city))
		::db_unset(hContact, this->m_szModuleName, "City");
	else
		::db_set_ws(hContact, this->m_szModuleName, "City", city);
	::mir_free(city);
}

void CSkypeProto::UpdateProfileCountry(SEObject *obj, HANDLE hContact)
{
	char *country;
	char *isocode = hContact ? ::mir_strdup(obj->GetStrProp(Contact::P_COUNTRY)) : ::mir_strdup(obj->GetStrProp(Account::P_COUNTRY));
	if ( !::strlen(isocode))
	{
		country = (char *)CallService(MS_UTILS_GETCOUNTRYBYNUMBER, 0xFFFF, 0);
		::db_set_ws(hContact, this->m_szModuleName, "Country", ::mir_a2t(country));
	}
	else
	{
		country = (char *)CallService(MS_UTILS_GETCOUNTRYBYISOCODE, (WPARAM)isocode, 0);
		::db_set_ws(hContact, this->m_szModuleName, "Country", ::mir_a2t(country));
	}
	::mir_free(isocode);
}

void CSkypeProto::UpdateProfileEmails(SEObject *obj, HANDLE hContact)
{
	wchar_t *emails = hContact ? ::mir_a2u(obj->GetStrProp(Contact::P_EMAILS)) : ::mir_a2u(obj->GetStrProp(Account::P_EMAILS));
	if (::wcscmp(emails, L"") == 0)
	{
		::db_unset(hContact, this->m_szModuleName, "e-mail0");
		::db_unset(hContact, this->m_szModuleName, "e-mail1");
		::db_unset(hContact, this->m_szModuleName, "e-mail2");
	}
	else
	{
		StringList emls = emails;
		for (int i = 0; i < emls.getCount(); i++)
		{
			std::stringstream ss;
			ss << "e-mail" << i;
			std::string key = ss.str();
		
			::db_set_ws(hContact, this->m_szModuleName, key.c_str(), emls[i]);
		}
	}
	::mir_free(emails);
}

void CSkypeProto::UpdateProfileFullName(SEObject *obj, HANDLE hContact)
{
	wchar_t *fullname = hContact ? ::mir_utf8decodeW(obj->GetStrProp(Contact::P_FULLNAME)) : ::mir_utf8decodeW(obj->GetStrProp(Account::P_FULLNAME));
	if ( !::wcslen(fullname))
	{
		::db_unset(hContact, this->m_szModuleName, "FirstName");
		::db_unset(hContact, this->m_szModuleName, "LastName");
	}
	else
	{
		SEString firstName, lastName;
		CContact *contact = (CContact *)obj;
		contact->GetFullname(firstName, lastName);

		::db_set_ws(hContact, this->m_szModuleName, "FirstName", mir_ptr<wchar_t>(::mir_utf8decodeW(firstName)));
		::db_set_ws(hContact, this->m_szModuleName, "LastName", mir_ptr<wchar_t>(::mir_utf8decodeW(lastName)));
	}
	::mir_free(fullname);
}

void CSkypeProto::UpdateProfileGender(SEObject *obj, HANDLE hContact)
{
	uint data = hContact ? obj->GetUintProp(Contact::P_GENDER) : obj->GetUintProp(Account::P_GENDER);
	if (data)
		::db_set_b(hContact, this->m_szModuleName, "Gender", (BYTE)(data == 1 ? 'M' : 'F'));
	else
		::db_unset(hContact, this->m_szModuleName, "Gender");
}

void CSkypeProto::UpdateProfileHomepage(SEObject *obj, HANDLE hContact)
{
	wchar_t *homepage = hContact ? ::mir_a2u(obj->GetStrProp(Contact::P_HOMEPAGE)) : ::mir_a2u(obj->GetStrProp(Account::P_HOMEPAGE));
	if (::wcscmp(homepage, L"") == 0)
		::db_unset(hContact, this->m_szModuleName, "Homepage");
	else
		::db_set_ws(hContact, this->m_szModuleName, "Homepage", homepage);
	::mir_free(homepage);	
}

void CSkypeProto::UpdateProfileLanguages(SEObject *obj, HANDLE hContact)
{
	wchar_t *isocodes = hContact ? ::mir_utf8decodeW(obj->GetStrProp(Contact::P_LANGUAGES)) : ::mir_utf8decodeW(obj->GetStrProp(Account::P_LANGUAGES));
	if ( !::wcslen(isocodes))
	{
		::db_unset(hContact, this->m_szModuleName, "Language1");
		::db_unset(hContact, this->m_szModuleName, "Language2");
		::db_unset(hContact, this->m_szModuleName, "Language3");
	}
	else
	{
		StringList langs = isocodes;
		for (int i = 0; i < langs.getCount(); i++)
		{
			if (CSkypeProto::languages.count(langs[i]))
			{
				std::stringstream ss;
				ss << "Language" << i + 1;
				std::string key = ss.str();
				std::wstring val = CSkypeProto::languages[langs[i]];
				::db_set_ws(hContact, this->m_szModuleName, key.c_str(), val.c_str());
			}
		}
	}
	::mir_free(isocodes);
}

void CSkypeProto::UpdateProfileMobilePhone(SEObject *obj, HANDLE hContact)
{
	wchar_t *phone = hContact ? ::mir_a2u(obj->GetStrProp(Contact::P_PHONE_MOBILE)) : ::mir_a2u(obj->GetStrProp(Account::P_PHONE_MOBILE));
	if ( !::wcslen(phone))
		::db_unset(hContact, this->m_szModuleName, "Cellular");
	else
		::db_set_ws(hContact, this->m_szModuleName, "Cellular", phone);
	::mir_free(phone);
}

void CSkypeProto::UpdateProfilePhone(SEObject *obj, HANDLE hContact)
{
	wchar_t *phone = hContact ? ::mir_a2u(obj->GetStrProp(Contact::P_PHONE_HOME)) : ::mir_a2u(obj->GetStrProp(Account::P_PHONE_HOME));
	if ( !::wcslen(phone))
		::db_unset(hContact, this->m_szModuleName, "Phone");
	else
		::db_set_ws(hContact, this->m_szModuleName, "Phone", phone);
	::mir_free(phone);
}

void CSkypeProto::UpdateProfileOfficePhone(SEObject *obj, HANDLE hContact)
{
	wchar_t *phone = hContact ? ::mir_a2u(obj->GetStrProp(Contact::P_PHONE_OFFICE)) : ::mir_a2u(obj->GetStrProp(Account::P_PHONE_OFFICE));
	if ( !::wcslen(phone))
		::db_unset(hContact, this->m_szModuleName, "CompanyPhone");
	else
		::db_set_ws(hContact, this->m_szModuleName, "CompanyPhone", phone);		
	::mir_free(phone);
}

void CSkypeProto::UpdateProfileState(SEObject *obj, HANDLE hContact)
{
	wchar_t *state = hContact ? ::mir_utf8decodeW(obj->GetStrProp(Contact::P_PROVINCE)) : ::mir_utf8decodeW(obj->GetStrProp(Account::P_PROVINCE));
	if ( !::wcslen(state))
		::db_unset(hContact, this->m_szModuleName, "State");
	else
		::db_set_ws(hContact, this->m_szModuleName, "State", state);		
	::mir_free(state);
}

void CSkypeProto::UpdateProfileStatusMessage(SEObject *obj, HANDLE hContact)
{
	wchar_t *statusMessage = hContact ? ::mir_utf8decodeW(obj->GetStrProp(Contact::P_MOOD_TEXT)) : ::mir_utf8decodeW(obj->GetStrProp(Account::P_MOOD_TEXT));
	if ( !::wcslen(statusMessage))
		::db_unset(hContact, this->m_szModuleName, "XStatusMsg");
	else
		::db_set_ws(hContact, this->m_szModuleName, "XStatusMsg", statusMessage);
	::mir_free(statusMessage);
}

void CSkypeProto::UpdateProfileTimezone(SEObject *obj, HANDLE hContact)
{
	uint data = hContact ? obj->GetUintProp(Contact::P_TIMEZONE) : obj->GetUintProp(Account::P_TIMEZONE);
	if (data > 0)
	{
		uint diffmin = (data - 24*3600) / 60;
		wchar_t sign[2];
		if (diffmin < 0)
			::wcscpy(sign, L"-");
		else
			::wcscpy(sign, L"+");
		uint hours = ::abs((int)(diffmin / 60));
		uint mins = ::abs((int)(diffmin % 60));
		wchar_t timeshift[7];
		::mir_sntprintf(timeshift, SIZEOF(timeshift), _T("%s%d:%02d"), sign, hours, mins);
			
		wchar_t *szMin = wcschr(timeshift, ':');
		int nTz = ::_wtoi(timeshift) * -2;
		nTz += (nTz < 0 ? -1 : 1) * (szMin ? _ttoi( szMin + 1 ) / 30 : 0);

		TIME_ZONE_INFORMATION tzinfo;
		if (::GetTimeZoneInformation(&tzinfo) == TIME_ZONE_ID_DAYLIGHT)
			nTz -= tzinfo.DaylightBias / 30;

		::db_set_b(hContact, this->m_szModuleName, "Timezone", (signed char)nTz);
	}
	else
		::db_unset(hContact, this->m_szModuleName, "TimeZone");
}

void CSkypeProto::UpdateProfile(SEObject *obj, HANDLE hContact)
{
	this->UpdateProfileAvatar(obj, hContact);

	uint newTS = hContact ? obj->GetUintProp(Contact::P_PROFILE_TIMESTAMP) : obj->GetUintProp(Account::P_PROFILE_TIMESTAMP);
	if (newTS > ::db_get_dw(hContact, this->m_szModuleName, "ProfileTS", 0))
	{
		this->UpdateProfileAboutText(obj, hContact);
		this->UpdateProfileBirthday(obj, hContact);
		this->UpdateProfileCity(obj, hContact);
		this->UpdateProfileCountry(obj, hContact);
		this->UpdateProfileEmails(obj, hContact);
		this->UpdateProfileFullName(obj, hContact);
		this->UpdateProfileGender(obj, hContact);
		this->UpdateProfileHomepage(obj, hContact);
		this->UpdateProfileLanguages(obj, hContact);
		this->UpdateProfileMobilePhone(obj, hContact);
		this->UpdateProfilePhone(obj, hContact);
		this->UpdateProfileOfficePhone(obj, hContact);
		this->UpdateProfileState(obj, hContact);
		this->UpdateProfileStatusMessage(obj, hContact);
		this->UpdateProfileTimezone(obj, hContact);

		if (hContact)
		{
			this->UpdateContactNickName(obj, hContact);
			this->UpdateContactOnlineSinceTime(obj, hContact);
			this->UpdateContactLastEventDate(obj, hContact);

			::db_set_ws(hContact, this->m_szModuleName, "MirVer", L"Skype");
		}

		::db_set_dw(hContact, this->m_szModuleName, "ProfileTS", newTS);
	}
}

void __cdecl CSkypeProto::LoadOwnInfo(void *)
{
	wchar_t *nick = ::db_get_wsa(NULL, this->m_szModuleName, "Nick");
	if ( !nick || !::wcslen(nick))
	{
		SEString data;
		this->account->GetPropFullname(data);

		mir_ptr<wchar_t> nick = ::mir_utf8decodeW(data);
		::db_set_ws(NULL, this->m_szModuleName, "Nick", nick);
	}

	this->UpdateProfile(this->account.fetch());
}