discourse-chat-integration/spec/jobs/onceoff/migrate_from_slack_official_spec.rb

# frozen_string_literal: true

require 'rails_helper'

RSpec.describe Jobs::DiscourseChatMigrateFromSlackOfficial do
  let(:category) { Fabricate(:category) }

  describe 'site settings' do
    before do
      PluginStoreRow.create!(
        plugin_name: 'discourse-slack-official',
        key: "category_#{category.id}",
        type_name: "JSON",
        value: "[{\"channel\":\"#slack-channel\",\"filter\":\"mute\"}]"
      )

      SiteSetting.create!(value: 't', data_type: 5, name: 'slack_enabled')
      SiteSetting.create!(value: 'token', data_type: 1, name: 'slack_access_token')
      SiteSetting.create!(value: 'token2', data_type: 1, name: 'slack_incoming_webhook_token')
      SiteSetting.create!(value: 300, data_type: 3, name: 'slack_discourse_excerpt_length')
      SiteSetting.create!(value: "https://hooks.slack.com/services/something", data_type: 1, name: 'slack_outbound_webhook_url')
      SiteSetting.create!(value: "http://outbound2.com", data_type: 1, name: 'slack_icon_url')
      SiteSetting.create!(value: 100, data_type: 3, name: 'post_to_slack_window_secs')
      SiteSetting.create!(value: User.last.username, data_type: 1, name: 'slack_discourse_username')
    end

    it 'should migrate the site settings correctly' do
      described_class.new.execute_onceoff({})

      expect(SiteSetting.find_by(name: 'slack_enabled').value).to eq('f')
      expect(SiteSetting.chat_integration_slack_access_token).to eq('token')
      expect(SiteSetting.chat_integration_slack_incoming_webhook_token).to eq('token2')
      expect(SiteSetting.chat_integration_slack_excerpt_length).to eq(300)

      expect(SiteSetting.chat_integration_slack_outbound_webhook_url)
        .to eq("https://hooks.slack.com/services/something")

      expect(SiteSetting.chat_integration_slack_icon_url)
        .to eq("http://outbound2.com")

      expect(SiteSetting.chat_integration_delay_seconds).to eq(100)
      expect(SiteSetting.chat_integration_discourse_username).to eq(User.last.username)
      expect(SiteSetting.chat_integration_slack_enabled).to eq(true)
      expect(SiteSetting.chat_integration_enabled).to eq(true)
    end

    describe 'when slack_discourse_username is not valid' do
      before do
        SiteSetting.find_by(name: 'slack_discourse_username').update!(value: 'someguy')
      end

      it 'should default to the system user' do
        described_class.new.execute_onceoff({})

        expect(SiteSetting.chat_integration_discourse_username)
          .to eq(Discourse.system_user.username)
      end
    end
  end

  describe 'when a uncategorized filter is present' do
    before do
      PluginStoreRow.create!(
        plugin_name: 'discourse-slack-official',
        key: "category_*",
        type_name: "JSON",
        value: "[{\"channel\":\"#channel1\",\"filter\":\"watch\"},{\"channel\":\"channel2\",\"filter\":\"follow\"},{\"channel\":\"#channel1\",\"filter\":\"mute\"}]"
      )
    end

    it 'should create the right channels and rules' do
      described_class.new.execute_onceoff({})

      expect(DiscourseChatIntegration::Channel.count).to eq(2)
      expect(DiscourseChatIntegration::Rule.count).to eq(2)

      channel = DiscourseChatIntegration::Channel.first

      expect(channel.value['provider']).to eq("slack")
      expect(channel.value['data']['identifier']).to eq("#channel1")

      rule = DiscourseChatIntegration::Rule.first

      expect(rule.value['channel_id']).to eq(channel.id)
      expect(rule.value['filter']).to eq('mute')
      expect(rule.value['category_id']).to eq(nil)

      channel = DiscourseChatIntegration::Channel.last

      expect(channel.value['provider']).to eq("slack")
      expect(channel.value['data']['identifier']).to eq("#channel2")

      rule = DiscourseChatIntegration::Rule.last

      expect(rule.value['channel_id']).to eq(channel.id)
      expect(rule.value['filter']).to eq('follow')
      expect(rule.value['category_id']).to eq(nil)
    end
  end

  describe 'when filter contains an invalid tag' do
    let(:tag) { Fabricate(:tag) }

    before do
      PluginStoreRow.create!(
        plugin_name: 'discourse-slack-official',
        key: "category_#{category.id}",
        type_name: "JSON",
        value: "[{\"channel\":\"#slack-channel\",\"filter\":\"mute\",\"tags\":[\"#{tag.name}\",\"random-tag\"]}]"
      )
    end

    it 'should discard invalid tags' do
      described_class.new.execute_onceoff({})

      rule = DiscourseChatIntegration::Rule.first

      expect(rule.value['tags']).to eq([tag.name])
    end
  end

  describe 'when a category filter is present' do
    before do
      PluginStoreRow.create!(
        plugin_name: 'discourse-slack-official',
        key: "category_#{category.id}",
        type_name: "JSON",
        value: "[{\"channel\":\"#slack-channel\",\"filter\":\"mute\"}]"
      )
    end

    it 'should migrate the settings correctly' do
      described_class.new.execute_onceoff({})

      channel = DiscourseChatIntegration::Channel.first

      expect(channel.value['provider']).to eq("slack")
      expect(channel.value['data']['identifier']).to eq("#slack-channel")

      rule = DiscourseChatIntegration::Rule.first

      expect(rule.value['channel_id']).to eq(channel.id)
      expect(rule.value['filter']).to eq('mute')
      expect(rule.value['category_id']).to eq(category.id)
    end
  end

  describe 'when a category has been deleted' do
    before do
      PluginStoreRow.create!(
        plugin_name: 'discourse-slack-official',
        key: 'category_9999',
        type_name: "JSON",
        value: "[{\"channel\":\"#slack-channel\",\"filter\":\"mute\"}]"
      )
    end

    it 'should not migrate the settings' do
      described_class.new.execute_onceoff({})

      expect(DiscourseChatIntegration::Channel.count).to eq(0)
      expect(DiscourseChatIntegration::Rule.count).to eq(0)
    end
  end
end