discourse-chat-integration/plugin.rb

# frozen_string_literal: true

# name: discourse-chat-integration
# about: Allows integration with several external chat system providers
# meta_topic_id: 66522
# version: 0.1
# url: https://github.com/discourse/discourse-chat-integration
# author: David Taylor

enabled_site_setting :chat_integration_enabled

register_asset "stylesheets/chat-integration.scss"

register_svg_icon "rocket" if respond_to?(:register_svg_icon)
register_svg_icon "fa-arrow-circle-o-right" if respond_to?(:register_svg_icon)

# Site setting validators must be loaded before initialize
require_relative "lib/discourse_chat_integration/provider/slack/slack_enabled_setting_validator"
require_relative "lib/discourse_chat_integration/chat_integration_reference_post"

after_initialize do
  require_relative "app/initializers/discourse_chat_integration"

  require_relative "app/services/problem_check/channel_errors"

  register_problem_check ProblemCheck::ChannelErrors

  on(:site_setting_changed) do |setting_name, old_value, new_value|
    is_enabled_setting = setting_name == :chat_integration_telegram_enabled
    is_access_token = setting_name == :chat_integration_telegram_access_token

    if (is_enabled_setting || is_access_token)
      enabled =
        is_enabled_setting ? new_value == true : SiteSetting.chat_integration_telegram_enabled

      if enabled && SiteSetting.chat_integration_telegram_access_token.present?
        Scheduler::Defer.later("Setup Telegram Webhook") do
          DiscourseChatIntegration::Provider::TelegramProvider.setup_webhook
        end
      end
    end
  end

  on(:post_created) do |post|
    # This will run for every post, even PMs. Don't worry, they're filtered out later.
    time = SiteSetting.chat_integration_delay_seconds.seconds
    Jobs.enqueue_in(time, :notify_chats, post_id: post.id)
  end

  add_admin_route "chat_integration.menu_title", "chat-integration"

  DiscourseChatIntegration::Provider.mount_engines

  if defined?(DiscourseAutomation)
    add_automation_scriptable("send_slack_message") do
      field :message, component: :message, required: true, accepts_placeholders: true
      field :url, component: :text, required: true
      field :channel, component: :text, required: true

      version 1

      triggerables %i[point_in_time recurring topic_tags_changed]

      script do |context, fields, automation|
        channel_name = fields.dig("channel", "value")
        channel =
          DiscourseChatIntegration::Channel.new(
            provider: "slack",
            data: {
              identifier: "##{channel_name}",
            },
          )

        begin
          message =
            DiscourseChatIntegration::Provider::SlackProvider.create_slack_message(
              context: context,
              content: fields.dig("message", "value"),
              url: fields.dig("url", "value"),
              channel_name: channel_name,
            )
          DiscourseChatIntegration::Provider::SlackProvider.send_via_api(nil, channel, message)
        rescue StandardError => _
          # StandardError here is when there are no tags but content includes reference to them.
        end
      end
    end

    add_automation_scriptable("send_chat_integration_message") do
      field :provider,
            component: :choices,
            extra: {
              content:
                DiscourseChatIntegration::Provider.enabled_provider_names.map do |provider|
                  { id: provider, name: "chat_integration.provider.#{provider}.title" }
                end,
            },
            required: true
      field :channel_name, component: :text, required: true
      field :trigger_with_pms, component: :boolean

      version 1

      triggerables %i[topic_tags_changed]

      script do |context, fields, automation|
        if context["topic"].private_message?
          next unless fields.dig("trigger_with_pms", "value")
        end

        # DiscourseTagging.tag_topic_by_names runs on topic creation and on tags change
        # we only want to send a message when tags change
        next if context["topic"].new_record?

        provider = fields.dig("provider", "value")
        channel_name = fields.dig("channel_name", "value")

        post =
          DiscourseChatIntegration::ChatIntegrationReferencePost.new(
            user: context["user"],
            topic: context["topic"],
            kind: context["kind"],
            context: {
              "added_tags" => context["added_tags"],
              "removed_tags" => context["removed_tags"],
            },
          )
        provider = DiscourseChatIntegration::Provider.get_by_name(provider)

        channel = provider.get_channel_by_name(channel_name) # user must have created a channel in /admin/plugins/chat-integration/<provider> page

        if channel.nil?
          Rails.logger.warn "[discourse-automation] Channel not found. Automation ID: #{automation.id}"
          next
        end

        begin
          provider.trigger_notification(post, channel, nil)
        rescue StandardError => e
          Rails.logger.warn "[discourse-automation] Error while sending chat integration message. Automation ID: #{automation.id}"
          Rails.logger.warn "[discourse-chat-integration] Error: #{e.inspect}"
          Rails.logger.warn "[discourse-chat-integration] Channel: #{channel_name}"
          Rails.logger.warn "[discourse-chat-integration] Reference post: #{post.inspect}"
        end
      end
    end
  end
end