Private npm repository forward api

Author: Thomasr

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

@@ -33,4 +33,5 @@ private NewUrl() {
     public static final String JS_LIBRARY = PREFIX + "/misc/js-library";
     public static final String MATERIAL_URL = PREFIX + "/materials";
     public static final String CONTACT_SYNC = PREFIX + "/sync";
+    public static final String NPM_REGISTRY = PREFIX + "/npm";
 }

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/npm/PrivateNpmRegistryController.java

@@ -0,0 +1,63 @@
+package org.lowcoder.api.npm;
+
+import lombok.RequiredArgsConstructor;
+import org.jetbrains.annotations.NotNull;
+import org.lowcoder.api.framework.view.ResponseView;
+import org.lowcoder.api.home.SessionUserService;
+import org.lowcoder.api.home.SessionUserServiceImpl;
+import org.lowcoder.domain.organization.service.OrganizationService;
+import org.lowcoder.domain.organization.service.OrganizationServiceImpl;
+import org.lowcoder.infra.constant.NewUrl;
+import org.lowcoder.infra.js.NodeServerHelper;
+import org.lowcoder.sdk.webclient.WebClientBuildHelper;
+import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.core.io.Resource;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.reactive.function.BodyInserters;
+import reactor.core.publisher.Mono;
+
+import java.util.Map;
+
+@RequiredArgsConstructor
+@RestController
+@RequestMapping(NewUrl.NPM_REGISTRY)
+public class PrivateNpmRegistryController implements PrivateNpmRegistryEndpoint{
+    private final OrganizationService organizationService;
+    private final SessionUserService sessionUserService;
+    NodeServerHelper nodeServerHelper;
+
+    private static final String NPM_REGISTRY_METADATA = "npm/registry";
+    private static final String NPM_REGISTRY_ASSET = "npm/package";
+
+    @Override
+    public Mono<ResponseEntity<Resource>> getNpmPackageMeta(String name) {
+        return forwardToNodeService(name, NPM_REGISTRY_METADATA);
+    }
+
+    @Override
+    public Mono<ResponseEntity<Resource>> getNpmPackageAsset(String path) {
+        return forwardToNodeService(path, NPM_REGISTRY_ASSET);
+    }
+
+    @NotNull
+    private Mono<ResponseEntity<Resource>> forwardToNodeService(String path, String prefix) {
+        return sessionUserService.getVisitorOrgMemberCache().flatMap(orgMember -> organizationService.getOrgCommonSettings(orgMember.getOrgId()).flatMap(organizationCommonSettings -> {
+            Map<String, Object> config = Map.of("npmRegistries", organizationCommonSettings.get("npmRegistries"), "workspaceId", orgMember.getOrgId());
+            return WebClientBuildHelper.builder()
+                    .systemProxy()
+                    .build()
+                    .post()
+                    .uri(nodeServerHelper.createUri(prefix + "/" + path))
+                    .contentType(MediaType.APPLICATION_JSON)
+                    .body(BodyInserters.fromValue(config))
+                    .retrieve().toEntity(Resource.class)
+                    .map(response -> ResponseEntity
+                            .status(response.getStatusCode())
+                            .headers(response.getHeaders())
+                            .body(response.getBody()));
+        }));
+    }
+}

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/npm/PrivateNpmRegistryEndpoint.java

@@ -0,0 +1,36 @@
+package org.lowcoder.api.npm;
+
+import io.swagger.v3.oas.annotations.Operation;
+import org.lowcoder.api.framework.view.ResponseView;
+import org.lowcoder.infra.constant.NewUrl;
+import org.springframework.core.io.Resource;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping(NewUrl.NPM_REGISTRY)
+public interface PrivateNpmRegistryEndpoint {
+    public static final String TAG_NPM_REGISTRY_MANAGEMENT = "Private NPM registry APIs";
+
+    @Operation(
+            tags = TAG_NPM_REGISTRY_MANAGEMENT,
+            operationId = "getNpmPackageMeta",
+            summary = "Get NPM registry Metadata",
+            description = "Retrieve the metadata of private NPM registry package within Lowcoder."
+    )
+    @GetMapping("/registry/{name}")
+    public Mono<ResponseEntity<Resource>> getNpmPackageMeta(@PathVariable String name);
+
+    @Operation(
+            tags = TAG_NPM_REGISTRY_MANAGEMENT,
+            operationId = "getNpmPackageAsset",
+            summary = "Get NPM registry asset",
+            description = "Retrieve the asset of private NPM registry package within Lowcoder."
+    )
+    @GetMapping("/package/{path}")
+    public Mono<ResponseEntity<Resource>> getNpmPackageAsset(@PathVariable String path);
+}