Skip to content

Commit

Permalink
Fix Announce activities of unknown statuses not fetching those status…
Browse files Browse the repository at this point in the history
…es (mastodon#10065)

Regression from mastodon#9998
  • Loading branch information
Gargron authored Feb 17, 2019
1 parent 8d4af05 commit 810ac98
Show file tree
Hide file tree
Showing 2 changed files with 32 additions and 14 deletions.
3 changes: 1 addition & 2 deletions app/lib/activitypub/activity.rb
Original file line number Diff line number Diff line change
Expand Up @@ -150,8 +150,7 @@ def status_from_object
end
end

# If the status is not from the actor, try to fetch it
return fetch_remote_original_status if value_or_id(first_of_value(@json['attributedTo'])) == @account.uri
fetch_remote_original_status
end

def fetch_remote_original_status
Expand Down
43 changes: 31 additions & 12 deletions spec/lib/activitypub/activity/announce_spec.rb
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
require 'rails_helper'

RSpec.describe ActivityPub::Activity::Announce do
let(:sender) { Fabricate(:account, followers_url: 'http://example.com/followers') }
let(:sender) { Fabricate(:account, followers_url: 'http://example.com/followers', uri: 'https://example.com/actor') }
let(:recipient) { Fabricate(:account) }
let(:status) { Fabricate(:status, account: recipient) }

Expand All @@ -10,21 +10,29 @@
'@context': 'https://www.w3.org/ns/activitystreams',
id: 'foo',
type: 'Announce',
actor: ActivityPub::TagManager.instance.uri_for(sender),
actor: 'https://example.com/actor',
object: object_json,
}.with_indifferent_access
end

subject { described_class.new(json, sender) }

before do
sender.update(uri: ActivityPub::TagManager.instance.uri_for(sender))
let(:unknown_object_json) do
{
'@context': 'https://www.w3.org/ns/activitystreams',
id: 'https://example.com/actor/hello-world',
type: 'Note',
attributedTo: 'https://example.com/actor',
content: 'Hello world',
to: 'http://example.com/followers',
}
end

subject { described_class.new(json, sender) }

describe '#perform' do
context 'when sender is followed by a local account' do
before do
Fabricate(:account).follow!(sender)
stub_request(:get, 'https://example.com/actor/hello-world').to_return(body: Oj.dump(unknown_object_json))
subject.perform
end

Expand All @@ -38,10 +46,21 @@
end
end

context 'an unknown status' do
let(:object_json) { 'https://example.com/actor/hello-world' }

it 'creates a reblog by sender of status' do
reblog = sender.statuses.first

expect(reblog).to_not be_nil
expect(reblog.reblog.text).to eq 'Hello world'
end
end

context 'self-boost of a previously unknown status with missing attributedTo' do
let(:object_json) do
{
id: [ActivityPub::TagManager.instance.uri_for(sender), '#bar'].join,
id: 'https://example.com/actor#bar',
type: 'Note',
content: 'Lorem ipsum',
to: 'http://example.com/followers',
Expand All @@ -56,10 +75,10 @@
context 'self-boost of a previously unknown status with correct attributedTo' do
let(:object_json) do
{
id: [ActivityPub::TagManager.instance.uri_for(sender), '#bar'].join,
id: 'https://example.com/actor#bar',
type: 'Note',
content: 'Lorem ipsum',
attributedTo: ActivityPub::TagManager.instance.uri_for(sender),
attributedTo: 'https://example.com/actor',
to: 'http://example.com/followers',
}
end
Expand Down Expand Up @@ -98,7 +117,7 @@

let(:object_json) do
{
id: [ActivityPub::TagManager.instance.uri_for(sender), '#bar'].join,
id: 'https://example.com/actor#bar',
type: 'Note',
content: 'Lorem ipsum',
to: 'http://example.com/followers',
Expand All @@ -117,7 +136,7 @@

let(:object_json) do
{
id: [ActivityPub::TagManager.instance.uri_for(sender), '#bar'].join,
id: 'https://example.com/actor#bar',
type: 'Note',
content: 'Lorem ipsum',
to: 'http://example.com/followers',
Expand All @@ -137,7 +156,7 @@

let(:object_json) do
{
id: [ActivityPub::TagManager.instance.uri_for(sender), '#bar'].join,
id: 'https://example.com/actor#bar',
type: 'Note',
content: 'Lorem ipsum',
to: 'http://example.com/followers',
Expand Down

0 comments on commit 810ac98

Please sign in to comment.