Add Domains V3 resource to CloudFoundryClient

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/client/_ReactorCloudFoundryClient.java

@@ -51,6 +51,7 @@
 import org.cloudfoundry.client.v3.applications.ApplicationsV3;
 import org.cloudfoundry.client.v3.builds.Builds;
 import org.cloudfoundry.client.v3.deployments.DeploymentsV3;
+import org.cloudfoundry.client.v3.domains.DomainsV3;
 import org.cloudfoundry.client.v3.droplets.Droplets;
 import org.cloudfoundry.client.v3.isolationsegments.IsolationSegments;
 import org.cloudfoundry.client.v3.jobs.JobsV3;
@@ -97,6 +98,7 @@
 import org.cloudfoundry.reactor.client.v3.applications.ReactorApplicationsV3;
 import org.cloudfoundry.reactor.client.v3.builds.ReactorBuilds;
 import org.cloudfoundry.reactor.client.v3.deployments.ReactorDeploymentsV3;
+import org.cloudfoundry.reactor.client.v3.domains.ReactorDomainsV3;
 import org.cloudfoundry.reactor.client.v3.droplets.ReactorDroplets;
 import org.cloudfoundry.reactor.client.v3.isolationsegments.ReactorIsolationSegments;
 import org.cloudfoundry.reactor.client.v3.jobs.ReactorJobsV3;
@@ -173,6 +175,12 @@ public Domains domains() {
         return new ReactorDomains(getConnectionContext(), getRootV2(), getTokenProvider(), getRequestTags());
     }
 
+    @Override
+    @Value.Derived
+    public DomainsV3 domainsV3() {
+        return new ReactorDomainsV3(getConnectionContext(), getRootV3(), getTokenProvider(), getRequestTags());
+    }
+
     @Override
     @Value.Derived
     public Droplets droplets() {

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/client/v3/domains/ReactorDomainsV3.java

@@ -0,0 +1,97 @@
+/*
+ * Copyright 2013-2020 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.cloudfoundry.reactor.client.v3.domains;
+
+import org.cloudfoundry.client.v3.domains.CreateDomainRequest;
+import org.cloudfoundry.client.v3.domains.CreateDomainResponse;
+import org.cloudfoundry.client.v3.domains.DeleteDomainRequest;
+import org.cloudfoundry.client.v3.domains.DomainsV3;
+import org.cloudfoundry.client.v3.domains.GetDomainRequest;
+import org.cloudfoundry.client.v3.domains.GetDomainResponse;
+import org.cloudfoundry.client.v3.domains.ListDomainsRequest;
+import org.cloudfoundry.client.v3.domains.ListDomainsResponse;
+import org.cloudfoundry.client.v3.domains.ShareDomainRequest;
+import org.cloudfoundry.client.v3.domains.ShareDomainResponse;
+import org.cloudfoundry.client.v3.domains.UnshareDomainRequest;
+import org.cloudfoundry.client.v3.domains.UpdateDomainRequest;
+import org.cloudfoundry.client.v3.domains.UpdateDomainResponse;
+import org.cloudfoundry.reactor.ConnectionContext;
+import org.cloudfoundry.reactor.TokenProvider;
+import org.cloudfoundry.reactor.client.v3.AbstractClientV3Operations;
+import reactor.core.publisher.Mono;
+
+import java.util.Map;
+
+/**
+ * The Reactor-based implementation of {@link DomainsV3}
+ */
+public final class ReactorDomainsV3 extends AbstractClientV3Operations implements DomainsV3 {
+
+    /**
+     * Creates an instance
+     *
+     * @param connectionContext the {@link ConnectionContext} to use when communicating with the server
+     * @param root              the root URI of the server. Typically something like {@code https://api.run.pivotal.io}.
+     * @param tokenProvider     the {@link TokenProvider} to use when communicating with the server
+     * @param requestTags       map with custom http headers which will be added to web request
+     */
+    public ReactorDomainsV3(ConnectionContext connectionContext, Mono<String> root, TokenProvider tokenProvider, Map<String, String> requestTags) {
+        super(connectionContext, root, tokenProvider, requestTags);
+    }
+
+    @Override
+    public Mono<CreateDomainResponse> create(CreateDomainRequest request) {
+        return post(request, CreateDomainResponse.class, builder -> builder.pathSegment("domains"))
+            .checkpoint();
+    }
+
+    @Override
+    public Mono<UpdateDomainResponse> update(UpdateDomainRequest request) {
+        return patch(request, UpdateDomainResponse.class, builder -> builder.pathSegment("domains", request.getDomainId()))
+            .checkpoint();
+    }
+
+    @Override
+    public Mono<String> delete(DeleteDomainRequest request) {
+        return delete(request, builder -> builder.pathSegment("domains", request.getDomainId()))
+            .checkpoint();
+    }
+
+    @Override
+    public Mono<GetDomainResponse> get(GetDomainRequest request) {
+        return get(request, GetDomainResponse.class, builder -> builder.pathSegment("domains", request.getDomainId()))
+            .checkpoint();
+    }
+
+    @Override
+    public Mono<ListDomainsResponse> list(ListDomainsRequest request) {
+        return get(request, ListDomainsResponse.class, builder -> builder.pathSegment("domains"))
+            .checkpoint();
+    }
+
+    @Override
+    public Mono<ShareDomainResponse> share(ShareDomainRequest request) {
+        return post(request, ShareDomainResponse.class, builder -> builder.pathSegment("domains", request.getDomainId(), "relationships", "shared_organizations"))
+            .checkpoint();
+    }
+
+    @Override
+    public Mono<Void> unshare(UnshareDomainRequest request) {
+        return delete(request, Void.class, builder -> builder.pathSegment("domains", request.getDomainId(), "relationships", "shared_organizations", request.getOrganizationId()))
+            .checkpoint();
+    }
+}

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/client/v3/organizations/ReactorOrganizationsV3.java

@@ -26,6 +26,8 @@
 import org.cloudfoundry.client.v3.organizations.GetOrganizationDefaultIsolationSegmentResponse;
 import org.cloudfoundry.client.v3.organizations.GetOrganizationRequest;
 import org.cloudfoundry.client.v3.organizations.GetOrganizationResponse;
+import org.cloudfoundry.client.v3.organizations.ListOrganizationDomainsRequest;
+import org.cloudfoundry.client.v3.organizations.ListOrganizationDomainsResponse;
 import org.cloudfoundry.client.v3.organizations.ListOrganizationsRequest;
 import org.cloudfoundry.client.v3.organizations.ListOrganizationsResponse;
 import org.cloudfoundry.client.v3.organizations.OrganizationsV3;
@@ -95,6 +97,12 @@ public Mono<ListOrganizationsResponse> list(ListOrganizationsRequest request) {
             .checkpoint();
     }
 
+    @Override
+    public Mono<ListOrganizationDomainsResponse> listDomains(ListOrganizationDomainsRequest request) {
+        return get(request, ListOrganizationDomainsResponse.class, builder -> builder.pathSegment("organizations", request.getOrganizationId(), "domains"))
+            .checkpoint();
+    }
+
     @Override
     public Mono<UpdateOrganizationResponse> update(UpdateOrganizationRequest request) {
         return patch(request, UpdateOrganizationResponse.class, builder -> builder.pathSegment("organizations", request.getOrganizationId()))

cloudfoundry-client-reactor/src/test/java/org/cloudfoundry/reactor/client/ReactorCloudFoundryClientTest.java

@@ -60,6 +60,11 @@ public void domains() {
         assertThat(this.client.domains()).isNotNull();
     }
 
+    @Test
+    public void domainsV3() {
+        assertThat(this.client.domainsV3()).isNotNull();
+    }
+
     @Test
     public void droplets() {
         assertThat(this.client.droplets()).isNotNull();