Contents

# frozen_string_literal: true
module Shipit
  class TasksController < ShipitController
    include Pagination

    before_action :stack, except: [:lookup]

    self.default_page_size = 20

    def index
      paginator = paginate(stack.tasks)
      @tasks = paginator.to_a
      @links = paginator.links
    end

    def new
      @definition = stack.find_task_definition(params[:definition_id])
      @task = stack.tasks.build(definition: @definition)
    end

    def show
      task
      respond_to do |format|
        format.html
        format.text { render(plain: @task.chunk_output) }
      end
    end

    def create
      @definition = stack.find_task_definition(params[:definition_id])

      begin
        @task = stack.trigger_task(
          params[:definition_id],
          current_user,
          env: task_params[:env],
          force: params[:force].present?,
        )
        redirect_to([stack, @task])
      rescue Task::ConcurrentTaskRunning
        redirect_to(new_stack_tasks_path(stack, @definition))
      end
    end

    def abort
      task.abort!(rollback_once_aborted: params[:rollback].present?, aborted_by: current_user)
      head(:ok)
    end

    def tail
      render(json: TailTaskSerializer.new(task, context: { last_byte: params[:last_byte].to_i }))
    end

    def lookup
      @task = Task.find(params[:id])

      redirect_to(url_for_task)
    end

    private

    def url_for_task
      base_task = @task.is_a?(Deploy) ? @task.becomes(Deploy) : @task

      url_for([base_task.stack, base_task])
    end

    def task
      @task ||= stack.tasks.find(params[:id])
    end

    def stack
      @stack ||= Stack.from_param!(params[:stack_id])
    end

    def task_params
      return {} unless params[:task]
      @definition = stack.find_task_definition(params[:definition_id])
      @task_params ||= params.require(:task).permit(env: @definition.variables.map(&:name))
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
shipit-engine-0.39.0	app/controllers/shipit/tasks_controller.rb
shipit-engine-0.38.0	app/controllers/shipit/tasks_controller.rb
shipit-engine-0.37.0	app/controllers/shipit/tasks_controller.rb
shipit-engine-0.36.1	app/controllers/shipit/tasks_controller.rb
shipit-engine-0.36.0	app/controllers/shipit/tasks_controller.rb
shipit-engine-0.35.1	app/controllers/shipit/tasks_controller.rb
shipit-engine-0.35.0	app/controllers/shipit/tasks_controller.rb
shipit-engine-0.34.0	app/controllers/shipit/tasks_controller.rb