feature: Implement the create bucket gRPC request

pull/24376/head
Carol (Nichols || Goulding) 2020-04-03 09:11:08 -04:00
parent db950b4aee
commit db0942c861
1 changed files with 14 additions and 1 deletions

View File

@ -28,8 +28,21 @@ pub struct GrpcServer {
impl Delorean for GrpcServer {
async fn create_bucket(
&self,
_req: tonic::Request<CreateBucketRequest>,
req: tonic::Request<CreateBucketRequest>,
) -> Result<tonic::Response<CreateBucketResponse>, Status> {
let create_bucket_request = req.into_inner();
let org_id = create_bucket_request.org_id;
let bucket = create_bucket_request
.bucket
.ok_or_else(|| Status::invalid_argument("missing bucket argument"))?;
self.app
.db
.create_bucket_if_not_exists(org_id, bucket)
.await
.map_err(|err| Status::internal(format!("error creating bucket: {}", err)))?;
Ok(tonic::Response::new(CreateBucketResponse {}))
}