Skip to content

Commit 852ed06

Browse files
committed
updated to exposed corehttp functions and fix read
1 parent 1a4d737 commit 852ed06

3 files changed

Lines changed: 10 additions & 7 deletions

File tree

src/extended_core_http_client.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,5 +109,5 @@ HTTPClient_Read(const TransportInterface_t* pTransport, HTTPResponse_t* pRespons
109109
HTTPStatus_t
110110
HTTPClient_Write(const TransportInterface_t* pTransport, HTTPClient_GetCurrentTimeFunc_t getTimestampMs,
111111
const uint8_t* pData, size_t dataLen) {
112-
return HTTPClient_InternalSendHttpData(pTransport, getTimestampMs, pData, dataLen);
112+
return HTTPClient_SendHttpData(pTransport, getTimestampMs, pData, dataLen);
113113
}

src/lcorehttp_client.c

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -358,8 +358,8 @@ l_corehttp_client_request(lua_State* L) {
358358
return push_error_status(L, response->status);
359359
}
360360

361-
response->status = HTTPClient_InternalSendHttpHeaders(transportInterface, response->response.getTime,
362-
&requestHeaders, body_len, sendFlags);
361+
response->status = HTTPClient_SendHttpHeaders(transportInterface, response->response.getTime, &requestHeaders,
362+
body_len, sendFlags);
363363
if (response->status != HTTPSuccess) {
364364
return push_error_status(L, response->status);
365365
}
@@ -386,8 +386,11 @@ l_corehttp_client_request(lua_State* L) {
386386
lua_pop(L, 1);
387387
}
388388

389-
response->status =
390-
HTTPClient_InternalReceiveAndParseHttpResponse(transportInterface, &response->response, &requestHeaders);
389+
response->status = HTTPClient_ReceiveAndParseHttpResponse(transportInterface, &response->response, &requestHeaders);
390+
if (response->status == HTTPInsufficientMemory
391+
&& response->response.areHeadersComplete) { // headers are complete, we can read the body later
392+
response->status = HTTPSuccess;
393+
}
391394
response->strStatus = HTTPClient_strerror(response->status);
392395
response->contentLength = response->response.contentLength;
393396

src/lcorehttp_response.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -131,8 +131,8 @@ l_corehttp_response_read(lua_State* L) {
131131
return 1;
132132
}
133133
size_t bytesRead = 0;
134-
HTTPStatus_t returnStatus =
135-
HTTPClient_Read(response->transport, &response->response, buffer, bufferLen - preloadedBytesToUse, &bytesRead);
134+
HTTPStatus_t returnStatus = HTTPClient_Read(response->transport, &response->response, buffer + preloadedBytesToUse,
135+
bufferLen - preloadedBytesToUse, &bytesRead);
136136
if (returnStatus != HTTPSuccess) {
137137
return push_error(L, "Failed to read response body.");
138138
}

0 commit comments

Comments
 (0)