TelegramBotClient.h

Go to the documentation of this file.

#pragma once
#ifndef TelegramBotClient_h
#define TelegramBotClient_h

#include "TBCDebug.h"
#include "Arduino.h"
#include <Client.h>
#include <ArduinoJson.h>
#include "JsonWebClient.h"

#define TELEGRAMHOST F("api.telegram.org")
#define TELEGRAMPORT 443
#define POLLINGTIMEOUT 600
#define USERAGENTSTRING F("telegrambotclient /0.1")

// Inspired by PubSubClient by Nick O'Leary (http://knolleary.net)
#ifdef ESP8266
#include <functional>
#define TBC_CALLBACK_RECEIVE_SIGNATURE std::function<void(TelegramProcessError, JwcProcessError, Message*)> callbackReceive
#define TBC_CALLBACK_ERROR_SIGNATURE std::function<void(TelegramProcessError, JwcProcessError)> callbackError
#else
#define TBC_CALLBACK_RECEIVE_SIGNATURE void (*callbackReceive)(TelegramProcessError, JwcProcessError, Message*)
#define TBC_CALLBACK_ERROR_SIGNATURE void (*callbackError)(TelegramProcessError, JwcProcessError)
#endif

enum class TelegramProcessError : int
{
  Ok = 0,
  JcwPollErr = -1,
  JcwPostErr = -2,
  RetPollErr = -3,
  RetPostErr = -4
};

static String TelegramProcessErrorString[] = {"Ok", "JcwPollErr", "JcwPostErr", "RetPollErr", "RetPostErr"};

static String toString(TelegramProcessError err)
{
  return TelegramProcessErrorString[(-1) * (int) err];
}

struct Message {
  long UpdateId;
  long MessageId;
  long FromId;
  bool FromIsBot;
  String FromFirstName;
  String FromLastName;
  String FromLanguageCode;
  long ChatId;
  String ChatFirstName;
  String ChatLastName;
  String ChatType;
  String Text;
  long Date;
};

struct TBCKeyBoardRow
{
  uint Count;
  String* Buttons;
};

class TBCKeyBoard
{
  private:

    uint Count;             /*< Maximum number of rows in the keyboard */
    uint Counter;           /*< Number of rows already stored in keyboard */
    TBCKeyBoardRow* Rows;   /*< Array of rows in the keyboard */
    bool OneTime = false;
    bool Resize = false;
  public:
  TBCKeyBoard (uint count, bool oneTime = false, bool resize = false);
    ~TBCKeyBoard ();
    TBCKeyBoard& push(uint count, const String buttons[]);
    const String get(const uint row, const uint col);
    const int length (const uint row);
    const int length ();

    const bool getOneTime() {
      return OneTime;
    }
    const bool getResize() {
      return Resize;
    }

};

class TelegramBotClient
{
  private:
    long LastUpdateId = 0;
    String Token;
    bool Parallel = false;
    JsonWebClient* SslPollClient;
    JsonWebClient* SslPostClient;

    void startPolling();
    void startPosting(String Message);
    TBC_CALLBACK_RECEIVE_SIGNATURE;
    TBC_CALLBACK_ERROR_SIGNATURE;
  public:
    TelegramBotClient (
      String token,
      Client& sslPollClient,
      Client& sslPostClient,
      TBC_CALLBACK_RECEIVE_SIGNATURE,
      TBC_CALLBACK_ERROR_SIGNATURE
    );
    TelegramBotClient (
      String token,
      Client& sslPollClient,
      Client& sslPostClient)
      : TelegramBotClient (token, sslPollClient, sslPostClient, 0, 0) {};
    TelegramBotClient (
      String token,
      Client& sslPollClient)
      : TelegramBotClient (token, sslPollClient, sslPollClient, 0, 0) {};
    ~TelegramBotClient();
    void begin(
      TBC_CALLBACK_RECEIVE_SIGNATURE,
      TBC_CALLBACK_ERROR_SIGNATURE);
    void setCallbacks(
      TBC_CALLBACK_RECEIVE_SIGNATURE,
      TBC_CALLBACK_ERROR_SIGNATURE);

    bool loop();
    void postMessage(long chatId, String text, TBCKeyBoard& keyBoard);
    void postMessage(long chatId, String text) {TBCKeyBoard keyBoard(0);
      postMessage(chatId, text, keyBoard);
    }
    void pollSuccess(JwcProcessError err, JsonObject& json);
    void pollError(JwcProcessError err, Client* client);
    void postSuccess(JwcProcessError err, JsonObject& json);
    void postError(JwcProcessError err, Client* client);

    static void callbackPollSuccess (void* obj, JwcProcessError err, JsonObject& json)
    {
      if (obj == 0) return;
      TelegramBotClient* botClient = (TelegramBotClient*)obj;
      botClient->pollSuccess(err, json);
    }
    static void callbackPollError(void* obj, JwcProcessError err, Client* client)
    {
      if (obj == 0) return;
      TelegramBotClient* botClient = (TelegramBotClient*)obj;
      botClient->pollError(err, client);
    }
    static void callbackPostSuccess (void* obj, JwcProcessError err, JsonObject& json)
    {
      if (obj == 0) return;
      TelegramBotClient* botClient = (TelegramBotClient*)obj;
      botClient->postSuccess(err, json);
    }
    static void callbackPostError(void* obj, JwcProcessError err, Client* client)
    {
      if (obj == 0) return;
      TelegramBotClient* botClient = (TelegramBotClient*)obj;
      botClient->postError(err, client);
    }
};

#endif