Struct ProcessFileUseCase 

pub struct ProcessFileUseCase { /* private fields */ }

Use case for processing files through pipelines.

This is the core use case that orchestrates the entire file processing workflow, from loading the pipeline configuration through executing all stages and generating the output .adapipe file.

Implementations

impl ProcessFileUseCase

pub fn new( metrics_service: Arc<MetricsService>, observability_service: Arc<ObservabilityService>, pipeline_repository: Arc<SqlitePipelineRepository>, ) -> Self

Creates a new Process File use case.

Parameters

• metrics_service - Metrics collection service
• observability_service - Observability and health monitoring
• pipeline_repository - Repository for pipeline data access

pub async fn execute(&self, config: ProcessFileConfig) -> Result<()>

Executes the process file use case.

Processes an input file through a configured pipeline, generating an output .adapipe binary format file with comprehensive metadata.

Parameters

• config - Processing configuration (input, output, pipeline, options)

Processing Steps

1. Load Pipeline: Retrieve pipeline configuration from repository
2. Determine Chunk Size: Adaptive or user-specified chunk size
3. Determine Worker Count: Optimal parallelism for file size
4. Create Services: Instantiate compression, encryption, I/O services
5. Execute Pipeline: Process file through all configured stages
6. Collect Metrics: Track performance at each stage
7. Generate Output: Write .adapipe binary format with metadata
8. Report Results: Display comprehensive processing summary

Returns

• Ok(()) - File processed successfully
• Err(anyhow::Error) - Processing failed

Errors

Returns errors for:

• Input file not found or unreadable
• Pipeline not found in repository
• Processing stage failures
• Output file write errors
• Insufficient permissions