jmug/stoatchat
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

Add temporary typing indicator impl.

Browse Source
This commit is contained in:
Paul
2021-02-19 14:50:23 +00:00
parent dadad271b4
commit 3c7852271a
4 changed files with 88 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
src/notifications/websocket.rs
View File

@@ -71,8 +71,6 @@ async fn accept(stream: TcpStream) {
let fwd = rx.map(Ok).forward(write);
let incoming = read.try_for_each(async move |msg| {
let mutex = mutex_generator();
//dbg!(&mutex.lock().unwrap());
if let Message::Text(text) = msg {
if let Ok(notification) = serde_json::from_str::<ServerboundNotification>(&text) {
match notification {
@@ -161,6 +159,43 @@ async fn accept(stream: TcpStream) {
));
}
}
// ! TEMP: verify user part of channel
// ! Could just run permission check here.
ServerboundNotification::BeginTyping { channel } => {
if mutex.lock().unwrap().is_some() {
ClientboundNotification::ChannelStartTyping {
id: channel.clone(),
// lol
user: mutex.lock().as_ref().unwrap().as_ref().unwrap().user_id.clone()
}
.publish(channel)
.await
.ok();
} else {
send(ClientboundNotification::Error(
WebSocketError::AlreadyAuthenticated,
));
return Ok(());
}
}
ServerboundNotification::EndTyping { channel } => {
if mutex.lock().unwrap().is_some() {
ClientboundNotification::ChannelStopTyping {
id: channel.clone(),
user: mutex.lock().as_ref().unwrap().as_ref().unwrap().user_id.clone()
}
.publish(channel)
.await
.ok();
} else {
send(ClientboundNotification::Error(
WebSocketError::AlreadyAuthenticated,
));
return Ok(());
}
}
}
}
}