diff options
Diffstat (limited to 'cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/utils/CmHandleIdMapper.java')
-rw-r--r-- | cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/utils/CmHandleIdMapper.java | 33 |
1 files changed, 8 insertions, 25 deletions
diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/utils/CmHandleIdMapper.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/utils/CmHandleIdMapper.java index 40c620f50..a88adbd11 100644 --- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/utils/CmHandleIdMapper.java +++ b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/utils/CmHandleIdMapper.java @@ -55,10 +55,15 @@ public class CmHandleIdMapper { private boolean addMappingWithValidation(final String cmHandleId, final String alternateId) { - if (StringUtils.isBlank(alternateId)) { + if (alternateIdPerCmHandleId.containsKey(cmHandleId)) { + final String originalAlternateId = alternateIdPerCmHandleId.get(cmHandleId); + if (!originalAlternateId.equals(alternateId)) { + log.warn("Alternate id update ignored, cannot update cm handle {}, already has an alternate id of {}", + cmHandleId, originalAlternateId); + } return false; } - if (isDuplicateId(cmHandleId, alternateId)) { + if (StringUtils.isBlank(alternateId)) { return false; } alternateIdPerCmHandleId.put(cmHandleId, alternateId); @@ -77,32 +82,10 @@ public class CmHandleIdMapper { } } - /** - * Check if alternate id is already used. - * - * @param cmHandleId the cmHandle id. - * @param alternateId the alternate id. - * @return boolean true if the alternate id is already used. - */ - public boolean isDuplicateId(final String cmHandleId, final String alternateId) { - if (StringUtils.isBlank(alternateId)) { - return false; - } - if (cmHandleIdPerAlternateId.get(alternateId) != null) { - log.warn("The given alternate id was added to the cache already: {}", alternateId); - return true; - } - if (alternateIdPerCmHandleId.get(cmHandleId) != null) { - log.warn("The given cmhandle id was added to the cache already: {}", cmHandleId); - return true; - } - return false; - } - private void initializeCache() { if (!cacheIsInitialized) { networkCmProxyCmHandleQueryService.getAllCmHandles().forEach(cmHandle -> - addMappingWithValidation(cmHandle.getCmHandleId(), cmHandle.getAlternateId()) + addMappingWithValidation(cmHandle.getCmHandleId(), cmHandle.getAlternateId()) ); log.info("Alternate ID cache initialized from DB with {} cm handle/alternate id pairs ", alternateIdPerCmHandleId.size()); |