diff --git a/plugins/wasm-rust/extensions/request-block/src/lib.rs b/plugins/wasm-rust/extensions/request-block/src/lib.rs index 5e1dec170..78daf6fd5 100644 --- a/plugins/wasm-rust/extensions/request-block/src/lib.rs +++ b/plugins/wasm-rust/extensions/request-block/src/lib.rs @@ -165,7 +165,7 @@ impl HttpContextWrapper for RquestBlock { } let mut request_url = value.unwrap().clone(); - if config.case_sensitive { + if !config.case_sensitive { request_url = request_url.to_lowercase(); } for block_exact_url in &config.block_exact_urls { @@ -229,7 +229,7 @@ impl HttpContextWrapper for RquestBlock { return Action::Continue; } let mut body = req_body.clone(); - if config.case_sensitive { + if !config.case_sensitive { body = body.to_ascii_lowercase(); } for block_body in &config.block_bodies { diff --git a/plugins/wasm-rust/src/plugin_wrapper.rs b/plugins/wasm-rust/src/plugin_wrapper.rs index bd431472d..8291d22e0 100644 --- a/plugins/wasm-rust/src/plugin_wrapper.rs +++ b/plugins/wasm-rust/src/plugin_wrapper.rs @@ -82,7 +82,43 @@ impl PluginHttpWrapper { } } } -impl Context for PluginHttpWrapper {} +impl Context for PluginHttpWrapper { + fn on_http_call_response( + &mut self, + token_id: u32, + num_headers: usize, + body_size: usize, + num_trailers: usize, + ) { + self.http_content + .on_http_call_response(token_id, num_headers, body_size, num_trailers) + } + + fn on_grpc_call_response(&mut self, token_id: u32, status_code: u32, response_size: usize) { + self.http_content + .on_grpc_call_response(token_id, status_code, response_size) + } + fn on_grpc_stream_initial_metadata(&mut self, token_id: u32, num_elements: u32) { + self.http_content + .on_grpc_stream_initial_metadata(token_id, num_elements) + } + fn on_grpc_stream_message(&mut self, token_id: u32, message_size: usize) { + self.http_content + .on_grpc_stream_message(token_id, message_size) + } + fn on_grpc_stream_trailing_metadata(&mut self, token_id: u32, num_elements: u32) { + self.http_content + .on_grpc_stream_trailing_metadata(token_id, num_elements) + } + fn on_grpc_stream_close(&mut self, token_id: u32, status_code: u32) { + self.http_content + .on_grpc_stream_close(token_id, status_code) + } + + fn on_done(&mut self) -> bool { + self.http_content.on_done() + } +} impl HttpContext for PluginHttpWrapper where PluginConfig: Default + DeserializeOwned + Clone,