Retrospring/lib/use_case/question/create_followers.rb

# frozen_string_literal: true

module UseCase
  module Question
    class CreateFollowers < UseCase::Base
      option :source_user_id, type: Types::Coercible::Integer
      option :content, type: Types::Coercible::String
      option :author_identifier, type: Types::Coercible::String | Types::Nil
      option :send_to_own_inbox, type: Types::Params::Bool, default: proc { false }

      def call
        question = ::Question.create!(
          content:,
          author_is_anonymous: false,
          author_identifier:,
          user:                source_user,
          direct:              false,
        )

        increment_asked_count
        increment_metric

        args = source_user.followers.map { |f| [f.id, question.id] }
        SendToInboxJob.perform_async(source_user_id, question.id) if send_to_own_inbox
        SendToInboxJob.perform_bulk(args)

        {
          status:   201,
          resource: question,
        }
      end

      private

      def increment_asked_count
        source_user.increment(:asked_count)
        source_user.save
      end

      def increment_metric
        Retrospring::Metrics::QUESTIONS_ASKED.increment(
          labels: {
            anonymous: false,
            followers: true,
            generated: false,
          },
        )
      end

      def source_user
        @source_user ||= ::User.includes(:followers).find(source_user_id)
      end
    end
  end
end