feat: support-cross-subaccount-consumption (#122)

Co-authored-by: sjvans <[email protected]>

Author: t-bonk

README.md

@@ -101,9 +101,10 @@ Please see [Validation of VMR Provisioning](https://help.sap.com/docs/sap-integr
 
 Additional configuration options for the messaging service are:
 
-Property | Type | Description |
- | --- | --- | --- |
+ Property                                                            | Type      | Description                                                                                                                                           |
+ |---------------------------------------------------------------------|-----------|-------------------------------------------------------------------------------------------------------------------------------------------------------|
 | `cds.messaging.services.<key>.connection.properties.skipManagement` | `boolean` | If set to `true`, the plugin will not create a queue or subscription. This is useful if you want to manage these resources manually, default: `false` |
+| `cds.messaging.services.<key>.connection.properties.subaccountId`   | `String`  | If set to a subaccount ID, the plugin will call the validation service with that given value, default: `null`                                         |
 
 
 ## Support, Feedback, Contributing

cds-feature-advanced-event-mesh/src/main/java/com/sap/cds/feature/messaging/aem/client/AemValidationClient.java

@@ -1,10 +1,12 @@
 package com.sap.cds.feature.messaging.aem.client;
 
+import com.google.common.base.Strings;
 import com.sap.cloud.environment.servicebinding.api.ServiceBinding;
 import com.sap.cloud.sdk.cloudplatform.connectivity.ServiceBindingDestinationOptions;
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
+import java.util.HashMap;
 import java.util.Map;
 
 public class AemValidationClient extends RestClient {
@@ -13,9 +15,15 @@ public AemValidationClient(ServiceBinding binding) {
     super(ServiceBindingDestinationOptions.forService(binding).build());
   }
 
-  public void validate(String managementUri) throws IOException, URISyntaxException {
+  public void validate(String managementUri, String subaccountId) throws IOException, URISyntaxException {
     URI uri = new URI(managementUri);
-    String payload = this.mapper.writeValueAsString(Map.of("hostName", uri.getHost()));
+    Map<String, String> payloadMap = new HashMap<>(Map.of("hostName", uri.getHost()));
+
+    if (!Strings.isNullOrEmpty(subaccountId)) {
+      payloadMap.put("subaccountId", subaccountId);
+    }
+
+    String payload = this.mapper.writeValueAsString(payloadMap);
 
     // The response is not used, only the status code is relevant. If there is a status code not
     // equal to 200,

cds-feature-advanced-event-mesh/src/main/java/com/sap/cds/feature/messaging/aem/service/AemMessagingService.java

@@ -38,6 +38,7 @@ public class AemMessagingService extends AbstractMessagingService {
   private volatile BrokerConnection connection;
   private volatile Boolean aemBrokerValidated = false;
   private volatile Boolean skipManagement = false;
+  private volatile String subaccountId = null;
 
   @SuppressWarnings("OptionalUsedAsFieldOrParameterType")
   protected AemMessagingService(
@@ -57,6 +58,9 @@ protected AemMessagingService(
     String skipManagementProperty = properties.get("skipManagement");
     String skip_ManagementProperty = properties.get("skip-management");
     this.skipManagement = Boolean.parseBoolean(skipManagementProperty) || Boolean.parseBoolean(skip_ManagementProperty);
+    String subaccountId = properties.getOrDefault("subaccountId", null);
+    String subaccount_Id = properties.getOrDefault("subaccount-id", null);
+    this.subaccountId = subaccountId != null ? subaccountId : subaccount_Id;
   }
 
   @VisibleForTesting
@@ -163,7 +167,7 @@ private void validate(String endpoint) {
       AemValidationClient validationClient = new AemValidationClient(this.validationBinding);
 
       try {
-        validationClient.validate(endpoint);
+        validationClient.validate(endpoint, this.subaccountId);
         this.aemBrokerValidated = true;
       } catch (IOException | URISyntaxException e) {
         throw new ServiceException("Failed to validate the AEM endpoint.", e);