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
|
#include "stdafx.h"
void CSteamProto::OnGotConversations(const JSONNode &root, void *)
{
if (root.isnull())
return;
const JSONNode &response = root["response"];
for (auto &session : response["message_sessions"]) {
long long accountId = _wtoi64(session["accountid_friend"].as_mstring());
const char *who = AccountIdToSteamId(accountId);
MCONTACT hContact = GetContact(who);
if (!hContact)
continue;
// Don't load any messages when we don't have lastMessageTS, as it may cause duplicates
time_t storedMessageTS = getDword(hContact, DB_KEY_LASTMSGTS);
if (storedMessageTS == 0)
continue;
time_t lastMessageTS = _wtoi64(session["last_message"].as_mstring());
if (lastMessageTS > storedMessageTS)
SendRequest(new GetHistoryMessagesRequest(m_szAccessToken, m_iSteamId, who, storedMessageTS), &CSteamProto::OnGotHistoryMessages, (void*)hContact);
}
}
void CSteamProto::OnGotHistoryMessages(const JSONNode &root, void *arg)
{
if (root.isnull())
return;
MCONTACT hContact = UINT_PTR(arg);
time_t storedMessageTS = getDword(hContact, DB_KEY_LASTMSGTS);
time_t newTS = storedMessageTS;
const JSONNode &response = root["response"];
const JSONNode &messages = response["messages"];
for (size_t i = messages.size(); i > 0; i--) {
const JSONNode &message = messages[i - 1];
long long accountId = _wtoi64(message["accountid"].as_mstring());
const char *steamId = AccountIdToSteamId(accountId);
json_string text = message["message"].as_string();
time_t timestamp = _wtoi64(message["timestamp"].as_mstring());
// Ignore already existing messages
if (timestamp <= storedMessageTS)
continue;
DB::EventInfo dbei;
dbei.timestamp = timestamp;
dbei.pBlob = (char *)text.c_str();
if (IsMe(steamId))
dbei.flags = DBEF_SENT;
RecvMsg(hContact, dbei);
if (timestamp > newTS)
newTS = timestamp;
}
setDword(hContact, DB_KEY_LASTMSGTS, newTS);
}
|
