Improve error reporting during the service import
[sdc.git] / catalog-be / src / main / java / org / openecomp / sdc / be / components / impl / CsarValidationUtils.java
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 package org.openecomp.sdc.be.components.impl;
21
22 import fj.data.Either;
23 import java.io.ByteArrayInputStream;
24 import java.io.IOException;
25 import java.io.StringReader;
26 import java.util.ArrayList;
27 import java.util.Arrays;
28 import java.util.List;
29 import java.util.Map;
30 import java.util.Optional;
31 import java.util.Properties;
32 import java.util.regex.Matcher;
33 import java.util.regex.Pattern;
34 import java.util.stream.Collectors;
35 import org.apache.commons.lang3.tuple.ImmutablePair;
36 import org.openecomp.sdc.be.config.BeEcompErrorManager;
37 import org.openecomp.sdc.be.config.BeEcompErrorManager.ErrorSeverity;
38 import org.openecomp.sdc.be.dao.api.ActionStatus;
39 import org.openecomp.sdc.be.impl.ComponentsUtils;
40 import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum;
41 import org.openecomp.sdc.be.tosca.CsarUtils;
42 import org.openecomp.sdc.common.log.wrappers.Logger;
43 import org.openecomp.sdc.common.util.GeneralUtility;
44 import org.openecomp.sdc.exception.ResponseFormat;
45
46 public class CsarValidationUtils {
47
48     private static final Logger log = Logger.getLogger(CsarValidationUtils.class.getName());
49     private static final String TOSCA_META_FILE_VERSION = "TOSCA-Meta-File-Version";
50     private static final String CSAR_VERSION = "CSAR-Version";
51     private static final String CREATED_BY = "Created-By";
52     private static final String NEW_LINE_DELM = "\n";
53     private static final String TOSCA_METADATA = "TOSCA-Metadata";
54     private static final String TOSCA_FILE = "TOSCA.meta";
55     private static final String DEL_PATTERN = "([/\\\\]+)";
56     public static final String TOSCA_METADATA_PATH_PATTERN = TOSCA_METADATA +
57         // Artifact Group (i.e Deployment/Informational)
58         DEL_PATTERN + TOSCA_FILE;
59     public static final String TOSCA_META_ENTRY_DEFINITIONS = "Entry-Definitions";
60     private static final String[] TOSCA_METADATA_FIELDS = {TOSCA_META_FILE_VERSION, CSAR_VERSION, CREATED_BY, TOSCA_META_ENTRY_DEFINITIONS};
61     private static final String ARTIFACTS_METADATA_FILE = "HEAT.meta";
62     private static final String TOSCA_CSAR_EXTENSION = ".csar";
63     private static final String TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID = "TOSCA-Metadata/TOSCA.meta file is not in expected key-value form in csar, csar ID {}";
64     private static final String TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID = "TOSCA-Metadata/TOSCA.meta file not in expected key-value form in CSAR with id ";
65     private static final String CSAR_INTERNALS_ARE_INVALID = "CSAR internals are invalid";
66     private static final String ENTRY_DEFINITIONS_ENTRY_NOT_FOUND_IN_TOSCA_METADATA_TOSCA_META_FILE_CSAR_ID = "Entry-Definitions entry not found in TOSCA-Metadata/TOSCA.meta file, csar ID {}";
67     private static final String FILE_NOT_FOUND_IN_CSAR_WITH_ID = " file not found in CSAR with id ";
68     private static final String CSAR_STRUCTURE_IS_INVALID = "CSAR structure is invalid";
69     private static final String ENTRY_DEFINITIONS = "Entry-Definitions ";
70     private static final Pattern floatPattern = Pattern.compile("^\\d{1}[.]\\d{1}$");
71
72     /**
73      * Utility classes, which are collections of static members, are not meant to be instantiated
74      */
75     private CsarValidationUtils() {
76     }
77
78     /**
79      * Validates Csar
80      *
81      * @param csar
82      * @param csarUUID
83      * @param componentsUtils
84      * @return
85      */
86     public static Either<Boolean, ResponseFormat> validateCsar(Map<String, byte[]> csar, String csarUUID, ComponentsUtils componentsUtils) {
87         Either<Boolean, ResponseFormat> validateStatus = validateIsTOSCAMetadataExist(csar, csarUUID, componentsUtils);
88         if (validateStatus.isRight()) {
89             return validateStatus;
90         }
91         removeNonUniqueArtifactsFromCsar(csar);
92         log.trace("TOSCA-Metadata/TOSCA.meta file found, CSAR id {}", csarUUID);
93         validateStatus = validateTOSCAMetadataFile(csar, csarUUID, componentsUtils);
94         if (validateStatus.isRight()) {
95             return validateStatus;
96         }
97         return Either.left(true);
98     }
99
100     private static void removeNonUniqueArtifactsFromCsar(Map<String, byte[]> csar) {
101         List<String> nonUniqueArtifactsToRemove = new ArrayList<>();
102         String[] paths = csar.keySet().toArray(new String[csar.keySet().size()]);
103         int numberOfArtifacts = paths.length;
104         for (int i = 0; i < numberOfArtifacts; ++i) {
105             collectNonUniqueArtifact(paths, i, numberOfArtifacts, nonUniqueArtifactsToRemove);
106         }
107         nonUniqueArtifactsToRemove.stream().forEach(csar::remove);
108     }
109
110     private static void collectNonUniqueArtifact(String[] paths, int currInd, int numberOfArtifacts, List<String> nonUniqueArtifactsToRemove) {
111         String[] parsedPath = paths[currInd].split("/");
112         String[] otherParsedPath;
113         int artifactNameInd = parsedPath.length - 1;
114         for (int j = currInd + 1; j < numberOfArtifacts; ++j) {
115             otherParsedPath = paths[j].split("/");
116             if (parsedPath.length == otherParsedPath.length && parsedPath.length > 3 && isEqualArtifactNames(parsedPath, otherParsedPath)) {
117                 log.error(
118                     "Can't upload two artifact with the same name {}. The artifact with path {} will be handled, and the artifact with path {} will be ignored. ",
119                     parsedPath[artifactNameInd], paths[currInd], paths[j]);
120                 nonUniqueArtifactsToRemove.add(paths[j]);
121             }
122         }
123     }
124
125     private static boolean isEqualArtifactNames(String[] parsedPath, String[] otherParsedPath) {
126         boolean isEqualArtifactNames = false;
127         int artifactNameInd = parsedPath.length - 1;
128         int artifactGroupTypeInd = parsedPath.length - 3;
129         String groupType = parsedPath[artifactGroupTypeInd];
130         String artifactName = parsedPath[artifactNameInd];
131         String otherGroupType = otherParsedPath[artifactGroupTypeInd];
132         String otherArtifactName = otherParsedPath[artifactNameInd];
133         String vfcToscaName = parsedPath.length == 5 ? parsedPath[1] : null;
134         if (artifactName.equalsIgnoreCase(otherArtifactName) && groupType.equalsIgnoreCase(otherGroupType)) {
135             isEqualArtifactNames = vfcToscaName == null || vfcToscaName.equalsIgnoreCase(otherParsedPath[1]);
136         }
137         return isEqualArtifactNames;
138     }
139
140     public static Either<ImmutablePair<String, String>, ResponseFormat> getToscaYaml(Map<String, byte[]> csar, String csarUUID,
141                                                                                      ComponentsUtils componentsUtils, AuditingActionEnum auditingAction) {
142         if (!AuditingActionEnum.UPDATE_SERVICE_TOSCA_TEMPLATE.equals(auditingAction)) {
143             Either<Boolean, ResponseFormat> validateStatus = validateIsTOSCAMetadataExist(csar, csarUUID, componentsUtils);
144             if (validateStatus.isRight()) {
145                 return Either.right(validateStatus.right().value());
146             }
147         }
148         Pattern pattern = Pattern.compile(TOSCA_METADATA_PATH_PATTERN);
149         Optional<String> keyOp = csar.keySet().stream().filter(k -> pattern.matcher(k).matches()).findAny();
150         if (keyOp.isEmpty()) {
151             log.error(TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID);
152             BeEcompErrorManager.getInstance()
153                 .logInternalDataError(TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID + csarUUID,
154                     CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
155             return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID_FORMAT, csarUUID,
156                 TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID));
157         }
158         Properties props = new Properties();
159         try {
160             props.load(new StringReader(new String(csar.get(keyOp.get())).replace("\\", "\\\\")));
161         } catch (IOException e) {
162             log.error(TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID, e);
163             BeEcompErrorManager.getInstance()
164                 .logInternalDataError(TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID + csarUUID,
165                     CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
166             return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID_FORMAT, csarUUID,
167                 TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID));
168         }
169         String yamlFileName = props.getProperty(TOSCA_META_ENTRY_DEFINITIONS);
170         String result = Arrays.asList(yamlFileName.split(DEL_PATTERN)).stream().map(x -> x).collect(Collectors.joining(DEL_PATTERN));
171         keyOp = csar.keySet().stream().filter(k -> Pattern.compile(result).matcher(k).matches()).findAny();
172         if (keyOp.isEmpty()) {
173             log.error(ENTRY_DEFINITIONS_ENTRY_NOT_FOUND_IN_TOSCA_METADATA_TOSCA_META_FILE_CSAR_ID, csarUUID);
174             BeEcompErrorManager.getInstance()
175                 .logInternalDataError(ENTRY_DEFINITIONS_ENTRY_NOT_FOUND_IN_TOSCA_METADATA_TOSCA_META_FILE_CSAR_ID + csarUUID,
176                     CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
177             return Either.right(componentsUtils.getResponseFormat(ActionStatus.YAML_NOT_FOUND_IN_CSAR, csarUUID, yamlFileName));
178         }
179         log.trace("Found Entry-Definitions property in TOSCA-Metadata/TOSCA.meta, Entry-Definitions: {}, CSAR id: {}", yamlFileName, csarUUID);
180         byte[] yamlFileBytes = csar.get(yamlFileName);
181         if (yamlFileBytes == null) {
182             log.error("Entry-Definitions {} file not found in csar, csar ID {}", yamlFileName, csarUUID);
183             BeEcompErrorManager.getInstance()
184                 .logInternalDataError(ENTRY_DEFINITIONS + yamlFileName + FILE_NOT_FOUND_IN_CSAR_WITH_ID + csarUUID, CSAR_STRUCTURE_IS_INVALID,
185                     ErrorSeverity.ERROR);
186             return Either.right(componentsUtils.getResponseFormat(ActionStatus.YAML_NOT_FOUND_IN_CSAR, csarUUID, yamlFileName));
187         }
188         return Either.left(new ImmutablePair<>(yamlFileName, new String(yamlFileBytes)));
189     }
190
191     public static Either<ImmutablePair<String, String>, ResponseFormat> getArtifactsMeta(Map<String, byte[]> csar, String csarUUID,
192                                                                                          ComponentsUtils componentsUtils) {
193         if (!csar.containsKey(CsarUtils.ARTIFACTS_PATH + ARTIFACTS_METADATA_FILE)) {
194             log.error(ENTRY_DEFINITIONS_ENTRY_NOT_FOUND_IN_TOSCA_METADATA_TOSCA_META_FILE_CSAR_ID, csarUUID);
195             BeEcompErrorManager.getInstance()
196                 .logInternalDataError(ENTRY_DEFINITIONS_ENTRY_NOT_FOUND_IN_TOSCA_METADATA_TOSCA_META_FILE_CSAR_ID + csarUUID,
197                     CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
198             return Either.right(componentsUtils.getResponseFormat(ActionStatus.YAML_NOT_FOUND_IN_CSAR, csarUUID, ARTIFACTS_METADATA_FILE));
199         }
200         log.trace("Found Entry-Definitions property in TOSCA-Metadata/TOSCA.meta, Entry-Definitions: {}, CSAR id: {}", ARTIFACTS_METADATA_FILE,
201             csarUUID);
202         byte[] artifactsMetaBytes = csar.get(CsarUtils.ARTIFACTS_PATH + ARTIFACTS_METADATA_FILE);
203         if (artifactsMetaBytes == null) {
204             log.error("Entry-Definitions {}{} file not found in csar, csar ID {}", CsarUtils.ARTIFACTS_PATH, ARTIFACTS_METADATA_FILE, csarUUID);
205             BeEcompErrorManager.getInstance().logInternalDataError(
206                 ENTRY_DEFINITIONS + CsarUtils.ARTIFACTS_PATH + ARTIFACTS_METADATA_FILE + FILE_NOT_FOUND_IN_CSAR_WITH_ID + csarUUID,
207                 CSAR_STRUCTURE_IS_INVALID, ErrorSeverity.ERROR);
208             return Either.right(
209                 componentsUtils.getResponseFormat(ActionStatus.YAML_NOT_FOUND_IN_CSAR, csarUUID, CsarUtils.ARTIFACTS_PATH + ARTIFACTS_METADATA_FILE));
210         }
211         return Either.left(new ImmutablePair<>(CsarUtils.ARTIFACTS_PATH + ARTIFACTS_METADATA_FILE, new String(artifactsMetaBytes)));
212     }
213
214     public static Either<ImmutablePair<String, byte[]>, ResponseFormat> getArtifactContent(String csarUUID, Map<String, byte[]> csar,
215                                                                                            String artifactPath, String artifactName,
216                                                                                            ComponentsUtils componentsUtils) {
217         if (!csar.containsKey(artifactPath)) {
218             log.error("Entry-Definitions entry not found in Artifacts/HEAT.meta file, csar ID {}", csarUUID);
219             BeEcompErrorManager.getInstance()
220                 .logInternalDataError(ENTRY_DEFINITIONS_ENTRY_NOT_FOUND_IN_TOSCA_METADATA_TOSCA_META_FILE_CSAR_ID + csarUUID,
221                     CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
222             return Either
223                 .right(componentsUtils.getResponseFormat(ActionStatus.ARTIFACT_NOT_FOUND_IN_CSAR, CsarUtils.ARTIFACTS_PATH + artifactName, csarUUID));
224         }
225         log.trace("Found Entry-Definitions property in Artifacts/HEAT.meta, Entry-Definitions: {}, CSAR id: {}", artifactPath, csarUUID);
226         byte[] artifactFileBytes = csar.get(artifactPath);
227         if (artifactFileBytes == null) {
228             log.error("Entry-Definitions {}{} file not found in csar, csar ID {}", CsarUtils.ARTIFACTS_PATH, artifactName, csarUUID);
229             BeEcompErrorManager.getInstance()
230                 .logInternalDataError(ENTRY_DEFINITIONS + artifactPath + FILE_NOT_FOUND_IN_CSAR_WITH_ID + csarUUID, CSAR_STRUCTURE_IS_INVALID,
231                     ErrorSeverity.ERROR);
232             return Either.right(componentsUtils.getResponseFormat(ActionStatus.ARTIFACT_NOT_FOUND_IN_CSAR, artifactPath, csarUUID));
233         }
234         return Either.left(new ImmutablePair<>(artifactName, artifactFileBytes));
235     }
236
237     private static Either<Boolean, ResponseFormat> validateTOSCAMetadataFile(Map<String, byte[]> csar, String csarUUID,
238                                                                              ComponentsUtils componentsUtils) {
239         Pattern pattern = Pattern.compile(TOSCA_METADATA_PATH_PATTERN);
240         Optional<String> keyOp = csar.keySet().stream().filter(k -> pattern.matcher(k).matches()).findAny();
241         if (keyOp.isEmpty()) {
242             log.error(TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID);
243             BeEcompErrorManager.getInstance()
244                 .logInternalDataError(TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID + csarUUID,
245                     CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
246             return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID_FORMAT, csarUUID,
247                 TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID));
248         }
249         String toscaMetadata = new String(csar.get(keyOp.get()));
250         String[] splited = toscaMetadata.split(NEW_LINE_DELM);
251         if (splited == null || splited.length < TOSCA_METADATA_FIELDS.length) {
252             log.error(TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID);
253             BeEcompErrorManager.getInstance()
254                 .logInternalDataError(TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID + csarUUID,
255                     CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
256             return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID_FORMAT, csarUUID,
257                 TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID));
258         }
259         Either<Boolean, ResponseFormat> blockStatus = validateBlock(csarUUID, splited, componentsUtils);
260         if (blockStatus.isRight()) {
261             return blockStatus;
262         }
263         return Either.left(true);
264     }
265
266     private static Either<Boolean, ResponseFormat> validateBlock(String csarUUID, String[] splited, ComponentsUtils componentsUtils) {
267         int index = 0;
268         for (String toscaField : TOSCA_METADATA_FIELDS) {
269             Properties props = new Properties();
270             try {
271                 props.load(new ByteArrayInputStream(splited[index].getBytes()));
272             } catch (IOException e) {
273                 log.error(TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID, e);
274                 BeEcompErrorManager.getInstance()
275                     .logInternalDataError(TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID + csarUUID,
276                         CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
277                 return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID_FORMAT, csarUUID,
278                     TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID));
279             }
280             if (!props.containsKey(toscaField)) {
281                 final String msg = "TOSCA.meta file format is invalid: No new line after block_0 as expected in csar, csar ID {}";
282                 log.error(msg, csarUUID);
283                 BeEcompErrorManager.getInstance()
284                     .logInternalDataError(TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID + csarUUID,
285                         CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
286                 return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID_FORMAT, csarUUID, msg, csarUUID));
287             }
288             final String value = props.getProperty(toscaField);
289             if (value == null || value.isEmpty()) {
290                 log.error(TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID);
291                 BeEcompErrorManager.getInstance()
292                     .logInternalDataError(TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID + csarUUID,
293                         CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
294                 return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID_FORMAT, csarUUID,
295                     TOSCA_METADATA_TOSCA_META_FILE_IS_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_CSAR_ID, csarUUID));
296             }
297             // TOSCA-Meta-File-Version & CSAR-Version : digit.digit - format validation
298             if ((toscaField.equals(TOSCA_META_FILE_VERSION) || toscaField.equals(CSAR_VERSION)) && !validateTOSCAMetaProperty(value)) {
299                 final String msg = "TOSCA-Metadata/TOSCA.meta file contains {} in wrong format (digit.digit), csar ID {}";
300                 log.error(msg, toscaField, csarUUID);
301                 BeEcompErrorManager.getInstance()
302                     .logInternalDataError(TOSCA_METADATA_TOSCA_META_FILE_NOT_IN_EXPECTED_KEY_VALUE_FORM_IN_CSAR_WITH_ID + csarUUID,
303                         CSAR_INTERNALS_ARE_INVALID, ErrorSeverity.ERROR);
304                 return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID_FORMAT, csarUUID, msg, toscaField, csarUUID));
305             }
306             index++;
307         }
308         return Either.left(true);
309     }
310
311     private static boolean validateTOSCAMetaProperty(String toscaProperty) {
312         return floatPattern.matcher(toscaProperty).matches();
313     }
314
315     private static Either<Boolean, ResponseFormat> validateIsTOSCAMetadataExist(Map<String, byte[]> csar, String csarUUID,
316                                                                                 ComponentsUtils componentsUtils) {
317         if (csar == null || csar.isEmpty()) {
318             log.error("Error when fetching csar with ID {}", csarUUID);
319             BeEcompErrorManager.getInstance().logBeDaoSystemError("Creating resource from CSAR: fetching CSAR with id " + csarUUID + " failed");
320             return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID, csarUUID));
321         }
322         Pattern pattern = Pattern.compile(TOSCA_METADATA_PATH_PATTERN);
323         Optional<String> keyOp = csar.keySet().stream().filter(k -> pattern.matcher(k).matches()).findAny();
324         if (keyOp.isEmpty()) {
325             log.error("TOSCA-Metadata/TOSCA.meta file not found in csar, csar ID {}", csarUUID);
326             BeEcompErrorManager.getInstance()
327                 .logInternalDataError("TOSCA-Metadata/TOSCA.meta file not found in CSAR with id " + csarUUID, CSAR_STRUCTURE_IS_INVALID,
328                     ErrorSeverity.ERROR);
329             return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID, csarUUID));
330         }
331         byte[] toscaMetaBytes = csar.get(keyOp.get());
332         if (toscaMetaBytes == null || toscaMetaBytes.length == 0) {
333             log.error("TOSCA-Metadata/TOSCA.meta file not found in csar, csar ID {}", csarUUID);
334             BeEcompErrorManager.getInstance()
335                 .logInternalDataError("TOSCA-Metadata/TOSCA.meta file not found in CSAR with id " + csarUUID, CSAR_STRUCTURE_IS_INVALID,
336                     ErrorSeverity.ERROR);
337             return Either.right(componentsUtils.getResponseFormat(ActionStatus.CSAR_INVALID, csarUUID));
338         }
339         return Either.left(Boolean.TRUE);
340     }
341
342     public static Either<String, ResponseFormat> getToscaYamlChecksum(Map<String, byte[]> csar, String csarUUID, ComponentsUtils componentsUtils) {
343         Either<ImmutablePair<String, String>, ResponseFormat> toscaYamlRes = getToscaYaml(csar, csarUUID, componentsUtils, AuditingActionEnum.GET_TOSCA_MODEL);
344         if (toscaYamlRes.isRight() || toscaYamlRes.left().value() == null || toscaYamlRes.left().value().getRight() == null) {
345             log.error("Faild to create toscaYamlChecksum for csar, csar ID {}", csarUUID);
346             return Either.right(toscaYamlRes.right().value());
347         }
348         return Either.left(GeneralUtility.calculateMD5Base64EncodedByByteArray(toscaYamlRes.left().value().getRight().getBytes()));
349     }
350
351     public static boolean isCsarPayloadName(String payloadName) {
352         return payloadName != null && payloadName.toLowerCase().endsWith(TOSCA_CSAR_EXTENSION);
353     }
354 }