library/messageslayer.cpp at master · kutegram/library · GitHub

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
#include "telegramclient.h"
#include "tlschema.h"
#include <QList>
#include "crypto.h"
#include <QtCore>

qint64 TelegramClient::getDialogs(qint32 offsetDate, qint32 offsetId, TObject offsetPeer, qint32 limit)
{
    TGOBJECT(getDialogs, TLType::MessagesGetDialogsMethod);

    //getDialogs["exclude_pinned"] = true;
    getDialogs["folder_id"] = 0; //0 for main list, 1 for archived chats
    getDialogs["offset_date"] = offsetDate;
    getDialogs["offset_id"] = offsetId;
    if (!ID(offsetPeer))
        offsetPeer = getInputPeer(offsetPeer);
    getDialogs["offset_peer"] = offsetPeer;
    getDialogs["limit"] = limit;

    return sendMTObject< &writeTLMethodMessagesGetDialogs >(getDialogs);
}

void TelegramClient::handleDialogs(QByteArray data, qint64 mtm)
{
    TelegramPacket packet(data);
    QVariant var;

    readTLMessagesDialogs(packet, var);
    TelegramObject obj = var.toMap();

    emit gotDialogs(mtm, 0, obj["dialogs"].toList(), obj["messages"].toList(), obj["chats"].toList(), obj["users"].toList());
}

void TelegramClient::handleDialogsSlice(QByteArray data, qint64 mtm)
{
    TelegramPacket packet(data);
    QVariant var;

    readTLMessagesDialogs(packet, var);
    TelegramObject obj = var.toMap();

    emit gotDialogs(mtm, obj["count"].toInt(), obj["dialogs"].toList(), obj["messages"].toList(), obj["chats"].toList(), obj["users"].toList());
}

qint64 TelegramClient::getHistory(TObject peer, qint32 offsetId, qint32 offsetDate, qint32 addOffset, qint32 limit)
{
    TGOBJECT(getHistory, TLType::MessagesGetHistoryMethod);

    getHistory["peer"] = peer;
    getHistory["offset_id"] = offsetId;
    getHistory["offset_date"] = offsetDate;
    getHistory["add_offset"] = addOffset;
    getHistory["limit"] = limit;

    return sendMTObject<&writeTLMethodMessagesGetHistory>(getHistory);
}

void TelegramClient::handleMessages(QByteArray data, qint64 mtm)
{
    TelegramPacket packet(data);
    QVariant var;

    readTLMessagesMessages(packet, var);
    TelegramObject obj = var.toMap();

    emit gotMessages(mtm, obj["count"].toInt(), obj["messages"].toList(), obj["chats"].toList(), obj["users"].toList(), obj["next_rate"].toInt(), obj["offset_id_offset"].toInt(), obj["inexact"].toBool());
}

void TelegramClient::handleMessagesSlice(QByteArray data, qint64 mtm)
{
    handleMessages(data, mtm);
}

void TelegramClient::handleChannelMessages(QByteArray data, qint64 mtm)
{
    handleMessages(data, mtm);
}

qint64 TelegramClient::sendMessage(TObject peer, QString message)
{
    TGOBJECT(sendMessage, TLType::MessagesSendMessageMethod);

    sendMessage["peer"] = peer;
    sendMessage["message"] = message;
    sendMessage["random_id"] = qFromLittleEndian<qint64>((const uchar*) randomBytes(sizeof(qint64)).constData()); //TODO random id handling

    return sendMTObject< &writeTLMethodMessagesSendMessage >(sendMessage);
}

qint64 TelegramClient::getMessages(TVector ids)
{
    TGOBJECT(getMessages, TLType::MessagesGetMessagesMethod);

    getMessages["id"] = ids;

    return sendMTObject< &writeTLMethodMessagesGetMessages >(getMessages);
}