mirror of
https://github.com/mastodon/mastodon.git
synced 2025-07-21 03:38:14 +00:00
Compare commits
5 Commits
bf2d991412
...
d9146bc08e
Author | SHA1 | Date | |
---|---|---|---|
![]() |
d9146bc08e | ||
![]() |
d7355d8a83 | ||
![]() |
8afd7de765 | ||
![]() |
3110ec63ce | ||
![]() |
42a816f48f |
|
@ -84,7 +84,7 @@ RSpec.describe ActivityPub::Activity::Accept do
|
|||
expect(DistributionWorker)
|
||||
.to have_enqueued_sidekiq_job(status.id, { 'update' => true })
|
||||
expect(ActivityPub::StatusUpdateDistributionWorker)
|
||||
.to have_enqueued_sidekiq_job(status.id, { 'update_id' => be_a(String) })
|
||||
.to have_enqueued_sidekiq_job(status.id, { 'updated_at' => be_a(String) })
|
||||
end
|
||||
|
||||
context 'when the quoted status is not from the sender of the Accept' do
|
||||
|
@ -153,7 +153,7 @@ RSpec.describe ActivityPub::Activity::Accept do
|
|||
expect(DistributionWorker)
|
||||
.to have_enqueued_sidekiq_job(status.id, { 'update' => true })
|
||||
expect(ActivityPub::StatusUpdateDistributionWorker)
|
||||
.to have_enqueued_sidekiq_job(status.id, { 'update_id' => be_a(String) })
|
||||
.to have_enqueued_sidekiq_job(status.id, { 'updated_at' => be_a(String) })
|
||||
end
|
||||
|
||||
context 'when approval_uri is missing' do
|
||||
|
|
|
@ -9,6 +9,7 @@ RSpec.describe ActivityPub::StatusUpdateDistributionWorker do
|
|||
let(:follower) { Fabricate(:account, protocol: :activitypub, inbox_url: 'http://example.com', domain: 'example.com') }
|
||||
|
||||
describe '#perform' do
|
||||
context 'with an explicitly edited status' do
|
||||
before do
|
||||
follower.follow!(status.account)
|
||||
|
||||
|
@ -25,9 +26,8 @@ RSpec.describe ActivityPub::StatusUpdateDistributionWorker do
|
|||
end
|
||||
|
||||
it 'delivers to followers' do
|
||||
expect_push_bulk_to_match(ActivityPub::DeliveryWorker, [[match_json_values(type: 'Update'), status.account.id, 'http://example.com', anything]]) do
|
||||
subject.perform(status.id)
|
||||
end
|
||||
expect { subject.perform(status.id) }
|
||||
.to enqueue_sidekiq_job(ActivityPub::DeliveryWorker).with(match_json_values(type: 'Update'), status.account_id, 'http://example.com', anything)
|
||||
end
|
||||
end
|
||||
|
||||
|
@ -37,8 +37,36 @@ RSpec.describe ActivityPub::StatusUpdateDistributionWorker do
|
|||
end
|
||||
|
||||
it 'delivers to followers' do
|
||||
expect_push_bulk_to_match(ActivityPub::DeliveryWorker, [[match_json_values(type: 'Update'), status.account.id, 'http://example.com', anything]]) do
|
||||
subject.perform(status.id)
|
||||
expect { subject.perform(status.id) }
|
||||
.to enqueue_sidekiq_job(ActivityPub::DeliveryWorker).with(match_json_values(type: 'Update'), status.account_id, 'http://example.com', anything)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
context 'with an implicitly edited status' do
|
||||
before do
|
||||
follower.follow!(status.account)
|
||||
end
|
||||
|
||||
context 'with public status' do
|
||||
before do
|
||||
status.update(visibility: :public)
|
||||
end
|
||||
|
||||
it 'delivers to followers' do
|
||||
expect { subject.perform(status.id, { 'updated_at' => Time.now.utc.iso8601 }) }
|
||||
.to enqueue_sidekiq_job(ActivityPub::DeliveryWorker).with(match_json_values(type: 'Update'), status.account_id, 'http://example.com', anything)
|
||||
end
|
||||
end
|
||||
|
||||
context 'with private status' do
|
||||
before do
|
||||
status.update(visibility: :private)
|
||||
end
|
||||
|
||||
it 'delivers to followers' do
|
||||
expect { subject.perform(status.id, { 'updated_at' => Time.now.utc.iso8601 }) }
|
||||
.to enqueue_sidekiq_job(ActivityPub::DeliveryWorker).with(match_json_values(type: 'Update'), status.account_id, 'http://example.com', anything)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Reference in New Issue
Block a user