cloudillo-types 0.8.13

// SPDX-FileCopyrightText: Szilárd Hajba
// SPDX-License-Identifier: LGPL-3.0-or-later

//! Adapter that manages and stores blobs (immutable file data)
use async_trait::async_trait;
use axum::body::Bytes;
use futures_core::Stream;
use std::{fmt::Debug, pin::Pin};
use tokio::io::AsyncRead;

use crate::prelude::*;

#[derive(Clone, Default)]
pub struct CreateBlobOptions {}

pub struct BlobStat {
	pub size: u64,
}

#[async_trait]
pub trait BlobAdapter: Debug + Send + Sync {
	/// Creates a new blob from a buffer
	async fn create_blob_buf(
		&self,
		tn_id: TnId,
		file_id: &str,
		data: &[u8],
		opts: &CreateBlobOptions,
	) -> ClResult<()>;

	/// Creates a new blob using a stream
	async fn create_blob_stream(
		&self,
		tn_id: TnId,
		file_id: &str,
		stream: &mut (dyn AsyncRead + Send + Unpin),
	) -> ClResult<()>;

	/// Stats a blob
	async fn stat_blob(&self, tn_id: TnId, blob_id: &str) -> Option<u64>;

	/// Reads a blob
	async fn read_blob_buf(&self, tn_id: TnId, blob_id: &str) -> ClResult<Box<[u8]>>;

	/// Reads a byte range from a blob
	async fn read_blob_range(
		&self,
		tn_id: TnId,
		blob_id: &str,
		offset: u64,
		length: u64,
	) -> ClResult<Box<[u8]>>;

	/// Reads a blob
	async fn read_blob_stream(
		&self,
		tn_id: TnId,
		blob_id: &str,
	) -> ClResult<Pin<Box<dyn Stream<Item = Result<Bytes, std::io::Error>> + Send>>>;

	/// Creates a new blob by copying a file from a local path (no memory allocation)
	async fn create_blob_from_path(
		&self,
		tn_id: TnId,
		file_id: &str,
		source: &std::path::Path,
		opts: &CreateBlobOptions,
	) -> ClResult<()>;

	/// Delete every blob owned by the tenant. Treats a missing tenant directory
	/// as success. Used by tenant purge orchestration.
	async fn delete_tenant_blobs(&self, tn_id: TnId) -> ClResult<()>;
}

// vim: ts=4