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
|
/*
* Created by yuuta on 4/1/22.
*/
#include "log.h"
#include "logic.h"
#include "botd.h"
#include "tdutils.h"
#include <stdio.h>
#include <stdbool.h>
struct refresh_session {
bool running;
long long chat_id;
long long message_id;
long long offset_message_id;
unsigned int progress;
};
static struct refresh_session current_session = {
false,
0,
0,
0
};
static void refresh_get(void);
static void send_msg(long long chat_id, long long message_id, char *text) {
td_send(TdCreateObjectSendMessage(chat_id,
0,
message_id,
TdCreateObjectMessageSendOptions(false,
false,
true,
NULL),
NULL,
(struct TdInputMessageContent *)
TdCreateObjectInputMessageText(
TdCreateObjectFormattedText(text,
(struct TdVectorTextEntity *)
TdCreateObjectVectorObject(
0, NULL)
),
false,
false)),
NULL,
NULL);
}
static void send_administrative_msg(char *text) {
send_msg(current_session.chat_id, current_session.message_id, text);
}
static void cb_refresh_mlink(bool successful, struct TdObject *result, struct TdError *error, void *cb_arg) {
if (!successful) {
char msg[512];
snprintf(msg, 512, "Cannot get message link info: %d (%s)",
error ? error->code_ : -1,
error ? error->message_ : "NULL");
send_administrative_msg(msg);
current_session.running = false;
return;
}
struct TdMessageLinkInfo *info = (struct TdMessageLinkInfo *) result;
if (!info->message_) {
refresh_get();
return;
}
LOGDV("%lld", info->message_->id_);
store(info->message_);
refresh_get();
}
static void cb_refresh_link(bool successful, struct TdObject *result, struct TdError *error, void *cb_arg) {
if (!successful) {
char msg[512];
snprintf(msg, 512, "Cannot get link: %d (%s)",
error ? error->code_ : -1,
error ? error->message_ : "NULL");
send_administrative_msg(msg);
current_session.running = false;
return;
}
struct TdInternalLinkType *type = (struct TdInternalLinkType *) result;
if (type->ID != CODE_InternalLinkTypeMessage) {
refresh_get();
return;
}
struct TdInternalLinkTypeMessage *m = (struct TdInternalLinkTypeMessage *) type;
td_send(TdCreateObjectGetMessageLinkInfo(m->url_), &cb_refresh_mlink, NULL);
}
static void refresh_get(void) {
if (current_session.progress > 815) {
send_administrative_msg("Done.");
current_session.running = false;
return;
}
char url[64];
sprintf(url, "https://t.me/ksyxsays/%u", current_session.progress ++);
LOGDV("Get %s", url);
td_send(TdCreateObjectGetInternalLinkType(url),
&cb_refresh_link,
NULL);
}
void refresh(struct TdMessage *msg) {
if (current_session.running) {
send_msg(msg->chat_id_, msg->id_, "A refresh is already in progress.");
return;
}
current_session.running = true;
current_session.message_id = msg->id_;
current_session.chat_id = msg->chat_id_;
current_session.offset_message_id = 0;
current_session.progress = 1;
send_administrative_msg("Refreshing ...");
refresh_get();
}
|
