AyonCppApi.h

Go to the documentation of this file.

#ifndef AYONCPPAPI_H
#define AYONCPPAPI_H
#include <sys/types.h>
#include <cstdint>
#include <memory>
#include <mutex>
#include <optional>
 
#include <string>
#include <utility>
#include <vector>
#include "lib/ynput/lib/logging/AyonLogger.hpp"
#include "appDataFoulder.h"
#include "httplib.h"
#include "nlohmann/json_fwd.hpp"
 
class AyonApi {
    public:
        AyonApi(const std::optional<std::string> &logFilePos,
                const std::string &authKey,
                const std::string &serverUrl,
                const std::string &ayonProjectName,
                const std::string &siteId,
                std::optional<int> concurrency = std::nullopt);
        ~AyonApi();
 
        std::string getKey();
        std::string getUrl();
 
        nlohmann::json GET(const std::shared_ptr<std::string> endPoint,
                           const std::shared_ptr<httplib::Headers> headers,
                           uint8_t sucsessStatus);
 
        nlohmann::json SPOST(const std::shared_ptr<std::string> endPoint,
                             const std::shared_ptr<httplib::Headers> headers,
                             nlohmann::json jsonPayload,
                             const std::shared_ptr<uint8_t> sucsessStatus);
        nlohmann::json CPOST(const std::shared_ptr<std::string> endPoint,
                             const std::shared_ptr<httplib::Headers> headers,
                             nlohmann::json jsonPayload,
                             const std::shared_ptr<uint8_t> sucsessStatus);
 
        std::pair<std::string, std::string> resolvePath(const std::string &uriPath);
        std::unordered_map<std::string, std::string> batchResolvePath(std::vector<std::string> &uriPaths);
 
        std::pair<std::string, std::string> getAssetIdent(const nlohmann::json &uriResolverRespone);
 
        bool loadEnvVars();
 
        std::shared_ptr<AyonLogger> logPointer();
 
        std::unordered_map<std::string, std::string>*
        getSiteRoots();   // TODO think about if this should only support current project or multiple projects
 
        std::string rootReplace(const std::string &rootLessPath);
 
    private:
        std::string serialCorePost(const std::string &endPoint,
                                   httplib::Headers headers,
                                   std::string &Payload,
                                   const int &sucsessStatus);
        std::string GenerativeCorePost(const std::string &endPoint,
                                       httplib::Headers headers,
                                       std::string &Payload,
                                       const int &sucsessStatus);
 
        std::string convertUriVecToString(const std::vector<std::string> &uriVec);
 
        // ----- Env Varibles
        std::unique_ptr<httplib::Client> m_AyonServer;
 
        std::unordered_map<std::string, std::string> m_siteRoots;
 
        const std::string m_authKey;
        const std::string m_serverUrl;
        std::string m_ayonProjectName;
 
        // ---- Server Vars
        std::string m_siteId;
        std::string m_userName;
 
        // --- Runtime Dep Vars
 
        // Async Grp Generation Varibles
        uint8_t m_minGrpSizeForAsyncRequests = 10;
        uint16_t m_regroupSizeForAsyncRequests = 200;
        uint16_t m_maxGroupSizeForAsyncRequests = 300;
        uint16_t m_minVecSizeForGroupSplitAsyncRequests = 50;
        uint8_t m_maxCallRetrys = 8;
        uint16_t m_retryWaight = 800;
 
        const int m_num_threads;   // set by constructor
        std::shared_ptr<AyonLogger> m_Log;
        std::string m_uriResolverEndpoint = "/api/resolve";
        std::string m_uriResolverEndpointPathOnlyVar = "?pathOnly=true";
        bool m_pathOnlyReselution = true;
 
        std::mutex m_ConcurentRequestAfterffoMutex;
        uint8_t m_maxConcurentRequestAfterffo = 8;
 
        uint16_t m_GenerativeCorePostMaxLoopIterations = 200;
 
        uint16_t m_connectionTimeOutMax = 200;
        uint8_t m_readTimeOutMax = 160;
 
        bool m_batchResolveOptimizeVector = true;
 
        uint16_t m_ServerBusyCode = 503;
        uint16_t m_RequestDelayWhenServerBusy = 10000;
 
        bool m_serverBusy = false;
 
        std::mutex m_AyonServerMutex;
};
 
#endif   // !AYONCPPAPI_H