From b7efe705e2865fa89cd3d3bfd3926fdb9667847d Mon Sep 17 00:00:00 2001 From: omagdy Date: Wed, 23 Jul 2025 03:20:14 +0300 Subject: feat: Implemented last step of handshake process --- src/lib.rs | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) (limited to 'src/lib.rs') diff --git a/src/lib.rs b/src/lib.rs index 4aef994..30e2d9f 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -79,6 +79,25 @@ fn handshake_process(slave: &RedisServer) -> Result<(), String> { if let Err(e) = stream.write_all(&resp_bytes!(array => [resp!(bulk "REPLCONF"), resp!(bulk "capa"), resp!(bulk "psync2")])) { return Err(format!("Failed to send: {}", e)); } + + let _ = match stream.read(&mut buffer) { + Ok(0) => return Ok(()), // connection closed + Ok(n) => n, + Err(_) => return Ok(()), // error occurred + }; + + if let Err(e) = stream.write_all( + &resp_bytes!(array => [resp!(bulk "PSYNC"), resp!(bulk "?"), resp!(bulk "-1")]), + ) { + return Err(format!("Failed to send: {}", e)); + } + + let _ = match stream.read(&mut buffer) { + Ok(0) => return Ok(()), // connection closed + Ok(n) => n, + Err(_) => return Ok(()), // error occurred + }; + Ok(()) } Err(e) => Err(format!("Master node doesn't exists: {}", e)), -- cgit v1.2.3