20
20
21
21
class EventDispatcherTest {
22
22
23
+ public static final String FINALIZER_NAME = "finalizer" ;
23
24
private CustomResource testCustomResource ;
24
25
private EventDispatcher eventDispatcher ;
25
- private ResourceController <CustomResource > controller = mock (ResourceController .class );
26
- private EventDispatcher .CustomResourceFacade customResourceFacade = mock (EventDispatcher .CustomResourceFacade .class );
26
+ private final ResourceController <CustomResource > controller = mock (ResourceController .class );
27
+ private final EventDispatcher .CustomResourceFacade customResourceFacade = mock (EventDispatcher .CustomResourceFacade .class );
27
28
28
29
@ BeforeEach
29
30
void setup () {
30
31
eventDispatcher = new EventDispatcher (controller ,
31
- controller . getDefaultFinalizerName () , customResourceFacade , false );
32
+ FINALIZER_NAME , customResourceFacade , false );
32
33
33
34
testCustomResource = getResource ();
34
35
@@ -45,7 +46,7 @@ void callCreateOrUpdateOnNewResource() {
45
46
46
47
@ Test
47
48
void updatesOnlyStatusSubResource () {
48
- testCustomResource .getMetadata ().getFinalizers ().add (controller . getDefaultFinalizerName () );
49
+ testCustomResource .getMetadata ().getFinalizers ().add (FINALIZER_NAME );
49
50
when (controller .createOrUpdateResource (eq (testCustomResource ), any ()))
50
51
.thenReturn (UpdateControl .updateStatusSubResource (testCustomResource ));
51
52
@@ -67,13 +68,13 @@ void adsDefaultFinalizerOnCreateIfNotThere() {
67
68
eventDispatcher .handleEvent (customResourceEvent (Watcher .Action .MODIFIED , testCustomResource ));
68
69
verify (controller , times (1 ))
69
70
.createOrUpdateResource (argThat (testCustomResource ->
70
- testCustomResource .getMetadata ().getFinalizers ().contains (controller . getDefaultFinalizerName () )), any ());
71
+ testCustomResource .getMetadata ().getFinalizers ().contains (FINALIZER_NAME )), any ());
71
72
}
72
73
73
74
@ Test
74
75
void callsDeleteIfObjectHasFinalizerAndMarkedForDelete () {
75
76
testCustomResource .getMetadata ().setDeletionTimestamp ("2019-8-10" );
76
- testCustomResource .getMetadata ().getFinalizers ().add (controller . getDefaultFinalizerName () );
77
+ testCustomResource .getMetadata ().getFinalizers ().add (FINALIZER_NAME );
77
78
78
79
eventDispatcher .handleEvent (customResourceEvent (Watcher .Action .MODIFIED , testCustomResource ));
79
80
@@ -172,9 +173,8 @@ void doesNotMarkNewGenerationInCaseOfException() {
172
173
.thenThrow (new IllegalStateException ("Exception for testing purposes" ))
173
174
.thenReturn (UpdateControl .noUpdate ());
174
175
175
- Assertions .assertThrows (IllegalStateException .class , () -> {
176
- eventDispatcher .handleEvent (customResourceEvent (Watcher .Action .MODIFIED , testCustomResource ));
177
- });
176
+ Assertions .assertThrows (IllegalStateException .class , () ->
177
+ eventDispatcher .handleEvent (customResourceEvent (Watcher .Action .MODIFIED , testCustomResource )));
178
178
eventDispatcher .handleEvent (customResourceEvent (Watcher .Action .MODIFIED , testCustomResource ));
179
179
180
180
verify (controller , times (2 )).createOrUpdateResource (eq (testCustomResource ), any ());
@@ -183,7 +183,7 @@ void doesNotMarkNewGenerationInCaseOfException() {
183
183
184
184
void generationAwareMode () {
185
185
eventDispatcher = new EventDispatcher (controller ,
186
- controller . getDefaultFinalizerName () , customResourceFacade , true );
186
+ FINALIZER_NAME , customResourceFacade , true );
187
187
}
188
188
189
189
private void markForDeletion (CustomResource customResource ) {
@@ -202,7 +202,7 @@ CustomResource getResource() {
202
202
.withDeletionGracePeriodSeconds (10L )
203
203
.withGeneration (10L )
204
204
.withName ("name" )
205
- .withFinalizers (controller . getDefaultFinalizerName () )
205
+ .withFinalizers (FINALIZER_NAME )
206
206
.withNamespace ("namespace" )
207
207
.withResourceVersion ("resourceVersion" )
208
208
<
629A
/td> .withSelfLink ("selfLink" )
0 commit comments