Skip to content

Commit

Permalink
refactor: ApplyService only accessible through JKubeServiceHub
Browse files Browse the repository at this point in the history
Signed-off-by: Marc Nuri <marc@marcnuri.com>
  • Loading branch information
manusa committed Jan 11, 2024
1 parent 275dc11 commit d8a1edd
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ public class ApplyService {
// This map is to track projects created.
private static final Set<String> projectsCreated = new HashSet<>();

public ApplyService(JKubeServiceHub serviceHub) {
ApplyService(JKubeServiceHub serviceHub) {
this.kubernetesClient = serviceHub.getClient();
this.log = serviceHub.getLog();
this.patchService = new PatchService(kubernetesClient);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ void setUp() {
.platformMode(RuntimeMode.KUBERNETES)
.clusterAccess(new ClusterAccess(ClusterConfiguration.from(kubernetesClient.getConfiguration()).build()))
.build();
applyService = new ApplyService(serviceHub);
applyService = serviceHub.getApplyService();
applyService.setNamespace("default");
kubernetesMockServer.expect()
.get()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ void setUp() {
.platformMode(RuntimeMode.KUBERNETES)
.clusterAccess(new ClusterAccess(ClusterConfiguration.from(client.getConfiguration()).build()))
.build();
applyService = new ApplyService(serviceHub);
applyService = serviceHub.getApplyService();
applyService.setNamespace("default");
// In OpenShift
mockServer.expect()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -92,9 +92,8 @@ void setUp() {
.clusterAccess(new ClusterAccess(ClusterConfiguration.from(kubernetesClient.getConfiguration()).build()))
.build();
singleThreadExecutor = Executors.newSingleThreadExecutor();
final ApplyService applyService = new ApplyService(serviceHub);
applyService.setNamespace(kubernetesClient.getNamespace());
debugService = new DebugService(logger, kubernetesClient, new PortForwardService(logger), applyService);
serviceHub.getApplyService().setNamespace(kubernetesClient.getNamespace());
debugService = new DebugService(logger, kubernetesClient, new PortForwardService(logger), serviceHub.getApplyService());
}

@AfterEach
Expand Down

0 comments on commit d8a1edd

Please sign in to comment.