# Copyright (C) The Arvados Authors. All rights reserved.
#
# SPDX-License-Identifier: AGPL-3.0

require 'arvados/collection'
require 'validate_serialized'
require 'whitelist_update'

class ContainerRequest < ArvadosModel
  include ArvadosModelUpdates
  include HasUuid
  include KindAndEtag
  include CommonApiTemplate
  include WhitelistUpdate

  belongs_to :container,
             foreign_key: 'container_uuid',
             primary_key: 'uuid',
             optional: true
  belongs_to :requesting_container,
             class_name: 'Container',
             foreign_key: 'requesting_container_uuid',
             primary_key: 'uuid',
             optional: true

  # Posgresql JSONB columns should NOT be declared as serialized, Rails 5
  # already know how to properly treat them.
  attribute :properties, :jsonbHash, default: {}
  attribute :secret_mounts, :jsonbHash, default: {}
  attribute :output_storage_classes, :jsonbArray, default: lambda { Rails.configuration.DefaultStorageClasses }
  attribute :output_properties, :jsonbHash, default: {}
  attribute :published_ports, :jsonbHash, default: {}

  serialize :environment, Hash
  serialize :mounts, Hash
  serialize :runtime_constraints, Hash
  serialize :command, Array
  serialize :scheduling_parameters, Hash
  serialize :output_glob, Array

  after_find :fill_container_defaults_after_find
  after_initialize { @state_was_when_initialized = self.state_was } # see finalize_if_needed
  before_validation :fill_field_defaults, :if => :new_record?
  before_validation :fill_cuda_to_gpu
  before_validation :fill_container_defaults
  validates :command, :container_image, :output_path, :cwd, :presence => true
  validates :output_ttl, numericality: { only_integer: true, greater_than_or_equal_to: 0 }
  validates :priority, numericality: { only_integer: true, greater_than_or_equal_to: 0, less_than_or_equal_to: 1000 }
  validates :command, array_of_strings: {allow_empty_strings: true}
  validates :environment, hash_attr: true
  validates :mounts, hash_attr: true
  validates :output_glob, array_of_strings: true
  validates :output_properties, hash_attr: true
  validates :output_storage_classes, array_of_strings: true
  validates :published_ports, hash_attr: true
  validates :properties, hash_attr: true
  validates :runtime_constraints, hash_attr: true
  validates :scheduling_parameters, hash_attr: true
  validates :secret_mounts, hash_attr: true
  validate :validate_datatypes
  validate :validate_runtime_constraints
  validate :validate_scheduling_parameters
  validate :validate_state_change
  validate :check_update_whitelist
  validate :secret_mounts_key_conflict
  validate :validate_runtime_token
  validate :validate_published_ports
  after_validation :scrub_secrets
  after_validation :set_preemptible
  after_validation :set_container
  before_create :set_requesting_container_uuid
  before_destroy :set_priority_zero
  after_save :update_priority
  after_save :finalize_if_needed

  api_accessible :user, extend: :common do |t|
    t.add :command
    t.add :container_count
    t.add :container_count_max
    t.add :container_image
    t.add :container_uuid
    t.add :cwd
    t.add :description
    t.add :environment
    t.add :expires_at
    t.add :filters
    t.add :log_uuid
    t.add :mounts
    t.add :name
    t.add :output_name
    t.add :output_path
    t.add :output_glob
    t.add :output_uuid
    t.add :output_ttl
    t.add :priority
    t.add :properties
    t.add :requesting_container_uuid
    t.add :runtime_constraints
    t.add :scheduling_parameters
    t.add :state
    t.add :use_existing
    t.add :output_storage_classes
    t.add :output_properties
    t.add :cumulative_cost
    t.add :service
    t.add :published_ports
  end

  # Supported states for a container request
  States =
    [
     (Uncommitted = 'Uncommitted'),
     (Committed = 'Committed'),
     (Final = 'Final'),
    ]

  State_transitions = {
    nil => [Uncommitted, Committed],
    Uncommitted => [Committed],
    Committed => [Final]
  }

  AttrsPermittedAlways = [:owner_uuid, :state, :name, :description, :properties]
  AttrsPermittedBeforeCommit = [:command, :container_count_max,
  :container_image, :cwd, :environment, :filters, :mounts,
  :output_path, :output_glob, :priority, :runtime_token,
  :runtime_constraints, :state, :container_uuid, :use_existing,
  :scheduling_parameters, :secret_mounts, :output_name, :output_ttl,
  :output_storage_classes, :output_properties, :service, :published_ports]

  def self.any_preemptible_instances?
    Rails.configuration.InstanceTypes.any? do |k, v|
      v["Preemptible"]
    end
  end

  def logged_attributes
    super.except('secret_mounts', 'runtime_token')
  end

  def state_transitions
    State_transitions
  end

  def skip_uuid_read_permission_check
    # The uuid_read_permission_check prevents users from making
    # references to objects they can't view.  However, in this case we
    # don't want to do that check since there's a circular dependency
    # where user can't view the container until the user has
    # constructed the container request that references the container.
    %w(container_uuid)
  end

  def finalize_if_needed
    return if state != Committed
    while true
      # get container lock first, then lock current container request
      # (same order as Container#handle_completed). Locking always
      # reloads the Container and ContainerRequest records.
      c = Container.find_by_uuid(container_uuid)
      c.lock! if !c.nil?
      self.lock!

      if !c.nil? && container_uuid != c.uuid
        # After locking, we've noticed a race, the container_uuid is
        # different than the container record we just loaded.  This
        # can happen if Container#handle_completed scheduled a new
        # container for retry and set container_uuid while we were
        # waiting on the container lock.  Restart the loop and get the
        # new container.
        redo
      end

      if !c.nil?
        if state == Committed && c.final?
          # The current container is
          act_as_system_user do
            leave_modified_by_user_alone do
              finalize!
            end
          end
        end
      elsif state == Committed
        # Behave as if the container is cancelled
        update!(state: Final)
      end
      return true
    end
  end

  # Finalize the container request after the container has
  # finished/cancelled.
  def finalize!
    container = Container.find_by_uuid(container_uuid)
    if !container.nil?
      # We don't want to add the container cost if the container was
      # already finished when this CR was committed. But we are
      # running in an after_save hook after a lock/reload, so
      # state_was has already been updated to Committed regardless.
      # Hence the need for @state_was_when_initialized.
      if @state_was_when_initialized == Committed
        # Add the final container cost to our cumulative cost (which
        # may already be non-zero from previous attempts if
        # container_count_max > 1).
        self.cumulative_cost += container.cost + container.subrequests_cost
      end

      # Add our cumulative cost to the subrequests_cost of the
      # requesting container, if any.
      if self.requesting_container_uuid
        Container.where(
          uuid: self.requesting_container_uuid,
          state: Container::Running,
        ).each do |c|
          c.subrequests_cost += self.cumulative_cost
          c.save!
        end
      end

      update_collections(container: container)
      # update_collections makes a log collection that includes all of the logs
      # for all of the containers associated with this request. For requests
      # that are retried, this is the primary way users can get logs for
      # failed containers.
      # The code below makes a log collection that is a verbatim copy of the
      # container's logs. This is required for container reuse: a container
      # will not be reused if the owner cannot read a collection with its logs.
      # See the "readable log" section of Container.find_reusable().
      if container.state == Container::Complete
        log_col = Collection.where(portable_data_hash: container.log).first
        if log_col
          # Need to save collection
          completed_coll = Collection.new(
            owner_uuid: self.owner_uuid,
            name: "Container log for container #{container_uuid}",
            properties: {
              'type' => 'log',
              'container_request' => self.uuid,
              'container_uuid' => container_uuid,
            },
            portable_data_hash: log_col.portable_data_hash,
            manifest_text: log_col.manifest_text,
            storage_classes_desired: self.output_storage_classes
          )
          completed_coll.save_with_unique_name!
        end
      end
    end
    update!(state: Final)
  end

  def update_collections(container:, collections: ['log', 'output'])

    # Check if parent is frozen or trashed, in which case it isn't
    # valid to create new collections in the project, so return
    # without creating anything.
    owner = Group.find_by_uuid(self.owner_uuid)
    return if owner && !owner.admin_change_permitted

    collections.each do |out_type|
      pdh = container.send(out_type)
      next if pdh.nil?
      c = Collection.where(portable_data_hash: pdh).first
      next if c.nil?
      manifest = c.manifest_text

      coll_name = "Container #{out_type} for request #{uuid}"
      trash_at = nil
      if out_type == 'output'
        if self.output_name and self.output_name != ""
          coll_name = self.output_name
        end
        if self.output_ttl > 0
          trash_at = db_current_time + self.output_ttl
        end
      end

      coll_uuid = self.send(out_type + '_uuid')
      coll = coll_uuid.nil? ? nil : Collection.where(uuid: coll_uuid).first
      if !coll
        coll = Collection.new(
          owner_uuid: self.owner_uuid,
          name: coll_name,
          manifest_text: "",
          storage_classes_desired: self.output_storage_classes)
      end

      if out_type == "log"
        # Copy the log into a merged collection
        src = Arv::Collection.new(manifest)
        dst = Arv::Collection.new(coll.manifest_text)
        dst.cp_r("./", ".", src)
        dst.cp_r("./", "log for container #{container.uuid}", src)
        manifest = dst.manifest_text
      end

      merged_properties = {}
      merged_properties['container_request'] = uuid

      if out_type == 'output' and !requesting_container_uuid.nil?
        # output of a child process, give it "intermediate" type by
        # default.
        merged_properties['type'] = 'intermediate'
      else
        merged_properties['type'] = out_type
      end

      if out_type == "output"
        merged_properties.update(container.output_properties)
        merged_properties.update(self.output_properties)
      end

      coll.assign_attributes(
        portable_data_hash: Digest::MD5.hexdigest(manifest) + '+' + manifest.bytesize.to_s,
        manifest_text: manifest,
        trash_at: trash_at,
        delete_at: trash_at,
        properties: merged_properties)
      coll.save_with_unique_name!
      self.send(out_type + '_uuid=', coll.uuid)
    end
  end

  def self.full_text_searchable_columns
    super - ["mounts", "secret_mounts", "secret_mounts_md5", "runtime_token", "output_storage_classes", "output_glob", "service", "published_ports"]
  end

  def set_priority_zero
    self.update!(priority: 0) if self.priority > 0 && self.state != Final
  end

  protected

  def fill_field_defaults
    self.state ||= Uncommitted
    self.environment ||= {}
    self.runtime_constraints ||= {}
    self.mounts ||= {}
    self.secret_mounts ||= {}
    self.cwd ||= "."
    self.container_count_max ||= Rails.configuration.Containers.MaxRetryAttempts
    self.scheduling_parameters ||= {}
    self.output_ttl ||= 0
    self.output_glob ||= []
    self.priority ||= 0
  end

  def fill_cuda_to_gpu
    ContainerRequest.translate_cuda_to_gpu attributes['runtime_constraints']
  end

  def self.translate_cuda_to_gpu rc
    if rc.is_a?(Hash) && rc['cuda'] && rc['cuda']['device_count'] > 0
      # Legacy API to request Nvidia GPUs, convert it so downstream
      # code only has to handle generic GPU requests.
      rc['gpu'] = {
          'device_count' => rc['cuda']['device_count'],
          'driver_version' => rc['cuda']['driver_version'],
          'hardware_target' => [rc['cuda']['hardware_capability']],
          'stack' => 'cuda',
          'vram' => 0,
      }
    end
  end

  def set_container
    if !errors.empty?
      # Validation failed, record won't be saved anyway.
      return false
    end
    if (container_uuid_changed? and
        not current_user.andand.is_admin and
        not container_uuid.nil?)
      errors.add :container_uuid, "can only be updated to nil."
      return false
    end
    if self.container_count_changed?
      errors.add :container_count, "cannot be updated directly."
      return false
    end
    if state_changed? and state == Committed and container_uuid.nil?
      if self.command.length > 0 and self.command[0] == "arvados-cwl-runner"
        # Special case, arvados-cwl-runner processes are always considered "supervisors"
        self.scheduling_parameters['supervisor'] = true
      end
      while true
        c = Container.resolve(self)
        c.lock!
        if c.state == Container::Cancelled
          # Lost a race, we have a lock on the container but the
          # container was cancelled in a different request, restart
          # the loop and resolve request to a new container.
          redo
        end
        self.container_uuid = c.uuid
        break
      end
    end
    if self.container_uuid != self.container_uuid_was
      self.container_count += 1
      return if self.container_uuid_was.nil?

      old_container_uuid = self.container_uuid_was
      old_container_log = Container.where(uuid: old_container_uuid).pluck(:log).first
      return if old_container_log.nil?

      old_logs = Collection.where(portable_data_hash: old_container_log).first
      return if old_logs.nil?

      log_coll = self.log_uuid.nil? ? nil : Collection.where(uuid: self.log_uuid).first
      if self.log_uuid.nil?
        log_coll = Collection.new(
          owner_uuid: self.owner_uuid,
          name: coll_name = "Container log for request #{uuid}",
          manifest_text: "",
          storage_classes_desired: self.output_storage_classes)
      end

      # copy logs from old container into CR's log collection
      src = Arv::Collection.new(old_logs.manifest_text)
      dst = Arv::Collection.new(log_coll.manifest_text)
      dst.cp_r("./", "log for container #{old_container_uuid}", src)
      manifest = dst.manifest_text

      log_coll.assign_attributes(
        portable_data_hash: Digest::MD5.hexdigest(manifest) + '+' + manifest.bytesize.to_s,
        manifest_text: manifest)
      log_coll.save_with_unique_name!
      self.log_uuid = log_coll.uuid
    end
  end

  def set_preemptible
    if (new_record? || state_changed?) &&
       state == Committed &&
       Rails.configuration.Containers.AlwaysUsePreemptibleInstances &&
       get_requesting_container_uuid() &&
       self.class.any_preemptible_instances?
      self.scheduling_parameters['preemptible'] = true
    end
  end

  def validate_runtime_constraints
    if errors[:runtime_constraints].any?
      # If runtime_constraints is not even a hash, don't raise other
      # confusing errors by trying to do more validation.
      return false
    end
    if state != Committed && !new_record?
      # Avoid running new validations on records that are already in
      # the database and aren't going to be submitted as a result of
      # this update.
      return
    end
    case self.state
    when Committed
      ['vcpus', 'ram'].each do |k|
        v = runtime_constraints[k]
        if !v.is_a?(Integer) || v <= 0
          errors.add(:runtime_constraints,
                     "[#{k}]=#{v.inspect} must be a positive integer")
        end
      end
      if runtime_constraints['cuda']
        disallow_extra_keys(
          :runtime_constraints, runtime_constraints['cuda'],
          ['device_count', 'driver_version', 'hardware_capability'])
        ['device_count'].each do |k|
          v = runtime_constraints['cuda'][k]
          if !v.is_a?(Integer) || v < 0
            errors.add(:runtime_constraints,
                       "[cuda.#{k}]=#{v.inspect} must be a positive or zero integer")
          end
        end
        ['driver_version', 'hardware_capability'].each do |k|
          v = runtime_constraints['cuda'][k]
          if !v.is_a?(String) || (runtime_constraints['cuda']['device_count'] > 0 && v.to_f == 0.0)
            errors.add(:runtime_constraints,
                       "[cuda.#{k}]=#{v.inspect} must be a string in format 'X.Y'")
          end
        end
      end

      if !runtime_constraints['gpu'].is_a?(Hash)
        errors.add(:runtime_constraints, "[gpu] must be a hash")
      elsif runtime_constraints['gpu']
        disallow_extra_keys(
          :runtime_constraints, runtime_constraints['gpu'],
          ['device_count', 'driver_version', 'hardware_target', 'stack', 'vram'])
        k = 'stack'
        v = runtime_constraints['gpu'][k]
        if not [nil, '', 'cuda', 'rocm'].include? v
            errors.add(:runtime_constraints,
                       "[gpu.#{k}]=#{v.inspect} must be one of 'cuda' or 'rocm' or be empty")
        end

        ['device_count', 'vram'].each do |k|
          v = runtime_constraints['gpu'][k]
          if !v.is_a?(Integer) || v < 0
            errors.add(:runtime_constraints,
                       "[gpu.#{k}]=#{v.inspect} must be a positive or zero integer")
          end
        end

        if runtime_constraints['gpu']['device_count'] > 0
          k = 'driver_version'
          v = runtime_constraints['gpu'][k]
          if !v.is_a?(String) || v.to_f == 0.0
            errors.add(:runtime_constraints,
                       "[gpu.#{k}]=#{v.inspect} must be a string in format 'X.Y'")
          end

          k = 'hardware_target'
          v = runtime_constraints['gpu'][k]
          if v.is_a?(Array)
            v.each do |tgt|
              if !tgt.is_a?(String)
                errors.add(:runtime_constraints,
                           "[gpu.#{k}]=#{v.inspect} must be an array of strings")
              end
            end
          else
            errors.add(:runtime_constraints,
                       "[gpu.#{k}]=#{v.inspect} must be an array of strings")
          end
        end
      end
    end
    disallow_extra_keys(
      :runtime_constraints, runtime_constraints,
      ['API', 'gpu', 'keep_cache_disk', 'keep_cache_ram', 'ram', 'vcpus',
       # When 'cuda' is automatically converted to 'gpu', the original
       # 'cuda' section also remains. See #21926#note-21.
       'cuda',
      ])
  end

  MountKindFields = {
    "collection" => ["uuid", "portable_data_hash", "writable", "path", "exclude_from_output"],
    "tmp" => ["capacity", "device_type", "exclude_from_output"],
    "keep" => ["exclude_from_output"],
    "file" => ["path", "exclude_from_output"],
    "json" => ["content", "exclude_from_output"],
    "text" => ["content", "exclude_from_output"],
  }

  SecretMountKindFields = {
    "json" => MountKindFields["json"],
    "text" => MountKindFields["text"],
  }

  MountSchema = {
    "kind" => "string",
    "uuid" => "string",
    "portable_data_hash" => "string",
    "writable" => "boolean",
    "path" => "string",
    "capacity" => "integer",
    "device_type" => ["ram", "ssd", "disk", "network", ""],
    "exclude_from_output" => "boolean",
  }

  def validate_mount_hash(attr, mountpoint, mountspec)
    kind = mountspec["kind"]
    allowed_fields =
      case attr
      when :mounts
        MountKindFields[kind]
      when :secret_mounts
        SecretMountKindFields[kind]
      else
        raise ArgumentError.new("validate_mount_hash called with unexpected attr #{attr}")
      end
    if !allowed_fields
      errors.add(attr, "[#{mountpoint}][kind]: unsupported value #{kind.inspect}")
      return
    end
    # Validate value types for the keys that are present, but don't
    # complain about keys that are not.
    schema = MountSchema.select { |k, v| mountspec.has_key?(k) }
    if kind == "text"
      schema["content"] = "string"
    elsif kind == "json"
      # content can be anything, so no validation
    end
    validator = HashValidator.validate(mountspec, schema)
    if !validator.valid?
      validator.errors.each do |key, err|
        errors.add(attr, "[#{mountpoint}][#{key}]: incompatible value type: #{err}")
      end
    end
    mountspec.each do |key, value|
      # Keys that do not apply to a given mount kind need to be
      # accepted as long as they have empty/zero values, because
      # that's how Go code (e.g., controller) serializes the Mount
      # struct that's used for all mount kinds.  But inapplicable keys
      # with non-empty values are not allowed.
      if key != "kind" && !allowed_fields.include?(key) && ![0, "", false, nil].include?(value)
        errors.add(attr, "[#{mountpoint}][#{key}]: parameter is not supported for a #{mountspec["kind"]} mount")
      end
    end
  end

  def validate_datatypes
    if state != Committed && !new_record?
      # Avoid running new validations on records that are already in
      # the database and aren't going to be submitted as a result of
      # this update.
      return
    end
    if !errors[:environment].any?
      environment.each do |k, v|
        if k.include?("\0") || k.include?("=")
          errors.add(:environment, "key #{k.inspect} contains an invalid character NUL or '='")
        end
        if k == ""
          errors.add(:environment, "key cannot be empty")
        end
        if !v.is_a?(String)
          errors.add(:environment, "[#{k}]: incompatible value type: string required")
        elsif v.include?("\0")
          errors.add(:environment, "value for #{k.inspect} contains invalid character NUL")
        end
      end
    end
    stream_targets = {
      mounts: ["stdin", "stdout", "stderr"],
      secret_mounts: ["stdin"],
    }
    [:mounts, :secret_mounts].each do |m|
      if errors[m].any?
        # Validation is already failing in a way that could make the
        # following validations fail (e.g., non-string keys).
        next
      end
      self[m].each do |k, v|
        if !k.in?(stream_targets[m]) && !k.start_with?("/")
          errors.add(m, "[#{k}]: invalid target: must be #{stream_targets[m].join(", ")} or an absolute path")
        end
        if !v.is_a?(Hash)
          errors.add(m, "[#{k}]: invalid mount specification: must be a hash, not a #{k.class.to_s.downcase}")
        else
          validate_mount_hash(m, k, v)
        end
      end
    end
    if !mounts.has_key?(output_path)
      errors.add(:output_path, "must be a mount target")
    end
  end

  def validate_scheduling_parameters
    if state != Committed && !new_record?
      # Avoid running new validations on records that are already in
      # the database and aren't going to be submitted as a result of
      # this update.
      return
    end
    if scheduling_parameters.include?('partitions') and
      !scheduling_parameters['partitions'].nil? and
      (!scheduling_parameters['partitions'].is_a?(Array) ||
       scheduling_parameters['partitions'].reject{|x| !x.is_a?(String)}.size !=
       scheduling_parameters['partitions'].size)
      errors.add :scheduling_parameters, "partitions must be an array of strings"
    end
    if scheduling_parameters.include? 'max_run_time' and
      (!scheduling_parameters['max_run_time'].is_a?(Integer) ||
       scheduling_parameters['max_run_time'] < 0)
      errors.add :scheduling_parameters, "max_run_time must be positive integer"
    end
    disallow_extra_keys(
      :scheduling_parameters, scheduling_parameters,
      ['max_run_time', 'partitions', 'preemptible', 'supervisor'])

    # Configuration could change before state changes to Committed, so
    # this is not flagged as an error for an Uncommitted.  We also
    # don't want to prevent finalizing due to a config change.
    if state == Committed &&
       scheduling_parameters['preemptible'] &&
       (new_record? || state_changed?) &&
       !self.class.any_preemptible_instances?
      errors.add :scheduling_parameters, "preemptible instances are not configured in InstanceTypes"
    end
  end

  def disallow_extra_keys(attr, h, allowed_keys)
    extra_keys = h.keys - allowed_keys
    if extra_keys.any?
      errors.add(attr, "contains unexpected keys #{extra_keys}")
    end
  end

  def check_update_whitelist
    permitted = AttrsPermittedAlways.dup

    if self.new_record? || self.state_was == Uncommitted
      # Allow create-and-commit in a single operation.
      permitted.push(*AttrsPermittedBeforeCommit)
    elsif mounts_changed? && mounts_was.keys.sort == mounts.keys.sort
      # Ignore the updated mounts if the only changes are default/zero
      # values as added by controller, see 17774
      only_defaults = true
      mounts.each do |path, mount|
        (mount.to_a - mounts_was[path].to_a).each do |k, v|
          if ![0, "", false, nil].index(v)
            only_defaults = false
          end
        end
      end
      if only_defaults
        clear_attribute_change("mounts")
      end
    end

    case self.state
    when Committed
      permitted.push :priority, :container_count_max, :container_uuid, :cumulative_cost

      if self.priority.nil?
        self.errors.add :priority, "cannot be nil"
      end

      # Allow container count to increment (not by client, only by us
      # -- see set_container)
      permitted.push :container_count

      if current_user.andand.is_admin
        permitted.push :log_uuid
      end

    when Final
      if self.state_was == Committed
        # "Cancel" means setting priority=0, state=Committed
        permitted.push :priority, :cumulative_cost

        if current_user.andand.is_admin
          permitted.push :output_uuid, :log_uuid
        end
      end

    end

    super(permitted)
  end

  def secret_mounts_key_conflict
    secret_mounts.each do |k, v|
      if mounts.has_key?(k)
        errors.add(:secret_mounts, 'conflict with non-secret mounts')
        return false
      end
    end
  end

  def validate_runtime_token
    if !self.runtime_token.nil? && self.runtime_token_changed?
      if !runtime_token[0..2] == "v2/"
        errors.add :runtime_token, "not a v2 token"
        return
      end
      if ApiClientAuthorization.validate(token: runtime_token).nil?
        errors.add :runtime_token, "failed validation"
      end
    end
  end

  def validate_published_ports
    if self.service and self.use_existing
      errors.add :use_existing, "cannot be true if 'service' is true"
    end

    self.published_ports.each do |k,v|
      if !/^[0-9]+$/.match?(k)
        errors.add :published_ports, "entry #{k} must be a decimal port number in the range 1-65535"
        next
      end
      i = k.to_i
      if i < 1 || i > 65535
        errors.add :published_ports, "entry #{k} must be a decimal port number in the range 1-65535"
        next
      end

      if v.is_a?(Hash)
        v.each do |vkey, _|
          if !["access", "label", "initial_path"].include? vkey
            errors.add :published_ports, "entry #{k} has invalid key: #{vkey.inspect}"
          end
        end
        if v["access"] != "private" && v["access"] != "public"
          errors.add :published_ports, "entry #{k} 'access' must be one of 'public' or 'private' but was: #{v["access"].inspect}"
        end
        if !v["label"].is_a?(String)
          errors.add :published_ports, "entry #{k} 'label' must be a string but was: #{v["label"].inspect}"
        elsif v["label"].empty?
          errors.add :published_ports, "entry #{k} 'label' cannot be empty"
        end
        if !v["initial_path"].is_a?(String)
          errors.add :published_ports, "entry #{k} 'initial_path' must be a string but was: #{v["initial_path"].inspect}"
        end
      else
        errors.add :published_ports, "entry #{k} must be an hash: #{v.inspect}"
      end
    end
  end

  def scrub_secrets
    if self.state == Final
      self.secret_mounts = {}
      self.runtime_token = nil
    end
  end

  def update_priority
    return unless saved_change_to_state? || saved_change_to_priority? || saved_change_to_container_uuid?
    update_priorities container_uuid_before_last_save if !container_uuid_before_last_save.nil? and container_uuid_before_last_save != self.container_uuid
    update_priorities self.container_uuid if self.container_uuid
  end

  def set_requesting_container_uuid
    if (self.requesting_container_uuid = get_requesting_container_uuid())
      # Determine the priority of container request for the requesting
      # container.
      self.priority = ContainerRequest.where(container_uuid: self.requesting_container_uuid).maximum("priority") || 0
    end
  end

  def get_requesting_container_uuid
    return self.requesting_container_uuid || Container.for_current_token.andand.uuid
  end
end
