zerodds-corba-iiop 1.0.0-rc.1

// SPDX-License-Identifier: Apache-2.0
// Copyright 2026 ZeroDDS Contributors

//! IIOP-Transport-Fehler.

use alloc::string::String;

use zerodds_corba_giop::GiopError;

use crate::profile_body::CdrError;

/// IIOP-Transport-Fehler.
#[derive(Debug)]
pub enum IiopError {
    /// TCP-Bind oder TCP-Connect-Fehler.
    Io(std::io::Error),
    /// GIOP-Wire-Codec-Fehler.
    Giop(GiopError),
    /// CDR-Marshalling-Fehler in ProfileBody / BiDir.
    Cdr(CdrError),
    /// Connection wurde vom Peer geschlossen.
    Closed,
    /// Pool ist erschoepft (`max_connections` erreicht).
    PoolExhausted,
    /// Diagnose-Sammelnachricht.
    Other(String),
}

impl From<std::io::Error> for IiopError {
    fn from(e: std::io::Error) -> Self {
        Self::Io(e)
    }
}

impl From<GiopError> for IiopError {
    fn from(e: GiopError) -> Self {
        Self::Giop(e)
    }
}

impl From<CdrError> for IiopError {
    fn from(e: CdrError) -> Self {
        Self::Cdr(e)
    }
}

impl core::fmt::Display for IiopError {
    fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
        match self {
            Self::Io(e) => write!(f, "io error: {e}"),
            Self::Giop(e) => write!(f, "giop error: {e:?}"),
            Self::Cdr(e) => write!(f, "cdr error: {e:?}"),
            Self::Closed => write!(f, "connection closed by peer"),
            Self::PoolExhausted => write!(f, "connection pool exhausted"),
            Self::Other(s) => write!(f, "{s}"),
        }
    }
}

impl std::error::Error for IiopError {
    fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
        match self {
            Self::Io(e) => Some(e),
            _ => None,
        }
    }
}