123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137 |
- # frozen_string_literal: true
- require 'rails_helper'
- RSpec.describe RemoveStatusService, :sidekiq_inline, type: :service do
- subject { described_class.new }
- let!(:alice) { Fabricate(:account) }
- let!(:bob) { Fabricate(:account, username: 'bob', domain: 'example.com') }
- let!(:jeff) { Fabricate(:account) }
- let!(:hank) { Fabricate(:account, username: 'hank', protocol: :activitypub, domain: 'example.com', inbox_url: 'http://example.com/inbox') }
- let!(:bill) { Fabricate(:account, username: 'bill', protocol: :activitypub, domain: 'example2.com', inbox_url: 'http://example2.com/inbox') }
- before do
- stub_request(:post, hank.inbox_url).to_return(status: 200)
- stub_request(:post, bill.inbox_url).to_return(status: 200)
- jeff.follow!(alice)
- hank.follow!(alice)
- end
- context 'when removed status is not a reblog' do
- let!(:media_attachment) { Fabricate(:media_attachment, account: alice) }
- let!(:status) { PostStatusService.new.call(alice, text: "Hello @#{bob.pretty_acct} ThisIsASecret", media_ids: [media_attachment.id]) }
- before do
- FavouriteService.new.call(jeff, status)
- Fabricate(:status, account: bill, reblog: status, uri: 'hoge')
- end
- it 'removes status from author\'s home feed' do
- subject.call(status)
- expect(HomeFeed.new(alice).get(10).pluck(:id)).to_not include(status.id)
- end
- it 'removes status from local follower\'s home feed' do
- subject.call(status)
- expect(HomeFeed.new(jeff).get(10).pluck(:id)).to_not include(status.id)
- end
- it 'publishes to public media timeline' do
- allow(redis).to receive(:publish).with(any_args)
- subject.call(status)
- expect(redis).to have_received(:publish).with('timeline:public:media', Oj.dump(event: :delete, payload: status.id.to_s))
- end
- it 'sends Delete activity to followers' do
- subject.call(status)
- expect(a_request(:post, hank.inbox_url).with(
- body: hash_including({
- 'type' => 'Delete',
- 'object' => {
- 'type' => 'Tombstone',
- 'id' => ActivityPub::TagManager.instance.uri_for(status),
- 'atomUri' => OStatus::TagManager.instance.uri_for(status),
- },
- })
- )).to have_been_made.once
- end
- it 'sends Delete activity to rebloggers' do
- subject.call(status)
- expect(a_request(:post, bill.inbox_url).with(
- body: hash_including({
- 'type' => 'Delete',
- 'object' => {
- 'type' => 'Tombstone',
- 'id' => ActivityPub::TagManager.instance.uri_for(status),
- 'atomUri' => OStatus::TagManager.instance.uri_for(status),
- },
- })
- )).to have_been_made.once
- end
- it 'remove status from notifications' do
- expect { subject.call(status) }.to change {
- Notification.where(activity_type: 'Favourite', from_account: jeff, account: alice).count
- }.from(1).to(0)
- end
- end
- context 'when removed status is a private self-reblog' do
- let!(:original_status) { Fabricate(:status, account: alice, text: 'Hello ThisIsASecret', visibility: :private) }
- let!(:status) { ReblogService.new.call(alice, original_status) }
- it 'sends Undo activity to followers' do
- subject.call(status)
- expect(a_request(:post, hank.inbox_url).with(
- body: hash_including({
- 'type' => 'Undo',
- 'object' => hash_including({
- 'type' => 'Announce',
- 'object' => ActivityPub::TagManager.instance.uri_for(original_status),
- }),
- })
- )).to have_been_made.once
- end
- end
- context 'when removed status is public self-reblog' do
- let!(:original_status) { Fabricate(:status, account: alice, text: 'Hello ThisIsASecret', visibility: :public) }
- let!(:status) { ReblogService.new.call(alice, original_status) }
- it 'sends Undo activity to followers' do
- subject.call(status)
- expect(a_request(:post, hank.inbox_url).with(
- body: hash_including({
- 'type' => 'Undo',
- 'object' => hash_including({
- 'type' => 'Announce',
- 'object' => ActivityPub::TagManager.instance.uri_for(original_status),
- }),
- })
- )).to have_been_made.once
- end
- end
- context 'when removed status is a reblog of a non-follower' do
- let!(:original_status) { Fabricate(:status, account: bill, text: 'Hello ThisIsASecret', visibility: :public) }
- let!(:status) { ReblogService.new.call(alice, original_status) }
- it 'sends Undo activity to followers' do
- subject.call(status)
- expect(a_request(:post, bill.inbox_url).with(
- body: hash_including({
- 'type' => 'Undo',
- 'object' => hash_including({
- 'type' => 'Announce',
- 'object' => ActivityPub::TagManager.instance.uri_for(original_status),
- }),
- })
- )).to have_been_made.once
- end
- end
- end
|