mirror
/
ESP32-CAM-Video-Recorder
kopia lustrzana https://github.com/jameszah/ESP32-CAM-Video-Recorder
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność
ESP32-CAM-Video-Recorder/old/v86/UniversalTelegramBot.cpp

953 wiersze
30 KiB
C++
Czysty Wina Historia

/*
Copyright (c) 2018 Brian Lough. All right reserved.
UniversalTelegramBot - Library to create your own Telegram Bot using
ESP8266 or ESP32 on Arduino IDE.
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
/*
**** Note Regarding Client Connection Keeping ****
Client connection is established in functions that directly involve use of
client, i.e sendGetToTelegram, sendPostToTelegram, and
sendMultipartFormDataToTelegram. It is closed at the end of
sendMultipartFormDataToTelegram, but not at the end of sendGetToTelegram and
sendPostToTelegram as these may need to keep the connection alive for respose
/ response checking. Re-establishing a connection then wastes time which is
noticeable in user experience. Due to this, it is important that connection
be closed manually after calling sendGetToTelegram or sendPostToTelegram by
calling closeClient(); Failure to close connection causes memory leakage and
SSL errors
*/
// James Zahary June 30, 2020
// - small mods to add caption to photos, and slow down transmit to telegram
#include "UniversalTelegramBot.h"
UniversalTelegramBot::UniversalTelegramBot(String token, Client &client) {
_token = token;
#ifdef ARDUINO_ESP8266_RELEASE_2_5_0
//client->setInsecure();
#endif
this->client = &client;
}
String UniversalTelegramBot::sendGetToTelegram(String command) {
String mess = "";
long now;
bool avail;
// Connect with api.telegram.org if not already connected
if (!client->connected()) {
#ifdef _debug
Serial.println(F("[BOT]Connecting to server"));
#endif
if (!client->connect(HOST, SSL_PORT)) {
#ifdef _debug
Serial.println(F("[BOT]Conection error"));
#endif
}
}
if (client->connected()) {
#ifdef _debug
Serial.println(F(".... connected to server"));
#endif
String a = "";
char c;
int ch_count = 0;
client->println("GET /" + command);
now = millis();
avail = false;
while (millis() - now < longPoll * 1000 + waitForResponse) {
while (client->available()) {
char c = client->read();
if (ch_count < maxMessageLength) {
mess = mess + c;
ch_count++;
}
avail = true;
}
if (avail) {
#ifdef _debug
Serial.println();
Serial.println(mess);
Serial.println();
#endif
break;
}
}
}
return mess;
}
String UniversalTelegramBot::sendPostToTelegram(String command, JsonObject payload) {
String body = "";
String headers = "";
long now;
bool responseReceived = false;
// Connect with api.telegram.org if not already connected
if (!client->connected()) {
#ifdef _debug
Serial.println(F("[BOT Client]Connecting to server"));
#endif
if (!client->connect(HOST, SSL_PORT)) {
#ifdef _debug
Serial.println(F("[BOT Client]Conection error"));
#endif
}
}
if (client->connected()) {
// POST URI
client->print("POST /" + command);
client->println(F(" HTTP/1.1"));
delay(100);
// Host header
client->print(F("Host:"));
client->println(HOST);
delay(100);
// JSON content type
client->println(F("Content-Type: application/json"));
delay(100);
// Content length
int length = measureJson(payload);
client->print(F("Content-Length:"));
client->println(length);
delay(100);
// End of headers
client->println();
// POST message body
String out;
serializeJson(payload, out);
client->println(out);
delay(100);
int ch_count = 0;
now = millis();
bool finishedHeaders = false;
bool currentLineIsBlank = true;
while (millis() - now < waitForResponse) {
while (client->available()) {
char c = client->read();
responseReceived = true;
if (!finishedHeaders) {
if (currentLineIsBlank && c == '\n') {
finishedHeaders = true;
} else {
headers = headers + c;
}
} else {
if (ch_count < maxMessageLength) {
body = body + c;
ch_count++;
}
}
if (c == '\n') currentLineIsBlank = true;
else if (c != '\r') currentLineIsBlank = false;
}
if (responseReceived && ch_count > 5) { //jz
#ifdef _debug
Serial.println();
Serial.println(body);
Serial.println();
#endif
//Serial.print(millis() - now); Serial.println(" sendPostToTelegram - breaking");
break;
}
}
}
return body;
}
String UniversalTelegramBot::sendMultipartFormDataToTelegram(
String command, String binaryProperyName, String fileName,
String contentType, String chat_id, int fileSize,
MoreDataAvailable moreDataAvailableCallback,
GetNextByte getNextByteCallback,
GetNextBuffer getNextBufferCallback,
GetNextBufferLen getNextBufferLenCallback) {
String body = "";
String headers = "";
long now;
bool responseReceived = false;
bool finishedHeaders = false;
bool currentLineIsBlank = true;
String boundry = F("------------------------b8f610217e83e29b");
// Connect with api.telegram.org if not already connected
if (!client->connected()) {
#ifdef _debug
Serial.println(F("[BOT Client]Connecting to server"));
#endif
if (!client->connect(HOST, SSL_PORT)) {
#ifdef _debug
Serial.println(F("[BOT Client]Conection error"));
#endif
}
}
if (client->connected()) {
String start_request = "";
String end_request = "";
start_request = start_request + "--" + boundry + "\r\n";
start_request = start_request + "content-disposition: form-data; name=\"chat_id\"" + "\r\n";
start_request = start_request + "\r\n";
start_request = start_request + chat_id + "\r\n";
start_request = start_request + "--" + boundry + "\r\n";
start_request = start_request + "content-disposition: form-data; name=\"caption\"" + "\r\n";
start_request = start_request + "\r\n";
start_request = start_request + "caption here!" + "\r\n";
start_request = start_request + "--" + boundry + "\r\n";
start_request = start_request + "content-disposition: form-data; name=\"" + binaryProperyName + "\"; filename=\"" + fileName + "\"" + "\r\n";
start_request = start_request + "Content-Type: " + contentType + "\r\n";
start_request = start_request + "\r\n";
end_request = end_request + "\r\n";
end_request = end_request + "--" + boundry + "--" + "\r\n";
client->print("POST /bot" + _token + "/" + command);
client->println(F(" HTTP/1.1"));
// Host header
client->print(F("Host: "));
client->println(HOST);
client->println(F("User-Agent: arduino/1.0"));
Serial.print("*") ; delay(100); //jz
client->println(F("Accept: */*"));
Serial.print("*") ; delay(100); //jz
int contentLength = fileSize + start_request.length() + end_request.length();
#ifdef _debug
Serial.println("Content-Length: " + String(contentLength));
#endif
client->print("Content-Length: ");
client->println(String(contentLength));
client->println("Content-Type: multipart/form-data; boundary=" + boundry);
Serial.print("*") ; delay(100); //jz
client->println("");
Serial.print("*") ; delay(100); //jz
client->print(start_request);
Serial.print("Start request: " + start_request);
#ifdef _debug
Serial.print("Start request: " + start_request);
#endif
if (getNextByteCallback == nullptr) {
while (moreDataAvailableCallback()) {
client->write((const uint8_t *)getNextBufferCallback(), getNextBufferLenCallback());
#ifdef _debug
Serial.println(F("Sending photo from buffer"));
#endif
}
} else {
#ifdef _debug
Serial.println(F("Sending photo by binary"));
#endif
byte buffer[512]; //jz 512
int count = 0;
char ch;
while (moreDataAvailableCallback()) {
buffer[count] = getNextByteCallback();
count++;
if (count == 512) { //jz 512
// yield();
#ifdef _debug
//Serial.println(F("Sending binary photo full buffer"));
#endif
client->write((const uint8_t *)buffer, 512); //jz 512
Serial.print("*") ; delay(100); //jz
count = 0;
}
}
if (count > 0) {
#ifdef _debug
Serial.println(F("Sending binary photo remaining buffer"));
#endif
client->write((const uint8_t *)buffer, count);
Serial.print("*") ; delay(100); //jz
}
}
client->print(end_request);
//#ifdef _debug
Serial.print("End request: " + end_request);
//#endif
Serial.print("... Done Sending. Client.Available = "); Serial.println(client->available());
delay(2000);
Serial.print("... 2 secs later. Client.Available = "); Serial.println(client->available());
int ch_count = 0;
now = millis();
while (millis() - now < waitForResponse) {
while (client->available()) {
char c = client->read();
responseReceived = true;
if (!finishedHeaders) {
if (currentLineIsBlank && c == '\n') {
finishedHeaders = true;
} else {
headers = headers + c;
}
} else {
if (ch_count < maxMessageLength) {
body = body + c;
ch_count++;
}
}
if (c == '\n') currentLineIsBlank = true;
else if (c != '\r') currentLineIsBlank = false;
}
if (responseReceived && ch_count > 5) { //jz && ch_count > 5
#ifdef _debug
Serial.println();
Serial.println(body);
Serial.println();
#endif
//Serial.print(millis() - now); Serial.println(" sendMultipartFormDataToTelegram - breaking");
break;
}
}
}
closeClient();
return body;
}
String UniversalTelegramBot::sendMultipartFormDataToTelegramWithCaption(
String command, String binaryProperyName, String fileName,
String contentType, String caption, String chat_id, int fileSize,
MoreDataAvailable moreDataAvailableCallback,
GetNextByte getNextByteCallback,
GetNextBuffer getNextBufferCallback,
GetNextBufferLen getNextBufferLenCallback) {
String body = "";
String headers = "";
long now;
bool responseReceived = false;
bool finishedHeaders = false;
bool currentLineIsBlank = true;
String boundry = F("------------------------b8f610217e83e29b");
// Connect with api.telegram.org if not already connected
if (!client->connected()) {
#ifdef _debug
Serial.println(F("[BOT Client]Connecting to server"));
#endif
if (!client->connect(HOST, SSL_PORT)) {
#ifdef _debug
Serial.println(F("[BOT Client]Conection error"));
#endif
}
}
if (client->connected()) {
String start_request = "";
String end_request = "";
//Serial.print("Start: "); Serial.println(ESP.getFreeHeap());
start_request = start_request + "--" + boundry + "\r\n";
start_request = start_request + "content-disposition: form-data; name=\"chat_id\"" + "\r\n";
start_request = start_request + "\r\n";
start_request = start_request + chat_id + "\r\n";
start_request = start_request + "--" + boundry + "\r\n"; //jz caption stuff
start_request = start_request + "content-disposition: form-data; name=\"caption\"" + "\r\n";
start_request = start_request + "\r\n";
start_request = start_request + caption + "\r\n";
start_request = start_request + "--" + boundry + "\r\n";
start_request = start_request + "content-disposition: form-data; name=\"" + binaryProperyName + "\"; filename=\"" + fileName + "\"" + "\r\n";
start_request = start_request + "Content-Type: " + contentType + "\r\n";
start_request = start_request + "\r\n";
end_request = end_request + "\r\n";
end_request = end_request + "--" + boundry + "--" + "\r\n";
client->print("POST /bot" + _token + "/" + command);
client->println(F(" HTTP/1.1"));
// Host header
client->print(F("Host: "));
client->println(HOST);
client->println(F("User-Agent: arduino/1.0"));
Serial.print("*") ; delay(100); //jz
client->println(F("Accept: */*"));
Serial.print("*") ; delay(100); //jz
int contentLength = fileSize + start_request.length() + end_request.length();
#ifdef _debug
Serial.println("Content-Length: " + String(contentLength));
#endif
client->print("Content-Length: ");
client->println(String(contentLength));
client->println("Content-Type: multipart/form-data; boundary=" + boundry);
Serial.print("*") ; delay(100); //jz
client->println("");
Serial.print("*") ; delay(100); //jz
client->print(start_request);
#ifdef _debug
Serial.print("Start request: " + start_request);
#endif
//Serial.print("End: "); Serial.println(ESP.getFreeHeap());
if (getNextByteCallback == nullptr) {
while (moreDataAvailableCallback()) {
client->write((const uint8_t *)getNextBufferCallback(), getNextBufferLenCallback());
#ifdef _debug
Serial.println(F("Sending photo from buffer"));
#endif
}
} else {
#ifdef _debug
Serial.println(F("Sending photo by binary"));
#endif
byte buffer[512];
int count = 0;
char ch;
while (moreDataAvailableCallback()) {
buffer[count] = getNextByteCallback();
count++;
if (count == 512) {
// yield();
#ifdef _debug
//Serial.println(F("Sending binary photo full buffer"));
#endif
client->write((const uint8_t *)buffer, 512);
Serial.print("*") ; delay(100); //jz
count = 0;
}
}
if (count > 0) {
#ifdef _debug
Serial.println(F("Sending binary photo remaining buffer"));
#endif
client->write((const uint8_t *)buffer, count);
Serial.print("*") ; delay(100); //jz
}
}
client->print(end_request);
#ifdef _debug
Serial.print("End request: " + end_request);
Serial.print("... Done Sending. Client.Available = "); Serial.println(client->available());
delay(2000);
Serial.print("... 2 secs later. Client.Available = "); Serial.println(client->available());
#endif
int ch_count = 0;
now = millis();
while (millis() - now < waitForResponse) {
while (client->available()) {
char c = client->read();
responseReceived = true;
if (!finishedHeaders) {
if (currentLineIsBlank && c == '\n') {
finishedHeaders = true;
} else {
headers = headers + c;
}
} else {
if (ch_count < maxMessageLength) {
body = body + c;
ch_count++;
}
}
if (c == '\n') currentLineIsBlank = true;
else if (c != '\r') currentLineIsBlank = false;
}
if (responseReceived && ch_count > 5) { //jz && ch_count > 5
#ifdef _debug
Serial.println();
Serial.println(body);
Serial.println();
#endif
//Serial.print(millis() - now); Serial.println(" sendMultipartFormDataToTelegram - breaking");
break;
}
}
}
closeClient();
return body;
}
bool UniversalTelegramBot::getMe() {
String command = "bot" + _token + "/getMe";
String response = sendGetToTelegram(command); // receive reply from telegram.org
DynamicJsonDocument doc(maxMessageLength);
DeserializationError error = deserializeJson(doc, response);
JsonObject obj = doc.as<JsonObject>(); //there is nothing better right now to use obj.containsKey("result")
closeClient();
if (!error) {
if (obj.containsKey("result")) {
String _name = doc["result"]["first_name"];
String _username = doc["result"]["username"];
name = _name;
userName = _username;
return true;
}
}
return false;
}
/***************************************************************
GetUpdates - function to receive messages from telegram
(Argument to pass: the last+1 message to read)
Returns the number of new messages
***************************************************************/
int UniversalTelegramBot::getUpdates(long offset) {
#ifdef _debug
Serial.println(F("GET Update Messages"));
#endif
String command = "bot" + _token + "/getUpdates?offset=" + String(offset) + "&limit=" + String(HANDLE_MESSAGES);
if (longPoll > 0) {
command = command + "&timeout=" + String(longPoll);
}
String response = sendGetToTelegram(command); // receive reply from telegram.org
if (response == "") {
#ifdef _debug
Serial.println(F("Received empty string in response!"));
#endif
// close the client as there's nothing to do with an empty string
closeClient();
return 0;
} else {
#ifdef _debug
Serial.print(F("incoming message length "));
Serial.println(response.length());
Serial.println(F("Creating DynamicJsonBuffer"));
#endif
// Parse response into Json object
DynamicJsonDocument doc(maxMessageLength);
DeserializationError error = deserializeJson(doc, response);
#ifdef _debug
Serial.print(F("GetUpdates parsed jsonDoc: "));
serializeJson(doc, Serial);
Serial.println();
#endif
JsonObject obj = doc.as<JsonObject>(); //there is nothing better right now
if (!error) {
#ifdef _debug
Serial.print(F("GetUpdates parsed jsonObj: "));
serializeJson(obj, Serial);
Serial.println();
#endif
if (obj.containsKey("result")) {
int resultArrayLength = doc["result"].size();
if (resultArrayLength > 0) {
int newMessageIndex = 0;
// Step through all results
for (int i = 0; i < resultArrayLength; i++) {
JsonObject result = doc["result"][i];
if (processResult(result, newMessageIndex)) newMessageIndex++;
}
// We will keep the client open because there may be a response to be
// given
return newMessageIndex;
} else {
#ifdef _debug
Serial.println(F("no new messages"));
#endif
}
} else {
#ifdef _debug
Serial.println(F("Response contained no 'result'"));
#endif
}
} else { // Parsing failed
if (response.length() < 2) { // Too short a message. Maybe a connection issue
#ifdef _debug
Serial.println(F("Parsing error: Message too short"));
#endif
} else {
// Buffer may not be big enough, increase buffer or reduce max number of
// messages
#ifdef _debug
Serial.print(F("Failed to parse update, the message could be too "
"big for the buffer. Error code: "));
Serial.println(error.c_str()); // debug print of parsing error
#endif
}
}
// Close the client as no response is to be given
closeClient();
return 0;
}
}
bool UniversalTelegramBot::processResult(JsonObject result, int messageIndex) {
int update_id = result["update_id"];
// Check have we already dealt with this message (this shouldn't happen!)
if (last_message_received != update_id) {
last_message_received = update_id;
messages[messageIndex].update_id = update_id;
messages[messageIndex].text = F("");
messages[messageIndex].from_id = F("");
messages[messageIndex].from_name = F("");
messages[messageIndex].longitude = 0;
messages[messageIndex].latitude = 0;
if (result.containsKey("message")) {
JsonObject message = result["message"];
messages[messageIndex].type = F("message");
messages[messageIndex].from_id = message["from"]["id"].as<String>();
messages[messageIndex].from_name = message["from"]["first_name"].as<String>();
messages[messageIndex].date = message["date"].as<String>();
messages[messageIndex].chat_id = message["chat"]["id"].as<String>();
messages[messageIndex].chat_title = message["chat"]["title"].as<String>();
if (message.containsKey("text")) {
messages[messageIndex].text = message["text"].as<String>();
} else if (message.containsKey("location")) {
messages[messageIndex].longitude = message["location"]["longitude"].as<float>();
messages[messageIndex].latitude = message["location"]["latitude"].as<float>();
}
} else if (result.containsKey("channel_post")) {
JsonObject message = result["channel_post"];
messages[messageIndex].type = F("channel_post");
messages[messageIndex].text = message["text"].as<String>();
messages[messageIndex].date = message["date"].as<String>();
messages[messageIndex].chat_id = message["chat"]["id"].as<String>();
messages[messageIndex].chat_title = message["chat"]["title"].as<String>();
} else if (result.containsKey("callback_query")) {
JsonObject message = result["callback_query"];
messages[messageIndex].type = F("callback_query");
messages[messageIndex].from_id = message["from"]["id"].as<String>();
messages[messageIndex].from_name = message["from"]["first_name"].as<String>();
messages[messageIndex].text = message["data"].as<String>();
messages[messageIndex].date = message["date"].as<String>();
messages[messageIndex].chat_id = message["message"]["chat"]["id"].as<String>();
messages[messageIndex].chat_title = F("");
} else if (result.containsKey("edited_message")) {
JsonObject message = result["edited_message"];
messages[messageIndex].type = F("edited_message");
messages[messageIndex].from_id = message["from"]["id"].as<String>();
messages[messageIndex].from_name = message["from"]["first_name"].as<String>();
messages[messageIndex].date = message["date"].as<String>();
messages[messageIndex].chat_id = message["chat"]["id"].as<String>();
messages[messageIndex].chat_title = message["chat"]["title"].as<String>();
if (message.containsKey("text")) {
messages[messageIndex].text = message["text"].as<String>();
} else if (message.containsKey("location")) {
messages[messageIndex].longitude = message["location"]["longitude"].as<float>();
messages[messageIndex].latitude = message["location"]["latitude"].as<float>();
}
}
return true;
}
return false;
}
/***********************************************************************
SendMessage - function to send message to telegram
(Arguments to pass: chat_id, text to transmit and markup(optional))
***********************************************************************/
bool UniversalTelegramBot::sendSimpleMessage(String chat_id, String text,
String parse_mode) {
bool sent = false;
#ifdef _debug
Serial.println(F("sendSimpleMessage: SEND Simple Message"));
#endif
long sttime = millis();
if (text != "") {
while (millis() < sttime + 8000) { // loop for a while to send the message
String command = "bot" + _token + "/sendMessage?chat_id=" + chat_id +
"&text=" + text + "&parse_mode=" + parse_mode;
String response = sendGetToTelegram(command);
#ifdef _debug
Serial.println(response);
#endif
sent = checkForOkResponse(response);
if (sent) break;
}
}
closeClient();
return sent;
}
bool UniversalTelegramBot::sendMessage(String chat_id, String text,
String parse_mode) {
DynamicJsonDocument payload(maxMessageLength);
payload["chat_id"] = chat_id;
payload["text"] = text;
if (parse_mode != "")
payload["parse_mode"] = parse_mode;
return sendPostMessage(payload.as<JsonObject>());
}
bool UniversalTelegramBot::sendMessageWithReplyKeyboard(
String chat_id, String text, String parse_mode, String keyboard,
bool resize, bool oneTime, bool selective) {
DynamicJsonDocument payload(maxMessageLength);
payload["chat_id"] = chat_id;
payload["text"] = text;
if (parse_mode != "")
payload["parse_mode"] = parse_mode;
JsonObject replyMarkup = payload.createNestedObject("reply_markup");
// Reply keyboard is an array of arrays.
// Outer array represents rows
// Inner arrays represents columns
// This example "ledon" and "ledoff" are two buttons on the top row
// and "status is a single button on the next row"
DynamicJsonDocument keyboardBuffer(maxMessageLength); // creating a buffer enough to keep keyboard string
deserializeJson(keyboardBuffer, keyboard);
replyMarkup["keyboard"] = keyboardBuffer.as<JsonArray>();
// Telegram defaults these values to false, so to decrease the size of the
// payload we will only send them if needed
if (resize)
replyMarkup["resize_keyboard"] = resize;
if (oneTime)
replyMarkup["one_time_keyboard"] = oneTime;
if (selective)
replyMarkup["selective"] = selective;
return sendPostMessage(payload.as<JsonObject>());
}
bool UniversalTelegramBot::sendMessageWithInlineKeyboard(String chat_id,
String text,
String parse_mode,
String keyboard) {
DynamicJsonDocument payload(maxMessageLength);
payload["chat_id"] = chat_id;
payload["text"] = text;
if (parse_mode != "")
payload["parse_mode"] = parse_mode;
JsonObject replyMarkup = payload.createNestedObject("reply_markup");
DynamicJsonDocument keyboardBuffer(maxMessageLength); // assuming keyboard buffer will alwas be limited to 1024 bytes
deserializeJson(keyboardBuffer, keyboard);
replyMarkup["inline_keyboard"] = keyboardBuffer.as<JsonArray>();
return sendPostMessage(payload.as<JsonObject>());
}
/***********************************************************************
SendPostMessage - function to send message to telegram
(Arguments to pass: chat_id, text to transmit and markup(optional))
***********************************************************************/
bool UniversalTelegramBot::sendPostMessage(JsonObject payload) {
bool sent = false;
#ifdef _debug
Serial.print(F("sendPostMessage: SEND Post Message: "));
serializeJson(payload, Serial);
Serial.println();
#endif
long sttime = millis();
if (payload.containsKey("text")) {
while (millis() < sttime + 8000) { // loop for a while to send the message
String command = "bot" + _token + "/sendMessage";
String response = sendPostToTelegram(command, payload);
#ifdef _debug
Serial.println(response);
#endif
sent = checkForOkResponse(response);
if (sent) break;
}
}
closeClient();
return sent;
}
String UniversalTelegramBot::sendPostPhoto(JsonObject payload) {
bool sent = false;
String response = "";
#ifdef _debug
Serial.println(F("sendPostPhoto: SEND Post Photo"));
#endif
long sttime = millis();
if (payload.containsKey("photo")) {
while (millis() < sttime + 8000) { // loop for a while to send the message
String command = "bot" + _token + "/sendPhoto";
response = sendPostToTelegram(command, payload);
#ifdef _debug
Serial.println(response);
#endif
sent = checkForOkResponse(response);
if (sent) break;
}
}
closeClient();
return response;
}
String UniversalTelegramBot::sendPhotoByBinary(
String chat_id, String contentType, int fileSize,
MoreDataAvailable moreDataAvailableCallback,
GetNextByte getNextByteCallback, GetNextBuffer getNextBufferCallback, GetNextBufferLen getNextBufferLenCallback) {
#ifdef _debug
Serial.println(F("sendPhotoByBinary: SEND Photo"));
#endif
String response = sendMultipartFormDataToTelegram("sendPhoto", "photo", "img.jpg",
contentType, chat_id, fileSize,
moreDataAvailableCallback, getNextByteCallback, getNextBufferCallback, getNextBufferLenCallback);
#ifdef _debug
Serial.println(response);
#endif
return response;
}
String UniversalTelegramBot::sendPhoto(String chat_id, String photo,
String caption,
bool disable_notification,
int reply_to_message_id,
String keyboard) {
DynamicJsonDocument payload(maxMessageLength);
payload["chat_id"] = chat_id;
payload["photo"] = photo;
if (caption)
payload["caption"] = caption;
if (disable_notification)
payload["disable_notification"] = disable_notification;
if (reply_to_message_id && reply_to_message_id != 0)
payload["reply_to_message_id"] = reply_to_message_id;
if (keyboard) {
JsonObject replyMarkup = payload.createNestedObject("reply_markup");
DynamicJsonDocument keyboardBuffer(maxMessageLength); // assuming keyboard buffer will alwas be limited to 1024 bytes
deserializeJson(keyboardBuffer, keyboard);
replyMarkup["keyboard"] = keyboardBuffer.as<JsonArray>();
}
return sendPostPhoto(payload.as<JsonObject>());
}
bool UniversalTelegramBot::checkForOkResponse(String response) {
int responseLength = response.length();
for (int m = 5; m < responseLength + 1; m++) {
if (response.substring(m - 10, m) ==
"{\"ok\":true") { // Chek if message has been properly sent
return true;
}
}
return false;
}
bool UniversalTelegramBot::sendChatAction(String chat_id, String text) {
bool sent = false;
#ifdef _debug
Serial.println(F("SEND Chat Action Message"));
#endif
long sttime = millis();
if (text != "") {
while (millis() < sttime + 8000) { // loop for a while to send the message
String command = "bot" + _token + "/sendChatAction?chat_id=" + chat_id +
"&action=" + text;
String response = sendGetToTelegram(command);
#ifdef _debug
Serial.println(response);
#endif
sent = checkForOkResponse(response);
if (sent) break;
}
}
closeClient();
return sent;
}
void UniversalTelegramBot::closeClient() {
if (client->connected()) {
#ifdef _debug
Serial.println(F("Closing client"));
#endif
client->stop();
}
}
Reference in New Issue View Git Blame Kopiuj bezpośredni odnośnik