Bot.h

Go to the documentation of this file.

//
// Created by norbert on 12.08.17.
//

#ifndef YATBCPP_BOT_H
#define YATBCPP_BOT_H

#include <iostream>
#include <vector>
#include <thread>
#include <functional>
#include <queue>
#include <condition_variable>

#include "../bot/Token.h"
#include "../types/InlineQuery.h"
#include "../types/MessageEntity.h"
#include "../types/Message.h"
#include "../types/Update.h"
#include "../types/User.h"

#include "../methods/sendMessage.h"

#include "../methods/telegram_methodJSON.h"
#include "../methods/telegram_methodMultipart.h"

namespace yatbcpp {
    class Bot {
    public:

        Bot(Token& T);

        void startLongPoll();

        void startLongPoll(long timeout);

        void stopLongPoll();

        void startUpdating();

        void stopUpdating();

        const User getMe() const ;

//        const Message sendSM(sendMessage sm);

        void addOnUpdateListener(std::function<void(Update)> Listener);

        void addOnMessageBotCommandListener(std::function<void(Message,MessageEntity)> Listener);

        void addOnMessageListener(std::function<void(Message)> Listener);

        void addOnMessageEditedListener(std::function<void(Message)> Listener);

        void addOnChannelPostListener(std::function<void(Message)> Listener);

        void addOnChannelPostEditedListener(std::function<void(Message)> Listener);

        void addOnInlineQueryListener(std::function<void(InlineQuery)> Listener);

        void join();
        
        const Message send(sendMessage sendMessage) const;

    private:

        const Token token;



        std::thread Polling;
        std::thread Updating;

        bool isPolling;
        bool isUpdating;

        void LongPolling(long timeout);
        void NotifyRegisteredListeners();

        std::mutex m;
        std::queue<Update> pendingUpdates;
        std::condition_variable pendingUpdatesAvailable;

        std::vector<std::function<void(Update)>> OnUpdateListeners;
        std::vector<std::function<void(Message,MessageEntity)>> OnMessageCommandListener;
        std::vector<std::function<void(Message)>> OnMessageListener;
        std::vector<std::function<void(Message)>> OnMessageEditedListener;
        std::vector<std::function<void(Message)>> OnChannelPostListener;
        std::vector<std::function<void(Message)>> OnChannelPostEditedListener;
        std::vector<std::function<void(InlineQuery)>> OnInlineQueryListener;
        
        


    };
}

#endif //YATBOT_BOT_H