bucket_request_parser.cc

// Copyright 2022 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

#include "google/cloud/storage/internal/grpc/bucket_request_parser.h"
#include "google/cloud/storage/internal/bucket_access_control_parser.h"
#include "google/cloud/storage/internal/grpc/bucket_access_control_parser.h"
#include "google/cloud/storage/internal/grpc/bucket_metadata_parser.h"
#include "google/cloud/storage/internal/grpc/bucket_name.h"
#include "google/cloud/storage/internal/grpc/object_access_control_parser.h"
#include "google/cloud/storage/internal/lifecycle_rule_parser.h"
#include "google/cloud/storage/internal/object_access_control_parser.h"
#include "google/cloud/storage/internal/patch_builder_details.h"
#include "google/cloud/internal/time_utils.h"
#include <algorithm>

namespace google {
namespace cloud {
namespace storage_internal {
GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_BEGIN
namespace {

using ::google::storage::v2::Bucket;

Status PatchSoftDeletePolicy(Bucket& b, nlohmann::json const& p) {
  if (p.is_null()) {
    b.clear_soft_delete_policy();
    return Status{};
  }
  b.mutable_soft_delete_policy()->mutable_retention_duration()->set_seconds(
      p.value("retentionDurationSeconds", std::int64_t{0}));
  return Status{};
}

Status PatchStorageClass(Bucket& b, nlohmann::json const& p) {
  b.set_storage_class(p.is_null() ? std::string{} : p.get<std::string>());
  return Status{};
}

Status PatchRpo(Bucket& b, nlohmann::json const& p) {
  b.set_rpo(p.is_null() ? std::string{} : p.get<std::string>());
  return Status{};
}

Status PatchAcl(Bucket& b, nlohmann::json const& patch) {
  if (patch.is_null()) {
    b.clear_acl();
    return Status{};
  }
  for (auto const& a : patch) {
    auto& acl = *b.add_acl();
    acl.set_entity(a.value("entity", ""));
    acl.set_role(a.value("role", ""));
  }
  return Status{};
}

Status PatchDefaultObjectAcl(Bucket& b, nlohmann::json const& patch) {
  if (patch.is_null()) {
    b.clear_default_object_acl();
    return Status{};
  }
  for (auto const& a : patch) {
    auto& acl = *b.add_default_object_acl();
    acl.set_entity(a.value("entity", ""));
    acl.set_role(a.value("role", ""));
  }
  return Status{};
}

Status PatchLifecycle(Bucket& b, nlohmann::json const& patch) {
  if (patch.is_null()) {
    b.clear_lifecycle();
    return Status{};
  }
  auto& lifecycle = *b.mutable_lifecycle();
  // By construction, the PatchBuilder always includes the "rule"
  // subobject.
  for (auto const& r : patch["rule"]) {
    auto lf = storage::internal::LifecycleRuleParser::FromJson(r);
    // We do not care if `b` may have been modified. It will be discarded if
    // this function (or similar functions) return a non-Okay Status.
    if (!lf) return std::move(lf).status();
    *lifecycle.add_rule() = storage_internal::ToProto(*lf);
  }
  return Status{};
}

Status PatchCors(Bucket& b, nlohmann::json const& patch) {
  if (patch.is_null()) {
    b.clear_cors();
    return Status{};
  }
  for (auto const& c : patch) {
    auto& cors = *b.add_cors();
    cors.set_max_age_seconds(c.value("maxAgeSeconds", std::int32_t{0}));
    if (c.contains("origin")) {
      for (auto const& o : c["origin"]) {
        cors.add_origin(o.get<std::string>());
      }
    }
    if (c.contains("method")) {
      for (auto const& m : c["method"]) {
        cors.add_method(m.get<std::string>());
      }
    }
    if (c.contains("responseHeader")) {
      for (auto const& h : c["responseHeader"]) {
        cors.add_response_header(h.get<std::string>());
      }
    }
  }
  return Status{};
}

Status PatchEventBasedHold(Bucket& b, nlohmann::json const& patch) {
  if (patch.is_null()) {
    b.clear_default_event_based_hold();
  } else {
    b.set_default_event_based_hold(patch.get<bool>());
  }
  return Status{};
}

Status PatchWebsite(Bucket& b, nlohmann::json const& w) {
  if (w.is_null()) {
    b.clear_website();
  } else {
    b.mutable_website()->set_main_page_suffix(w.value("mainPageSuffix", ""));
    b.mutable_website()->set_not_found_page(w.value("notFoundPage", ""));
  }
  return Status{};
}

Status PatchVersioning(Bucket& b, nlohmann::json const& v) {
  if (v.is_null()) {
    b.clear_versioning();
  } else {
    b.mutable_versioning()->set_enabled(v.value("enabled", false));
  }
  return Status{};
}

Status PatchLogging(Bucket& b, nlohmann::json const& l) {
  if (l.is_null()) {
    b.clear_logging();
  } else {
    b.mutable_logging()->set_log_bucket(
        GrpcBucketIdToName(l.value("logBucket", "")));
    b.mutable_logging()->set_log_object_prefix(l.value("logObjectPrefix", ""));
  }
  return Status{};
}

Status PatchEncryption(Bucket& b, nlohmann::json const& e) {
  if (e.is_null()) {
    b.clear_encryption();
  } else {
    b.mutable_encryption()->set_default_kms_key(
        e.value("defaultKmsKeyName", ""));
  }
  return Status{};
}

Status PatchBilling(Bucket& bucket, nlohmann::json const& b) {
  if (b.is_null()) {
    bucket.clear_billing();
  } else {
    bucket.mutable_billing()->set_requester_pays(
        b.value("requesterPays", false));
  }
  return Status{};
}

Status PatchRetentionPolicy(Bucket& b, nlohmann::json const& r) {
  if (r.is_null()) {
    b.clear_retention_policy();
  } else {
    b.mutable_retention_policy()->mutable_retention_duration()->set_seconds(
        r.value("retentionPeriod", std::int64_t{0}));
  }
  return Status{};
}

Status PatchIamConfig(Bucket& b, nlohmann::json const& i) {
  if (i.is_null()) {
    b.clear_iam_config();
    return Status{};
  }
  auto& iam_config = *b.mutable_iam_config();
  if (i.contains("uniformBucketLevelAccess")) {
    iam_config.mutable_uniform_bucket_level_access()->set_enabled(
        i["uniformBucketLevelAccess"].value("enabled", false));
  }
  if (i.contains("publicAccessPrevention")) {
    auto pap = i.value("publicAccessPrevention", "");
    iam_config.set_public_access_prevention(pap);
  }
  return Status{};
}

Status PatchAutoclass(Bucket& bucket, nlohmann::json const& p) {
  if (p.is_null()) {
    bucket.clear_autoclass();
  } else {
    bucket.mutable_autoclass()->set_enabled(p.value("enabled", false));
  }
  return Status{};
}

void UpdateAcl(Bucket& bucket, storage::BucketMetadata const& metadata) {
  for (auto const& a : metadata.acl()) {
    auto& acl = *bucket.add_acl();
    acl.set_entity(a.entity());
    acl.set_role(a.role());
  }
}

void UpdateDefaultObjectAcl(Bucket& bucket,
                            storage::BucketMetadata const& metadata) {
  for (auto const& a : metadata.default_acl()) {
    auto& acl = *bucket.add_default_object_acl();
    acl.set_entity(a.entity());
    acl.set_role(a.role());
  }
}

void UpdateLifecycle(Bucket& bucket, storage::BucketMetadata const& metadata) {
  if (!metadata.has_lifecycle()) return;
  auto& lifecycle = *bucket.mutable_lifecycle();
  // By construction, the PatchBuilder always includes the "rule"
  // subobject.
  for (auto const& r : metadata.lifecycle().rule) {
    *lifecycle.add_rule() = storage_internal::ToProto(r);
  }
}

void UpdateCors(Bucket& bucket, storage::BucketMetadata const& metadata) {
  for (auto const& c : metadata.cors()) {
    auto& cors = *bucket.add_cors();
    cors.set_max_age_seconds(
        static_cast<std::int32_t>(c.max_age_seconds.value_or(0)));
    for (auto const& o : c.origin) {
      cors.add_origin(o);
    }
    for (auto const& m : c.method) {
      cors.add_method(m);
    }
    for (auto const& h : c.response_header) {
      cors.add_response_header(h);
    }
  }
}

void UpdateLabels(Bucket& bucket, storage::BucketMetadata const& metadata) {
  for (auto const& kv : metadata.labels()) {
    (*bucket.mutable_labels())[kv.first] = kv.second;
  }
}

void UpdateWebsite(Bucket& bucket, storage::BucketMetadata const& metadata) {
  if (!metadata.has_website()) return;
  auto const& w = metadata.website();
  bucket.mutable_website()->set_main_page_suffix(w.main_page_suffix);
  bucket.mutable_website()->set_not_found_page(w.not_found_page);
}

void UpdateVersioning(Bucket& bucket, storage::BucketMetadata const& metadata) {
  if (!metadata.has_versioning()) return;
  bucket.mutable_versioning()->set_enabled(metadata.versioning()->enabled);
}

void UpdateLogging(Bucket& bucket, storage::BucketMetadata const& metadata) {
  if (!metadata.has_logging()) return;
  bucket.mutable_logging()->set_log_bucket(metadata.logging().log_bucket);
  bucket.mutable_logging()->set_log_object_prefix(
      metadata.logging().log_object_prefix);
}

void UpdateEncryption(Bucket& bucket, storage::BucketMetadata const& metadata) {
  if (!metadata.has_encryption()) return;
  bucket.mutable_encryption()->set_default_kms_key(
      metadata.encryption().default_kms_key_name);
}

void UpdateBilling(Bucket& bucket, storage::BucketMetadata const& metadata) {
  if (!metadata.has_billing()) return;
  bucket.mutable_billing()->set_requester_pays(
      metadata.billing().requester_pays);
}

void UpdateRetentionPolicy(Bucket& bucket,
                           storage::BucketMetadata const& metadata) {
  if (!metadata.has_retention_policy()) return;
  *bucket.mutable_retention_policy()->mutable_retention_duration() =
      google::cloud::internal::ToDurationProto(
          metadata.retention_policy().retention_period);
}

void UpdateIamConfig(Bucket& bucket, storage::BucketMetadata const& metadata) {
  if (!metadata.has_iam_configuration()) return;
  auto& iam_config = *bucket.mutable_iam_config();
  auto const& i = metadata.iam_configuration();
  if (i.uniform_bucket_level_access.has_value()) {
    iam_config.mutable_uniform_bucket_level_access()->set_enabled(
        i.uniform_bucket_level_access->enabled);
  }
  if (i.public_access_prevention.has_value()) {
    auto pap = i.public_access_prevention.value();
    iam_config.set_public_access_prevention(pap);
  }
}

void UpdateAutoclass(Bucket& bucket, storage::BucketMetadata const& metadata) {
  if (!metadata.has_autoclass()) return;
  bucket.mutable_autoclass()->set_enabled(metadata.autoclass().enabled);
}

void UpdateSoftDeletePolicy(Bucket& bucket,
                            storage::BucketMetadata const& metadata) {
  if (!metadata.has_soft_delete_policy()) return;
  *bucket.mutable_soft_delete_policy()->mutable_retention_duration() =
      google::cloud::internal::ToDurationProto(
          metadata.soft_delete_policy().retention_duration);
}

}  // namespace

google::storage::v2::DeleteBucketRequest ToProto(
    storage::internal::DeleteBucketRequest const& request) {
  google::storage::v2::DeleteBucketRequest result;
  result.set_name(GrpcBucketIdToName(request.bucket_name()));
  if (request.HasOption<storage::IfMetagenerationMatch>()) {
    result.set_if_metageneration_match(
        request.GetOption<storage::IfMetagenerationMatch>().value());
  }
  if (request.HasOption<storage::IfMetagenerationNotMatch>()) {
    result.set_if_metageneration_not_match(
        request.GetOption<storage::IfMetagenerationNotMatch>().value());
  }
  return result;
}

google::storage::v2::GetBucketRequest ToProto(
    storage::internal::GetBucketMetadataRequest const& request) {
  google::storage::v2::GetBucketRequest result;
  result.set_name(GrpcBucketIdToName(request.bucket_name()));
  if (request.HasOption<storage::IfMetagenerationMatch>()) {
    result.set_if_metageneration_match(
        request.GetOption<storage::IfMetagenerationMatch>().value());
  }
  if (request.HasOption<storage::IfMetagenerationNotMatch>()) {
    result.set_if_metageneration_not_match(
        request.GetOption<storage::IfMetagenerationNotMatch>().value());
  }
  auto projection = request.GetOption<storage::Projection>().value_or("");
  if (projection == "full") result.mutable_read_mask()->add_paths("*");
  return result;
}

google::storage::v2::CreateBucketRequest ToProto(
    storage::internal::CreateBucketRequest const& request) {
  google::storage::v2::CreateBucketRequest result;
  result.set_parent("projects/_");
  result.set_bucket_id(request.metadata().name());
  if (request.HasOption<storage::PredefinedAcl>()) {
    result.set_predefined_acl(
        request.GetOption<storage::PredefinedAcl>().value());
  }
  if (request.HasOption<storage::PredefinedDefaultObjectAcl>()) {
    result.set_predefined_default_object_acl(
        request.GetOption<storage::PredefinedDefaultObjectAcl>().value());
  }
  *result.mutable_bucket() = storage_internal::ToProto(request.metadata());
  result.mutable_bucket()->set_project("projects/" + request.project_id());
  // Ignore fields commonly set by ToProto().
  result.mutable_bucket()->set_name("");
  result.mutable_bucket()->set_bucket_id("");
  result.mutable_bucket()->clear_create_time();
  result.mutable_bucket()->clear_update_time();
  return result;
}

google::storage::v2::ListBucketsRequest ToProto(
    storage::internal::ListBucketsRequest const& request) {
  google::storage::v2::ListBucketsRequest result;
  result.set_parent("projects/" + request.project_id());
  auto const page_size = request.GetOption<storage::MaxResults>().value_or(0);
  // Clamp out of range values. The service will clamp to its own range
  // ([0, 1000] as of this writing) anyway.
  if (page_size < 0) {
    result.set_page_size(0);
  } else if (page_size < std::numeric_limits<std::int32_t>::max()) {
    result.set_page_size(static_cast<std::int32_t>(page_size));
  } else {
    result.set_page_size(std::numeric_limits<std::int32_t>::max());
  }
  result.set_page_token(request.page_token());
  result.set_prefix(request.GetOption<storage::Prefix>().value_or(""));
  if (request.return_partial_success()) {
    result.set_return_partial_success(true);
  }
  if (request.GetOption<storage::Projection>().value_or("") == "full") {
    result.mutable_read_mask()->add_paths("*");
  }
  return result;
}

storage::internal::ListBucketsResponse FromProto(
    google::storage::v2::ListBucketsResponse const& response) {
  storage::internal::ListBucketsResponse result;
  result.next_page_token = response.next_page_token();
  result.items.reserve(response.buckets_size());
  auto const& current_options = internal::CurrentOptions();
  std::transform(response.buckets().begin(), response.buckets().end(),
                 std::back_inserter(result.items),
                 [&](google::storage::v2::Bucket const& b) {
                   return storage_internal::FromProto(b, current_options);
                 });
  for (auto const& u : response.unreachable()) {
    result.unreachable.push_back(u);
  }
  return result;
}

google::storage::v2::LockBucketRetentionPolicyRequest ToProto(
    storage::internal::LockBucketRetentionPolicyRequest const& request) {
  google::storage::v2::LockBucketRetentionPolicyRequest result;
  result.set_bucket(GrpcBucketIdToName(request.bucket_name()));
  result.set_if_metageneration_match(request.metageneration());
  return result;
}

google::iam::v1::GetIamPolicyRequest ToProto(
    storage::internal::GetBucketIamPolicyRequest const& request) {
  google::iam::v1::GetIamPolicyRequest result;
  result.set_resource(GrpcBucketIdToName(request.bucket_name()));
  if (request.HasOption<storage::RequestedPolicyVersion>()) {
    result.mutable_options()->set_requested_policy_version(
        static_cast<std::int32_t>(
            request.GetOption<storage::RequestedPolicyVersion>().value()));
  }
  return result;
}

storage::NativeIamBinding FromProto(google::iam::v1::Binding const& b) {
  std::vector<std::string> members{b.members().begin(), b.members().end()};
  if (!b.has_condition()) return {b.role(), std::move(members)};
  storage::NativeExpression expr(
      b.condition().expression(), b.condition().title(),
      b.condition().description(), b.condition().location());
  return {b.role(), std::move(members), std::move(expr)};
}

storage::NativeIamPolicy FromProto(google::iam::v1::Policy const& response) {
  std::vector<storage::NativeIamBinding> bindings;
  std::transform(
      response.bindings().begin(), response.bindings().end(),
      std::back_inserter(bindings),
      [](google::iam::v1::Binding const& b) { return FromProto(b); });

  return storage::NativeIamPolicy(std::move(bindings), response.etag(),
                                  response.version());
}

google::iam::v1::SetIamPolicyRequest ToProto(
    storage::internal::SetNativeBucketIamPolicyRequest const& request) {
  google::iam::v1::SetIamPolicyRequest result;
  result.set_resource(GrpcBucketIdToName(request.bucket_name()));
  auto& policy = *result.mutable_policy();
  policy.set_version(request.policy().version());
  policy.set_etag(request.policy().etag());
  for (auto const& b : request.policy().bindings()) {
    google::iam::v1::Binding binding;
    binding.set_role(b.role());
    for (auto const& m : b.members()) binding.add_members(m);
    if (b.has_condition()) {
      auto& expr = *binding.mutable_condition();
      expr.set_expression(b.condition().expression());
      expr.set_location(b.condition().location());
      expr.set_title(b.condition().title());
      expr.set_description(b.condition().description());
    }
    *policy.add_bindings() = std::move(binding);
  }
  return result;
}

google::iam::v1::TestIamPermissionsRequest ToProto(
    storage::internal::TestBucketIamPermissionsRequest const& request) {
  google::iam::v1::TestIamPermissionsRequest result;
  result.set_resource(GrpcBucketIdToName(request.bucket_name()));
  for (auto const& p : request.permissions()) {
    result.add_permissions(p);
  }
  return result;
}

storage::internal::TestBucketIamPermissionsResponse FromProto(
    google::iam::v1::TestIamPermissionsResponse const& response) {
  storage::internal::TestBucketIamPermissionsResponse result;
  for (auto const& p : response.permissions()) {
    result.permissions.push_back(p);
  }
  return result;
}

StatusOr<google::storage::v2::UpdateBucketRequest> ToProto(
    storage::internal::PatchBucketRequest const& request) {
  google::storage::v2::UpdateBucketRequest result;

  auto& bucket = *result.mutable_bucket();
  bucket.set_name(GrpcBucketIdToName(request.bucket()));

  // The `labels` field is too special, handle separately.
  auto const& subpatch =
      storage::internal::PatchBuilderDetails::GetLabelsSubPatch(
          request.patch());
  if (subpatch.is_null()) {
    bucket.clear_labels();
    result.mutable_update_mask()->add_paths("labels");
  } else {
    // The semantics in gRPC are to replace any labels.
    for (auto const& kv : subpatch.items()) {
      result.mutable_update_mask()->add_paths("labels." + kv.key());
      auto const& v = kv.value();
      if (!v.is_string()) continue;
      (*bucket.mutable_labels())[kv.key()] = v.get<std::string>();
    }
  }

  // This struct and the vector refactors some common code to create patches for
  // each field.
  struct Field {
    std::string name;
    std::string rename;
    std::function<Status(Bucket&, nlohmann::json const&)> action;
  } fields[] = {
      // To ease inspection, the fields appear in the same order as they are
      // declared in the proto
      {"softDeletePolicy", "soft_delete_policy", PatchSoftDeletePolicy},
      {"storageClass", "storage_class", PatchStorageClass},
      {"rpo", "", PatchRpo},
      {"acl", "", PatchAcl},
      {"defaultObjectAcl", "default_object_acl", PatchDefaultObjectAcl},
      {"lifecycle", "", PatchLifecycle},
      {"cors", "", PatchCors},
      {"defaultEventBasedHold", "default_event_based_hold",
       PatchEventBasedHold},
      {"website", "", PatchWebsite},
      {"versioning", "", PatchVersioning},
      {"logging", "", PatchLogging},
      {"encryption", "", PatchEncryption},
      {"billing", "", PatchBilling},
      {"retentionPolicy", "retention_policy", PatchRetentionPolicy},
      {"iamConfiguration", "iam_config", PatchIamConfig},
      {"autoclass", "", PatchAutoclass},
  };

  auto const& patch =
      storage::internal::PatchBuilderDetails::GetPatch(request.patch());
  for (auto const& field : fields) {
    if (!patch.contains(field.name)) continue;
    auto status = field.action(bucket, patch[field.name]);
    if (!status.ok()) return status;
    result.mutable_update_mask()->add_paths(
        field.rename.empty() ? field.name : field.rename);
  }

  if (request.HasOption<storage::IfMetagenerationMatch>()) {
    result.set_if_metageneration_match(
        request.GetOption<storage::IfMetagenerationMatch>().value());
  }
  if (request.HasOption<storage::IfMetagenerationNotMatch>()) {
    result.set_if_metageneration_not_match(
        request.GetOption<storage::IfMetagenerationNotMatch>().value());
  }
  if (request.HasOption<storage::PredefinedAcl>()) {
    result.set_predefined_acl(
        request.GetOption<storage::PredefinedAcl>().value());
  }
  if (request.HasOption<storage::PredefinedDefaultObjectAcl>()) {
    result.set_predefined_default_object_acl(
        request.GetOption<storage::PredefinedDefaultObjectAcl>().value());
  }

  return result;
}

google::storage::v2::UpdateBucketRequest ToProto(
    storage::internal::UpdateBucketRequest const& request) {
  google::storage::v2::UpdateBucketRequest result;

  auto& bucket = *result.mutable_bucket();
  auto const& metadata = request.metadata();
  bucket.set_name(GrpcBucketIdToName(metadata.name()));

  // We set the update_mask for all fields, even if not present in `metadata` as
  // "not present" implies the field should be cleared.

  result.mutable_update_mask()->add_paths("storage_class");
  bucket.set_storage_class(metadata.storage_class());
  result.mutable_update_mask()->add_paths("rpo");
  bucket.set_rpo(metadata.rpo());
  result.mutable_update_mask()->add_paths("acl");
  UpdateAcl(bucket, metadata);
  result.mutable_update_mask()->add_paths("default_object_acl");
  UpdateDefaultObjectAcl(bucket, metadata);
  result.mutable_update_mask()->add_paths("lifecycle");
  UpdateLifecycle(bucket, metadata);
  result.mutable_update_mask()->add_paths("cors");
  UpdateCors(bucket, metadata);
  result.mutable_update_mask()->add_paths("default_event_based_hold");
  bucket.set_default_event_based_hold(metadata.default_event_based_hold());
  result.mutable_update_mask()->add_paths("labels");
  UpdateLabels(bucket, metadata);
  result.mutable_update_mask()->add_paths("website");
  UpdateWebsite(bucket, metadata);
  result.mutable_update_mask()->add_paths("versioning");
  UpdateVersioning(bucket, metadata);
  result.mutable_update_mask()->add_paths("logging");
  UpdateLogging(bucket, metadata);
  result.mutable_update_mask()->add_paths("encryption");
  UpdateEncryption(bucket, metadata);
  result.mutable_update_mask()->add_paths("billing");
  UpdateBilling(bucket, metadata);
  result.mutable_update_mask()->add_paths("retention_policy");
  UpdateRetentionPolicy(bucket, metadata);
  result.mutable_update_mask()->add_paths("iam_config");
  UpdateIamConfig(bucket, metadata);
  result.mutable_update_mask()->add_paths("autoclass");
  UpdateAutoclass(bucket, metadata);
  result.mutable_update_mask()->add_paths("soft_delete_policy");
  UpdateSoftDeletePolicy(bucket, metadata);

  if (request.HasOption<storage::IfMetagenerationMatch>()) {
    result.set_if_metageneration_match(
        request.GetOption<storage::IfMetagenerationMatch>().value());
  }
  if (request.HasOption<storage::IfMetagenerationNotMatch>()) {
    result.set_if_metageneration_not_match(
        request.GetOption<storage::IfMetagenerationNotMatch>().value());
  }
  if (request.HasOption<storage::PredefinedAcl>()) {
    result.set_predefined_acl(
        request.GetOption<storage::PredefinedAcl>().value());
  }
  if (request.HasOption<storage::PredefinedDefaultObjectAcl>()) {
    result.set_predefined_default_object_acl(
        request.GetOption<storage::PredefinedDefaultObjectAcl>().value());
  }

  return result;
}

GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END
}  // namespace storage_internal
}  // namespace cloud
}  // namespace google