added a wait for port to be avaiable to increase reliability of the specs

Author: patvice

spec/fixtures/fast-mcp-ruby/lib/app.rb

@@ -124,7 +124,7 @@ def content
 log_writer = is_silent ? Puma::LogWriter.new(NullWriter.new, NullWriter.new) : Puma::LogWriter.stdio
 
 config = Puma::Configuration.new(log_writer: log_writer) do |user_config|
-  user_config.bind "tcp://localhost:3006"
+  user_config.bind "tcp://127.0.0.1:3006"
   user_config.app app
 end
 

spec/support/test_server_manager.rb

@@ -1,5 +1,8 @@
 # frozen_string_literal: true
 
+require "socket"
+require "timeout"
+
 class TestServerManager
   SERVERS = {
     stdio: {
@@ -10,18 +13,21 @@ class TestServerManager
     http: {
       command: "bun",
       args: ["spec/fixtures/typescript-mcp/index.ts", "--", "--silent"],
-      pid_accessor: :http_server_pid
+      pid_accessor: :http_server_pid,
+      port: 3005
     },
     pagination: {
       command: "bun",
       args: ["spec/fixtures/pagination-server/index.ts", "--", "--silent"],
-      pid_accessor: :pagination_server_pid
+      pid_accessor: :pagination_server_pid,
+      port: 3007
     },
     sse: {
       command: "ruby",
       args: ["lib/app.rb", "--silent"],
       chdir: "spec/fixtures/fast-mcp-ruby",
-      pid_accessor: :sse_server_pid
+      pid_accessor: :sse_server_pid,
+      port: 3006
     }
   }.freeze
 
@@ -35,9 +41,6 @@ def start_server
         start_server_type(:stdio)
         start_server_type(:http)
         start_server_type(:pagination)
-
-        # Give servers time to start
-        sleep 1.0
       rescue StandardError => e
         puts "Failed to start test server: #{e.message}"
         stop_server
@@ -97,6 +100,9 @@ def start_server_type(server_type)
       pid = spawn(config[:command], *config[:args], **spawn_options)
       Process.detach(pid)
       send("#{pid_accessor}=", pid)
+
+      # Wait for the server to start, ensure they are ready to start
+      wait_for_port(config[:port]) if config[:port]
     end
 
     def stop_server_type(server_type)
@@ -118,6 +124,17 @@ def stop_server_type(server_type)
       end
     end
 
+    def wait_for_port(port, host = "127.0.0.1", timeout = 15)
+      Timeout.timeout(timeout) do
+        loop do
+          Socket.tcp(host, port, connect_timeout: 1).close
+          break
+        rescue Errno::ECONNREFUSED, Errno::EHOSTUNREACH
+          sleep 0.1
+        end
+      end
+    end
+
     def process_exists?(pid)
       Process.kill(0, pid)
       true