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
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
|
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;
bool m_bMainSite;
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 INT64_PARAM : public PARAM
{
SnowFlake iValue;
__forceinline INT64_PARAM(LPCSTR _name, SnowFlake _value) :
PARAM(_name), iValue(_value)
{}
};
AsyncHttpRequest* operator<<(AsyncHttpRequest*, const INT64_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);
void __cdecl SendMessageAckThread(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_hWorkerThread; // worker thread handle
HNETLIBCONN m_hAPIConnection; // working connection
bool
m_bOnline, // protocol is online
m_bTerminated; // Miranda's going down
//////////////////////////////////////////////////////////////////////////////////////
// gateway
CMStringA
m_szGateway, // gateway url
m_szGatewaySessionId; // current session id
HNETLIBUSER m_hGatewayNetlibUser; // the separate netlib user handle for gateways
HNETLIBCONN 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);
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;
mir_cs csMarkReadQueue;
LIST<CDiscordUser> arMarkReadQueue;
OBJLIST<CDiscordUser> arUsers;
CDiscordUser* FindUser(SnowFlake id);
CDiscordUser* FindUser(const wchar_t *pwszUsername, int iDiscriminator);
CDiscordUser* FindUserByChannel(SnowFlake channelId);
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 RecvMsg(MCONTACT hContact, PROTORECVEVENT *evt) override;
virtual int __cdecl SendMsg(MCONTACT hContact, int flags, const char* pszSrc) override;
virtual int __cdecl SetStatus(int iNewStatus) override;
virtual int __cdecl OnEvent(PROTOEVENTTYPE, WPARAM, LPARAM) override;
// Services
INT_PTR __cdecl SvcCreateAccMgrUI(WPARAM, LPARAM);
INT_PTR __cdecl GetStatus(WPARAM, LPARAM);
INT_PTR __cdecl GetAvatarCaps(WPARAM, LPARAM);
INT_PTR __cdecl GetAvatarInfo(WPARAM, LPARAM);
INT_PTR __cdecl GetMyAvatar(WPARAM, LPARAM);
INT_PTR __cdecl SetMyAvatar(WPARAM, LPARAM);
// Events
int __cdecl OnModulesLoaded(WPARAM, LPARAM);
int __cdecl OnPreShutdown(WPARAM, LPARAM);
int __cdecl OnOptionsInit(WPARAM, LPARAM);
int __cdecl OnDbEventRead(WPARAM, LPARAM);
// dispatch commands
void OnCommandMessage(const JSONNode&);
void OnCommandPresence(const JSONNode&);
void OnCommandReady(const JSONNode&);
void OnCommandTyping(const JSONNode&);
void OnCommandUserUpdate(const JSONNode&);
void OnLoggedIn();
void OnLoggedOut();
void OnReceiveAuth(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveChannels(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveFriends(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveGateway(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveGuilds(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveMessage(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveMessageAck(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
void OnReceiveToken(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*);
bool RetrieveAvatar(MCONTACT hContact);
void OnReceiveAvatar(NETLIBHTTPREQUEST*, AsyncHttpRequest*);
// Misc
void SetServerStatus(int iStatus);
CMStringW GetAvatarFilename(MCONTACT hContact);
__forceinline int getHeartbeatInterval() const { return m_iHartbeatInterval; }
static void CALLBACK HeartbeatTimerProc(HWND hwnd, UINT msg, UINT_PTR id, DWORD);
static void CALLBACK MarkReadTimerProc(HWND hwnd, UINT msg, UINT_PTR id, DWORD);
};
|
