Use Hash#fetch for connpass to fetch responses to validate if given column exists

Author: yasulab

lib/upcoming_events/tasks/connpass.rb

@@ -12,21 +12,24 @@ def run
           dojo.dojo_event_services.for(:connpass).pluck(:group_id)
         end
 
-        @client.fetch_events(**@params.merge(group_id: group_ids)).each do |e|
-          dojo_event_service = DojoEventService.find_by(group_id: e.dig('series', 'id').to_s)
+        events = @client.fetch_events(**@params.merge(group_id: group_ids))
+        puts "[connpass] Fetched events: #{events.size}"
+        events.each do |e|
+          puts "[connpass] event_id: #{e.fetch('id')}, title: #{e.fetch('title')}"
+          dojo_event_service = DojoEventService.find_by(group_id: e.dig('group', 'id').to_s)
           next unless dojo_event_service
 
-          record = dojo_event_service.upcoming_events.find_or_initialize_by(event_id: e['event_id'])
+          record = dojo_event_service.upcoming_events.find_or_initialize_by(event_id: e.fetch('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'])
+                         event_title:  e.fetch('title'),
+                         event_url:    e.fetch('url'),
+                         event_at:     Time.zone.parse(e.fetch('started_at')),
+                         event_end_at: Time.zone.parse(e.fetch('ended_at')),
+                         participants: e.fetch('accepted'),
+                         event_update_at: Time.zone.parse(e.fetch('updated_at')),
+                         address:      e.fetch('address'),
+                         place:        e.fetch('place'),
+                         limit:        e.fetch('limit'))
         end
       end
 

lib/upcoming_events/tasks/doorkeeper.rb

@@ -11,7 +11,9 @@ def run
         @dojos.each do |dojo|
           dojo.dojo_event_services.for(:doorkeeper).each do |dojo_event_service|
             events = @client.fetch_events(**@params.merge(group_id: dojo_event_service.group_id))
+            puts "[doorkeeper] dojo_id: #{dojo.id}, group_id: #{dojo_event_service.group_id}, fetched events: #{events&.size || 0}"
             (events || []).compact.each do |e|
+              puts "[doorkeeper] event_id: #{e['id']}, title: #{e['title']}"
               next unless e['group'].to_s == dojo_event_service.group_id
 
               record = dojo_event_service.upcoming_events.find_or_initialize_by(event_id: e['id'])