refactor: improve efficiency and maintainability based on code review

- Optimize start_listener to avoid second hashmap lookup
- Simplify stop_listener using remove() directly instead of get_mut + drain + remove
- Extract duplicated test code into create_test_listener_config helper function
- Improve code readability and performance

Signed-off-by: Eeshu-Yadav <eeshuyadav123@gmail.com>

Author: Eeshu-Yadav

orion-lib/src/listeners/listeners_manager.rs

@@ -154,11 +154,10 @@ impl ListenersManager {
     pub fn stop_listener(&mut self, listener_name: &str) -> Result<()> {
         if let Some(listeners) = self.listener_handles.get_vec_mut(listener_name) {
             info!("Stopping all {} version(s) of listener {}", listeners.len(), listener_name);
-            for listener_info in listeners.drain(..) {
+            for listener_info in listeners {
                 info!("Stopping listener {} version {}", listener_name, listener_info.version);
                 listener_info.handle.abort();
             }
-            self.listener_handles.remove(listener_name);
         } else {
             info!("No listeners found with name {}", listener_name);
         }
@@ -175,9 +174,22 @@ mod tests {
     };
 
     use super::*;
-    use orion_configuration::config::Listener as ListenerConfig;
+    use orion_configuration::config::{Listener as ListenerConfig, ListenerAddress};
     use tracing_test::traced_test;
 
+    fn create_test_listener_config(name: &str, port: u16) -> ListenerConfig {
+        ListenerConfig {
+            name: name.into(),
+            address: ListenerAddress::Socket(SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), port)),
+            filter_chains: HashMap::default(),
+            bind_device: None,
+            with_tls_inspector: false,
+            proxy_protocol_config: None,
+            with_tlv_listener_filter: false,
+            tlv_listener_filter_config: None,
+        }
+    }
+
     #[traced_test]
     #[tokio::test]
     async fn start_listener_dup() {
@@ -282,50 +294,23 @@ mod tests {
         let (routeb_tx1, routeb_rx) = broadcast::channel(chan);
         let (_secb_tx1, secb_rx) = broadcast::channel(chan);
         let l1 = Listener::test_listener(name, routeb_rx, secb_rx);
-        let l1_info = ListenerConfig {
-            name: name.into(),
-            address: ListenerAddress::Socket(SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 1234)),
-            filter_chains: HashMap::default(),
-            bind_device: None,
-            with_tls_inspector: false,
-            proxy_protocol_config: None,
-            with_tlv_listener_filter: false,
-            tlv_listener_filter_config: None,
-        };
+        let l1_info = create_test_listener_config(name, 1234);
         man.start_listener(l1, l1_info).unwrap();
         assert!(routeb_tx1.send(RouteConfigurationChange::Removed("n/a".into())).is_ok());
         tokio::task::yield_now().await;
 
         let (routeb_tx2, routeb_rx) = broadcast::channel(chan);
         let (_secb_tx2, secb_rx) = broadcast::channel(chan);
         let l2 = Listener::test_listener(name, routeb_rx, secb_rx);
-        let l2_info = ListenerConfig {
-            name: name.into(),
-            address: ListenerAddress::Socket(SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 1235)), // Different port
-            filter_chains: HashMap::default(),
-            bind_device: None,
-            with_tls_inspector: false,
-            proxy_protocol_config: None,
-            with_tlv_listener_filter: false,
-            tlv_listener_filter_config: None,
-        };
+        let l2_info = create_test_listener_config(name, 1235);
         man.start_listener(l2, l2_info).unwrap();
         assert!(routeb_tx2.send(RouteConfigurationChange::Removed("n/a".into())).is_ok());
         tokio::task::yield_now().await;
 
         let (routeb_tx3, routeb_rx) = broadcast::channel(chan);
         let (_secb_tx3, secb_rx) = broadcast::channel(chan);
         let l3 = Listener::test_listener(name, routeb_rx, secb_rx);
-        let l3_info = ListenerConfig {
-            name: name.into(),
-            address: ListenerAddress::Socket(SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 1236)), // Different port
-            filter_chains: HashMap::default(),
-            bind_device: None,
-            with_tls_inspector: false,
-            proxy_protocol_config: None,
-            with_tlv_listener_filter: false,
-            tlv_listener_filter_config: None,
-        };
+        let l3_info = create_test_listener_config(name, 1236);
         man.start_listener(l3, l3_info).unwrap();
         assert!(routeb_tx3.send(RouteConfigurationChange::Removed("n/a".into())).is_ok());
         tokio::task::yield_now().await;