use libp2p::core::multiaddr;
use nym_sphinx::addressing::clients::RecipientFormattingError;

use super::message::SubstreamId;

#[derive(Debug, thiserror::Error)]
pub enum Error {
    #[error("unimplemented")]
    Unimplemented,
    #[error("failed to format multiaddress from nym address")]
    FailedToFormatMultiaddr(#[from] multiaddr::Error),
    #[error("unexpected protocol in multiaddress")]
    InvalidProtocolForMultiaddr,
    #[error("failed to decode message")]
    InvalidMessageBytes,
    #[error("no connection found for ConnectionResponse")]
    NoConnectionForResponse,
    #[error("received ConnectionResponse but connection was already established")]
    ConnectionAlreadyEstablished,
    #[error("received None recipient in ConnectionRequest")]
    NoneRecipientInConnectionRequest,
    #[error("cannot handle connection request; already have connection with given ID")]
    ConnectionIDExists,
    #[error("no connection found for TransportMessage")]
    NoConnectionForTransportMessage,
    #[error("failed to decode ConnectionMessage; too short")]
    ConnectionMessageBytesTooShort,
    #[error("failed to decode ConnectionMessage; no recipient")]
    ConnectionMessageBytesNoRecipient,
    #[error("failed to decode ConnectionMessage; no peer ID")]
    ConnectionMessageBytesNoPeerId,
    #[error("invalid peer ID bytes")]
    InvalidPeerIdBytes,
    #[error("invalid recipient bytes")]
    InvalidRecipientBytes(#[from] RecipientFormattingError),
    #[error("invalid recipient prefix byte")]
    InvalidRecipientPrefixByte,
    #[error("failed to decode TransportMessage; too short")]
    TransportMessageBytesTooShort,
    #[error("failed to decode TransportMessage; invalid nonce")]
    InvalidNonce,
    #[error("invalid substream ID")]
    InvalidSubstreamMessageBytes,
    #[error("invalid substream message type byte")]
    InvalidSubstreamMessageType,
    #[error("substrean with given ID already exists")]
    SubstreamIdExists(SubstreamId),
    #[error("no substream found for given ID")]
    SubstreamIdDoesNotExist(SubstreamId),
    #[error("recv error: channel closed")]
    OneshotRecvFailure(#[from] tokio::sync::oneshot::error::RecvError),
    #[error("recv error: channel closed")]
    RecvFailure,
    #[error("outbound send error")]
    OutboundSendFailure(String),
    #[error("inbound send error")]
    InboundSendFailure(String),
    #[error("failed to send new connection; receiver dropped")]
    ConnectionSendFailure,
    #[error("failed to send initial TransportEvent::NewAddress")]
    SendErrorTransportEvent,
    #[error("dial timed out")]
    DialTimeout(#[from] tokio::time::error::Elapsed),
}