module Scrivito

class Revision < Struct.new(:id, :workspace, :base)
  def initialize(options)
    super(*options.values_at(:id, :workspace, :base))
  end

  def content_state_id
    base ? workspace.base_content_state_id : workspace.content_state_id
  end

  def content_state_node
    @node ||= Backend::ContentStateNode.new(content_state_id)
  end

  # returns a list of raw rest-api hashes, one for each given id
  def obj_mget_request(ids)
    internal_obj_mget(ids, [])
  end

  # performs given search-query, returns the search-hits as a list of obj-ids
  def obj_search_request(query)
    if base
      raise Scrivito::InternalError, "search not possible for base revision"
    end

    internal_obj_search(query, [])
  end

  def api_request(verb, path, payload = nil)
    CmsRestApi.public_send(verb, "revisions/#{id}#{path}", payload)
  end

  def base?
    !!base
  end

  private

  def internal_obj_search(query, result, continuation=nil, tentative=false)
    response = workspace.api_request(:get, "/objs/search",
      query: query,
      include_deleted: true,
      size: 100,
      continuation: continuation,
      consistent_with: content_state_id
    )

    cur_result = response['results'].map { |obj_data| obj_data['id'] }
    result += cur_result
    continuation = response['continuation']
    tentative ||= !!response['tentative']

    if continuation
      internal_obj_search(query, result, continuation, tentative)
    else
      [result.uniq, tentative]
    end
  end

  def internal_obj_mget(ids, result)
    response = api_request(
        :get, "/objs/mget", ids: ids, include_deleted: true)

    current_result = result + response["results"]

    if response["results"].size < ids.size
      internal_obj_mget(ids.drop(response["results"].size), current_result)
    else
      current_result
    end
  end
end

end