ankurah-websocket-server 0.7.13

use ankurah_core::connector::SendError;
use ankurah_proto as proto;
use axum::extract::ws::WebSocket;
use futures_util::stream::SplitSink;

pub enum Connection {
    Initial(Option<SplitSink<WebSocket, axum::extract::ws::Message>>),
    Established(super::sender::WebSocketClientSender),
}

impl Connection {
    pub async fn send(&mut self, message: proto::Message) -> Result<(), SendError> {
        match self {
            Connection::Initial(sender) => {
                if let Ok(data) = bincode::serialize(&message) {
                    use futures_util::SinkExt;
                    if let Some(sender) = sender.as_mut() {
                        sender.send(axum::extract::ws::Message::Binary(data.into())).await.map_err(|_| SendError::Unknown)?;
                        Ok(())
                    } else {
                        Err(SendError::Unknown)
                    }
                } else {
                    Err(SendError::Other(anyhow::anyhow!("Serialization error")))
                }
            }
            Connection::Established(peer_sender) => peer_sender.send_message(message),
        }
    }
}