123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321 |
- # frozen_string_literal: true
- require 'rails_helper'
- RSpec.describe ActivityPub::FetchRemoteStatusService, type: :service do
- include ActionView::Helpers::TextHelper
- subject { described_class.new }
- let!(:sender) { Fabricate(:account, domain: 'foo.bar', uri: 'https://foo.bar') }
- let(:existing_status) { nil }
- let(:note) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1234',
- type: 'Note',
- content: 'Lorem ipsum',
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- }
- end
- before do
- stub_request(:get, 'https://foo.bar/watch?v=12345').to_return(status: 404, body: '')
- stub_request(:get, object[:id]).to_return(body: Oj.dump(object))
- end
- describe '#call' do
- before do
- existing_status
- subject.call(object[:id], prefetched_body: Oj.dump(object))
- end
- context 'with Note object' do
- let(:object) { note }
- it 'creates status' do
- status = sender.statuses.first
- expect(status).to_not be_nil
- expect(status.text).to eq 'Lorem ipsum'
- end
- end
- context 'with Video object' do
- let(:object) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1234',
- type: 'Video',
- name: 'Nyan Cat 10 hours remix',
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- url: [
- {
- type: 'Link',
- mimeType: 'application/x-bittorrent',
- href: 'https://foo.bar/12345.torrent',
- },
- {
- type: 'Link',
- mimeType: 'text/html',
- href: 'https://foo.bar/watch?v=12345',
- },
- ],
- }
- end
- it 'creates status' do
- status = sender.statuses.first
- expect(status).to_not be_nil
- expect(status.url).to eq 'https://foo.bar/watch?v=12345'
- expect(strip_tags(status.text)).to eq 'Nyan Cat 10 hours remixhttps://foo.bar/watch?v=12345'
- end
- end
- context 'with Audio object' do
- let(:object) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1234',
- type: 'Audio',
- name: 'Nyan Cat 10 hours remix',
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- url: [
- {
- type: 'Link',
- mimeType: 'application/x-bittorrent',
- href: 'https://foo.bar/12345.torrent',
- },
- {
- type: 'Link',
- mimeType: 'text/html',
- href: 'https://foo.bar/watch?v=12345',
- },
- ],
- }
- end
- it 'creates status' do
- status = sender.statuses.first
- expect(status).to_not be_nil
- expect(status.url).to eq 'https://foo.bar/watch?v=12345'
- expect(strip_tags(status.text)).to eq 'Nyan Cat 10 hours remixhttps://foo.bar/watch?v=12345'
- end
- end
- context 'with Event object' do
- let(:object) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1234',
- type: 'Event',
- name: "Let's change the world",
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- }
- end
- it 'creates status' do
- status = sender.statuses.first
- expect(status).to_not be_nil
- expect(status.url).to eq 'https://foo.bar/@foo/1234'
- expect(strip_tags(status.text)).to eq "Let's change the worldhttps://foo.bar/@foo/1234"
- end
- end
- context 'with wrong id' do
- let(:note) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://real.address/@foo/1234',
- type: 'Note',
- content: 'Lorem ipsum',
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- }
- end
- let(:object) do
- temp = note.dup
- temp[:id] = 'https://fake.address/@foo/5678'
- temp
- end
- it 'does not create status' do
- expect(sender.statuses.first).to be_nil
- end
- end
- context 'with a valid Create activity' do
- let(:object) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1234/create',
- type: 'Create',
- actor: ActivityPub::TagManager.instance.uri_for(sender),
- object: note,
- }
- end
- it 'creates status' do
- status = sender.statuses.first
- expect(status).to_not be_nil
- expect(status.uri).to eq note[:id]
- expect(status.text).to eq note[:content]
- end
- end
- context 'with a Create activity with a mismatching id' do
- let(:object) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1234/create',
- type: 'Create',
- actor: ActivityPub::TagManager.instance.uri_for(sender),
- object: {
- id: 'https://real.address/@foo/1234',
- type: 'Note',
- content: 'Lorem ipsum',
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- },
- }
- end
- it 'does not create status' do
- expect(sender.statuses.first).to be_nil
- end
- end
- context 'when status already exists' do
- let(:existing_status) { Fabricate(:status, account: sender, text: 'Foo', uri: note[:id]) }
- context 'with a Note object' do
- let(:object) { note.merge(updated: '2021-09-08T22:39:25Z') }
- it 'updates status' do
- existing_status.reload
- expect(existing_status.text).to eq 'Lorem ipsum'
- expect(existing_status.edits).to_not be_empty
- end
- end
- context 'with a Create activity' do
- let(:object) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1234/create',
- type: 'Create',
- actor: ActivityPub::TagManager.instance.uri_for(sender),
- object: note.merge(updated: '2021-09-08T22:39:25Z'),
- }
- end
- it 'updates status' do
- existing_status.reload
- expect(existing_status.text).to eq 'Lorem ipsum'
- expect(existing_status.edits).to_not be_empty
- end
- end
- end
- end
- context 'with statuses referencing other statuses', :sidekiq_inline do
- before do
- stub_const 'ActivityPub::FetchRemoteStatusService::DISCOVERIES_PER_REQUEST', 5
- end
- context 'when using inReplyTo' do
- let(:object) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1',
- type: 'Note',
- content: 'Lorem ipsum',
- inReplyTo: 'https://foo.bar/@foo/2',
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- }
- end
- before do
- 8.times do |i|
- status_json = {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: "https://foo.bar/@foo/#{i}",
- type: 'Note',
- content: 'Lorem ipsum',
- inReplyTo: "https://foo.bar/@foo/#{i + 1}",
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- to: 'as:Public',
- }.with_indifferent_access
- stub_request(:get, "https://foo.bar/@foo/#{i}").to_return(status: 200, body: status_json.to_json, headers: { 'Content-Type': 'application/activity+json' })
- end
- end
- it 'creates at least some statuses' do
- expect { subject.call(object[:id], prefetched_body: Oj.dump(object)) }.to change { sender.statuses.count }.by_at_least(2)
- end
- it 'creates no more account than the limit allows' do
- expect { subject.call(object[:id], prefetched_body: Oj.dump(object)) }.to change { sender.statuses.count }.by_at_most(5)
- end
- end
- context 'when using replies' do
- let(:object) do
- {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: 'https://foo.bar/@foo/1',
- type: 'Note',
- content: 'Lorem ipsum',
- replies: {
- type: 'Collection',
- id: 'https://foo.bar/@foo/1/replies',
- first: {
- type: 'CollectionPage',
- partOf: 'https://foo.bar/@foo/1/replies',
- items: ['https://foo.bar/@foo/2'],
- },
- },
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- }
- end
- before do
- 8.times do |i|
- status_json = {
- '@context': 'https://www.w3.org/ns/activitystreams',
- id: "https://foo.bar/@foo/#{i}",
- type: 'Note',
- content: 'Lorem ipsum',
- replies: {
- type: 'Collection',
- id: "https://foo.bar/@foo/#{i}/replies",
- first: {
- type: 'CollectionPage',
- partOf: "https://foo.bar/@foo/#{i}/replies",
- items: ["https://foo.bar/@foo/#{i + 1}"],
- },
- },
- attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
- to: 'as:Public',
- }.with_indifferent_access
- stub_request(:get, "https://foo.bar/@foo/#{i}").to_return(status: 200, body: status_json.to_json, headers: { 'Content-Type': 'application/activity+json' })
- end
- end
- it 'creates at least some statuses' do
- expect { subject.call(object[:id], prefetched_body: Oj.dump(object)) }.to change { sender.statuses.count }.by_at_least(2)
- end
- it 'creates no more account than the limit allows' do
- expect { subject.call(object[:id], prefetched_body: Oj.dump(object)) }.to change { sender.statuses.count }.by_at_most(5)
- end
- end
- end
- end
|