mirror of
https://github.com/codeninjasllc/discourse.git
synced 2024-11-30 10:58:31 -05:00
87 lines
2.7 KiB
Ruby
87 lines
2.7 KiB
Ruby
|
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?
|
||
|
|
|
||
|
|
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 self.find_by_type(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)
|
||
|
|
end
|
||
|
|
|
||
|
|
def self.enqueue_hooks(type, opts = {})
|
||
|
|
find_by_type(type).each do |w|
|
||
|
|
Jobs.enqueue(:emit_web_hook_event, opts.merge(web_hook_id: w.id, event_type: type.to_s))
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
def self.enqueue_topic_hooks(topic, user)
|
||
|
|
WebHook.enqueue_hooks(:topic, topic_id: topic.id, user_id: user&.id, category_id: topic&.category&.id)
|
||
|
|
end
|
||
|
|
|
||
|
|
%i(topic_destroyed topic_recovered).each do |event|
|
||
|
|
DiscourseEvent.on(event) do |topic, user|
|
||
|
|
WebHook.enqueue_topic_hooks(topic, user)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
DiscourseEvent.on(:topic_created) do |topic, _, user|
|
||
|
|
WebHook.enqueue_topic_hooks(topic, user)
|
||
|
|
end
|
||
|
|
|
||
|
|
%i(post_created
|
||
|
|
post_destroyed
|
||
|
|
post_recovered).each do |event|
|
||
|
|
|
||
|
|
DiscourseEvent.on(event) do |post, _, user|
|
||
|
|
WebHook.enqueue_hooks(:post,
|
||
|
|
post_id: post.id,
|
||
|
|
topic_id: post&.topic&.id,
|
||
|
|
user_id: user&.id,
|
||
|
|
category_id: post.topic&.category&.id
|
||
|
|
)
|
||
|
|
end
|
||
|
|
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
|
||
|
|
# 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
|
||
|
|
# updated_at :datetime
|
||
|
|
#
|