Commit 26644bfd authored by GitLab Bot's avatar GitLab Bot

Automatic merge of gitlab-org/gitlab-ce master

parents 37525a1a 1898e1bb
...@@ -37,7 +37,7 @@ module Ci ...@@ -37,7 +37,7 @@ module Ci
variables_attributes: params[:variables_attributes], variables_attributes: params[:variables_attributes],
project: project, project: project,
current_user: current_user, current_user: current_user,
push_options: params[:push_options], push_options: params[:push_options] || {},
chat_data: params[:chat_data], chat_data: params[:chat_data],
**extra_options(options)) **extra_options(options))
......
...@@ -79,7 +79,7 @@ module Git ...@@ -79,7 +79,7 @@ module Git
limited_commits, limited_commits,
event_message, event_message,
commits_count: commits_count, commits_count: commits_count,
push_options: params[:push_options] || [] push_options: params[:push_options] || {}
) )
# Dependent code may modify the push data, so return a duplicate each time # Dependent code may modify the push data, so return a duplicate each time
......
# frozen_string_literal: true
module MergeRequests
class PushOptionsHandlerService
LIMIT = 10
attr_reader :branches, :changes_by_branch, :current_user, :errors,
:project, :push_options, :target_project
def initialize(project, current_user, changes, push_options)
@project = project
@target_project = @project.default_merge_request_target
@current_user = current_user
@branches = get_branches(changes)
@push_options = push_options
@errors = []
end
def execute
validate_service
return self if errors.present?
branches.each do |branch|
execute_for_branch(branch)
rescue Gitlab::Access::AccessDeniedError
errors << 'User access was denied'
rescue StandardError => e
Gitlab::AppLogger.error(e)
errors << 'An unknown error occurred'
end
self
end
private
def get_branches(raw_changes)
Gitlab::ChangesList.new(raw_changes).map do |changes|
next unless Gitlab::Git.branch_ref?(changes[:ref])
# Deleted branch
next if Gitlab::Git.blank_ref?(changes[:newrev])
# Default branch
branch_name = Gitlab::Git.branch_name(changes[:ref])
next if branch_name == target_project.default_branch
branch_name
end.compact.uniq
end
def validate_service
errors << 'User is required' if current_user.nil?
unless target_project.merge_requests_enabled?
errors << "Merge requests are not enabled for project #{target_project.full_path}"
end
if branches.size > LIMIT
errors << "Too many branches pushed (#{branches.size} were pushed, limit is #{LIMIT})"
end
if push_options[:target] && !target_project.repository.branch_exists?(push_options[:target])
errors << "Branch #{push_options[:target]} does not exist"
end
end
# Returns a Hash of branch => MergeRequest
def merge_requests
@merge_requests ||= MergeRequest.from_project(target_project)
.opened
.from_source_branches(branches)
.index_by(&:source_branch)
end
def execute_for_branch(branch)
merge_request = merge_requests[branch]
if merge_request
update!(merge_request)
else
create!(branch)
end
end
def create!(branch)
unless push_options[:create]
errors << "A merge_request.create push option is required to create a merge request for branch #{branch}"
return
end
# Use BuildService to assign the standard attributes of a merge request
merge_request = ::MergeRequests::BuildService.new(
project,
current_user,
create_params(branch)
).execute
unless merge_request.errors.present?
merge_request = ::MergeRequests::CreateService.new(
project,
current_user,
merge_request.attributes
).execute
end
collect_errors_from_merge_request(merge_request) unless merge_request.persisted?
end
def update!(merge_request)
merge_request = ::MergeRequests::UpdateService.new(
target_project,
current_user,
update_params
).execute(merge_request)
collect_errors_from_merge_request(merge_request) unless merge_request.valid?
end
def create_params(branch)
params = {
assignee: current_user,
source_branch: branch,
source_project: project,
target_branch: push_options[:target] || target_project.default_branch,
target_project: target_project
}
if push_options.key?(:merge_when_pipeline_succeeds)
params.merge!(
merge_when_pipeline_succeeds: push_options[:merge_when_pipeline_succeeds],
merge_user: current_user
)
end
params
end
def update_params
params = {}
if push_options.key?(:merge_when_pipeline_succeeds)
params.merge!(
merge_when_pipeline_succeeds: push_options[:merge_when_pipeline_succeeds],
merge_user: current_user
)
end
if push_options.key?(:target)
params[:target_branch] = push_options[:target]
end
params
end
def collect_errors_from_merge_request(merge_request)
merge_request.errors.full_messages.each do |error|
errors << error
end
end
end
end
...@@ -3,7 +3,7 @@ ...@@ -3,7 +3,7 @@
class PostReceive class PostReceive
include ApplicationWorker include ApplicationWorker
def perform(gl_repository, identifier, changes, push_options = []) def perform(gl_repository, identifier, changes, push_options = {})
project, repo_type = Gitlab::GlRepository.parse(gl_repository) project, repo_type = Gitlab::GlRepository.parse(gl_repository)
if project.nil? if project.nil?
......
---
title: Allow merge requests to be created via git push options
merge_request: 26752
author:
type: added
---
title: Allow merge requests to be set to merge when pipeline succeeds via git push
options
merge_request: 26842
author:
type: added
...@@ -243,6 +243,64 @@ apply the patches. The target branch can be specified using the ...@@ -243,6 +243,64 @@ apply the patches. The target branch can be specified using the
[`/target_branch` quick action](../quick_actions.md). If the source [`/target_branch` quick action](../quick_actions.md). If the source
branch already exists, the patches will be applied on top of it. branch already exists, the patches will be applied on top of it.
## Git push options
> [Introduced](https://gitlab.com/gitlab-org/gitlab-ce/merge_requests/26752) in GitLab 11.10.
NOTE: **Note:**
Git push options are only available with Git 2.10 or newer.
GitLab supports using
[Git push options](https://git-scm.com/docs/git-push#Documentation/git-push.txt--oltoptiongt)
to perform the following actions against merge requests at the same time
as pushing changes:
- Create a new merge request for the pushed branch.
- Set the target of the merge request to a particular branch.
- Set the merge request to merge when its pipeline succeeds.
### Create a new merge request using git push options
To create a new merge request for a branch, use the
`merge_request.create` push option:
```sh
git push -o merge_request.create
```
### Set the target branch of a merge request using git push options
To update an existing merge request's target branch, use the
`merge_request.target=<branch_name>` push option:
```sh
git push -o merge_request.target=branch_name
```
You can also create a merge request and set its target branch at the
same time using a `-o` flag per push option:
```sh
git push -o merge_request.create -o merge_request.target=branch_name
```
### Set merge when pipeline succeeds using git push options
To set an existing merge request to
[merge when its pipeline succeeds](merge_when_pipeline_succeeds.md), use
the `merge_request.merge_when_pipeline_succeeds` push option:
```sh
git push -o merge_request.merge_when_pipeline_succeeds
```
You can also create a merge request and set it to merge when its
pipeline succeeds at the same time using a `-o` flag per push option:
```sh
git push -o merge_request.create -o merge_request.merge_when_pipeline_succeeds
```
## Find the merge request that introduced a change ## Find the merge request that introduced a change
> [Introduced](https://gitlab.com/gitlab-org/gitlab-ce/issues/2383) in GitLab 10.5. > [Introduced](https://gitlab.com/gitlab-org/gitlab-ce/issues/2383) in GitLab 10.5.
......
...@@ -43,6 +43,28 @@ module API ...@@ -43,6 +43,28 @@ module API
::MergeRequests::GetUrlsService.new(project).execute(params[:changes]) ::MergeRequests::GetUrlsService.new(project).execute(params[:changes])
end end
def process_mr_push_options(push_options, project, user, changes)
output = {}
service = ::MergeRequests::PushOptionsHandlerService.new(
project,
user,
changes,
push_options
).execute
if service.errors.present?
output[:warnings] = push_options_warning(service.errors.join("\n\n"))
end
output
end
def push_options_warning(warning)
options = Array.wrap(params[:push_options]).map { |p| "'#{p}'" }.join(' ')
"Error encountered with push options #{options}: #{warning}"
end
def redis_ping def redis_ping
result = Gitlab::Redis::SharedState.with { |redis| redis.ping } result = Gitlab::Redis::SharedState.with { |redis| redis.ping }
......
...@@ -256,19 +256,27 @@ module API ...@@ -256,19 +256,27 @@ module API
post '/post_receive' do post '/post_receive' do
status 200 status 200
output = {} # Messages to gitlab-shell
user = identify(params[:identifier])
project = Gitlab::GlRepository.parse(params[:gl_repository]).first
push_options = Gitlab::PushOptions.new(params[:push_options])
PostReceive.perform_async(params[:gl_repository], params[:identifier], PostReceive.perform_async(params[:gl_repository], params[:identifier],
params[:changes], params[:push_options].to_a) params[:changes], push_options.as_json)
if Feature.enabled?(:mr_push_options, default_enabled: true)
mr_options = push_options.get(:merge_request)
output.merge!(process_mr_push_options(mr_options, project, user, params[:changes])) if mr_options.present?
end
broadcast_message = BroadcastMessage.current&.last&.message broadcast_message = BroadcastMessage.current&.last&.message
reference_counter_decreased = Gitlab::ReferenceCounter.new(params[:gl_repository]).decrease reference_counter_decreased = Gitlab::ReferenceCounter.new(params[:gl_repository]).decrease
output = { output.merge!(
merge_request_urls: merge_request_urls,
broadcast_message: broadcast_message, broadcast_message: broadcast_message,
reference_counter_decreased: reference_counter_decreased reference_counter_decreased: reference_counter_decreased,
} merge_request_urls: merge_request_urls
)
project = Gitlab::GlRepository.parse(params[:gl_repository]).first
user = identify(params[:identifier])
# A user is not guaranteed to be returned; an orphaned write deploy # A user is not guaranteed to be returned; an orphaned write deploy
# key could be used # key could be used
......
...@@ -8,7 +8,6 @@ module Gitlab ...@@ -8,7 +8,6 @@ module Gitlab
include ::Gitlab::Utils::StrongMemoize include ::Gitlab::Utils::StrongMemoize
SKIP_PATTERN = /\[(ci[ _-]skip|skip[ _-]ci)\]/i SKIP_PATTERN = /\[(ci[ _-]skip|skip[ _-]ci)\]/i
SKIP_PUSH_OPTION = 'ci.skip'
def perform! def perform!
if skipped? if skipped?
...@@ -35,7 +34,8 @@ module Gitlab ...@@ -35,7 +34,8 @@ module Gitlab
end end
def push_option_skips_ci? def push_option_skips_ci?
!!(@command.push_options&.include?(SKIP_PUSH_OPTION)) @command.push_options.present? &&
@command.push_options.deep_symbolize_keys.dig(:ci, :skip).present?
end end
end end
end end
......
...@@ -32,10 +32,7 @@ module Gitlab ...@@ -32,10 +32,7 @@ module Gitlab
} }
], ],
total_commits_count: 1, total_commits_count: 1,
push_options: [ push_options: { ci: { skip: true } }
"ci.skip",
"custom option"
]
}.freeze }.freeze
# Produce a hash of post-receive data # Produce a hash of post-receive data
...@@ -57,11 +54,11 @@ module Gitlab ...@@ -57,11 +54,11 @@ module Gitlab
# }, # },
# commits: Array, # commits: Array,
# total_commits_count: Fixnum, # total_commits_count: Fixnum,
# push_options: Array # push_options: Hash
# } # }
# #
# rubocop:disable Metrics/ParameterLists # rubocop:disable Metrics/ParameterLists
def build(project, user, oldrev, newrev, ref, commits = [], message = nil, commits_count: nil, push_options: []) def build(project, user, oldrev, newrev, ref, commits = [], message = nil, commits_count: nil, push_options: {})
commits = Array(commits) commits = Array(commits)
# Total commits count # Total commits count
......
...@@ -5,7 +5,7 @@ module Gitlab ...@@ -5,7 +5,7 @@ module Gitlab
include Gitlab::Identifier include Gitlab::Identifier
attr_reader :project, :identifier, :changes, :push_options attr_reader :project, :identifier, :changes, :push_options
def initialize(project, identifier, changes, push_options) def initialize(project, identifier, changes, push_options = {})
@project = project @project = project
@identifier = identifier @identifier = identifier
@changes = deserialize_changes(changes) @changes = deserialize_changes(changes)
......
# frozen_string_literal: true
module Gitlab
class PushOptions
VALID_OPTIONS = HashWithIndifferentAccess.new({
merge_request: {
keys: [:create, :merge_when_pipeline_succeeds, :target]
},
ci: {
keys: [:skip]
}
}).freeze
NAMESPACE_ALIASES = HashWithIndifferentAccess.new({
mr: :merge_request
}).freeze
OPTION_MATCHER = /(?<namespace>[^\.]+)\.(?<key>[^=]+)=?(?<value>.*)/
attr_reader :options
def initialize(options = [])
@options = parse_options(options)
end
def get(*args)
options.dig(*args)
end
# Allow #to_json serialization
def as_json(*_args)
options
end
private
def parse_options(raw_options)
options = HashWithIndifferentAccess.new
Array.wrap(raw_options).each do |option|
namespace, key, value = parse_option(option)
next if [namespace, key].any?(&:nil?)
options[namespace] ||= HashWithIndifferentAccess.new
options[namespace][key] = value
end
options
end
def parse_option(option)
parts = OPTION_MATCHER.match(option)
return unless parts
namespace, key, value = parts.values_at(:namespace, :key, :value).map(&:strip)
namespace = NAMESPACE_ALIASES[namespace] if NAMESPACE_ALIASES[namespace]
value = value.presence || true
return unless valid_option?(namespace, key)
[namespace, key, value]
end
def valid_option?(namespace, key)
keys = VALID_OPTIONS.dig(namespace, :keys)
keys && keys.include?(key.to_sym)
end
end
end
...@@ -139,7 +139,7 @@ describe 'Dropdown milestone', :js do ...@@ -139,7 +139,7 @@ describe 'Dropdown milestone', :js do
expect_filtered_search_input_empty expect_filtered_search_input_empty
end end
it 'fills in the milestone name when the milestone is partially filled' do it 'fills in the milestone name when the milestone is partially filled', :quarantine do
filtered_search.send_keys('v') filtered_search.send_keys('v')
click_milestone(milestone.title) click_milestone(milestone.title)
......
...@@ -21,7 +21,7 @@ describe 'Labels Hierarchy', :js, :nested_groups do ...@@ -21,7 +21,7 @@ describe 'Labels Hierarchy', :js, :nested_groups do
end end
shared_examples 'assigning labels from sidebar' do shared_examples 'assigning labels from sidebar' do
it 'can assign all ancestors labels' do it 'can assign all ancestors labels', :quarantine do
[grandparent_group_label, parent_group_label, project_label_1].each do |label| [grandparent_group_label, parent_group_label, project_label_1].each do |label|
page.within('.block.labels') do page.within('.block.labels') do
find('.edit-link').click find('.edit-link').click
......
...@@ -113,7 +113,7 @@ describe 'Merge request > User creates image diff notes', :js do ...@@ -113,7 +113,7 @@ describe 'Merge request > User creates image diff notes', :js do
create_image_diff_note create_image_diff_note
end end
it 'shows indicator and avatar badges, and allows collapsing/expanding the discussion notes' do it 'shows indicator and avatar badges, and allows collapsing/expanding the discussion notes', :quarantine do
indicator = find('.js-image-badge', match: :first) indicator = find('.js-image-badge', match: :first)
badge = find('.user-avatar-link .badge', match: :first) badge = find('.user-avatar-link .badge', match: :first)
......
...@@ -43,7 +43,7 @@ describe "User creates wiki page" do ...@@ -43,7 +43,7 @@ describe "User creates wiki page" do
expect(page).to have_content("Create Page") expect(page).to have_content("Create Page")
end end
it "shows non-escaped link in the pages list", :js do it "shows non-escaped link in the pages list", :js, :quarantine do
fill_in(:wiki_title, with: "one/two/three-test") fill_in(:wiki_title, with: "one/two/three-test")
page.within(".wiki-form") do page.within(".wiki-form") do
......
# frozen_string_literal: true
require 'spec_helper'
describe Gitlab::PushOptions do
describe 'namespace and key validation' do
it 'ignores unrecognised namespaces' do
options = described_class.new(['invalid.key=value'])
expect(options.get(:invalid)).to eq(nil)
end
it 'ignores unrecognised keys' do
options = described_class.new(['merge_request.key=value'])
expect(options.get(:merge_request)).to eq(nil)
end
it 'ignores blank keys' do
options = described_class.new(['merge_request'])
expect(options.get(:merge_request)).to eq(nil)
end
it 'parses recognised namespace and key pairs' do
options = described_class.new(['merge_request.target=value'])
expect(options.get(:merge_request)).to include({
target: 'value'
})
end
end
describe '#get' do
it 'can emulate Hash#dig' do
options = described_class.new(['merge_request.target=value'])
expect(options.get(:merge_request, :target)).to eq('value')
end
end
describe '#as_json' do
it 'returns all options' do
options = described_class.new(['merge_request.target=value'])
expect(options.as_json).to include(
merge_request: {
target: 'value'
}
)
end
end
it 'can parse multiple push options' do
options = described_class.new([
'merge_request.create',
'merge_request.target=value'
])
expect(options.get(:merge_request)).to include({
create: true,
target: 'value'
})
expect(options.get(:merge_request, :create)).to eq(true)
expect(options.get(:merge_request, :target)).to eq('value')
end
it 'stores options internally as a HashWithIndifferentAccess' do
options = described_class.new([
'merge_request.create'
])
expect(options.get('merge_request', 'create')).to eq(true)
expect(options.get(:merge_request, :create)).to eq(true)
end
it 'selects the last option when options contain duplicate namespace and key pairs' do
options = described_class.new([
'merge_request.target=value1',
'merge_request.target=value2'
])
expect(options.get(:merge_request, :target)).to eq('value2')
end
it 'defaults values to true' do
options = described_class.new(['merge_request.create'])
expect(options.get(:merge_request, :create)).to eq(true)
end
it 'expands aliases' do
options = described_class.new(['mr.target=value'])
expect(options.get(:merge_request, :target)).to eq('value')
end
it 'forgives broken push options' do
options = described_class.new(['merge_request . target = value'])
expect(options.get(:merge_request, :target)).to eq('value')
end
end
...@@ -888,8 +888,10 @@ describe API::Internal do ...@@ -888,8 +888,10 @@ describe API::Internal do
} }
end end
let(:branch_name) { 'feature' }
let(:changes) do let(:changes) do
"#{Gitlab::Git::BLANK_SHA} 570e7b2abdd848b95f2f578043fc23bd6f6fd24d refs/heads/new_branch" "#{Gitlab::Git::BLANK_SHA} 570e7b2abdd848b95f2f578043fc23bd6f6fd24d refs/heads/#{branch_name}"
end end
let(:push_options) do let(:push_options) do
...@@ -905,9 +907,9 @@ describe API::Internal do ...@@ -905,9 +907,9 @@ describe API::Internal do
it 'enqueues a PostReceive worker job' do it 'enqueues a PostReceive worker job' do
expect(PostReceive).to receive(:perform_async) expect(PostReceive).to receive(:perform_async)
.with(gl_repository, identifier, changes, push_options) .with(gl_repository, identifier, changes, { ci: { skip: true } })
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
end end
it 'decreases the reference counter and returns the result' do it 'decreases the reference counter and returns the result' do
...@@ -915,17 +917,17 @@ describe API::Internal do ...@@ -915,17 +917,17 @@ describe API::Internal do
.and_return(reference_counter) .and_return(reference_counter)
expect(reference_counter).to receive(:decrease).and_return(true) expect(reference_counter).to receive(:decrease).and_return(true)
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(json_response['reference_counter_decreased']).to be(true) expect(json_response['reference_counter_decreased']).to be(true)
end end
it 'returns link to create new merge request' do it 'returns link to create new merge request' do
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(json_response['merge_request_urls']).to match [{ expect(json_response['merge_request_urls']).to match [{
"branch_name" => "new_branch", "branch_name" => branch_name,
"url" => "http://#{Gitlab.config.gitlab.host}/#{project.namespace.name}/#{project.path}/merge_requests/new?merge_request%5Bsource_branch%5D=new_branch", "url" => "http://#{Gitlab.config.gitlab.host}/#{project.namespace.name}/#{project.path}/merge_requests/new?merge_request%5Bsource_branch%5D=#{branch_name}",
"new_merge_request" => true "new_merge_request" => true
}] }]
end end
...@@ -933,16 +935,87 @@ describe API::Internal do ...@@ -933,16 +935,87 @@ describe API::Internal do
it 'returns empty array if printing_merge_request_link_enabled is false' do it 'returns empty array if printing_merge_request_link_enabled is false' do
project.update!(printing_merge_request_link_enabled: false) project.update!(printing_merge_request_link_enabled: false)
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(json_response['merge_request_urls']).to eq([]) expect(json_response['merge_request_urls']).to eq([])
end end
it 'does not invoke MergeRequests::PushOptionsHandlerService' do
expect(MergeRequests::PushOptionsHandlerService).not_to receive(:new)
post api('/internal/post_receive'), params: valid_params
end
context 'when there are merge_request push options' do
before do
valid_params[:push_options] = ['merge_request.create']
end
it 'invokes MergeRequests::PushOptionsHandlerService' do
expect(MergeRequests::PushOptionsHandlerService).to receive(:new)
post api('/internal/post_receive'), params: valid_params
end
it 'creates a new merge request' do
expect do
post api('/internal/post_receive'), params: valid_params
end.to change { MergeRequest.count }.by(1)
end
it 'links to the newly created merge request' do
post api('/internal/post_receive'), params: valid_params
expect(json_response['merge_request_urls']).to match [{
'branch_name' => branch_name,
'url' => "http://#{Gitlab.config.gitlab.host}/#{project.namespace.name}/#{project.path}/merge_requests/1",
'new_merge_request' => false
}]
end
it 'adds errors on the service instance to warnings' do
expect_any_instance_of(
MergeRequests::PushOptionsHandlerService
).to receive(:errors).at_least(:once).and_return(['my error'])
post api('/internal/post_receive'), params: valid_params
expect(json_response['warnings']).to eq('Error encountered with push options \'merge_request.create\': my error')
end
it 'adds ActiveRecord errors on invalid MergeRequest records to warnings' do
invalid_merge_request = MergeRequest.new
invalid_merge_request.errors.add(:base, 'my error')
expect_any_instance_of(
MergeRequests::CreateService
).to receive(:execute).and_return(invalid_merge_request)
post api('/internal/post_receive'), params: valid_params
expect(json_response['warnings']).to eq('Error encountered with push options \'merge_request.create\': my error')
end
context 'when the feature is disabled' do
it 'does not invoke MergeRequests::PushOptionsHandlerService' do
Feature.disable(:mr_push_options)
expect(MergeRequests::PushOptionsHandlerService).to receive(:new)
expect do
post api('/internal/post_receive'), params: valid_params
end.not_to change { MergeRequest.count }
Feature.enable(:mr_push_options)
end
end
end
context 'broadcast message exists' do context 'broadcast message exists' do
let!(:broadcast_message) { create(:broadcast_message, starts_at: 1.day.ago, ends_at: 1.day.from_now ) } let!(:broadcast_message) { create(:broadcast_message, starts_at: 1.day.ago, ends_at: 1.day.from_now ) }
it 'returns one broadcast message' do it 'returns one broadcast message' do
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(response).to have_gitlab_http_status(200) expect(response).to have_gitlab_http_status(200)
expect(json_response['broadcast_message']).to eq(broadcast_message.message) expect(json_response['broadcast_message']).to eq(broadcast_message.message)
...@@ -951,7 +1024,7 @@ describe API::Internal do ...@@ -951,7 +1024,7 @@ describe API::Internal do
context 'broadcast message does not exist' do context 'broadcast message does not exist' do
it 'returns empty string' do it 'returns empty string' do
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(response).to have_gitlab_http_status(200) expect(response).to have_gitlab_http_status(200)
expect(json_response['broadcast_message']).to eq(nil) expect(json_response['broadcast_message']).to eq(nil)
...@@ -962,7 +1035,7 @@ describe API::Internal do ...@@ -962,7 +1035,7 @@ describe API::Internal do
it 'returns empty string' do it 'returns empty string' do
allow(BroadcastMessage).to receive(:current).and_return(nil) allow(BroadcastMessage).to receive(:current).and_return(nil)
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(response).to have_gitlab_http_status(200) expect(response).to have_gitlab_http_status(200)
expect(json_response['broadcast_message']).to eq(nil) expect(json_response['broadcast_message']).to eq(nil)
...@@ -974,7 +1047,7 @@ describe API::Internal do ...@@ -974,7 +1047,7 @@ describe API::Internal do
project_moved = Gitlab::Checks::ProjectMoved.new(project, user, 'http', 'foo/baz') project_moved = Gitlab::Checks::ProjectMoved.new(project, user, 'http', 'foo/baz')
project_moved.add_message project_moved.add_message
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(response).to have_gitlab_http_status(200) expect(response).to have_gitlab_http_status(200)
expect(json_response["redirected_message"]).to be_present expect(json_response["redirected_message"]).to be_present
...@@ -987,7 +1060,7 @@ describe API::Internal do ...@@ -987,7 +1060,7 @@ describe API::Internal do
project_created = Gitlab::Checks::ProjectCreated.new(project, user, 'http') project_created = Gitlab::Checks::ProjectCreated.new(project, user, 'http')
project_created.add_message project_created.add_message
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(response).to have_gitlab_http_status(200) expect(response).to have_gitlab_http_status(200)
expect(json_response["project_created_message"]).to be_present expect(json_response["project_created_message"]).to be_present
...@@ -999,7 +1072,7 @@ describe API::Internal do ...@@ -999,7 +1072,7 @@ describe API::Internal do
it 'does not try to notify that project moved' do it 'does not try to notify that project moved' do
allow_any_instance_of(Gitlab::Identifier).to receive(:identify).and_return(nil) allow_any_instance_of(Gitlab::Identifier).to receive(:identify).and_return(nil)
post api("/internal/post_receive"), params: valid_params post api('/internal/post_receive'), params: valid_params
expect(response).to have_gitlab_http_status(200) expect(response).to have_gitlab_http_status(200)
end end
......
...@@ -418,8 +418,7 @@ describe Ci::CreatePipelineService do ...@@ -418,8 +418,7 @@ describe Ci::CreatePipelineService do
context 'when push options contain ci.skip' do context 'when push options contain ci.skip' do
let(:push_options) do let(:push_options) do
['ci.skip', { 'ci' => { 'skip' => true } }
'another push option']
end end
it 'creates a pipline in the skipped state' do it 'creates a pipline in the skipped state' do
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment