blob: a42c06dcf63b7d22ffe440dcc4cfff6827bfbfbc (
plain)
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
|
#pragma once
class CMTProto;
typedef void (CMTProto::*TG_QUERY_HANDLER)(td::ClientManager::Response &response);
struct TG_REQUEST
{
TG_REQUEST(int32_t _1, TG_QUERY_HANDLER _2) :
queryId(_1),
pHandler(_2)
{}
int32_t queryId;
TG_QUERY_HANDLER pHandler;
};
class CMTProto : public PROTO<CMTProto>
{
std::unique_ptr<td::ClientManager> m_pClientMmanager;
td::td_api::object_ptr<td::td_api::AuthorizationState> pAuthState;
bool m_bAuthorized, m_bRunning = false, m_bTerminated;
int32_t m_iClientId;
uint64_t m_iQueryId;
OBJLIST<TG_REQUEST> m_arRequests;
void ProcessResponse(td::ClientManager::Response);
void SendQuery(td::td_api::Function *pFunc, TG_QUERY_HANDLER pHandler = nullptr);
public:
//////////////////////////////////////////////////////////////////////////////////////
// Ctors
CMTProto(const char *protoName, const wchar_t *userName);
~CMTProto();
//////////////////////////////////////////////////////////////////////////////////////
// Virtual functions
INT_PTR GetCaps(int type, MCONTACT hContact = NULL) override;
int SetStatus(int iNewStatus) override;
// Processing Threads //////////////////////////////////////////////////////////////////
void __cdecl ServerThread(void *);
};
|
