Client.hpp

Go to the documentation of this file.

#pragma once

#include <zeus/WebServer.hpp>
#include <eproperty/Value.hpp>
#include <zeus/debug.hpp>
#include <chrono>

#include <zeus/Future.hpp>
#include <zeus/ServiceRemote.hpp>

namespace zeus {
    class Client : public eproperty::Interface {
        friend class ServiceRemote;
        public:
            eproperty::Value<std::string> propertyIp; 
            eproperty::Value<uint16_t> propertyPort; 
        private:
            ememory::SharedPtr<zeus::WebServer> m_interfaceClient; 
        public:
            //Client(const std::string& _address, const std::string& _clientName, const std::string& _clientTocken);
            //Client(const std::string& _address, const std::string& _userPassword);
            //Client(const std::string& _address);
            
            Client();
            virtual ~Client();
        protected:
            bool connectTo(const std::string& _address);
        public:
            bool connect(const std::string& _address);
            bool connect(const std::string& _address, const std::string& _userPassword);
            bool connect(const std::string& _address, const std::string& _clientName, const std::string& _clientTocken);
            void disconnect();
        public:
            zeus::ServiceRemote getService(const std::string& _serviceName);
        private:
            void onClientData(ememory::SharedPtr<zeus::Buffer> _value);
        public:
            template<class... _ARGS>
            zeus::FutureBase call(const std::string& _functionName, _ARGS&&... _args) {
                if (m_interfaceClient == nullptr) {
                    ememory::SharedPtr<zeus::BufferAnswer> ret = zeus::BufferAnswer::create();
                    ret->addError("NULLPTR", "call " + _functionName + " with no interface open");
                    return zeus::FutureBase(0, ret);
                }
                return m_interfaceClient->call(_functionName, _args...);
            }
            template<class... _ARGS>
            zeus::FutureBase callAction(const std::string& _functionName, _ARGS&&... _args, zeus::FutureData::ObserverFinish _callback) {
                if (m_interfaceClient == nullptr) {
                    ememory::SharedPtr<zeus::BufferAnswer> ret = zeus::BufferAnswer::create();
                    ret->addError("NULLPTR", "call " + _functionName + " with no interface open");
                    return zeus::FutureBase(0, ret, _callback);
                }
                return m_interfaceClient->callAction(_functionName, _args..., _callback);
            }
        private:
            void onPropertyChangeIp();
            void onPropertyChangePort();
    };
}