/*
 * Copyright: JessMA Open Source (ldcsaa@gmail.com)
 *
 * Version	: 3.6.1
 * Author	: Bruce Liang
 * Website	: http://www.jessma.org
 * Project	: https://github.com/ldcsaa
 * Blog		: http://www.cnblogs.com/ldcsaa
 * Wiki		: http://www.oschina.net/p/hp-socket
 * QQ Group	: 75375912
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
#pragma once

#include "HPSocket4C.h"
#include "SocketInterface.h"

class C_HP_Object
{
public:
	template<class T> static inline T* ToFirst(HP_Object pObject)
	{
		return (T*)((char*)pObject + first);
	}

	template<class T> static inline T* ToSecond(HP_Object pObject)
	{
		return (T*)((char*)pObject + ((C_HP_Object*)pObject)->second);
	}

	template<class T> static inline HP_Object FromFirst(T* pFirst)
	{
		return (HP_Object)((char*)pFirst - first);
	}

	template<class T> static inline HP_Object FromSecond(T* pSecond)
	{
		C_HP_Object* pObj = (C_HP_Object*)((char*)pSecond - first);

		if(pObj->second != first)
		{
			pObj = (C_HP_Object*)((char*)pObj - sizeof(HP_Object));
			ASSERT(pObj->second == first + sizeof(HP_Object));
		}

		return (HP_Object)pObj;
	}

public:
	C_HP_Object(int offset = 0) : second(first + offset) {}
	virtual ~C_HP_Object() {}

private:
	static const size_t first = (sizeof(PVOID) + sizeof(size_t));
	size_t second;
};

template<class T, class L, int offset = 0> class C_HP_ObjectT : private C_HP_Object, public T
{
public:
	C_HP_ObjectT(L* pListener) : C_HP_Object(offset), T(pListener) {}
};

class C_HP_ServerListener : public IServerListener
{
public:
	virtual EnHandleResult OnPrepareListen(UINT_PTR soListen)
	{
		return	(m_fnOnPrepareListen)
				? m_fnOnPrepareListen(soListen)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnAccept(CONNID dwConnID, UINT_PTR soClient)
	{
		return	(m_fnOnAccept)
				? m_fnOnAccept(dwConnID, soClient)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnHandShake(CONNID dwConnID)
	{
		return	(m_fnOnHandShake)
				? m_fnOnHandShake(dwConnID)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnSend(CONNID dwConnID, const BYTE* pData, int iLength)
	{
		return	(m_fnOnSend)
				? m_fnOnSend(dwConnID, pData, iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnReceive(CONNID dwConnID, const BYTE* pData, int iLength)
	{
		ASSERT(m_fnOnReceive);

		return	(m_fnOnReceive)
				? m_fnOnReceive(dwConnID, pData, iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnReceive(CONNID dwConnID, int iLength)
	{
		ASSERT(m_fnOnPullReceive);

		return	(m_fnOnPullReceive)
				? m_fnOnPullReceive(dwConnID, iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnClose(CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode)
	{
		ASSERT(m_fnOnClose);

		return	(m_fnOnClose)
				? m_fnOnClose(dwConnID, enOperation, iErrorCode)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnShutdown()
	{
		return	(m_fnOnShutdown)
				? m_fnOnShutdown()
				: HR_IGNORE;
	}

public:
	C_HP_ServerListener()
		: m_fnOnPrepareListen	(nullptr)
		, m_fnOnAccept			(nullptr)
		, m_fnOnHandShake		(nullptr)
		, m_fnOnSend			(nullptr)
		, m_fnOnReceive			(nullptr)
		, m_fnOnPullReceive		(nullptr)
		, m_fnOnClose			(nullptr)
		, m_fnOnShutdown		(nullptr)
	{
	}

public:
	HP_FN_Server_OnPrepareListen	m_fnOnPrepareListen	;
	HP_FN_Server_OnAccept			m_fnOnAccept		;
	HP_FN_Server_OnHandShake		m_fnOnHandShake		;
	HP_FN_Server_OnSend				m_fnOnSend			;
	HP_FN_Server_OnReceive			m_fnOnReceive		;
	HP_FN_Server_OnPullReceive		m_fnOnPullReceive	;
	HP_FN_Server_OnClose			m_fnOnClose			;
	HP_FN_Server_OnShutdown			m_fnOnShutdown		;
};

class C_HP_AgentListener : public IAgentListener
{
public:
	virtual EnHandleResult OnPrepareConnect(CONNID dwConnID, UINT_PTR socket)
	{
		return	(m_fnOnPrepareConnect)
				? m_fnOnPrepareConnect(dwConnID, socket)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnConnect(CONNID dwConnID)
	{
		return	(m_fnOnConnect)
				? m_fnOnConnect(dwConnID)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnHandShake(CONNID dwConnID)
	{
		return	(m_fnOnHandShake)
				? m_fnOnHandShake(dwConnID)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnSend(CONNID dwConnID, const BYTE* pData, int iLength)
	{
		return	(m_fnOnSend)
				? m_fnOnSend(dwConnID, pData, iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnReceive(CONNID dwConnID, const BYTE* pData, int iLength)
	{
		ASSERT(m_fnOnReceive);

		return	(m_fnOnReceive)
				? m_fnOnReceive(dwConnID, pData, iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnReceive(CONNID dwConnID, int iLength)
	{
		ASSERT(m_fnOnPullReceive);

		return	(m_fnOnPullReceive)
				? m_fnOnPullReceive(dwConnID, iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnClose(CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode)
	{
		ASSERT(m_fnOnClose);

		return	(m_fnOnClose)
				? m_fnOnClose(dwConnID, enOperation, iErrorCode)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnShutdown()
	{
		return	(m_fnOnShutdown)
				? m_fnOnShutdown()
				: HR_IGNORE;
	}

public:
	C_HP_AgentListener()
		: m_fnOnPrepareConnect	(nullptr)
		, m_fnOnConnect			(nullptr)
		, m_fnOnHandShake		(nullptr)
		, m_fnOnSend			(nullptr)
		, m_fnOnReceive			(nullptr)
		, m_fnOnPullReceive		(nullptr)
		, m_fnOnClose			(nullptr)
		, m_fnOnShutdown		(nullptr)
	{
	}

public:
	HP_FN_Agent_OnPrepareConnect	m_fnOnPrepareConnect;
	HP_FN_Agent_OnConnect			m_fnOnConnect		;
	HP_FN_Agent_OnHandShake			m_fnOnHandShake		;
	HP_FN_Agent_OnSend				m_fnOnSend			;
	HP_FN_Agent_OnReceive			m_fnOnReceive		;
	HP_FN_Agent_OnPullReceive		m_fnOnPullReceive	;
	HP_FN_Agent_OnClose				m_fnOnClose			;
	HP_FN_Agent_OnShutdown			m_fnOnShutdown		;
};

class C_HP_ClientListener : public IClientListener
{
public:
	virtual EnHandleResult OnPrepareConnect(IClient* pClient, UINT_PTR socket)
	{
		return	(m_fnOnPrepareConnect)
				? m_fnOnPrepareConnect(C_HP_Object::FromSecond(pClient), socket)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnConnect(IClient* pClient)
	{
		return	(m_fnOnConnect)
				? m_fnOnConnect(C_HP_Object::FromSecond(pClient))
				: HR_IGNORE;
	}

	virtual EnHandleResult OnHandShake(IClient* pClient)
	{
		return	(m_fnOnHandShake)
				? m_fnOnHandShake(C_HP_Object::FromSecond(pClient))
				: HR_IGNORE;
	}

	virtual EnHandleResult OnSend(IClient* pClient, const BYTE* pData, int iLength)
	{
		return	(m_fnOnSend)
				? m_fnOnSend(C_HP_Object::FromSecond(pClient), pData, iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnReceive(IClient* pClient, const BYTE* pData, int iLength)
	{
		ASSERT(m_fnOnReceive);

		return	(m_fnOnReceive)
				? m_fnOnReceive(C_HP_Object::FromSecond(pClient), pData, iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnReceive(IClient* pClient, int iLength)
	{
		ASSERT(m_fnOnPullReceive);

		return	(m_fnOnPullReceive)
				? m_fnOnPullReceive(C_HP_Object::FromSecond(pClient), iLength)
				: HR_IGNORE;
	}

	virtual EnHandleResult OnClose(IClient* pClient, EnSocketOperation enOperation, int iErrorCode)
	{
		ASSERT(m_fnOnClose);

		return	(m_fnOnClose)
				? m_fnOnClose(C_HP_Object::FromSecond(pClient), enOperation, iErrorCode)
				: HR_IGNORE;
	}

public:
	C_HP_ClientListener()
		: m_fnOnPrepareConnect	(nullptr)
		, m_fnOnConnect			(nullptr)
		, m_fnOnHandShake		(nullptr)
		, m_fnOnSend			(nullptr)
		, m_fnOnReceive			(nullptr)
		, m_fnOnPullReceive		(nullptr)
		, m_fnOnClose			(nullptr)
	{
	}

public:
	HP_FN_Client_OnPrepareConnect	m_fnOnPrepareConnect;
	HP_FN_Client_OnConnect			m_fnOnConnect		;
	HP_FN_Client_OnHandShake		m_fnOnHandShake		;
	HP_FN_Client_OnSend				m_fnOnSend			;
	HP_FN_Client_OnReceive			m_fnOnReceive		;
	HP_FN_Client_OnPullReceive		m_fnOnPullReceive	;
	HP_FN_Client_OnClose			m_fnOnClose			;
};

class C_HP_ComplexHttpListener : public IComplexHttpListener
{
public:
	virtual EnHttpParseResult OnMessageBegin(CONNID dwConnID)
	{
		return	(m_fnOnMessageBegin)
				? m_fnOnMessageBegin(dwConnID)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnRequestLine(CONNID dwConnID, LPCSTR lpszMethod, LPCSTR lpszUrl)
	{
		return	(m_fnOnRequestLine)
				? m_fnOnRequestLine(dwConnID, lpszMethod, lpszUrl)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnStatusLine(CONNID dwConnID, USHORT usStatusCode, LPCSTR lpszDesc)
	{
		return	(m_fnOnStatusLine)
				? m_fnOnStatusLine(dwConnID, usStatusCode, lpszDesc)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnHeader(CONNID dwConnID, LPCSTR lpszName, LPCSTR lpszValue)
	{
		return	(m_fnOnHeader)
				? m_fnOnHeader(dwConnID, lpszName, lpszValue)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnHeadersComplete(CONNID dwConnID)
	{
		ASSERT(m_fnOnHeadersComplete);

		return	(m_fnOnHeadersComplete)
				? m_fnOnHeadersComplete(dwConnID)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnBody(CONNID dwConnID, const BYTE* pData, int iLength)
	{
		ASSERT(m_fnOnBody);

		return	(m_fnOnBody)
				? m_fnOnBody(dwConnID, pData, iLength)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnChunkHeader(CONNID dwConnID, int iLength)
	{
		return	(m_fnOnChunkHeader)
				? m_fnOnChunkHeader(dwConnID, iLength)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnChunkComplete(CONNID dwConnID)
	{
		return	(m_fnOnChunkComplete)
				? m_fnOnChunkComplete(dwConnID)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnMessageComplete(CONNID dwConnID)
	{
		ASSERT(m_fnOnMessageComplete);

		return	(m_fnOnMessageComplete)
				? m_fnOnMessageComplete(dwConnID)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnUpgrade(CONNID dwConnID, EnHttpUpgradeType enUpgradeType)
	{
		return	(m_fnOnUpgrade)
				? m_fnOnUpgrade(dwConnID, enUpgradeType)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnParseError(CONNID dwConnID, int iErrorCode, LPCSTR lpszErrorDesc)
	{
		ASSERT(m_fnOnParseError);

		return	(m_fnOnParseError)
				? m_fnOnParseError(dwConnID, iErrorCode, lpszErrorDesc)
				: HPR_OK;
	}

public:
	C_HP_ComplexHttpListener()
		: m_fnOnMessageBegin	(nullptr)
		, m_fnOnRequestLine		(nullptr)
		, m_fnOnStatusLine		(nullptr)
		, m_fnOnHeader			(nullptr)
		, m_fnOnHeadersComplete	(nullptr)
		, m_fnOnBody			(nullptr)
		, m_fnOnChunkHeader		(nullptr)
		, m_fnOnChunkComplete	(nullptr)
		, m_fnOnMessageComplete	(nullptr)
		, m_fnOnUpgrade			(nullptr)
		, m_fnOnParseError		(nullptr)
	{
	}

public:
	HP_FN_ComplexHttp_OnMessageBegin	m_fnOnMessageBegin		;
	HP_FN_ComplexHttp_OnRequestLine		m_fnOnRequestLine		;
	HP_FN_ComplexHttp_OnStatusLine		m_fnOnStatusLine		;
	HP_FN_ComplexHttp_OnHeader			m_fnOnHeader			;
	HP_FN_ComplexHttp_OnHeadersComplete	m_fnOnHeadersComplete	;
	HP_FN_ComplexHttp_OnBody			m_fnOnBody				;
	HP_FN_ComplexHttp_OnChunkHeader		m_fnOnChunkHeader		;
	HP_FN_ComplexHttp_OnChunkComplete	m_fnOnChunkComplete		;
	HP_FN_ComplexHttp_OnMessageComplete	m_fnOnMessageComplete	;
	HP_FN_ComplexHttp_OnUpgrade			m_fnOnUpgrade			;
	HP_FN_ComplexHttp_OnParseError		m_fnOnParseError		;
};

class C_HP_HttpServerListener : public IHttpServerListener
{
public:
	virtual EnHttpParseResult OnMessageBegin(CONNID dwConnID)
		{return m_lsnHttp.OnMessageBegin(dwConnID);}
	virtual EnHttpParseResult OnRequestLine(CONNID dwConnID, LPCSTR lpszMethod, LPCSTR lpszUrl)
		{return m_lsnHttp.OnRequestLine(dwConnID, lpszMethod, lpszUrl);}
	virtual EnHttpParseResult OnStatusLine(CONNID dwConnID, USHORT usStatusCode, LPCSTR lpszDesc)
		{return m_lsnHttp.OnStatusLine(dwConnID, usStatusCode, lpszDesc);}
	virtual EnHttpParseResult OnHeader(CONNID dwConnID, LPCSTR lpszName, LPCSTR lpszValue)
		{return m_lsnHttp.OnHeader(dwConnID, lpszName, lpszValue);}
	virtual EnHttpParseResult OnHeadersComplete(CONNID dwConnID)
		{return m_lsnHttp.OnHeadersComplete(dwConnID);}
	virtual EnHttpParseResult OnBody(CONNID dwConnID, const BYTE* pData, int iLength)
		{return m_lsnHttp.OnBody(dwConnID, pData, iLength);}
	virtual EnHttpParseResult OnChunkHeader(CONNID dwConnID, int iLength)
		{return m_lsnHttp.OnChunkHeader(dwConnID, iLength);}
	virtual EnHttpParseResult OnChunkComplete(CONNID dwConnID)
		{return m_lsnHttp.OnChunkComplete(dwConnID);}
	virtual EnHttpParseResult OnMessageComplete(CONNID dwConnID)
		{return m_lsnHttp.OnMessageComplete(dwConnID);}
	virtual EnHttpParseResult OnUpgrade(CONNID dwConnID, EnHttpUpgradeType enUpgradeType)
		{return m_lsnHttp.OnUpgrade(dwConnID, enUpgradeType);}
	virtual EnHttpParseResult OnParseError(CONNID dwConnID, int iErrorCode, LPCSTR lpszErrorDesc)
		{return m_lsnHttp.OnParseError(dwConnID, iErrorCode, lpszErrorDesc);}

	virtual EnHandleResult OnPrepareListen(UINT_PTR soListen)
		{return m_lsnServer.OnPrepareListen(soListen);}
	virtual EnHandleResult OnAccept(CONNID dwConnID, UINT_PTR soClient)
		{return m_lsnServer.OnAccept(dwConnID, soClient);}
	virtual EnHandleResult OnHandShake(CONNID dwConnID)
		{return m_lsnServer.OnHandShake(dwConnID);}
	virtual EnHandleResult OnSend(CONNID dwConnID, const BYTE* pData, int iLength)
		{return m_lsnServer.OnSend(dwConnID, pData, iLength);}
	virtual EnHandleResult OnReceive(CONNID dwConnID, const BYTE* pData, int iLength)
		{return m_lsnServer.OnReceive(dwConnID, pData, iLength);}
	virtual EnHandleResult OnReceive(CONNID dwConnID, int iLength)
		{return m_lsnServer.OnReceive(dwConnID, iLength);}
	virtual EnHandleResult OnClose(CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode)
		{return m_lsnServer.OnClose(dwConnID, enOperation, iErrorCode);}
	virtual EnHandleResult OnShutdown()
		{return m_lsnServer.OnShutdown();}

public:
	C_HP_ComplexHttpListener	m_lsnHttp;
	C_HP_ServerListener			m_lsnServer;
};

class C_HP_HttpAgentListener : public IHttpAgentListener
{
public:
	virtual EnHttpParseResult OnMessageBegin(CONNID dwConnID)
		{return m_lsnHttp.OnMessageBegin(dwConnID);}
	virtual EnHttpParseResult OnRequestLine(CONNID dwConnID, LPCSTR lpszMethod, LPCSTR lpszUrl)
		{return m_lsnHttp.OnRequestLine(dwConnID, lpszMethod, lpszUrl);}
	virtual EnHttpParseResult OnStatusLine(CONNID dwConnID, USHORT usStatusCode, LPCSTR lpszDesc)
		{return m_lsnHttp.OnStatusLine(dwConnID, usStatusCode, lpszDesc);}
	virtual EnHttpParseResult OnHeader(CONNID dwConnID, LPCSTR lpszName, LPCSTR lpszValue)
		{return m_lsnHttp.OnHeader(dwConnID, lpszName, lpszValue);}
	virtual EnHttpParseResult OnHeadersComplete(CONNID dwConnID)
		{return m_lsnHttp.OnHeadersComplete(dwConnID);}
	virtual EnHttpParseResult OnBody(CONNID dwConnID, const BYTE* pData, int iLength)
		{return m_lsnHttp.OnBody(dwConnID, pData, iLength);}
	virtual EnHttpParseResult OnChunkHeader(CONNID dwConnID, int iLength)
		{return m_lsnHttp.OnChunkHeader(dwConnID, iLength);}
	virtual EnHttpParseResult OnChunkComplete(CONNID dwConnID)
		{return m_lsnHttp.OnChunkComplete(dwConnID);}
	virtual EnHttpParseResult OnMessageComplete(CONNID dwConnID)
		{return m_lsnHttp.OnMessageComplete(dwConnID);}
	virtual EnHttpParseResult OnUpgrade(CONNID dwConnID, EnHttpUpgradeType enUpgradeType)
		{return m_lsnHttp.OnUpgrade(dwConnID, enUpgradeType);}
	virtual EnHttpParseResult OnParseError(CONNID dwConnID, int iErrorCode, LPCSTR lpszErrorDesc)
		{return m_lsnHttp.OnParseError(dwConnID, iErrorCode, lpszErrorDesc);}

	virtual EnHandleResult OnPrepareConnect(CONNID dwConnID, UINT_PTR socket)
		{return m_lsnAgent.OnPrepareConnect(dwConnID, socket);}
	virtual EnHandleResult OnConnect(CONNID dwConnID)
		{return m_lsnAgent.OnConnect(dwConnID);}
	virtual EnHandleResult OnHandShake(CONNID dwConnID)
		{return m_lsnAgent.OnHandShake(dwConnID);}
	virtual EnHandleResult OnSend(CONNID dwConnID, const BYTE* pData, int iLength)
		{return m_lsnAgent.OnSend(dwConnID, pData, iLength);}
	virtual EnHandleResult OnReceive(CONNID dwConnID, const BYTE* pData, int iLength)
		{return m_lsnAgent.OnReceive(dwConnID, pData, iLength);}
	virtual EnHandleResult OnReceive(CONNID dwConnID, int iLength)
		{return m_lsnAgent.OnReceive(dwConnID, iLength);}
	virtual EnHandleResult OnClose(CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode)
		{return m_lsnAgent.OnClose(dwConnID, enOperation, iErrorCode);}
	virtual EnHandleResult OnShutdown()
		{return m_lsnAgent.OnShutdown();}

public:
	C_HP_ComplexHttpListener	m_lsnHttp;
	C_HP_AgentListener			m_lsnAgent;
};

class C_HP_SingleHttpListener : public IHttpListener
{
public:
	virtual EnHttpParseResult OnMessageBegin(IHttp* pHttp)
	{
		return	(m_fnOnMessageBegin)
				? m_fnOnMessageBegin(C_HP_Object::FromFirst(pHttp))
				: HPR_OK;
	}

	virtual EnHttpParseResult OnRequestLine(IHttp* pHttp, LPCSTR lpszMethod, LPCSTR lpszUrl)
	{
		return	(m_fnOnRequestLine)
				? m_fnOnRequestLine(C_HP_Object::FromFirst(pHttp), lpszMethod, lpszUrl)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnStatusLine(IHttp* pHttp, USHORT usStatusCode, LPCSTR lpszDesc)
	{
		return	(m_fnOnStatusLine)
				? m_fnOnStatusLine(C_HP_Object::FromFirst(pHttp), usStatusCode, lpszDesc)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnHeader(IHttp* pHttp, LPCSTR lpszName, LPCSTR lpszValue)
	{
		return	(m_fnOnHeader)
				? m_fnOnHeader(C_HP_Object::FromFirst(pHttp), lpszName, lpszValue)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnHeadersComplete(IHttp* pHttp)
	{
		ASSERT(m_fnOnHeadersComplete);

		return	(m_fnOnHeadersComplete)
				? m_fnOnHeadersComplete(C_HP_Object::FromFirst(pHttp))
				: HPR_OK;
	}

	virtual EnHttpParseResult OnBody(IHttp* pHttp, const BYTE* pData, int iLength)
	{
		ASSERT(m_fnOnBody);

		return	(m_fnOnBody)
				? m_fnOnBody(C_HP_Object::FromFirst(pHttp), pData, iLength)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnChunkHeader(IHttp* pHttp, int iLength)
	{
		return	(m_fnOnChunkHeader)
				? m_fnOnChunkHeader(C_HP_Object::FromFirst(pHttp), iLength)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnChunkComplete(IHttp* pHttp)
	{
		return	(m_fnOnChunkComplete)
				? m_fnOnChunkComplete(C_HP_Object::FromFirst(pHttp))
				: HPR_OK;
	}

	virtual EnHttpParseResult OnMessageComplete(IHttp* pHttp)
	{
		ASSERT(m_fnOnMessageComplete);

		return	(m_fnOnMessageComplete)
				? m_fnOnMessageComplete(C_HP_Object::FromFirst(pHttp))
				: HPR_OK;
	}

	virtual EnHttpParseResult OnUpgrade(IHttp* pHttp, EnHttpUpgradeType enUpgradeType)
	{
		return	(m_fnOnUpgrade)
				? m_fnOnUpgrade(C_HP_Object::FromFirst(pHttp), enUpgradeType)
				: HPR_OK;
	}

	virtual EnHttpParseResult OnParseError(IHttp* pHttp, int iErrorCode, LPCSTR lpszErrorDesc)
	{
		ASSERT(m_fnOnParseError);

		return	(m_fnOnParseError)
				? m_fnOnParseError(C_HP_Object::FromFirst(pHttp), iErrorCode, lpszErrorDesc)
				: HPR_OK;
	}

public:
	C_HP_SingleHttpListener()
		: m_fnOnMessageBegin	(nullptr)
		, m_fnOnRequestLine		(nullptr)
		, m_fnOnStatusLine		(nullptr)
		, m_fnOnHeader			(nullptr)
		, m_fnOnHeadersComplete	(nullptr)
		, m_fnOnBody			(nullptr)
		, m_fnOnChunkHeader		(nullptr)
		, m_fnOnChunkComplete	(nullptr)
		, m_fnOnMessageComplete	(nullptr)
		, m_fnOnUpgrade			(nullptr)
		, m_fnOnParseError		(nullptr)
	{
	}

public:
	HP_FN_SingleHttp_OnMessageBegin		m_fnOnMessageBegin		;
	HP_FN_SingleHttp_OnRequestLine		m_fnOnRequestLine		;
	HP_FN_SingleHttp_OnStatusLine		m_fnOnStatusLine		;
	HP_FN_SingleHttp_OnHeader			m_fnOnHeader			;
	HP_FN_SingleHttp_OnHeadersComplete	m_fnOnHeadersComplete	;
	HP_FN_SingleHttp_OnBody				m_fnOnBody				;
	HP_FN_SingleHttp_OnChunkHeader		m_fnOnChunkHeader		;
	HP_FN_SingleHttp_OnChunkComplete	m_fnOnChunkComplete		;
	HP_FN_SingleHttp_OnMessageComplete	m_fnOnMessageComplete	;
	HP_FN_SingleHttp_OnUpgrade			m_fnOnUpgrade			;
	HP_FN_SingleHttp_OnParseError		m_fnOnParseError		;
};

class C_HP_HttpClientListener : public IHttpClientListener
{
public:
	virtual EnHttpParseResult OnMessageBegin(IHttp* pHttp)
		{return m_lsnHttp.OnMessageBegin(pHttp);}
	virtual EnHttpParseResult OnRequestLine(IHttp* pHttp, LPCSTR lpszMethod, LPCSTR lpszUrl)
		{return m_lsnHttp.OnRequestLine(pHttp, lpszMethod, lpszUrl);}
	virtual EnHttpParseResult OnStatusLine(IHttp* pHttp, USHORT usStatusCode, LPCSTR lpszDesc)
		{return m_lsnHttp.OnStatusLine(pHttp, usStatusCode, lpszDesc);}
	virtual EnHttpParseResult OnHeader(IHttp* pHttp, LPCSTR lpszName, LPCSTR lpszValue)
		{return m_lsnHttp.OnHeader(pHttp, lpszName, lpszValue);}
	virtual EnHttpParseResult OnHeadersComplete(IHttp* pHttp)
		{return m_lsnHttp.OnHeadersComplete(pHttp);}
	virtual EnHttpParseResult OnBody(IHttp* pHttp, const BYTE* pData, int iLength)
		{return m_lsnHttp.OnBody(pHttp, pData, iLength);}
	virtual EnHttpParseResult OnChunkHeader(IHttp* pHttp, int iLength)
		{return m_lsnHttp.OnChunkHeader(pHttp, iLength);}
	virtual EnHttpParseResult OnChunkComplete(IHttp* pHttp)
		{return m_lsnHttp.OnChunkComplete(pHttp);}
	virtual EnHttpParseResult OnMessageComplete(IHttp* pHttp)
		{return m_lsnHttp.OnMessageComplete(pHttp);}
	virtual EnHttpParseResult OnUpgrade(IHttp* pHttp, EnHttpUpgradeType enUpgradeType)
		{return m_lsnHttp.OnUpgrade(pHttp, enUpgradeType);}
	virtual EnHttpParseResult OnParseError(IHttp* pHttp, int iErrorCode, LPCSTR lpszErrorDesc)
		{return m_lsnHttp.OnParseError(pHttp, iErrorCode, lpszErrorDesc);}

	virtual EnHandleResult OnPrepareConnect(IClient* pClient, UINT_PTR socket)
		{return m_lsnClient.OnPrepareConnect(pClient, socket);}
	virtual EnHandleResult OnConnect(IClient* pClient)
		{return m_lsnClient.OnConnect(pClient);}
	virtual EnHandleResult OnHandShake(IClient* pClient)
		{return m_lsnClient.OnHandShake(pClient);}
	virtual EnHandleResult OnSend(IClient* pClient, const BYTE* pData, int iLength)
		{return m_lsnClient.OnSend(pClient, pData, iLength);}
	virtual EnHandleResult OnReceive(IClient* pClient, const BYTE* pData, int iLength)
		{return m_lsnClient.OnReceive(pClient, pData, iLength);}
	virtual EnHandleResult OnReceive(IClient* pClient, int iLength)
		{return m_lsnClient.OnReceive(pClient, iLength);}
	virtual EnHandleResult OnClose(IClient* pClient, EnSocketOperation enOperation, int iErrorCode)
		{return m_lsnClient.OnClose(pClient, enOperation, iErrorCode);}

public:
	C_HP_SingleHttpListener	m_lsnHttp;
	C_HP_ClientListener		m_lsnClient;
};