module EventSource
  class Iterator
    include Log::Dependency

    dependency :cycle, Cycle

    attr_accessor :position
    attr_accessor :batch
    attr_writer :batch_position
    attr_writer :stream_offset

    def batch_position
      @batch_position ||= 0
    end

    def stream_offset
      @stream_offset ||= (position || 0)
    end

    initializer :get

    def self.build(get, position: nil, cycle: nil)
      new(get).tap do |instance|
        instance.position = position
        Cycle.configure instance, cycle: cycle
      end
    end

    def self.configure(receiver, get, attr_name: nil, position: nil, cycle: nil)
      attr_name ||= :iterator
      instance = build(get, position: position, cycle: cycle)
      receiver.public_send "#{attr_name}=", instance
    end

    def next
      logger.trace { "Getting next event data (Batch Length: #{batch.nil? ? '<none>' : batch.length}, Batch Position: #{batch_position}, Stream Offset: #{stream_offset})" }

      resupply(batch)

      event_data = batch[batch_position]

      logger.debug { "Finished getting next event data (Batch Length: #{batch.nil? ? '<none>' : batch.length}, Batch Position: #{batch_position}, Stream Offset: #{stream_offset})" }
      logger.debug(tags: [:data, :event_data]) { "Event Data: #{event_data.pretty_inspect}" }

      advance_positions

      event_data
    end

    def resupply(batch)
      logger.trace { "Resupplying batch" }

      if batch.nil?
        batch_log_text = "Batch: #{batch.inspect}"
      else
        batch_log_text = "Batch Length: #{batch.length}"
      end

      if batch.nil? || batch_position == batch.length
        logger.debug { "Current batch is depleted (#{batch_log_text}, Batch Position: #{batch_position})" }

        batch = get_batch
        reset(batch)
      else
        logger.debug { "Current batch not depleted (#{batch_log_text}, Batch Position: #{batch_position})" }
      end

      logger.debug { "Finished resupplying batch" }
    end

    def reset(batch)
      logger.trace { "Resetting batch" }

      self.batch = batch
      self.batch_position = 0

      logger.debug { "Reset batch" }
      logger.debug(tags: [:data, :batch]) { "Batch: #{batch.pretty_inspect}" }
      logger.debug(tags: [:data, :batch]) { "Batch Position: #{batch_position.inspect}" }
    end

    def get_batch
      logger.trace "Getting batch"

      batch = nil
      cycle.() do
        batch = get.(position: stream_offset)
      end

      logger.debug { "Finished getting batch (Count: #{batch.length})" }

      batch
    end

    def advance_positions
      logger.trace { "Advancing positions (Batch Position: #{batch_position}, Stream Offset: #{stream_offset})" }
      self.batch_position += 1
      self.stream_offset += 1
      logger.debug { "Advanced positions (Batch Position: #{batch_position}, Stream Offset: #{stream_offset})" }
    end
  end
end