feat(server): Enable upcoming integrations endpoint

app/server/appsmith-server/src/main/java/com/appsmith/server/controllers/PluginController.java

@@ -1,5 +1,6 @@
 package com.appsmith.server.controllers;
 
+import com.appsmith.server.configurations.CloudServicesConfig;
 import com.appsmith.server.constants.Url;
 import com.appsmith.server.controllers.ce.PluginControllerCE;
 import com.appsmith.server.plugins.base.PluginService;
@@ -11,7 +12,10 @@
 @RequestMapping(Url.PLUGIN_URL)
 public class PluginController extends PluginControllerCE {
 
-    public PluginController(PluginService service, PluginTriggerSolution pluginTriggerSolution) {
-        super(service, pluginTriggerSolution);
+    public PluginController(
+            PluginService service,
+            PluginTriggerSolution pluginTriggerSolution,
+            CloudServicesConfig cloudServicesConfig) {
+        super(service, pluginTriggerSolution, cloudServicesConfig);
     }
 }

app/server/appsmith-server/src/main/java/com/appsmith/server/controllers/ce/PluginControllerCE.java

@@ -3,12 +3,14 @@
 import com.appsmith.external.models.TriggerRequestDTO;
 import com.appsmith.external.models.TriggerResultDTO;
 import com.appsmith.external.views.Views;
+import com.appsmith.server.configurations.CloudServicesConfig;
 import com.appsmith.server.constants.FieldName;
 import com.appsmith.server.constants.Url;
 import com.appsmith.server.domains.Plugin;
 import com.appsmith.server.dtos.ResponseDTO;
 import com.appsmith.server.plugins.base.PluginService;
 import com.appsmith.server.plugins.solutions.PluginTriggerSolution;
+import com.appsmith.util.WebClientUtils;
 import com.fasterxml.jackson.annotation.JsonView;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -28,6 +30,7 @@
 import reactor.core.publisher.Mono;
 
 import java.util.List;
+import java.util.Map;
 
 @RequestMapping(Url.PLUGIN_URL)
 @RequiredArgsConstructor
@@ -38,6 +41,8 @@ public class PluginControllerCE {
 
     private final PluginTriggerSolution pluginTriggerSolution;
 
+    private final CloudServicesConfig cloudServicesConfig;
+
     @JsonView(Views.Public.class)
     @GetMapping
     public Mono<ResponseDTO<List<Plugin>>> getAll(@RequestParam String workspaceId) {
@@ -96,4 +101,29 @@ public Mono<ResponseDTO<TriggerResultDTO>> triggerMultipart(
                         serverWebExchange.getRequest().getHeaders())
                 .map(triggerResultDTO -> new ResponseDTO<>(HttpStatus.OK, triggerResultDTO));
     }
+
+    @JsonView(Views.Public.class)
+    @GetMapping("/upcoming-integrations")
+    public Mono<ResponseDTO<List<Map<String, String>>>> getUpcomingIntegrations() {
+        log.debug("Fetching upcoming integrations from external API");
+
+        String apiUrl = cloudServicesConfig.getBaseUrl() + "/api/v1/config/external-saas/upcoming-integrations";
+
+        return WebClientUtils.create()
+                .get()
+                .uri(apiUrl)
+                .retrieve()
+                .bodyToMono(Map.class)
+                .map(response -> {
+                    // Extract the integrations list from the response
+                    List<Map<String, String>> integrations =
+                            response.containsKey("data") ? (List<Map<String, String>>) response.get("data") : List.of();
+                    return new ResponseDTO<>(HttpStatus.OK, integrations);
+                })
+                .onErrorResume(error -> {
+                    log.warn("Error retrieving upcoming integrations from external service: {}", error.getMessage());
+                    return Mono.just(new ResponseDTO<>(
+                            HttpStatus.OK.value(), List.of(), "Unable to fetch upcoming integrations at this time"));
+                });
+    }
 }