-/*-\r
- * ============LICENSE_START=======================================================\r
- * SDC\r
- * ================================================================================\r
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
- * ================================================================================\r
- * Licensed under the Apache License, Version 2.0 (the "License");\r
- * you may not use this file except in compliance with the License.\r
- * You may obtain a copy of the License at\r
- * \r
- * http://www.apache.org/licenses/LICENSE-2.0\r
- * \r
- * Unless required by applicable law or agreed to in writing, software\r
- * distributed under the License is distributed on an "AS IS" BASIS,\r
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- * See the License for the specific language governing permissions and\r
- * limitations under the License.\r
- * ============LICENSE_END=========================================================\r
- */\r
-\r
-package org.openecomp.sdc.be.servlets;\r
-\r
-import java.io.File;\r
-import java.io.IOException;\r
-import java.util.List;\r
-import java.util.Map;\r
-import java.util.Set;\r
-import java.util.function.Supplier;\r
-import java.util.stream.Collectors;\r
-import javax.inject.Inject;\r
-import javax.servlet.http.HttpServletRequest;\r
-import javax.ws.rs.Consumes;\r
-import javax.ws.rs.HeaderParam;\r
-import javax.ws.rs.POST;\r
-import javax.ws.rs.Path;\r
-import javax.ws.rs.Produces;\r
-import javax.ws.rs.core.Context;\r
-import javax.ws.rs.core.MediaType;\r
-import javax.ws.rs.core.Response;\r
-import org.apache.commons.lang3.tuple.ImmutablePair;\r
-import org.glassfish.jersey.media.multipart.FormDataParam;\r
-import org.openecomp.sdc.be.components.impl.CapabilityTypeImportManager;\r
-import org.openecomp.sdc.be.components.impl.CategoriesImportManager;\r
-import org.openecomp.sdc.be.components.impl.ComponentInstanceBusinessLogic;\r
-import org.openecomp.sdc.be.components.impl.DataTypeImportManager;\r
-import org.openecomp.sdc.be.components.impl.GroupTypeImportManager;\r
-import org.openecomp.sdc.be.components.impl.InterfaceLifecycleTypeImportManager;\r
-import org.openecomp.sdc.be.components.impl.PolicyTypeImportManager;\r
-import org.openecomp.sdc.be.components.impl.RelationshipTypeImportManager;\r
-import org.openecomp.sdc.be.components.impl.ResourceImportManager;\r
-import org.openecomp.sdc.be.components.impl.model.ToscaTypeImportData;\r
-import org.openecomp.sdc.be.config.BeEcompErrorManager;\r
-import org.openecomp.sdc.be.dao.api.ActionStatus;\r
-import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;\r
-import org.openecomp.sdc.be.impl.ComponentsUtils;\r
-import org.openecomp.sdc.be.impl.ServletUtils;\r
-import org.openecomp.sdc.be.model.DataTypeDefinition;\r
-import org.openecomp.sdc.be.model.GroupTypeDefinition;\r
-import org.openecomp.sdc.be.model.PolicyTypeDefinition;\r
-import org.openecomp.sdc.be.model.RelationshipTypeDefinition;\r
-import org.openecomp.sdc.be.model.User;\r
-import org.openecomp.sdc.be.model.normatives.ToscaTypeMetadata;\r
-import org.openecomp.sdc.be.user.UserBusinessLogic;\r
-import org.openecomp.sdc.common.api.Constants;\r
-import org.openecomp.sdc.common.datastructure.FunctionalInterfaces.ConsumerTwoParam;\r
-import org.openecomp.sdc.common.datastructure.Wrapper;\r
-import org.openecomp.sdc.common.log.wrappers.Logger;\r
-import org.openecomp.sdc.exception.ResponseFormat;\r
-import org.springframework.stereotype.Controller;\r
-import com.google.gson.reflect.TypeToken;\r
-import com.jcabi.aspects.Loggable;\r
-import fj.data.Either;\r
-import io.swagger.v3.oas.annotations.OpenAPIDefinition;\r
-import io.swagger.v3.oas.annotations.Operation;\r
-import io.swagger.v3.oas.annotations.Parameter;\r
-import io.swagger.v3.oas.annotations.info.Info;\r
-import io.swagger.v3.oas.annotations.media.ArraySchema;\r
-import io.swagger.v3.oas.annotations.media.Content;\r
-import io.swagger.v3.oas.annotations.media.Schema;\r
-import io.swagger.v3.oas.annotations.responses.ApiResponse;\r
-import io.swagger.v3.oas.annotations.responses.ApiResponses;\r
-\r
-@Loggable(prepend = true, value = Loggable.DEBUG, trim = false)\r
-@Path("/v1/catalog/uploadType")\r
-@Consumes(MediaType.MULTIPART_FORM_DATA)\r
-@Produces(MediaType.APPLICATION_JSON)\r
-@OpenAPIDefinition(info = @Info(title = "Catalog Types Upload"))\r
-@Controller\r
-public class TypesUploadServlet extends AbstractValidationsServlet {\r
- private static final Logger log = Logger.getLogger(TypesUploadServlet.class);\r
- public static final String CREATE = "Create ";\r
-\r
- private final CapabilityTypeImportManager capabilityTypeImportManager;\r
- private final InterfaceLifecycleTypeImportManager interfaceLifecycleTypeImportManager;\r
- private final CategoriesImportManager categoriesImportManager;\r
- private final DataTypeImportManager dataTypeImportManager;\r
- private final GroupTypeImportManager groupTypeImportManager;\r
- private final PolicyTypeImportManager policyTypeImportManager;\r
- private final RelationshipTypeImportManager relationshipTypeImportManager;\r
-\r
- @Inject\r
- public TypesUploadServlet(UserBusinessLogic userBusinessLogic,\r
- ComponentInstanceBusinessLogic componentInstanceBL,\r
- ComponentsUtils componentsUtils, ServletUtils servletUtils,\r
- ResourceImportManager resourceImportManager,\r
- CapabilityTypeImportManager capabilityTypeImportManager,\r
- InterfaceLifecycleTypeImportManager interfaceLifecycleTypeImportManager,\r
- CategoriesImportManager categoriesImportManager,\r
- DataTypeImportManager dataTypeImportManager,\r
- GroupTypeImportManager groupTypeImportManager,\r
- PolicyTypeImportManager policyTypeImportManager,\r
- RelationshipTypeImportManager relationshipTypeImportManager) {\r
- super(userBusinessLogic, componentInstanceBL, componentsUtils, servletUtils, resourceImportManager);\r
- this.capabilityTypeImportManager = capabilityTypeImportManager;\r
- this.interfaceLifecycleTypeImportManager = interfaceLifecycleTypeImportManager;\r
- this.categoriesImportManager = categoriesImportManager;\r
- this.dataTypeImportManager = dataTypeImportManager;\r
- this.groupTypeImportManager = groupTypeImportManager;\r
- this.policyTypeImportManager = policyTypeImportManager;\r
- this.relationshipTypeImportManager = relationshipTypeImportManager;\r
- }\r
-\r
- @POST\r
- @Path("/capability")\r
- @Operation(description = "Create Capability Type from yaml", method = "POST",\r
- summary = "Returns created Capability Type", responses = @ApiResponse(\r
- content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))\r
- @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Capability Type created"),\r
- @ApiResponse(responseCode = "403", description = "Restricted operation"),\r
- @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),\r
- @ApiResponse(responseCode = "409", description = "Capability Type already exist")})\r
- public Response uploadCapabilityType(@Parameter(description = "FileInputStream") @FormDataParam("capabilityTypeZip") File file,\r
- @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {\r
- ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod =\r
- (responseWrapper, ymlPayload) -> createElementsType(responseWrapper,\r
- () -> capabilityTypeImportManager.createCapabilityTypes(ymlPayload));\r
- return uploadElementTypeServletLogic(createElementsMethod, file, request, creator,\r
- NodeTypeEnum.CapabilityType.name());\r
- }\r
-\r
- @POST\r
- @Path("/relationship")\r
- @Operation(description = "Create Relationship Type from yaml", method = "POST",\r
- summary = "Returns created Relationship Type", responses = @ApiResponse(\r
- content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))\r
- @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Relationship Type created"),\r
- @ApiResponse(responseCode = "403", description = "Restricted operation"),\r
- @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),\r
- @ApiResponse(responseCode = "409", description = "Relationship Type already exist")})\r
- public Response uploadRelationshipType(@Parameter(description = "FileInputStream") @FormDataParam("relationshipTypeZip") File file,\r
- @Context final HttpServletRequest request,\r
- @HeaderParam("USER_ID") String creator) {\r
- return uploadElementTypeServletLogic(this::createRelationshipTypes, file, request, creator,\r
- NodeTypeEnum.RelationshipType.getName());\r
- }\r
-\r
- @POST\r
- @Path("/interfaceLifecycle")\r
- @Operation(description = "Create Interface Lyfecycle Type from yaml", method = "POST",\r
- summary = "Returns created Interface Lifecycle Type", responses = @ApiResponse(\r
- content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))\r
- @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Interface Lifecycle Type created"),\r
- @ApiResponse(responseCode = "403", description = "Restricted operation"),\r
- @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),\r
- @ApiResponse(responseCode = "409", description = "Interface Lifecycle Type already exist")})\r
- public Response uploadInterfaceLifecycleType(\r
- @Parameter(description = "FileInputStream") @FormDataParam("interfaceLifecycleTypeZip") File file,\r
- @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {\r
- ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod =\r
- (responseWrapper, ymlPayload) -> createElementsType(responseWrapper,\r
- () -> interfaceLifecycleTypeImportManager.createLifecycleTypes(ymlPayload));\r
- return uploadElementTypeServletLogic(createElementsMethod, file, request, creator, "Interface Types");\r
- }\r
-\r
- @POST\r
- @Path("/categories")\r
- @Operation(description = "Create Categories from yaml", method = "POST", summary = "Returns created categories",\r
- responses = @ApiResponse(\r
- content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))\r
- @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Categories created"),\r
- @ApiResponse(responseCode = "403", description = "Restricted operation"),\r
- @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),\r
- @ApiResponse(responseCode = "409", description = "Category already exist")})\r
- public Response uploadCategories(@Parameter(description = "FileInputStream") @FormDataParam("categoriesZip") File file,\r
- @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {\r
- ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod =\r
- (responseWrapper, ymlPayload) -> createElementsType(responseWrapper,\r
- () -> categoriesImportManager.createCategories(ymlPayload));\r
- return uploadElementTypeServletLogic(createElementsMethod, file, request, creator, "categories");\r
- }\r
-\r
- @POST\r
- @Path("/datatypes")\r
- @Operation(description = "Create Categories from yaml", method = "POST", summary = "Returns created data types",\r
- responses = @ApiResponse(\r
- content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))\r
- @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Data types created"),\r
- @ApiResponse(responseCode = "403", description = "Restricted operation"),\r
- @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),\r
- @ApiResponse(responseCode = "409", description = "Data types already exist")})\r
- public Response uploadDataTypes(@Parameter(description = "FileInputStream") @FormDataParam("dataTypesZip") File file,\r
- @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {\r
- ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod = this::createDataTypes;\r
- return uploadElementTypeServletLogic(createElementsMethod, file, request, creator,\r
- NodeTypeEnum.DataType.getName());\r
- }\r
-\r
- @POST\r
- @Path("/grouptypes")\r
- @Operation(description = "Create GroupTypes from yaml", method = "POST", summary = "Returns created group types",\r
- responses = @ApiResponse(\r
- content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))\r
- @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "group types created"),\r
- @ApiResponse(responseCode = "403", description = "Restricted operation"),\r
- @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),\r
- @ApiResponse(responseCode = "409", description = "group types already exist")})\r
- public Response uploadGroupTypes(\r
- @Parameter(description = "toscaTypeMetadata") @FormDataParam("toscaTypeMetadata") String toscaTypesMetaData,\r
- @Parameter(description = "FileInputStream") @FormDataParam("groupTypesZip") File file,\r
- @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {\r
- Map<String, ToscaTypeMetadata> typesMetadata = getTypesMetadata(toscaTypesMetaData);\r
- return uploadTypesWithMetaData(this::createGroupTypes, typesMetadata, file, request, creator,\r
- NodeTypeEnum.GroupType.getName());\r
- }\r
-\r
- @POST\r
- @Path("/policytypes")\r
- @Operation(description = "Create PolicyTypes from yaml", method = "POST", summary = "Returns created policy types",\r
- responses = @ApiResponse(\r
- content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))\r
- @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "policy types created"),\r
- @ApiResponse(responseCode = "403", description = "Restricted operation"),\r
- @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),\r
- @ApiResponse(responseCode = "409", description = "policy types already exist")})\r
- public Response uploadPolicyTypes(\r
- @Parameter(description = "toscaTypeMetadata") @FormDataParam("toscaTypeMetadata") String toscaTypesMetaData,\r
- @Parameter(description = "FileInputStream") @FormDataParam("policyTypesZip") File file,\r
- @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {\r
- Map<String, ToscaTypeMetadata> typesMetadata = getTypesMetadata(toscaTypesMetaData);\r
- return uploadTypesWithMetaData(this::createPolicyTypes, typesMetadata, file, request, creator,\r
- NodeTypeEnum.PolicyType.getName());\r
- }\r
-\r
- private Map<String, ToscaTypeMetadata> getTypesMetadata(String toscaTypesMetaData) {\r
- return gson.fromJson(toscaTypesMetaData, new TypeToken<Map<String, ToscaTypeMetadata>>(){}.getType());\r
- }\r
-\r
- private Response uploadElementTypeServletLogic(ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod, File file, final HttpServletRequest request, String creator, String elementTypeName) {\r
- init();\r
- String userId = initHeaderParam(creator, request, Constants.USER_ID_HEADER);\r
- try {\r
- Wrapper<String> yamlStringWrapper = new Wrapper<>();\r
-\r
- String url = request.getMethod() + " " + request.getRequestURI();\r
- log.debug("Start handle request of {}", url);\r
- Wrapper<Response> responseWrapper = doUploadTypeValidations(request, userId, file);\r
- if (responseWrapper.isEmpty()) {\r
- fillZipContents(yamlStringWrapper, file);\r
- }\r
- if (responseWrapper.isEmpty()) {\r
- createElementsMethod.accept(responseWrapper, yamlStringWrapper.getInnerElement());\r
- }\r
- return responseWrapper.getInnerElement();\r
- } catch (Exception e) {\r
- log.debug("create {} failed with exception:", elementTypeName, e);\r
- BeEcompErrorManager.getInstance().logBeRestApiGeneralError(CREATE + elementTypeName);\r
- return buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));\r
- }\r
- }\r
-\r
- private Wrapper<Response> doUploadTypeValidations(final HttpServletRequest request, String userId, File file) {\r
- Wrapper<Response> responseWrapper = new Wrapper<>();\r
- Wrapper<User> userWrapper = new Wrapper<>();\r
-\r
- String url = request.getMethod() + " " + request.getRequestURI();\r
- log.debug("Start handle request of {}", url);\r
-\r
- validateUserExist(responseWrapper, userWrapper, userId);\r
-\r
- if (responseWrapper.isEmpty()) {\r
- validateUserRole(responseWrapper, userWrapper.getInnerElement());\r
- }\r
-\r
- if (responseWrapper.isEmpty()) {\r
- validateDataNotNull(responseWrapper, file);\r
- }\r
- return responseWrapper;\r
- }\r
-\r
- private Response uploadTypesWithMetaData(ConsumerTwoParam<Wrapper<Response>, ToscaTypeImportData> createElementsMethod, Map<String, ToscaTypeMetadata> typesMetaData, File file, final HttpServletRequest request, String creator, String elementTypeName) {\r
- init();\r
- String userId = initHeaderParam(creator, request, Constants.USER_ID_HEADER);\r
- Wrapper<String> yamlStringWrapper = new Wrapper<>();\r
- try {\r
- Wrapper<Response> responseWrapper = doUploadTypeValidations(request, userId, file);\r
- if (responseWrapper.isEmpty()) {\r
- fillZipContents(yamlStringWrapper, file);\r
- }\r
- if (responseWrapper.isEmpty()) {\r
- ToscaTypeImportData toscaTypeImportData = new ToscaTypeImportData(yamlStringWrapper.getInnerElement(), typesMetaData);\r
- createElementsMethod.accept(responseWrapper, toscaTypeImportData);\r
- }\r
- return responseWrapper.getInnerElement();\r
- } catch (Exception e) {\r
- log.debug("create {} failed with exception:", elementTypeName, e);\r
- BeEcompErrorManager.getInstance().logBeRestApiGeneralError(CREATE + elementTypeName);\r
- return buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));\r
- }\r
- }\r
-\r
- private <T> void createElementsType(Wrapper<Response> responseWrapper, Supplier<Either<T, ResponseFormat>> elementsCreater) {\r
- Either<T, ResponseFormat> eitherResult = elementsCreater.get();\r
- if (eitherResult.isRight()) {\r
- Response response = buildErrorResponse(eitherResult.right().value());\r
- responseWrapper.setInnerElement(response);\r
- } else {\r
- try {\r
- Response response = buildOkResponse(getComponentsUtils().getResponseFormat(ActionStatus.CREATED), RepresentationUtils.toRepresentation(eitherResult.left().value()));\r
- responseWrapper.setInnerElement(response);\r
- } catch (Exception e) {\r
- Response response = buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));\r
- responseWrapper.setInnerElement(response);\r
- log.error("#createElementsType - json serialization failed with error: ", e);\r
- }\r
- }\r
- }\r
-\r
- // data types\r
- private void createDataTypes(Wrapper<Response> responseWrapper, String dataTypesYml) {\r
- final Supplier<Either<List<ImmutablePair<DataTypeDefinition, Boolean>>, ResponseFormat>> generateElementTypeFromYml =\r
- () -> dataTypeImportManager.createDataTypes(dataTypesYml);\r
- buildStatusForElementTypeCreate(responseWrapper, generateElementTypeFromYml,\r
- ActionStatus.DATA_TYPE_ALREADY_EXIST, NodeTypeEnum.DataType.name());\r
- }\r
-\r
- // group types\r
- private void createGroupTypes(Wrapper<Response> responseWrapper, ToscaTypeImportData toscaTypeImportData) {\r
- final Supplier<Either<List<ImmutablePair<GroupTypeDefinition, Boolean>>, ResponseFormat>> generateElementTypeFromYml =\r
- () -> groupTypeImportManager.createGroupTypes(toscaTypeImportData);\r
- buildStatusForElementTypeCreate(responseWrapper, generateElementTypeFromYml,\r
- ActionStatus.GROUP_TYPE_ALREADY_EXIST, NodeTypeEnum.GroupType.name());\r
- }\r
-\r
- // policy types\r
- private void createPolicyTypes(Wrapper<Response> responseWrapper, ToscaTypeImportData toscaTypeImportData) {\r
- final Supplier<Either<List<ImmutablePair<PolicyTypeDefinition, Boolean>>, ResponseFormat>> generateElementTypeFromYml =\r
- () -> policyTypeImportManager.createPolicyTypes(toscaTypeImportData);\r
- buildStatusForElementTypeCreate(responseWrapper, generateElementTypeFromYml,\r
- ActionStatus.POLICY_TYPE_ALREADY_EXIST, NodeTypeEnum.PolicyType.name());\r
- }\r
-\r
- // data types\r
- private <ElementTypeDefinition> void buildStatusForElementTypeCreate(Wrapper<Response> responseWrapper, Supplier<Either<List<ImmutablePair<ElementTypeDefinition, Boolean>>, ResponseFormat>> generateElementTypeFromYml, ActionStatus alreadyExistStatus, String elementTypeName) {\r
- Either<List<ImmutablePair<ElementTypeDefinition, Boolean>>, ResponseFormat> eitherResult = generateElementTypeFromYml.get();\r
-\r
- if (eitherResult.isRight()) {\r
- Response response = buildErrorResponse(eitherResult.right().value());\r
- responseWrapper.setInnerElement(response);\r
- } else {\r
- Object representation;\r
- try {\r
- List<ImmutablePair<ElementTypeDefinition, Boolean>> list = eitherResult.left().value();\r
- ActionStatus status = ActionStatus.OK;\r
- if (list != null) {\r
-\r
- // Group result by the right value - true or false.\r
- // I.e., get the number of data types which are new and\r
- // which are old.\r
- Map<Boolean, List<ImmutablePair<ElementTypeDefinition, Boolean>>> collect = list.stream().collect(Collectors.groupingBy(ImmutablePair<ElementTypeDefinition, Boolean>::getRight));\r
- if (collect != null) {\r
- Set<Boolean> keySet = collect.keySet();\r
- if (keySet.size() == 1) {\r
- Boolean isNew = keySet.iterator().next();\r
- if (isNew.booleanValue()) {\r
- // all data types created at the first time\r
- status = ActionStatus.CREATED;\r
- } else {\r
- // All data types already exists\r
-\r
- status = alreadyExistStatus;\r
- }\r
- }\r
- }\r
- }\r
- representation = RepresentationUtils.toRepresentation(eitherResult.left().value());\r
-\r
- Response response = buildOkResponse(getComponentsUtils().getResponseFormat(status), representation);\r
- responseWrapper.setInnerElement(response);\r
-\r
- } catch (IOException e) {\r
- BeEcompErrorManager.getInstance().logBeRestApiGeneralError(CREATE + elementTypeName);\r
- log.debug("failed to convert {} to json", elementTypeName, e);\r
- Response response = buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));\r
- responseWrapper.setInnerElement(response);\r
- }\r
- }\r
- }\r
- // relationship types\r
- private void createRelationshipTypes(Wrapper<Response> responseWrapper, String relationshipTypesYml) {\r
- final Supplier<Either<List<ImmutablePair<RelationshipTypeDefinition, Boolean>>, ResponseFormat>>\r
- generateElementTypeFromYml =\r
- () -> relationshipTypeImportManager.createRelationshipTypes(relationshipTypesYml);\r
- buildStatusForElementTypeCreate(responseWrapper, generateElementTypeFromYml,\r
- ActionStatus.RELATIONSHIP_TYPE_ALREADY_EXIST, NodeTypeEnum.RelationshipType.name());\r
- }\r
-\r
-}\r
+/*-
+ * ============LICENSE_START=======================================================
+ * SDC
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.openecomp.sdc.be.servlets;
+
+import com.google.gson.reflect.TypeToken;
+import com.jcabi.aspects.Loggable;
+import fj.data.Either;
+import io.swagger.v3.oas.annotations.OpenAPIDefinition;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.info.Info;
+import io.swagger.v3.oas.annotations.media.ArraySchema;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.responses.ApiResponses;
+import org.apache.commons.lang3.tuple.ImmutablePair;
+import org.glassfish.jersey.media.multipart.FormDataParam;
+import org.openecomp.sdc.be.components.impl.CapabilityTypeImportManager;
+import org.openecomp.sdc.be.components.impl.CategoriesImportManager;
+import org.openecomp.sdc.be.components.impl.ComponentInstanceBusinessLogic;
+import org.openecomp.sdc.be.components.impl.DataTypeImportManager;
+import org.openecomp.sdc.be.components.impl.GroupTypeImportManager;
+import org.openecomp.sdc.be.components.impl.InterfaceLifecycleTypeImportManager;
+import org.openecomp.sdc.be.components.impl.PolicyTypeImportManager;
+import org.openecomp.sdc.be.components.impl.RelationshipTypeImportManager;
+import org.openecomp.sdc.be.components.impl.ResourceImportManager;
+import org.openecomp.sdc.be.components.impl.aaf.AafPermission;
+import org.openecomp.sdc.be.components.impl.aaf.PermissionAllowed;
+import org.openecomp.sdc.be.components.impl.model.ToscaTypeImportData;
+import org.openecomp.sdc.be.config.BeEcompErrorManager;
+import org.openecomp.sdc.be.dao.api.ActionStatus;
+import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;
+import org.openecomp.sdc.be.impl.ComponentsUtils;
+import org.openecomp.sdc.be.impl.ServletUtils;
+import org.openecomp.sdc.be.model.DataTypeDefinition;
+import org.openecomp.sdc.be.model.GroupTypeDefinition;
+import org.openecomp.sdc.be.model.PolicyTypeDefinition;
+import org.openecomp.sdc.be.model.RelationshipTypeDefinition;
+import org.openecomp.sdc.be.model.User;
+import org.openecomp.sdc.be.model.normatives.ToscaTypeMetadata;
+import org.openecomp.sdc.be.user.UserBusinessLogic;
+import org.openecomp.sdc.common.api.Constants;
+import org.openecomp.sdc.common.datastructure.FunctionalInterfaces.ConsumerTwoParam;
+import org.openecomp.sdc.common.datastructure.Wrapper;
+import org.openecomp.sdc.common.log.wrappers.Logger;
+import org.openecomp.sdc.exception.ResponseFormat;
+import org.springframework.stereotype.Controller;
+
+import javax.inject.Inject;
+import javax.servlet.http.HttpServletRequest;
+import javax.ws.rs.Consumes;
+import javax.ws.rs.HeaderParam;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.io.File;
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.function.Supplier;
+import java.util.stream.Collectors;
+
+@Loggable(prepend = true, value = Loggable.DEBUG, trim = false)
+@Path("/v1/catalog/uploadType")
+@Consumes(MediaType.MULTIPART_FORM_DATA)
+@Produces(MediaType.APPLICATION_JSON)
+@OpenAPIDefinition(info = @Info(title = "Catalog Types Upload"))
+@Controller
+public class TypesUploadServlet extends AbstractValidationsServlet {
+ private static final Logger log = Logger.getLogger(TypesUploadServlet.class);
+ public static final String CREATE = "Create ";
+
+ private final CapabilityTypeImportManager capabilityTypeImportManager;
+ private final InterfaceLifecycleTypeImportManager interfaceLifecycleTypeImportManager;
+ private final CategoriesImportManager categoriesImportManager;
+ private final DataTypeImportManager dataTypeImportManager;
+ private final GroupTypeImportManager groupTypeImportManager;
+ private final PolicyTypeImportManager policyTypeImportManager;
+ private final RelationshipTypeImportManager relationshipTypeImportManager;
+
+ @Inject
+ public TypesUploadServlet(UserBusinessLogic userBusinessLogic,
+ ComponentInstanceBusinessLogic componentInstanceBL,
+ ComponentsUtils componentsUtils, ServletUtils servletUtils,
+ ResourceImportManager resourceImportManager,
+ CapabilityTypeImportManager capabilityTypeImportManager,
+ InterfaceLifecycleTypeImportManager interfaceLifecycleTypeImportManager,
+ CategoriesImportManager categoriesImportManager,
+ DataTypeImportManager dataTypeImportManager,
+ GroupTypeImportManager groupTypeImportManager,
+ PolicyTypeImportManager policyTypeImportManager,
+ RelationshipTypeImportManager relationshipTypeImportManager) {
+ super(userBusinessLogic, componentInstanceBL, componentsUtils, servletUtils, resourceImportManager);
+ this.capabilityTypeImportManager = capabilityTypeImportManager;
+ this.interfaceLifecycleTypeImportManager = interfaceLifecycleTypeImportManager;
+ this.categoriesImportManager = categoriesImportManager;
+ this.dataTypeImportManager = dataTypeImportManager;
+ this.groupTypeImportManager = groupTypeImportManager;
+ this.policyTypeImportManager = policyTypeImportManager;
+ this.relationshipTypeImportManager = relationshipTypeImportManager;
+ }
+
+ @POST
+ @Path("/capability")
+ @Operation(description = "Create Capability Type from yaml", method = "POST",
+ summary = "Returns created Capability Type", responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Capability Type created"),
+ @ApiResponse(responseCode = "403", description = "Restricted operation"),
+ @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
+ @ApiResponse(responseCode = "409", description = "Capability Type already exist")})
+ @PermissionAllowed(AafPermission.PermNames.INTERNAL_ALL_VALUE)
+ public Response uploadCapabilityType(@Parameter(description = "FileInputStream") @FormDataParam("capabilityTypeZip") File file,
+ @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {
+ ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod =
+ (responseWrapper, ymlPayload) -> createElementsType(responseWrapper,
+ () -> capabilityTypeImportManager.createCapabilityTypes(ymlPayload));
+ return uploadElementTypeServletLogic(createElementsMethod, file, request, creator,
+ NodeTypeEnum.CapabilityType.name());
+ }
+
+ @POST
+ @Path("/relationship")
+ @Operation(description = "Create Relationship Type from yaml", method = "POST",
+ summary = "Returns created Relationship Type", responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Relationship Type created"),
+ @ApiResponse(responseCode = "403", description = "Restricted operation"),
+ @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
+ @ApiResponse(responseCode = "409", description = "Relationship Type already exist")})
+ @PermissionAllowed(AafPermission.PermNames.INTERNAL_ALL_VALUE)
+ public Response uploadRelationshipType(@Parameter(description = "FileInputStream") @FormDataParam("relationshipTypeZip") File file,
+ @Context final HttpServletRequest request,
+ @HeaderParam("USER_ID") String creator) {
+ return uploadElementTypeServletLogic(this::createRelationshipTypes, file, request, creator,
+ NodeTypeEnum.RelationshipType.getName());
+ }
+
+ @POST
+ @Path("/interfaceLifecycle")
+ @Operation(description = "Create Interface Lyfecycle Type from yaml", method = "POST",
+ summary = "Returns created Interface Lifecycle Type", responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Interface Lifecycle Type created"),
+ @ApiResponse(responseCode = "403", description = "Restricted operation"),
+ @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
+ @ApiResponse(responseCode = "409", description = "Interface Lifecycle Type already exist")})
+ @PermissionAllowed(AafPermission.PermNames.INTERNAL_ALL_VALUE)
+ public Response uploadInterfaceLifecycleType(
+ @Parameter(description = "FileInputStream") @FormDataParam("interfaceLifecycleTypeZip") File file,
+ @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {
+ ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod =
+ (responseWrapper, ymlPayload) -> createElementsType(responseWrapper,
+ () -> interfaceLifecycleTypeImportManager.createLifecycleTypes(ymlPayload));
+ return uploadElementTypeServletLogic(createElementsMethod, file, request, creator, "Interface Types");
+ }
+
+ @POST
+ @Path("/categories")
+ @Operation(description = "Create Categories from yaml", method = "POST", summary = "Returns created categories",
+ responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Categories created"),
+ @ApiResponse(responseCode = "403", description = "Restricted operation"),
+ @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
+ @ApiResponse(responseCode = "409", description = "Category already exist")})
+ @PermissionAllowed(AafPermission.PermNames.INTERNAL_ALL_VALUE)
+ public Response uploadCategories(@Parameter(description = "FileInputStream") @FormDataParam("categoriesZip") File file,
+ @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {
+ ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod =
+ (responseWrapper, ymlPayload) -> createElementsType(responseWrapper,
+ () -> categoriesImportManager.createCategories(ymlPayload));
+ return uploadElementTypeServletLogic(createElementsMethod, file, request, creator, "categories");
+ }
+
+ @POST
+ @Path("/datatypes")
+ @Operation(description = "Create Categories from yaml", method = "POST", summary = "Returns created data types",
+ responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "Data types created"),
+ @ApiResponse(responseCode = "403", description = "Restricted operation"),
+ @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
+ @ApiResponse(responseCode = "409", description = "Data types already exist")})
+ @PermissionAllowed(AafPermission.PermNames.INTERNAL_ALL_VALUE)
+ public Response uploadDataTypes(@Parameter(description = "FileInputStream") @FormDataParam("dataTypesZip") File file,
+ @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {
+ ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod = this::createDataTypes;
+ return uploadElementTypeServletLogic(createElementsMethod, file, request, creator,
+ NodeTypeEnum.DataType.getName());
+ }
+
+ @POST
+ @Path("/grouptypes")
+ @Operation(description = "Create GroupTypes from yaml", method = "POST", summary = "Returns created group types",
+ responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "group types created"),
+ @ApiResponse(responseCode = "403", description = "Restricted operation"),
+ @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
+ @ApiResponse(responseCode = "409", description = "group types already exist")})
+ @PermissionAllowed(AafPermission.PermNames.INTERNAL_ALL_VALUE)
+ public Response uploadGroupTypes(
+ @Parameter(description = "toscaTypeMetadata") @FormDataParam("toscaTypeMetadata") String toscaTypesMetaData,
+ @Parameter(description = "FileInputStream") @FormDataParam("groupTypesZip") File file,
+ @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {
+ Map<String, ToscaTypeMetadata> typesMetadata = getTypesMetadata(toscaTypesMetaData);
+ return uploadTypesWithMetaData(this::createGroupTypes, typesMetadata, file, request, creator,
+ NodeTypeEnum.GroupType.getName());
+ }
+
+ @POST
+ @Path("/policytypes")
+ @Operation(description = "Create PolicyTypes from yaml", method = "POST", summary = "Returns created policy types",
+ responses = @ApiResponse(
+ content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))))
+ @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "policy types created"),
+ @ApiResponse(responseCode = "403", description = "Restricted operation"),
+ @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
+ @ApiResponse(responseCode = "409", description = "policy types already exist")})
+ @PermissionAllowed(AafPermission.PermNames.INTERNAL_ALL_VALUE)
+ public Response uploadPolicyTypes(
+ @Parameter(description = "toscaTypeMetadata") @FormDataParam("toscaTypeMetadata") String toscaTypesMetaData,
+ @Parameter(description = "FileInputStream") @FormDataParam("policyTypesZip") File file,
+ @Context final HttpServletRequest request, @HeaderParam("USER_ID") String creator) {
+ Map<String, ToscaTypeMetadata> typesMetadata = getTypesMetadata(toscaTypesMetaData);
+ return uploadTypesWithMetaData(this::createPolicyTypes, typesMetadata, file, request, creator,
+ NodeTypeEnum.PolicyType.getName());
+ }
+
+ private Map<String, ToscaTypeMetadata> getTypesMetadata(String toscaTypesMetaData) {
+ return gson.fromJson(toscaTypesMetaData, new TypeToken<Map<String, ToscaTypeMetadata>>(){}.getType());
+ }
+
+ private Response uploadElementTypeServletLogic(ConsumerTwoParam<Wrapper<Response>, String> createElementsMethod, File file, final HttpServletRequest request, String creator, String elementTypeName) {
+ init();
+ String userId = initHeaderParam(creator, request, Constants.USER_ID_HEADER);
+ try {
+ Wrapper<String> yamlStringWrapper = new Wrapper<>();
+
+ String url = request.getMethod() + " " + request.getRequestURI();
+ log.debug("Start handle request of {}", url);
+ Wrapper<Response> responseWrapper = doUploadTypeValidations(request, userId, file);
+ if (responseWrapper.isEmpty()) {
+ fillZipContents(yamlStringWrapper, file);
+ }
+ if (responseWrapper.isEmpty()) {
+ createElementsMethod.accept(responseWrapper, yamlStringWrapper.getInnerElement());
+ }
+ return responseWrapper.getInnerElement();
+ } catch (Exception e) {
+ log.debug("create {} failed with exception:", elementTypeName, e);
+ BeEcompErrorManager.getInstance().logBeRestApiGeneralError(CREATE + elementTypeName);
+ return buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));
+ }
+ }
+
+ private Wrapper<Response> doUploadTypeValidations(final HttpServletRequest request, String userId, File file) {
+ Wrapper<Response> responseWrapper = new Wrapper<>();
+ Wrapper<User> userWrapper = new Wrapper<>();
+
+ String url = request.getMethod() + " " + request.getRequestURI();
+ log.debug("Start handle request of {}", url);
+
+ validateUserExist(responseWrapper, userWrapper, userId);
+
+ if (responseWrapper.isEmpty()) {
+ validateUserRole(responseWrapper, userWrapper.getInnerElement());
+ }
+
+ if (responseWrapper.isEmpty()) {
+ validateDataNotNull(responseWrapper, file);
+ }
+ return responseWrapper;
+ }
+
+ private Response uploadTypesWithMetaData(ConsumerTwoParam<Wrapper<Response>, ToscaTypeImportData> createElementsMethod, Map<String, ToscaTypeMetadata> typesMetaData, File file, final HttpServletRequest request, String creator, String elementTypeName) {
+ init();
+ String userId = initHeaderParam(creator, request, Constants.USER_ID_HEADER);
+ Wrapper<String> yamlStringWrapper = new Wrapper<>();
+ try {
+ Wrapper<Response> responseWrapper = doUploadTypeValidations(request, userId, file);
+ if (responseWrapper.isEmpty()) {
+ fillZipContents(yamlStringWrapper, file);
+ }
+ if (responseWrapper.isEmpty()) {
+ ToscaTypeImportData toscaTypeImportData = new ToscaTypeImportData(yamlStringWrapper.getInnerElement(), typesMetaData);
+ createElementsMethod.accept(responseWrapper, toscaTypeImportData);
+ }
+ return responseWrapper.getInnerElement();
+ } catch (Exception e) {
+ log.debug("create {} failed with exception:", elementTypeName, e);
+ BeEcompErrorManager.getInstance().logBeRestApiGeneralError(CREATE + elementTypeName);
+ return buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));
+ }
+ }
+
+ private <T> void createElementsType(Wrapper<Response> responseWrapper, Supplier<Either<T, ResponseFormat>> elementsCreater) {
+ Either<T, ResponseFormat> eitherResult = elementsCreater.get();
+ if (eitherResult.isRight()) {
+ Response response = buildErrorResponse(eitherResult.right().value());
+ responseWrapper.setInnerElement(response);
+ } else {
+ try {
+ Response response = buildOkResponse(getComponentsUtils().getResponseFormat(ActionStatus.CREATED), RepresentationUtils.toRepresentation(eitherResult.left().value()));
+ responseWrapper.setInnerElement(response);
+ } catch (Exception e) {
+ Response response = buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));
+ responseWrapper.setInnerElement(response);
+ log.error("#createElementsType - json serialization failed with error: ", e);
+ }
+ }
+ }
+
+ // data types
+ private void createDataTypes(Wrapper<Response> responseWrapper, String dataTypesYml) {
+ final Supplier<Either<List<ImmutablePair<DataTypeDefinition, Boolean>>, ResponseFormat>> generateElementTypeFromYml =
+ () -> dataTypeImportManager.createDataTypes(dataTypesYml);
+ buildStatusForElementTypeCreate(responseWrapper, generateElementTypeFromYml,
+ ActionStatus.DATA_TYPE_ALREADY_EXIST, NodeTypeEnum.DataType.name());
+ }
+
+ // group types
+ private void createGroupTypes(Wrapper<Response> responseWrapper, ToscaTypeImportData toscaTypeImportData) {
+ final Supplier<Either<List<ImmutablePair<GroupTypeDefinition, Boolean>>, ResponseFormat>> generateElementTypeFromYml =
+ () -> groupTypeImportManager.createGroupTypes(toscaTypeImportData);
+ buildStatusForElementTypeCreate(responseWrapper, generateElementTypeFromYml,
+ ActionStatus.GROUP_TYPE_ALREADY_EXIST, NodeTypeEnum.GroupType.name());
+ }
+
+ // policy types
+ private void createPolicyTypes(Wrapper<Response> responseWrapper, ToscaTypeImportData toscaTypeImportData) {
+ final Supplier<Either<List<ImmutablePair<PolicyTypeDefinition, Boolean>>, ResponseFormat>> generateElementTypeFromYml =
+ () -> policyTypeImportManager.createPolicyTypes(toscaTypeImportData);
+ buildStatusForElementTypeCreate(responseWrapper, generateElementTypeFromYml,
+ ActionStatus.POLICY_TYPE_ALREADY_EXIST, NodeTypeEnum.PolicyType.name());
+ }
+
+ // data types
+ private <ElementTypeDefinition> void buildStatusForElementTypeCreate(Wrapper<Response> responseWrapper, Supplier<Either<List<ImmutablePair<ElementTypeDefinition, Boolean>>, ResponseFormat>> generateElementTypeFromYml, ActionStatus alreadyExistStatus, String elementTypeName) {
+ Either<List<ImmutablePair<ElementTypeDefinition, Boolean>>, ResponseFormat> eitherResult = generateElementTypeFromYml.get();
+
+ if (eitherResult.isRight()) {
+ Response response = buildErrorResponse(eitherResult.right().value());
+ responseWrapper.setInnerElement(response);
+ } else {
+ Object representation;
+ try {
+ List<ImmutablePair<ElementTypeDefinition, Boolean>> list = eitherResult.left().value();
+ ActionStatus status = ActionStatus.OK;
+ if (list != null) {
+
+ // Group result by the right value - true or false.
+ // I.e., get the number of data types which are new and
+ // which are old.
+ Map<Boolean, List<ImmutablePair<ElementTypeDefinition, Boolean>>> collect = list.stream().collect(Collectors.groupingBy(ImmutablePair<ElementTypeDefinition, Boolean>::getRight));
+ if (collect != null) {
+ Set<Boolean> keySet = collect.keySet();
+ if (keySet.size() == 1) {
+ Boolean isNew = keySet.iterator().next();
+ if (isNew) {
+ // all data types created at the first time
+ status = ActionStatus.CREATED;
+ } else {
+ // All data types already exists
+
+ status = alreadyExistStatus;
+ }
+ }
+ }
+ }
+ representation = RepresentationUtils.toRepresentation(eitherResult.left().value());
+
+ Response response = buildOkResponse(getComponentsUtils().getResponseFormat(status), representation);
+ responseWrapper.setInnerElement(response);
+
+ } catch (IOException e) {
+ BeEcompErrorManager.getInstance().logBeRestApiGeneralError(CREATE + elementTypeName);
+ log.debug("failed to convert {} to json", elementTypeName, e);
+ Response response = buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));
+ responseWrapper.setInnerElement(response);
+ }
+ }
+ }
+ // relationship types
+ private void createRelationshipTypes(Wrapper<Response> responseWrapper, String relationshipTypesYml) {
+ final Supplier<Either<List<ImmutablePair<RelationshipTypeDefinition, Boolean>>, ResponseFormat>>
+ generateElementTypeFromYml =
+ () -> relationshipTypeImportManager.createRelationshipTypes(relationshipTypesYml);
+ buildStatusForElementTypeCreate(responseWrapper, generateElementTypeFromYml,
+ ActionStatus.RELATIONSHIP_TYPE_ALREADY_EXIST, NodeTypeEnum.RelationshipType.name());
+ }
+
+}
Code Review / sdc.git / blobdiff