20
20
import java .util .HashMap ;
21
21
import java .util .Map ;
22
22
import java .util .Optional ;
23
+ import java .util .Properties ;
23
24
24
25
import io .fabric8 .kubernetes .client .server .mock .EnableKubernetesMockClient ;
25
26
import io .fabric8 .kubernetes .client .server .mock .KubernetesMockServer ;
47
48
import org .eclipse .jkube .kit .config .service .BuildServiceConfig ;
48
49
import org .eclipse .jkube .kit .config .service .JKubeServiceException ;
49
50
import org .eclipse .jkube .kit .config .service .JKubeServiceHub ;
51
+ import org .eclipse .jkube .kit .config .resource .MetaDataConfig ;
50
52
51
53
import com .google .common .collect .ImmutableMap ;
52
54
import io .fabric8 .kubernetes .api .model .KubernetesList ;
@@ -109,6 +111,10 @@ class OpenshiftBuildServiceIntegrationTest {
109
111
private BuildServiceConfig .BuildServiceConfigBuilder dockerImageConfig ;
110
112
111
113
private ResourceConfig resourceConfig ;
114
+
115
+ private MetaDataConfig labels ;
116
+
117
+ private Properties props ;
112
118
113
119
@ BeforeEach
114
120
void init (@ TempDir Path temporaryFolder ) throws Exception {
@@ -126,8 +132,12 @@ void init(@TempDir Path temporaryFolder) throws Exception {
126
132
jKubeBuildTarArchiver = mockConstruction (JKubeBuildTarArchiver .class , (mock , ctx ) ->
127
133
when (mock .createArchive (any (File .class ), any (BuildDirs .class ), eq (ArchiveCompression .none )))
128
134
.thenReturn (emptyDockerBuildTar ));
129
-
130
- resourceConfig = ResourceConfig .builder ().namespace ("ns1" ).build ();
135
+
136
+ props = new Properties ();
137
+ props .setProperty ("buildName" , projectName );
138
+
139
+ labels = MetaDataConfig .builder ().all (props ).pod (props ).build ();
140
+ resourceConfig = ResourceConfig .builder ().namespace ("ns1" ).labels (labels ).build ();
131
141
132
142
jKubeServiceHub = mock (JKubeServiceHub .class , RETURNS_DEEP_STUBS );
133
143
when (jKubeServiceHub .getClient ()).thenReturn (client );
@@ -552,6 +562,7 @@ private WebServerEventCollector prepareMockServer(
552
562
.build ();
553
563
554
564
if (!buildConfigExists ) {
565
+ mockServer .expect ().get ().withPath ("/api/v1/namespaces/ns1/pods?labelSelector=openshift.io%2Fbuild.name" ).andReply (collector .record ("build-config-check" ).andReturn (200 , bc )).always ();
555
566
mockServer .expect ().get ().withPath ("/apis/build.openshift.io/v1/namespaces/ns1/buildconfigs/" + resourceName + s2iBuildNameSuffix ).andReply (collector .record ("build-config-check" ).andReturn
556
567
(404 , "" )).once ();
557
568
mockServer .expect ().get ().withPath ("/apis/build.openshift.io/v1/namespaces/ns1/buildconfigs/" + resourceName + s2iBuildNameSuffix + "pullSecret" ).andReply (collector .record ("build-config-check" ).andReturn
@@ -560,7 +571,7 @@ private WebServerEventCollector prepareMockServer(
560
571
if (bcSecret != null ) {
561
572
mockServer .expect ().post ().withPath ("/apis/build.openshift.io/v1/namespaces/ns1/buildconfigs" ).andReply (collector .record ("new-build-config" ).andReturn (201 , bcSecret )).once ();
562
573
}
563
- } else {
574
+ } else {
564
575
mockServer .expect ().patch ().withPath ("/apis/build.openshift.io/v1/namespaces/ns1/buildconfigs/" + resourceName + s2iBuildNameSuffix ).andReply (collector .record ("patch-build-config" ).andReturn
565
576
(200 , bc )).once ();
566
577
if (bcSecret != null ) {
@@ -579,6 +590,7 @@ private WebServerEventCollector prepareMockServer(
579
590
if (!imageStreamExists ) {
580
591
mockServer .expect ().get ().withPath ("/apis/image.openshift.io/v1/namespaces/ns1/imagestreams/" + resourceName ).andReturn (404 , "" ).once ();
581
592
}
593
+ mockServer .expect ().get ().withPath ("/api/v1/namespaces/ns1/pods?labelSelector=openshift.io%2Fbuild.name" ).andReply (collector .record ("build-config-check" ).andReturn (200 , bc )).always ();
582
594
mockServer .expect ().get ().withPath ("/apis/image.openshift.io/v1/namespaces/ns1/imagestreams/" + resourceName ).andReturn (200 , imageStream ).always ();
583
595
584
596
mockServer .expect ().post ().withPath ("/apis/image.openshift.io/v1/namespaces/ns1/imagestreams" ).andReturn (201 , imageStream ).once ();
0 commit comments