class RailsAiAdmin::Collections::Queries

# File lib/rails_ai_admin/collections/queries.rb, line 11
def fetch(context:, job_ref:, summary: false)
  ActiveRecord::Base.while_preventing_writes do
    parent = Contract.owned(context, job_ref)
    resource, definition = Contract.definition(parent)
    access = Authorization::Access.new(context, resource)
    access.authorize_receipt!(parent.operation, nil)
    Contract.verify_manifest!(parent)
    Contract.verify_approved!(parent, definition, context) if parent.approved_digest
    items = BatchItem.where(parent_run_id: parent.id).order(:position).limit(Selections::Builder::LIMIT + 1).to_a
    if parent.approved_digest && items.size != parent.manifest_payload.size
      raise ConfigurationError, "Collection result manifest is inconsistent"
    end
    counts = items.group_by(&:status).transform_values(&:size).freeze
    entries = summary ? [] : items.filter_map { |item| entry(access, parent, item) }
    cancellable = begin
      access.authorize_cancel!(parent.operation)
      parent.status == "proposed" || Contract::ACTIVE.include?(parent.status)
    rescue AccessDenied
      false
    end
    waiting = Contract::ACTIVE.include?(parent.status) && items.none? { |item| item.status == "running" } ?
      items.select { |item| item.status == "queued" }.map(&:created_at).compact.min : nil
    Snapshot.new(parent.id, resource.key.to_s, parent.operation, definition.description, parent.status, counts,
      entries.freeze, summary ? 0 : items.size - entries.size, cancellable, parent.warning_code, waiting)
  end
rescue StandardError => error
  raise if error.is_a?(AccessDenied) || error.is_a?(ConfigurationError)
  raise ConfigurationError, "Collection result cannot be projected safely", cause: nil
end

# File lib/rails_ai_admin/collections/queries.rb, line 41
def recent(context:)
  raise AccessDenied, "UNAUTHENTICATED" unless context.is_a?(Context)
  refs = OperationRun.where(actor_ref: context.actor_ref, tenant_ref: context.tenant_ref, security_version: context.security_version,
    parent_run_id: nil).where.not(selection_id: nil).where.not(status: "proposed").order(created_at: :desc, id: :desc).limit(50).pluck(:id)
  refs.filter_map do |ref|
    fetch(context: context, job_ref: ref, summary: true)
  rescue AccessDenied
    nil
  end
end