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? before_save :strip_url 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) WebHook.where(active: true) .joins(:web_hook_event_types) .where("web_hooks.wildcard_web_hook = ? OR web_hook_event_types.name = ?", true, type.to_s) .distinct end def self.enqueue_hooks(type, event, opts = {}) active_web_hooks(type).each do |web_hook| Jobs.enqueue(:emit_web_hook_event, opts.merge( web_hook_id: web_hook.id, event_name: event.to_s, event_type: type.to_s )) end end def self.enqueue_object_hooks(type, object, event, serializer = nil) if active_web_hooks(type).exists? payload = WebHook.generate_payload(type, object, serializer) WebHook.enqueue_hooks(type, event, id: object.id, payload: payload ) end end def self.enqueue_topic_hooks(event, topic) if active_web_hooks('topic').exists? topic_view = TopicView.new(topic.id, Discourse.system_user) payload = WebHook.generate_payload(:topic, topic_view, WebHookTopicViewSerializer) WebHook.enqueue_hooks(:topic, event, id: topic.id, category_id: topic&.category_id, payload: payload ) end end def self.enqueue_post_hooks(event, post) if active_web_hooks('post').exists? payload = WebHook.generate_payload(:post, post) WebHook.enqueue_hooks(:post, event, id: post.id, category_id: post&.topic&.category_id, payload: payload ) end end def self.generate_payload(type, object, serializer = nil) serializer ||= TagSerializer if type == :tag serializer ||= "WebHook#{type.capitalize}Serializer".constantize serializer.new(object, scope: self.guardian, root: false ).to_json end private def self.guardian @guardian ||= Guardian.new(Discourse.system_user) end 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 # status :integer default(1), not null # secret :string default("") # wildcard_web_hook :boolean default(FALSE), not null # verify_certificate :boolean default(TRUE), not null # active :boolean default(FALSE), not null # created_at :datetime not null # updated_at :datetime not null #