Implementation to aggregate statistical information #12

Gemfile

@@ -26,6 +26,7 @@ gem 'secure_headers'
 # Rendering legal documents
 gem 'kramdown'
 
+gem 'faraday'
 # TODO: Delete this if the following issue is fixed
 # https://github.com/bundler/bundler/issues/5332
 gem 'faraday_middleware', '0.10'

Gemfile.lock

@@ -284,6 +284,7 @@ DEPENDENCIES
   bootstrap-sass
   capybara
   coffee-rails
+  faraday
   faraday_middleware (= 0.10)
   font-awesome-rails
   jbuilder
@@ -315,4 +316,4 @@ RUBY VERSION
    ruby 2.4.0p0
 
 BUNDLED WITH
-   1.13.7
+   1.15.3

app/models/dojo.rb

@@ -3,6 +3,9 @@ class Dojo < ApplicationRecord
   NUM_OF_WHOLE_DOJOS = "1,250"
   NUM_OF_JAPAN_DOJOS = Dojo.count.to_s
 
+  has_one :dojo_event_service
+  has_many :event_history
+
   serialize :tags
   default_scope -> { order(order: :asc) }
   before_save { self.email = self.email.downcase }

app/models/dojo_event_service.rb

@@ -0,0 +1,3 @@
+class DojoEventService < ApplicationRecord
+  belongs_to :dojo
+end

app/models/event_history.rb

@@ -0,0 +1,11 @@
+class EventHistory < ApplicationRecord
+  belongs_to :dojo
+
+  validates :dojo_name, presence: true
+  validates :service_name, presence: true, uniqueness: { scope: :event_id  }
+  validates :service_group_id, presence: true
+  validates :event_id, presence: true
+  validates :event_url, presence: true, uniqueness: true, allow_nil: true
+  validates :participants, presence: true
+  validates :evented_at, presence: true
+end

config/application.rb

@@ -11,5 +11,9 @@ class Application < Rails::Application
     # Settings in config/environments/* take precedence over those specified here.
     # Application configuration should go into files in config/initializers
     # -- all .rb files in that directory are automatically loaded.
+
+    # Timezone
+    config.time_zone = 'Asia/Tokyo'
+    ENV['TZ'] = 'Asia/Tokyo'
   end
 end

db/migrate/20170730050122_create_event_histories.rb

@@ -0,0 +1,18 @@
+class CreateEventHistories < ActiveRecord::Migration[5.0]
+  def change
+    create_table :event_histories do |t|
+      t.references :dojo, foreign_key: true, index: true, null: false
+      t.string :dojo_name, null: false
+      t.string :service_name, null: false
+      t.integer :service_group_id, null: false
+      t.integer :event_id, null: false
+      t.string :event_url, unique: true, null: false
+      t.integer :participants, null: false
+      t.datetime :evented_at, null: false
+      t.timestamps
+
+      t.index [:service_name, :event_id], unique: true
+      t.index [:evented_at, :dojo_id]
+    end
+  end
+end

db/migrate/20170730114150_create_dojo_event_services.rb

@@ -0,0 +1,11 @@
+class CreateDojoEventServices < ActiveRecord::Migration[5.0]
+  def change
+    create_table :dojo_event_services do |t|
+      t.references :dojo, foreign_key: true, index: true, null: false
+      t.string :name
+      t.string :url
+      t.integer :group_id
+      t.timestamps
+    end
+  end
+end

db/schema.rb

@@ -10,7 +10,17 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema.define(version: 20161217063010) do
+ActiveRecord::Schema.define(version: 20170730114150) do
+
+  create_table "dojo_event_services", force: :cascade do |t|
+    t.integer  "dojo_id",    null: false
+    t.string   "name"
+    t.string   "url"
+    t.integer  "group_id"
+    t.datetime "created_at", null: false
+    t.datetime "updated_at", null: false
+    t.index ["dojo_id"], name: "index_dojo_event_services_on_dojo_id"
+  end
 
   create_table "dojos", force: :cascade do |t|
     t.string   "name"
@@ -24,4 +34,20 @@
     t.datetime "updated_at",                        null: false
   end
 
+  create_table "event_histories", force: :cascade do |t|
+    t.integer  "dojo_id",          null: false
+    t.string   "dojo_name",        null: false
+    t.string   "service_name",     null: false
+    t.integer  "service_group_id", null: false
+    t.integer  "event_id",         null: false
+    t.string   "event_url",        null: false
+    t.integer  "participants",     null: false
+    t.datetime "evented_at",       null: false
+    t.datetime "created_at",       null: false
+    t.datetime "updated_at",       null: false
+    t.index ["dojo_id"], name: "index_event_histories_on_dojo_id"
+    t.index ["evented_at", "dojo_id"], name: "index_event_histories_on_evented_at_and_dojo_id"
+    t.index ["service_name", "event_id"], name: "index_event_histories_on_service_name_and_event_id", unique: true
+  end
+
 end

lib/statistics.rb

@@ -0,0 +1,3 @@
+module Statistics; end
+
+require_relative 'statistics/client'

lib/statistics/client.rb

@@ -0,0 +1,69 @@
+module Statistics
+  class Client
+    class_attribute :debug
+    self.debug = false
+
+    def initialize(endpoint, &block)
+      @conn = connection_for(endpoint, &block)
+    end
+
+    def get(path, params)
+      @conn.get(path, params).body
+    end
+
+    private
+
+    def connection_for(endpoint, &block)
+      Faraday.new(endpoint) do |f|
+        f.response :logger if self.debug
+        f.response :json, :content_type => /\bjson$/
+        f.response :raise_error
+
+        yield f if block_given?
+
+        f.adapter  Faraday.default_adapter
+      end
+    end
+
+    class Connpass
+      ENDPOINT = 'https://connpass.com/api/v1'.freeze
+
+      def initialize
+        @client = Client.new(ENDPOINT)
+      end
+
+      def fetch_series_id(**params)
+        @client.get('event/', params.merge(count: 1))
+          .fetch('events')
+          .first
+          .dig('series', 'id')
+      end
+
+      def fetch_events(series_id:)
+        @client.get('event/', series_id: series_id, count: 100)
+          .fetch('events')
+      end
+    end
+
+    class Doorkeeper
+      ENDPOINT = 'https://api.doorkeeper.jp'.freeze
+      DEFAULT_SINCE = Date.parse('2010-07-01')
+
+      def initialize
+        @client = Client.new(ENDPOINT) do |c|
+          c.authorization(:Bearer, ENV.fetch('DOORKEEPER_API_TOKEN'))
+        end
+      end
+
+      def fetch_group_id(keyword:)
+        @client.get('events', q: keyword, since: DEFAULT_SINCE)
+          .first
+          .dig('event', 'group')
+      end
+
+      def fetch_events(group_id:, offset: 1, since: DEFAULT_SINCE)
+        @client.get("groups/#{group_id}/events", offset: offset, since: since)
+      end
+    end
+  end
+end