mastodon/spec/requests/api/v1_alpha/async_refreshes_spec.rb

# frozen_string_literal: true

require 'rails_helper'

RSpec.describe 'AsyncRefreshes' do
  let(:user)    { Fabricate(:user) }
  let(:token)   { Fabricate(:accessible_access_token, resource_owner_id: user.id, scopes: scopes) }
  let(:headers) { { 'Authorization' => "Bearer #{token.token}" } }
  let(:job) { AsyncRefresh.new('test_job') }

  describe 'GET /api/v1_alpha/async_refreshes/:id' do
    context 'when not authorized' do
      it 'returns http unauthorized' do
        get api_v1_alpha_async_refresh_path(job.id)

        expect(response)
          .to have_http_status(401)
        expect(response.content_type)
          .to start_with('application/json')
      end
    end

    context 'with wrong scope' do
      before do
        get api_v1_alpha_async_refresh_path(job.id), headers: headers
      end

      it_behaves_like 'forbidden for wrong scope', 'write write:accounts'
    end

    context 'with correct scope' do
      let(:scopes) { 'read' }

      context 'when job exists' do
        before do
          redis.hset('test_job', { 'status' => 'running', 'result_count' => 10 })
        end

        after do
          redis.del('test_job')
        end

        it 'returns http success' do
          get api_v1_alpha_async_refresh_path(job.id), headers: headers

          expect(response)
            .to have_http_status(200)

          expect(response.content_type)
            .to start_with('application/json')

          parsed_response = response.parsed_body
          expect(parsed_response)
            .to be_present
          expect(parsed_response['async_refresh'])
            .to include('status' => 'running', 'result_count' => 10)
        end
      end

      context 'when job does not exist' do
        it 'returns not found' do
          get api_v1_alpha_async_refresh_path(job.id), headers: headers

          expect(response)
            .to have_http_status(404)
        end
      end
    end
  end
end