diff options
| author | Stefan Boberg <[email protected]> | 2023-05-15 20:41:57 +0200 |
|---|---|---|
| committer | Stefan Boberg <[email protected]> | 2023-05-15 20:41:57 +0200 |
| commit | c0eabf9ce24274336d402737b2f8ea3d6772d33b (patch) | |
| tree | 853dcee9fa1d4542fb5d18b17638a1cf0395024f /src/zenhttp/httpclient.cpp | |
| parent | added some top-level trace scopes to httpsys impl (diff) | |
| download | zen-c0eabf9ce24274336d402737b2f8ea3d6772d33b.tar.xz zen-c0eabf9ce24274336d402737b2f8ea3d6772d33b.zip | |
some HttpClient changes eliminating some cpr helpers
Diffstat (limited to 'src/zenhttp/httpclient.cpp')
| -rw-r--r-- | src/zenhttp/httpclient.cpp | 24 |
1 files changed, 6 insertions, 18 deletions
diff --git a/src/zenhttp/httpclient.cpp b/src/zenhttp/httpclient.cpp index fa290ef52..761b4b08e 100644 --- a/src/zenhttp/httpclient.cpp +++ b/src/zenhttp/httpclient.cpp @@ -23,11 +23,9 @@ namespace zen { using namespace std::literals; -HttpClient::Response -FromCprResponse(cpr::Response& InResponse) -{ - return {.StatusCode = HttpResponseCode(InResponse.status_code)}; -} +////////////////////////////////////////////////////////////////////////// +// +// CPR helpers cpr::Body AsCprBody(const CbObject& Obj) @@ -51,14 +49,6 @@ AsCprBody(const CompositeBuffer& Buffers) return cpr::Body{std::move(String)}; } -CbObject -AsCbObject(cpr::Response& Response) -{ - const std::string& Data = Response.text; - - return LoadCompactBinaryObject(IoBufferBuilder::MakeCloneFromMemory(Data.data(), Data.size())); -} - ////////////////////////////////////////////////////////////////////////// HttpClient::Response @@ -213,9 +203,7 @@ HttpClient::TransactPackage(std::string_view Url, CbPackage Package) for (const CbAttachment& Attachment : Attachments) { - IoHash Hash = Attachment.GetHash(); - - Writer.AddHash(Hash); + Writer.AddHash(Attachment.GetHash()); } Writer.EndArray(); @@ -233,7 +221,7 @@ HttpClient::TransactPackage(std::string_view Url, CbPackage Package) IoBuffer ResponseBuffer(IoBuffer::Wrap, FilterResponse.text.data(), FilterResponse.text.size()); CbObject ResponseObject = LoadCompactBinaryObject(ResponseBuffer); - for (auto& Entry : ResponseObject["need"]) + for (CbFieldView& Entry : ResponseObject["need"]) { ZEN_ASSERT(Entry.IsHash()); AttachmentsToSend.push_back(Entry.AsHash()); @@ -272,7 +260,7 @@ HttpClient::TransactPackage(std::string_view Url, CbPackage Package) if (!IsHttpSuccessCode(FilterResponse.status_code)) { - return FromCprResponse(FilterResponse); + return {.StatusCode = HttpResponseCode(FilterResponse.status_code)}; } IoBuffer ResponseBuffer(IoBuffer::Clone, FilterResponse.text.data(), FilterResponse.text.size()); |