Add simulation testing via turmoil

Cargo.toml

@@ -21,6 +21,7 @@ name = "mini-redis-server"
 path = "src/bin/server.rs"
 
 [dependencies]
+async-trait = "0.1"
 async-stream = "0.3.0"
 atoi = "0.3.2"
 bytes = "1"
@@ -39,10 +40,14 @@ tracing-opentelemetry = { version = "0.17.2", optional = true }
 opentelemetry-aws = { version = "0.5.0", optional = true }
 # Allows you to send data to the OTel collector
 opentelemetry-otlp = { version = "0.10.0", optional = true }
+# Optional depedency used for simulation testing
+turmoil = { version = "0.4", optional = true }
 
 [dev-dependencies]
 # Enable test-utilities in dev mode only. This is mostly for tests.
 tokio = { version = "1", features = ["test-util"] }
 
 [features]
 otel = ["dep:opentelemetry", "dep:tracing-opentelemetry", "dep:opentelemetry-aws", "dep:opentelemetry-otlp"]
+sim = ["dep:turmoil"]
+

src/blocking_client.rs

@@ -4,9 +4,9 @@
 
 use bytes::Bytes;
 use std::time::Duration;
-use tokio::net::ToSocketAddrs;
-use tokio::runtime::Runtime;
+use tokio::{net::ToSocketAddrs, runtime::Runtime};
 
+use crate::client;
 pub use crate::client::Message;
 
 /// Established connection with a Redis server.
@@ -74,7 +74,7 @@ pub fn connect<T: ToSocketAddrs>(addr: T) -> crate::Result<BlockingClient> {
         .enable_all()
         .build()?;
 
-    let inner = rt.block_on(crate::client::connect(addr))?;
+    let inner = rt.block_on(client::connect(addr))?;
 
     Ok(BlockingClient { inner, rt })
 }