diff options
Diffstat (limited to 'src/buildtool/execution_api/remote/bazel/bazel_response.cpp')
-rw-r--r-- | src/buildtool/execution_api/remote/bazel/bazel_response.cpp | 32 |
1 files changed, 11 insertions, 21 deletions
diff --git a/src/buildtool/execution_api/remote/bazel/bazel_response.cpp b/src/buildtool/execution_api/remote/bazel/bazel_response.cpp index d05517a1..6ae2457e 100644 --- a/src/buildtool/execution_api/remote/bazel/bazel_response.cpp +++ b/src/buildtool/execution_api/remote/bazel/bazel_response.cpp @@ -5,6 +5,17 @@ #include "src/buildtool/execution_api/remote/bazel/bazel_cas_client.hpp" #include "src/buildtool/logging/logger.hpp" +namespace { + +auto ProcessDirectoryMessage(bazel_re::Directory const& dir) noexcept + -> std::optional<BazelBlob> { + auto data = dir.SerializeAsString(); + auto digest = ArtifactDigest::Create(data); + return BazelBlob{std::move(digest), std::move(data)}; +} + +} // namespace + auto BazelResponse::ReadStringBlob(bazel_re::Digest const& id) noexcept -> std::string { auto blobs = network_->ReadBlobs({id}).Next(); @@ -120,24 +131,3 @@ auto BazelResponse::UploadTreeMessageDirectories( } return ArtifactDigest{root_digest}; } - -auto BazelResponse::ProcessDirectoryMessage( - bazel_re::Directory const& dir) const noexcept -> std::optional<BazelBlob> { - auto data = dir.SerializeAsString(); - auto digest = ArtifactDigest::Create(data); - - if (tree_map_ and not tree_map_->HasTree(digest)) { - // cache in local tree map - auto tree = tree_map_->CreateTree(); - if (not BazelMsgFactory::ReadObjectInfosFromDirectory( - dir, - [&tree](auto path, auto info) { - return tree.AddInfo(path, info); - }) or - not tree_map_->AddTree(digest, std::move(tree))) { - return std::nullopt; - } - } - - return BazelBlob{std::move(digest), std::move(data)}; -} |