Class: Jobs::ProcessPost
Instance Method Summary collapse
- #enqueue_pull_hotlinked_images(post) ⇒ Object
- #execute(args) ⇒ Object
-
#extract_links(post) ⇒ Object
onebox may have added some links, so extract them now.
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
#enqueue_pull_hotlinked_images(post) ⇒ Object
70 71 72 73 |
# File 'app/jobs/regular/process_post.rb', line 70 def enqueue_pull_hotlinked_images(post) Jobs.cancel_scheduled_job(:pull_hotlinked_images, post_id: post.id) Jobs.enqueue(:pull_hotlinked_images, post_id: post.id) end |
#execute(args) ⇒ Object
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 |
# File 'app/jobs/regular/process_post.rb', line 7 def execute(args) DistributedMutex.synchronize("process_post_#{args[:post_id]}", validity: 10.minutes) do post = Post.find_by(id: args[:post_id]) # two levels of deletion return unless post.present? && post.topic.present? orig_cooked = post.cooked recooked = nil if args[:cook].present? = args[:cooking_options] || {} [:topic_id] = post.topic_id recooked = post.cook(post.raw, .symbolize_keys) post.update_columns( cooked: recooked, baked_at: Time.zone.now, baked_version: Post::BAKED_VERSION, ) end cp = CookedPostProcessor.new(post, args) cp.post_process(new_post: args[:new_post]) # If we changed the document, save it cooked = cp.html if cooked != (recooked || orig_cooked) if orig_cooked.present? && cooked.blank? # TODO stop/restart the worker if needed, let's gather a few here first Rails.logger.warn( "Cooked post processor in FATAL state, bypassing. You need to urgently restart sidekiq\norig: #{orig_cooked}\nrecooked: #{recooked}\ncooked: #{cooked}\npost id: #{post.id}", ) else post.update_column(:cooked, cp.html) post.topic.update_excerpt(post.excerpt_for_topic) if post.is_first_post? extract_links(post) post.publish_change_to_clients! :revised end end enqueue_pull_hotlinked_images(post) unless args[:skip_pull_hotlinked_images] if !post.user&.staff? && !post.user&.staged? s = post.raw s << " #{post.topic.title}" if post.post_number == 1 if !args[:bypass_bump] && WordWatcher.new(s).should_flag? PostActionCreator.create( Discourse.system_user, post, :inappropriate, reason: :watched_word, ) end end end end |
#extract_links(post) ⇒ Object
onebox may have added some links, so extract them now
65 66 67 68 |
# File 'app/jobs/regular/process_post.rb', line 65 def extract_links(post) TopicLink.extract_from(post) QuotedPost.extract_from(post) end |