135 lines
4.3 KiB
Ruby
135 lines
4.3 KiB
Ruby
require 'spec_helper'
|
|
|
|
describe Projects::MirrorsController do
|
|
include ReactiveCachingHelpers
|
|
|
|
describe 'setting up a remote mirror' do
|
|
set(:project) { create(:project, :repository) }
|
|
|
|
context 'when the current project is not a mirror' do
|
|
it 'allows to create a remote mirror' do
|
|
sign_in(project.owner)
|
|
|
|
expect do
|
|
do_put(project, remote_mirrors_attributes: { '0' => { 'enabled' => 1, 'url' => 'http://foo.com' } })
|
|
end.to change { RemoteMirror.count }.to(1)
|
|
end
|
|
end
|
|
end
|
|
|
|
describe '#update' do
|
|
let(:project) { create(:project, :repository, :remote_mirror) }
|
|
|
|
before do
|
|
sign_in(project.owner)
|
|
end
|
|
|
|
around do |example|
|
|
Sidekiq::Testing.fake! { example.run }
|
|
end
|
|
|
|
context 'With valid URL for a push' do
|
|
let(:remote_mirror_attributes) do
|
|
{ "0" => { "enabled" => "0", url: 'https://updated.example.com' } }
|
|
end
|
|
|
|
it 'processes a successful update' do
|
|
do_put(project, remote_mirrors_attributes: remote_mirror_attributes)
|
|
|
|
expect(response).to redirect_to(project_settings_repository_path(project, anchor: 'js-push-remote-settings'))
|
|
expect(flash[:notice]).to match(/successfully updated/)
|
|
end
|
|
|
|
it 'should create a RemoteMirror object' do
|
|
expect { do_put(project, remote_mirrors_attributes: remote_mirror_attributes) }.to change(RemoteMirror, :count).by(1)
|
|
end
|
|
end
|
|
|
|
context 'With invalid URL for a push' do
|
|
let(:remote_mirror_attributes) do
|
|
{ "0" => { "enabled" => "0", url: 'ftp://invalid.invalid' } }
|
|
end
|
|
|
|
it 'processes an unsuccessful update' do
|
|
do_put(project, remote_mirrors_attributes: remote_mirror_attributes)
|
|
|
|
expect(response).to redirect_to(project_settings_repository_path(project, anchor: 'js-push-remote-settings'))
|
|
expect(flash[:alert]).to match(/Only allowed protocols are/)
|
|
end
|
|
|
|
it 'should not create a RemoteMirror object' do
|
|
expect { do_put(project, remote_mirrors_attributes: remote_mirror_attributes) }.not_to change(RemoteMirror, :count)
|
|
end
|
|
end
|
|
end
|
|
|
|
describe '#ssh_host_keys', :use_clean_rails_memory_store_caching do
|
|
let(:project) { create(:project) }
|
|
let(:cache) { SshHostKey.new(project: project, url: "ssh://example.com:22") }
|
|
|
|
before do
|
|
sign_in(project.owner)
|
|
end
|
|
|
|
context 'invalid URLs' do
|
|
%w[
|
|
INVALID
|
|
git@example.com:foo/bar.git
|
|
ssh://git@example.com:foo/bar.git
|
|
].each do |url|
|
|
it "returns an error with a 400 response for URL #{url.inspect}" do
|
|
do_get(project, url)
|
|
|
|
expect(response).to have_gitlab_http_status(400)
|
|
expect(json_response).to eq('message' => 'Invalid URL')
|
|
end
|
|
end
|
|
end
|
|
|
|
context 'no data in cache' do
|
|
it 'requests the cache to be filled and returns a 204 response' do
|
|
expect(ReactiveCachingWorker).to receive(:perform_async).with(cache.class, cache.id).at_least(:once)
|
|
|
|
do_get(project)
|
|
|
|
expect(response).to have_gitlab_http_status(204)
|
|
end
|
|
end
|
|
|
|
context 'error in the cache' do
|
|
it 'returns the error with a 400 response' do
|
|
stub_reactive_cache(cache, error: 'An error')
|
|
|
|
do_get(project)
|
|
|
|
expect(response).to have_gitlab_http_status(400)
|
|
expect(json_response).to eq('message' => 'An error')
|
|
end
|
|
end
|
|
|
|
context 'data in the cache' do
|
|
let(:ssh_key) { 'ssh-ed25519 AAAAC3NzaC1lZDI1NTE5AAAAIAfuCHKVTjquxvt6CM6tdG4SLp1Btn/nOeHHE5UOzRdf' }
|
|
let(:ssh_fp) { { type: 'ed25519', bits: 256, fingerprint: '2e:65:6a:c8:cf:bf:b2:8b:9a:bd:6d:9f:11:5c:12:16', index: 0 } }
|
|
|
|
it 'returns the data with a 200 response' do
|
|
stub_reactive_cache(cache, known_hosts: ssh_key)
|
|
|
|
do_get(project)
|
|
|
|
expect(response).to have_gitlab_http_status(200)
|
|
expect(json_response).to eq('known_hosts' => ssh_key, 'fingerprints' => [ssh_fp.stringify_keys], 'host_keys_changed' => true)
|
|
end
|
|
end
|
|
|
|
def do_get(project, url = 'ssh://example.com')
|
|
get :ssh_host_keys, namespace_id: project.namespace, project_id: project, ssh_url: url
|
|
end
|
|
end
|
|
|
|
def do_put(project, options, extra_attrs = {})
|
|
attrs = extra_attrs.merge(namespace_id: project.namespace.to_param, project_id: project.to_param)
|
|
attrs[:project] = options
|
|
|
|
put :update, attrs
|
|
end
|
|
end
|