-
Notifications
You must be signed in to change notification settings - Fork 8.2k
/
process_post.rb
57 lines (45 loc) · 1.81 KB
/
process_post.rb
1
2
3
4
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
require 'image_sizer'
require_dependency 'cooked_post_processor'
module Jobs
class ProcessPost < Jobs::Base
def execute(args)
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?
cooking_options = args[:cooking_options] || {}
cooking_options[:topic_id] = post.topic_id
recooked = post.cook(post.raw, cooking_options.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(bypass_bump: args[:bypass_bump], 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 suicide 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!(cooked: cp.html)
extract_links(post)
post.publish_change_to_clients! :revised
end
end
if !post.user&.staff? && !post.user&.staged?
s = post.cooked
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)
end
end
end
# onebox may have added some links, so extract them now
def extract_links(post)
TopicLink.extract_from(post)
QuotedPost.extract_from(post)
end
end
end