store

src/socket/event.rs

-use crate::{event::{EventType, SocketEvent}, socket::protocol::Qos};
+use crate::{
+    event::{EventType, SocketEvent},
+    socket::protocol::Qos,
+};
 
 use super::model::TokenInfo;
 
 pub trait BusinessEvent {
-    fn message(key: Option<String>, qos: Qos, msg_id: i64, msg_ty: i32) -> SocketEvent;
+    fn message(
+        key: Option<String>,
+        qos: Qos,
+        msg_id: i64,
+        msg_ty: i32,
+        extra: Option<String>,
+    ) -> SocketEvent;
 }
 
 impl BusinessEvent for SocketEvent {
-    fn message(key: Option<String>, qos: Qos, msg_id: i64, msg_ty: i32) -> SocketEvent {
+    fn message(
+        key: Option<String>,
+        qos: Qos,
+        msg_id: i64,
+        msg_ty: i32,
+        extra: Option<String>,
+    ) -> SocketEvent {
         SocketEvent {
             seller_id: None,
             store_id: None,
@@ -22,7 +37,7 @@ impl BusinessEvent for SocketEvent {
             msg_ty: Some(msg_ty),
             status: 1,
             desc: qos.desc(),
-            extra: None,
+            extra,
         }
     }
 }