Skip to content
Snippets Groups Projects
fileuploader.h 1.44 KiB
Newer Older
Armin Felder's avatar
Armin Felder committed
#ifndef FILEUPLOADER_H
#define FILEUPLOADER_H

#include <QObject>
#include <QString>
#include <QByteArray>
#include <QMutexLocker>

#include "api/meteorddp.h"
#include "api/restapi.h"
#include "restRequests/restfileuploadrequest.h"
#include "ddpRequests/ddpmethodrequest.h"
#include "ddpRequests/ddpufscreaterequest.h"

class RocketChatServerData;
class FileUploader : public QObject
{
        Q_OBJECT
    public:
        FileUploader( RocketChatServerData *pServer, QUrl pUri, QString pChannelId );
        void upload( std::function<void( void )> );
        void cancel( void );
        QString getFileId() const;

    protected:
        void onUfsCreated( QJsonObject pResponse );
        void onUploadCompleted( QJsonObject pResponse );
        void nextRequest( void );

        QMutex mLock;
        QUrl mUri;
        MeteorDDP *mDdpApi;
        RestApi *mRestApi;
        QString mChannelId;
        QByteArray mDump;
        QMimeType mType;
        QString mToken;
        QString mFileId;
        int mSize;
        QVector<QSharedPointer<RestFileUploadRequest>> mPartialRequests;
        std::function<void( void )> mCleanUp;
        RocketChatServerData *mServer;
        bool mCanceled = 0;
        bool mErrorStatus = 0;
    signals:
        void ufsCreated( QString mFileId );
        void progressChanged( double progress );
        void fileuploadCompleted( void );
        void error( QString erorrString );
    public slots:

};

#endif // FILEUPLOADER_H