hotfix 0.12.0

use crate::store::StoreError;
use hotfix_message::error::EncodingError;
use thiserror::Error;

#[derive(Debug, Error)]
pub enum SessionError {
    #[error("store operation failed")]
    Store(#[from] StoreError),
}

#[derive(Debug, Error)]
pub enum SessionCreationError {
    #[error("unsupported BeginString: {0}")]
    UnsupportedBeginString(String),

    #[error("dictionary failed to parse")]
    MalformedDictionary(#[from] hotfix_message::dict::ParseError),

    #[error("dictionary contents are invalid")]
    InvalidDictionary(#[from] hotfix_message::error::ParserError),

    #[error("schedule configuration is invalid: {0}")]
    InvalidSchedule(String),
}

/// Outcome of a successful message send operation.
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum SendOutcome {
    /// Message was persisted and sent with the given sequence number.
    Sent { sequence_number: u64 },
    /// Message was dropped by the application callback.
    Dropped,
}

/// Error that can occur when sending an outbound message to the session.
#[derive(Debug, Error)]
pub enum SendError {
    #[error("session is disconnected")]
    Disconnected,

    #[error("failed to persist message")]
    Persist(#[source] StoreError),

    #[error("failed to update sequence number")]
    SequenceNumber(#[source] StoreError),

    #[error("session terminated by application")]
    SessionTerminated,

    /// The session task is no longer running.
    #[error("session is no longer available")]
    SessionGone,
}

impl<T> From<tokio::sync::mpsc::error::SendError<T>> for SendError {
    fn from(_: tokio::sync::mpsc::error::SendError<T>) -> Self {
        SendError::SessionGone
    }
}

impl From<tokio::sync::oneshot::error::RecvError> for SendError {
    fn from(_: tokio::sync::oneshot::error::RecvError) -> Self {
        SendError::SessionGone
    }
}

/// Error that can occur when sending a message internally within the session.
///
/// This is a subset of `SendError` without `SessionTerminated` and `SessionGone`,
/// which only make sense in the context of the public API.
#[derive(Debug, Error)]
pub(crate) enum InternalSendError {
    #[error("failed to persist message")]
    Persist(#[source] StoreError),

    #[error("failed to update sequence number")]
    SequenceNumber(#[source] StoreError),
}

impl From<InternalSendError> for SendError {
    fn from(err: InternalSendError) -> Self {
        match err {
            InternalSendError::Persist(e) => SendError::Persist(e),
            InternalSendError::SequenceNumber(e) => SendError::SequenceNumber(e),
        }
    }
}

/// Error that can occur during internal session operations.
///
/// This replaces anyhow::Context wrapping with structured error variants.
#[derive(Debug, Error)]
pub(crate) enum SessionOperationError {
    /// Failed to send a message.
    #[error("failed to send {context}")]
    Send {
        #[source]
        source: InternalSendError,
        context: &'static str,
    },

    /// A store operation failed.
    #[error("store operation failed")]
    Store(#[from] StoreError),

    /// Failed to encode a message.
    #[error("failed to encode message")]
    MessageEncoding(#[from] EncodingError),

    /// Failed to parse a stored message.
    #[error("failed to parse stored message: {0}")]
    StoredMessageParse(String),

    /// A required field was missing from a message.
    #[error("missing required field: {0}")]
    MissingField(&'static str),
}

/// Extension trait to convert `Result<T, InternalSendError>` to `Result<T, SessionOperationError>`
/// with context about what send operation failed.
pub(crate) trait InternalSendResultExt<T> {
    fn with_send_context(self, context: &'static str) -> Result<T, SessionOperationError>;
}

impl<T> InternalSendResultExt<T> for Result<T, InternalSendError> {
    fn with_send_context(self, context: &'static str) -> Result<T, SessionOperationError> {
        self.map_err(|source| SessionOperationError::Send { source, context })
    }
}

/// Error returned when setting the next expected target sequence number via admin.
#[derive(Debug, Error)]
pub enum SetNextTargetSeqNumError {
    /// The session was not in a state where the target sequence number can be
    /// safely adjusted. Only permitted while `Disconnected`.
    #[error("operation rejected in state {current:?}; only permitted while disconnected")]
    InvalidState { current: crate::session::Status },

    /// Channel-level failure — the session task is gone or the responder was dropped.
    #[error(transparent)]
    Send(#[from] SendError),

    /// Underlying store write failed.
    #[error(transparent)]
    Store(#[from] StoreError),
}

#[cfg(test)]
mod tests {
    use super::*;

    fn test_store_error() -> StoreError {
        StoreError::Initialization("test".into())
    }

    #[test]
    fn mpsc_send_error_converts_to_session_gone() {
        let err: SendError = tokio::sync::mpsc::error::SendError(()).into();
        assert!(matches!(err, SendError::SessionGone));
    }

    #[tokio::test]
    async fn oneshot_recv_error_converts_to_session_gone() {
        let (tx, rx) = tokio::sync::oneshot::channel::<()>();
        drop(tx);
        // await the receiver to get RecvError (not TryRecvError)
        let recv_err = rx.await.unwrap_err();

        let err: SendError = recv_err.into();
        assert!(matches!(err, SendError::SessionGone));
    }

    #[test]
    fn internal_send_error_persist_converts_to_send_error() {
        let internal_err = InternalSendError::Persist(test_store_error());
        let send_err: SendError = internal_err.into();
        assert!(matches!(send_err, SendError::Persist(_)));
    }

    #[test]
    fn internal_send_error_sequence_number_converts_to_send_error() {
        let internal_err = InternalSendError::SequenceNumber(test_store_error());
        let send_err: SendError = internal_err.into();
        assert!(matches!(send_err, SendError::SequenceNumber(_)));
    }

    #[test]
    fn with_send_context_converts_error() {
        let result: Result<(), InternalSendError> =
            Err(InternalSendError::Persist(test_store_error()));

        let op_err = result.with_send_context("heartbeat").unwrap_err();
        match op_err {
            SessionOperationError::Send { context, .. } => {
                assert_eq!(context, "heartbeat");
            }
            _ => panic!("expected SessionOperationError::Send"),
        }
    }

    #[test]
    fn with_send_context_passes_through_ok() {
        let result: Result<u64, InternalSendError> = Ok(42);
        let op_result = result.with_send_context("heartbeat");
        assert_eq!(op_result.unwrap(), 42);
    }
}