Merge pull request #54 from harness/FFM-12281

feat: [FFM-12281]: thread safety fixes

Author: conormurray95

lib/ff/ruby/server/sdk/api/cf_client.rb

@@ -5,13 +5,17 @@
 
 class CfClient < Closeable
   include Singleton
-
+  
+  @@instance_mutex = Mutex.new
   def init(api_key, config, connector = nil)
     # Only initialize if @client is nil to avoid reinitialization
-    unless @client
-      @config = config || ConfigBuilder.new.build
-      @client = InnerClient.new(api_key, @config, connector)
-      @config.logger.debug "Client initialized with API key: #{api_key}"
+    
+    @@instance_mutex.synchronize do
+      unless @client
+        @config = config || ConfigBuilder.new.build
+        @client = InnerClient.new(api_key, @config, connector)
+        @config.logger.debug "Client initialized with API key: #{api_key}"
+      end
     end
     @client
   end

lib/ff/ruby/server/sdk/api/inner_client.rb

@@ -120,9 +120,11 @@ def on_auth_success
   end
 
   def on_auth_failed
-    SdkCodes::warn_auth_failed_srv_defaults @config.logger
-    @initialized = true
-    @condition.signal
+    @my_mutex.synchronize do
+      SdkCodes::warn_auth_failed_srv_defaults @config.logger
+      @initialized = true
+      @condition.broadcast
+    end
   end
 
   def close
@@ -243,7 +245,7 @@ def on_processor_ready(processor)
 
       SdkCodes.info_sdk_init_ok @config.logger
 
-      @condition.signal
+      @condition.broadcast
       @initialized = true
     end
   end
@@ -257,7 +259,6 @@ def wait_for_initialization(timeout: nil)
       remaining = timeout ? timeout / 1000.0 : nil # Convert timeout to seconds
 
       until @initialized
-
         # Break if timeout has elapsed
         if remaining && remaining <= 0
           @config.logger.warn "The SDK has timed out waiting to initialize with supplied timeout #{timeout} ms. The SDK will continue to initialize in the background.  Default variations will be served until the SDK initializes."