logo

mastofe

My custom branche(s) on git.pleroma.social/pleroma/mastofe git clone https://hacktivis.me/git/mastofe.git

process_feed_service_spec.rb (12445B)

    

  1. require 'rails_helper'
  3. RSpec.describe ProcessFeedService do
  4.   subject { ProcessFeedService.new }
  6.   describe 'processing a feed' do
  7.     let(:body) { File.read(File.join(Rails.root, 'spec', 'fixtures', 'xml', 'mastodon.atom')) }
  8.     let(:account) { Fabricate(:account, username: 'localhost', domain: 'kickass.zone') }
  10.     before do
  11.       stub_request(:post, "https://pubsubhubbub.superfeedr.com/").to_return(:status => 200, :body => "", :headers => {})
  12.       stub_request(:head, "http://kickass.zone/media/2").to_return(:status => 404)
  13.       stub_request(:head, "http://kickass.zone/media/3").to_return(:status => 404)
  14.       stub_request(:get, "http://kickass.zone/system/accounts/avatars/000/000/001/large/eris.png").to_return(request_fixture('avatar.txt'))
  15.       stub_request(:get, "http://kickass.zone/system/media_attachments/files/000/000/002/original/morpheus_linux.jpg?1476059910").to_return(request_fixture('attachment1.txt'))
  16.       stub_request(:get, "http://kickass.zone/system/media_attachments/files/000/000/003/original/gizmo.jpg?1476060065").to_return(request_fixture('attachment2.txt'))
  17.     end
  19.     context 'when domain does not reject media' do
  20.       before do
  21.         subject.call(body, account)
  22.       end
  24.       it 'updates remote user\'s account information' do
  25.         account.reload
  26.         expect(account.display_name).to eq '::1'
  27.         expect(account).to have_attached_file(:avatar)
  28.         expect(account.avatar_file_name).not_to be_nil
  29.       end
  31.       it 'creates posts' do
  32.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=1:objectType=Status')).to_not be_nil
  33.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=2:objectType=Status')).to_not be_nil
  34.       end
  36.       it 'marks replies as replies' do
  37.         status = Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=2:objectType=Status')
  38.         expect(status.reply?).to be true
  39.       end
  41.       it 'sets account being replied to when possible' do
  42.         status = Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=2:objectType=Status')
  43.         expect(status.in_reply_to_account_id).to eq status.account_id
  44.       end
  46.       it 'ignores delete statuses unless they existed before' do
  47.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=3:objectType=Status')).to be_nil
  48.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=12:objectType=Status')).to be_nil
  49.       end
  51.       it 'does not create statuses for follows' do
  52.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=1:objectType=Follow')).to be_nil
  53.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=2:objectType=Follow')).to be_nil
  54.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=4:objectType=Follow')).to be_nil
  55.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=7:objectType=Follow')).to be_nil
  56.       end
  58.       it 'does not create statuses for favourites' do
  59.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=2:objectType=Favourite')).to be_nil
  60.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=3:objectType=Favourite')).to be_nil
  61.       end
  63.       it 'creates posts with media' do
  64.         status = Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=14:objectType=Status')
  66.         expect(status).to_not be_nil
  67.         expect(status.media_attachments.first).to have_attached_file(:file)
  68.         expect(status.media_attachments.first.image?).to be true
  69.         expect(status.media_attachments.first.file_file_name).not_to be_nil
  70.       end
  71.     end
  73.     context 'when domain is set to reject media' do
  74.       let!(:domain_block) { Fabricate(:domain_block, domain: 'kickass.zone', reject_media: true) }
  76.       before do
  77.         subject.call(body, account)
  78.       end
  80.       it 'updates remote user\'s account information' do
  81.         account.reload
  82.         expect(account.display_name).to eq '::1'
  83.       end
  85.       it 'rejects remote user\'s avatar' do
  86.         account.reload
  87.         expect(account.display_name).to eq '::1'
  88.         expect(account.avatar_file_name).to be_nil
  89.       end
  91.       it 'creates posts' do
  92.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=1:objectType=Status')).to_not be_nil
  93.         expect(Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=2:objectType=Status')).to_not be_nil
  94.       end
  96.       it 'creates posts with remote-only media' do
  97.         status = Status.find_by(uri: 'tag:kickass.zone,2016-10-10:objectId=14:objectType=Status')
  99.         expect(status).to_not be_nil
  100.         expect(status.media_attachments.first.file_file_name).to be_nil
  101.         expect(status.media_attachments.first.unknown?).to be true
  102.       end
  103.     end
  104.   end
  106.   it 'does not accept tampered reblogs' do
  107.     good_actor = Fabricate(:account, username: 'tracer', domain: 'overwatch.com')
  109.     real_body = <<XML
  110. <?xml version="1.0"?>
  111. <entry xmlns="http://www.w3.org/2005/Atom" xmlns:thr="http://purl.org/syndication/thread/1.0" xmlns:activity="http://activitystrea.ms/spec/1.0/" xmlns:poco="http://portablecontacts.net/spec/1.0" xmlns:media="http://purl.org/syndication/atommedia" xmlns:ostatus="http://ostatus.org/schema/1.0" xmlns:mastodon="http://mastodon.social/schema/1.0">
  112.   <id>tag:overwatch.com,2017-04-27:objectId=4467137:objectType=Status</id>
  113.   <published>2017-04-27T13:49:25Z</published>
  114.   <updated>2017-04-27T13:49:25Z</updated>
  115.   <activity:object-type>http://activitystrea.ms/schema/1.0/note</activity:object-type>
  116.   <activity:verb>http://activitystrea.ms/schema/1.0/post</activity:verb>
  117.   <author>
  118.     <id>https://overwatch.com/users/tracer</id>
  119.     <activity:object-type>http://activitystrea.ms/schema/1.0/person</activity:object-type>
  120.     <uri>https://overwatch.com/users/tracer</uri>
  121.     <name>tracer</name>
  122.   </author>
  123.   <content type="html">Overwatch rocks</content>
  124. </entry>
  125. XML
  127.     stub_request(:get, 'https://overwatch.com/users/tracer/updates/1').to_return(status: 200, body: real_body, headers: { 'Content-Type' => 'application/atom+xml' })
  129.     bad_actor = Fabricate(:account, username: 'sombra', domain: 'talon.xyz')
  131.     body = <<XML
  132. <?xml version="1.0"?>
  133. <entry xmlns="http://www.w3.org/2005/Atom" xmlns:thr="http://purl.org/syndication/thread/1.0" xmlns:activity="http://activitystrea.ms/spec/1.0/" xmlns:poco="http://portablecontacts.net/spec/1.0" xmlns:media="http://purl.org/syndication/atommedia" xmlns:ostatus="http://ostatus.org/schema/1.0" xmlns:mastodon="http://mastodon.social/schema/1.0">
  134.   <id>tag:talon.xyz,2017-04-27:objectId=4467137:objectType=Status</id>
  135.   <published>2017-04-27T13:49:25Z</published>
  136.   <updated>2017-04-27T13:49:25Z</updated>
  137.   <author>
  138.     <id>https://talon.xyz/users/sombra</id>
  139.     <activity:object-type>http://activitystrea.ms/schema/1.0/person</activity:object-type>
  140.     <uri>https://talon.xyz/users/sombra</uri>
  141.     <name>sombra</name>
  142.   </author>
  143.   <activity:object-type>http://activitystrea.ms/schema/1.0/activity</activity:object-type>
  144.   <activity:verb>http://activitystrea.ms/schema/1.0/share</activity:verb>
  145.   <content type="html">Overwatch SUCKS AHAHA</content>
  146.   <activity:object>
  147.     <id>tag:overwatch.com,2017-04-27:objectId=4467137:objectType=Status</id>
  148.     <activity:object-type>http://activitystrea.ms/schema/1.0/note</activity:object-type>
  149.     <activity:verb>http://activitystrea.ms/schema/1.0/post</activity:verb>
  150.     <author>
  151.       <id>https://overwatch.com/users/tracer</id>
  152.       <activity:object-type>http://activitystrea.ms/schema/1.0/person</activity:object-type>
  153.       <uri>https://overwatch.com/users/tracer</uri>
  154.       <name>tracer</name>
  155.     </author>
  156.     <content type="html">Overwatch SUCKS AHAHA</content>
  157.     <link rel="alternate" type="text/html" href="https://overwatch.com/users/tracer/updates/1" />
  158.   </activity:object>
  159. </entry>
  160. XML
  161.     created_statuses = subject.call(body, bad_actor)
  163.     expect(created_statuses.first.reblog?).to be true
  164.     expect(created_statuses.first.account_id).to eq bad_actor.id
  165.     expect(created_statuses.first.reblog.account_id).to eq good_actor.id
  166.     expect(created_statuses.first.reblog.text).to eq 'Overwatch rocks'
  167.   end
  169.   it 'ignores reblogs if it failed to retreive reblogged statuses' do
  170.     stub_request(:get, 'https://overwatch.com/users/tracer/updates/1').to_return(status: 404)
  172.     actor = Fabricate(:account, username: 'tracer', domain: 'overwatch.com')
  174.     body = <<XML
  175. <?xml version="1.0"?>
  176. <entry xmlns="http://www.w3.org/2005/Atom" xmlns:thr="http://purl.org/syndication/thread/1.0" xmlns:activity="http://activitystrea.ms/spec/1.0/" xmlns:poco="http://portablecontacts.net/spec/1.0" xmlns:media="http://purl.org/syndication/atommedia" xmlns:ostatus="http://ostatus.org/schema/1.0" xmlns:mastodon="http://mastodon.social/schema/1.0">
  177.   <id>tag:overwatch.com,2017-04-27:objectId=4467137:objectType=Status</id>
  178.   <published>2017-04-27T13:49:25Z</published>
  179.   <updated>2017-04-27T13:49:25Z</updated>
  180.   <author>
  181.     <id>https://overwatch.com/users/tracer</id>
  182.     <activity:object-type>http://activitystrea.ms/schema/1.0/person</activity:object-type>
  183.     <uri>https://overwatch.com/users/tracer</uri>
  184.     <name>tracer</name>
  185.   </author>
  186.   <activity:object-type>http://activitystrea.ms/schema/1.0/activity</activity:object-type>
  187.   <activity:verb>http://activitystrea.ms/schema/1.0/share</activity:verb>
  188.   <content type="html">Overwatch rocks</content>
  189.   <activity:object>
  190.     <id>tag:overwatch.com,2017-04-27:objectId=4467137:objectType=Status</id>
  191.     <activity:object-type>http://activitystrea.ms/schema/1.0/note</activity:object-type>
  192.     <activity:verb>http://activitystrea.ms/schema/1.0/post</activity:verb>
  193.     <author>
  194.       <id>https://overwatch.com/users/tracer</id>
  195.       <activity:object-type>http://activitystrea.ms/schema/1.0/person</activity:object-type>
  196.       <uri>https://overwatch.com/users/tracer</uri>
  197.       <name>tracer</name>
  198.     </author>
  199.     <content type="html">Overwatch rocks</content>
  200.     <link rel="alternate" type="text/html" href="https://overwatch.com/users/tracer/updates/1" />
  201.   </activity:object>
  202. XML
  204.     created_statuses = subject.call(body, actor)
  206.     expect(created_statuses).to eq []
  207.   end
  209.   it 'ignores statuses with an out-of-order delete' do
  210.     sender = Fabricate(:account, username: 'tracer', domain: 'overwatch.com')
  212.     delete_body = <<XML
  213. <?xml version="1.0"?>
  214. <entry xmlns="http://www.w3.org/2005/Atom" xmlns:thr="http://purl.org/syndication/thread/1.0" xmlns:activity="http://activitystrea.ms/spec/1.0/" xmlns:poco="http://portablecontacts.net/spec/1.0" xmlns:media="http://purl.org/syndication/atommedia" xmlns:ostatus="http://ostatus.org/schema/1.0" xmlns:mastodon="http://mastodon.social/schema/1.0">
  215.   <id>tag:overwatch.com,2017-04-27:objectId=4487555:objectType=Status</id>
  216.   <published>2017-04-27T13:49:25Z</published>
  217.   <updated>2017-04-27T13:49:25Z</updated>
  218.   <activity:object-type>http://activitystrea.ms/schema/1.0/note</activity:object-type>
  219.   <activity:verb>http://activitystrea.ms/schema/1.0/delete</activity:verb>
  220.   <author>
  221.     <id>https://overwatch.com/users/tracer</id>
  222.     <activity:object-type>http://activitystrea.ms/schema/1.0/person</activity:object-type>
  223.     <uri>https://overwatch.com/users/tracer</uri>
  224.     <name>tracer</name>
  225.   </author>
  226. </entry>
  227. XML
  229.     status_body = <<XML
  230. <?xml version="1.0"?>
  231. <entry xmlns="http://www.w3.org/2005/Atom" xmlns:thr="http://purl.org/syndication/thread/1.0" xmlns:activity="http://activitystrea.ms/spec/1.0/" xmlns:poco="http://portablecontacts.net/spec/1.0" xmlns:media="http://purl.org/syndication/atommedia" xmlns:ostatus="http://ostatus.org/schema/1.0" xmlns:mastodon="http://mastodon.social/schema/1.0">
  232.   <id>tag:overwatch.com,2017-04-27:objectId=4487555:objectType=Status</id>
  233.   <published>2017-04-27T13:49:25Z</published>
  234.   <updated>2017-04-27T13:49:25Z</updated>
  235.   <activity:object-type>http://activitystrea.ms/schema/1.0/note</activity:object-type>
  236.   <activity:verb>http://activitystrea.ms/schema/1.0/post</activity:verb>
  237.   <author>
  238.     <id>https://overwatch.com/users/tracer</id>
  239.     <activity:object-type>http://activitystrea.ms/schema/1.0/person</activity:object-type>
  240.     <uri>https://overwatch.com/users/tracer</uri>
  241.     <name>tracer</name>
  242.   </author>
  243.   <content type="html">Overwatch rocks</content>
  244. </entry>
  245. XML
  247.     subject.call(delete_body, sender)
  248.     created_statuses = subject.call(status_body, sender)
  250.     expect(created_statuses).to be_empty
  251.   end
  252. end