Struct WebsocketServer

pub struct WebsocketServer {
    pub auth_controller: Arc<dyn AuthController>,
    pub handlers: HashMap<u32, WsEndpoint>,
    pub allowed_roles: HashMap<u32, Option<HashSet<u32>>>,
    pub message_receiver: Option<Receiver<ConnectionId>>,
    pub toolbox: ArcToolbox,
    pub config: WsServerConfig,
}

Fields

auth_controller: Arc<dyn AuthController>

handlers: HashMap<u32, WsEndpoint>

allowed_roles: HashMap<u32, Option<HashSet<u32>>>

message_receiver: Option<Receiver<ConnectionId>>

toolbox: ArcToolbox

config: WsServerConfig

Implementations

impl WebsocketServer

pub fn new(config: WsServerConfig) -> Self

pub fn set_auth_controller(&mut self, controller: impl AuthController + 'static)

pub fn add_handler<T: RequestHandler + 'static>(&mut self, handler: T)

pub fn add_handler_erased( &mut self, schema: EndpointSchema, roles: Option<&[u32]>, handler: Arc<dyn RequestHandlerErased>, )

pub async fn handle_session_connection<S: AsyncRead + AsyncWrite + Unpin + Send + 'static>( self: Arc<Self>, conn: Arc<WsConnection>, states: Arc<WebsocketStates>, stream: WebSocketStream<S>, rx: Receiver<Message>, )

pub async fn listen(self) -> Result<()>

pub fn dump_schemas(&self) -> Result<()>