Skip to content

Commit 2f35a2f

Browse files
committed
Fixes from comments
1 parent 0f9090f commit 2f35a2f

File tree

5 files changed

+86
-158
lines changed

5 files changed

+86
-158
lines changed

multiapps-controller-process/src/main/java/org/cloudfoundry/multiapps/controller/process/util/DependentModuleStopResolver.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,15 +42,16 @@ public List<Module> resolveDependentModulesToStop(ProcessContext context, Module
4242

4343
List<Module> result = new ArrayList<>();
4444
Set<String> visited = new HashSet<>();
45+
visited.add(root.getName());
4546

4647
collectModulesDependentOnPostOrder(root.getName(), modulesDependentOn, visited, result);
47-
48-
result.remove(root);
48+
4949
return result;
5050
}
5151

5252
private boolean isDependencyAwareStopOrderEnabled(ProcessContext context, DeploymentDescriptor descriptor) {
53-
boolean isExplicitlySetFromContext = VariableHandling.get(context.getExecution(), Variables.STOP_ORDER_IS_DEPENDENCY_AWARE);
53+
boolean isExplicitlySetFromContext = Boolean.TRUE.equals(
54+
VariableHandling.get(context.getExecution(), Variables.STOP_ORDER_IS_DEPENDENCY_AWARE));
5455
if (isExplicitlySetFromContext) {
5556
return true;
5657
}

multiapps-controller-process/src/test/java/org/cloudfoundry/multiapps/controller/process/steps/BuildApplicationDeployModelStepTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ void testModuleResolutionAsyncServiceBindings() {
4040
}
4141

4242
@Test
43-
void testModuleResolutionAsyncServiceBindings1() {
43+
void testModuleResolutionAsyncServiceBindingsAfterResume() {
4444
Module module = Module.createV3()
4545
.setName("test-module");
4646
setUpMocks(module);

multiapps-controller-process/src/test/java/org/cloudfoundry/multiapps/controller/process/steps/PrepareToStopDependentModuleStepTest.java

Lines changed: 2 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,9 @@
77
import org.cloudfoundry.multiapps.controller.client.facade.domain.ImmutableStaging;
88
import org.cloudfoundry.multiapps.controller.client.facade.domain.Staging;
99
import org.cloudfoundry.multiapps.controller.client.lib.domain.ImmutableCloudApplicationExtended;
10-
import org.cloudfoundry.multiapps.controller.core.cf.util.ModulesCloudModelBuilderContentCalculator;
1110
import org.cloudfoundry.multiapps.controller.core.cf.v2.ApplicationCloudModelBuilder;
12-
import org.cloudfoundry.multiapps.controller.core.cf.v2.ServiceKeysCloudModelBuilder;
1311
import org.cloudfoundry.multiapps.controller.core.helpers.ModuleToDeployHelper;
1412
import org.cloudfoundry.multiapps.controller.process.util.ApplicationEnvironmentCalculator;
15-
import org.cloudfoundry.multiapps.controller.process.util.DeprecatedBuildpackChecker;
16-
import org.cloudfoundry.multiapps.controller.process.util.ProcessTypeParser;
1713
import org.cloudfoundry.multiapps.controller.process.variables.Variables;
1814
import org.cloudfoundry.multiapps.mta.model.DeploymentDescriptor;
1915
import org.cloudfoundry.multiapps.mta.model.Module;
@@ -30,17 +26,7 @@ class PrepareToStopDependentModuleStepTest extends SyncFlowableStepTest<PrepareT
3026
private ModuleToDeployHelper moduleToDeployHelper;
3127

3228
@Mock
33-
protected ApplicationCloudModelBuilder applicationCloudModelBuilder;
34-
@Mock
35-
protected ModulesCloudModelBuilderContentCalculator modulesCloudModelBuilderContentCalculator;
36-
@Mock
37-
protected ServiceKeysCloudModelBuilder serviceKeysCloudModelBuilder;
38-
39-
@Mock
40-
private ProcessTypeParser processTypeParser;
41-
42-
@Mock
43-
private DeprecatedBuildpackChecker deprecatedBuildpackChecker;
29+
private ApplicationCloudModelBuilder applicationCloudModelBuilder;
4430

4531
@Mock
4632
private ApplicationEnvironmentCalculator applicationEnvironmentCalculator;
@@ -73,7 +59,7 @@ void testPrepareToStopDependentModuleStepIdleURIs() {
7359
.getName(), module.getName());
7460
assertStepFinishedSuccessfully();
7561
}
76-
62+
7763
private void setUpMocks(Module module) {
7864
DeploymentDescriptor completeDeploymentDescriptor = DeploymentDescriptor.createV3();
7965
completeDeploymentDescriptor.setModules(List.of(module));

multiapps-controller-process/src/test/java/org/cloudfoundry/multiapps/controller/process/steps/PrepareToStopDependentModulesStepTest.java

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,10 @@
33
import java.util.Collections;
44
import java.util.List;
55

6+
import org.cloudfoundry.multiapps.controller.core.model.SubprocessPhase;
67
import org.cloudfoundry.multiapps.controller.process.variables.Variables;
78
import org.cloudfoundry.multiapps.mta.model.Module;
9+
import org.junit.jupiter.api.Assertions;
810
import org.junit.jupiter.api.Test;
911

1012
class PrepareToStopDependentModulesStepTest extends SyncFlowableStepTest<PrepareToStopDependentModulesStep> {
@@ -13,17 +15,23 @@ class PrepareToStopDependentModulesStepTest extends SyncFlowableStepTest<Prepare
1315
void testPrepareToStopDependentModulesStepEmpty() {
1416
context.setVariable(Variables.DEPENDENT_MODULES_TO_STOP, Collections.emptyList());
1517
step.execute(execution);
16-
context.setVariable(Variables.APPS_TO_STOP_COUNT, 0);
1718
assertStepFinishedSuccessfully();
19+
Assertions.assertEquals(context.getVariable(Variables.APPS_TO_STOP_INDEX), 0);
20+
Assertions.assertEquals(context.getVariable(Variables.SUBPROCESS_PHASE), SubprocessPhase.BEFORE_APPLICATION_STOP);
21+
Assertions.assertEquals(context.getVariable(Variables.APPS_TO_STOP_COUNT), 0);
22+
Assertions.assertEquals(context.getVariable(Variables.INDEX_VARIABLE_NAME), Variables.APPS_TO_STOP_INDEX.getName());
1823
}
1924

2025
@Test
2126
void testPrepareToStopDependentModulesStepTest() {
2227
context.setVariable(Variables.DEPENDENT_MODULES_TO_STOP, List.of(Module.createV3()
2328
.setName("module")));
2429
step.execute(execution);
25-
context.setVariable(Variables.APPS_TO_STOP_COUNT, 1);
2630
assertStepFinishedSuccessfully();
31+
Assertions.assertEquals(context.getVariable(Variables.APPS_TO_STOP_INDEX), 0);
32+
Assertions.assertEquals(context.getVariable(Variables.SUBPROCESS_PHASE), SubprocessPhase.BEFORE_APPLICATION_STOP);
33+
Assertions.assertEquals(context.getVariable(Variables.APPS_TO_STOP_COUNT), 1);
34+
Assertions.assertEquals(context.getVariable(Variables.INDEX_VARIABLE_NAME), Variables.APPS_TO_STOP_INDEX.getName());
2735
}
2836

2937
@Override

0 commit comments

Comments
 (0)