jmug/stoatchat
1
0
Fork 1
mirror of https://github.com/stoatchat/stoatchat.git synced 2026-07-06 03:06:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(bonfire): send InvalidSession error if token is not sent successfully

Browse Source 
closes #289
This commit is contained in:
Paul Makles
2024-06-09 13:42:12 +01:00
parent 506968634e
commit da9a91e05f
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/bonfire/src/websocket.rs
View File

@@ -19,6 +19,7 @@ use revolt_database::{
use revolt_presence::{create_session, delete_session}; use revolt_presence::{create_session, delete_session};
use async_std::{net::TcpStream, sync::Mutex}; use async_std::{net::TcpStream, sync::Mutex};
use revolt_result::create_error;
use crate::config::{ProtocolConfiguration, WebsocketHandshakeCallback}; use crate::config::{ProtocolConfiguration, WebsocketHandshakeCallback};
use crate::events::state::{State, SubscriptionStateChange}; use crate::events::state::{State, SubscriptionStateChange};
@@ -69,6 +70,7 @@ pub async fn client(db: &'static Database, stream: TcpStream, addr: SocketAddr)
// Try to authenticate the user. // Try to authenticate the user.
let Some(token) = config.get_session_token().as_ref() else { let Some(token) = config.get_session_token().as_ref() else {
write.send(config.encode(&create_error!(InvalidSession))).await.ok();
return; return;
}; };
let user = match User::from_token(db, token, UserHint::Any).await { let user = match User::from_token(db, token, UserHint::Any).await {