discourse/app/jobs/regular/process_post.rb

50 lines
1.4 KiB
Ruby
Raw Normal View History

2013-02-05 14:16:51 -05:00
require 'image_sizer'
require_dependency 'cooked_post_processor'
module Jobs
class ProcessPost < Jobs::Base
2013-02-25 11:42:20 -05:00
def execute(args)
post = Post.find_by(id: args[:post_id])
2013-04-17 21:34:40 -04:00
# two levels of deletion
return unless post.present? && post.topic.present?
2013-02-05 14:16:51 -05:00
2014-12-07 00:39:15 -05:00
orig_cooked = post.cooked
recooked = nil
if args[:cook].present?
cooking_options = args[:cooking_options] || {}
cooking_options[:topic_id] = post.topic_id
recooked = post.cook(post.raw, cooking_options.symbolize_keys)
2014-12-07 00:39:15 -05:00
post.update_column(:cooked, recooked)
end
2013-02-05 14:16:51 -05:00
cp = CookedPostProcessor.new(post, args)
2013-11-21 19:52:26 -05:00
cp.post_process(args[:bypass_bump])
2013-02-05 14:16:51 -05:00
# If we changed the document, save it
2014-12-07 00:39:15 -05:00
cooked = cp.html
if cooked != (recooked || orig_cooked)
if orig_cooked.present? && cooked.blank?
# TODO suicide if needed, let's gather a few here first
2014-12-07 00:43:26 -05:00
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}")
2014-12-07 00:39:15 -05:00
else
post.update_column(:cooked, cp.html)
extract_links(post)
2014-12-07 00:39:15 -05:00
post.publish_change_to_clients! :revised
end
end
2013-02-05 14:16:51 -05:00
end
# onebox may have added some links, so extract them now
def extract_links(post)
TopicLink.extract_from(post)
QuotedPost.extract_from(post)
end
2013-02-05 14:16:51 -05:00
end
end