discourse/app/models/web_hook.rb

117 lines
3.4 KiB
Ruby
Raw Normal View History

2016-06-15 13:49:57 -04:00
class WebHook < ActiveRecord::Base
has_and_belongs_to_many :web_hook_event_types
has_and_belongs_to_many :groups
has_and_belongs_to_many :categories
has_many :web_hook_events, dependent: :destroy
default_scope { order('id ASC') }
validates :payload_url, presence: true, format: URI::regexp(%w(http https))
validates :secret, length: { minimum: 12 }, allow_blank: true
validates_presence_of :content_type
validates_presence_of :last_delivery_status
validates_presence_of :web_hook_event_types, unless: :wildcard_web_hook?
2017-12-11 03:15:50 -05:00
before_save :strip_url
2016-06-15 13:49:57 -04:00
def self.content_types
@content_types ||= Enum.new('application/json' => 1,
'application/x-www-form-urlencoded' => 2)
end
def self.last_delivery_statuses
@last_delivery_statuses ||= Enum.new(inactive: 1,
failed: 2,
successful: 3)
end
def self.default_event_types
[WebHookEventType.find(WebHookEventType::POST)]
end
def strip_url
self.payload_url = (payload_url || "").strip.presence
end
def self.active_web_hooks(type)
2016-06-15 13:49:57 -04:00
WebHook.where(active: true)
2017-07-27 21:20:09 -04:00
.joins(:web_hook_event_types)
.where("web_hooks.wildcard_web_hook = ? OR web_hook_event_types.name = ?", true, type.to_s)
.distinct
2016-06-15 13:49:57 -04:00
end
def self.enqueue_hooks(type, opts = {})
active_web_hooks(type).each do |web_hook|
Jobs.enqueue(:emit_web_hook_event, opts.merge(
web_hook_id: web_hook.id, event_type: type.to_s
))
2016-06-15 13:49:57 -04:00
end
end
def self.enqueue_object_hooks(type, object, event, serializer = nil)
if active_web_hooks(type).exists?
serializer ||= "WebHook#{type.capitalize}Serializer".constantize
WebHook.enqueue_hooks(type,
event_name: event.to_s,
payload: serializer.new(object,
scope: self.guardian,
root: false
).to_json
)
end
2016-06-15 13:49:57 -04:00
end
def self.enqueue_topic_hooks(event, topic)
if active_web_hooks('topic').exists?
topic_view = TopicView.new(topic.id, Discourse.system_user)
WebHook.enqueue_hooks(:topic,
category_id: topic&.category_id,
event_name: event.to_s,
payload: WebHookTopicViewSerializer.new(topic_view,
scope: self.guardian,
root: false
).to_json
)
end
end
2017-12-11 03:15:50 -05:00
def self.enqueue_post_hooks(event, post)
if active_web_hooks('post').exists?
WebHook.enqueue_hooks(:post,
category_id: post&.topic&.category_id,
event_name: event.to_s,
payload: WebHookPostSerializer.new(post,
scope: self.guardian,
root: false
).to_json
)
end
2017-12-11 03:15:50 -05:00
end
private
2018-06-07 01:28:18 -04:00
def self.guardian
@guardian ||= Guardian.new(Discourse.system_user)
end
2016-06-15 13:49:57 -04:00
end
# == Schema Information
#
# Table name: web_hooks
#
# id :integer not null, primary key
# payload_url :string not null
# content_type :integer default(1), not null
# last_delivery_status :integer default(1), not null
2016-10-31 05:32:11 -04:00
# status :integer default(1), not null
2016-06-15 13:49:57 -04:00
# secret :string default("")
# wildcard_web_hook :boolean default(FALSE), not null
# verify_certificate :boolean default(TRUE), not null
# active :boolean default(FALSE), not null
2018-02-20 01:28:58 -05:00
# created_at :datetime not null
# updated_at :datetime not null
2016-06-15 13:49:57 -04:00
#