require 'test_helper'

module Shipit
  class TasksControllerTest < ActionController::TestCase
    setup do
      @stack = shipit_stacks(:shipit)
      @definition = @stack.find_task_definition('restart')
      @task = shipit_tasks(:shipit_restart)
      @commit = shipit_commits(:second)
      session[:user_id] = shipit_users(:walrus).id
    end

    test "tasks defined in the shipit.yml can be displayed" do
      get :new, stack_id: @stack, definition_id: @definition.id
      assert_response :ok
    end

    test "tasks defined in the shipit.yml can't be triggered if the stack is being deployed" do
      assert @stack.active_task?
      assert_no_difference -> { @stack.tasks.count } do
        post :create, stack_id: @stack, definition_id: @definition.id
      end
      assert_redirected_to new_stack_tasks_path(@stack, @definition)
    end

    test "tasks defined in the shipit.yml can be triggered anyway if force apram is present" do
      assert @stack.active_task?
      assert_difference -> { @stack.tasks.count } do
        post :create, stack_id: @stack, definition_id: @definition.id, force: 'true'
      end
      assert_redirected_to stack_task_path(@stack, Task.last)
    end

    test "tasks defined in the shipit.yml can be triggered while the stack is being deployed if specified as such" do
      @definition = @stack.find_task_definition('flush_cache')
      assert_difference -> { @stack.tasks.count } do
        post :create, stack_id: @stack, definition_id: @definition.id
      end
      assert_redirected_to stack_task_path(@stack, Task.last)
    end

    test "tasks with variables defined in the shipit.yml can be triggered with their variables set" do
      env = {"FOO" => "0"}

      post :create, stack_id: @stack, definition_id: @definition.id, task: {env: env}, force: 'true'

      assert_redirected_to stack_tasks_path(@stack, Task.last)
    end

    test "triggered tasks can be observed" do
      get :show, stack_id: @stack, id: @task.id
      assert_response :ok
    end

    test "triggered tasks can be observed as raw text" do
      get :show, stack_id: @stack, id: @task.id, format: "txt"
      assert_response :success
      assert_equal("text/plain", @response.content_type)
    end

    test ":abort call abort! on the deploy" do
      @task = shipit_deploys(:shipit_running)
      @task.ping
      post :abort, stack_id: @stack.to_param, id: @task.id

      @task.reload
      assert_response :success
      assert_equal 'aborting', @task.reload.status
      assert_equal false, @task.rollback_once_aborted?
    end

    test ":abort schedule the rollback if `rollback` is present" do
      @task = shipit_deploys(:shipit_running)
      @task.ping
      post :abort, stack_id: @stack.to_param, id: @task.id, rollback: 'true'

      @task.reload
      assert_response :success
      assert_equal 'aborting', @task.status
      assert_equal true, @task.rollback_once_aborted?
    end

    test ":index list the stack deploys" do
      get :index, stack_id: @stack.to_param
      assert_response :success
      assert_select '.task-list .task', @stack.tasks.count
    end

    test ":index paginates with the `since` parameter" do
      get :index, stack_id: @stack.to_param, since: @stack.tasks.last.id
      assert_response :success
      assert_select '.task-list .task', @stack.tasks.count - 1
    end

    test ":tail returns the task status, output, and next url" do
      @task = shipit_deploys(:shipit_running)
      last_chunk = @task.chunks.last

      get :tail, stack_id: @stack.to_param, id: @task.id, last_id: last_chunk.id, format: :json
      assert_response :success
      assert_json_keys %w(url status output)
      assert_json 'status', @task.status
    end

    test ":tail doesn't returns the next url if the task is finished" do
      @task = shipit_deploys(:shipit)

      get :tail, stack_id: @stack.to_param, id: @task.id, format: :json
      assert_response :success
      assert_no_json 'url'
    end

    test ":tail returns the rollback url if the task have been aborted" do
      @task = shipit_deploys(:shipit_aborted)

      get :tail, stack_id: @stack.to_param, id: @task.id, format: :json
      assert_response :success
      assert_json_keys %w(status output rollback_url)
    end
  end
end