WIP Refactor stuff

app/services/nostr_manager/fetch_latest_event.rb

@@ -1,59 +1,31 @@
 module NostrManager
   class FetchLatestEvent < NostrManagerService
-    TIMEOUT = 1
 
-    def initialize(filter:, relay_url:)
+    def initialize(relays:, filter:, max_events: 2)
+      @relays = relays
       @filter = filter
-      @relay = new_relay(relay_url)
-      @client = Nostr::Client.new
+      @max_events = max_events
     end
 
     def call
-      filter, client, relay = @filter, @client, @relay
-      latest_event = nil
-      mutex = Mutex.new
-      received_event = ConditionVariable.new
-      log_prefix = "[nostr][#{@relay.name}]"
+      received_events = 0
+      events = []
 
-      thread = Thread.new do
-        client.on :connect do
-          client.subscribe(filter: filter)
+      @relays.each do |url|
+        event = NostrManager::FetchEvent.call(filter: @filter, relay_url: url)
+
+        if event.present?
+          events << event if events.none? { |e| e["id"] == event["id"] }
+          received_events += 1
         end
 
-        client.on :error do |e|
-          Rails.logger.info "#{log_prefix} Error: #{e}"
-          Thread.current.exit
+        if received_events >= @max_events
+          puts "Found #{@max_events} events, ending the search"
+          break
         end
-
-        client.on :message do |m|
-          msg = JSON.parse(m) rescue nil
-          if msg && msg[0] == "EVENT" && msg[2]
-            puts "#{log_prefix} Event received: #{msg[2]["id"]}"
-            mutex.synchronize do
-              latest_event = msg[2]
-              received_event.signal
-            end
-          elsif msg && msg[0] == "EOSE"
-            Thread.current.exit
-          end
-        end
-
-        client.connect relay
       end
 
-      begin
-        Timeout.timeout(TIMEOUT) do
-          mutex.synchronize do
-            received_event.wait(mutex) if latest_event.nil?
-          end
-        end
-      rescue Timeout::Error
-        puts "#{log_prefix} Timeout: No event received within #{TIMEOUT} seconds"
-      ensure
-        thread.exit
-      end
-
-      latest_event
+      events.min_by { |e| e["created_at"] }
     end
   end
 end