oar_ocr_core/models/rectification/

uvdoc.rs

//! UVDoc Document Rectification Model
//!
//! This module provides a pure implementation of the UVDoc model for document rectification.
//! The model takes distorted document images and outputs rectified (flattened) versions.

use crate::core::OCRError;
use crate::core::inference::{OrtInfer, TensorInput};
use crate::processors::{NormalizeImage, TensorLayout, UVDocPostProcess};
use image::{DynamicImage, RgbImage, imageops::FilterType};
use std::borrow::Cow;

type PreprocessResult = Result<(ndarray::Array4<f32>, Vec<(u32, u32)>), OCRError>;

/// Configuration for UVDoc model preprocessing.
#[derive(Debug, Clone)]
pub struct UVDocPreprocessConfig {
    /// Input shape [channels, height, width]
    pub rec_image_shape: [usize; 3],
}

impl Default for UVDocPreprocessConfig {
    fn default() -> Self {
        Self {
            rec_image_shape: [3, 512, 512],
        }
    }
}

/// Output from UVDoc model.
#[derive(Debug, Clone)]
pub struct UVDocModelOutput {
    /// Rectified images
    pub images: Vec<RgbImage>,
}

/// Pure UVDoc model implementation.
///
/// This model performs document rectification (unwarping) on distorted document images.
#[derive(Debug)]
pub struct UVDocModel {
    /// ONNX Runtime inference engine
    inference: OrtInfer,
    /// Image normalizer for preprocessing
    normalizer: NormalizeImage,
    /// UVDoc postprocessor for converting tensor to images
    postprocessor: UVDocPostProcess,
    /// Input shape [channels, height, width]
    rec_image_shape: [usize; 3],
}

impl UVDocModel {
    /// Creates a new UVDoc model.
    pub fn new(
        inference: OrtInfer,
        normalizer: NormalizeImage,
        postprocessor: UVDocPostProcess,
        rec_image_shape: [usize; 3],
    ) -> Self {
        Self {
            inference,
            normalizer,
            postprocessor,
            rec_image_shape,
        }
    }

    /// Preprocesses images for rectification.
    ///
    /// # Arguments
    ///
    /// * `images` - Input images to preprocess
    ///
    /// # Returns
    ///
    /// A tuple of (batch_tensor, original_sizes)
    pub fn preprocess(&self, images: Vec<RgbImage>) -> PreprocessResult {
        let image_refs: Vec<_> = images.iter().collect();
        self.preprocess_refs(&image_refs)
    }

    /// Preprocesses borrowed images without cloning full-resolution source pages.
    pub fn preprocess_refs(&self, images: &[&RgbImage]) -> PreprocessResult {
        let mut original_sizes = Vec::with_capacity(images.len());
        let mut processed_images = Vec::with_capacity(images.len());

        let target_height = self.rec_image_shape[1] as u32;
        let target_width = self.rec_image_shape[2] as u32;
        let should_resize = target_height > 0 && target_width > 0;

        for &img in images {
            let original_size = (img.width(), img.height());
            original_sizes.push(original_size);

            if should_resize && (img.width() != target_width || img.height() != target_height) {
                // Use cv2.INTER_LINEAR for UVDoc resize.
                let resized =
                    image::imageops::resize(img, target_width, target_height, FilterType::Triangle);
                processed_images.push(Cow::Owned(resized));
            } else {
                processed_images.push(Cow::Borrowed(img));
            }
        }

        // Normalize and convert to tensor
        let processed_refs: Vec<_> = processed_images.iter().map(Cow::as_ref).collect();
        let batch_tensor = self.normalizer.normalize_batch_refs(&processed_refs)?;

        Ok((batch_tensor, original_sizes))
    }

    /// Runs inference on the preprocessed batch.
    ///
    /// # Arguments
    ///
    /// * `batch_tensor` - Preprocessed batch tensor
    ///
    /// # Returns
    ///
    /// Model predictions as a 4D tensor
    pub fn infer(
        &self,
        batch_tensor: &ndarray::Array4<f32>,
    ) -> Result<ndarray::Array4<f32>, OCRError> {
        let input_name = self.inference.input_name();
        let inputs = vec![(input_name, TensorInput::Array4(batch_tensor))];

        let outputs = self
            .inference
            .infer(&inputs)
            .map_err(|e| OCRError::Inference {
                model_name: "UVDoc".to_string(),
                context: format!(
                    "failed to run inference on batch with shape {:?}",
                    batch_tensor.shape()
                ),
                source: Box::new(e),
            })?;

        let output = outputs
            .into_iter()
            .next()
            .ok_or_else(|| OCRError::InvalidInput {
                message: "UVDoc: no output returned from inference".to_string(),
            })?;

        output
            .1
            .try_into_array4_f32()
            .map_err(|e| OCRError::Inference {
                model_name: "UVDoc".to_string(),
                context: "failed to convert output to 4D array".to_string(),
                source: Box::new(e),
            })
    }

    /// Postprocesses model predictions to rectified images.
    ///
    /// # Arguments
    ///
    /// * `predictions` - Model predictions
    /// * `original_sizes` - Original image sizes (width, height)
    ///
    /// # Returns
    ///
    /// Rectified images resized to original dimensions
    pub fn postprocess(
        &self,
        predictions: &ndarray::Array4<f32>,
        original_sizes: &[(u32, u32)],
    ) -> Result<Vec<RgbImage>, OCRError> {
        // Use UVDocPostProcess to convert tensor to images
        let mut images =
            self.postprocessor
                .apply_batch(predictions)
                .map_err(|e| OCRError::ConfigError {
                    message: format!("Failed to postprocess rectification output: {}", e),
                })?;

        if images.len() != original_sizes.len() {
            return Err(OCRError::InvalidInput {
                message: format!(
                    "Mismatched rectification batch sizes: predictions={}, originals={}",
                    images.len(),
                    original_sizes.len()
                ),
            });
        }

        // Resize back to original dimensions
        for (img, &(orig_w, orig_h)) in images.iter_mut().zip(original_sizes) {
            if orig_w == 0 || orig_h == 0 {
                continue;
            }

            if img.width() != orig_w || img.height() != orig_h {
                // Use cv2.INTER_LINEAR for resizing outputs back to original size.
                let resized = DynamicImage::ImageRgb8(std::mem::take(img)).resize_exact(
                    orig_w,
                    orig_h,
                    FilterType::Triangle,
                );
                *img = resized.into_rgb8();
            }
        }

        Ok(images)
    }

    /// Performs complete forward pass: preprocess -> infer -> postprocess.
    ///
    /// # Arguments
    ///
    /// * `images` - Input images to rectify
    ///
    /// # Returns
    ///
    /// UVDocModelOutput containing rectified images
    pub fn forward(&self, images: Vec<RgbImage>) -> Result<UVDocModelOutput, OCRError> {
        let image_refs: Vec<_> = images.iter().collect();
        self.forward_refs(&image_refs)
    }

    /// Runs rectification on borrowed images without cloning shared page buffers.
    pub fn forward_refs(&self, images: &[&RgbImage]) -> Result<UVDocModelOutput, OCRError> {
        let (batch_tensor, original_sizes) = self.preprocess_refs(images)?;
        let predictions = self.infer(&batch_tensor)?;
        let rectified_images = self.postprocess(&predictions, &original_sizes)?;

        Ok(UVDocModelOutput {
            images: rectified_images,
        })
    }
}

/// Builder for UVDoc model.
#[derive(Debug, Default)]
pub struct UVDocModelBuilder {
    /// Preprocessing configuration
    preprocess_config: UVDocPreprocessConfig,
    /// ONNX Runtime session configuration
    ort_config: Option<crate::core::config::OrtSessionConfig>,
}

impl UVDocModelBuilder {
    /// Creates a new UVDoc model builder.
    pub fn new() -> Self {
        Self {
            preprocess_config: UVDocPreprocessConfig::default(),
            ort_config: None,
        }
    }

    /// Sets the preprocessing configuration.
    pub fn preprocess_config(mut self, config: UVDocPreprocessConfig) -> Self {
        self.preprocess_config = config;
        self
    }

    /// Sets the input image shape.
    pub fn rec_image_shape(mut self, shape: [usize; 3]) -> Self {
        self.preprocess_config.rec_image_shape = shape;
        self
    }

    /// Sets the ONNX Runtime session configuration.
    pub fn with_ort_config(mut self, config: crate::core::config::OrtSessionConfig) -> Self {
        self.ort_config = Some(config);
        self
    }

    /// Builds the UVDoc model.
    ///
    /// # Arguments
    ///
    /// * `model_source` - Path to the ONNX model file
    ///
    /// # Returns
    ///
    /// A configured UVDoc model instance
    pub fn build(
        self,
        model_source: impl Into<crate::core::ModelSource>,
    ) -> Result<UVDocModel, OCRError> {
        // Create ONNX inference engine
        let inference = if self.ort_config.is_some() {
            use crate::core::config::ModelInferenceConfig;
            let common_config = ModelInferenceConfig {
                ort_session: self.ort_config,
                ..Default::default()
            };
            OrtInfer::from_config(&common_config, model_source, Some("image"))?
        } else {
            OrtInfer::new(model_source, Some("image"))?
        };

        // Create normalizer (scale to [0, 1] without mean shift).
        let normalizer = NormalizeImage::with_color_order(
            Some(1.0 / 255.0),
            Some(vec![0.0, 0.0, 0.0]),
            Some(vec![1.0, 1.0, 1.0]),
            Some(TensorLayout::CHW),
            Some(crate::processors::types::ColorOrder::BGR),
        )?;

        // Create postprocessor
        let postprocessor = UVDocPostProcess::new(255.0);

        Ok(UVDocModel::new(
            inference,
            normalizer,
            postprocessor,
            self.preprocess_config.rec_image_shape,
        ))
    }
}