diff --git a/src/broker_messages/pind.rs b/src/broker_messages/pind.rs index 5d01e47..74be444 100644 --- a/src/broker_messages/pind.rs +++ b/src/broker_messages/pind.rs @@ -67,7 +67,7 @@ pub struct SendStatus { pub struct DeleteMsg { pub kaksh_kunjika: String, pub kunjika: String, - pub msg_id: Vec + pub msg_id: Vec } // Request to send list of users diff --git a/src/broker_messages/sansad.rs b/src/broker_messages/sansad.rs index 8d18e14..3c849bf 100644 --- a/src/broker_messages/sansad.rs +++ b/src/broker_messages/sansad.rs @@ -40,7 +40,7 @@ pub struct WsStatus { #[derive(Clone, Message)] #[rtype(result = "()")] pub struct WsDeleteMsg { - pub msg_id: Vec, + pub msg_id: Vec, pub sender_kunjika: String } diff --git a/src/chat_pinnd/mod.rs b/src/chat_pinnd/mod.rs index e25a099..5ff4832 100644 --- a/src/chat_pinnd/mod.rs +++ b/src/chat_pinnd/mod.rs @@ -48,6 +48,7 @@ impl Actor for ChatPinnd { // for actix broker self.subscribe_system_async::(ctx); self.subscribe_system_async::(ctx); + self.subscribe_system_async::(ctx); self.subscribe_system_async::(ctx); self.subscribe_system_async::(ctx); } diff --git a/src/ws_sansad/messages.rs b/src/ws_sansad/messages.rs index 4aa081d..c517c33 100644 --- a/src/ws_sansad/messages.rs +++ b/src/ws_sansad/messages.rs @@ -156,7 +156,7 @@ impl WsSansad { }.as_array().unwrap(); for id in ids { - msg_id.push(id.as_str().unwrap().parse::().unwrap()); + msg_id.push(id.as_str().unwrap().to_owned()); } drop(ids); @@ -167,6 +167,7 @@ impl WsSansad { return; } }; + Broker::::issue_async(ms::pind::DeleteMsg { kaksh_kunjika, kunjika: self.kunjika.to_owned(), diff --git a/static/index.html b/static/index.html index cff3caa..6d150ec 100644 --- a/static/index.html +++ b/static/index.html @@ -155,7 +155,7 @@