class Poll

# File lib/poll/poll.rb, line 22
def self.build(interval_milliseconds: nil, timeout_milliseconds: nil, delay_condition: nil)
  instance = new

  instance.interval_milliseconds = interval_milliseconds
  instance.timeout_milliseconds = timeout_milliseconds
  instance.delay_condition = delay_condition

  instance.configure

  instance
end

# File lib/poll/poll.rb, line 55
def self.call(interval_milliseconds: nil, timeout_milliseconds: nil, delay_condition: nil, &action)
  instance = build(interval_milliseconds: interval_milliseconds, timeout_milliseconds: timeout_milliseconds, delay_condition: delay_condition)
  instance.call(&action)
end

# File lib/poll/poll.rb, line 34
def self.configure(receiver, attr_name: nil, interval_milliseconds: nil, timeout_milliseconds: nil, delay_condition: nil, poll: nil)
  attr_name ||= :poll

  if !poll.nil?
    instance = poll
  else
    instance = build(interval_milliseconds: interval_milliseconds, timeout_milliseconds: timeout_milliseconds, delay_condition: delay_condition)
  end

  receiver.public_send "#{attr_name}=", instance
end

# File lib/poll/poll.rb, line 46
def self.none
  None.build
end

# File lib/poll/poll.rb, line 142
def self.register_telemetry_sink(cycle)
  sink = Telemetry.sink
  cycle.telemetry.register(sink)
  sink
end

# File lib/poll/poll.rb, line 60
def call(&action)
  stop_time = nil
  stop_time_iso8601 = nil
  if !timeout_milliseconds.nil?
    stop_time = clock.now + (timeout_milliseconds.to_f / 1000.0)
    stop_time_iso8601 = clock.iso8601(stop_time, precision: 5)
  end

  logger.trace { "Cycling (Interval Milliseconds: #{interval_milliseconds}, Timeout Milliseconds: #{timeout_milliseconds.inspect}, Stop Time: #{stop_time_iso8601})" }

  cycle = -1
  result = nil
  loop do
    cycle += 1
    telemetry.record :cycle, cycle

    result, elapsed_milliseconds = invoke(cycle, &action)

    if delay_condition.(result)
      logger.debug { "Got no results from action (Cycle: #{cycle})" }
      delay(elapsed_milliseconds)
    else
      logger.debug { "Got results from action (Cycle: #{cycle})" }
      telemetry.record :got_result
      break
    end

    if !timeout_milliseconds.nil?
      now = clock.now
      if now >= stop_time
        logger.debug { "Timeout has lapsed (Cycle: #{cycle}, Stop Time: #{stop_time_iso8601}, Timeout Milliseconds: #{timeout_milliseconds})" }
        telemetry.record :timed_out, now
        break
      end
    end
  end

  logger.debug { "Cycled (Iterations: #{cycle + 1}, Interval Milliseconds: #{interval_milliseconds}, Timeout Milliseconds: #{timeout_milliseconds.inspect}, Stop Time: #{stop_time_iso8601})" }

  return result
end

# File lib/poll/poll.rb, line 50
def configure
  Clock::UTC.configure self
  ::Telemetry.configure self
end

# File lib/poll/poll.rb, line 123
def delay(elapsed_milliseconds)
  delay_milliseconds = interval_milliseconds - elapsed_milliseconds

  logger.trace { "Delaying (Delay Milliseconds: #{delay_milliseconds}, Interval Milliseconds: #{interval_milliseconds}, Elapsed Milliseconds: #{elapsed_milliseconds})" }

  if delay_milliseconds <= 0
    logger.debug { "Elapsed time exceeds or equals interval. Not delayed. (Delay Milliseconds: #{delay_milliseconds}, Interval Milliseconds: #{interval_milliseconds}, Elapsed Milliseconds: #{elapsed_milliseconds})" }
    return
  end

  delay_seconds = (delay_milliseconds.to_f / 1000.0)

  sleep delay_seconds

  telemetry.record :delayed, delay_milliseconds

  logger.debug { "Finished delaying (Delay Milliseconds: #{delay_milliseconds}, Interval Milliseconds: #{interval_milliseconds}, Elapsed Milliseconds: #{elapsed_milliseconds})" }
end

# File lib/poll/poll.rb, line 18
def delay_condition
  @delay_condition ||= Defaults.delay_condition
end

# File lib/poll/poll.rb, line 11
def interval_milliseconds
  @interval_milliseconds ||= Defaults.interval_milliseconds
end

# File lib/poll/poll.rb, line 102
def invoke(cycle, &action)
  if action.nil?
    raise Error, "Poll must be actuated with a block"
  end

  action_start_time = clock.now

  logger.trace { "Invoking action (Cycle: #{cycle}, Start Time: #{clock.iso8601(action_start_time, precision: 5)})" }

  result = action.call(cycle)

  action_end_time = clock.now
  elapsed_milliseconds = clock.elapsed_milliseconds(action_start_time, action_end_time)

  telemetry.record :invoked_action, elapsed_milliseconds

  logger.debug { "Invoked action (Cycle: #{cycle}, Elapsed Milliseconds: #{elapsed_milliseconds}, Start Time: #{clock.iso8601(action_start_time, precision: 5)}, End Time: #{clock.iso8601(action_end_time, precision: 5)})" }

  [result, elapsed_milliseconds]
end