use onnx_ir_derive::NodeBuilder;
use crate::ir::{ArgType, Argument, Node, RawNode, TensorType};
use crate::processor::{
InputSpec, NodeProcessor, NodeSpec, OutputPreferences, OutputSpec, ProcessError, validate_opset,
};
#[derive(Debug, Clone, NodeBuilder)]
pub struct DetNode {
pub name: String,
pub inputs: Vec<Argument>,
pub outputs: Vec<Argument>,
}
pub(crate) struct DetProcessor;
impl NodeProcessor for DetProcessor {
type Config = ();
fn spec(&self) -> NodeSpec {
NodeSpec {
min_opset: 11,
max_opset: None,
inputs: InputSpec::Exact(1),
outputs: OutputSpec::Exact(1),
}
}
fn infer_types(
&self,
node: &mut RawNode,
opset: usize,
_output_preferences: &OutputPreferences,
) -> Result<(), ProcessError> {
validate_opset(opset, 11)?;
let (rank, dtype, static_shape) = match &node.inputs[0].ty {
ArgType::Tensor(tensor) => {
if tensor.rank < 2 {
return Err(ProcessError::Custom(format!(
"Det: input must have rank >= 2 (got rank {})",
tensor.rank
)));
}
if let Some(shape) = &tensor.static_shape {
let n = shape.len();
if let (Some(rows), Some(cols)) = (shape[n - 2], shape[n - 1])
&& rows != cols
{
return Err(ProcessError::Custom(format!(
"Det: input must be a square matrix, but last two dimensions are [{rows}, {cols}]"
)));
}
}
(tensor.rank, tensor.dtype, tensor.static_shape.clone())
}
_ => {
return Err(ProcessError::TypeMismatch {
expected: "Tensor".to_string(),
actual: format!("{:?}", node.inputs[0].ty),
});
}
};
if rank == 2 {
node.outputs[0].ty = ArgType::ScalarTensor(dtype);
} else {
let out_rank = rank - 2;
node.outputs[0].ty = ArgType::Tensor(TensorType {
dtype,
rank: out_rank,
static_shape: Some(
static_shape
.map(|s| s[..s.len() - 2].to_vec())
.unwrap_or_else(|| vec![None; out_rank]),
),
});
}
Ok(())
}
fn build_node(&self, builder: RawNode, _opset: usize) -> Node {
Node::Det(DetNode {
name: builder.name,
inputs: builder.inputs,
outputs: builder.outputs,
})
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::ir::{ArgType, DType, NodeType};
use crate::node::test_utils::TestNodeBuilder;
use crate::processor::OutputPreferences;
#[test]
fn test_det_2d_infer_types() {
let mut node = TestNodeBuilder::new(NodeType::Det, "test_det")
.input_tensor_f32("X", 2, None)
.output_tensor_f32("Y", 0, None)
.build();
let processor = DetProcessor;
let prefs = OutputPreferences::new();
processor.infer_types(&mut node, 11, &prefs).unwrap();
assert!(matches!(
node.outputs[0].ty,
ArgType::ScalarTensor(DType::F32)
));
}
#[test]
fn test_det_3d_infer_types() {
let mut node = TestNodeBuilder::new(NodeType::Det, "test_det")
.input_tensor_f32("X", 3, None)
.output_tensor_f32("Y", 0, None)
.build();
let processor = DetProcessor;
let prefs = OutputPreferences::new();
processor.infer_types(&mut node, 11, &prefs).unwrap();
match &node.outputs[0].ty {
ArgType::Tensor(t) => {
assert_eq!(t.rank, 1);
assert_eq!(t.dtype, DType::F32);
}
_ => panic!("Expected Tensor output for 3D input"),
}
}
#[test]
fn test_det_4d_infer_types() {
let mut node = TestNodeBuilder::new(NodeType::Det, "test_det")
.input_tensor_f32("X", 4, None)
.output_tensor_f32("Y", 0, None)
.build();
let processor = DetProcessor;
let prefs = OutputPreferences::new();
processor.infer_types(&mut node, 11, &prefs).unwrap();
match &node.outputs[0].ty {
ArgType::Tensor(t) => {
assert_eq!(t.rank, 2);
assert_eq!(t.dtype, DType::F32);
}
_ => panic!("Expected Tensor output for 4D input"),
}
}
#[test]
fn test_det_f64_preserves_dtype() {
let mut node = TestNodeBuilder::new(NodeType::Det, "test_det")
.add_input(
"X",
ArgType::Tensor(TensorType {
dtype: DType::F64,
rank: 2,
static_shape: None,
}),
)
.output_tensor_f32("Y", 0, None)
.build();
let processor = DetProcessor;
let prefs = OutputPreferences::new();
processor.infer_types(&mut node, 11, &prefs).unwrap();
assert!(matches!(
node.outputs[0].ty,
ArgType::ScalarTensor(DType::F64)
));
}
#[test]
fn test_det_rank_too_low() {
let mut node = TestNodeBuilder::new(NodeType::Det, "test_det")
.input_tensor_f32("X", 1, None)
.output_tensor_f32("Y", 0, None)
.build();
let processor = DetProcessor;
let prefs = OutputPreferences::new();
let result = processor.infer_types(&mut node, 11, &prefs);
assert!(result.is_err());
}
#[test]
fn test_det_non_square_rejected() {
let mut node = TestNodeBuilder::new(NodeType::Det, "test_det")
.input_tensor_f32("X", 2, Some(vec![3, 4]))
.output_tensor_f32("Y", 0, None)
.build();
let processor = DetProcessor;
let prefs = OutputPreferences::new();
let result = processor.infer_types(&mut node, 11, &prefs);
assert!(result.is_err());
let err = result.unwrap_err().to_string();
assert!(
err.contains("square matrix"),
"Error should mention square matrix: {err}"
);
}
#[test]
fn test_det_static_shape_propagated() {
let mut node = TestNodeBuilder::new(NodeType::Det, "test_det")
.input_tensor_f32("X", 3, Some(vec![2, 3, 3]))
.output_tensor_f32("Y", 0, None)
.build();
let processor = DetProcessor;
let prefs = OutputPreferences::new();
processor.infer_types(&mut node, 11, &prefs).unwrap();
match &node.outputs[0].ty {
ArgType::Tensor(t) => {
assert_eq!(t.rank, 1);
assert_eq!(t.static_shape, Some(vec![Some(2)]));
}
_ => panic!("Expected Tensor output for 3D input"),
}
}
}