service_objects_bp_3.rb

class CommentsController
  def create
    comment = Comment.new(params[:comment])
    @comment = CommentCreator.new(comment).create!
    respond_with @comment
  end
end

class CommentCreator
  def initialize(comment)
    @comment = comment
    @comment_thread = comment.comment_thread
  end

  def create!
    @comment.save!
    CommentCreatedWorker.perform_async(@comment.id)
    @comment
  end

  def perform
    comment_thread.participants.each do |participant|
      CommentThreadMailer.activity_notification(comment_thread, comment, participant)
    end

    if comment.previous_comment?
      in_reply_to_user = comment.previous_comment.author
      ReplyMailer.notification(in_reply_to_user, comment).deliver
    end

    Kissmetrics.record(comment.author, 'Added Comment')
  end
end

class CommentCreatedWorker
  include Sidekiq::Worker

  def perform(comment_id)
    comment = Comment.find(comment_id)
    CommentCreator.new(comment).perform
  end
end