class StatusMessageCreationService
  include Rails.application.routes.url_helpers

  def initialize(user)
    @user = user
  end

  def create(params)
    build_status_message(params).tap do |status_message|
      add_attachments(status_message, params)
      status_message.save
      process(status_message, params[:aspect_ids], params[:services])
    end
  end

  private

  attr_reader :user

  def build_status_message(params)
    public = params[:public] || false
    filter_mentions params
    user.build_post(:status_message, params[:status_message].merge(public: public))
  end

  def filter_mentions(params)
    unless params[:public]
      params[:status_message][:text] = Diaspora::Mentionable.filter_for_aspects(
        params[:status_message][:text],
        user,
        *params[:aspect_ids]
      )
    end
  end

  def add_attachments(status_message, params)
    add_location(status_message, params[:location_address], params[:location_coords])
    add_poll(status_message, params)
    add_photos(status_message, params[:photos])
  end

  def add_location(status_message, address, coordinates)
    status_message.build_location(address: address, coordinates: coordinates) if address.present?
  end

  def add_poll(status_message, params)
    if params[:poll_question].present?
      status_message.build_poll(question: params[:poll_question])
      [*params[:poll_answers]].each do |poll_answer|
        status_message.poll.poll_answers.build(answer: poll_answer)
      end
    end
  end

  def add_photos(status_message, photos)
    if photos.present?
      status_message.photos << Photo.where(id: photos, author_id: status_message.author_id)
      status_message.photos.each do |photo|
        photo.public = status_message.public
        photo.pending = false
      end
    end
  end

  def process(status_message, aspect_ids, services)
    add_to_streams(status_message, aspect_ids) unless status_message.public
    dispatch(status_message, services)
  end

  def add_to_streams(status_message, aspect_ids)
    aspects = user.aspects_from_ids(aspect_ids)
    user.add_to_streams(status_message, aspects)
    status_message.photos.each {|photo| user.add_to_streams(photo, aspects) }
  end

  def dispatch(status_message, services)
    receiving_services = services ? Service.titles(services) : []
    user.dispatch_post(status_message,
                       url:           short_post_url(status_message.guid, host: AppConfig.environment.url),
                       service_types: receiving_services)
  end
end