add flow api

Author: Thomasr

server/api-service/lowcoder-infra/src/main/java/org/lowcoder/infra/constant/NewUrl.java

@@ -11,6 +11,7 @@ private NewUrl() {
     public static final String USER_URL = PREFIX + "/users";
     public static final String CONFIG_URL = PREFIX + "/configs";
     public static final String SERVER_SETTING_URL = PREFIX + "/serverSettings";
+    public static final String FLOW_URL = PREFIX + "/flow";
     public static final String GROUP_URL = PREFIX + "/groups";
     public static final String ASSET_URL = PREFIX + "/assets";
 

server/api-service/lowcoder-infra/src/main/java/org/lowcoder/infra/constant/Url.java

@@ -7,6 +7,7 @@ public final class Url {
     public static final String DATASOURCE_URL = BASE_URL + VERSION + "/datasources";
     public static final String USER_URL = BASE_URL + VERSION + "/users";
     public static final String CONFIG_URL = BASE_URL + VERSION + "/configs";
+    public static final String FLOW_URL = BASE_URL + VERSION + "/flow";
     public static final String SERVER_SETTING_URL = BASE_URL + VERSION + "/serverSettings";
     public static final String GROUP_URL = BASE_URL + VERSION + "/groups";
     public static final String ASSET_URL = BASE_URL + VERSION + "/assets";

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/framework/security/SecurityConfig.java

@@ -95,6 +95,7 @@ SecurityWebFilterChain securityWebFilterChain(ServerHttpSecurity http) {
                         // used in public viewed apps
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, CONFIG_URL), // system config
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, SERVER_SETTING_URL), // system env
+                        ServerWebExchangeMatchers.pathMatchers(HttpMethod.POST, FLOW_URL), // system config
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, CONFIG_URL + "/deploymentId"), // system config
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, APPLICATION_URL + "/*"), // application view
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, APPLICATION_URL + "/*/view"), // application view
@@ -124,6 +125,8 @@ SecurityWebFilterChain securityWebFilterChain(ServerHttpSecurity http) {
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, NewUrl.INVITATION_URL + "/**"),
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.POST, NewUrl.CUSTOM_AUTH + "/logout"),
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, NewUrl.CONFIG_URL),
+                        ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, NewUrl.SERVER_SETTING_URL), // system env
+                        ServerWebExchangeMatchers.pathMatchers(HttpMethod.POST, NewUrl.FLOW_URL),
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, NewUrl.CONFIG_URL + "/deploymentId"),
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.HEAD, NewUrl.STATE_URL + "/healthCheck"),
                         ServerWebExchangeMatchers.pathMatchers(HttpMethod.GET, NewUrl.PREFIX + "/status/**"),

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/misc/ApiFlowController.java

@@ -0,0 +1,49 @@
+package org.lowcoder.api.misc;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.lowcoder.api.authentication.request.AuthException;
+import org.lowcoder.sdk.util.JsonUtils;
+import org.lowcoder.sdk.webclient.WebClientBuildHelper;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.reactive.function.BodyInserters;
+import reactor.core.publisher.Mono;
+
+import java.util.Map;
+import java.util.function.Consumer;
+
+import static org.lowcoder.api.authentication.util.AuthenticationUtils.mapToAuthToken;
+import static org.lowcoder.sdk.plugin.common.constant.Constants.HTTP_TIMEOUT;
+
+@RequiredArgsConstructor
+@RestController
+public class ApiFlowController implements ApiFlowEndpoints
+{
+    @Override
+    public Mono<String> flow(FlowRequest flowRequest) {
+        try {
+            String url;
+            if (StringUtils.isEmpty(flowRequest.host())) url = "https://flow.lowcoder.cloud/" + flowRequest.path();
+            else url = flowRequest.host() + "/" + flowRequest.path();
+            ObjectMapper objectMapper = new ObjectMapper();
+            String jsonBody = objectMapper.writeValueAsString(flowRequest.data());
+            return WebClientBuildHelper.builder()
+                    .systemProxy()
+                    .timeoutMs(HTTP_TIMEOUT)
+                    .build()
+                    .method(HttpMethod.valueOf(flowRequest.method().toUpperCase()))
+                    .uri(url)
+                    .body(BodyInserters.fromValue(jsonBody))
+                    .headers(httpHeaders -> flowRequest.headers().forEach(httpHeaders::add))
+                    .retrieve()
+                    .bodyToMono(String.class);
+        } catch (Exception e) {
+            return Mono.error(e);
+        }
+    }
+
+}

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/misc/ApiFlowEndpoints.java

@@ -0,0 +1,36 @@
+package org.lowcoder.api.misc;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.Operation;
+import jakarta.annotation.Nullable;
+import org.lowcoder.infra.constant.NewUrl;
+import org.lowcoder.infra.constant.Url;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping(value = {Url.FLOW_URL, NewUrl.FLOW_URL})
+public interface ApiFlowEndpoints
+{
+	String TAG_SERVER_SETTING_MANAGEMENT = "Flow APIs";
+	
+	@Operation(
+			tags = TAG_SERVER_SETTING_MANAGEMENT,
+		    operationId = "flow",
+		    summary = "Call flow api",
+		    description = "Call flow api."
+	)
+    @PostMapping
+	Mono<String> flow(@RequestBody FlowRequest flowRequest);
+	public record FlowRequest(String path,
+							  String method,
+							  Map<String, Object> data,
+							  Map<String, String> headers,
+							  @Nullable String host) {
+	}
+}