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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
|
typedef __int64 SnowFlake;
class CDiscordProto;
typedef void (CDiscordProto::*HttpCallback)(NETLIBHTTPREQUEST*, struct AsyncHttpRequest*);
typedef void (CDiscordProto::*GatewayHandlerFunc)(const JSONNode&);
struct AsyncHttpRequest : public NETLIBHTTPREQUEST, public MZeroedObject
{
AsyncHttpRequest();
AsyncHttpRequest(CDiscordProto*, int iRequestType, LPCSTR szUrl, HttpCallback pFunc, JSONNode *pNode = NULL);
~AsyncHttpRequest();
void AddHeader(LPCSTR, LPCSTR);
CMStringA m_szUrl;
CMStringA m_szParam;
HttpCallback m_pCallback;
int m_iErrorCode, m_iReqNum;
void *pUserInfo;
};
struct PARAM
{
LPCSTR szName;
__forceinline PARAM(LPCSTR _name) : szName(_name)
{}
};
struct BOOL_PARAM : public PARAM
{
bool bValue;
__forceinline BOOL_PARAM(LPCSTR _name, bool _value) :
PARAM(_name), bValue(_value)
{}
};
AsyncHttpRequest* operator<<(AsyncHttpRequest*, const BOOL_PARAM&);
struct INT_PARAM : public PARAM
{
int iValue;
__forceinline INT_PARAM(LPCSTR _name, int _value) :
PARAM(_name), iValue(_value)
{}
};
AsyncHttpRequest* operator<<(AsyncHttpRequest*, const INT_PARAM&);
struct CHAR_PARAM : public PARAM
{
LPCSTR szValue;
__forceinline CHAR_PARAM(LPCSTR _name, LPCSTR _value) :
PARAM(_name), szValue(_value)
{}
};
AsyncHttpRequest* operator<<(AsyncHttpRequest*, const CHAR_PARAM&);
struct WCHAR_PARAM : public PARAM
{
LPCWSTR wszValue;
__forceinline WCHAR_PARAM(LPCSTR _name, LPCWSTR _value) :
PARAM(_name), wszValue(_value)
{}
};
AsyncHttpRequest* operator<<(AsyncHttpRequest*, const WCHAR_PARAM&);
JSONNode& operator<<(JSONNode &json, const INT_PARAM ¶m);
JSONNode& operator<<(JSONNode &json, const BOOL_PARAM ¶m);
JSONNode& operator<<(JSONNode &json, const CHAR_PARAM ¶m);
JSONNode& operator<<(JSONNode &json, const WCHAR_PARAM ¶m);
/////////////////////////////////////////////////////////////////////////////////////////
enum CDiscordHitoryOp
{
MSG_NOFILTER, MSG_AFTER, MSG_BEFORE
};
struct CDiscordUser : public MZeroedObject
{
CDiscordUser(SnowFlake _id) :
id(_id)
{}
SnowFlake id;
MCONTACT hContact;
SnowFlake channelId;
SnowFlake lastMessageId;
bool bIsPrivate;
CMStringW wszUsername;
int iDiscriminator;
};
class CDiscordProto : public PROTO<CDiscordProto>
{
friend struct AsyncHttpRequest;
friend class CDiscardAccountOptions;
//////////////////////////////////////////////////////////////////////////////////////
// threads
void __cdecl ServerThread(void*);
void __cdecl SearchThread(void *param);
//////////////////////////////////////////////////////////////////////////////////////
// session control
void SetAllContactStatuses(int iStatus);
void ConnectionFailed(int iReason);
void ShutdownSession(void);
ptrA m_szAccessToken;
mir_cs m_csHttpQueue;
HANDLE m_evRequestsQueue;
LIST<AsyncHttpRequest> m_arHttpQueue;
void ExecuteRequest(AsyncHttpRequest *pReq);
AsyncHttpRequest* Push(AsyncHttpRequest *pReq, int iTimeout = 10000);
HANDLE
m_hAPIConnection, // working connection
m_hWorkerThread; // worker thread handle
bool
m_bOnline, // protocol is online
m_bTerminated; // Miranda's going down
//////////////////////////////////////////////////////////////////////////////////////
// gateway
CMStringA
m_szGateway, // gateway url
m_szGatewaySessionId; // current session id
HANDLE
m_hGatewayNetlibUser, // the separate netlib user handle for gateways
m_hGatewayConnection; // gateway connection
void __cdecl GatewayThread(void*);
void CDiscordProto::GatewayThreadWorker(void);
void GatewaySend(const JSONNode&, int opCode = 1);
void GatewayProcess(const JSONNode&);
void GatewaySendHeartbeat(void);
void GatewaySendIdentify(void);
void OnReceiveGateway(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
GatewayHandlerFunc GetHandler(const wchar_t*);
int m_iHartbeatInterval; // in milliseconds
int m_iGatewaySeq; // gateway sequence number
//////////////////////////////////////////////////////////////////////////////////////
// options
CMOption<wchar_t*> m_wszEmail; // my own email
CMOption<wchar_t*> m_wszDefaultGroup; // clist group to store contacts
//////////////////////////////////////////////////////////////////////////////////////
// common data
SnowFlake m_ownId;
OBJLIST<CDiscordUser> arUsers;
CDiscordUser* FindUser(SnowFlake id);
CDiscordUser* FindUser(const wchar_t *pwszUsername, int iDiscriminator);
CDiscordUser* PrepareUser(const JSONNode&);
//////////////////////////////////////////////////////////////////////////////////////
// misc methods
SnowFlake getId(const char *szName);
SnowFlake getId(MCONTACT hContact, const char *szName);
void setId(const char *szName, SnowFlake iValue);
void setId(MCONTACT hContact, const char *szName, SnowFlake iValue);
public:
CDiscordProto(const char*,const wchar_t*);
~CDiscordProto();
// PROTO_INTERFACE
virtual DWORD_PTR __cdecl GetCaps(int, MCONTACT = 0) override;
virtual HWND __cdecl CreateExtendedSearchUI(HWND owner) override;
virtual HWND __cdecl SearchAdvanced(HWND owner) override;
virtual HANDLE __cdecl SearchBasic(const wchar_t* id) override;
virtual MCONTACT __cdecl AddToList(int flags, PROTOSEARCHRESULT* psr) override;
virtual int __cdecl AuthRequest(MCONTACT hContact, const wchar_t*) override;
virtual int __cdecl SetStatus(int iNewStatus) override;
virtual int __cdecl OnEvent(PROTOEVENTTYPE, WPARAM, LPARAM) override;
// Services
INT_PTR __cdecl GetStatus(WPARAM, LPARAM);
// Events
int __cdecl OnModulesLoaded(WPARAM, LPARAM);
int __cdecl OnPreShutdown(WPARAM, LPARAM);
int __cdecl OnOptionsInit(WPARAM, LPARAM);
int __cdecl OnSrmmEvent(WPARAM, LPARAM);
// dispatch commands
void OnCommandReady(const JSONNode&);
void OnLoggedIn();
void OnLoggedOut();
void OnReceiveAuth(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveToken(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveGuilds(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveChannels(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveFriends(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void RetrieveUserInfo(MCONTACT hContact);
void OnReceiveUserInfo(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void RetrieveHistory(MCONTACT hContact, CDiscordHitoryOp iOp = MSG_NOFILTER, SnowFlake msgid = 0, int iLimit = 50);
void OnReceiveHistory(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
// Misc
void SetServerStatus(int iStatus);
static void CALLBACK HeartbeatTimerProc(HWND hwnd, UINT msg, UINT_PTR id, DWORD);
__forceinline int getHeartbeatInterval() const { return m_iHartbeatInterval; }
};
|
