aboutsummaryrefslogtreecommitdiff
path: root/src/zenhttp/httpclient.cpp
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2023-05-15 20:41:57 +0200
committerStefan Boberg <[email protected]>2023-05-15 20:41:57 +0200
commitc0eabf9ce24274336d402737b2f8ea3d6772d33b (patch)
tree853dcee9fa1d4542fb5d18b17638a1cf0395024f /src/zenhttp/httpclient.cpp
parentadded some top-level trace scopes to httpsys impl (diff)
downloadzen-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.cpp24
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());