1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
#include "common.h"
bool CSteamProto::IsOnline()
{
return m_iStatus > ID_STATUS_OFFLINE;
}
void CSteamProto::Authorize(SteamWebApi::AuthorizationApi::AuthResult *authResult)
{
ptrW username(getWStringA("Username"));
ptrA password(getStringA("Password"));
// try to authorize
SteamWebApi::AuthorizationApi::Authorize(m_hNetlibUser, username, password, authResult);
if (authResult->IsEmailAuthNeeded() || authResult->IsCaptchaNeeded())
{
do
{
if (authResult->IsEmailAuthNeeded())
{
GuardParam guard;
lstrcpyA(guard.domain, authResult->GetEmailDomain());
if (DialogBoxParam(
g_hInstance,
MAKEINTRESOURCE(IDD_GUARD),
NULL,
CSteamProto::GuardProc,
(LPARAM)&guard) != 1)
break;
authResult->SetAuthCode(guard.code);
}
if (authResult->IsCaptchaNeeded())
{
// todo: show captcha dialog
}
// try to authorize with emailauthcode or captcha taxt
SteamWebApi::AuthorizationApi::Authorize(m_hNetlibUser, username, password, authResult);
} while (authResult->IsEmailAuthNeeded() || authResult->IsCaptchaNeeded());
}
}
void CSteamProto::LogInThread(void* param)
{
CMStringA token(getStringA("TokenSecret"));
if (token.IsEmpty()/* && !this->IsOnline()*/)
{
SteamWebApi::AuthorizationApi::AuthResult authResult;
Authorize(&authResult);
// if some error
if (!authResult.IsSuccess())
{
// todo: dosplay error message from authResult.GetMessage()
//ProtoBroadcastAck(NULL, ACKTYPE_LOGIN, ACKRESULT_FAILED, NULL, LOGINERR_BADUSERID);
m_iStatus = m_iDesiredStatus = ID_STATUS_OFFLINE;
ProtoBroadcastAck(NULL, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)ID_STATUS_CONNECTING, ID_STATUS_OFFLINE);
return;
}
token = authResult.GetToken();
setString("TokenSecret", token);
setString("SteamID", authResult.GetSteamid());
}
SteamWebApi::LoginApi::LoginResult loginResult;
SteamWebApi::LoginApi::Logon(m_hNetlibUser, token, &loginResult);
// if some error
if (!loginResult.IsSuccess())
{
// set status to offline
m_iStatus = m_iDesiredStatus = ID_STATUS_OFFLINE;
ProtoBroadcastAck(NULL, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)ID_STATUS_CONNECTING, ID_STATUS_OFFLINE);
return;
}
else
{
setString("SessionID", loginResult.GetSessionId());
setDword("MessageID", loginResult.GetMessageId());
// set selected status
m_iStatus = m_iDesiredStatus;
ProtoBroadcastAck(NULL, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)ID_STATUS_CONNECTING, m_iDesiredStatus);
}
// start pooling thread
if (m_hPollingThread == NULL && !m_bTerminated)
{
m_bTerminated = false;
m_hPollingThread = ForkThreadEx(&CSteamProto::PollingThread, NULL, NULL);
}
// get contact list
SteamWebApi::FriendListApi::FriendList friendList;
SteamWebApi::FriendListApi::Load(m_hNetlibUser, token, loginResult.GetSteamId(), &friendList);
if (friendList.IsSuccess())
{
for (int i = 0; i < friendList.GetCount(); i++)
{
if (!FindContact(friendList[i]))
{
SteamWebApi::FriendApi::Friend rFriend;
SteamWebApi::FriendApi::LoadSummaries(m_hNetlibUser, token, friendList[i], &rFriend);
if (!rFriend.IsSuccess()) continue;
AddContact(rFriend);
}
}
}
}
void CSteamProto::LogOutThread(void*)
{
ptrA token(getStringA("TokenSecret"));
ptrA sessionId(getStringA("SessionID"));
SteamWebApi::LoginApi::Logoff(m_hNetlibUser, token, sessionId);
delSetting("SessionID");
}
|
