Cosmos.Storage.Abstractions 0.2.0

Cosmos.Storage.Abstractions

Puertos agnósticos de object storage y la capa transaccional. No referencia ningún SDK de nube (su única dependencia es Microsoft.Extensions.DependencyInjection.Abstractions, para el registro DI).

Contratos

• IStorageProvider — upload / download / delete / exists / metadata / URL temporal de descarga. Cada proveedor (Azure Blob, S3, GCS, in-memory) lo implementa en su propio paquete.
• ITransactionalStorageProvider : IStorageProvider — añade semántica de unit-of-work: RollbackAsync (deshace los uploads del scope) y Commit (los confirma).
• Modelos: UploadOptions, UploadResult, DownloadResult, ObjectMetadata, DownloadUrlOptions.

Depende solo de Cosmos.Storage.Types (para StorageInfo).

Decorator transaccional

TransactionalStorageProvider es un decorator de IStorageProvider con semántica de unit-of-work: rastrea los objetos subidos en el scope actual y permite deshacerlos (RollbackAsync) si la operación de negocio falla, o confirmarlos (Commit) si tiene éxito. Es agnóstico del proveedor —envuelve cualquier IStorageProvider— y no depende de ningún SDK de nube ni de Wolverine/Marten.

Por qué existe

El blob vive fuera de la transacción de base de datos, así que la unit-of-work de Marten/Wolverine no lo cubre. Si el comando de negocio falla después de subir un archivo, el blob queda huérfano. El decorator rastrea los uploads del scope para poder compensarlos.

El rollback está pensado para dispararse desde un middleware del host ante una excepción, no a mano por el handler.

Nota: el rollback es compensatorio y best-effort (DeleteAsync idempotente). Si el proceso muere a mitad del rollback pueden quedar huérfanos; la red de seguridad para eso es una lifecycle policy / GC sweep del lado de infraestructura, no este paquete.

Registro

AgregarStorageTransaccional() registra ITransactionalStorageProvider como decorator Scoped sobre el IStorageProvider ya registrado. Llamarlo después del provider concreto:

services.AgregarAzureBlobStorage(connectionString); // u otro provider de IStorageProvider
services.AgregarStorageTransaccional();             // registra ITransactionalStorageProvider (Scoped)

El host inyecta ITransactionalStorageProvider, sube archivos durante el scope, y un middleware llama a Commit() al éxito o RollbackAsync() ante excepción.