feat: refact codebase and use match on tcp listener accept in server lib

src/handler.rs

@@ -14,16 +14,13 @@ impl Handler {
   pub fn handle_connection(mut tcp_stream: TcpStream, router: &Box<dyn Fn(&[u8]) + Send + Sync>) {
     loop {
       let mut buffer = [0; 1028];
-
       match tcp_stream.read(&mut buffer) {
         Ok(stream_count) => {
           if stream_count == 0 {
             break;
           }
-
           let request = &buffer[0..stream_count];
           router(request);
-
           println!("{}", Handler::get_request_path(request));
         }
         Err(e) => panic!("{}", e),
@@ -35,7 +32,6 @@ impl Handler {
     if let Err(e) = ctrlc::set_handler(move || {
       exit.store(true, Ordering::SeqCst);
       println!("Ctrl + C pressed. Exiting gracefully...");
-
       process::exit(0);
     }) {
       panic!("{}", e);
@@ -45,7 +41,6 @@ impl Handler {
   pub fn get_request_path(request: &[u8]) -> String {
     let request_str = String::from_utf8_lossy(request);
     let request_lines: Vec<&str> = request_str.lines().collect();
-
     let request_path = request_lines
       .first()
       .unwrap_or(&"")

src/params.rs

@@ -4,7 +4,6 @@ use regex::Regex;
 pub fn is_empty(host: &str, port: u32) -> bool {
   let is_host_empty = host.is_empty();
   let is_port_empty = port == 0;
-
   match (is_host_empty, is_port_empty) {
     (true, true) => true,
     _ => false,
@@ -13,7 +12,6 @@ pub fn is_empty(host: &str, port: u32) -> bool {
 
 pub fn is_valid_local_host(host: &str) -> bool {
   let pattern = constants::HOST_REGEX;
-
   match Regex::new(pattern) {
     Ok(re) => re.is_match(host),
     Err(_) => false,
@@ -22,7 +20,6 @@ pub fn is_valid_local_host(host: &str) -> bool {
 
 pub fn is_valid_port(port: u32) -> bool {
   let pattern = constants::PORT_REGEX;
-
   match Regex::new(pattern) {
     Ok(re) => re.is_match(&port.to_string()),
     Err(_) => false,

src/server.rs

@@ -34,7 +34,6 @@ impl Server {
     F: Fn(&[u8]) + Send + Sync + 'static,
   {
     self.initialize();
-
     self
       .routes
       .lock()
@@ -44,36 +43,32 @@ impl Server {
 
   pub fn listen(&self, host: &str, port: u32) {
     self.initialize();
-
     validator::validate_host_and_port(host, port);
-
     let addr = format!("{}:{}", host, port);
-
     let term = Arc::new(AtomicBool::new(false));
 
     self::Handler::handle_exit_process(Arc::clone(&term).clone());
 
-    println!("App is listening on {}", &addr);
-
-    let listener = TcpListener::bind(&addr).expect("An error occured while listening app");
+    let listener = TcpListener::bind(&addr).unwrap();
+    match listener.accept() {
+      Ok((_socket, _addr)) => println!("App is listening on {}", &addr),
+      Err(e) => println!("An error occured while listening app with error, {}", e),
+    }
 
     for stream in listener.incoming() {
       if term.load(Ordering::SeqCst) {
         println!("Exiting thread...");
-
         break;
       }
 
       match stream {
         Ok(tcp_stream) => {
           let routes_clone = Arc::clone(&self.routes);
-
           thread::spawn(move || {
             let routes_lock = routes_clone.lock().unwrap();
             let router = routes_lock.get("/").unwrap_or_else(|| {
               panic!("An error occurred, no handler found for default route");
             });
-
             Handler::handle_connection(tcp_stream, router);
           });
         }