WebClientUnity.hpp

#pragma once
 
#include "IWebClient.hpp"
 
#include <custom-types/shared/coroutine.hpp>
#include <System/TimeSpan.hpp>
 
#include <map>
#include <mutex>
 
namespace CP_SDK::Network {
 
    namespace _u
    {
        using namespace System;
        using namespace System::Threading;
        using namespace UnityEngine::Networking;
    }
    namespace _v
    {
        using namespace CP_SDK::Utils;
    }
 
    class WebClientUnity : public IWebClient, public std::enable_shared_from_this<WebClientUnity>
    {
        CP_SDK_NO_COPYMOVE_CTORS(WebClientUnity);
        CP_SDK_PRIV_TAG();
 
        public:
            using Ptr = std::shared_ptr<WebClientUnity>;
 
        private:
            static Ptr m_GlobalClient;
 
        public:
            static WebClientUnity* GlobalClient();
 
        private:
            std::u16string                              m_BaseAddress;
            int                                         m_Timeout;
            std::map<std::u16string, std::u16string>    m_Headers;
            std::mutex                                  m_HeadersLock;
 
        public:
            int DownloadTimeout;
            int MaxRetry;
            int RetryInterval;
 
        public:
            WebClientUnity(CP_SDK_PRIV_TAG_ARG(), std::u16string_view p_BaseAddress, _u::TimeSpan p_TimeOut, bool p_ForceCacheDiscard);
 
            static Ptr Make(std::u16string_view p_BaseAddress, _u::TimeSpan p_TimeOut, bool p_ForceCacheDiscard = false);
 
        public:
            virtual std::u16string GetHeader(std::u16string_view p_Name) override final;
            virtual void SetHeader(std::u16string_view p_Name, std::u16string_view p_Value) override final;
            virtual void RemoveHeader(std::u16string_view p_Name) override final;
 
        public:
            virtual void GetAsync(std::u16string_view p_URL, _u::CancellationToken p_Token, _v::CActionRef<WebResponse::Ptr> p_Callback, bool p_DontRetry = false, _v::CActionRef<float> p_Progress = nullptr) override final;
            virtual void DownloadAsync(std::u16string_view p_URL, _u::CancellationToken p_Token, _v::CActionRef<WebResponse::Ptr> p_Callback, bool p_DontRetry = false, _v::CActionRef<float> p_Progress = nullptr) override final;
            virtual void PostAsync(std::u16string_view p_URL, const WebContent::Ptr& p_Content, _u::CancellationToken p_Token, _v::CActionRef<WebResponse::Ptr> p_Callback, bool p_DontRetry = false) override final;
            virtual void PatchAsync(std::u16string_view p_URL, const WebContent::Ptr& p_Content, _u::CancellationToken p_Token, _v::CActionRef<WebResponse::Ptr> p_Callback, bool p_DontRetry = false) override final;
            virtual void DeleteAsync(std::u16string_view p_URL, _u::CancellationToken p_Token, _v::CActionRef<WebResponse::Ptr> p_Callback, bool p_DontRetry = false) override final;
 
        private:
            std::u16string GetURL(std::u16string_view p_URL);
            std::u16string SafeURL(std::u16string_view p_URL);
 
        private:
            void PrepareRequest(_u::UnityWebRequest* p_Request, bool p_IsDownload);
            static custom_types::Helpers::Coroutine Coroutine_DoRequest(Ptr                             p_Self,
                                                                        std::u16string                  p_DebugName,
                                                                        std::u16string                  p_HttpMethod,
                                                                        std::u16string                  p_URL,
                                                                        WebContent::Ptr                 p_Content,
                                                                        _u::CancellationToken           p_Token,
                                                                        _v::Action<WebResponse::Ptr>    p_Callback,
                                                                        bool                            p_DontRetry,
                                                                        _v::Action<float>               p_Progress);
 
    };
 
}