Struct StorageEngine 

pub struct StorageEngine { /* private fields */ }

Thread-safe, lazily-initialised storage engine.

The engine owns the ObjectStore adapter and exposes the asset-ingestion pipeline. It is Send + Sync and designed to be stored in a global OnceLock so that FFI bindings can access it without constructing their own instance.

Implementations

impl StorageEngine

pub fn from_env() -> StorageResult<Self>

Construct the engine from environment variables.

Environment Variables

Variable	Used by	Purpose
NAP_STORAGE_BACKEND	both	local (default) or s3
NAP_DIR	local	Base directory (default: ~/.nap)
NAP_S3_BUCKET	s3	S3 bucket name (required)
AWS_ACCESS_KEY_ID	s3	AWS / R2 access key
AWS_SECRET_ACCESS_KEY	s3	AWS / R2 secret key
AWS_REGION	s3	AWS region (e.g. us-east-1)
AWS_ENDPOINT_URL_S3	s3	Custom S3 endpoint (R2, MinIO)
AWS_ENDPOINT_URL	s3	Fallback if AWS_ENDPOINT_URL_S3 unset

pub fn config(&self) -> &StorageConfig

Return the active configuration.

pub fn store(&self) -> &dyn ObjectStore

Return a reference to the underlying ObjectStore.

pub async fn ingest_media( &self, data: &[u8], format: &str, ) -> StorageResult<String>

Ingest media bytes into the content-addressed store.

This is the core ingestion pipeline:

1. Hash — Compute blake3:<hex> from the byte slice.
2. Idempotency check — Send a HEAD request to see if the blob already exists. If it does, return the hash immediately without any network / disk write.
3. PUT — Upload the bytes as <hex>.<format> under the assets prefix (.nap-assets/ for both backends).

Arguments

• data — Raw media bytes (image, audio, mesh, etc.).
• format — File extension without leading dot (e.g. "png", "jpg", "wav", "glb").

Returns

The content-addressed hash string blake3:<hex>.