aboutsummaryrefslogtreecommitdiff
path: root/zenserver/upstream/jupiter.cpp
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2021-05-23 21:29:21 +0200
committerStefan Boberg <[email protected]>2021-05-23 21:29:21 +0200
commitd6c221e378813e47b29694c99296943b9f2a4fd8 (patch)
tree1661c1ca10354b85cd332c3a16e19d9b62b942ce /zenserver/upstream/jupiter.cpp
parentAdded IoBuffer::operator MemoryView for convenience (diff)
downloadzen-d6c221e378813e47b29694c99296943b9f2a4fd8.tar.xz
zen-d6c221e378813e47b29694c99296943b9f2a4fd8.zip
Implemented new URI addressing scheme for the Zen cache endpoints, and prepared for additional indexing capabilities
Diffstat (limited to 'zenserver/upstream/jupiter.cpp')
-rw-r--r--zenserver/upstream/jupiter.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/zenserver/upstream/jupiter.cpp b/zenserver/upstream/jupiter.cpp
index 755e0bca4..977bcc712 100644
--- a/zenserver/upstream/jupiter.cpp
+++ b/zenserver/upstream/jupiter.cpp
@@ -124,7 +124,7 @@ CloudCacheSession::Put(std::string_view BucketId, const IoHash& Key, ZenCacheVal
m_CacheClient->AcquireAccessToken(Auth);
Session.SetOption(cpr::Url{Uri.c_str()});
- if (Data.IsCompactBinary)
+ if (Data.Value.GetContentType() == ZenContentType::kCbObject)
{
CbObjectView Cbo(Data.Value.Data());
const IoHash Hash = Cbo.GetHash();
@@ -133,7 +133,7 @@ CloudCacheSession::Put(std::string_view BucketId, const IoHash& Key, ZenCacheVal
Session.SetOption(
cpr::Header{{"Authorization", Auth}, {"X-Jupiter-IoHash", Hash.ToHexString()}, {"Content-Type", "application/x-ue-cb"}});
- Session.SetOption(cpr::Body{(const char*)DataView.GetData(), DataView.GetSize()});
+ Session.SetOption(cpr::Body{reinterpret_cast<const char*>(DataView.GetData()), DataView.GetSize()});
}
else
{
@@ -142,7 +142,7 @@ CloudCacheSession::Put(std::string_view BucketId, const IoHash& Key, ZenCacheVal
Session.SetOption(
cpr::Header{{"Authorization", Auth}, {"X-Jupiter-IoHash", Hash.ToHexString()}, {"Content-Type", "application/x-ue-cb"}});
- Session.SetOption(cpr::Body{(const char*)Data.Value.Data(), Data.Value.Size()});
+ Session.SetOption(cpr::Body{reinterpret_cast<const char*>(Data.Value.Data()), Data.Value.Size()});
}
cpr::Response Response = Session.Put();