diff options
Diffstat (limited to 'src/model/bucket_helper.rs')
-rw-r--r-- | src/model/bucket_helper.rs | 63 |
1 files changed, 0 insertions, 63 deletions
diff --git a/src/model/bucket_helper.rs b/src/model/bucket_helper.rs deleted file mode 100644 index b55ebc4b..00000000 --- a/src/model/bucket_helper.rs +++ /dev/null @@ -1,63 +0,0 @@ -use garage_util::data::*; -use garage_util::error::*; - -use garage_table::util::EmptyKey; - -use crate::bucket_table::Bucket; -use crate::garage::Garage; - -pub struct BucketHelper<'a>(pub(crate) &'a Garage); - -impl<'a> BucketHelper<'a> { - #[allow(clippy::ptr_arg)] - pub async fn resolve_global_bucket_name( - &self, - bucket_name: &String, - ) -> Result<Option<Uuid>, Error> { - // Bucket names in Garage are aliases, true bucket identifiers - // are 32-byte UUIDs. This function resolves bucket names into - // their full identifier by looking up in the bucket_alias_table. - // This function also allows buckets to be identified by their - // full UUID (hex-encoded). Here, if the name to be resolved is a - // hex string of the correct length, it is directly parsed as a bucket - // identifier which is returned. There is no risk of this conflicting - // with an actual bucket name: bucket names are max 63 chars long by - // the AWS spec, and hex-encoded UUIDs are 64 chars long. - let hexbucket = hex::decode(bucket_name.as_str()) - .ok() - .map(|by| Uuid::try_from(&by)) - .flatten(); - if let Some(bucket_id) = hexbucket { - Ok(self - .0 - .bucket_table - .get(&bucket_id, &EmptyKey) - .await? - .filter(|x| !x.state.is_deleted()) - .map(|_| bucket_id)) - } else { - Ok(self - .0 - .bucket_alias_table - .get(&EmptyKey, bucket_name) - .await? - .map(|x| x.state.get().as_option().map(|x| x.bucket_id)) - .flatten()) - } - } - - pub async fn get_existing_bucket(&self, bucket_id: Uuid) -> Result<Bucket, Error> { - self.0 - .bucket_table - .get(&bucket_id, &EmptyKey) - .await? - .filter(|b| !b.is_deleted()) - .map(Ok) - .unwrap_or_else(|| { - Err(Error::BadRpc(format!( - "Bucket {:?} does not exist", - bucket_id - ))) - }) - } -} |