doorkeeperのイベント取得で、イベントデータのキーをシンボルに変更

Author: rakuda-san-desu

lib/event_service/providers/doorkeeper.rb

@@ -31,7 +31,7 @@ def fetch_events(group_id:, since_at: @default_since, until_at: @default_until)
 
               break if part.size.zero?
 
-              events.push(*part.map { |e| e['event'] })
+              events.push(*part.map { |e| e[:event] })
 
               break if part.size < 25   # 25 items / 1 request
 

lib/upcoming_events/tasks/doorkeeper.rb

@@ -13,20 +13,22 @@ def run
             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.fetch('id')}, title: #{e.fetch('title')}"
-              next unless e.fetch('group').to_s == dojo_event_service.group_id
+              puts "[Doorkeeper] event_id: #{e.fetch(:id)}, title: #{e.fetch(:title)}"
+              next unless e.fetch(:group).to_s == dojo_event_service.group_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.fetch('title'),
-                             event_url:    e.fetch('public_url'),
-                             participants: e.fetch('participants'),
-                             event_at:     Time.zone.parse(e.fetch('starts_at')),
-                             event_end_at: Time.zone.parse(e.fetch('ends_at')),
-                             event_update_at: Time.zone.parse(e.fetch('updated_at')),
-                             address:      e.fetch('address'),
-                             place:        e.fetch('venue_name'),
-                             limit:        e.fetch('ticket_limit'))
+              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.fetch(:title),
+                event_url:    e.fetch(:public_url),
+                participants: e.fetch(:participants),
+                event_at:     Time.zone.parse(e.fetch(:starts_at)),
+                event_end_at: Time.zone.parse(e.fetch(:ends_at)),
+                event_update_at: Time.zone.parse(e.fetch(:updated_at)),
+                address:      e.fetch(:address),
+                place:        e.fetch(:venue_name),
+                limit:        e.fetch(:ticket_limit)
+              )
             end
           end
         end