diff --git a/app/services/fetch_link_card_service.rb b/app/services/fetch_link_card_service.rb index 84c4ba06f16..d1df8e27c6c 100644 --- a/app/services/fetch_link_card_service.rb +++ b/app/services/fetch_link_card_service.rb @@ -73,6 +73,7 @@ class FetchLinkCardService < BaseService PreviewCardsStatus.create(status: @status, preview_card: @card, url: @original_url) Rails.cache.delete(@status) Trends.links.register(@status) + DistributionWorker.perform_async(@status.id, { update: true }) end end diff --git a/spec/services/fetch_link_card_service_spec.rb b/spec/services/fetch_link_card_service_spec.rb index 1d61e33c0b7..c939582bace 100644 --- a/spec/services/fetch_link_card_service_spec.rb +++ b/spec/services/fetch_link_card_service_spec.rb @@ -6,6 +6,7 @@ RSpec.describe FetchLinkCardService do subject { described_class.new } let(:html) { 'Hello world' } + let(:status) { Fabricate(:status, text: 'http://example.com/html') } let(:oembed_cache) { nil } before do @@ -34,11 +35,22 @@ RSpec.describe FetchLinkCardService do stub_request(:get, 'http://example.com/long_canonical_url').to_return(request_fixture('long_canonical_url.txt')) stub_request(:get, 'http://example.com/alternative_utf8_spelling_in_header').to_return(request_fixture('alternative_utf8_spelling_in_header.txt')) + allow(DistributionWorker).to receive(:perform_async) + allow(Trends.links).to receive(:register) + Rails.cache.write('oembed_endpoint:example.com', oembed_cache) if oembed_cache subject.call(status) end + it 'registers trends' do + expect(Trends.links).to have_received(:register).with(status) + end + + it 'redistributes status' do + expect(DistributionWorker).to have_received(:perform_async).with(status.id, { update: true }) + end + context 'with a local status' do context 'with URL of a regular HTML page' do let(:status) { Fabricate(:status, text: 'http://example.com/html') }