1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
# frozen_string_literal: true
module QA
RSpec.describe 'Manage' do
describe(
'WebHooks integration',
:requires_admin,
:integrations,
:orchestrated,
product_group: :integrations
) do
before(:context) do
toggle_local_requests(true)
end
after(:context) do
Resource::ProjectWebHook.teardown!
end
let(:session) { SecureRandom.hex(5) }
let(:tag_name) { SecureRandom.hex(5) }
it 'sends a push event', testcase: 'https://gitlab.com/gitlab-org/gitlab/-/quality/test_cases/348945' do
Resource::ProjectWebHook.setup(session: session, push: true) do |webhook, smocker|
Resource::Repository::ProjectPush.fabricate! do |project_push|
project_push.project = webhook.project
end
expect_web_hook_single_event_success(webhook, smocker, type: 'push')
end
end
it 'sends a merge request event', testcase: 'https://gitlab.com/gitlab-org/gitlab/-/quality/test_cases/349720' do
Resource::ProjectWebHook.setup(session: session, merge_requests: true) do |webhook, smocker|
Resource::MergeRequest.fabricate_via_api! do |merge_request|
merge_request.project = webhook.project
end
expect_web_hook_single_event_success(webhook, smocker, type: 'merge_request')
end
end
it 'sends a wiki page event', testcase: 'https://gitlab.com/gitlab-org/gitlab/-/quality/test_cases/349722' do
Resource::ProjectWebHook.setup(session: session, wiki_page: true) do |webhook, smocker|
Resource::Wiki::ProjectPage.fabricate_via_api! do |page|
page.project = webhook.project
end
expect_web_hook_single_event_success(webhook, smocker, type: 'wiki_page')
end
end
it 'sends an issues and note event',
testcase: 'https://gitlab.com/gitlab-org/gitlab/-/quality/test_cases/349723' do
Resource::ProjectWebHook.setup(session: session, issues: true, note: true) do |webhook, smocker|
issue = Resource::Issue.fabricate_via_api! do |issue_init|
issue_init.project = webhook.project
end
Resource::ProjectIssueNote.fabricate_via_api! do |note|
note.project = issue.project
note.issue = issue
end
expect { smocker.events(session).size }.to eventually_eq(2)
.within(max_duration: 30, sleep_interval: 2),
-> { "Should have 2 events, got: #{smocker.stringified_history(session)}" }
events = smocker.events(session)
aggregate_failures do
expect(events).to include(
a_hash_including(object_kind: 'note'),
a_hash_including(object_kind: 'issue')
)
end
end
end
it 'sends a tag event',
testcase: 'https://gitlab.com/gitlab-org/gitlab/-/quality/test_cases/383577' do
Resource::ProjectWebHook.setup(session: session, tag_push: true) do |webhook, smocker|
project_push = Resource::Repository::ProjectPush.fabricate! do |project_push|
project_push.project = webhook.project
end
Resource::Tag.fabricate_via_api! do |tag|
tag.project = project_push.project
tag.ref = project_push.branch_name
tag.name = tag_name
end
expect_web_hook_single_event_success(webhook, smocker, type: 'tag_push')
end
end
context 'when hook fails' do
let(:fail_mock) do
<<~YAML
- request:
method: POST
path: /default
response:
status: 404
headers:
Content-Type: text/plain
body: 'webhook failed'
YAML
end
let(:hook_trigger_times) { 5 }
let(:disabled_after) { 4 }
it 'hook is auto-disabled',
testcase: 'https://gitlab.com/gitlab-org/gitlab/-/quality/test_cases/389595' do
Resource::ProjectWebHook.setup(fail_mock, session: session, issues: true) do |webhook, smocker|
hook_trigger_times.times do
Resource::Issue.fabricate_via_api! do |issue_init|
issue_init.project = webhook.project
end
# using sleep to give rate limiter a chance to activate.
sleep 0.5
end
expect { smocker.events(session).size }.to eventually_eq(disabled_after)
.within(max_duration: 30, sleep_interval: 2),
-> { "Should have #{disabled_after} events, got: #{smocker.events(session).size}" }
webhook.reload!
expect(webhook.alert_status).to eql('disabled')
end
end
end
end
private
def expect_web_hook_single_event_success(webhook, smocker, type:)
expect { smocker.events(session).size }.to eventually_eq(1)
.within(max_duration: 30, sleep_interval: 2),
-> { "Should have 1 events, got: #{smocker.stringified_history(session)}" }
event = smocker.events(session).first
aggregate_failures do
expect(event).to match(a_hash_including(
object_kind: type,
project: a_hash_including(name: webhook.project.name)
))
end
end
def toggle_local_requests(on)
Runtime::ApplicationSettings.set_application_settings(allow_local_requests_from_web_hooks_and_services: on)
end
end
end
|
