giantswarmclient.hpp

#ifndef BIDSTACK_GIANTSWARM_CLIENT_HPP
#define BIDSTACK_GIANTSWARM_CLIENT_HPP

#include <QObject>
#include <QVariantList>
#include <QVariantMap>

#include "giantswarmerror.hpp"
#include "repositories/environmentrepository.hpp"

#include "deps/http/httpclient.hpp"
#include "deps/http/httprequest.hpp"
#include "deps/http/httpresponse.hpp"

#include "deps/cache/abstractcacheadapter.hpp"

#include "deps/qjson4/QJsonObject.h"
#include "deps/qjson4/QJsonArray.h"

using namespace Bidstack::Http;
using namespace Bidstack::Cache;
using namespace Bidstack::Giantswarm::Repositories;

namespace Bidstack {
    namespace Giantswarm {

        const int STATUS_CODE_SUCCESS = 10000;
        const int STATUS_CODE_CREATED = 10003;
        const int STATUS_CODE_STARTED = 10004;
        const int STATUS_CODE_STOPPED = 10005;
        const int STATUS_CODE_UPDATED = 10006;
        const int STATUS_CODE_DELETED = 10007;

        class GiantswarmClient : public QObject {
            Q_OBJECT

        public:
            GiantswarmClient(QSqlDatabase& database, QObject *parent = 0);

        public:
            void setCache(AbstractCacheAdapter *cache);
            void setEndpoint(QString endpoint);

        public:
            Q_INVOKABLE bool login(QString email, QString password);
            Q_INVOKABLE bool logout();
            Q_INVOKABLE bool isLoggedIn();
            Q_INVOKABLE void setToken(QString token);

            Q_INVOKABLE QVariantList getCompanies();
            Q_INVOKABLE bool hasCompanies();
            Q_INVOKABLE bool createCompany(QString companyName);
            Q_INVOKABLE bool deleteCompany(QString companyName);

            Q_INVOKABLE QVariantList getCompanyUsers(QString companyName);
            Q_INVOKABLE bool addUserToCompany(QString companyName, QString username);
            Q_INVOKABLE bool removeUserFromCompany(QString companyName, QString username);

            Q_INVOKABLE QVariantList getEnvironments();
            Q_INVOKABLE bool hasEnvironments();
            Q_INVOKABLE bool hasEnvironment(QString companyName, QString environmentName);
            Q_INVOKABLE bool createEnvironment(QString companyName, QString environmentName);
            Q_INVOKABLE bool deleteEnvironment(QString companyName, QString environmentName);

            Q_INVOKABLE QVariantList getAllApplications();
            Q_INVOKABLE QVariantList getApplications(QString companyName, QString environmentName);
            Q_INVOKABLE QVariantMap getApplicationStatus(QString companyName, QString environmentName, QString applicationName);
            Q_INVOKABLE QVariantMap getApplicationConfiguration(QString companyName, QString environmentName, QString applicationName);
            Q_INVOKABLE bool startApplication(QString companyName, QString environmentName, QString applicationName);
            Q_INVOKABLE bool stopApplication(QString companyName, QString environmentName, QString applicationName);
            Q_INVOKABLE bool scaleApplicationUp(QString companyName, QString environmentName, QString applicationName, QString serviceName, QString componentName);
            Q_INVOKABLE bool scaleApplicationUp(QString companyName, QString environmentName, QString applicationName, QString serviceName, QString componentName, int count);
            Q_INVOKABLE bool scaleApplicationDown(QString companyName, QString environmentName, QString applicationName, QString serviceName, QString componentName);
            Q_INVOKABLE bool scaleApplicationDown(QString companyName, QString environmentName, QString applicationName, QString serviceName, QString componentName, int count);

            Q_INVOKABLE QVariantMap getInstanceStatistics(QString companyName, QString instanceId);

            Q_INVOKABLE QVariantMap getUser();
            Q_INVOKABLE bool updateEmail(QString email);
            Q_INVOKABLE bool updatePassword(QString old_password, QString new_password);

            Q_INVOKABLE bool ping();

        private:
            HttpResponse* send(QString cacheKey, HttpRequest *request);
            HttpResponse* send(HttpRequest *request);

            QString generateCachableStringFromResponse(HttpResponse *response);
            HttpResponse* generateResponseFromCachableString(QString string);

            QJsonObject extractDataAsObject(HttpResponse* response);
            QJsonArray extractDataAsArray(HttpResponse* response);

            void assertLoggedIn();
            void assertNotLoggedIn();
            void assertStatusCode(HttpResponse* response, int status);

            void throwError(GiantswarmError::Error e);

        private:
            QString m_token;
            QString m_endpoint;
            HttpClient *m_httpclient;
            AbstractCacheAdapter *m_cache;
            EnvironmentRepository *m_environments;
        };

    };
};

#endif