Struct AuthenticatedConnection 

pub struct AuthenticatedConnection { /* private fields */ }

Authenticated WebSocket connection wrapper

Examples

use reinhardt_websockets::auth::{AuthenticatedConnection, SimpleAuthUser};
use reinhardt_websockets::WebSocketConnection;
use tokio::sync::mpsc;
use std::sync::Arc;

let (tx, _rx) = mpsc::unbounded_channel();
let conn = Arc::new(WebSocketConnection::new("conn_1".to_string(), tx));
let user = SimpleAuthUser::new(
    "user_1".to_string(),
    "alice".to_string(),
    vec!["chat.read".to_string()],
);

let auth_conn = AuthenticatedConnection::new(conn, Box::new(user));
assert_eq!(auth_conn.user().username(), "alice");

Implementations

impl AuthenticatedConnection

pub fn new( connection: Arc<WebSocketConnection>, user: Box<dyn AuthUser>, ) -> Self

Create a new authenticated connection

pub fn connection(&self) -> &Arc<WebSocketConnection>

Get the underlying WebSocket connection

pub fn user(&self) -> &dyn AuthUser

Get the authenticated user

pub async fn send_with_auth<P: AuthorizationPolicy>( &self, message: Message, policy: &P, ) -> WebSocketResult<()>

Send a message with authorization check