From 3a38322a54f0eeb3eba037a4fd61a072bda44311 Mon Sep 17 00:00:00 2001 From: Eugen Rochko Date: Wed, 10 May 2017 02:55:43 +0200 Subject: Add spec for Pubsubhubbub::DistributionWorker. PuSH-deliver public items (#2954) to all subscribers. IDN-normalize callback URLs for subscriptions on insert. --- .../pubsubhubbub/distribution_worker_spec.rb | 46 ++++++++++++++++++++++ 1 file changed, 46 insertions(+) create mode 100644 spec/workers/pubsubhubbub/distribution_worker_spec.rb (limited to 'spec') diff --git a/spec/workers/pubsubhubbub/distribution_worker_spec.rb b/spec/workers/pubsubhubbub/distribution_worker_spec.rb new file mode 100644 index 000000000..9565a2f7c --- /dev/null +++ b/spec/workers/pubsubhubbub/distribution_worker_spec.rb @@ -0,0 +1,46 @@ +require 'rails_helper' + +describe Pubsubhubbub::DistributionWorker do + subject { Pubsubhubbub::DistributionWorker.new } + + let!(:alice) { Fabricate(:account, username: 'alice') } + let!(:bob) { Fabricate(:account, username: 'bob', domain: 'example2.com') } + let!(:anonymous_subscription) { Fabricate(:subscription, account_id: alice.id, callback_url: 'http://example1.com', confirmed: true, lease_seconds: 3600) } + let!(:subscription_with_follower) { Fabricate(:subscription, account_id: alice.id, callback_url: 'http://example2.com', confirmed: true, lease_seconds: 3600) } + + before do + bob.follow!(alice) + end + + describe 'with public status' do + let(:status) { Fabricate(:status, account: alice, text: 'Hello', visibility: :public) } + + it 'delivers payload to all subscriptions' do + allow(Pubsubhubbub::DeliveryWorker).to receive(:perform_async) + subject.perform(status.stream_entry.id) + expect(Pubsubhubbub::DeliveryWorker).to have_received(:perform_async).with(subscription_with_follower.id, /.*/) + expect(Pubsubhubbub::DeliveryWorker).to have_received(:perform_async).with(anonymous_subscription.id, /.*/) + end + end + + describe 'with private status' do + let(:status) { Fabricate(:status, account: alice, text: 'Hello', visibility: :private) } + + it 'delivers payload only to subscriptions with followers' do + allow(Pubsubhubbub::DeliveryWorker).to receive(:perform_async) + subject.perform(status.stream_entry.id) + expect(Pubsubhubbub::DeliveryWorker).to have_received(:perform_async).with(subscription_with_follower.id, /.*/) + expect(Pubsubhubbub::DeliveryWorker).to_not have_received(:perform_async).with(anonymous_subscription.id, /.*/) + end + end + + describe 'with direct status' do + let(:status) { Fabricate(:status, account: alice, text: 'Hello', visibility: :direct) } + + it 'does not deliver payload' do + allow(Pubsubhubbub::DeliveryWorker).to receive(:perform_async) + subject.perform(status.stream_entry.id) + expect(Pubsubhubbub::DeliveryWorker).to_not have_received(:perform_async) + end + end +end -- cgit