QutBioacoustics/baw-server

# frozen_string_literal: true

class AnalysisJobsController < ApplicationController
  include Api::ControllerHelper

  SYSTEM_JOB_ID = AnalysisJobsItem::SYSTEM_JOB_ID

  # GET /analysis_jobs
  def index
    do_authorize_class

    @analysis_jobs, opts = Settings.api_response.response_advanced(
      api_filter_params,
      get_analysis_jobs,
      AnalysisJob,
      AnalysisJob.filter_settings
    )
    respond_index(opts)
  end

  # GET /analysis_jobs/1
  def show
    return system_show if system_job?

    do_load_resource
    do_authorize_instance

    respond_show
  end

  # GET /analysis_jobs/new
  def new
    do_new_resource
    do_set_attributes
    do_authorize_instance

    respond_new
  end

  # POST /analysis_jobs
  def create
    do_new_resource
    do_set_attributes(analysis_job_create_params)
    do_authorize_instance

    # runs first step in analysis_job workflow (`initialize_workflow`) and then saves
    if @analysis_job.save

      # now create and enqueue job items (which updates status attributes again)
      # needs to be called after save as it makes use of the analysis_job id.
      @analysis_job.prepare!

      respond_create_success
    else
      respond_change_fail
    end
  end

  # PUT|PATCH /analysis_jobs/1
  def update
    return system_mutate if system_job?

    do_load_resource
    do_authorize_instance

    parameters = analysis_job_update_params

    # allow the API to transition this analysis job to a new state.
    # Used for suspending, resuming, and retrying an analysis_job
    if parameters.key?(:overall_status)
      @analysis_job.transition_to_state!(parameters[:overall_status].to_sym)
      parameters = parameters.except(:overall_status)
    end

    if @analysis_job.update(parameters)
      respond_show
    else
      respond_change_fail
    end
  end

  # DELETE /analysis_jobs/1
  def destroy
    return system_mutate if system_job?

    do_load_resource
    do_authorize_instance

    # only allow deleting from suspended or completed states
    can_delete = @analysis_job.completed? || @analysis_job.suspended?

    # also allow from processing, since we can suspend
    if @analysis_job.processing? && @analysis_job.may_suspend?
      can_delete = true
      @analysis_job.suspend!
    end

    if can_delete
      @analysis_job.destroy
      add_archived_at_header(@analysis_job)

      respond_destroy
    else
      respond_error(:conflict, "Cannot be deleted while `overall_status` is `#{@analysis_job.overall_status}`")
    end
  end

  # GET|POST /analysis_jobs/filter
  def filter
    do_authorize_class

    filter_response, opts = Settings.api_response.response_advanced(
      api_filter_params,
      get_analysis_jobs,
      AnalysisJob,
      AnalysisJob.filter_settings
    )
    respond_filter(filter_response, opts)
  end

  private

  # GET|HEAD /analysis_jobs/system
  def system_show
    raise NotImplementedError
  end

  # PUT|PATCH|DELETE /analysis_jobs/system
  def system_mutate
    raise CustomErrors::MethodNotAllowedError.new('Cannot update a system job', [:post, :put, :patch, :delete])
  end

  def system_job?
    params[:id] == 'system'
  end

  def analysis_job_create_params
    # When Analysis jobs are created, they must have
    # a script, saved search, name, and custom settings.
    # May have a description.
    params.require(:analysis_job).permit(
      :script_id,
      :saved_search_id,
      :name,
      :custom_settings,
      :description,
      :annotation_name
    )
  end

  def analysis_job_update_params
    # Only name and description can be updated via API.
    # Other properties are updated by the processing system.
    params.require(:analysis_job).permit(:name, :description, :overall_status)
  end

  def get_analysis_jobs
    Access::ByPermission.analysis_jobs(current_user)
  end
end