module GnipApi
  module PowerTrack
    class Buffer
      attr_reader :terminator, :data
      
      def initialize options={}
        @terminator = options.delete(:terminator) || "\r\n"
        @data = ""
        @limit = GnipApi.config.buffer_limit
      end
      
      def size
        @data.size
      end
      
      def insert! chunk
        @data << chunk
      end

      def read!
        objects = @data.split(terminator)[0..-2]
        unless objects.empty?
          # Get the number of chars to read from buffer, counting
          # the size of each splited chunk plus the number of chunks by
          # terminator size, since it's still present in the buffer
          size = objects.map(&:size).reduce(:+) + objects.size * terminator.size
          consume!(size)
        end
        return objects
      end

      def consume! chars
        @data[0..chars-1] = ''
      end

      def over_limit?
        return false unless @limit
        return size > @limit
      end
    end
  end
end