20210818

Windows/Demo/Global/helper.h

@@ -0,0 +1,283 @@
+#pragma once
+
+#include "../../Include/HPSocket/SocketInterface.h"
+
+#define USER_INFO_MSG			(WM_USER + 100)
+#define MAX_LOG_RECORD_LENGTH	1000
+
+#define EVT_ON_SEND				_T("OnSend")
+#define EVT_ON_RECEIVE			_T("OnReceive")
+#define EVT_ON_CLOSE			_T("OnClose")
+#define EVT_ON_ERROR			_T("OnError")
+#define EVT_ON_PREPARE_CONNECT	_T("OnPrepareConnect")
+#define EVT_ON_PREPARE_LISTEN	_T("OnPrepareListen")
+#define EVT_ON_ACCEPT			_T("OnAccept")
+#define EVT_ON_CONNECT			_T("OnConnect")
+#define EVT_ON_HAND_SHAKE		_T("OnHandShake")
+#define EVT_ON_SHUTDOWN			_T("OnShutdown")
+#define EVT_ON_END_TEST			_T("END TEST")
+
+#define EVT_ON_MESSAGE_BEGIN	_T("OnMessageBegin")
+#define EVT_ON_REQUEST_LINE		_T("OnRequestLine")
+#define EVT_ON_STATUS_LINE		_T("OnStatusLine")
+#define EVT_ON_HEADER			_T("OnHeader")
+#define EVT_ON_HEADERS_COMPLETE	_T("OnHeadersComplete")
+#define EVT_ON_BODY				_T("OnBody")
+#define EVT_ON_CHUNK_HEADER		_T("OnChunkHeader")
+#define EVT_ON_CHUNK_COMPLETE	_T("OnChunkComplete")
+#define EVT_ON_MESSAGE_COMPLETE	_T("OnMessageComplete")
+#define EVT_ON_UPGRADE			_T("OnUpgrade")
+#define EVT_ON_PARSE_ERROR		_T("OnParseError")
+
+#define EVT_ON_WS_MSG_HEADER	_T("OnWSMessageHeader")
+#define EVT_ON_WS_MSG_BODY		_T("OnWSMessageBody")
+#define EVT_ON_WS_MSG_COMPLETE	_T("OnWSMessageComplete")
+
+#define EVT_ON_UNCOMPRESS_BODY		_T("Uncompress Body")
+#define EVT_ON_UNCOMPRESS_BODY_FAIL	_T("Uncompress Body Fail")
+
+#define IPV4_LOOPBACK_ADDRESS	_T("127.0.0.1")
+#define IPV6_LOOPBACK_ADDRESS	_T("::1")
+#define IPV4_ANY_ADDRESS		_T("0.0.0.0")
+#define IPV6_ANY_ADDRESS		_T("::")
+#define BROAD_CAST_ADDRESS		_T("255.255.255.255")
+
+enum EnAppState
+{
+	ST_STARTING, ST_STARTED, ST_CONNECTING, ST_CONNECTED, ST_STOPPING, ST_STOPPED
+};
+
+struct info_msg
+{
+	LPCTSTR name;
+	CONNID connID;
+	LPCTSTR evt;
+	int contentLength;
+	LPCTSTR content;
+
+	static info_msg* Construct(CONNID dwConnID, LPCTSTR lpszEvent, int iContentLength = 0, LPCTSTR lpszContent = nullptr, LPCTSTR lpszName = nullptr);
+	static void Destruct(info_msg* pMsg);
+
+private:
+	info_msg(CONNID dwConnID, LPCTSTR lpszEvent, int iContentLength = 0, LPCTSTR lpszContent = nullptr, LPCTSTR lpszName = nullptr);
+	~info_msg();
+};
+
+struct TPkgHeader 
+{
+	DWORD seq;
+	int body_len;
+};
+
+struct TPkgBody 
+{
+	char name[30];
+	short age;
+	char desc[1];
+};
+
+struct TPkgInfo
+{
+	bool is_header;
+	int length;
+
+	TPkgInfo(bool header = true, int len = sizeof(TPkgHeader)) : is_header(header), length(len) {}
+	void Reset() {is_header = true, length = sizeof(TPkgHeader);}
+	~TPkgInfo() {}
+};
+
+ADDRESS_FAMILY GuessAddrFamily(LPCTSTR lpszAddress);
+LPCTSTR GetLoopbackAddress(LPCTSTR lpszLikeAddress);
+LPCTSTR GetAnyAddress(LPCTSTR lpszLikeAddress);
+
+
+CBufferPtr* GeneratePkgBuffer(DWORD seq, LPCTSTR lpszName, short age, LPCTSTR lpszDesc);
+CBufferPtr* GeneratePkgBuffer(const TPkgHeader& header, const TPkgBody& body);
+
+void SetMainWnd(CWnd* pWnd);
+void SetInfoList(CListBox* pInfoList);
+
+void LogServerStart(LPCTSTR lpszAddress, USHORT port, LPCTSTR lpszName = nullptr);
+void LogServerStartFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void LogServerStop(LPCTSTR lpszName = nullptr);
+void LogServerStopFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void LogClientStart(LPCTSTR lpszAddress, USHORT port, LPCTSTR lpszName = nullptr);
+void LogStarting(LPCTSTR lpszAddress, USHORT port, LPCTSTR lpszName = nullptr);
+void LogClientStarting(LPCTSTR lpszAddress, USHORT port, LPCTSTR lpszName = nullptr);
+void LogClientStartFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void LogStartFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void LogClientStopping(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogStopping(LPCTSTR lpszName = nullptr);
+void LogClientStopFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void LogSend(LPCTSTR lpszContent, LPCTSTR lpszName = nullptr);
+void LogSend(CONNID dwConnID, LPCTSTR lpszContent, LPCTSTR lpszName = nullptr);
+void LogClientSendFail(int iSequence, int iSocketIndex, DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void LogSendFail(DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void LogSendFail(CONNID dwConnID, DWORD code, LPCTSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void LogDisconnect(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogDisconnectFail(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogRelease(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogReleaseFail(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogDetect(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogDetectFail(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogOnConnect(CONNID dwConnID, const CString& strAddress, USHORT usPort, LPCTSTR lpszName = nullptr);
+void LogOnConnect2(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogOnConnect3(CONNID dwConnID, const CString& strAddress, USHORT usPort, LPCTSTR lpszName = nullptr);
+void LogOnHandShake2(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void LogOnClose(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+
+void PostOnSend(CONNID dwConnID, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnSendTo(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnReceive(CONNID dwConnID, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnReceiveFrom(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnReceiveCast(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnClose(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostOnError(CONNID dwConnID, int enOperation, int iErrorCode, LPCTSTR lpszName = nullptr);
+void PostOnError2(CONNID dwConnID, int enOperation, int iErrorCode, LPCTSTR lpszAddress, USHORT usPort, const BYTE* pBuffer, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnAccept(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, BOOL bPass, LPCTSTR lpszName = nullptr);
+void PostOnAccept2(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostOnHandShake(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostOnPrepareListen(LPCTSTR lpszAddress, USHORT usPort, LPCTSTR lpszName = nullptr);
+void PostOnPrepareConnect(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostOnConnect(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, LPCTSTR lpszName = nullptr);
+void PostOnConnect2(CONNID dwConnID, LPCTSTR lpszAddress, USHORT usPort, LPCTSTR lpszName = nullptr);
+void PostOnConnect3(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostOnShutdown(LPCTSTR lpszName = nullptr);
+void PostServerStatics(const LONGLONG& llTotalSent, const LONGLONG& llTotalReceived, LPCTSTR lpszName = nullptr);
+void PostTimeConsuming(DWORD dwTickCount, LPCTSTR lpszName = nullptr);
+
+#ifdef _NEED_HTTP
+void PostOnMessageBegin(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostOnRequestLine(CONNID dwConnID, LPCSTR lpszMethod, USHORT usUrlFieldSet, LPCSTR lpszUrl, LPCTSTR lpszName = nullptr);
+void PostOnStatusLine(CONNID dwConnID, USHORT usStatusCode, LPCSTR lpszDesc, LPCTSTR lpszName = nullptr);
+void PostOnHeader(CONNID dwConnID, LPCSTR lpszHeaderName, LPCSTR lpszHeaderValue, LPCTSTR lpszName = nullptr);
+void PostOnHeadersComplete(CONNID dwConnID, LPCSTR lpszSummary, LPCTSTR lpszName = nullptr);
+void PostOnBody(CONNID dwConnID, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnChunkHeader(CONNID dwConnID, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnChunkComplete(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostOnMessageComplete(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostOnUpgrade(CONNID dwConnID, EnHttpUpgradeType enUpgradeType, LPCTSTR lpszName = nullptr);
+void PostOnParseError(CONNID dwConnID, int iErrorCode, LPCSTR lpszErrorDesc, LPCTSTR lpszName = nullptr);
+void PostOnWSMessageHeader(CONNID dwConnID, BOOL bFinal, BYTE iReserved, BYTE iOperationCode, const BYTE lpszMask[4], ULONGLONG ullBodyLen, LPCTSTR lpszName = nullptr);
+void PostOnWSMessageBody(CONNID dwConnID, const BYTE* pData, int iLength, LPCTSTR lpszName = nullptr);
+void PostOnWSMessageComplete(CONNID dwConnID, LPCTSTR lpszName = nullptr);
+void PostUncompressBody(CONNID dwConnID, int iLength, LPCTSTR lpszName = nullptr);
+void PostUncompressBodyFail(CONNID dwConnID, int iResult, LPCTSTR lpszName = nullptr);
+#endif
+
+void PostInfoMsg(info_msg* msg);
+void LogInfoMsg(info_msg* pInfoMsg);
+void LogMsg(const CString& msg);
+
+extern LPCTSTR g_lpszDefaultCookieFile;
+
+LPCTSTR GetDefaultCookieFile();
+BOOL SetCurrentPathToModulePath(HMODULE hModule = nullptr);
+
+#ifdef _NEED_SSL
+
+extern int g_c_iVerifyMode;
+extern BOOL g_c_bNeedClientVerification;
+extern LPCSTR g_c_lpszPemCert;
+extern LPCSTR g_c_lpszPemKey;
+extern LPCSTR g_c_lpszCAPemCert;
+extern LPCSTR g_s_lpszPemCert;
+extern LPCSTR g_s_lpszPemKey;
+extern LPCSTR g_s_lpszCAPemCert;
+extern LPCTSTR g_c_lpszCAPemCertFileOrPath;
+extern LPCTSTR g_c_lpszPemCertFile;
+extern LPCTSTR g_c_lpszPemKeyFile;
+extern LPCTSTR g_c_lpszKeyPasswod;
+
+extern int g_s_iVerifyMode;
+extern BOOL g_s_bNeedClientVerification;
+extern LPCTSTR g_s_lpszCAPemCertFileOrPath;
+extern LPCTSTR g_s_lpszPemCertFile;
+extern LPCTSTR g_s_lpszPemKeyFile;
+extern LPCTSTR g_s_lpszKeyPasswod;
+
+extern int g_c_iVerifyMode2;
+extern BOOL g_c_bNeedClientVerification2;
+extern LPCTSTR g_c_lpszCAPemCertFileOrPath2;
+extern LPCTSTR g_c_lpszPemCertFile2;
+extern LPCTSTR g_c_lpszPemKeyFile2;
+extern LPCTSTR g_c_lpszKeyPasswod2;
+
+extern int g_s_iVerifyMode2;
+extern BOOL g_s_bNeedClientVerification2;
+extern LPCTSTR g_s_lpszCAPemCertFileOrPath2;
+extern LPCTSTR g_s_lpszPemCertFile2;
+extern LPCTSTR g_s_lpszPemKeyFile2;
+extern LPCTSTR g_s_lpszKeyPasswod2;
+
+#endif
+
+#ifdef _NEED_HTTP
+
+#include "../../Src/Common/crypto/crypto.h"
+
+#define HTTP_NAME					_T("http")
+#define HTTPS_NAME					_T("https")
+
+#define CRLF						"\r\n"
+#define NV_SEPARATOR_CHAR			'='
+#define HEADER_SEPARATOR			": "
+#define COOKIE_TOKENIZE				"; "
+#define STR_HTTP_1_0				"HTTP/1.0"
+#define STR_HTTP_1_1				"HTTP/1.1"
+#define HOST_HEADER					"Host"
+#define COOKIE_HEADER				"Cookie"
+#define SET_COOKIE_HEADER			"Set-Cookie"
+#define CONTENT_TYPE_HEADER			"Content-Type"
+#define CONTENT_LENGTH_HEADER		"Content-Length"
+#define TRANSFER_ENCODING_HEADER	"Transfer-Encoding"
+#define UPGRADE_HEADER				"Upgrade"
+#define WEB_SOCKET_HEADER_VALUE		"WebSocket"
+
+#define HTTP_METHOD_POST			"POST"
+#define HTTP_METHOD_PUT				"PUT"
+#define HTTP_METHOD_PATCH			"PATCH"
+#define HTTP_METHOD_GET				"GET"
+#define HTTP_METHOD_DELETE			"DELETE"
+#define HTTP_METHOD_HEAD			"HEAD"
+#define HTTP_METHOD_TRACE			"TRACE"
+#define HTTP_METHOD_OPTIONS			"OPTIONS"
+#define HTTP_METHOD_CONNECT			"CONNECT"
+
+#define HTTP_WEB_SOCKET_SEC_SALT	"258EAFA5-E914-47DA-95CA-C5AB0DC85B11"
+
+struct THttpHeader
+{
+	CStringA strName;
+	CStringA strValue;
+
+	THttpHeader(LPCTSTR lpszName, LPCTSTR lpszValue) : strName(lpszName), strValue(lpszValue) {}
+
+	struct hash
+	{
+		size_t operator() (const CStringA& str) const
+		{
+			size_t s = hash_value((LPCSTR)str);
+			return s;
+		}
+	};
+
+	struct equal_to
+	{
+		bool operator () (const CStringA& strA, const CStringA& strB) const
+		{
+			return strA == strB;
+		}
+	};
+
+};
+
+typedef unordered_multimap<CStringA, CStringA,
+		THttpHeader::hash, THttpHeader::equal_to>	THttpHeaderMap;
+typedef THttpHeaderMap::const_iterator				THttpHeaderMapCI;
+typedef THttpHeaderMap::iterator					THttpHeaderMapI;
+
+CStringA& HttpVersionToString(EnHttpVersion enVersion, CStringA& strResult);
+CStringA& MakeSecWebSocketAccept(LPCSTR lpszKey, CStringA& strAccept);
+
+#endif

Windows/Demo/HttpProxy/HttpProxy.sln

@@ -0,0 +1,36 @@
+
+Microsoft Visual Studio Solution File, Format Version 11.00
+# Visual Studio 2010
+Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "Server-1", "Server-1\Server-1.vcxproj", "{5A2EE763-53B1-462E-AE9F-7CC58436C878}"
+EndProject
+Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "Server-2", "Server-2\Server-2.vcxproj", "{5A2EE763-53B1-462E-AE9F-7CC58436C879}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Win32 = Debug|Win32
+		Debug|x64 = Debug|x64
+		Release|Win32 = Release|Win32
+		Release|x64 = Release|x64
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{5A2EE763-53B1-462E-AE9F-7CC58436C878}.Debug|Win32.ActiveCfg = Debug|Win32
+		{5A2EE763-53B1-462E-AE9F-7CC58436C878}.Debug|Win32.Build.0 = Debug|Win32
+		{5A2EE763-53B1-462E-AE9F-7CC58436C878}.Debug|x64.ActiveCfg = Debug|x64
+		{5A2EE763-53B1-462E-AE9F-7CC58436C878}.Debug|x64.Build.0 = Debug|x64
+		{5A2EE763-53B1-462E-AE9F-7CC58436C878}.Release|Win32.ActiveCfg = Release|Win32
+		{5A2EE763-53B1-462E-AE9F-7CC58436C878}.Release|Win32.Build.0 = Release|Win32
+		{5A2EE763-53B1-462E-AE9F-7CC58436C878}.Release|x64.ActiveCfg = Release|x64
+		{5A2EE763-53B1-462E-AE9F-7CC58436C878}.Release|x64.Build.0 = Release|x64
+		{5A2EE763-53B1-462E-AE9F-7CC58436C879}.Debug|Win32.ActiveCfg = Debug|Win32
+		{5A2EE763-53B1-462E-AE9F-7CC58436C879}.Debug|Win32.Build.0 = Debug|Win32
+		{5A2EE763-53B1-462E-AE9F-7CC58436C879}.Debug|x64.ActiveCfg = Debug|x64
+		{5A2EE763-53B1-462E-AE9F-7CC58436C879}.Debug|x64.Build.0 = Debug|x64
+		{5A2EE763-53B1-462E-AE9F-7CC58436C879}.Release|Win32.ActiveCfg = Release|Win32
+		{5A2EE763-53B1-462E-AE9F-7CC58436C879}.Release|Win32.Build.0 = Release|Win32
+		{5A2EE763-53B1-462E-AE9F-7CC58436C879}.Release|x64.ActiveCfg = Release|x64
+		{5A2EE763-53B1-462E-AE9F-7CC58436C879}.Release|x64.Build.0 = Release|x64
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+EndGlobal