discourse/app/models/topic_converter.rb

class TopicConverter

  attr_reader :topic

  def initialize(topic, user)
    @topic = topic
    @user = user
  end

  def convert_to_public_topic(category_id = nil)
    Topic.transaction do
      @topic.category_id =
        if category_id
          category_id
        elsif SiteSetting.allow_uncategorized_topics
          SiteSetting.uncategorized_category_id
        else
          Category.where(read_restricted: false)
            .where.not(id: SiteSetting.uncategorized_category_id)
            .order('id asc')
            .pluck(:id).first
        end

      @topic.archetype = Archetype.default
      @topic.save
      update_user_stats
      update_category_topic_count_by(1)
      Jobs.enqueue(:topic_action_converter, topic_id: @topic.id)

      watch_topic(topic)
    end
    @topic
  end

  def convert_to_private_message
    Topic.transaction do
      update_category_topic_count_by(-1)
      @topic.category_id = nil
      @topic.archetype = Archetype.private_message
      add_allowed_users
      @topic.save!
      Jobs.enqueue(:topic_action_converter, topic_id: @topic.id)
      watch_topic(topic)
    end
    @topic
  end

  private

  def update_user_stats
    @topic.posts.where(deleted_at: nil).each do |p|
      user = User.find(p.user_id)
      # update posts count. NOTE that DirectoryItem.refresh will overwrite this by counting UserAction records.
      user.user_stat.post_count += 1
      user.user_stat.save!
    end
    # update topics count
    @topic.user.user_stat.topic_count += 1
    @topic.user.user_stat.save!
  end

  def add_allowed_users
    @topic.posts.where(deleted_at: nil).each do |p|
      user = User.find(p.user_id)
      @topic.topic_allowed_users.build(user_id: user.id) unless @topic.topic_allowed_users.where(user_id: user.id).exists?
      # update posts count. NOTE that DirectoryItem.refresh will overwrite this by counting UserAction records.
      user.user_stat.post_count -= 1
      user.user_stat.save!
    end
    @topic.topic_allowed_users.build(user_id: @user.id) unless @topic.topic_allowed_users.where(user_id: @user.id).exists?
    # update topics count
    @topic.user.user_stat.topic_count -= 1
    @topic.user.user_stat.save!
  end

  def watch_topic(topic)
    @topic.notifier.watch_topic!(topic.user_id)

    @topic.reload.topic_allowed_users.each do |tau|
      next if tau.user_id < 0 || tau.user_id == topic.user_id
      topic.notifier.watch!(tau.user_id)
    end
  end

  def update_category_topic_count_by(num)
    if @topic.category_id.present?
      Category.where(['id = ?', @topic.category_id]).update_all("topic_count = topic_count " + (num > 0 ? '+' : '') + "#{num}")
    end
  end

end