gitea/nas
1
0
Fork 2
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

他サーバーからきた投稿の参照を同期的に取得

Browse source
This commit is contained in:
KMY 2023-10-02 13:15:14 +09:00
parent 72f3f95221
commit c4568be616
3 changed files with 10 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
app/lib/activitypub/activity/create.rb
View file

@ -486,7 +486,7 @@ class ActivityPub::Activity::Create < ActivityPub::Activity
def process_references! def process_references!
references = @object['references'].nil? ? [] : ActivityPub::FetchReferencesService.new.call(@status, @object['references']) references = @object['references'].nil? ? [] : ActivityPub::FetchReferencesService.new.call(@status, @object['references'])
ProcessReferencesService.perform_worker_async(@status, [], references, [quote].compact) ProcessReferencesService.call_service_without_error(@status, [], references, [quote].compact)
end end
def quote_local? def quote_local?

2
app/services/activitypub/process_status_update_service.rb
View file

@ -255,7 +255,7 @@ class ActivityPub::ProcessStatusUpdateService < BaseService
references = @json['references'].nil? ? [] : ActivityPub::FetchReferencesService.new.call(@status, @json['references']) references = @json['references'].nil? ? [] : ActivityPub::FetchReferencesService.new.call(@status, @json['references'])
quote = @json['quote'] || @json['quoteUrl'] || @json['quoteURL'] || @json['_misskey_quote'] quote = @json['quote'] || @json['quoteUrl'] || @json['quoteURL'] || @json['_misskey_quote']
ProcessReferencesService.perform_worker_async(@status, [], references, [quote].compact) ProcessReferencesService.call_service_without_error(@status, [], references, [quote].compact)
end end
def expected_type? def expected_type?

8
app/services/process_references_service.rb
View file

@ -58,6 +58,14 @@ class ProcessReferencesService < BaseService
ProcessReferencesService.new.call(status, reference_parameters || [], urls: urls || [], fetch_remote: false, quote_urls: quote_urls) ProcessReferencesService.new.call(status, reference_parameters || [], urls: urls || [], fetch_remote: false, quote_urls: quote_urls)
end end
def self.call_service_without_error(status, reference_parameters, urls, quote_urls = [])
begin
call_service(status, reference_parameters, urls, quote_urls)
rescue
true
end
end
private private
def references def references