Refactors PostCreator.

lib/post_creator.rb

@@ -70,19 +70,10 @@ class PostCreator
       @post.save_reply_relationships
     end
 
-    if @spam
-      GroupMessage.create( Group[:moderators].name,
-                           :spam_post_blocked,
-                           { user: @user,
-                             limit_once_per: 24.hours,
-                             message_params: {domains: @post.linked_hosts.keys.join(', ')} } )
-    elsif @post && !@post.errors.present? && !@opts[:skip_validations]
-      SpamRulesEnforcer.enforce!(@post)
-    end
-
+    handle_spam
     track_latest_on_category
-
     enqueue_jobs
+
     @post
   end
 
@@ -92,9 +83,7 @@ class PostCreator
   end
 
   def self.before_create_tasks(post)
-    if post.reply_to_post_number.present?
-      post.reply_to_user_id ||= Post.select(:user_id).where(topic_id: post.topic_id, post_number: post.reply_to_post_number).first.try(:user_id)
-    end
+    set_reply_user_id(post)
 
     post.word_count = post.raw.scan(/\w+/).size
     post.post_number ||= Topic.next_post_number(post.topic_id, post.reply_to_post_number.present?)
@@ -108,16 +97,31 @@ class PostCreator
     post.last_version_at ||= Time.now
   end
 
+  def self.set_reply_user_id(post)
+    return unless post.reply_to_post_number.present?
+
+    post.reply_to_user_id ||= Post.select(:user_id).where(topic_id: post.topic_id, post_number: post.reply_to_post_number).first.try(:user_id)
+  end
 
   protected
 
+  def handle_spam
+    if @spam
+      GroupMessage.create( Group[:moderators].name,
+                           :spam_post_blocked,
+                           { user: @user,
+                             limit_once_per: 24.hours,
+                             message_params: {domains: @post.linked_hosts.keys.join(', ')} } )
+    elsif @post && !@post.errors.present? && !@opts[:skip_validations]
+      SpamRulesEnforcer.enforce!(@post)
+    end
+  end
+
   def track_latest_on_category
-    if @post && @post.errors.count == 0 && @topic && @topic.category_id
+    return unless @post && @post.errors.count == 0 && @topic && @topic.category_id
+
     Category.where(id: @topic.category_id).update_all(latest_post_id: @post.id)
-      if @post.post_number == 1
-        Category.where(id: @topic.category_id).update_all(latest_topic_id: @topic.id)
-      end
-    end
+    Category.where(id: @topic.category_id).update_all(latest_topic_id: @topic.id) if @post.post_number == 1
   end
 
   def ensure_in_allowed_users
@@ -135,10 +139,12 @@ class PostCreator
   end
 
   def after_post_create
-    if !@topic.private_message? && @post.post_type != Post.types[:moderator_action]
+    return if @topic.private_message? || @post.post_type == Post.types[:moderator_action]
+
     if @post.post_number > 1
       TopicTrackingState.publish_unread(@post)
     end
+
     if SiteSetting.enable_mailing_list_mode
       Jobs.enqueue_in(
           SiteSetting.email_time_window_mins.minutes,
@@ -147,12 +153,11 @@ class PostCreator
       )
     end
   end
-  end
 
   def after_topic_create
+    return unless @new_topic
     # Don't publish invisible topics
     return unless @topic.visible?
-
     return if @topic.private_message? || @post.post_type == Post.types[:moderator_action]
 
     @topic.posters = @topic.posters_summary
@@ -218,13 +223,13 @@ class PostCreator
                             reply_to_post_number: @opts[:reply_to_post_number])
 
     # Attributes we pass through to the post instance if present
-    [:post_type, :no_bump, :cooking_options, :image_sizes, :acting_user, :invalidate_oneboxes].each do |a|
+    [:post_type, :no_bump, :cooking_options, :image_sizes, :acting_user, :invalidate_oneboxes, :cook_method].each do |a|
       post.send("#{a}=", @opts[a]) if @opts[a].present?
     end
 
-    post.cook_method = @opts[:cook_method] if @opts[:cook_method].present?
     post.extract_quoted_post_numbers
     post.created_at = Time.zone.parse(@opts[:created_at].to_s) if @opts[:created_at].present?
+
     @post = post
   end
 
@@ -249,10 +254,10 @@ class PostCreator
   end
 
   def consider_clearing_flags
-    if @topic.private_message? && @post.post_number > 1 && @topic.user_id != @post.user_id
+    return unless @topic.private_message? && @post.post_number > 1 && @topic.user_id != @post.user_id
+
     clear_possible_flags(@topic)
   end
-  end
 
   def update_user_counts
     # We don't count replies to your own topics
@@ -266,7 +271,8 @@ class PostCreator
   end
 
   def publish
-    if @post.post_number > 1
+    return unless @post.post_number > 1
+
     MessageBus.publish("/topic/#{@post.topic_id}",{
                     id: @post.id,
                     created_at: @post.created_at,
@@ -276,14 +282,14 @@ class PostCreator
                   group_ids: secure_group_ids(@topic)
     )
   end
-  end
 
   def extract_links
     TopicLink.extract_from(@post)
   end
 
   def track_topic
-    unless @opts[:auto_track] == false
+    return if @opts[:auto_track] == false
+
     TopicUser.auto_track(@user.id, @topic.id, TopicUser.notification_reasons[:created_post])
     # Update topic user data
     TopicUser.change(@post.user.id,
@@ -292,17 +298,16 @@ class PostCreator
                      last_read_post_number: @post.post_number,
                      seen_post_count: @post.post_number)
   end
-  end
 
   def enqueue_jobs
-    if @post && !@post.errors.present?
+    return unless @post && !@post.errors.present?
+
     # We need to enqueue jobs after the transaction. Otherwise they might begin before the data has
     # been comitted.
     topic_id = @opts[:topic_id] || @topic.try(:id)
     Jobs.enqueue(:feature_topic_users, topic_id: @topic.id) if topic_id.present?
     @post.trigger_post_process
     after_post_create
-      after_topic_create if @new_topic
-    end
+    after_topic_create
   end
 end