mirror of
https://github.com/discourse/discourse-chat-integration.git
synced 2025-10-31 05:48:37 +00:00
86 lines
2.7 KiB
Ruby
86 lines
2.7 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module DiscourseChatIntegration::Provider::RocketchatProvider
|
|
PROVIDER_NAME = "rocketchat".freeze
|
|
|
|
PROVIDER_ENABLED_SETTING = :chat_integration_rocketchat_enabled
|
|
|
|
CHANNEL_PARAMETERS = [{ key: "identifier", regex: '^[@#]\S*$', unique: true }]
|
|
|
|
def self.rocketchat_message(post, channel)
|
|
display_name = ::DiscourseChatIntegration::Helper.formatted_display_name(post.user)
|
|
|
|
topic = post.topic
|
|
|
|
category = ""
|
|
if topic.category&.uncategorized?
|
|
category = "[#{I18n.t("uncategorized_category_name")}]"
|
|
elsif topic.category
|
|
category =
|
|
(
|
|
if (topic.category.parent_category)
|
|
"[#{topic.category.parent_category.name}/#{topic.category.name}]"
|
|
else
|
|
"[#{topic.category.name}]"
|
|
end
|
|
)
|
|
end
|
|
|
|
message = { channel: channel, attachments: [] }
|
|
|
|
summary = {
|
|
fallback: "#{topic.title} - #{display_name}",
|
|
author_name: display_name,
|
|
author_icon: post.user.small_avatar_url,
|
|
color: topic.category ? "##{topic.category.color}" : nil,
|
|
text:
|
|
post.excerpt(
|
|
SiteSetting.chat_integration_rocketchat_excerpt_length,
|
|
text_entities: true,
|
|
strip_links: true,
|
|
remap_emoji: true,
|
|
),
|
|
mrkdwn_in: ["text"],
|
|
title:
|
|
"#{topic.title} #{category} #{topic.tags.present? ? topic.tags.map(&:name).join(", ") : ""}",
|
|
title_link: post.full_url,
|
|
}
|
|
|
|
message[:attachments].push(summary)
|
|
|
|
message
|
|
end
|
|
|
|
def self.send_via_webhook(message)
|
|
uri = URI(SiteSetting.chat_integration_rocketchat_webhook_url)
|
|
|
|
http = FinalDestination::HTTP.new(uri.host, uri.port)
|
|
http.use_ssl = (uri.scheme == "https")
|
|
|
|
req = Net::HTTP::Post.new(uri, "Content-Type" => "application/json")
|
|
req.body = message.to_json
|
|
response = http.request(req)
|
|
|
|
unless response.kind_of? Net::HTTPSuccess
|
|
if response.body.include?("invalid-channel")
|
|
error_key = "chat_integration.provider.rocketchat.errors.invalid_channel"
|
|
else
|
|
error_key = nil
|
|
end
|
|
raise ::DiscourseChatIntegration::ProviderError.new info: {
|
|
error_key: error_key,
|
|
request: req.body,
|
|
response_code: response.code,
|
|
response_body: response.body,
|
|
}
|
|
end
|
|
end
|
|
|
|
def self.trigger_notification(post, channel, rule)
|
|
channel_id = channel.data["identifier"]
|
|
message = rocketchat_message(post, channel_id)
|
|
|
|
self.send_via_webhook(message)
|
|
end
|
|
end
|