follow.destroy!
create_notification(follow) unless @target_account.local?
+ create_reject_notification(follow) if @target_account.local? && !@source_account.local?
UnmergeWorker.perform_async(@target_account.id, @source_account.id)
follow
end
end
end
+ def create_reject_notification(follow)
+ # Rejecting an already-existing follow request
+ return unless follow.account.activitypub?
+ ActivityPub::DeliveryWorker.perform_async(build_reject_json(follow), follow.target_account_id, follow.account.inbox_url)
+ end
+
def build_json(follow)
ActiveModelSerializers::SerializableResource.new(
follow,
).to_json
end
+ def build_reject_json(follow)
+ ActiveModelSerializers::SerializableResource.new(
+ follow,
+ serializer: ActivityPub::RejectFollowSerializer,
+ adapter: ActivityPub::Adapter
+ ).to_json
+ end
+
def build_xml(follow)
OStatus::AtomSerializer.render(OStatus::AtomSerializer.new.unfollow_salmon(follow))
end
expect(a_request(:post, 'http://example.com/inbox')).to have_been_made.once
end
end
+
+ describe 'remote ActivityPub (reverse)' do
+ let(:bob) { Fabricate(:user, email: 'bob@example.com', account: Fabricate(:account, username: 'bob', protocol: :activitypub, domain: 'example.com', inbox_url: 'http://example.com/inbox')).account }
+
+ before do
+ bob.follow!(sender)
+ stub_request(:post, 'http://example.com/inbox').to_return(status: 200)
+ subject.call(bob, sender)
+ end
+
+ it 'destroys the following relation' do
+ expect(bob.following?(sender)).to be false
+ end
+
+ it 'sends a reject activity' do
+ expect(a_request(:post, 'http://example.com/inbox')).to have_been_made.once
+ end
+ end
end