Struct Storage 

pub struct Storage { /* private fields */ }

The storage facade: a service + connection + signer with high-level helpers.

Implementations

impl Storage

pub fn new( conn: DatabaseConnection, service: Arc<dyn Service>, signer: Signer, ) -> Self

Build a storage facade from an explicit service and signer.

pub async fn from_config(conn: DatabaseConnection) -> Result<Self>

Build from the storage config section (current environment) plus a signer read from DOIDO_SECRET_KEY_BASE.

pub fn with_prefix(self, prefix: impl Into<String>) -> Self

Override the URL route prefix (default /doido/storage).

pub fn with_expiry(self, expires_in: Duration) -> Self

Override how long generated URLs stay valid (default 5 minutes).

pub fn conn(&self) -> &DatabaseConnection

The sea-orm connection.

pub fn service(&self) -> &Arc<dyn Service>

The active storage service.

pub fn prefix(&self) -> &str

The route prefix used by crate::serving::routes.

pub async fn ensure_tables(&self) -> Result<()>

Create the metadata tables if they don’t exist (test/dev convenience).

pub async fn create_and_upload( &self, filename: &str, data: Vec<u8>, metadata: Option<Value>, ) -> Result<Blob>

Upload data to the service and record a blob. Detects content type, computes the MD5 checksum and byte size.

pub async fn find_blob(&self, key: &str) -> Result<Option<Blob>>

Find a blob by key.

pub async fn download(&self, key: &str) -> Result<Vec<u8>>

Download a blob’s bytes.

pub async fn purge(&self, key: &str) -> Result<()>

Delete a blob everywhere: the service object, its attachment rows, and the metadata row.

pub async fn attach_upload( &self, record_type: &str, record_id: &str, name: &str, filename: &str, data: Vec<u8>, ) -> Result<Blob>

Upload a file and attach it to record under name (append — for has_many). Returns the new blob.

pub async fn attach( &self, record_type: &str, record_id: &str, name: &str, blob_key: &str, ) -> Result<()>

Attach an existing blob to record under name (append).

pub async fn one( &self, record_type: &str, record_id: &str, name: &str, ) -> Result<Option<Blob>>

has_one_attached: the attached blob, if any.

pub async fn many( &self, record_type: &str, record_id: &str, name: &str, ) -> Result<Vec<Blob>>

has_many_attached: all attached blobs.

pub async fn detach( &self, record_type: &str, record_id: &str, name: &str, ) -> Result<()>

Detach (but don’t purge) everything in the name slot.

pub async fn purge_for_record( &self, record_type: &str, record_id: &str, ) -> Result<()>

Purge every blob attached to a record (the dependent: :purge default), then remove the attachment rows. Call from a model’s after-destroy hook.

pub fn signed_id(&self, key: &str) -> String

A permanent signed id for a blob key (Rails blob.signed_id).

pub fn verify_signed_id(&self, signed_id: &str) -> Result<String>

Resolve a signed id back to a blob key, erroring if tampered/expired.

pub fn redirect_path(&self, blob: &Blob) -> String

The redirect URL for a blob ({prefix}/blobs/redirect/{signed_id}/{filename}) — the stable URL to put in HTML. The redirect handler 302s to the service’s native URL (S3/Azure) or to the proxy route (disk/memory).

pub fn proxy_path(&self, blob: &Blob) -> String

The proxy URL for a blob (streams through the app).

pub async fn url_for( &self, blob: &Blob, disposition: Disposition, ) -> Result<String>

A URL a client can GET to fetch the object: the service’s native (presigned/public) URL if it has one, else the proxy route.

Trait Implementations

impl Clone for Storage

fn clone(&self) -> Storage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.