2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2021 Nordix Foundation
4 * ================================================================================
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
9 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
16 * SPDX-License-Identifier: Apache-2.0
17 * ============LICENSE_END=========================================================
19 package org.openecomp.sdc.be.servlets;
21 import com.googlecode.jmapper.JMapper;
22 import com.jcabi.aspects.Loggable;
23 import io.swagger.v3.oas.annotations.Operation;
24 import io.swagger.v3.oas.annotations.Parameter;
25 import io.swagger.v3.oas.annotations.media.ArraySchema;
26 import io.swagger.v3.oas.annotations.media.Content;
27 import io.swagger.v3.oas.annotations.media.Schema;
28 import io.swagger.v3.oas.annotations.responses.ApiResponse;
29 import io.swagger.v3.oas.annotations.servers.Server;
30 import io.swagger.v3.oas.annotations.tags.Tag;
31 import java.io.InputStream;
32 import java.util.Arrays;
33 import java.util.List;
34 import javax.inject.Inject;
35 import javax.validation.Valid;
36 import javax.validation.constraints.NotNull;
37 import javax.ws.rs.Consumes;
38 import javax.ws.rs.GET;
39 import javax.ws.rs.HeaderParam;
40 import javax.ws.rs.POST;
41 import javax.ws.rs.PUT;
42 import javax.ws.rs.Path;
43 import javax.ws.rs.Produces;
44 import javax.ws.rs.QueryParam;
45 import javax.ws.rs.core.MediaType;
46 import javax.ws.rs.core.Response;
47 import javax.ws.rs.core.Response.Status;
48 import org.apache.commons.lang3.StringUtils;
49 import org.glassfish.jersey.media.multipart.FormDataParam;
50 import org.openecomp.sdc.be.components.impl.ComponentInstanceBusinessLogic;
51 import org.openecomp.sdc.be.components.impl.ModelBusinessLogic;
52 import org.openecomp.sdc.be.components.impl.ResourceImportManager;
53 import org.openecomp.sdc.be.components.validation.UserValidations;
54 import org.openecomp.sdc.be.config.BeEcompErrorManager;
55 import org.openecomp.sdc.be.dao.api.ActionStatus;
56 import org.openecomp.sdc.be.datatypes.enums.ModelTypeEnum;
57 import org.openecomp.sdc.be.exception.BusinessException;
58 import org.openecomp.sdc.be.impl.ComponentsUtils;
59 import org.openecomp.sdc.be.impl.ServletUtils;
60 import org.openecomp.sdc.be.model.Model;
61 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.exception.ModelOperationExceptionSupplier;
62 import org.openecomp.sdc.be.ui.model.ModelCreateRequest;
63 import org.openecomp.sdc.be.user.Role;
64 import org.openecomp.sdc.common.api.Constants;
65 import org.openecomp.sdc.common.util.ValidationUtils;
66 import org.slf4j.Logger;
67 import org.slf4j.LoggerFactory;
68 import org.springframework.stereotype.Controller;
71 * Root resource (exposed at "/" path)
73 @Loggable(prepend = true, value = Loggable.DEBUG, trim = false)
75 @Tag(name = "SDCE-2 APIs")
76 @Server(url = "/sdc2/rest")
78 public class ModelServlet extends AbstractValidationsServlet {
80 private static final Logger log = LoggerFactory.getLogger(ModelServlet.class);
81 private final ModelBusinessLogic modelBusinessLogic;
82 private final UserValidations userValidations;
85 public ModelServlet(final ComponentInstanceBusinessLogic componentInstanceBL,
86 final ComponentsUtils componentsUtils, final ServletUtils servletUtils, final ResourceImportManager resourceImportManager,
87 final ModelBusinessLogic modelBusinessLogic, final UserValidations userValidations) {
88 super(componentInstanceBL, componentsUtils, servletUtils, resourceImportManager);
89 this.modelBusinessLogic = modelBusinessLogic;
90 this.userValidations = userValidations;
95 @Consumes(MediaType.MULTIPART_FORM_DATA)
96 @Produces(MediaType.APPLICATION_JSON)
97 @Operation(description = "Create a TOSCA model, along with its imports files", method = "POST", summary = "Create a TOSCA model", responses = {
98 @ApiResponse(content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))),
99 @ApiResponse(responseCode = "201", description = "Model created"),
100 @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
101 @ApiResponse(responseCode = "403", description = "Restricted operation"),
102 @ApiResponse(responseCode = "409", description = "Model already exists")})
103 public Response createModel(@Parameter(description = "model to be created", required = true)
104 @NotNull @Valid @FormDataParam("model") final ModelCreateRequest modelCreateRequest,
105 @Parameter(description = "the model TOSCA imports zipped", required = true)
106 @NotNull @FormDataParam("modelImportsZip") final InputStream modelImportsZip,
107 @HeaderParam(value = Constants.USER_ID_HEADER) final String userId) {
108 validateUser(ValidationUtils.sanitizeInputString(userId));
109 final var modelName = ValidationUtils.sanitizeInputString(modelCreateRequest.getName().trim());
111 final Model createdModel = modelBusinessLogic
112 .createModel(new JMapper<>(Model.class, ModelCreateRequest.class).getDestination(modelCreateRequest));
113 modelBusinessLogic.createModelImports(modelName, modelImportsZip);
114 return buildOkResponse(getComponentsUtils().getResponseFormat(ActionStatus.CREATED),
115 RepresentationUtils.toRepresentation(createdModel));
116 } catch (final BusinessException e) {
118 } catch (final Exception e) {
119 var errorMsg = String.format("Unexpected error while creating model '%s' imports", modelName);
120 BeEcompErrorManager.getInstance().logBeRestApiGeneralError(errorMsg);
121 log.error(errorMsg, e);
122 return buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));
128 @Produces(MediaType.APPLICATION_JSON)
129 @Operation(method = "GET", summary = "List TOSCA models", description = "List all the existing TOSCA models",
131 @ApiResponse(content = @Content(array = @ArraySchema(schema = @Schema(implementation = Model.class)))),
132 @ApiResponse(responseCode = "200", description = "Listing successful"),
133 @ApiResponse(responseCode = "403", description = "Restricted operation")
136 public Response listModels(@HeaderParam(value = Constants.USER_ID_HEADER) final String userId, @QueryParam("modelType") final String modelType) {
137 validateUser(ValidationUtils.sanitizeInputString(userId));
139 final List<Model> modelList =
140 StringUtils.isEmpty(modelType) ? modelBusinessLogic.listModels() : modelBusinessLogic.listModels(getModelTypeEnum(modelType));
141 return buildOkResponse(getComponentsUtils().getResponseFormat(ActionStatus.OK), RepresentationUtils.toRepresentation(modelList));
142 } catch (final BusinessException e) {
144 } catch (final Exception e) {
145 var errorMsg = "Unexpected error while listing the models";
146 BeEcompErrorManager.getInstance().logBeRestApiGeneralError(errorMsg);
147 log.error(errorMsg, e);
148 return buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));
152 private ModelTypeEnum getModelTypeEnum(final String modelType) {
153 final ModelTypeEnum modelTypeEnum = ModelTypeEnum.valueOf(modelType.toUpperCase());
154 if (modelTypeEnum == null) {
155 throw ModelOperationExceptionSupplier.unknownModelType(modelType).get();
157 return modelTypeEnum;
161 @Path("/model/imports")
162 @Consumes(MediaType.MULTIPART_FORM_DATA)
163 @Produces(MediaType.APPLICATION_JSON)
164 @Operation(description = "Update a model TOSCA imports", method = "PUT", summary = "Update a model TOSCA imports", responses = {
165 @ApiResponse(content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class)))),
166 @ApiResponse(responseCode = "204", description = "Model imports updated"),
167 @ApiResponse(responseCode = "400", description = "Invalid content / Missing content"),
168 @ApiResponse(responseCode = "403", description = "Restricted operation"),
169 @ApiResponse(responseCode = "404", description = "Model not found")})
170 public Response updateModelImports(@Parameter(description = "model to be created", required = true)
171 @NotNull @FormDataParam("modelName") String modelName,
172 @Parameter(description = "the model TOSCA imports zipped", required = true)
173 @NotNull @FormDataParam("modelImportsZip") final InputStream modelImportsZip,
174 @HeaderParam(value = Constants.USER_ID_HEADER) final String userId) {
175 validateUser(ValidationUtils.sanitizeInputString(userId));
176 modelName = ValidationUtils.sanitizeInputString(modelName);
178 modelBusinessLogic.createModelImports(modelName, modelImportsZip);
179 } catch (final BusinessException e) {
181 } catch (final Exception e) {
182 var errorMsg = String.format("Unexpected error while creating model '%s' imports", modelName);
183 BeEcompErrorManager.getInstance().logBeRestApiGeneralError(errorMsg);
184 log.error(errorMsg, e);
185 return buildErrorResponse(getComponentsUtils().getResponseFormat(ActionStatus.GENERAL_ERROR));
187 return Response.status(Status.NO_CONTENT).build();
190 private void validateUser(final String userId) {
191 userValidations.validateUserRole(userValidations.validateUserExists(userId), Arrays.asList(Role.DESIGNER, Role.ADMIN));