refactor: streamline imports and improve data handling in helper and parser modules

Author: Xerxes-2

src/helper.rs

@@ -1,17 +1,13 @@
 use crate::{
-    parser::{decode_action, LiqiMessage},
-    settings::Settings,
     ARBITRARY_MD5,
+    parser::{LiqiMessage, decode_action},
+    settings::Settings,
 };
 use anyhow::{Context, Result};
 use reqwest::Client;
 use serde::Serialize;
-use serde_json::{json, Map, Value as JsonValue};
-use std::{
-    borrow::Cow,
-    future::Future,
-    sync::{Arc, LazyLock},
-};
+use serde_json::{Map, Value as JsonValue, json};
+use std::{borrow::Cow, future::Future, sync::LazyLock};
 use tokio::{spawn, sync::mpsc::Receiver, time::sleep};
 use tracing::{debug, error, info};
 
@@ -61,17 +57,13 @@ fn process_message(mut parsed: LiqiMessage, settings: &Settings) -> Result<()> {
                 return Ok(());
             }
             if name == "ActionNewRound" {
-                Arc::<serde_json::Value>::make_mut(&mut parsed.data)["data"]
+                parsed
+                    .data
                     .as_object_mut()
                     .context("data field invalid")?
                     .insert("md5".to_string(), json!(ARBITRARY_MD5));
             }
-            Cow::Owned(
-                Arc::<serde_json::Value>::make_mut(&mut parsed.data)
-                    .get_mut("data")
-                    .context("No data field")?
-                    .take(),
-            )
+            Cow::Owned(parsed.data.get_mut("data").context("No data field")?.take())
         }
         ".lq.FastTest.syncGame" => {
             let game_restore = parsed.data["game_restore"]["actions"]

src/lib.rs

@@ -13,7 +13,7 @@ mod handler;
 mod helper;
 mod modder;
 mod parser;
-pub(crate) mod proto;
+mod proto;
 mod settings;
 
 pub use crate::{

src/parser.rs

@@ -1,9 +1,9 @@
-use anyhow::{ensure, Context, Result};
+use anyhow::{Context, Result, ensure};
 use base64::prelude::*;
 use bytes::Bytes;
 use prost::Message;
 use prost_reflect::{DescriptorPool, DynamicMessage, MessageDescriptor, SerializeOptions};
-use serde_json::{value::Serializer, Value as JsonValue};
+use serde_json::{Value as JsonValue, value::Serializer};
 use std::{collections::HashMap, sync::Arc};
 
 use crate::proto::base::BaseMessage;
@@ -24,7 +24,7 @@ pub struct LiqiMessage {
     pub id: usize,
     pub msg_type: MessageType,
     pub method_name: Arc<str>,
-    pub data: Arc<JsonValue>,
+    pub data: JsonValue,
 }
 
 impl LiqiMessage {
@@ -33,7 +33,7 @@ impl LiqiMessage {
             id,
             msg_type,
             method_name,
-            data: Arc::new(data),
+            data,
         }
     }
 }