call connpass API with multiple series_ids

Author: takatama

lib/statistics/tasks/connpass.rb

@@ -14,24 +14,25 @@ def initialize(dojos, period)
       end
 
       def run
-        @dojos.each do |dojo|
-          dojo.dojo_event_services.for(:connpass).each do |dojo_event_service|
-            @client.fetch_events(**@params.merge(series_id: dojo_event_service.group_id)).each do |e|
-              next unless e.dig('series', 'id').to_s == dojo_event_service.group_id
-        
-              EventHistory.create!(dojo_id: dojo.id,
-                                   dojo_name: dojo.name,
-                                   service_name: dojo_event_service.name,
-                                   service_group_id: dojo_event_service.group_id,
-                                   event_id: e['event_id'],
-                                   event_url: e['event_url'],
-                                   participants: e['accepted'],
-                                   evented_at: Time.zone.parse(e['started_at']))
-            end
-          end
+        group_ids = @dojos.flat_map do |dojo|
+          dojo.dojo_event_services.for(:connpass).pluck(:group_id)
+        end
+      
+        @client.fetch_events(**@params.merge(series_id: group_ids)).each do |e|
+          dojo_event_service = DojoEventService.find_by(group_id: e.dig('series', 'id').to_s)
+          next unless dojo_event_service
+      
+          EventHistory.create!(dojo_id: dojo_event_service.dojo_id,
+                               dojo_name: dojo_event_service.dojo.name,
+                               service_name: dojo_event_service.name,
+                               service_group_id: dojo_event_service.group_id,
+                               event_id: e['event_id'],
+                               event_url: e['event_url'],
+                               participants: e['accepted'],
+                               evented_at: Time.zone.parse(e['started_at']))
         end
       end
-
+      
       private
 
       def build_params(period)

lib/upcoming_events/tasks/connpass.rb

@@ -8,24 +8,25 @@ def initialize(dojos, period)
       end
 
       def run
-        @dojos.each do |dojo|
-          dojo.dojo_event_services.for(:connpass).each do |dojo_event_service|
-            @client.fetch_events(**@params.merge(series_id: dojo_event_service.group_id)).each do |e|
-              next unless e.dig('series', 'id').to_s == dojo_event_service.group_id
-
-              record = dojo_event_service.upcoming_events.find_or_initialize_by(event_id: e['event_id'])
-              record.update!(service_name: dojo_event_service.name,
-                             event_title:  e['title'],
-                             event_url:    e['event_url'],
-                             event_at:     Time.zone.parse(e['started_at']),
-                             event_end_at: Time.zone.parse(e['ended_at']),
-                             participants: e['accepted'],
-                             event_update_at: Time.zone.parse(e['updated_at']),
-                             address:      e['address'],
-                             place:        e['place'],
-                             limit:        e['limit'])
-            end
-          end
+        group_ids = @dojos.flat_map do |dojo|
+          dojo.dojo_event_services.for(:connpass).pluck(:group_id)
+        end
+      
+        @client.fetch_events(**@params.merge(series_id: group_ids)).each do |e|
+          dojo_event_service = DojoEventService.find_by(group_id: e.dig('series', 'id').to_s)
+          next unless dojo_event_service
+      
+          record = dojo_event_service.upcoming_events.find_or_initialize_by(event_id: e['event_id'])
+          record.update!(service_name: dojo_event_service.name,
+                         event_title:  e['title'],
+                         event_url:    e['event_url'],
+                         event_at:     Time.zone.parse(e['started_at']),
+                         event_end_at: Time.zone.parse(e['ended_at']),
+                         participants: e['accepted'],
+                         event_update_at: Time.zone.parse(e['updated_at']),
+                         address:      e['address'],
+                         place:        e['place'],
+                         limit:        e['limit'])
         end
       end