From 7f37a8ed984b90aea50c4a74b18310d85f2ccdaa Mon Sep 17 00:00:00 2001
From: Pierre <pierremarais67@gmail.com>
Date: Thu, 28 Mar 2024 10:13:08 +0100
Subject: [PATCH] Create new thread per request to support parallel requests

---
 src/action_handler.rs       |  3 ++-
 src/key_value_repository.rs |  1 +
 src/main.rs                 |  5 +++--
 src/server.rs               | 11 ++++++++---
 4 files changed, 14 insertions(+), 6 deletions(-)

diff --git a/src/action_handler.rs b/src/action_handler.rs
index 9ed1ef1..b9ae6a7 100644
--- a/src/action_handler.rs
+++ b/src/action_handler.rs
@@ -1,5 +1,6 @@
 use crate::{key_value_repository::RedisDatabase, resp::RespType};
 
+#[derive(Clone)]
 pub struct RedisActionHandler {
     db: RedisDatabase,
 }
@@ -9,7 +10,7 @@ impl RedisActionHandler {
         RedisActionHandler { db }
     }
     
-    pub fn handle(&mut self, resp: RespType) -> RespType {
+    pub fn handle(&self, resp: RespType) -> RespType {
         let action = RedisAction::from(resp);
         match action {
             RedisAction::Set(key, value) => {
diff --git a/src/key_value_repository.rs b/src/key_value_repository.rs
index b686216..083b168 100644
--- a/src/key_value_repository.rs
+++ b/src/key_value_repository.rs
@@ -1,5 +1,6 @@
 use dashmap::DashMap;
 
+#[derive(Clone)]
 pub struct RedisDatabase {
     data: DashMap<String, String>,
 }
diff --git a/src/main.rs b/src/main.rs
index c239416..a201bce 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -2,12 +2,13 @@ mod server;
 mod action_handler;
 mod key_value_repository;
 mod resp;
+use std::sync::Arc;
 
 fn main() {
     let repository = key_value_repository::RedisDatabase::new();
-    let mut action_handler = action_handler::RedisActionHandler::new(repository);
+    let action_handler = Arc::new(action_handler::RedisActionHandler::new(repository));
 
     let port: &str = "6388";
     println!("Starting tcp stream on port {}", port);
-    server::start_tcp_stream(port, &mut action_handler);
+    server::start_tcp_stream(port, action_handler);
 }
diff --git a/src/server.rs b/src/server.rs
index 1ae95f7..e319d17 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -1,11 +1,13 @@
 use std::io::BufReader;
 use std::net::{TcpListener, TcpStream};
+use std::thread;
+use std::sync::Arc;
 
 use crate::action_handler::{self};
 use crate::resp::{RespType, RespDeserializer, RespSerializer};
 
 
-fn handle_client(mut stream: TcpStream, action_handler: &mut action_handler::RedisActionHandler) {
+fn handle_client(mut stream: TcpStream, action_handler: Arc<action_handler::RedisActionHandler>) {
     println!("Incoming connection from: {}", stream.peer_addr().unwrap());
     let buf_reader = BufReader::new(&mut stream);
     let mut parser = RespDeserializer::new(buf_reader);
@@ -23,12 +25,15 @@ fn handle_client(mut stream: TcpStream, action_handler: &mut action_handler::Red
     }
 }
 
-pub fn start_tcp_stream(port: &str, action_handler: &mut action_handler::RedisActionHandler) {
+pub fn start_tcp_stream(port: &str, action_handler: Arc<action_handler::RedisActionHandler>) {
     let listener = TcpListener::bind(format!("127.0.0.1:{}", port)).expect("Could not bind");
     for stream in listener.incoming() {
         match stream {
             Ok(stream) => {
-                handle_client(stream, action_handler);
+                let handler = Arc::clone(&action_handler);
+                thread::spawn(move || {
+                    handle_client(stream, handler);
+                });
             }
             Err(e) => {
                 eprintln!("Failed: {}", e)