Page MenuHomePhabricator
Files F3346824

D8456.diff
No OneTemporary
Actions

D8456.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
@@ -166,6 +166,61 @@
self.db.put_blob_item(blob_item).await?;
Ok(())
}
+
+ pub async fn assign_holder(
+ &self,
+ blob_hash: impl Into<String>,
+ holder: impl Into<String>,
+ ) -> BlobServiceResult<bool> {
+ let blob_hash: String = blob_hash.into();
+ trace!(blob_hash, "Attempting to assign holder");
+ self
+ .db
+ .put_holder_assignment(blob_hash.clone(), holder.into())
+ .await?;
+
+ trace!("Holder assigned. Checking if data exists");
+ let data_exists = self.db.get_blob_item(blob_hash).await?.is_some();
+ Ok(data_exists)
+ }
+
+ pub async fn revoke_holder(
+ &self,
+ blob_hash: impl Into<String>,
+ holder: impl Into<String>,
+ ) -> BlobServiceResult<()> {
+ let blob_hash: String = blob_hash.into();
+ let holder: String = holder.into();
+
+ trace!(blob_hash, holder, "Attempting to revoke holder");
+ self.db.delete_holder_assignment(&blob_hash, holder).await?;
+
+ if self.config.instant_delete_orphaned_blobs {
+ trace!("Instant orphan deletion enabled. Looking for holders");
+ let is_orphan = self
+ .db
+ .list_blob_holders(&blob_hash, Some(1))
+ .await?
+ .is_empty();
+ if !is_orphan {
+ trace!("Found holders, nothing to do");
+ return Ok(());
+ }
+
+ debug!("No holders left, deleting blob if exists");
+ trace!("Getting blob item");
+ let Some(blob_item) = self.db.get_blob_item(&blob_hash).await? else {
+ trace!("Blob item not found, nothing to do");
+ return Ok(())
+ };
+
+ trace!("Deleting S3 object");
+ self.s3.delete_object(&blob_item.s3_path).await?;
+ trace!("Deleting blob item entry from DB");
+ self.db.delete_blob_item(blob_hash).await?;
+ }
+ Ok(())
+ }
}
pub struct BlobDownloadObject {

File Metadata

Mime Type
text/plain
Expires
Sat, Nov 23, 9:58 AM (19 h, 2 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2570153
Default Alt Text
D8456.diff (1 KB)

Event Timeline