101 lines
		
	
	
		
			3.0 KiB
		
	
	
	
		
			Ruby
		
	
	
	
	
	
			
		
		
	
	
			101 lines
		
	
	
		
			3.0 KiB
		
	
	
	
		
			Ruby
		
	
	
	
	
	
| # frozen_string_literal: true
 | |
| 
 | |
| require 'rails_helper'
 | |
| 
 | |
| describe Admin::SystemCheck::ElasticsearchCheck do
 | |
|   subject(:check) { described_class.new(user) }
 | |
| 
 | |
|   let(:user) { Fabricate(:user) }
 | |
| 
 | |
|   it_behaves_like 'a check available to devops users'
 | |
| 
 | |
|   describe 'pass?' do
 | |
|     context 'when chewy is enabled' do
 | |
|       before { allow(Chewy).to receive(:enabled?).and_return(true) }
 | |
| 
 | |
|       context 'when running version is present and high enough' do
 | |
|         before do
 | |
|           allow(Chewy.client).to receive(:info)
 | |
|             .and_return({ 'version' => { 'number' => '999.99.9' } })
 | |
|         end
 | |
| 
 | |
|         it 'returns true' do
 | |
|           expect(check.pass?).to be true
 | |
|         end
 | |
|       end
 | |
| 
 | |
|       context 'when running version is present and too low' do
 | |
|         context 'when compatible version is too low' do
 | |
|           before do
 | |
|             allow(Chewy.client).to receive(:info)
 | |
|               .and_return({ 'version' => { 'number' => '1.2.3', 'minimum_wire_compatibility_version' => '1.0' } })
 | |
|           end
 | |
| 
 | |
|           it 'returns false' do
 | |
|             expect(check.pass?).to be false
 | |
|           end
 | |
|         end
 | |
| 
 | |
|         context 'when compatible version is high enough' do
 | |
|           before do
 | |
|             allow(Chewy.client).to receive(:info)
 | |
|               .and_return({ 'version' => { 'number' => '1.2.3', 'minimum_wire_compatibility_version' => '99.9' } })
 | |
|           end
 | |
| 
 | |
|           it 'returns true' do
 | |
|             expect(check.pass?).to be true
 | |
|           end
 | |
|         end
 | |
|       end
 | |
| 
 | |
|       context 'when running version is missing' do
 | |
|         before do
 | |
|           client = instance_double(Elasticsearch::Transport::Client)
 | |
|           allow(client).to receive(:info).and_raise(Elasticsearch::Transport::Transport::Error)
 | |
|           allow(Chewy).to receive(:client).and_return(client)
 | |
|         end
 | |
| 
 | |
|         it 'returns false' do
 | |
|           expect(check.pass?).to be false
 | |
|         end
 | |
|       end
 | |
|     end
 | |
| 
 | |
|     context 'when chewy is not enabled' do
 | |
|       before { allow(Chewy).to receive(:enabled?).and_return(false) }
 | |
| 
 | |
|       it 'returns true' do
 | |
|         expect(check.pass?).to be true
 | |
|       end
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   describe 'message' do
 | |
|     context 'when running version is present' do
 | |
|       before { allow(Chewy.client).to receive(:info).and_return({ 'version' => { 'number' => '999.99.9' } }) }
 | |
| 
 | |
|       it 'sends class name symbol to message instance' do
 | |
|         allow(Admin::SystemCheck::Message).to receive(:new)
 | |
|           .with(:elasticsearch_version_check, anything)
 | |
| 
 | |
|         check.message
 | |
| 
 | |
|         expect(Admin::SystemCheck::Message).to have_received(:new)
 | |
|           .with(:elasticsearch_version_check, 'Elasticsearch 999.99.9 is running while 7.x is required')
 | |
|       end
 | |
|     end
 | |
| 
 | |
|     context 'when running version is missing' do
 | |
|       it 'sends class name symbol to message instance' do
 | |
|         allow(Admin::SystemCheck::Message).to receive(:new)
 | |
|           .with(:elasticsearch_running_check)
 | |
| 
 | |
|         check.message
 | |
| 
 | |
|         expect(Admin::SystemCheck::Message).to have_received(:new)
 | |
|           .with(:elasticsearch_running_check)
 | |
|       end
 | |
|     end
 | |
|   end
 | |
| end
 |