Skip to content

Commit 155cbd0

Browse files
lzf575taloric
authored andcommitted
feat: wasm add field endpoint/req_type/biz_code/biz_scenario
1 parent 9db8449 commit 155cbd0

1 file changed

Lines changed: 19 additions & 2 deletions

File tree

agent/src/plugin/mod.rs

Lines changed: 19 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -592,6 +592,8 @@ impl L7ProtocolInfoInterface for CustomInfo {
592592

593593
swap_if!(self.resp, exception, is_empty, w.resp);
594594
swap_if!(self.resp, result, is_empty, w.resp);
595+
swap_if!(self.resp, req_type, is_empty, w.resp);
596+
swap_if!(self.resp, endpoint, is_empty, w.resp);
595597

596598
if self.resp_len.is_none() {
597599
self.resp_len = w.resp_len;
@@ -666,10 +668,18 @@ impl From<CustomInfo> for L7ProtocolSendLog {
666668
captured_response_byte: w.captured_response_byte,
667669

668670
req: L7Request {
669-
req_type: w.req.req_type,
671+
req_type: if w.req.req_type.is_empty() {
672+
w.resp.req_type
673+
} else {
674+
w.req.req_type
675+
},
670676
domain: w.req.domain,
671677
resource: w.req.resource,
672-
endpoint: w.req.endpoint,
678+
endpoint: if w.req.endpoint.is_empty() {
679+
w.resp.endpoint
680+
} else {
681+
w.req.endpoint
682+
},
673683
},
674684
resp: L7Response {
675685
status: w.resp.status,
@@ -699,6 +709,13 @@ impl From<CustomInfo> for L7ProtocolSendLog {
699709
..Default::default()
700710
}),
701711
biz_response_code: w.biz_response_code.unwrap_or_default(),
712+
version: if w.req.version.is_empty() {
713+
None
714+
} else {
715+
Some(w.req.version)
716+
},
717+
biz_code: w.biz_code.unwrap_or_default(),
718+
biz_scenario: w.biz_scenario.unwrap_or_default(),
702719
..Default::default()
703720
}
704721
}

0 commit comments

Comments
 (0)