use super::*;
impl S3Service {
pub(crate) fn put_bucket_versioning(
&self,
account_id: &str,
req: &AwsRequest,
bucket: &str,
) -> Result<AwsResponse, AwsServiceError> {
let body_str = std::str::from_utf8(&req.body).unwrap_or("");
let status_val = extract_xml_value(body_str, "Status").unwrap_or_default();
let mut accts = self.state.write();
let state = accts.get_or_create(account_id);
let b = state
.buckets
.get_mut(bucket)
.ok_or_else(|| no_such_bucket(bucket))?;
if status_val == "Enabled" || status_val == "Suspended" {
b.versioning = Some(status_val);
}
let meta = bucket_meta_snapshot(b);
self.store
.put_bucket_meta(bucket, &meta)
.map_err(crate::service::persistence_error)?;
Ok(AwsResponse {
status: StatusCode::OK,
content_type: "application/xml".to_string(),
body: Bytes::new().into(),
headers: HeaderMap::new(),
})
}
pub(crate) fn get_bucket_versioning(
&self,
account_id: &str,
bucket: &str,
) -> Result<AwsResponse, AwsServiceError> {
let accts = self.state.read();
let __empty = crate::state::S3State::new(account_id, "us-east-1");
let state = accts.get(account_id).unwrap_or(&__empty);
let b = state
.buckets
.get(bucket)
.ok_or_else(|| no_such_bucket(bucket))?;
let status_xml = match &b.versioning {
Some(s) => format!("<Status>{s}</Status>"),
None => String::new(),
};
let body = format!(
"<?xml version=\"1.0\" encoding=\"UTF-8\"?>\
<VersioningConfiguration xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">\
{status_xml}\
</VersioningConfiguration>"
);
Ok(s3_xml(StatusCode::OK, body))
}
}