discourse-chat-integration/lib/discourse_chat_integration/provider/matrix/matrix_provider.rb

# frozen_string_literal: true

module DiscourseChatIntegration
  module Provider
    module MatrixProvider
      PROVIDER_NAME = "matrix".freeze
      PROVIDER_ENABLED_SETTING = :chat_integration_matrix_enabled
      CHANNEL_PARAMETERS = [
        { key: "name", regex: '^\S+' },
        { key: "room_id", regex: '^\!\S+:\S+$', unique: true, hidden: true },
      ]

      def self.send_message(room_id, message)
        homeserver = SiteSetting.chat_integration_matrix_homeserver
        event_type = "m.room.message"
        uid = Time.now.to_i

        url_params =
          URI.encode_www_form(access_token: SiteSetting.chat_integration_matrix_access_token)

        url =
          "#{homeserver}/_matrix/client/r0/rooms/#{CGI.escape(room_id)}/send/#{event_type}/#{uid}"

        uri = URI([url, url_params].join("?"))

        http = FinalDestination::HTTP.new(uri.host, uri.port)
        http.use_ssl = true

        req = Net::HTTP::Put.new(uri, "Content-Type" => "application/json")
        req.body = message.to_json
        response = http.request(req)

        response
      end

      def self.generate_matrix_message(post)
        display_name = ::DiscourseChatIntegration::Helper.formatted_display_name(post.user)

        message = {
          msgtype: SiteSetting.chat_integration_matrix_use_notice ? "m.notice" : "m.text",
          body:
            I18n.t(
              "chat_integration.provider.matrix.text_message",
              user: display_name,
              post_url: post.full_url,
              title: post.topic.title,
            ),
          format: "org.matrix.custom.html",
          formatted_body:
            I18n.t(
              "chat_integration.provider.matrix.formatted_message",
              user: display_name,
              post_url: post.full_url,
              title: post.topic.title,
              excerpt:
                post.excerpt(
                  SiteSetting.chat_integration_matrix_excerpt_length,
                  text_entities: true,
                  strip_links: true,
                  remap_emoji: true,
                ),
            ),
        }

        message
      end

      def self.trigger_notification(post, channel, rule)
        message = generate_matrix_message(post)

        response = send_message(channel.data["room_id"], message)

        if !response.kind_of?(Net::HTTPSuccess)
          error_key = nil
          begin
            responseData = JSON.parse(response.body)
            if responseData["errcode"] == "M_UNKNOWN_TOKEN"
              error_key = "chat_integration.provider.matrix.errors.unknown_token"
            elsif responseData["errcode"] == "M_UNKNOWN"
              error_key = "chat_integration.provider.matrix.errors.unknown_room"
            end
          ensure
            raise ::DiscourseChatIntegration::ProviderError.new info: {
                                                                  error_key: error_key,
                                                                  message: message,
                                                                  response_body: response.body,
                                                                }
          end
        end
      end
    end
  end
end