diff --git a/src/websocket/rw.rs b/src/websocket/rw.rs index e9952f4..99bb1e3 100644 --- a/src/websocket/rw.rs +++ b/src/websocket/rw.rs @@ -105,7 +105,7 @@ pub async fn read( } "heartbeat" => { let new_updated_time = Instant::now(); - let uidd = uid.try_lock().unwrap().clone(); + let uidd = uid.lock().await.clone(); *last_seen.lock().await = new_updated_time; info!("{}: active", uidd.to_string()); diff --git a/src/websocket/tasks/recipe.rs b/src/websocket/tasks/recipe.rs index eb9a38c..8b975ad 100644 --- a/src/websocket/tasks/recipe.rs +++ b/src/websocket/tasks/recipe.rs @@ -538,7 +538,8 @@ pub async fn handle_request_list_menu_recipe( "type": "notify", "payload": { "to": uidd, - "value": result + "value": result, + "from": "list-menu" } }))) .await