ibot.h

Go to the documentation of this file.

//#
//# Copyright (C) 2021-2024 QuasarApp.
//# Distributed under the GPLv3 software license, see the accompanying
//# Everyone is permitted to copy and distribute verbatim copies
//# of this license document, but changing it is not allowed.
//#
 
 
#ifndef IBOT_H
#define IBOT_H
 
#include "qTbot/global.h"
#include "qTbot/iupdate.h"
#include "qTbot/irequest.h"
 
#include "ifile.h"
#include "qfileinfo.h"
 
#include <QMap>
#include <QHash>
#include <QSet>
 
#include <QNetworkReply>
#include <QObject>
#include <QSharedPointer>
 
namespace qTbot {
 
class ReplayData;
 
class QTBOT_EXPORT IBot: public QObject
{
    Q_OBJECT
public:
    IBot();
    ~IBot();
 
    virtual bool login(const QByteArray& token) = 0;
 
    virtual void logout();
 
    virtual bool sendMessage(const QVariant& chatId, const QString& text) = 0;
 
    virtual bool deleteMessage(const QVariant& chatId, const QVariant& messageId) = 0;
 
    virtual QSharedPointer<iFile> getFile(const QString& fileId, iFile::Type fileType = iFile::Type::Ram) = 0;
 
    virtual bool sendFile( const QFileInfo& file, const QVariant& chatId) = 0;
 
    virtual bool sendFile( const QByteArray& file, const QString& fileName, const QVariant& chatId) = 0;
 
    const QByteArray &token() const;
 
    const QString& name() const;
 
    void setName(const QString &newName);
 
    QSharedPointer<iUpdate> takeNextUnreadUpdate();
 
    QSet<unsigned long long> processed() const;
 
    virtual void setProcessed(const QSet<unsigned long long> &newProcessed);
 
protected:
 
    template<class MessageType, class ... Args>
    static QSharedPointer<MessageType> makeMesasge(const QByteArray& data, Args&& ...args) {
        auto&& ptr = QSharedPointer<MessageType>(new MessageType(std::forward<Args>(args)...));
        ptr->setRawData(data);
 
        return ptr;
    }
 
    template<class MessageType, class ... Args>
    static QSharedPointer<MessageType> makeMesasge(const QJsonObject& data, Args&& ...args) {
        auto&& ptr = QSharedPointer<MessageType>(new MessageType(std::forward<Args>(args)...));
        ptr->setRawJson(data);
 
        return ptr;
    }
 
 
    virtual QString makeUrl(const QSharedPointer<iRequest>& request) const = 0;
 
    QSharedPointer<QNetworkReply>
    sendRequest(const QSharedPointer<iRequest>& rquest);
 
    void setToken(const QByteArray &newToken);
 
    void incomeNewUpdate(const QSharedPointer<iUpdate>& message);
 
    void markUpdateAsProcessed(const QSharedPointer<iUpdate>& message);
 
    void markUpdateAsUnprocessed(const QSharedPointer<iUpdate>& message);
 
    void markUpdateAsUnprocessed(unsigned long long messageID);
 
    virtual QString defaultFileStorageLocation() const;
 
    virtual void handleIncomeNewUpdate(const QSharedPointer<iUpdate>& );
signals:
    void sigReceiveUpdate(const QSharedPointer<iUpdate>& );
 
    void sigStopRequire();
 
private:
    void doRemoveFinishedRequests();
 
    QByteArray _token;
    QString _name;
    QMap<unsigned long long, QSharedPointer<iUpdate>> _notProcessedUpdates;
    QSet<unsigned long long> _processed;
    QNetworkAccessManager *_manager = nullptr;
 
    QMap<size_t,QSharedPointer<QNetworkReply>> _replayStorage;
    QList<size_t> _toRemove;
 
};
 
}
#endif // IBOT_H