DefaultDomains: constructor takes XyzClient, not Mono<XyzClient>

Author: Kehrlann

cloudfoundry-operations/src/main/java/org/cloudfoundry/operations/_DefaultCloudFoundryOperations.java

@@ -91,7 +91,15 @@ public Buildpacks buildpacks() {
     @Override
     @Value.Derived
     public Domains domains() {
-        return new DefaultDomains(getCloudFoundryClientPublisher(), getRoutingClientPublisher());
+        CloudFoundryClient cloudFoundryClient = getCloudFoundryClient();
+        if (cloudFoundryClient == null) {
+            throw new IllegalStateException("CloudFoundryClient must be set");
+        }
+        RoutingClient routingClient = getRoutingClient();
+        if (routingClient == null) {
+            throw new IllegalStateException("RoutingClient must be set");
+        }
+        return new DefaultDomains(cloudFoundryClient, routingClient);
     }
 
     @Override

cloudfoundry-operations/src/main/java/org/cloudfoundry/operations/domains/DefaultDomains.java

@@ -45,32 +45,32 @@
 
 public final class DefaultDomains implements Domains {
 
-    private final Mono<CloudFoundryClient> cloudFoundryClient;
+    private final CloudFoundryClient cloudFoundryClient;
 
-    private final Mono<RoutingClient> routingClient;
+    private final RoutingClient routingClient;
 
-    public DefaultDomains(
-            Mono<CloudFoundryClient> cloudFoundryClient, Mono<RoutingClient> routingClient) {
+    public DefaultDomains(CloudFoundryClient cloudFoundryClient, RoutingClient routingClient) {
         this.cloudFoundryClient = cloudFoundryClient;
         this.routingClient = routingClient;
     }
 
+    /**
+     * @deprecated use {@link DefaultDomains(CloudFoundryClient, RoutingClient)} instead.
+     */
+    @Deprecated
+    public DefaultDomains(
+            Mono<CloudFoundryClient> cloudFoundryClient, Mono<RoutingClient> routingClient) {
+        this.cloudFoundryClient = cloudFoundryClient.block();
+        this.routingClient = routingClient.block();
+    }
+
     @Override
     public Mono<Void> create(CreateDomainRequest request) {
-        return this.cloudFoundryClient
-                .flatMap(
-                        cloudFoundryClient ->
-                                Mono.zip(
-                                        Mono.just(cloudFoundryClient),
-                                        getOrganizationId(
-                                                cloudFoundryClient, request.getOrganization())))
+        return getOrganizationId(cloudFoundryClient, request.getOrganization())
                 .flatMap(
-                        function(
-                                (cloudFoundryClient, organizationId) ->
-                                        requestCreateDomain(
-                                                cloudFoundryClient,
-                                                request.getDomain(),
-                                                organizationId)))
+                        organizationId ->
+                                requestCreateDomain(
+                                        cloudFoundryClient, request.getDomain(), organizationId))
                 .then()
                 .transform(OperationsLogging.log("Create Domain"))
                 .checkpoint();
@@ -79,31 +79,16 @@ public Mono<Void> create(CreateDomainRequest request) {
     @Override
     public Mono<Void> createShared(CreateSharedDomainRequest request) {
         if (request.getRouterGroup() == null) {
-            return this.cloudFoundryClient
-                    .flatMap(
-                            cloudFoundryClient ->
-                                    requestCreateSharedDomain(
-                                            cloudFoundryClient, request.getDomain(), null))
+            return requestCreateSharedDomain(cloudFoundryClient, request.getDomain(), null)
                     .then()
                     .transform(OperationsLogging.log("Create Shared Domain"))
                     .checkpoint();
         } else {
-            return Mono.zip(this.cloudFoundryClient, this.routingClient)
-                    .flatMap(
-                            function(
-                                    (cloudFoundryClient, routingClient) ->
-                                            Mono.zip(
-                                                    Mono.just(cloudFoundryClient),
-                                                    getRouterGroupId(
-                                                            routingClient,
-                                                            request.getRouterGroup()))))
+            return getRouterGroupId(routingClient, request.getRouterGroup())
                     .flatMap(
-                            function(
-                                    (cloudFoundryClient, routerGroupId) ->
-                                            requestCreateSharedDomain(
-                                                    cloudFoundryClient,
-                                                    request.getDomain(),
-                                                    routerGroupId)))
+                            routerGroupId ->
+                                    requestCreateSharedDomain(
+                                            cloudFoundryClient, request.getDomain(), routerGroupId))
                     .then()
                     .transform(OperationsLogging.log("Create Shared Domain"))
                     .checkpoint();
@@ -112,22 +97,17 @@ public Mono<Void> createShared(CreateSharedDomainRequest request) {
 
     @Override
     public Flux<Domain> list() {
-        return this.cloudFoundryClient
-                .flatMapMany(
-                        cloudFoundryClient ->
-                                requestListPrivateDomains(cloudFoundryClient)
-                                        .map(DefaultDomains::toDomain)
-                                        .mergeWith(
-                                                requestListSharedDomains(cloudFoundryClient)
-                                                        .map(DefaultDomains::toDomain)))
+        return requestListPrivateDomains(cloudFoundryClient)
+                .map(DefaultDomains::toDomain)
+                .mergeWith(
+                        requestListSharedDomains(cloudFoundryClient).map(DefaultDomains::toDomain))
                 .transform(OperationsLogging.log("List Domains"))
                 .checkpoint();
     }
 
     @Override
     public Flux<RouterGroup> listRouterGroups() {
-        return this.routingClient
-                .flatMapMany(DefaultDomains::requestListRouterGroups)
+        return requestListRouterGroups(routingClient)
                 .flatMapIterable(ListRouterGroupsResponse::getRouterGroups)
                 .map(DefaultDomains::toRouterGroup)
                 .transform(OperationsLogging.log("List Router Groups"))
@@ -136,31 +116,21 @@ public Flux<RouterGroup> listRouterGroups() {
 
     @Override
     public Mono<Void> share(ShareDomainRequest request) {
-        return this.cloudFoundryClient
-                .flatMap(
-                        cloudFoundryClient ->
-                                Mono.zip(
-                                        Mono.just(cloudFoundryClient),
-                                        getPrivateDomainId(cloudFoundryClient, request.getDomain()),
-                                        getOrganizationId(
-                                                cloudFoundryClient, request.getOrganization())))
-                .flatMap(function(DefaultDomains::requestAssociateOrganizationPrivateDomainRequest))
+        return Mono.zip(
+                        getPrivateDomainId(cloudFoundryClient, request.getDomain()),
+                        getOrganizationId(cloudFoundryClient, request.getOrganization()))
+                .flatMap(function(this::requestAssociateOrganizationPrivateDomainRequest))
                 .then()
                 .transform(OperationsLogging.log("Share Domain"))
                 .checkpoint();
     }
 
     @Override
     public Mono<Void> unshare(UnshareDomainRequest request) {
-        return this.cloudFoundryClient
-                .flatMap(
-                        cloudFoundryClient ->
-                                Mono.zip(
-                                        Mono.just(cloudFoundryClient),
-                                        getPrivateDomainId(cloudFoundryClient, request.getDomain()),
-                                        getOrganizationId(
-                                                cloudFoundryClient, request.getOrganization())))
-                .flatMap(function(DefaultDomains::requestRemoveOrganizationPrivateDomainRequest))
+        return Mono.zip(
+                        getPrivateDomainId(cloudFoundryClient, request.getDomain()),
+                        getOrganizationId(cloudFoundryClient, request.getOrganization()))
+                .flatMap(function(this::requestRemoveOrganizationPrivateDomainRequest))
                 .transform(OperationsLogging.log("Unshare Domain"))
                 .checkpoint();
     }
@@ -205,10 +175,10 @@ private static Mono<String> getRouterGroupId(RoutingClient routingClient, String
                 .map(org.cloudfoundry.routing.v1.routergroups.RouterGroup::getRouterGroupId);
     }
 
-    private static Mono<AssociateOrganizationPrivateDomainResponse>
+    private Mono<AssociateOrganizationPrivateDomainResponse>
             requestAssociateOrganizationPrivateDomainRequest(
-                    CloudFoundryClient cloudFoundryClient, String domainId, String organizationId) {
-        return cloudFoundryClient
+                    String domainId, String organizationId) {
+        return this.cloudFoundryClient
                 .organizations()
                 .associatePrivateDomain(
                         AssociateOrganizationPrivateDomainRequest.builder()
@@ -292,9 +262,9 @@ private static Flux<OrganizationResource> requestOrganizations(
                                                 .build()));
     }
 
-    private static Mono<Void> requestRemoveOrganizationPrivateDomainRequest(
-            CloudFoundryClient cloudFoundryClient, String domainId, String organizationId) {
-        return cloudFoundryClient
+    private Mono<Void> requestRemoveOrganizationPrivateDomainRequest(
+            String domainId, String organizationId) {
+        return this.cloudFoundryClient
                 .organizations()
                 .removePrivateDomain(
                         RemoveOrganizationPrivateDomainRequest.builder()

cloudfoundry-operations/src/test/java/org/cloudfoundry/operations/domains/DefaultDomainsTest.java

@@ -49,7 +49,7 @@
 final class DefaultDomainsTest extends AbstractOperationsTest {
 
     private final DefaultDomains domains =
-            new DefaultDomains(Mono.just(this.cloudFoundryClient), Mono.just(this.routingClient));
+            new DefaultDomains(this.cloudFoundryClient, this.routingClient);
 
     @Test
     void createDomain() {