EuvStmClientBase.hpp

//
// Created by xiong on 2020/10/23.
//
 
#ifndef EMX_EUVSTMCLIENTBASE_HPP
#define EMX_EUVSTMCLIENTBASE_HPP
 
#include <memory>
#include "EuvStreamInf.hpp"
 
namespace Emx {
    class EuvStmClientBase {
    public:
 
        EuvStmClientBase(EuvStreamInf *stm) : m_stm(stm) {
            m_isConnected = false;
        }
 
        virtual ~EuvStmClientBase() {}
 
        ErrCodeE Create(EuvLoop &loop, char *buffer, int32_t size,
                        const char *serverIp, uint16_t serverPort,
                        const char *localIp = nullptr, uint16_t localPort = 0);
 
        void Destroy();
 
        ErrCodeE Send(std::shared_ptr<std::string> &data);
 
        void PauseRecv();
 
        ErrCodeE ResumeRecv();
 
        bool IsReceiving() { return m_stm->IsReceiving(); }
 
        std::string GetSockName() {
            char name[EMX_MAX_PATH_SIZE] = {};
            size_t size = EMX_MAX_PATH_SIZE;
            m_stm->GetSockName(name, size);
            return name;
        }
 
        std::string GetPeerName() {
            char name[EMX_MAX_PATH_SIZE] = {};
            size_t size = EMX_MAX_PATH_SIZE;
            m_stm->GetPeerName(name, size);
            return name;
        }
 
    protected:
 
        virtual void OnConnect() = 0;
 
        virtual void OnDisConnect() = 0;
 
        virtual void OnRecv(const char *data, int32_t size) {};
 
        virtual void OnSendDone(ErrCodeE e, const char *buffer, int32_t size) {};
    private:
        struct WriteReq {
            uv_write_t req;
            uv_buf_t buf;
            std::shared_ptr<std::string> data;
            EuvStmClientBase *obj;
        };
    private:
        bool m_isConnected;
        char *m_buffer;
        int32_t m_size;
        EuvStreamInf *m_stm;
    };
}
 
#endif //EMX_EUVSTMCLIENTBASE_HPP