use std::sync::Arc; use http_body_util::BodyExt; use hyper::{Request, Response, StatusCode}; use garage_util::data::*; use garage_model::garage::Garage; use garage_model::s3::object_table::*; use crate::helpers::*; use crate::s3::api_server::{ReqBody, ResBody}; use crate::s3::error::*; use crate::s3::put::next_timestamp; use crate::s3::xml as s3_xml; use crate::signature::verify_signed_content; async fn handle_delete_internal( garage: &Garage, bucket_id: Uuid, key: &str, ) -> Result<(Uuid, Uuid), Error> { let object = garage .object_table .get(&bucket_id, &key.to_string()) .await? .ok_or(Error::NoSuchKey)?; // No need to delete let del_timestamp = next_timestamp(Some(&object)); let del_uuid = gen_uuid(); let deleted_version = object .versions() .iter() .rev() .find(|v| !matches!(&v.state, ObjectVersionState::Aborted)) .or_else(|| object.versions().iter().rev().next()); let deleted_version = match deleted_version { Some(dv) => dv.uuid, None => { warn!("Object has no versions: {:?}", object); Uuid::from([0u8; 32]) } }; let object = Object::new( bucket_id, key.into(), vec![ObjectVersion { uuid: del_uuid, timestamp: del_timestamp, state: ObjectVersionState::Complete(ObjectVersionData::DeleteMarker), }], ); garage.object_table.insert(&object).await?; Ok((deleted_version, del_uuid)) } pub async fn handle_delete( garage: Arc<Garage>, bucket_id: Uuid, key: &str, ) -> Result<Response<ResBody>, Error> { match handle_delete_internal(&garage, bucket_id, key).await { Ok(_) | Err(Error::NoSuchKey) => Ok(Response::builder() .status(StatusCode::NO_CONTENT) .body(empty_body()) .unwrap()), Err(e) => Err(e), } } pub async fn handle_delete_objects( garage: Arc<Garage>, bucket_id: Uuid, req: Request<ReqBody>, content_sha256: Option<Hash>, ) -> Result<Response<ResBody>, Error> { let body = BodyExt::collect(req.into_body()).await?.to_bytes(); if let Some(content_sha256) = content_sha256 { verify_signed_content(content_sha256, &body[..])?; } let cmd_xml = roxmltree::Document::parse(std::str::from_utf8(&body)?)?; let cmd = parse_delete_objects_xml(&cmd_xml).ok_or_bad_request("Invalid delete XML query")?; let mut ret_deleted = Vec::new(); let mut ret_errors = Vec::new(); for obj in cmd.objects.iter() { match handle_delete_internal(&garage, bucket_id, &obj.key).await { Ok((deleted_version, delete_marker_version)) => { if cmd.quiet { continue; } ret_deleted.push(s3_xml::Deleted { key: s3_xml::Value(obj.key.clone()), version_id: s3_xml::Value(hex::encode(deleted_version)), delete_marker_version_id: s3_xml::Value(hex::encode(delete_marker_version)), }); } Err(e) => { ret_errors.push(s3_xml::DeleteError { code: s3_xml::Value(e.aws_code().to_string()), key: Some(s3_xml::Value(obj.key.clone())), message: s3_xml::Value(format!("{}", e)), version_id: None, }); } } } let xml = s3_xml::to_xml_with_header(&s3_xml::DeleteResult { xmlns: (), deleted: ret_deleted, errors: ret_errors, })?; Ok(Response::builder() .header("Content-Type", "application/xml") .body(string_body(xml))?) } struct DeleteRequest { quiet: bool, objects: Vec<DeleteObject>, } struct DeleteObject { key: String, } fn parse_delete_objects_xml(xml: &roxmltree::Document) -> Option<DeleteRequest> { let mut ret = DeleteRequest { quiet: false, objects: vec![], }; let root = xml.root(); let delete = root.first_child()?; if !delete.has_tag_name("Delete") { return None; } for item in delete.children() { if item.has_tag_name("Object") { let key = item.children().find(|e| e.has_tag_name("Key"))?; let key_str = key.text()?; ret.objects.push(DeleteObject { key: key_str.to_string(), }); } else if item.has_tag_name("Quiet") { if item.text()? == "true" { ret.quiet = true; } else { ret.quiet = false; } } else { return None; } } Some(ret) }