forked from opensearch-project/opensearch-build
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathTestRunPerfTestScript.groovy
115 lines (95 loc) · 3.99 KB
/
TestRunPerfTestScript.groovy
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
/*
* SPDX-License-Identifier: Apache-2.0
*
* The OpenSearch Contributors require contributions made to
* this file be licensed under the Apache-2.0 license or a
* compatible open source license.
*/
import jenkins.tests.BuildPipelineTest
import org.junit.Before
import org.junit.Test
import static com.lesfurets.jenkins.unit.MethodCall.callArgsToString
import static org.hamcrest.CoreMatchers.equalTo
import static org.hamcrest.CoreMatchers.hasItem
import static org.hamcrest.MatcherAssert.assertThat
class TestRunPerfTestScript extends BuildPipelineTest {
@Before
void setUp() {
this.registerLibTester(new RunPerfTestScriptLibTester(
'tests/jenkins/data/opensearch-1.3.0-bundle.yml',
'1236',
'true',
'nyc_taxis',
'1',
'1',
true
))
super.setUp()
}
@Test
public void testRunPerfTestScript_Pipeline() {
super.testPipeline("jenkins/opensearch/perf-test.jenkinsfile",
"tests/jenkins/jenkinsjob-regression-files/opensearch/perf-test-with-security.jenkinsfile")
}
@Test
void testRunPerfTestScript_verifyArtifactDownloads() {
runScript("jenkins/opensearch/perf-test.jenkinsfile")
def curlCommands = getCommandExecutions('sh', 'curl').findAll {
shCommand -> shCommand.contains('curl')
}
assertThat(curlCommands.size(), equalTo(4))
assertThat(curlCommands, hasItem(
"curl -sSL test://artifact.url --output tests/jenkins/data/opensearch-1.3.0-bundle.yml".toString()
))
def s3DownloadCommands = getCommandExecutions('s3Download', 'bucket').findAll {
shCommand -> shCommand.contains('bucket')
}
assertThat(s3DownloadCommands.size(), equalTo(2))
assertThat(s3DownloadCommands, hasItem(
"{file=config.yml, bucket=ARTIFACT_BUCKET_NAME, path=test_config/config.yml, force=true}".toString()
))
}
@Test
void testRunPerfTestScript_verifyPackageInstallation() {
runScript("jenkins/opensearch/perf-test.jenkinsfile")
def pipenvCommands = getCommandExecutions('sh', 'pipenv').findAll {
shCommand -> shCommand.contains('pipenv')
}
assertThat(pipenvCommands.size(), equalTo(2))
}
@Test
void testRunPerfTestScript_verifyScriptExecutions() {
runScript("jenkins/opensearch/perf-test.jenkinsfile")
def testScriptCommands = getCommandExecutions('sh', './test.sh').findAll {
shCommand -> shCommand.contains('./test.sh')
}
assertThat(testScriptCommands.size(), equalTo(2))
assertThat(testScriptCommands, hasItem(
"./test.sh perf-test --stack test-single-security-1236-x64-307 --bundle-manifest tests/jenkins/data/opensearch-1.3.0-bundle.yml --config config.yml --workload nyc_taxis --test-iters 1 --warmup-iters 1 ".toString()
))
assertThat(testScriptCommands, hasItem(
"./test.sh perf-test --stack test-single-1236-x64-307 --bundle-manifest tests/jenkins/data/opensearch-1.3.0-bundle.yml --config config.yml --without-security --workload nyc_taxis --test-iters 1 --warmup-iters 1 ".toString()
))
def resultUploadScriptCommands = getCommandExecutions('s3Upload', 'test-results').findAll {
shCommand -> shCommand.contains('test-results')
}
assertThat(resultUploadScriptCommands.size(), equalTo(2))
assertThat(resultUploadScriptCommands, hasItem(
"{file=test-results, bucket=ARTIFACT_BUCKET_NAME, path=perf-test/1.3.0/1236/linux/x64/tar/test-results/307}".toString()
))
}
def getCommandExecutions(methodName, command) {
def shCommands = helper.callStack.findAll {
call ->
call.methodName == methodName
}.
collect {
call ->
callArgsToString(call)
}.findAll {
shCommand ->
shCommand.contains(command)
}
return shCommands
}
}