Changeset View
Changeset View
Standalone View
Standalone View
services/tunnelbroker/src/websockets/session.rs
| Show All 13 Lines | ) -> WebsocketSession { | ||||
| WebsocketSession { tx } | WebsocketSession { tx } | ||||
| } | } | ||||
| pub fn handle_message_from_device( | pub fn handle_message_from_device( | ||||
| &self, | &self, | ||||
| message: &str, | message: &str, | ||||
| ) -> Result<(), serde_json::Error> { | ) -> Result<(), serde_json::Error> { | ||||
| match serde_json::from_str::<Messages>(message)? { | match serde_json::from_str::<Messages>(message)? { | ||||
| Messages::SessionRequest(session_info) => { | Messages::ConnectionInitializationMessage(session_info) => { | ||||
| ACTIVE_CONNECTIONS.insert(session_info.device_id, self.tx.clone()); | ACTIVE_CONNECTIONS.insert(session_info.device_id, self.tx.clone()); | ||||
| } | } | ||||
| _ => { | _ => { | ||||
| debug!("Received invalid request"); | debug!("Received invalid request"); | ||||
| } | } | ||||
| } | } | ||||
| Ok(()) | Ok(()) | ||||
| } | } | ||||
| } | } | ||||