create.rb 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215
  1. # frozen_string_literal: true
  2. class ActivityPub::Activity::Create < ActivityPub::Activity
  3. def perform
  4. return if delete_arrived_first?(object_uri) || unsupported_object_type?
  5. RedisLock.acquire(lock_options) do |lock|
  6. if lock.acquired?
  7. @status = find_existing_status
  8. process_status if @status.nil?
  9. end
  10. end
  11. @status
  12. end
  13. private
  14. def process_status
  15. ApplicationRecord.transaction do
  16. @status = Status.create!(status_params)
  17. process_tags(@status)
  18. process_attachments(@status)
  19. end
  20. resolve_thread(@status)
  21. distribute(@status)
  22. forward_for_reply if @status.public_visibility? || @status.unlisted_visibility?
  23. end
  24. def find_existing_status
  25. status = status_from_uri(object_uri)
  26. status ||= Status.find_by(uri: @object['atomUri']) if @object['atomUri'].present?
  27. status
  28. end
  29. def status_params
  30. {
  31. uri: @object['id'],
  32. url: object_url || @object['id'],
  33. account: @account,
  34. text: text_from_content || '',
  35. language: language_from_content,
  36. spoiler_text: @object['summary'] || '',
  37. created_at: @object['published'] || Time.now.utc,
  38. reply: @object['inReplyTo'].present?,
  39. sensitive: @object['sensitive'] || false,
  40. visibility: visibility_from_audience,
  41. thread: replied_to_status,
  42. conversation: conversation_from_uri(@object['conversation']),
  43. }
  44. end
  45. def process_tags(status)
  46. return unless @object['tag'].is_a?(Array)
  47. @object['tag'].each do |tag|
  48. case tag['type']
  49. when 'Hashtag'
  50. process_hashtag tag, status
  51. when 'Mention'
  52. process_mention tag, status
  53. when 'Emoji'
  54. process_emoji tag, status
  55. end
  56. end
  57. end
  58. def process_hashtag(tag, status)
  59. return if tag['name'].blank?
  60. hashtag = tag['name'].gsub(/\A#/, '').mb_chars.downcase
  61. hashtag = Tag.where(name: hashtag).first_or_initialize(name: hashtag)
  62. status.tags << hashtag
  63. end
  64. def process_mention(tag, status)
  65. return if tag['href'].blank?
  66. account = account_from_uri(tag['href'])
  67. account = FetchRemoteAccountService.new.call(tag['href'], id: false) if account.nil?
  68. return if account.nil?
  69. account.mentions.create(status: status)
  70. end
  71. def process_emoji(tag, _status)
  72. return if tag['name'].blank? || tag['href'].blank?
  73. shortcode = tag['name'].delete(':')
  74. emoji = CustomEmoji.find_by(shortcode: shortcode, domain: @account.domain)
  75. return if !emoji.nil? || skip_download?
  76. emoji = CustomEmoji.new(domain: @account.domain, shortcode: shortcode)
  77. emoji.image_remote_url = tag['href']
  78. emoji.save
  79. end
  80. def process_attachments(status)
  81. return unless @object['attachment'].is_a?(Array)
  82. @object['attachment'].each do |attachment|
  83. next if unsupported_media_type?(attachment['mediaType']) || attachment['url'].blank?
  84. href = Addressable::URI.parse(attachment['url']).normalize.to_s
  85. media_attachment = MediaAttachment.create(status: status, account: status.account, remote_url: href, description: attachment['name'].presence)
  86. next if skip_download?
  87. media_attachment.file_remote_url = href
  88. media_attachment.save
  89. end
  90. rescue Addressable::URI::InvalidURIError => e
  91. Rails.logger.debug e
  92. end
  93. def resolve_thread(status)
  94. return unless status.reply? && status.thread.nil?
  95. ThreadResolveWorker.perform_async(status.id, in_reply_to_uri)
  96. end
  97. def conversation_from_uri(uri)
  98. return nil if uri.nil?
  99. return Conversation.find_by(id: OStatus::TagManager.instance.unique_tag_to_local_id(uri, 'Conversation')) if OStatus::TagManager.instance.local_id?(uri)
  100. Conversation.find_by(uri: uri) || Conversation.create(uri: uri)
  101. end
  102. def visibility_from_audience
  103. if equals_or_includes?(@object['to'], ActivityPub::TagManager::COLLECTIONS[:public])
  104. :public
  105. elsif equals_or_includes?(@object['cc'], ActivityPub::TagManager::COLLECTIONS[:public])
  106. :unlisted
  107. elsif equals_or_includes?(@object['to'], @account.followers_url)
  108. :private
  109. else
  110. :direct
  111. end
  112. end
  113. def audience_includes?(account)
  114. uri = ActivityPub::TagManager.instance.uri_for(account)
  115. equals_or_includes?(@object['to'], uri) || equals_or_includes?(@object['cc'], uri)
  116. end
  117. def replied_to_status
  118. return @replied_to_status if defined?(@replied_to_status)
  119. if in_reply_to_uri.blank?
  120. @replied_to_status = nil
  121. else
  122. @replied_to_status = status_from_uri(in_reply_to_uri)
  123. @replied_to_status ||= status_from_uri(@object['inReplyToAtomUri']) if @object['inReplyToAtomUri'].present?
  124. @replied_to_status
  125. end
  126. end
  127. def in_reply_to_uri
  128. value_or_id(@object['inReplyTo'])
  129. end
  130. def text_from_content
  131. if @object['content'].present?
  132. @object['content']
  133. elsif language_map?
  134. @object['contentMap'].values.first
  135. end
  136. end
  137. def language_from_content
  138. return nil unless language_map?
  139. @object['contentMap'].keys.first
  140. end
  141. def object_url
  142. return if @object['url'].blank?
  143. value = first_of_value(@object['url'])
  144. return value if value.is_a?(String)
  145. value['href']
  146. end
  147. def language_map?
  148. @object['contentMap'].is_a?(Hash) && !@object['contentMap'].empty?
  149. end
  150. def unsupported_object_type?
  151. @object.is_a?(String) || !%w(Article Note).include?(@object['type'])
  152. end
  153. def unsupported_media_type?(mime_type)
  154. mime_type.present? && !(MediaAttachment::IMAGE_MIME_TYPES + MediaAttachment::VIDEO_MIME_TYPES).include?(mime_type)
  155. end
  156. def skip_download?
  157. return @skip_download if defined?(@skip_download)
  158. @skip_download ||= DomainBlock.find_by(domain: @account.domain)&.reject_media?
  159. end
  160. def reply_to_local?
  161. !replied_to_status.nil? && replied_to_status.account.local?
  162. end
  163. def forward_for_reply
  164. return unless @json['signature'].present? && reply_to_local?
  165. ActivityPub::RawDistributionWorker.perform_async(Oj.dump(@json), replied_to_status.account_id)
  166. end
  167. def lock_options
  168. { redis: Redis.current, key: "create:#{@object['id']}" }
  169. end
  170. end