Support facebook on Statistics::Aggregation

Author: nalabjp

app/models/dojo_event_service.rb

@@ -1,4 +1,4 @@
 class DojoEventService < ApplicationRecord
   belongs_to :dojo
-  enum name: %i( connpass doorkeeper )
+  enum name: %i( connpass doorkeeper facebook )
 end

lib/statistics/aggregation.rb

@@ -4,9 +4,11 @@ class << self
       def run(date:)
         cnps_dojos = Dojo.joins(:dojo_event_service).where(dojo_event_services: { name: :connpass }).to_a
         drkp_dojos = Dojo.joins(:dojo_event_service).where(dojo_event_services: { name: :doorkeeper }).to_a
+        fsbk_dojos = Dojo.joins(:dojo_event_service).where(dojo_event_services: { name: :facebook }).to_a
 
         Connpass.run(cnps_dojos, date)
         Doorkeeper.run(drkp_dojos, date)
+        Facebook.run(fsbk_dojos, date)
       end
     end
 
@@ -62,5 +64,32 @@ def run(dojos, date)
         end
       end
     end
+
+    class Facebook
+      class << self
+        def run(dojos, date)
+          fsbk = Client::Facebook.new
+          params = {
+            since_at: date.beginning_of_month,
+            until_at: date.end_of_month
+          }
+
+          dojos.each do |dojo|
+            fsbk.fetch_events(params.merge(group_id: dojo.dojo_event_service.group_id)).each do |e|
+              next unless e.dig('owner', 'id') == dojo.dojo_event_service.group_id
+
+              EventHistory.create!(dojo_id: dojo.id,
+                                   dojo_name: dojo.name,
+                                   service_name: dojo.dojo_event_service.name,
+                                   service_group_id: dojo.dojo_event_service.group_id,
+                                   event_id: e['id'],
+                                   event_url: "https://www.facebook.com/events/#{e['id']}",
+                                   participants: e['attending_count'],
+                                   evented_at: Time.zone.parse(e['start_time']))
+            end
+          end
+        end
+      end
+    end
   end
 end

spec/lib/statistics/aggregation_spec.rb

@@ -4,6 +4,7 @@
 RSpec.describe Statistics::Aggregation do
   include_context 'Use stubs for Connpass'
   include_context 'Use stubs for Doorkeeper'
+  include_context 'Use stubs for Facebook'
 
   before(:all) do
     Dojo.delete_all
@@ -21,14 +22,16 @@
     before do
       d1 = Dojo.create(name: 'Dojo1', email: 'info@dojo1.com', description: 'CoderDojo1', tags: %w(CoderDojo1), url: 'https://dojo1.com')
       d2 = Dojo.create(name: 'Dojo2', email: 'info@dojo2.com', description: 'CoderDojo2', tags: %w(CoderDojo2), url: 'https://dojo2.com')
+      d3 = Dojo.create(name: 'Dojo3', email: 'info@dojo3.com', description: 'CoderDojo3', tags: %w(CoderDojo3), url: 'https://dojo3.com')
       DojoEventService.create(dojo_id: d1.id, name: :connpass, group_id: 9876)
       DojoEventService.create(dojo_id: d2.id, name: :doorkeeper, group_id: 5555)
+      DojoEventService.create(dojo_id: d3.id, name: :facebook, group_id: 123451234512345)
     end
 
     subject { Statistics::Aggregation.run(date: Time.current) }
 
     it do
-      expect{ subject }.to change{EventHistory.count}.from(0).to(2)
+      expect{ subject }.to change{EventHistory.count}.from(0).to(3)
     end
   end
 end