mirror of
https://github.com/mastodon/mastodon.git
synced 2025-09-06 18:01:05 +00:00
70 lines
2.2 KiB
Ruby
70 lines
2.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require 'rails_helper'
|
|
|
|
RSpec.describe Fasp::FollowRecommendationWorker, feature: :fasp do
|
|
include ProviderRequestHelper
|
|
|
|
subject { described_class.new.perform(account.id) }
|
|
|
|
let(:provider) { Fabricate(:follow_recommendation_fasp) }
|
|
let(:account) { Fabricate(:account) }
|
|
let(:account_uri) { ActivityPub::TagManager.instance.uri_for(account) }
|
|
let(:fetch_service) { instance_double(ActivityPub::FetchRemoteActorService) }
|
|
let(:path) { "/follow_recommendation/v0/accounts?accountUri=#{URI.encode_uri_component(account_uri)}" }
|
|
|
|
let!(:stubbed_request) do
|
|
stub_provider_request(provider,
|
|
method: :get,
|
|
path:,
|
|
response_body: [
|
|
'https://fedi.example.com/accounts/1',
|
|
'https://fedi.example.com/accounts/7',
|
|
])
|
|
end
|
|
|
|
before do
|
|
allow(ActivityPub::FetchRemoteActorService).to receive(:new).and_return(fetch_service)
|
|
|
|
allow(fetch_service).to receive(:call).and_invoke(->(_) { Fabricate(:account, domain: 'fedi.example.com') })
|
|
end
|
|
|
|
it "sends the requesting account's uri to provider and fetches received account uris" do
|
|
subject
|
|
|
|
expect(stubbed_request).to have_been_made
|
|
expect(fetch_service).to have_received(:call).with('https://fedi.example.com/accounts/1')
|
|
expect(fetch_service).to have_received(:call).with('https://fedi.example.com/accounts/7')
|
|
end
|
|
|
|
it 'marks a running async refresh as finished' do
|
|
async_refresh = AsyncRefresh.create("fasp:follow_recommendation:#{account.id}", count_results: true)
|
|
|
|
subject
|
|
|
|
expect(async_refresh.reload).to be_finished
|
|
end
|
|
|
|
it 'tracks the number of fetched accounts in the async refresh' do
|
|
async_refresh = AsyncRefresh.create("fasp:follow_recommendation:#{account.id}", count_results: true)
|
|
|
|
subject
|
|
|
|
expect(async_refresh.reload.result_count).to eq 2
|
|
end
|
|
|
|
it 'persists the results' do
|
|
expect do
|
|
subject
|
|
end.to change(Fasp::FollowRecommendation, :count).by(2)
|
|
end
|
|
|
|
describe 'provider delivery failure handling' do
|
|
let(:base_stubbed_request) do
|
|
stub_request(:get, provider.url(path))
|
|
end
|
|
|
|
it_behaves_like('worker handling fasp delivery failures')
|
|
end
|
|
end
|