-
Notifications
You must be signed in to change notification settings - Fork 0
/
telegram_bot_handling.cpp
154 lines (144 loc) · 6.3 KB
/
telegram_bot_handling.cpp
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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
/* ********************************************************************************************** */
/* */
/* Soft Tracker Project ESP32-C3 ::::::::: ::: */
/* telegram_bot_handling.cpp :+: :+: :+: :+: */
/* +:+ +:+ +:+ +:+ */
/* By: Roman Alexandrov <[email protected]> +#++:++#: +#++:++#++: */
/* +#+ +#+ +#+ +#+ */
/* Created: 2023/09/09 14:49:16 #+# #+# #+# #+# */
/* Updated: 2023/09/25 09:48:41 ### ### ### ### */
/* */
/* */
/* These functions are for checking on new Telegram messages, reading them and reacting to */
/* them accordingly. */
/* WARNING! DO NOT CALL THE ft_go_to_sleep() FUNCTION FROM ANY OF THESE FUNCTIONS! THE DEVICE */
/* WOULD BECOME UNRESPONSIVE TO ANY MESSAGES FROM THE TELEGRAM CHAT! */
/* The "cycles" variable is also responsible for how long the device stays ON and responds to */
/* the user's messages. E.g. cycles == WAIT_FOR_MESSAGES_LIMIT equals to ≈ 1 second; */
/* cycles == 0 equals to ≈ 2 x WAIT_FOR_MESSAGES_LIMIT seconds; cycles == -32767 equals to */
/* ≈ 2 x (32767 + WAIT_FOR_MESSAGES_LIMIT) seconds. */
/* */
/* ********************************************************************************************** */
#include "IoT-Name-Badge-ESP32.h"
static short IRAM_ATTR ft_answer_engine(String text)
{
String message;
if (text == "/status")
{
message = "Connected to " + String(WiFi.SSID());
message += ". Signal strength is " + String(WiFi.RSSI()) + " dBm. ";
message += "Battery is " + String(globals.battery) + "% charged, ";
message += "software version " + String(SOFTWARE_VERSION);
bot.sendMessage(rtc_g.chat_id, message, "Markdown");
return (0);
}
else if (text == "/ota")
{
if (rtc_g.ota == false)
{
ft_write_spiffs_file("/ota.txt", ACTIVE);
globals.reboot = true;
}
else
{
rtc_g.ota = false;
ft_write_spiffs_file("/ota.txt", CLOSED);
globals.reboot = false;
}
return (WAIT_FOR_MESSAGES_LIMIT);
}
else if (text == "/reboot")
{
bot.sendMessage(rtc_g.chat_id, "Rebooting!", "");
globals.reboot = true;
return (WAIT_FOR_MESSAGES_LIMIT);
}
else if (text == "/off")
{
bot.sendMessage(rtc_g.chat_id, "Switching off!", "");
return (WAIT_FOR_MESSAGES_LIMIT);
}
else if (text == "/clear")
{
bot.sendMessage(rtc_g.chat_id, "The display has been cleared", "");
ft_clear_display(true);
return (0);
}
else
{
message = text;
message.remove(0, 1);
ft_display_animated_text_with_font(message);
text.clear();
text = "Roman's badge now says:\n\"" + message + "\"";
bot.sendMessage(rtc_g.chat_id, text, "");
return (0);
}
return (0);
}
static short ft_new_messages(short numNewMessages) // function to handle what happens when you receive new messages
{
short cycles;
String text;
String from_name;
cycles = WAIT_FOR_MESSAGES_LIMIT;
DEBUG_PRINTF("\nHandling new messages\n", "");
DEBUG_PRINTF("Number of messages to handle: %d\n", numNewMessages);
for (short i = 0; i < numNewMessages; i++)
{
DEBUG_PRINTF("Handling loop iterations: i = %d\n", i);
rtc_g.chat_id = String(bot.messages[i].chat_id);
ft_write_spiffs_file("/chat_id.txt", rtc_g.chat_id);
text = bot.messages[i].text;
rtc_g.from_name = bot.messages[i].from_name;
DEBUG_PRINTF("%s says: ", rtc_g.from_name.c_str());
DEBUG_PRINTF("%s\n\n", text.c_str());
cycles = ft_answer_engine(text);
}
return (cycles);
}
static short ft_check_incomming_messages(short cycles)
{
short numNewMessages;
while (cycles <= WAIT_FOR_MESSAGES_LIMIT)
{
DEBUG_PRINTF("Waiting for incomming commands from Telegram chat. Waiting loop cycles: %d\n", cycles);
numNewMessages = bot.getUpdates(bot.last_message_received + 1);
while (numNewMessages)
{
cycles = ft_new_messages(numNewMessages);
numNewMessages = bot.getUpdates(bot.last_message_received + 1);
}
if ((cycles + 25) == WAIT_FOR_MESSAGES_LIMIT)
bot.sendMessage(rtc_g.chat_id, "Going to sleep in 1 minute. To keep me awake, write me any command", "");
if ((cycles + 1) == WAIT_FOR_MESSAGES_LIMIT)
bot.sendMessage(rtc_g.chat_id, "Good talk! I'm off now", "");
cycles++;
}
return (numNewMessages);
}
void telegram_bot_init(short cycles)
{
short numNewMessages;
client.setCACert(TELEGRAM_CERTIFICATE_ROOT);
ft_wifi_list();
if (wifiMulti.run(CONNECT_TIMEOUT) == WL_CONNECTED)
{
DEBUG_PRINTF("\nTelegram bot initialised\n", "");
switch (globals.reason)
{
case ESP_RST_POWERON:
bot.sendMessage(rtc_g.chat_id, "Hello! I am the IoT Name Badge. I am ON and ready for work!", "");
break;
case ESP_RST_PANIC:
bot.sendMessage(rtc_g.chat_id, "Don't panic, but my Core has just panicked!", "");
cycles = 0;
break;
}
numNewMessages = ft_check_incomming_messages(cycles);
}
esp_wifi_set_mode(WIFI_MODE_NULL);
DEBUG_PRINTF("Telegram bot has stopped. Wi-Fi is now OFF\n", "");
if (globals.reboot)
ESP.restart();
}