perform a status test when initializing the solr connector

lib/goo/search/solr/solr_admin.rb

@@ -5,6 +5,19 @@ def admin_url
       "#{@solr_url}/admin"
     end
 
+    def solr_alive?
+      collections_url = URI.parse("#{admin_url}/collections?action=CLUSTERSTATUS")
+      http = Net::HTTP.new(collections_url.host, collections_url.port)
+      request = Net::HTTP::Get.new(collections_url.request_uri)
+
+      begin
+        response = http.request(request)
+        return response.code.eql?("200") && JSON.parse(response.body).dig("responseHeader", "status").eql?(0)
+      rescue StandardError => e
+        return false
+      end
+    end
+
     def fetch_all_collections
       collections_url = URI.parse("#{admin_url}/collections?action=LIST")
 

lib/goo/search/solr/solr_connector.rb

@@ -14,6 +14,17 @@ def initialize(solr_url, collection_name)
       @solr_url = solr_url
       @collection_name = collection_name
       @solr = RSolr.connect(url: collection_url)
+
+      # Perform a status test and wait up to 30 seconds before raising an error
+      wait_time = 0
+      max_wait_time = 30
+      until solr_alive? || wait_time >= max_wait_time
+        sleep 1
+        wait_time += 1
+      end
+      raise "Solr instance not reachable within #{max_wait_time} seconds" unless solr_alive?
+
+
       @custom_schema = false
     end