use super::reflection::AnnotationCoordinates;
use crate::blueprint::ErrorHandler;
use crate::blueprint::conversions::coordinates2coordinates;
use pavex_bp_schema::{Blueprint as BlueprintSchema, Component, Location};
pub struct PreProcessingMiddleware {
#[doc(hidden)]
pub coordinates: AnnotationCoordinates,
}
pub struct RegisteredPreProcessingMiddleware<'a> {
pub(crate) blueprint: &'a mut BlueprintSchema,
pub(crate) component_id: usize,
}
impl RegisteredPreProcessingMiddleware<'_> {
#[track_caller]
pub fn error_handler(mut self, error_handler: ErrorHandler) -> Self {
let error_handler = pavex_bp_schema::ErrorHandler {
coordinates: coordinates2coordinates(error_handler.coordinates),
registered_at: Location::caller(),
};
self.pre_processing_middleware().error_handler = Some(error_handler);
self
}
fn pre_processing_middleware(&mut self) -> &mut pavex_bp_schema::PreProcessingMiddleware {
let component = &mut self.blueprint.components[self.component_id];
let Component::PreProcessingMiddleware(c) = component else {
unreachable!("The component should be a pre-processing middleware")
};
c
}
}