forked from YeeYoungHan/cpphttpstack
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathHttpNoCacheProxy.cpp
More file actions
151 lines (129 loc) · 4.55 KB
/
HttpNoCacheProxy.cpp
File metadata and controls
151 lines (129 loc) · 4.55 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
/*
* Copyright (C) 2012 Yee Young Han <[email protected]> (http://blog.naver.com/websearch)
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
#include "HttpNoCacheProxy.h"
#include "HttpStatusCode.h"
#include "HttpClient.h"
#include "Log.h"
#include "MemoryDebug.h"
extern CHttpStack gclsStack;
CHttpNoCacheProxy::CHttpNoCacheProxy() : m_iServerPort(80), m_bStop(false)
{
}
CHttpNoCacheProxy::~CHttpNoCacheProxy()
{
}
/**
* @ingroup HttpNoCacheProxy
* @brief HTTP 요청 수신 이벤트 callback
* @param pclsRequest HTTP 요청 메시지
* @param pclsResponse HTTP 응답 메시지 - 응용에서 저장한다.
* @returns 응용에서 HTTP 응답 메시지를 정상적으로 생성하면 true 를 리턴하고 그렇지 않으면 false 를 리턴한다.
*/
bool CHttpNoCacheProxy::RecvHttpRequest( CHttpMessage * pclsRequest, CHttpMessage * pclsResponse )
{
CLog::Print( LOG_DEBUG, "req uri[%s]", pclsRequest->m_strReqUri.c_str() );
CHttpClient clsClient;
const char * pszMethod = pclsRequest->m_strHttpMethod.c_str();
const char * pszUrl = pclsRequest->m_strReqUri.c_str();
const char * pszPath;
std::string strUrl, strContentType, strContent;
pclsResponse->AddHeader( "Cache-Control", "no-cache, no-store, must-revalidate" );
if( !strncmp( pszUrl, "http://", 7 ) )
{
pszPath = strstr( pszUrl + 7, "/" );
}
else
{
pszPath = pszUrl;
}
strUrl = "http://";
strUrl.append( m_strServerIp );
if( m_iServerPort != 80 )
{
char szPort[12];
snprintf( szPort, sizeof(szPort), ":%d", m_iServerPort );
strUrl.append( szPort );
}
strUrl.append( pszPath );
if( !strcmp( pszMethod, "GET" ) )
{
if( clsClient.DoGet( strUrl.c_str(), strContentType, strContent ) )
{
pclsResponse->m_iStatusCode = HTTP_OK;
pclsResponse->m_strContentType = strContentType;
pclsResponse->m_strBody = strContent;
}
else
{
pclsResponse->m_iStatusCode = HTTP_INTERNAL_SERVER_ERROR;
}
}
else if( !strcmp( pszMethod, "POST" ) )
{
HTTP_HEADER_LIST clsHeaderList;
if( clsClient.DoPost( strUrl.c_str(), &clsHeaderList, pclsRequest->m_strContentType.c_str(), pclsRequest->m_strBody.c_str(), pclsRequest->m_strBody.length(), strContentType, strContent ) )
{
pclsResponse->m_iStatusCode = HTTP_OK;
pclsResponse->m_strContentType = strContentType;
pclsResponse->m_strBody = strContent;
}
else
{
pclsResponse->m_iStatusCode = HTTP_INTERNAL_SERVER_ERROR;
}
}
else
{
pclsResponse->m_iStatusCode = HTTP_NOT_IMPLEMENTED;
}
return true;
}
/**
* @ingroup HttpNoCacheProxy
* @brief WebSocket 클라이언트 TCP 연결 시작 이벤트 callback
* @param pszClientIp WebSocket 클라이언트 IP 주소
* @param iClientPort WebSocket 클라이언트 포트 번호
*/
void CHttpNoCacheProxy::WebSocketConnected( const char * pszClientIp, int iClientPort )
{
printf( "WebSocket[%s:%d] connected\n", pszClientIp, iClientPort );
}
/**
* @ingroup HttpNoCacheProxy
* @brief WebSocket 클라이언트 TCP 연결 종료 이벤트 callback
* @param pszClientIp WebSocket 클라이언트 IP 주소
* @param iClientPort WebSocket 클라이언트 포트 번호
*/
void CHttpNoCacheProxy::WebSocketClosed( const char * pszClientIp, int iClientPort )
{
printf( "WebSocket[%s:%d] closed\n", pszClientIp, iClientPort );
}
/**
* @ingroup HttpNoCacheProxy
* @brief WebSocket 클라이언트 데이터 수신 이벤트 callback
* @param pszClientIp WebSocket 클라이언트 IP 주소
* @param iClientPort WebSocket 클라이언트 포트 번호
* @param strData WebSocket 클라이언트가 전송한 데이터
* @returns WebSocket 클라이언트 연결을 유지하려면 true 를 리턴하고 그렇지 않으면 false 를 리턴한다.
*/
bool CHttpNoCacheProxy::WebSocketData( const char * pszClientIp, int iClientPort, std::string & strData )
{
printf( "WebSocket[%s:%d] recv[%s]\n", pszClientIp, iClientPort, strData.c_str() );
gclsStack.SendWebSocketPacket( pszClientIp, iClientPort, strData.c_str(), strData.length() );
return true;
}