dispatcher.rb

module Providence
  class Dispatcher < Strategy
    class << self
      include Configurable
    end
    include Configurable
    inherit_configuration_from Strategy

    def self.strategies
      configuration.strategies || []
    end

    def initialize agency, transport
      @strategies = configuration.strategies.map { |klass| klass.new agency, transport }
    end

    def activate
      EM::MultiRequest.new.tap do |multi|
        @strategies.each { |st| multi.add st, st.activate }
      end
    end

    def do_visits_between station, start_s, end_s, limit, **_
      start_time = Time.parse(start_s)
      end_time   = Time.parse(end_s)
      profile_time = Time.now
      log = proc do |result| 
        puts <<~EOF
        Received call to `providence.visits_between`:
            stop:   #{station}
            start:  #{start_s}
            end:    #{end_s}
            count:  #{limit}
        Responded in #{(Time.now - profile_time) * 1000}ms with:
        #{result}
        EOF
      end
      @strategies.lazy.map do |strategy| 
        strategy.visits_between(station, start_time, end_time, limit)
      end.select(&:itself).first.callback { |result| log.call result }
    end
  end
end