Class: Jobs::CreateLinkedTopic

Inherits:
Base
  • Object
show all
Defined in:
app/jobs/regular/create_linked_topic.rb

Instance Method Summary collapse

Methods inherited from Base

acquire_cluster_concurrency_lock!, clear_cluster_concurrency_lock!, cluster_concurrency, cluster_concurrency_redis_key, delayed_perform, #error_context, get_cluster_concurrency, #last_db_duration, #log, #perform, #perform_immediately

Instance Method Details

#execute(args) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
 
# File 'app/jobs/regular/create_linked_topic.rb', line 5

def execute(args)
  reference_post = Post.find_by(id: args[:post_id])
  return unless reference_post.present?
  parent_topic = reference_post.topic
  return unless parent_topic.present? && parent_topic.regular?
  parent_topic_id = parent_topic.id
  parent_category_id = parent_topic.category_id
  parent_title = parent_topic.title
  @post_creator = nil

  ActiveRecord::Base.transaction do
    linked_topic_record = parent_topic.linked_topic
    if linked_topic_record.present?
      raw_title =
        parent_title.delete_suffix(
          I18n.t(
            "create_linked_topic.topic_title_with_sequence",
            topic_title: "",
            count: linked_topic_record.sequence,
          ),
        )
      original_topic_id = linked_topic_record.original_topic_id
      sequence = linked_topic_record.sequence + 1
    else
      raw_title = parent_title

      # update parent topic title to append title_suffix_locale
      parent_title =
        I18n.t(
          "create_linked_topic.topic_title_with_sequence",
          topic_title: parent_title,
          count: 1,
        )
      parent_topic.title = parent_title
      parent_topic.save!

      # create linked topic record
      original_topic_id = parent_topic_id
      LinkedTopic.create!(
        topic_id: parent_topic_id,
        original_topic_id: original_topic_id,
        sequence: 1,
      )
      sequence = 2
    end

    # fetch previous topic titles
    previous_topics = ""
    linked_topic_ids = LinkedTopic.where(original_topic_id: original_topic_id).pluck(:topic_id)
    Topic
      .where(id: linked_topic_ids)
      .order(:id)
      .each { |topic| previous_topics += "- #{topic.url}\n" }

    # create new topic
    new_topic_title =
      I18n.t(
        "create_linked_topic.topic_title_with_sequence",
        topic_title: raw_title,
        count: sequence,
      )
    new_topic_raw =
      I18n.t(
        "create_linked_topic.post_raw",
        parent_url: reference_post.full_url,
        previous_topics: previous_topics,
      )
    system_user = Discourse.system_user
    @post_creator =
      PostCreator.new(
        system_user,
        title: new_topic_title,
        raw: new_topic_raw,
        category: parent_category_id,
        skip_validations: true,
        skip_jobs: true,
      )
    new_post = @post_creator.create
    new_topic = new_post.topic
    new_topic_id = new_topic.id

    # create linked_topic record
    LinkedTopic.create!(
      topic_id: new_topic_id,
      original_topic_id: original_topic_id,
      sequence: sequence,
    )

    # copy over topic tracking state from old topic
    params = { old_topic_id: parent_topic_id, new_topic_id: new_topic_id }
    DB.exec(<<~SQL, params)
      INSERT INTO topic_users(user_id, topic_id, notification_level,
                              notifications_reason_id)
      SELECT tu.user_id,
             :new_topic_id AS topic_id,
             tu.notification_level,
             tu.notifications_reason_id
      FROM topic_users tu
           JOIN topics t ON (t.id = :new_topic_id)
      WHERE tu.topic_id = :old_topic_id
        AND tu.notification_level != 1
      ON CONFLICT (topic_id, user_id) DO NOTHING
    SQL

    # update small action post on old topic to add new topic link
    small_action_post =
      Post.where(
        topic_id: parent_topic_id,
        post_type: Post.types[:small_action],
        action_code: "closed.enabled",
      ).last
    if small_action_post.present?
      small_action_post.raw =
        "#{small_action_post.raw} #{I18n.t("create_linked_topic.small_action_post_raw", new_title: "[#{new_topic_title}](#{new_topic.url})")}"
      small_action_post.save!
    end
  end
  @post_creator.enqueue_jobs if @post_creator
end