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
|
#include "stdafx.h"
bool CSlackProto::IsOnline()
{
return !isTerminated && m_iStatus > ID_STATUS_OFFLINE;
}
void CSlackProto::Login()
{
ptrA token(getStringA("TokenSecret"));
if (mir_strlen(token))
{
PushRequest(new GetUserListRequest(token), &CSlackProto::OnGotUserList);
ProtoBroadcastAck(NULL, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)ID_STATUS_CONNECTING, m_iStatus = m_iDesiredStatus);
return;
}
CSlackOAuth oauth(this);
if (!oauth.DoModal())
{
SetStatus(ID_STATUS_OFFLINE);
return;
}
HttpRequest *request = new HttpRequest(HttpMethod::HttpPost, SLACK_API_URL "/oauth.access");
request->Headers
<< CHAR_VALUE("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
request->Content
<< CHAR_VALUE("client_id", SLACK_CLIENT_ID)
<< CHAR_VALUE("client_secret", SLACK_CLIENT_SECRET)
<< ENCODED_VALUE("code", oauth.GetAuthCode())
<< ENCODED_VALUE("redirect_uri", SLACK_REDIRECT_URL);
PushRequest(request, &CSlackProto::OnAuthorize);
}
void CSlackProto::OnAuthorize(JSONNode &root, void*)
{
if (!root)
{
SetStatus(ID_STATUS_OFFLINE);
ProtoBroadcastAck(NULL, ACKTYPE_LOGIN, ACKRESULT_FAILED, NULL, NULL);
return;
}
bool isOk = root["ok"].as_bool();
if (!isOk)
{
SetStatus(ID_STATUS_OFFLINE);
json_string error = root["error"].as_string();
debugLogA(__FUNCTION__": %s", error);
ProtoBroadcastAck(NULL, ACKTYPE_LOGIN, ACKRESULT_FAILED, NULL, LOGINERR_BADUSERID);
return;
}
json_string token = root["access_token"].as_string();
setString("TokenSecret", token.c_str());
json_string userId = root["user_id"].as_string();
setString("UserId", userId.c_str());
CMStringW teamName = root["team_name"].as_mstring();
setWString("TeamName", teamName);
if (!teamName.IsEmpty() && !Clist_GroupExists(teamName))
Clist_GroupCreate(0, teamName);
json_string teamId = root["team_id"].as_string();
setString("TeamId", userId.c_str());
PushRequest(new GetUserListRequest(token.c_str()), &CSlackProto::OnGotUserList);
ProtoBroadcastAck(NULL, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)ID_STATUS_CONNECTING, m_iStatus = m_iDesiredStatus);
}
void CSlackProto::LogOut()
{
isTerminated = true;
if (hRequestQueueThread)
SetEvent(hRequestsQueueEvent);
}
|
