fixes

Author: ovadiagal

rust/src/http_access_logger.rs

@@ -186,10 +186,10 @@ mod tests {
         let mut envoy_filter = envoy_proxy_dynamic_modules_rust_sdk::MockEnvoyHttpFilter::new();
         envoy_filter
             .expect_get_request_headers()
-            .returning(|| vec![(EnvoyBuffer::new("host"), EnvoyBuffer::new("example.com"))]);
+            .returning(|| vec![(EnvoyBuffer::new(b"host"), EnvoyBuffer::new(b"example.com"))]);
         envoy_filter
             .expect_get_response_headers()
-            .returning(|| vec![(EnvoyBuffer::new("content-length"), EnvoyBuffer::new("123"))]);
+            .returning(|| vec![(EnvoyBuffer::new(b"content-length"), EnvoyBuffer::new(b"123"))]);
         access_logger_filter.on_request_headers(&mut envoy_filter, false);
         access_logger_filter.on_response_headers(&mut envoy_filter, false);
 

rust/src/http_header_mutation.rs

@@ -118,10 +118,10 @@ mod tests {
             .expect_get_attribute_string()
             .returning(|id| match id {
                 abi::envoy_dynamic_module_type_attribute_id::SourceAddress => {
-                    return Some(EnvoyBuffer::new("1.1.1.1:12345"));
+                    return Some(EnvoyBuffer::new(b"1.1.1.1:12345"));
                 }
                 abi::envoy_dynamic_module_type_attribute_id::UpstreamAddress => {
-                    return Some(EnvoyBuffer::new("2.2.2.2:12345"));
+                    return Some(EnvoyBuffer::new(b"2.2.2.2:12345"));
                 }
                 _ => panic!("Unexpected attribute id"),
             });

rust/src/http_random_auth.rs

@@ -37,7 +37,7 @@ impl<EHF: EnvoyHttpFilter> HttpFilter<EHF> for Filter {
     ) -> abi::envoy_dynamic_module_type_on_http_filter_request_headers_status {
         let reject = rand::rng().random::<bool>();
         if reject {
-            envoy_filter.send_response(403, vec![], Some(b"Access forbidden"), None);
+            envoy_filter.send_response(403, &[], Some(b"Access forbidden"), None);
             return abi::envoy_dynamic_module_type_on_http_filter_request_headers_status::StopIteration;
         }
         abi::envoy_dynamic_module_type_on_http_filter_request_headers_status::Continue

rust/src/http_zero_copy_regex_waf.rs

@@ -70,7 +70,7 @@ impl<EHF: EnvoyHttpFilter> HttpFilter<EHF> for Filter {
             .expect("Failed to do regex match");
         if matched {
             // If the regex matches, we send a 403 response.
-            envoy_filter.send_response(403, vec![], Some(b"Access forbidden"), None);
+            envoy_filter.send_response(403, &[], Some(b"Access forbidden"), None);
             return abi::envoy_dynamic_module_type_on_http_filter_request_body_status::StopIterationNoBuffer;
         }
         abi::envoy_dynamic_module_type_on_http_filter_request_body_status::Continue
@@ -141,8 +141,8 @@ mod tests {
                 static mut HELLO: [u8; 6] = *b"Hello ";
                 static mut WORLD: [u8; 6] = *b"World!";
                 Some(vec![
-                    EnvoyMutBuffer::new(unsafe { &mut HELLO }),
-                    EnvoyMutBuffer::new(unsafe { &mut WORLD }),
+                    unsafe { EnvoyMutBuffer::new(&raw mut HELLO) },
+                    unsafe { EnvoyMutBuffer::new(&raw mut WORLD) },
                 ])
             })
             .times(1);
@@ -160,8 +160,8 @@ mod tests {
                 static mut GOOD: [u8; 5] = *b"Good ";
                 static mut MORNING: [u8; 8] = *b"Morning!";
                 Some(vec![
-                    EnvoyMutBuffer::new(unsafe { &mut GOOD }),
-                    EnvoyMutBuffer::new(unsafe { &mut MORNING }),
+                    unsafe { EnvoyMutBuffer::new(&raw mut GOOD) },
+                    unsafe { EnvoyMutBuffer::new(&raw mut MORNING) },
                 ])
             })
             .times(1);