aboutsummaryrefslogtreecommitdiff
path: root/src/zenserver/projectstore/zenremoteprojectstore.cpp
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2024-12-12 08:27:54 +0100
committerGitHub Enterprise <[email protected]>2024-12-12 08:27:54 +0100
commit9bb2bf10a76127fea1db01fab42c795bdc07c936 (patch)
tree4bdb9d40ee265798afe4ec439dea45b7a7c5ed3c /src/zenserver/projectstore/zenremoteprojectstore.cpp
parentMemory tracking improvements (#262) (diff)
downloadzen-9bb2bf10a76127fea1db01fab42c795bdc07c936.tar.xz
zen-9bb2bf10a76127fea1db01fab42c795bdc07c936.zip
Builds API remote project store (#258)
Feature: zen command oplog-export and oplog-import now supports --builds remote target using the Jupiter builds API
Diffstat (limited to 'src/zenserver/projectstore/zenremoteprojectstore.cpp')
-rw-r--r--src/zenserver/projectstore/zenremoteprojectstore.cpp20
1 files changed, 9 insertions, 11 deletions
diff --git a/src/zenserver/projectstore/zenremoteprojectstore.cpp b/src/zenserver/projectstore/zenremoteprojectstore.cpp
index 6b05442b3..566d0d4b2 100644
--- a/src/zenserver/projectstore/zenremoteprojectstore.cpp
+++ b/src/zenserver/projectstore/zenremoteprojectstore.cpp
@@ -36,7 +36,6 @@ public:
.UseTempBlockFiles = false,
.AllowChunking = false,
.ContainerName = fmt::format("{}/{}", m_Project, m_Oplog),
- .BaseContainerName = "",
.Description = fmt::format("[zen] {}"sv, m_HostAddress)};
}
@@ -51,6 +50,12 @@ public:
.m_PeakBytesPerSec = m_PeakBytesPerSec.load()};
}
+ virtual CreateContainerResult CreateContainer() override
+ {
+ // Nothing to do here
+ return {};
+ }
+
virtual SaveResult SaveContainer(const IoBuffer& Payload) override
{
std::string SaveRequest = fmt::format("/{}/oplog/{}/save"sv, m_Project, m_Oplog);
@@ -88,7 +93,7 @@ public:
return Result;
}
- virtual SaveAttachmentResult SaveAttachment(const CompositeBuffer& Payload, const IoHash& RawHash) override
+ virtual SaveAttachmentResult SaveAttachment(const CompositeBuffer& Payload, const IoHash& RawHash, Block&&) override
{
std::string SaveRequest = fmt::format("/{}/oplog/{}/{}"sv, m_Project, m_Oplog, RawHash);
HttpClient::Response Response = m_Client.Post(SaveRequest, Payload, ZenContentType::kCompressedBinary);
@@ -231,16 +236,9 @@ public:
return Result;
}
- virtual LoadContainerResult LoadBaseContainer() override
- {
- return LoadContainerResult{{.ErrorCode = static_cast<int>(HttpResponseCode::NoContent)}};
- }
-
- virtual HasAttachmentsResult HasAttachments(const std::span<IoHash>) override
+ virtual GetKnownBlocksResult GetKnownBlocks() override
{
- // For zen as remote store we never store blocks so we should never get here
- ZEN_ASSERT(false);
- return HasAttachmentsResult{};
+ return GetKnownBlocksResult{{.ErrorCode = static_cast<int>(HttpResponseCode::NoContent)}};
}
virtual LoadAttachmentResult LoadAttachment(const IoHash& RawHash) override