CreateBuckets and DeleteBuckets #181
1 changed files with 6 additions and 2 deletions
|
@ -531,7 +531,9 @@ impl AdminRpcHandler {
|
||||||
.bucket_helper()
|
.bucket_helper()
|
||||||
.get_existing_matching_key(&query.key_pattern)
|
.get_existing_matching_key(&query.key_pattern)
|
||||||
.await?;
|
.await?;
|
||||||
|
if query.create_bucket {
|
||||||
key.params_mut().unwrap().allow_create_bucket.update(true);
|
key.params_mut().unwrap().allow_create_bucket.update(true);
|
||||||
|
}
|
||||||
self.garage.key_table.insert(&key).await?;
|
self.garage.key_table.insert(&key).await?;
|
||||||
self.key_info_result(key).await
|
self.key_info_result(key).await
|
||||||
}
|
}
|
||||||
|
@ -542,7 +544,9 @@ impl AdminRpcHandler {
|
||||||
.bucket_helper()
|
.bucket_helper()
|
||||||
.get_existing_matching_key(&query.key_pattern)
|
.get_existing_matching_key(&query.key_pattern)
|
||||||
.await?;
|
.await?;
|
||||||
|
if query.create_bucket {
|
||||||
key.params_mut().unwrap().allow_create_bucket.update(false);
|
key.params_mut().unwrap().allow_create_bucket.update(false);
|
||||||
|
}
|
||||||
self.garage.key_table.insert(&key).await?;
|
self.garage.key_table.insert(&key).await?;
|
||||||
self.key_info_result(key).await
|
self.key_info_result(key).await
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue