369efe38bcbfe82751a98679ee45ffa2374646a2
[sdc.git] /
1 /*-
2  * ============LICENSE_START=======================================================
3  * SDC
4  * ================================================================================
5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  * 
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  * 
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20
21 package org.openecomp.sdc.vendorsoftwareproduct.utils;
22
23 import org.apache.commons.collections4.CollectionUtils;
24 import org.apache.commons.collections4.MapUtils;
25 import org.openecomp.core.enrichment.types.MonitoringUploadType;
26 import org.openecomp.core.utilities.file.FileContentHandler;
27 import org.openecomp.sdc.common.errors.ErrorCode;
28 import org.openecomp.sdc.common.errors.Messages;
29 import org.openecomp.sdc.common.utils.SdcCommon;
30 import org.openecomp.sdc.datatypes.error.ErrorLevel;
31 import org.openecomp.sdc.datatypes.error.ErrorMessage;
32 import org.openecomp.sdc.logging.api.Logger;
33 import org.openecomp.sdc.logging.api.LoggerFactory;
34 import org.openecomp.sdc.logging.context.impl.MdcDataErrorMessage;
35 import org.openecomp.sdc.logging.types.LoggerConstants;
36 import org.openecomp.sdc.logging.types.LoggerErrorDescription;
37 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComponentMonitoringUploadEntity;
38 import org.openecomp.sdc.vendorsoftwareproduct.types.OrchestrationTemplateActionResponse;
39 import org.slf4j.MDC;
40
41 import java.io.File;
42 import java.util.ArrayList;
43 import java.util.Collection;
44 import java.util.HashMap;
45 import java.util.List;
46 import java.util.Map;
47
48 public class VendorSoftwareProductUtils {
49
50   protected static Logger logger =
51       LoggerFactory.getLogger(VendorSoftwareProductUtils.class);
52
53   /**
54    * Add file names to upload file response.
55    *
56    * @param fileContentMap     the file content map
57    * @param uploadFileResponse the upload file response
58    */
59   public static void addFileNamesToUploadFileResponse(FileContentHandler fileContentMap,
60                                                       OrchestrationTemplateActionResponse uploadFileResponse) {
61     uploadFileResponse.setFileNames(new ArrayList<>());
62     for (String filename : fileContentMap.getFileList()) {
63       if (!new File(filename).isDirectory()) {
64         uploadFileResponse.addNewFileToList(filename);
65       }
66     }
67     uploadFileResponse.removeFileFromList(SdcCommon.MANIFEST_NAME);
68   }
69
70
71   /**
72    * Validate content zip data.
73    *
74    * @param contentMap the content map
75    * @param errors     the errors
76    */
77   public static void validateContentZipData(FileContentHandler contentMap,
78                                             Map<String, List<ErrorMessage>> errors) {
79     MDC.put(LoggerConstants.ERROR_DESCRIPTION, LoggerErrorDescription.INVALID_ZIP);
80     if (contentMap.getFileList().isEmpty()) {
81       ErrorMessage.ErrorMessageUtil.addMessage(SdcCommon.UPLOAD_FILE, errors)
82           .add(new ErrorMessage(ErrorLevel.ERROR, Messages.INVALID_ZIP_FILE.getErrorMessage()));
83     }
84   }
85
86
87   /**
88    * Maps all artifacts by type.
89    *
90    * @param artifacts the artifacts
91    * @return the map
92    */
93   public static Map<MonitoringUploadType, String> mapArtifactsByType(
94       Collection<ComponentMonitoringUploadEntity> artifacts) {
95     Map<MonitoringUploadType, String> artifactTypeToFilename = new HashMap<>();
96
97     for (ComponentMonitoringUploadEntity entity : artifacts) {
98       artifactTypeToFilename.put(entity.getType(), entity.getArtifactName());
99     }
100
101     return artifactTypeToFilename;
102   }
103
104
105   /**
106    * Sets errors into logger.
107    *  @param errors            the errors
108    * @param targetServiceName the target service name
109    */
110   public static void setErrorsIntoLogger(Map<String, List<ErrorMessage>> errors,
111                                          String targetServiceName) {
112     MdcDataErrorMessage mdcDataErrorMessage =
113         new MdcDataErrorMessage(targetServiceName, LoggerConstants.TARGET_ENTITY_DB,
114             ErrorLevel.ERROR.name(), null, null);
115     mdcDataErrorMessage.setMdcValues();
116
117     if (MapUtils.isEmpty(errors)) {
118       return;
119     }
120
121     for (Map.Entry<String, List<ErrorMessage>> listEntry : errors.entrySet()) {
122       List<ErrorMessage> errorList = listEntry.getValue();
123       for (ErrorMessage message : errorList) {
124         logger.error(message.getMessage());
125       }
126     }
127   }
128
129   /**
130    * Sets errors into logger.
131    *  @param errors            the errors
132    * @param targetServiceName the target service name
133    */
134   public static void setErrorsIntoLogger(Collection<ErrorCode> errors,
135                                          String targetServiceName) {
136     MdcDataErrorMessage mdcDataErrorMessage =
137         new MdcDataErrorMessage(targetServiceName, LoggerConstants.TARGET_ENTITY_DB,
138             ErrorLevel.ERROR.name(), null, null);
139     mdcDataErrorMessage.setMdcValues();
140
141     if (CollectionUtils.isEmpty(errors)) {
142       return;
143     }
144
145     for (ErrorCode error : errors) {
146       logger.error(error.message());
147     }
148   }
149 }