MunProxySessionToCustomAuthServer.hpp

Go to the documentation of this file.

#ifndef __MUN_PROXY_SESSION_TO_AUTH_SERVER_HPP__
#define __MUN_PROXY_SESSION_TO_AUTH_SERVER_HPP__

#include <string>
#include <vector>
#include <curl/multi.h>
#ifdef _WIN32
#include <windows.h>
#include <process.h>
#else
#include <pthread.h>
#endif
#include <mrs.hpp>
#include "config/MunProxyConfigure.hpp"

class MunProxySessionToCustomAuthServer
{
private:
    enum  ERRORCODE
    {
        ERRORCODE_NONE = 0,         
        ERRORCODE_WAIT = 1,         
        ERRORCODE_SUCCEEDED = 2,    
        ERRORCODE_FAILURE = -1,     
    };
    
    class CURLInfo
    {
    public:
        MrsConnection   m_pMunClient;

        uint64          m_StartTime;

        ERRORCODE       m_ErrorCode;

        bool            m_IsIgnoreError;

#if _WIN32
        HANDLE          m_Thread;
#else
        pthread_t       m_Thread;
#endif

        uint32          m_SendCount;

        uint32          m_ReceivedCount;

        std::string     m_Url;

        std::vector<std::string>    m_SendData;

        std::vector<std::string>    m_ReceivedData;

        CURLInfo()
        {
            m_pMunClient = NULL;
            m_StartTime = 0;
            m_ErrorCode = ERRORCODE_NONE;
            m_IsIgnoreError = false;
#if _WIN32
            m_Thread = NULL;
#else
            m_Thread = 0;
#endif
            m_Url = "";
            m_SendCount = 0;
            m_ReceivedCount = 0;
        }
    };

private:
    static  bool                    s_IsUseCustomAuthServer;

    static  std::string             s_CustomAuthServerAddress;

    static  uint64                  s_CustomAuthServerWaitLimit;

    static std::list<CURLInfo*>     s_CurlList;

protected:
#ifdef _WIN32
    static unsigned __stdcall   OpThread(void * pData);
#else
    static void*    OpThread(void * pData);
#endif

    static  size_t  OpSendPayload(void *ptr, size_t size, size_t num, void * pData);

    static  size_t  OpReceivedPayload(void *ptr, size_t size, size_t num, void * pData);

public:
    static  bool    Initialize(MunProxyConfigure& configure);

    static  bool    OpSend(MrsConnection pMunClient, bool isUseDefaultUrl, std::string customAuthServerAddr, bool isIgnoreError, std::string getParam, std::string body);

    static  void    Update();

    static  void    Finalize();

    static  void    Send_Relay_Anything(MrsConnection pMunClient, uint16 payload_type, MunBuffer& buffer);

private:
    static  void    OnNewTcpConnectionCallback(MrsServer pMunProxy, void* server_data, MrsConnection pMunClient);

    static  void    OnNewUdpConnectionCallback(MrsServer pMunProxy, void* server_data, MrsConnection pMunClient);

    static  void    OnDisconnectTcpCallback(MrsConnection pMunClient, void* connection_data);

    static  void    OnDisconnectUdpCallback(MrsConnection pMunClient, void* connection_data);

    static  void    OnErrorTcpCallback(MrsConnection pMunClient, void* connection_data, MrsConnectionError status);

    static  void    OnErrorUdpCallback(MrsConnection pMunClient, void* connection_data, MrsConnectionError status);

    static  void    OnReadRecordCallback(MrsConnection pMunClient, void* connection_data, uint32 seqnum, uint16 options, uint16 payload_type, const void* payload, uint32 payload_len);
};

#endif  /* __MUN_PROXY_SESSION_TO_AUTH_SERVER_HPP__ */