GCloudStorage.h++

Go to the documentation of this file.

#ifndef __libquark_gcloud_GCloudStorage_hxx
#define __libquark_gcloud_GCloudStorage_hxx

#include <QByteArray>
#include <QFile>
#include <QHttpMultiPart>
#include <QList>
#include <QNetworkAccessManager>
#include <QNetworkReply>
#include <QObject>
#include <QString>

#include <quark/GCloudBucket.h++>
#include <quark/GCloudCommon.h++>
#include <quark/GCloudObject.h++>
#include <quark/OAuth2AccessToken.h++>

namespace quark {
namespace gcloud {

class GCloudStorage : public QObject
{
  Q_OBJECT;

  public:

  GCloudStorage(QNetworkAccessManager *networkAccess, QObject *parent = NULL);
  virtual ~GCloudStorage();

  void setAccessToken(const oauth2::OAuth2AccessToken &token);

  bool isRequestInProgress() const;
  void cancelRequest();

  // Bucket operations.
  bool listBuckets(const QString &projectID, QString prefix = QString::null);

  bool createBucket(const QString &projectID, const QString &name,
                    AccessMode bucketAccessMode = AccessModeDefault,
                    AccessMode defaultObjectAccessMode = AccessModeDefault);

  bool deleteBucket(const QString &name);

  // Object operations.
  bool listObjects(const QString &bucketName, QString prefix = QString::null);

  bool createObject(const QString &bucketName, const QString &name,
                    const QString &contentType, const QString &localPath,
                    AccessMode accessMode = AccessModeDefault);

  bool deleteObject(const QString &bucketName, const QString &name);

  bool downloadObject(const QString &bucketName, const QString &name,
                      const QString &localPath);

  signals:

  void bucketCreated(quark::gcloud::GCloudBucket bucket);
  void bucketDeleted(const QString &name);
  void bucketListAvailable(QList<quark::gcloud::GCloudBucket> buckets);

  void objectCreated(const QString &bucketName,
                     quark::gcloud::GCloudObject object);
  void objectDeleted(const QString &bucketName, const QString &name);
  void objectListAvailable(const QString &bucketName,
                           QList<quark::gcloud::GCloudObject> objects);

  void objectTransferProgress(qint64 bytesTransferred, qint64 bytesTotal);
  void objectDownloaded(const QString &bucketName, const QString &objectName,
                        const QString &localPath);
  void objectUploaded(const QString &bucketName, const QString &objectName,
                      const QString &localPath);
  void requestFailed();
  void requestCancelled();

  private slots:

  void handleError(QNetworkReply::NetworkError error);
  void handleReply();
  void handleTransferProgress(qint64 bytesTransferred, qint64 bytesTotal);
  void handleDownloadFinished();

  private:

  enum RequestType { REQ_NONE = 0, REQ_LIST_BUCKETS, REQ_CREATE_BUCKET,
                     REQ_DELETE_BUCKET, REQ_LIST_OBJECTS, REQ_CREATE_OBJECT,
                     REQ_DELETE_OBJECT, REQ_DOWNLOAD_OBJECT };

  bool parseBucketMetadata(const QJsonObject &json, GCloudBucket &bucket);
  bool parseBucketList(const QJsonObject &object,
                       QList<GCloudBucket> &buckets);
  bool parseObjectMetadata(const QJsonObject &json, GCloudObject &object);
  bool parseObjectList(const QJsonObject &json,
                       QList<GCloudObject> &objects);
  qint64 parseTime(const QString &value);
  QString tokenForAccessMode(AccessMode accessMode);
  void startGetRequest(const QUrl &url);
  void startPostRequest(const QUrl &url, const QByteArray &requestBody);
  void startPostRequest(const QUrl &url, QHttpMultiPart *requestBody);
  void startDeleteRequest(const QUrl &url);
  QHttpMultiPart *buildMultiPartForUpload(const QString &contentType,
                                          const QString &localPath);

  QNetworkAccessManager *_networkAccess;
  oauth2::OAuth2AccessToken _token;
  RequestType _requestType;
  QNetworkReply *_networkReply;
  QString _currentBucketName;
  QString _currentObjectName;
  QScopedPointer<QFile> _localFile;
};

} // namespace gcloud
} // namespace quark

#endif // __libquark_gcloud_GCloudStorage_hxx