aggregation.rb

module UpcomingEvents
  class Aggregation
    def initialize(args)
      # NOTE: 1 ヶ月前 〜 2 ヶ月後のイベント情報を対象に収集
      today = Time.zone.today
      @from = today - 1.months + 1.day
      @to   = today + 2.months
      @provider = args[:provider]

      # NOTE: 対象は一旦収集可能な connpass, doorkeeper のみにする
      @externals = fetch_dojos(@provider)
    end

    def run
      puts "UpcomingEvents aggregate"
      with_notifying do
        delete_upcoming_events
        execute
      end
    end

    private

    def fetch_dojos(provider)
      base_providers = DojoEventService::EXTERNAL_SERVICES - [:facebook]
      services = if provider.blank?
                   # 全プロバイダ対象
                   base_providers
                 elsif base_providers.include?(provider.to_sym)
                   [provider.to_sym]
                 end
      return [] unless services
      find_dojos_by(services)
    end

    def find_dojos_by(services)
      services.each.with_object({}) do |name, hash|
        hash[name] = Dojo.eager_load(:dojo_event_services).where(dojo_event_services: { name: name }).to_a
      end
    end

    def with_notifying
      yield
      Notifier.notify_success(@provider)
    rescue => e
      Notifier.notify_failure(@provider, e)
    end

    def delete_upcoming_events
      UpcomingEvent.until(@from).delete_all
    end

    def execute
      target_period = @from..@to
      @externals.each do |kind, list|
        puts "Aggregate of #{kind}"
        "UpcomingEvents::Tasks::#{kind.to_s.camelize}".constantize.new(list, target_period).run
      end
    end

    class Notifier
      class << self
        def notify_success(provider)
          # NOTE: UNIX 哲学に沿って、成功時は何も表示せず失敗時 (notify_failure) のみ通知する
          #       https://ja.wikipedia.org/wiki/UNIX哲学#:~:text=沈黙のルール
          # notify("近日開催イベント情報#{provider_info(provider)}を収集しました")
        end

        def notify_failure(provider, exception)
          notify("近日開催イベント情報の収集#{provider_info(provider)}でエラーが発生しました\n#{exception.message}\n#{exception.backtrace.join("\n")}")
        end

        private

        def provider_info(provider)
          provider ? "(#{provider})" : nil
        end

        def slack_hook_url
          @slack_hook_url ||= ENV['SLACK_HOOK_URL']
        end

        def notifierable?
          slack_hook_url.present?
        end

        def notify(msg)
          $stdout.puts msg
          SlackNotifier.post_message(msg, slack_hook_url) if notifierable?
        end
      end
    end
  end
end