chatwoot/spec/models/data_import_spec.rb

require 'rails_helper'

RSpec.describe DataImport do
  describe 'associations' do
    it { is_expected.to belong_to(:account) }
  end

  describe 'validations' do
    it 'returns false for invalid data type' do
      expect(build(:data_import, data_type: 'Xyc').valid?).to be false
    end
  end

  describe 'access token encryption' do
    it 'encrypts the Intercom access token at rest' do
      skip('encryption keys missing; see run_mfa_spec workflow') unless Chatwoot.encryption_configured?

      data_import = create(:data_import, :intercom, access_token: 'intercom-secret')
      stored_value = data_import.reload.read_attribute_before_type_cast(:access_token).to_s

      expect(stored_value).not_to include('intercom-secret')
      expect(data_import.access_token).to eq('intercom-secret')
    end
  end

  describe 'callbacks' do
    let(:data_import) { build(:data_import) }

    it 'schedules a job after creation' do
      expect do
        data_import.save
      end.to have_enqueued_job(DataImportJob).with(data_import).on_queue('low')
    end
  end

  describe '#abandon!' do
    let(:account) { create(:account) }
    let(:data_import) do
      create(
        :data_import, :intercom,
        account: account,
        status: :processing
      )
    end

    before do
      account.enable_features!('data_import')
    end

    it 'abandons active Intercom imports', :aggregate_failures do
      data_import.abandon!

      expect(data_import).to be_abandoned
      expect(data_import.abandoned_at).to be_present
    end

    it 'does not overwrite terminal status from a stale instance', :aggregate_failures do
      stale_import = described_class.find(data_import.id)
      data_import.update!(status: :completed, completed_at: 1.minute.ago)

      stale_import.abandon!

      expect(data_import.reload).to be_completed
      expect(data_import.abandoned_at).to be_nil
    end
  end
end