forked from cybrespace/mastodon
Rename FollowRemoteAccountService to ResolveRemoteAccountService (#3847)
Rename Activitypub to ActivityPub
This commit is contained in:
parent
aebebdc5d1
commit
f3be605286
|
@ -1,6 +1,6 @@
|
||||||
# frozen_string_literal: true
|
# frozen_string_literal: true
|
||||||
|
|
||||||
class Api::Activitypub::ActivitiesController < Api::BaseController
|
class Api::ActivityPub::ActivitiesController < Api::BaseController
|
||||||
include Authorization
|
include Authorization
|
||||||
|
|
||||||
# before_action :set_follow, only: [:show_follow]
|
# before_action :set_follow, only: [:show_follow]
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
# frozen_string_literal: true
|
# frozen_string_literal: true
|
||||||
|
|
||||||
class Api::Activitypub::NotesController < Api::BaseController
|
class Api::ActivityPub::NotesController < Api::BaseController
|
||||||
include Authorization
|
include Authorization
|
||||||
|
|
||||||
before_action :set_status
|
before_action :set_status
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
# frozen_string_literal: true
|
# frozen_string_literal: true
|
||||||
|
|
||||||
class Api::Activitypub::OutboxController < Api::BaseController
|
class Api::ActivityPub::OutboxController < Api::BaseController
|
||||||
before_action :set_account
|
before_action :set_account
|
||||||
|
|
||||||
respond_to :activitystreams2
|
respond_to :activitystreams2
|
||||||
|
|
|
@ -40,7 +40,7 @@ class AuthorizeFollowsController < ApplicationController
|
||||||
end
|
end
|
||||||
|
|
||||||
def account_from_remote_follow
|
def account_from_remote_follow
|
||||||
FollowRemoteAccountService.new.call(acct_without_prefix)
|
ResolveRemoteAccountService.new.call(acct_without_prefix)
|
||||||
end
|
end
|
||||||
|
|
||||||
def acct_param_is_url?
|
def acct_param_is_url?
|
||||||
|
|
|
@ -18,7 +18,7 @@ class AccountSearchService < BaseService
|
||||||
return [] if query_blank_or_hashtag? || limit < 1
|
return [] if query_blank_or_hashtag? || limit < 1
|
||||||
|
|
||||||
if resolving_non_matching_remote_account?
|
if resolving_non_matching_remote_account?
|
||||||
[FollowRemoteAccountService.new.call("#{query_username}@#{query_domain}")]
|
[ResolveRemoteAccountService.new.call("#{query_username}@#{query_domain}")]
|
||||||
else
|
else
|
||||||
search_results_and_exact_match.compact.uniq.slice(0, limit)
|
search_results_and_exact_match.compact.uniq.slice(0, limit)
|
||||||
end
|
end
|
||||||
|
|
|
@ -18,6 +18,6 @@ module AuthorExtractor
|
||||||
acct = "#{username}@#{domain}"
|
acct = "#{username}@#{domain}"
|
||||||
end
|
end
|
||||||
|
|
||||||
FollowRemoteAccountService.new.call(acct, update_profile)
|
ResolveRemoteAccountService.new.call(acct, update_profile)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -7,7 +7,7 @@ class FollowService < BaseService
|
||||||
# @param [Account] source_account From which to follow
|
# @param [Account] source_account From which to follow
|
||||||
# @param [String] uri User URI to follow in the form of username@domain
|
# @param [String] uri User URI to follow in the form of username@domain
|
||||||
def call(source_account, uri)
|
def call(source_account, uri)
|
||||||
target_account = FollowRemoteAccountService.new.call(uri)
|
target_account = ResolveRemoteAccountService.new.call(uri)
|
||||||
|
|
||||||
raise ActiveRecord::RecordNotFound if target_account.nil? || target_account.id == source_account.id || target_account.suspended?
|
raise ActiveRecord::RecordNotFound if target_account.nil? || target_account.id == source_account.id || target_account.suspended?
|
||||||
raise Mastodon::NotPermittedError if target_account.blocking?(source_account) || source_account.blocking?(target_account)
|
raise Mastodon::NotPermittedError if target_account.blocking?(source_account) || source_account.blocking?(target_account)
|
||||||
|
|
|
@ -41,6 +41,6 @@ class ProcessMentionsService < BaseService
|
||||||
private
|
private
|
||||||
|
|
||||||
def follow_remote_account_service
|
def follow_remote_account_service
|
||||||
@follow_remote_account_service ||= FollowRemoteAccountService.new
|
@follow_remote_account_service ||= ResolveRemoteAccountService.new
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
# frozen_string_literal: true
|
# frozen_string_literal: true
|
||||||
|
|
||||||
class FollowRemoteAccountService < BaseService
|
class ResolveRemoteAccountService < BaseService
|
||||||
include OStatus2::MagicKey
|
include OStatus2::MagicKey
|
||||||
include HttpHelper
|
include HttpHelper
|
||||||
|
|
|
@ -41,7 +41,7 @@ class ImportWorker
|
||||||
def process_mutes
|
def process_mutes
|
||||||
import_rows.each do |row|
|
import_rows.each do |row|
|
||||||
begin
|
begin
|
||||||
target_account = FollowRemoteAccountService.new.call(row.first)
|
target_account = ResolveRemoteAccountService.new.call(row.first)
|
||||||
next if target_account.nil?
|
next if target_account.nil?
|
||||||
MuteService.new.call(from_account, target_account)
|
MuteService.new.call(from_account, target_account)
|
||||||
rescue Goldfinger::Error, HTTP::Error, OpenSSL::SSL::SSLError
|
rescue Goldfinger::Error, HTTP::Error, OpenSSL::SSL::SSLError
|
||||||
|
@ -53,7 +53,7 @@ class ImportWorker
|
||||||
def process_blocks
|
def process_blocks
|
||||||
import_rows.each do |row|
|
import_rows.each do |row|
|
||||||
begin
|
begin
|
||||||
target_account = FollowRemoteAccountService.new.call(row.first)
|
target_account = ResolveRemoteAccountService.new.call(row.first)
|
||||||
next if target_account.nil?
|
next if target_account.nil?
|
||||||
BlockService.new.call(from_account, target_account)
|
BlockService.new.call(from_account, target_account)
|
||||||
rescue Goldfinger::Error, HTTP::Error, OpenSSL::SSL::SSLError
|
rescue Goldfinger::Error, HTTP::Error, OpenSSL::SSL::SSLError
|
||||||
|
|
|
@ -13,4 +13,5 @@
|
||||||
ActiveSupport::Inflector.inflections(:en) do |inflect|
|
ActiveSupport::Inflector.inflections(:en) do |inflect|
|
||||||
inflect.acronym 'StatsD'
|
inflect.acronym 'StatsD'
|
||||||
inflect.acronym 'OEmbed'
|
inflect.acronym 'OEmbed'
|
||||||
|
inflect.acronym 'ActivityPub'
|
||||||
end
|
end
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
require 'rails_helper'
|
require 'rails_helper'
|
||||||
|
|
||||||
RSpec.describe Api::Activitypub::ActivitiesController, type: :controller do
|
RSpec.describe Api::ActivityPub::ActivitiesController, type: :controller do
|
||||||
render_views
|
render_views
|
||||||
|
|
||||||
let(:user) { Fabricate(:user, account: Fabricate(:account, username: 'alice')) }
|
let(:user) { Fabricate(:user, account: Fabricate(:account, username: 'alice')) }
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
require 'rails_helper'
|
require 'rails_helper'
|
||||||
|
|
||||||
RSpec.describe Api::Activitypub::NotesController, type: :controller do
|
RSpec.describe Api::ActivityPub::NotesController, type: :controller do
|
||||||
render_views
|
render_views
|
||||||
|
|
||||||
let(:user_alice) { Fabricate(:user, account: Fabricate(:account, username: 'alice')) }
|
let(:user_alice) { Fabricate(:user, account: Fabricate(:account, username: 'alice')) }
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
require 'rails_helper'
|
require 'rails_helper'
|
||||||
|
|
||||||
RSpec.describe Api::Activitypub::OutboxController, type: :controller do
|
RSpec.describe Api::ActivityPub::OutboxController, type: :controller do
|
||||||
render_views
|
render_views
|
||||||
|
|
||||||
let(:user) { Fabricate(:user, account: Fabricate(:account, username: 'alice')) }
|
let(:user) { Fabricate(:user, account: Fabricate(:account, username: 'alice')) }
|
||||||
|
|
|
@ -30,7 +30,7 @@ describe AuthorizeFollowsController do
|
||||||
|
|
||||||
it 'renders error when account cant be found' do
|
it 'renders error when account cant be found' do
|
||||||
service = double
|
service = double
|
||||||
allow(FollowRemoteAccountService).to receive(:new).and_return(service)
|
allow(ResolveRemoteAccountService).to receive(:new).and_return(service)
|
||||||
allow(service).to receive(:call).with('missing@hostname').and_return(nil)
|
allow(service).to receive(:call).with('missing@hostname').and_return(nil)
|
||||||
|
|
||||||
get :show, params: { acct: 'acct:missing@hostname' }
|
get :show, params: { acct: 'acct:missing@hostname' }
|
||||||
|
@ -54,7 +54,7 @@ describe AuthorizeFollowsController do
|
||||||
it 'sets account from acct uri' do
|
it 'sets account from acct uri' do
|
||||||
account = Account.new
|
account = Account.new
|
||||||
service = double
|
service = double
|
||||||
allow(FollowRemoteAccountService).to receive(:new).and_return(service)
|
allow(ResolveRemoteAccountService).to receive(:new).and_return(service)
|
||||||
allow(service).to receive(:call).with('found@hostname').and_return(account)
|
allow(service).to receive(:call).with('found@hostname').and_return(account)
|
||||||
|
|
||||||
get :show, params: { acct: 'acct:found@hostname' }
|
get :show, params: { acct: 'acct:found@hostname' }
|
||||||
|
|
|
@ -17,7 +17,7 @@ RSpec.describe Settings::ImportsController, type: :controller do
|
||||||
describe 'POST #create' do
|
describe 'POST #create' do
|
||||||
it 'redirects to settings path with successful following import' do
|
it 'redirects to settings path with successful following import' do
|
||||||
service = double(call: nil)
|
service = double(call: nil)
|
||||||
allow(FollowRemoteAccountService).to receive(:new).and_return(service)
|
allow(ResolveRemoteAccountService).to receive(:new).and_return(service)
|
||||||
post :create, params: {
|
post :create, params: {
|
||||||
import: {
|
import: {
|
||||||
type: 'following',
|
type: 'following',
|
||||||
|
@ -30,7 +30,7 @@ RSpec.describe Settings::ImportsController, type: :controller do
|
||||||
|
|
||||||
it 'redirects to settings path with successful blocking import' do
|
it 'redirects to settings path with successful blocking import' do
|
||||||
service = double(call: nil)
|
service = double(call: nil)
|
||||||
allow(FollowRemoteAccountService).to receive(:new).and_return(service)
|
allow(ResolveRemoteAccountService).to receive(:new).and_return(service)
|
||||||
post :create, params: {
|
post :create, params: {
|
||||||
import: {
|
import: {
|
||||||
type: 'blocking',
|
type: 'blocking',
|
||||||
|
|
|
@ -123,7 +123,7 @@ describe AccountSearchService do
|
||||||
describe 'when there is a domain but no exact match' do
|
describe 'when there is a domain but no exact match' do
|
||||||
it 'follows the remote account when resolve is true' do
|
it 'follows the remote account when resolve is true' do
|
||||||
service = double(call: nil)
|
service = double(call: nil)
|
||||||
allow(FollowRemoteAccountService).to receive(:new).and_return(service)
|
allow(ResolveRemoteAccountService).to receive(:new).and_return(service)
|
||||||
|
|
||||||
results = subject.call('newuser@remote.com', 10, true)
|
results = subject.call('newuser@remote.com', 10, true)
|
||||||
expect(service).to have_received(:call).with('newuser@remote.com')
|
expect(service).to have_received(:call).with('newuser@remote.com')
|
||||||
|
@ -131,7 +131,7 @@ describe AccountSearchService do
|
||||||
|
|
||||||
it 'does not follow the remote account when resolve is false' do
|
it 'does not follow the remote account when resolve is false' do
|
||||||
service = double(call: nil)
|
service = double(call: nil)
|
||||||
allow(FollowRemoteAccountService).to receive(:new).and_return(service)
|
allow(ResolveRemoteAccountService).to receive(:new).and_return(service)
|
||||||
|
|
||||||
results = subject.call('newuser@remote.com', 10, false)
|
results = subject.call('newuser@remote.com', 10, false)
|
||||||
expect(service).not_to have_received(:call)
|
expect(service).not_to have_received(:call)
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
require 'rails_helper'
|
require 'rails_helper'
|
||||||
|
|
||||||
RSpec.describe FollowRemoteAccountService do
|
RSpec.describe ResolveRemoteAccountService do
|
||||||
subject { FollowRemoteAccountService.new }
|
subject { ResolveRemoteAccountService.new }
|
||||||
|
|
||||||
before do
|
before do
|
||||||
stub_request(:get, "https://quitter.no/.well-known/host-meta").to_return(request_fixture('.host-meta.txt'))
|
stub_request(:get, "https://quitter.no/.well-known/host-meta").to_return(request_fixture('.host-meta.txt'))
|
Loading…
Reference in New Issue