class Kuroko2::Api::JobDefinitionsController

def admin_id_params(params)
  params.permit(user_id: []).
    try!(:[], :user_id).
    try!(:reject, &:blank?).
    try!(:map, &:to_i) || []
end

def create_resource
  definition = Kuroko2::JobDefinition.new(definition_params(params))
  user_ids = admin_id_params(params)
  definition.admins = Kuroko2::User.active.with(user_ids)
  definition.tags = tags(params)
  if definition.save_and_record_revision
    definition.job_schedules = job_schedules(params, definition)
    definition.admins.each do |user|
      user.stars.create(job_definition: definition) if user.google_account?
    end
    @resource = Kuroko2::Api::JobDefinitionResource.new(definition)
  else
    raise Http::UnprocessableEntity.new("#{definition.name}: #{definition.errors.full_messages.join}")
  end
end

def definition_params(params)
  params.permit(
    :name,
    :description,
    :script,
    :notify_cancellation,
    :hipchat_room,
    :hipchat_notify_finished,
    :suspended,
    :prevent_multi,
    :prevent_multi_on_failure,
    :hipchat_additional_text,
    :text_tags,
    :api_allowed,
    :slack_channel,
    :webhook_url)
end

def destroy_resource
  @resource.destroy
end

def job_schedules(params, definition)
  cron_strings = params.permit(cron: []).fetch(:cron, [])
  cron_strings.map do |cron|
    schedule = definition.job_schedules.find_or_create_by(cron: cron)
    raise Http::UnprocessableEntity.new("#{cron}: #{schedule.errors.full_messages.join}") unless schedule.valid?
    schedule
  end
end

def require_resource
  definition = Kuroko2::JobDefinition.includes(:tags, :job_schedules).find(params[:id])
  @resource = Kuroko2::Api::JobDefinitionResource.new(definition)
end

def require_resources
  definitions = Kuroko2::JobDefinition.includes(:tags, :job_schedules)
  if params[:tags].present?
    definitions = definitions.tagged_by(params[:tags])
  end
  @resources = definitions.ordered.map { |definition| Kuroko2::Api::JobDefinitionResource.new(definition) }
end

def tags(params)
  tag_strings = params.permit(tags: []).fetch(:tags, [])
  tag_strings.map do |name|
    Kuroko2::Tag.find_or_create_by(name: name)
  end
end

def update_resource
  definition = Kuroko2::JobDefinition.find(params[:id])
  definition.tags = tags(params)
  definition.job_schedules = job_schedules(params, definition)
  if definition.update_and_record_revision(definition_params(params))
    @resource = Kuroko2::Api::JobDefinitionResource.new(definition)
  else
    raise Http::UnprocessableEntity.new("#{definition.name}: #{definition.errors.full_messages.join}")
  end
end