fix: missing lifetime specifier

Author: yuanchaoa

agent/crates/enterprise-utils/src/lib.rs

@@ -32,6 +32,8 @@ pub mod l7 {
         }
 
         pub mod custom_field_policy {
+            use std::marker::PhantomData;
+
             pub mod enums {
                 use std::sync::Arc;
 
@@ -89,8 +91,11 @@ pub mod l7 {
             }
 
             #[derive(Clone, Copy, Debug)]
-            pub struct PolicySlice;
-            impl PolicySlice {
+            pub struct PolicySlice<'a> {
+                _marker: PhantomData<&'a ()>,
+            }
+
+            impl<'a> PolicySlice<'a> {
                 pub fn apply(
                     &self,
                     _: &mut Store,
@@ -339,6 +344,7 @@ pub mod l7 {
 
     pub mod mq {
         pub mod web_sphere_mq {
+            use public::l7_protocol::LogMessageType;
 
             #[derive(Default)]
             pub struct WebSphereMqParser {
@@ -349,7 +355,7 @@ pub mod l7 {
             }
 
             impl WebSphereMqParser {
-                pub fn check_payload(&mut self, _: &[u8], _: bool) -> bool {
+                pub fn check_payload(&mut self, _: &[u8], _: bool) -> Option<LogMessageType> {
                     unimplemented!()
                 }
 

agent/src/flow_generator/protocol_logs/mq/webspheremq.rs

@@ -325,11 +325,7 @@ const RESPONSE_CODE_OK_SUFFIX: &str = "0000";
 impl L7ProtocolParserInterface for WebSphereMqLog {
     fn check_payload(&mut self, payload: &[u8], param: &ParseParam) -> Option<LogMessageType> {
         let has_wasm = param.wasm_vm.borrow().is_some();
-        if self.parser.check_payload(payload, has_wasm) {
-            Some(LogMessageType::Request)
-        } else {
-            None
-        }
+        self.parser.check_payload(payload, has_wasm)
     }
 
     fn parse_payload(&mut self, payload: &[u8], param: &ParseParam) -> Result<L7ParseResult> {

agent/src/flow_generator/protocol_logs/rpc/dubbo.rs

@@ -516,7 +516,7 @@ pub struct DubboLog {
 #[cfg(feature = "enterprise")]
 struct CustomFieldContext<'a> {
     direction: PacketDirection,
-    policies: Option<PolicySlice>,
+    policies: Option<PolicySlice<'a>>,
     store: &'a mut Store,
 }