discourse/lib/post_jobs_enqueuer.rb

65 lines
1.6 KiB
Ruby
Raw Normal View History

2014-02-17 01:57:37 -05:00
class PostJobsEnqueuer
2017-07-27 21:20:09 -04:00
def initialize(post, topic, new_topic, opts = {})
2014-02-17 01:57:37 -05:00
@post = post
@topic = topic
@new_topic = new_topic
@opts = opts
2014-02-17 01:57:37 -05:00
end
def enqueue_jobs
# We need to enqueue jobs after the transaction.
# Otherwise they might begin before the data has been comitted.
2015-04-20 13:34:57 -04:00
enqueue_post_alerts unless @opts[:import_mode]
feature_topic_users unless @opts[:import_mode]
2014-02-17 01:57:37 -05:00
trigger_post_post_process
2015-04-20 13:34:57 -04:00
2014-02-17 01:57:37 -05:00
unless skip_after_create?
after_post_create
after_topic_create
end
end
private
2015-04-20 13:34:57 -04:00
def enqueue_post_alerts
Jobs.enqueue(:post_alert, post_id: @post.id, options: @opts[:post_alert_options])
2015-04-20 13:34:57 -04:00
end
2014-02-17 01:57:37 -05:00
def feature_topic_users
Jobs.enqueue(:feature_topic_users, topic_id: @topic.id)
end
def trigger_post_post_process
@post.trigger_post_process
end
def after_post_create
TopicTrackingState.publish_unread(@post) if @post.post_number > 1
TopicTrackingState.publish_latest(@topic, @post.post_type == Post.types[:whisper])
2014-02-17 01:57:37 -05:00
Jobs.enqueue_in(
SiteSetting.email_time_window_mins.minutes,
:notify_mailing_list_subscribers,
post_id: @post.id
)
2014-02-17 01:57:37 -05:00
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]
2014-02-17 01:57:37 -05:00
end
end