mirror of
https://github.com/discourse/discourse.git
synced 2024-11-23 02:19:27 +08:00
b1f32f2f57
* DEV: TopicTrackingState calls should happen in the background It was observed that calling TopicTrackingState on popular topics could result in a large number of calls to redis, resulting in slow response times when posting replies. These calls should be moved to a background job. * DEV: PostUpdateTopicTrackingState should execute on default queue
86 lines
2.1 KiB
Ruby
86 lines
2.1 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class PostJobsEnqueuer
|
|
def initialize(post, topic, new_topic, opts = {})
|
|
@post = post
|
|
@topic = topic
|
|
@new_topic = new_topic
|
|
@opts = opts
|
|
end
|
|
|
|
def enqueue_jobs
|
|
# We need to enqueue jobs after the transaction.
|
|
# Otherwise they might begin before the data has been comitted.
|
|
enqueue_post_alerts unless @opts[:import_mode]
|
|
feature_topic_users unless @opts[:import_mode]
|
|
trigger_post_post_process
|
|
|
|
unless skip_after_create?
|
|
after_post_create
|
|
after_topic_create
|
|
make_visible
|
|
end
|
|
|
|
if @topic.private_message?
|
|
TopicTrackingState.publish_private_message(@topic, post: @post)
|
|
TopicGroup.new_message_update(@topic.last_poster, @topic.id, @post.post_number)
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def enqueue_post_alerts
|
|
Jobs.enqueue(:post_alert,
|
|
post_id: @post.id,
|
|
new_record: true,
|
|
options: @opts[:post_alert_options],
|
|
)
|
|
end
|
|
|
|
def feature_topic_users
|
|
Jobs.enqueue(:feature_topic_users, topic_id: @topic.id)
|
|
end
|
|
|
|
def trigger_post_post_process
|
|
@post.trigger_post_process(new_post: true)
|
|
end
|
|
|
|
def make_visible
|
|
return unless SiteSetting.embed_unlisted?
|
|
return unless @post.post_number > 1
|
|
return if @topic.visible?
|
|
return if @post.post_type != Post.types[:regular]
|
|
|
|
if @topic.topic_embed.present?
|
|
Jobs.enqueue(:make_embedded_topic_visible, topic_id: @topic.id)
|
|
end
|
|
end
|
|
|
|
def after_post_create
|
|
Jobs.enqueue(:post_update_topic_tracking_state, post_id: @post.id)
|
|
|
|
Jobs.enqueue_in(SiteSetting.email_time_window_mins.minutes,
|
|
:notify_mailing_list_subscribers,
|
|
post_id: @post.id,
|
|
)
|
|
end
|
|
|
|
def after_topic_create
|
|
return unless @new_topic
|
|
# Don't publish invisible topics
|
|
return unless @topic.visible?
|
|
|
|
@topic.posters = @topic.posters_summary
|
|
@topic.posts_count = 1
|
|
|
|
TopicTrackingState.publish_new(@topic)
|
|
end
|
|
|
|
def skip_after_create?
|
|
@opts[:import_mode] ||
|
|
@topic.private_message? ||
|
|
@post.post_type == Post.types[:moderator_action] ||
|
|
@post.post_type == Post.types[:small_action]
|
|
end
|
|
end
|