Page MenuHomePhabricator
Files F3505733

D5702.id18917.diff
No OneTemporary
Actions

D5702.id18917.diff
View Options

diff --git a/services/blob/src/service.rs b/services/blob/src/service.rs
--- a/services/blob/src/service.rs
+++ b/services/blob/src/service.rs
@@ -144,8 +144,50 @@
async fn remove(
&self,
- _request: Request<blob::RemoveRequest>,
+ request: Request<blob::RemoveRequest>,
) -> Result<Response<()>, Status> {
- Err(Status::unimplemented("Not implemented yet"))
+ let message = request.into_inner();
+ let holder = message.holder.as_str();
+ let reverse_index_item = self
+ .db
+ .find_reverse_index_by_holder(holder)
+ .await
+ .map_err(|_| Status::aborted("Internal error"))?
+ .ok_or_else(|| Status::not_found("Blob not found"))?;
+ let blob_hash = &reverse_index_item.blob_hash;
+
+ if self.db.remove_reverse_index_item(holder).await.is_err() {
+ return Err(Status::aborted("Internal error"));
+ }
+
+ // TODO handle cleanup here properly
+ // for now the object's being removed right away
+ // after the last holder was removed
+ if self
+ .db
+ .find_reverse_index_by_hash(blob_hash)
+ .await
+ .map_err(|_| Status::aborted("Internal error"))?
+ .is_empty()
+ {
+ let s3_path = self
+ .find_s3_path_by_reverse_index(&reverse_index_item)
+ .await?;
+
+ self
+ .s3
+ .delete_object()
+ .bucket(&s3_path.bucket_name)
+ .key(&s3_path.object_name)
+ .send()
+ .await
+ .map_err(|_| Status::aborted("Internal error"))?;
+
+ if self.db.remove_blob_item(blob_hash).await.is_err() {
+ return Err(Status::aborted("Internal error"));
+ }
+ }
+
+ Ok(Response::new(()))
}
}

File Metadata

Mime Type
text/plain
Expires
Sat, Dec 21, 2:25 PM (19 h, 59 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2687481
Default Alt Text
D5702.id18917.diff (1 KB)

Event Timeline