Complete the handshake

1 files changed, 4 insertions, 1 deletions

diff --git a/src/saprus.zig b/src/saprus.zig
index 97748be..9d676c1 100644
--- a/src/saprus.zig
+++ b/src/saprus.zig
@@ -131,10 +131,13 @@ pub fn connect(payload: []const u8, allocator: Allocator) !?SaprusMessage {
     try setting_up_socket.timedWait(500 * 1000 * 1000 * 1000);
 
     const msg = try sendInitialConnection(payload, initial_port, allocator);
-    _ = msg;
 
+    // Await response from the sentinel
     response_thread.join();
 
+    // Complete handshake after awaiting response
+    try broadcastSaprusMessage(msg, allocator);
+
     return initial_conn_res;
 }