g3proxy: use less allocation when publish data to escaper

g3proxy/src/control/capnp/escaper.rs

@@ -28,7 +28,7 @@ impl escaper_control::Server for EscaperControlImpl {
         params: escaper_control::PublishParams,
         mut results: escaper_control::PublishResults,
     ) -> capnp::Result<()> {
-        let data = params.get()?.get_data()?.to_string()?;
+        let data = params.get()?.get_data()?.to_str()?;
         let r = self.escaper.publish(data).await;
         set_operation_result(results.get().init_result(), r);
         Ok(())

g3proxy/src/escape/comply_audit/mod.rs

@@ -94,7 +94,7 @@ impl Escaper for ComplyAuditEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/direct_fixed/mod.rs

@@ -291,7 +291,7 @@ impl Escaper for DirectFixedEscaper {
         Some(self.stats.clone())
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/direct_float/mod.rs

@@ -337,7 +337,7 @@ impl Escaper for DirectFloatEscaper {
         Some(Arc::clone(&self.stats) as ArcEscaperStats)
     }
 
-    async fn publish(&self, data: String) -> anyhow::Result<()> {
+    async fn publish(&self, data: &str) -> anyhow::Result<()> {
         publish::publish_records(&self.config, &self.bind_v4, &self.bind_v6, data).await
     }
 

g3proxy/src/escape/direct_float/publish.rs

@@ -93,10 +93,10 @@ pub(super) async fn publish_records(
     config: &DirectFloatEscaperConfig,
     v4_container: &ArcSwap<BindSet>,
     v6_container: &ArcSwap<BindSet>,
-    data: String,
+    data: &str,
 ) -> anyhow::Result<()> {
     let obj =
-        Value::from_str(&data).map_err(|e| anyhow!("the input data is not valid json: {:?}", e))?;
+        Value::from_str(data).map_err(|e| anyhow!("the input data is not valid json: {:?}", e))?;
 
     if let Value::Object(map) = obj {
         for (k, v) in map.into_iter() {

g3proxy/src/escape/divert_tcp/mod.rs

@@ -196,7 +196,7 @@ impl Escaper for DivertTcpEscaper {
         Some(self.stats.clone())
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/dummy_deny/mod.rs

@@ -86,7 +86,7 @@ impl Escaper for DummyDenyEscaper {
         Some(self.stats.clone())
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/mod.rs

@@ -157,7 +157,7 @@ pub(crate) trait Escaper: EscaperInternal {
         None
     }
 
-    async fn publish(&self, data: String) -> anyhow::Result<()>;
+    async fn publish(&self, data: &str) -> anyhow::Result<()>;
 
     async fn tcp_setup_connection(
         &self,

g3proxy/src/escape/proxy_float/mod.rs

@@ -175,7 +175,7 @@ impl Escaper for ProxyFloatEscaper {
         Some(self.stats.clone())
     }
 
-    async fn publish(&self, data: String) -> anyhow::Result<()> {
+    async fn publish(&self, data: &str) -> anyhow::Result<()> {
         source::publish_peers(&self.config, &self.peers, data).await
     }
 

g3proxy/src/escape/proxy_float/source/mod.rs

@@ -49,9 +49,9 @@ async fn parse_and_save_peers(
 pub(super) async fn publish_peers(
     config: &ProxyFloatEscaperConfig,
     peers_container: &Arc<ArcSwap<PeerSet>>,
-    data: String,
+    data: &str,
 ) -> anyhow::Result<()> {
-    let obj = serde_json::from_str(&data)
+    let obj = serde_json::from_str(data)
         .map_err(|e| anyhow!("the publish data is not valid json: {e:?}"))?;
     let records = match obj {
         serde_json::Value::Array(v) => v,

g3proxy/src/escape/proxy_http/mod.rs

@@ -166,7 +166,7 @@ impl Escaper for ProxyHttpEscaper {
         Some(self.stats.clone())
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/proxy_https/mod.rs

@@ -175,7 +175,7 @@ impl Escaper for ProxyHttpsEscaper {
         Some(self.stats.clone())
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/proxy_socks5/mod.rs

@@ -166,7 +166,7 @@ impl Escaper for ProxySocks5Escaper {
         Some(Arc::clone(&self.stats) as ArcEscaperStats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/proxy_socks5s/mod.rs

@@ -174,7 +174,7 @@ impl Escaper for ProxySocks5sEscaper {
         Some(Arc::clone(&self.stats) as ArcEscaperStats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/route_client/mod.rs

@@ -139,7 +139,7 @@ impl Escaper for RouteClientEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/route_failover/mod.rs

@@ -104,7 +104,7 @@ impl Escaper for RouteFailoverEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/route_geoip/mod.rs

@@ -240,7 +240,7 @@ impl Escaper for RouteGeoIpEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/route_mapping/mod.rs

@@ -112,7 +112,7 @@ impl Escaper for RouteMappingEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/route_query/mod.rs

@@ -136,7 +136,7 @@ impl Escaper for RouteQueryEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/route_resolved/mod.rs

@@ -161,7 +161,7 @@ impl Escaper for RouteResolvedEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/route_select/mod.rs

@@ -145,7 +145,7 @@ impl Escaper for RouteSelectEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/route_upstream/mod.rs

@@ -164,7 +164,7 @@ impl Escaper for RouteUpstreamEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }
 

g3proxy/src/escape/trick_float/mod.rs

@@ -111,7 +111,7 @@ impl Escaper for TrickFloatEscaper {
         Some(&self.stats)
     }
 
-    async fn publish(&self, _data: String) -> anyhow::Result<()> {
+    async fn publish(&self, _data: &str) -> anyhow::Result<()> {
         Err(anyhow!("not implemented"))
     }