mirror of
https://github.com/mastodon/mastodon
synced 2024-12-11 21:28:23 +09:00
ad5ddd5e95
These are currently user facing errors, but are not localized. This adds the ability for these messages to be localized.
62 lines
2.1 KiB
Ruby
62 lines
2.1 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 [String] :visibility
|
|
# @option [String] :spoiler_text
|
|
# @option [Enumerable] :media_ids Optional array of media IDs to attach
|
|
# @option [Doorkeeper::Application] :application
|
|
# @return [Status]
|
|
def call(account, text, in_reply_to = nil, options = {})
|
|
media = validate_media!(options[:media_ids])
|
|
status = account.statuses.create!(text: text,
|
|
thread: in_reply_to,
|
|
sensitive: options[:sensitive],
|
|
spoiler_text: options[:spoiler_text] || '',
|
|
visibility: options[:visibility],
|
|
application: options[:application])
|
|
|
|
attach_media(status, media)
|
|
process_mentions_service.call(status)
|
|
process_hashtags_service.call(status)
|
|
|
|
LinkCrawlWorker.perform_async(status.id)
|
|
DistributionWorker.perform_async(status.id)
|
|
Pubsubhubbub::DistributionWorker.perform_async(status.stream_entry.id)
|
|
|
|
status
|
|
end
|
|
|
|
private
|
|
|
|
def validate_media!(media_ids)
|
|
return if media_ids.nil? || !media_ids.is_a?(Enumerable)
|
|
|
|
raise Mastodon::ValidationError, I18n.t('media_attachments.validations.too_many') if media_ids.size > 4
|
|
|
|
media = MediaAttachment.where(status_id: nil).where(id: media_ids.take(4).map(&:to_i))
|
|
|
|
raise Mastodon::ValidationError, I18n.t('media_attachments.validations.images_and_video') if media.size > 1 && media.find(&:video?)
|
|
|
|
media
|
|
end
|
|
|
|
def attach_media(status, media)
|
|
return if media.nil?
|
|
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
|