80e02b90e4
Filters out hidden stream entries from Atom feed Blocks now generate hidden stream entries, can be used to federate blocks Private statuses cannot be reblogged (generates generic 422 error for now) POST /api/v1/statuses now takes visibility=(public|unlisted|private) param instead of unlisted boolean Statuses JSON now contains visibility=(public|unlisted|private) field
40 lines
1.3 KiB
Ruby
40 lines
1.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class PostStatusService < BaseService
|
|
# Post a text status update, fetch and notify remote users mentioned
|
|
# @param [Account] account Account from which to post
|
|
# @param [String] text Message
|
|
# @param [Status] in_reply_to Optional status to reply to
|
|
# @param [Hash] options
|
|
# @option [Boolean] :sensitive
|
|
# @option [Enumerable] :media_ids Optional array of media IDs to attach
|
|
# @return [Status]
|
|
def call(account, text, in_reply_to = nil, options = {})
|
|
status = account.statuses.create!(text: text, thread: in_reply_to, sensitive: options[:sensitive], visibility: options[:visibility])
|
|
attach_media(status, options[:media_ids])
|
|
process_mentions_service.call(status)
|
|
process_hashtags_service.call(status)
|
|
|
|
DistributionWorker.perform_async(status.id)
|
|
Pubsubhubbub::DistributionWorker.perform_async(status.stream_entry.id)
|
|
|
|
status
|
|
end
|
|
|
|
private
|
|
|
|
def attach_media(status, media_ids)
|
|
return if media_ids.nil? || !media_ids.is_a?(Enumerable)
|
|
|
|
media = MediaAttachment.where(status_id: nil).where(id: media_ids.take(4).map(&:to_i))
|
|
media.update(status_id: status.id)
|
|
end
|
|
|
|
def process_mentions_service
|
|
@process_mentions_service ||= ProcessMentionsService.new
|
|
end
|
|
|
|
def process_hashtags_service
|
|
@process_hashtags_service ||= ProcessHashtagsService.new
|
|
end
|
|
end
|