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
|
#include "stdafx.h"
int CSteamProto::SendMsg(MCONTACT hContact, MEVENT, const char *message)
{
if (!IsOnline())
return -1;
UINT hMessage = InterlockedIncrement(&hMessageProcess);
CMStringA szId(FORMAT, "%d", hMessage);
{
mir_cslock lck(m_csOwnMessages);
m_arOwnMessages.insert(new COwnMessage(hContact, hMessage));
}
CFriendMessagesSendMessageRequest request;
request.chat_entry_type = (int)EChatEntryType::ChatMsg; request.has_chat_entry_type = true;
request.client_message_id = szId.GetBuffer();
request.contains_bbcode = request.has_contains_bbcode = true;
request.steamid = GetId(hContact, DBKEY_STEAM_ID); request.has_steamid = true;
request.message = (char *)message;
WSSendClient("FriendMessages.SendMessage#1", request, &CSteamProto::OnMessageSent);
return hMessage;
}
void CSteamProto::OnMessageSent(const uint8_t *buf, size_t cbLen)
{
proto::FriendMessagesSendMessageResponse reply(buf, cbLen);
if (!reply)
return;
COwnMessage *pOwn;
{
mir_cslock lck(m_csOwnMessages);
pOwn = m_arOwnMessages.find((COwnMessage *)&reply->ordinal);
}
if (pOwn) {
uint32_t timestamp = (reply->has_server_timestamp) ? reply->server_timestamp : 0;
if (timestamp > getDword(pOwn->hContact, DB_KEY_LASTMSGTS))
setDword(pOwn->hContact, DB_KEY_LASTMSGTS, timestamp);
pOwn->timestamp = timestamp;
ProtoBroadcastAck(pOwn->hContact, ACKTYPE_MESSAGE, ACKRESULT_SUCCESS, (HANDLE)pOwn->iMessageId, 0);
}
}
int CSteamProto::OnPreCreateMessage(WPARAM, LPARAM lParam)
{
MessageWindowEvent *evt = (MessageWindowEvent *)lParam;
if (mir_strcmp(Proto_GetBaseAccountName(evt->hContact), m_szModuleName))
return 0;
mir_cslock lck(m_csOwnMessages);
if (auto *pOwn = m_arOwnMessages.find((COwnMessage *)&evt->seq)) {
evt->dbei->timestamp = pOwn->timestamp;
m_arOwnMessages.remove(pOwn);
}
return 0;
}
int CSteamProto::UserIsTyping(MCONTACT hContact, int type)
{
// NOTE: Steam doesn't support sending "user stopped typing" so we're sending only positive info
if (type == PROTOTYPE_SELFTYPING_OFF)
return 0;
ptrA steamId(getStringA(hContact, DBKEY_STEAM_ID));
//SendRequest(new SendTypingRequest(m_szAccessToken, m_szUmqId, steamId));
return 0;
}
|
