Armael/garage
1
0
Fork 0
forked from Deuxfleurs/garage
Code Pull requests Activity

refactor

Browse source
This commit is contained in:
Alex 2022-05-17 17:02:38 +02:00
parent 8b1338ef2f
commit e92c52eb65
Signed by untrusted user: lx
GPG key ID: 0E496D15096376BE
1 changed files with 9 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
src/api/admin/bucket.rs
View file

@ -103,18 +103,18 @@ pub async fn handle_get_bucket_info(
} }
}; };
bucket_info_results(garage, bucket_id).await
}
async fn bucket_info_results(
garage: &Arc<Garage>,
bucket_id: Uuid,
) -> Result<Response<Body>, Error> {
let bucket = garage let bucket = garage
.bucket_helper() .bucket_helper()
.get_existing_bucket(bucket_id) .get_existing_bucket(bucket_id)
.await?; .await?;
bucket_info_results(garage, bucket).await
}
async fn bucket_info_results(
garage: &Arc<Garage>,
bucket: Bucket,
) -> Result<Response<Body>, Error> {
let mut relevant_keys = HashMap::new(); let mut relevant_keys = HashMap::new();
for (k, _) in bucket for (k, _) in bucket
.state .state
@ -299,12 +299,7 @@ pub async fn handle_create_bucket(
} }
} }
let bucket = garage bucket_info_results(garage, bucket.id).await
.bucket_table
.get(&EmptyKey, &bucket.id)
.await?
.ok_or_internal_error("Bucket should now exist but doesn't")?;
bucket_info_results(garage, bucket).await
} }
#[derive(Deserialize)] #[derive(Deserialize)]
@ -425,12 +420,7 @@ pub async fn handle_bucket_change_key_perm(
.set_bucket_key_permissions(bucket.id, &key.key_id, perm) .set_bucket_key_permissions(bucket.id, &key.key_id, perm)
.await?; .await?;
let bucket = garage bucket_info_results(garage, bucket.id).await
.bucket_table
.get(&EmptyKey, &bucket.id)
.await?
.ok_or_internal_error("Bucket should now exist but doesn't")?;
bucket_info_results(garage, bucket).await
} }
#[derive(Deserialize)] #[derive(Deserialize)]