/*******************************************************************************
|
* File Name : HTTP.c
|
* Description :
|
* Created on : 2020Äê7ÔÂ1ÈÕ
|
* Author : ¶Å¼ü
|
*******************************************************************************/
|
|
/*******************************************************************************
|
* Include Files *
|
*******************************************************************************/
|
#include "HTTPClient.h"
|
|
#include "string.h"
|
#include "HIDO_Util.h"
|
#include "HIDO_Debug.h"
|
#include "HIDO_ArraryQueue.h"
|
#include "HIDO_Timer.h"
|
#include "Socket.h"
|
#include "Internet.h"
|
|
/*******************************************************************************
|
* Macro *
|
*******************************************************************************/
|
#define HTTP_RECV_BUFF_SIZE (1024 * 8)
|
|
/*******************************************************************************
|
* Type Definition *
|
*******************************************************************************/
|
typedef enum
|
{
|
HTTP_CLIENT_STATE_IDLE,
|
HTTP_CLIENT_STATE_CONNECTING,
|
HTTP_CLIENT_STATE_CONNECTED,
|
} E_HTTPClientState;
|
|
typedef enum
|
{
|
HTTP_RECV_STATE_HEAD,
|
HTTP_RECV_STATE_BODY,
|
} E_HTTPRecvState;
|
|
typedef enum
|
{
|
HTTP_METHOD_GET,
|
HTTP_METHOD_POST,
|
HTTP_METHOD_GET_FILE,
|
HTTP_METHOD_POST_FILE,
|
} E_HTTPMethod;
|
|
/*******************************************************************************
|
* Local Variable *
|
*******************************************************************************/
|
static E_HTTPClientState l_eHTTPClientState = HTTP_CLIENT_STATE_IDLE;
|
static E_HTTPRecvState l_eHTTPRecvState = HTTP_RECV_STATE_HEAD;
|
static E_HTTPMethod l_eHTTPMethod;
|
|
static HIDO_INT32 l_i32HTTPClientSockID = 0;
|
static HIDO_UINT32 l_u32HTTPClientTimerID = 0;
|
|
static HIDO_CHAR l_acHTTPUrl[128];
|
|
static FN_HTTPResponseCallback l_fnHTTPResponseCallback;
|
static FN_HTTPGetFileCallback l_fnHTTPGetFileCallback;
|
static FN_HTTPPostDataCallback l_fnHTTPostDataCallback;
|
static HIDO_VOID *l_pHTTPArg = HIDO_NULL;
|
|
static HIDO_UINT32 l_u32HTTPTryCnt = 0;
|
static HIDO_UINT32 l_u32HTTPPort = 80;
|
static HIDO_CHAR l_acHTTPPath[64];
|
static HIDO_CHAR l_acHTTPHost[64];
|
static HIDO_UINT32 l_u32HTTPPostLen = 0;
|
|
static HIDO_CHAR l_acHTTPSendBuff[1024];
|
static HIDO_UINT32 l_u32HTTPSendBuffLen;
|
|
static HIDO_CHAR l_acHTTPRecvBuff[HTTP_RECV_BUFF_SIZE + 1];
|
static HIDO_UINT32 l_u32HTTPRecvBuffLen = 0;
|
static HIDO_UINT32 l_u32HTTPRecvTotalLen = 0;
|
static HIDO_UINT32 l_u32HTTPRespCode = 0;
|
static HIDO_UINT32 l_u32HTTPContentLength = 0;
|
static HIDO_UINT8 *l_pu8HTTPRespBody = HIDO_NULL;
|
static HIDO_UINT8 l_au8HTTPPostBuff[1024];
|
|
//static ST_HTTPGetFileOpt l_stHTTPGetFileOpt;
|
static ST_HTTPGetFileResponse l_stHTTPGetFileResponse;
|
|
/*******************************************************************************
|
* Local Function Declaration *
|
*******************************************************************************/
|
|
/*******************************************************************************
|
* Local Function *
|
*******************************************************************************/
|
/*******************************************************************************
|
* Function Name : HTTPClient_Response
|
* Description :
|
* Input :
|
* Output :
|
* Return :
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê7ÔÂ1ÈÕ
|
*******************************************************************************/
|
static HIDO_INT32 HTTPClient_Response(HIDO_UINT32 _u32RespCode, HIDO_UINT8 *_pu8Data, HIDO_UINT32 _u32Len)
|
{
|
if(HTTP_METHOD_GET_FILE == l_eHTTPMethod)
|
{
|
if(l_fnHTTPGetFileCallback != HIDO_NULL)
|
{
|
l_fnHTTPGetFileCallback(_u32RespCode, &l_stHTTPGetFileResponse, _pu8Data, _u32Len, l_pHTTPArg);
|
}
|
}
|
else
|
{
|
HIDO_DebugString((HIDO_CHAR *)_pu8Data, _u32Len);
|
|
if(l_fnHTTPResponseCallback != HIDO_NULL)
|
{
|
l_fnHTTPResponseCallback(_u32RespCode, _pu8Data, _u32Len, l_pHTTPArg);
|
}
|
}
|
|
return HIDO_OK;
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_TimerCallback
|
* Description :
|
* Input :
|
* Output :
|
* Return :
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê7ÔÂ1ÈÕ
|
*******************************************************************************/
|
static HIDO_VOID HTTPClient_TimerCallback(HIDO_VOID *_pArg)
|
{
|
if(l_eHTTPClientState != HTTP_CLIENT_STATE_IDLE)
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
}
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_SocketEventProc
|
* Description :
|
* Input :
|
* Output :
|
* Return :
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê11ÔÂ14ÈÕ
|
*******************************************************************************/
|
static void HTTPClient_SocketEventProc(HIDO_INT32 _i32SockID, E_SocketEvent _eEvent, HIDO_VOID *_pArg)
|
{
|
switch (_eEvent)
|
{
|
case SOCKET_EVENT_CONNECT_FAILED:
|
{
|
if(HTTP_CLIENT_STATE_CONNECTING == l_eHTTPClientState)
|
{
|
if(l_u32HTTPTryCnt < 3)
|
{
|
l_u32HTTPTryCnt++;
|
Socket_Connect(l_i32HTTPClientSockID, l_acHTTPHost, l_u32HTTPPort);
|
}
|
else
|
{
|
l_eHTTPClientState = HTTP_CLIENT_STATE_IDLE;
|
HTTPClient_Response(408, HIDO_NULL, 0);
|
}
|
}
|
|
break;
|
}
|
case SOCKET_EVENT_CONNECTED:
|
{
|
if(HTTP_CLIENT_STATE_CONNECTING == l_eHTTPClientState)
|
{
|
l_eHTTPClientState = HTTP_CLIENT_STATE_CONNECTED;
|
l_eHTTPRecvState = HTTP_RECV_STATE_HEAD;
|
l_u32HTTPRecvBuffLen = 0;
|
|
if(l_eHTTPMethod != HTTP_METHOD_POST_FILE)
|
{
|
Socket_Send(l_i32HTTPClientSockID, (HIDO_UINT8 *)l_acHTTPSendBuff, l_u32HTTPSendBuffLen);
|
}
|
}
|
|
break;
|
}
|
case SOCKET_EVENT_CLOSED:
|
{
|
if(l_eHTTPClientState != HTTP_CLIENT_STATE_IDLE)
|
{
|
HIDO_TimerCancel(l_u32HTTPClientTimerID);
|
l_eHTTPClientState = HTTP_CLIENT_STATE_IDLE;
|
|
HTTPClient_Response(l_u32HTTPRespCode, l_pu8HTTPRespBody, l_u32HTTPContentLength);
|
}
|
else
|
{
|
HIDO_TimerCancel(l_u32HTTPClientTimerID);
|
}
|
|
break;
|
}
|
case SOCKET_EVENT_RECV_DATA:
|
{
|
HIDO_INT32 i32Ret = 0;
|
HIDO_UINT32 u32RecvLen = 0;
|
|
do
|
{
|
if (l_u32HTTPRecvBuffLen >= HTTP_RECV_BUFF_SIZE)
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
|
break;
|
}
|
|
i32Ret = Socket_Recv(l_i32HTTPClientSockID, (HIDO_UINT8 *)(l_acHTTPRecvBuff + l_u32HTTPRecvBuffLen),
|
HTTP_RECV_BUFF_SIZE - l_u32HTTPRecvBuffLen, &u32RecvLen);
|
|
if ((i32Ret != HIDO_OK) || (0 == u32RecvLen))
|
{
|
break;
|
}
|
|
l_u32HTTPRecvBuffLen += u32RecvLen;
|
|
if (HTTP_RECV_STATE_HEAD == l_eHTTPRecvState)
|
{
|
/* ÊÕµ½"\r\n\r\n */
|
l_pu8HTTPRespBody = (HIDO_UINT8 *)HIDO_UtilStrnstr(l_acHTTPRecvBuff, "\r\n\r\n", u32RecvLen);
|
if (l_pu8HTTPRespBody != HIDO_NULL)
|
{
|
HIDO_CHAR *pcKeyName = HIDO_NULL;
|
HIDO_UINT32 u32Range0 = 0;
|
HIDO_UINT32 u32Range1 = 0;
|
HIDO_UINT32 u32RangeAll = 0;
|
|
l_pu8HTTPRespBody += 4;
|
|
if (HIDO_UtilParseFormat((HIDO_UINT8 *) l_acHTTPRecvBuff, u32RecvLen, "HTTP/1.1 %d %*\r\n",
|
&l_u32HTTPRespCode) != 2)
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
|
break;
|
}
|
|
pcKeyName = HIDO_UtilStrnstr(l_acHTTPRecvBuff, "Content-Length: ", u32RecvLen);
|
if (pcKeyName != HIDO_NULL)
|
{
|
if (HIDO_UtilParseFormat((HIDO_UINT8 *) pcKeyName,
|
u32RecvLen - (pcKeyName - l_acHTTPRecvBuff), "Content-Length: %d\r\n",
|
&l_u32HTTPContentLength) != 1)
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
|
break;
|
}
|
}
|
else
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
|
break;
|
}
|
|
/* »ñÈ¡Îļþ·ÖƬÐÅÏ¢ */
|
if(HTTP_METHOD_GET_FILE == l_eHTTPMethod)
|
{
|
HIDO_DataStruct stETag;
|
|
memset(&l_stHTTPGetFileResponse, 0, sizeof(l_stHTTPGetFileResponse));
|
|
pcKeyName = HIDO_UtilStrnstr(l_acHTTPRecvBuff, "Content-Range: ", u32RecvLen);
|
if (pcKeyName != HIDO_NULL)
|
{
|
if (HIDO_UtilParseFormat((HIDO_UINT8 *) pcKeyName,
|
u32RecvLen - (pcKeyName - l_acHTTPRecvBuff), "Content-Range: bytes %d-%d/%d\r\n",
|
&u32Range0, &u32Range1, &u32RangeAll) != 3)
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
|
break;
|
}
|
}
|
else
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
|
break;
|
}
|
|
l_stHTTPGetFileResponse.m_u32RangeBegin = u32Range0;
|
l_stHTTPGetFileResponse.m_u32RangeEnd = u32Range1;
|
l_stHTTPGetFileResponse.m_u32RangeTotal = u32RangeAll;
|
|
pcKeyName = HIDO_UtilStrnstr(l_acHTTPRecvBuff, "ETag: ", u32RecvLen);
|
if (pcKeyName != HIDO_NULL)
|
{
|
if (HIDO_UtilParseFormat((HIDO_UINT8 *) pcKeyName,
|
u32RecvLen - (pcKeyName - l_acHTTPRecvBuff), "ETag: %p\r\n", &stETag) != 1)
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
|
break;
|
}
|
}
|
else
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
|
break;
|
}
|
|
if((stETag.m_u32Len + 1) < sizeof(l_stHTTPGetFileResponse.m_acETag))
|
{
|
memcpy(l_stHTTPGetFileResponse.m_acETag, stETag.m_pData, stETag.m_u32Len);
|
}
|
}
|
|
l_u32HTTPRecvTotalLen = l_pu8HTTPRespBody - (HIDO_UINT8 *)l_acHTTPRecvBuff + l_u32HTTPContentLength;
|
l_eHTTPRecvState = HTTP_RECV_STATE_BODY;
|
|
if (l_u32HTTPRecvBuffLen >= l_u32HTTPRecvTotalLen)
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
}
|
}
|
}
|
else
|
{
|
if (l_u32HTTPRecvBuffLen >= l_u32HTTPRecvTotalLen)
|
{
|
Socket_Close(l_i32HTTPClientSockID);
|
}
|
}
|
}
|
while(HIDO_TRUE);
|
|
break;
|
}
|
default:
|
{
|
break;
|
}
|
}
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_ParseUrl
|
* Description : ½âÎöUrl
|
* Input :
|
* Output :
|
* Return :
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê7ÔÂ1ÈÕ
|
*******************************************************************************/
|
HIDO_INT32 HTTPClient_ParseUrl(HIDO_CHAR *_pcUrl, HIDO_CHAR *_pcHost, HIDO_UINT32 _u32HostSize,
|
HIDO_CHAR *_pcPath, HIDO_UINT32 _u32PathSize, HIDO_UINT32 *_pu32Port)
|
{
|
HIDO_DataStruct stHost;
|
HIDO_DataStruct stPath;
|
HIDO_UINT32 u32Port = 0;
|
|
if(HIDO_NULL == _pcUrl)
|
{
|
return HIDO_ERR;
|
}
|
|
if(HIDO_UtilParseFormat((HIDO_UINT8 *)_pcUrl, strlen(_pcUrl), "http://%p:%d/%p", &stHost, &u32Port, &stPath) != 3)
|
{
|
u32Port = 80;
|
|
if (HIDO_UtilParseFormat((HIDO_UINT8 *) _pcUrl, strlen(_pcUrl), "http://%p/%p", &stHost, &stPath) != 2)
|
{
|
return HIDO_ERR;
|
}
|
}
|
|
/* HOST */
|
if((stHost.m_u32Len + 1) < _u32HostSize)
|
{
|
memcpy(_pcHost, stHost.m_pData, stHost.m_u32Len);
|
_pcHost[stHost.m_u32Len] = '\0';
|
}
|
else
|
{
|
return HIDO_ERR;
|
}
|
|
/* Path */
|
if(stPath.m_u32Len > 0)
|
{
|
if((stPath.m_u32Len + 1) < _u32PathSize)
|
{
|
memcpy(_pcPath, stPath.m_pData, stPath.m_u32Len);
|
_pcPath[stPath.m_u32Len] = '\0';
|
}
|
else
|
{
|
return HIDO_ERR;
|
}
|
}
|
else
|
{
|
_pcPath[0] = '\0';
|
}
|
|
*_pu32Port = u32Port;
|
|
return HIDO_OK;
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTP_GetPostData
|
* Description :
|
* Input :
|
* Output :
|
* Return :
|
* Author : ¶Å¼ü
|
* Modified Date: : 2021Äê5ÔÂ3ÈÕ
|
*******************************************************************************/
|
HIDO_INT32 HTTPClient_GetPostFileData(HIDO_UINT32 _u32Offset, HIDO_VOID *_pBuff, HIDO_UINT32 _u32BuffSize, HIDO_UINT32 *_pu32Len)
|
{
|
if(l_fnHTTPostDataCallback != HIDO_NULL)
|
{
|
return l_fnHTTPostDataCallback(_u32Offset, _pBuff, _u32BuffSize, _pu32Len, l_pHTTPArg);
|
}
|
|
return HIDO_ERR;
|
}
|
|
/*******************************************************************************
|
* Global Function *
|
*******************************************************************************/
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_Post
|
* Description :
|
* Input :
|
* Output :
|
* Return :
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê7ÔÂ1ÈÕ
|
*******************************************************************************/
|
HIDO_INT32 HTTPClient_Post(HIDO_CHAR *_pcUrl, HIDO_CHAR *_pcBody, HIDO_UINT32 _u32BodyLen, FN_HTTPResponseCallback _fnResponseCallback, HIDO_VOID *_pArg)
|
{
|
if(l_eHTTPClientState != HTTP_CLIENT_STATE_IDLE)
|
{
|
return HIDO_ERR;
|
}
|
|
if(Internet_IsIPReady() != HIDO_TRUE)
|
{
|
return HIDO_ERR;
|
}
|
|
/* ½âÎöUrl */
|
if(HTTPClient_ParseUrl(_pcUrl, l_acHTTPHost, sizeof(l_acHTTPHost), l_acHTTPPath, sizeof(l_acHTTPPath), &l_u32HTTPPort) != HIDO_OK)
|
{
|
return HIDO_ERR;
|
}
|
|
/* URL */
|
HIDO_UtilSnprintf(l_acHTTPUrl, sizeof(l_acHTTPUrl), _pcUrl);
|
|
l_u32HTTPSendBuffLen = HIDO_UtilSnprintf(l_acHTTPSendBuff, sizeof(l_acHTTPSendBuff),
|
"POST /%s HTTP/1.1\r\n"
|
"Host: %s\r\n"
|
"User-Agent: QUECTEL_MODULE\r\n"
|
"Connection: Keep-Alive\r\n"
|
"Content-Type: application/json\r\n"
|
"Accept: */*\r\n"
|
"Content-Length: %u\r\n"
|
"\r\n"
|
"%s" , l_acHTTPPath, l_acHTTPHost, _u32BodyLen, _pcBody);
|
|
l_fnHTTPResponseCallback = _fnResponseCallback;
|
l_pHTTPArg = _pArg;
|
|
l_u32HTTPRespCode = 0;
|
l_u32HTTPContentLength = 0;
|
l_eHTTPClientState = HTTP_CLIENT_STATE_CONNECTING;
|
l_eHTTPMethod = HTTP_METHOD_POST;
|
l_u32HTTPTryCnt = 1;
|
Socket_Connect(l_i32HTTPClientSockID, l_acHTTPHost, l_u32HTTPPort);
|
HIDO_TimerStart(l_u32HTTPClientTimerID, HIDO_TIMER_TYPE_ONCE, HIDO_TIMER_TICK_S(15), HTTPClient_TimerCallback, HIDO_NULL);
|
|
return HIDO_OK;
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_Get
|
* Description :
|
* Input :
|
* Output :
|
* Return :
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê7ÔÂ1ÈÕ
|
*******************************************************************************/
|
HIDO_INT32 HTTPClient_Get(HIDO_CHAR *_pcUrl, FN_HTTPResponseCallback _fnResponseCallback, HIDO_VOID *_pArg)
|
{
|
if(l_eHTTPClientState != HTTP_CLIENT_STATE_IDLE)
|
{
|
return HIDO_ERR;
|
}
|
|
if(Internet_IsIPReady() != HIDO_TRUE)
|
{
|
return HIDO_ERR;
|
}
|
|
/* ½âÎöUrl */
|
if(HTTPClient_ParseUrl(_pcUrl, l_acHTTPHost, sizeof(l_acHTTPHost), l_acHTTPPath, sizeof(l_acHTTPPath), &l_u32HTTPPort) != HIDO_OK)
|
{
|
return HIDO_ERR;
|
}
|
|
/* URL */
|
HIDO_UtilSnprintf(l_acHTTPUrl, sizeof(l_acHTTPUrl), _pcUrl);
|
|
l_u32HTTPSendBuffLen = HIDO_UtilSnprintf(l_acHTTPSendBuff, sizeof(l_acHTTPSendBuff),
|
"GET /%s HTTP/1.1\r\n"
|
"Host: %s\r\n"
|
"User-Agent: QUECTEL_MODULE\r\n"
|
"Connection: Keep-Alive\r\n"
|
"Accept: */*\r\n"
|
"\r\n" , l_acHTTPPath, l_acHTTPHost);
|
|
l_fnHTTPResponseCallback = _fnResponseCallback;
|
l_pHTTPArg = _pArg;
|
|
l_u32HTTPRespCode = 0;
|
l_u32HTTPContentLength = 0;
|
l_eHTTPClientState = HTTP_CLIENT_STATE_CONNECTING;
|
l_eHTTPMethod = HTTP_METHOD_GET;
|
l_u32HTTPTryCnt = 1;
|
Socket_Connect(l_i32HTTPClientSockID, l_acHTTPHost, l_u32HTTPPort);
|
HIDO_TimerStart(l_u32HTTPClientTimerID, HIDO_TIMER_TYPE_ONCE, HIDO_TIMER_TICK_S(15), HTTPClient_TimerCallback, HIDO_NULL);
|
|
return HIDO_OK;
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_GetFile
|
* Description : HTTP ÏÂÔØÎļþ
|
* Input : _pcUrl ÎļþÁ¬½Ó
|
* : _fnGetFileCallback ÎļþÏÂÔØʼþ»Øµ÷
|
* : _pstOpt ÏÂÔزÎÊý
|
* £º _pArg Óû§²ÎÊý,»Øµ÷ʹÓÃ
|
* Output : None
|
* Return : HIDO_OK ³É¹¦,HIDO_ERR ʧ°Ü
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê7ÔÂ1ÈÕ
|
*******************************************************************************/
|
HIDO_INT32 HTTPClient_GetFile(HIDO_CHAR *_pcUrl, FN_HTTPGetFileCallback _fnGetFileCallback, ST_HTTPGetFileOpt *_pstOpt, HIDO_VOID *_pArg)
|
{
|
if(l_eHTTPClientState != HTTP_CLIENT_STATE_IDLE)
|
{
|
return HIDO_ERR;
|
}
|
|
if((HIDO_NULL == _pcUrl) || (HIDO_NULL == _pstOpt))
|
{
|
return HIDO_ERR;
|
}
|
|
if(Internet_IsIPReady() != HIDO_TRUE)
|
{
|
return HIDO_ERR;
|
}
|
|
/* ½âÎöUrl */
|
if(HTTPClient_ParseUrl(_pcUrl, l_acHTTPHost, sizeof(l_acHTTPHost), l_acHTTPPath, sizeof(l_acHTTPPath), &l_u32HTTPPort) != HIDO_OK)
|
{
|
return HIDO_ERR;
|
}
|
|
/* URL */
|
HIDO_UtilSnprintf(l_acHTTPUrl, sizeof(l_acHTTPUrl), _pcUrl);
|
|
l_u32HTTPSendBuffLen = HIDO_UtilSnprintf(l_acHTTPSendBuff, sizeof(l_acHTTPSendBuff),
|
"GET /%s HTTP/1.1\r\n"
|
"Host: %s\r\n"
|
"User-Agent: QUECTEL_MODULE\r\n"
|
"Connection: Keep-Alive\r\n"
|
"Accept: */*\r\n"
|
"Range: bytes=%u-%u\r\n",
|
l_acHTTPPath, l_acHTTPHost, _pstOpt->m_u32RangeBegin, _pstOpt->m_u32RangeEnd);
|
|
if(strlen(_pstOpt->m_acIfRange) != 0)
|
{
|
l_u32HTTPSendBuffLen += HIDO_UtilSnprintf(l_acHTTPSendBuff + l_u32HTTPSendBuffLen, sizeof(l_acHTTPSendBuff) - l_u32HTTPSendBuffLen,
|
"If-Range: \"%s\"\r\n"
|
"\r\n" , _pstOpt->m_acIfRange);
|
}
|
else
|
{
|
l_u32HTTPSendBuffLen += HIDO_UtilSnprintf(l_acHTTPSendBuff + l_u32HTTPSendBuffLen, sizeof(l_acHTTPSendBuff) - l_u32HTTPSendBuffLen,
|
"\r\n");
|
}
|
|
l_fnHTTPGetFileCallback = _fnGetFileCallback;
|
l_pHTTPArg = _pArg;
|
l_u32HTTPRespCode = 0;
|
l_u32HTTPContentLength = 0;
|
l_eHTTPClientState = HTTP_CLIENT_STATE_CONNECTING;
|
l_eHTTPMethod = HTTP_METHOD_GET_FILE;
|
l_u32HTTPTryCnt = 1;
|
Socket_Connect(l_i32HTTPClientSockID, l_acHTTPHost, l_u32HTTPPort);
|
HIDO_TimerStart(l_u32HTTPClientTimerID, HIDO_TIMER_TYPE_ONCE, HIDO_TIMER_TICK_S(30), HTTPClient_TimerCallback, HIDO_NULL);
|
|
return HIDO_OK;
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_PostFile
|
* Description : HTTP ÉÏ´«Îļþ
|
* Input : _pcUrl HTTP·¾¶
|
* : _pcFileName ÎļþÃû³Æ
|
* : _fnResponseCallback HTTPÏìÓ¦»Øµ÷º¯Êý
|
* : _pArg ²ÎÊý
|
* Output : Mone
|
* Return : HIDO_OK ³É¹¦,HIDO_ERR ʧ°Ü
|
* Author : ¶Å¼ü
|
* Modified Date: : 2021Äê5ÔÂ3ÈÕ
|
*******************************************************************************/
|
HIDO_INT32 HTTPClient_PostFile(HIDO_CHAR *_pcUrl, FN_HTTPPostDataCallback _fnPostDataCallback, FN_HTTPResponseCallback _fnResponseCallback,
|
HIDO_VOID *_pArg)
|
{
|
if(l_eHTTPClientState != HTTP_CLIENT_STATE_IDLE)
|
{
|
return HIDO_ERR;
|
}
|
|
if(HIDO_NULL == _pcUrl)
|
{
|
return HIDO_ERR;
|
}
|
|
if(HIDO_NULL == _fnPostDataCallback)
|
{
|
return HIDO_ERR;
|
}
|
|
if(HIDO_NULL == _fnResponseCallback)
|
{
|
return HIDO_ERR;
|
}
|
|
if(Internet_IsIPReady() != HIDO_TRUE)
|
{
|
return HIDO_ERR;
|
}
|
|
/* ½âÎöUrl */
|
if(HTTPClient_ParseUrl(_pcUrl, l_acHTTPHost, sizeof(l_acHTTPHost), l_acHTTPPath, sizeof(l_acHTTPPath), &l_u32HTTPPort) != HIDO_OK)
|
{
|
return HIDO_ERR;
|
}
|
|
l_fnHTTPResponseCallback = _fnResponseCallback;
|
l_fnHTTPostDataCallback = _fnPostDataCallback;
|
l_pHTTPArg = _pArg;
|
l_u32HTTPPostLen = 0;
|
|
l_eHTTPMethod = HTTP_METHOD_POST_FILE;
|
l_eHTTPClientState = HTTP_CLIENT_STATE_CONNECTING;
|
Socket_Connect(l_i32HTTPClientSockID, l_acHTTPHost, l_u32HTTPPort);
|
|
return HIDO_OK;
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_Poll
|
* Description : HTTP¿Í»§¶ËÂÖѯ´¦Àí
|
* Input : None
|
* Output : None
|
* Return : HIDO_OK ³É¹¦,HIDO_ERR ʧ°Ü
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê7ÔÂ1ÈÕ
|
*******************************************************************************/
|
HIDO_INT32 HTTPClient_Poll(HIDO_VOID)
|
{
|
if(HTTP_CLIENT_STATE_CONNECTED == l_eHTTPClientState)
|
{
|
if(HTTP_METHOD_POST_FILE == l_eHTTPMethod)
|
{
|
if(Socket_IsSendQueueEmpty(l_i32HTTPClientSockID) == HIDO_TRUE)
|
{
|
HIDO_UINT32 u32PostLen = 0;
|
HIDO_INT32 i32Result = 0;
|
|
i32Result = HTTPClient_GetPostFileData(l_u32HTTPPostLen, l_au8HTTPPostBuff, sizeof(l_au8HTTPPostBuff), &u32PostLen);
|
|
if((HIDO_OK == i32Result) && (u32PostLen != 0))
|
{
|
Socket_Send(l_i32HTTPClientSockID, l_au8HTTPPostBuff, u32PostLen);
|
}
|
}
|
}
|
}
|
|
return HIDO_OK;
|
}
|
|
/*******************************************************************************
|
* Function Name : HTTPClient_Init
|
* Description : HTTP¿Í»§¶Ë³õʼ»¯
|
* Input : None
|
* Output : None
|
* Return : HIDO_OK ³É¹¦,HIDO_ERR ʧ°Ü
|
* Author : ¶Å¼ü
|
* Modified Date: : 2020Äê7ÔÂ1ÈÕ
|
*******************************************************************************/
|
HIDO_INT32 HTTPClient_Init(HIDO_VOID)
|
{
|
l_eHTTPClientState = HTTP_CLIENT_STATE_IDLE;
|
|
if(Socket_Create(&l_i32HTTPClientSockID, SOCKET_TYPE_TCP, HTTPClient_SocketEventProc, HIDO_NULL) != HIDO_OK)
|
{
|
|
return HIDO_ERR;
|
}
|
|
if(HIDO_TimerCreate(&l_u32HTTPClientTimerID) != HIDO_OK)
|
{
|
|
return HIDO_ERR;
|
}
|
|
return HIDO_OK;
|
}
|
