diff options
author | ChrisC <cc697w@intl.att.com> | 2017-01-31 11:40:03 +0100 |
---|---|---|
committer | ChrisC <cc697w@intl.att.com> | 2017-01-31 12:59:33 +0100 |
commit | 025301d08b061482c1f046d562bf017c8cbcfe8d (patch) | |
tree | 68a2a549736c9bf0f7cd4e71c76e40ef7e2606f2 /mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/MockRequestsDatabase.java | |
parent | 2754ad52f833278a5c925bd788a16d1dce16a598 (diff) |
Initial OpenECOMP MSO commit
Change-Id: Ia6a7574859480717402cc2f22534d9973a78fa6d
Signed-off-by: ChrisC <cc697w@intl.att.com>
Diffstat (limited to 'mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/MockRequestsDatabase.java')
-rw-r--r-- | mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/MockRequestsDatabase.java | 72 |
1 files changed, 72 insertions, 0 deletions
diff --git a/mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/MockRequestsDatabase.java b/mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/MockRequestsDatabase.java new file mode 100644 index 0000000000..22179e95f8 --- /dev/null +++ b/mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/MockRequestsDatabase.java @@ -0,0 +1,72 @@ +/*- + * ============LICENSE_START======================================================= + * OPENECOMP - MSO + * ================================================================================ + * 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.mso.requestsdb; + + + +import java.util.HashMap; +import java.util.Map; + +public class MockRequestsDatabase { + + private Map<String, InfraActiveRequests> activeRequests; + + public MockRequestsDatabase() { + activeRequests = new HashMap<String, InfraActiveRequests>(); + } + + public void addRecord(InfraActiveRequests record) { + String serviceType = record.getServiceType(); + String serviceInstanceId = record.getServiceInstanceId(); + String key = serviceType + "::" + serviceInstanceId; + activeRequests.put(key, record); + } + + public void deleteRecord(String serviceType, String serviceInstanceId) { + String key = serviceType + "::" + serviceInstanceId; + activeRequests.remove(key); + } + + public InfraActiveRequests getRecord(String serviceType, String serviceInstanceId) { + String key = serviceType + "::" + serviceInstanceId; + InfraActiveRequests record = activeRequests.get(key); + return record; + } + + public InfraActiveRequests checkDuplicate(String serviceType, String serviceInstanceId) { + return getRecord(serviceType, serviceInstanceId); + } + + public InfraActiveRequests checkRetry(String serviceType, String serviceInstanceId) { + InfraActiveRequests record = getRecord(serviceType, serviceInstanceId); + InfraActiveRequests returnRecord = null; + if (record != null) { + String requestAction = record.getRequestAction(); + if (requestAction == null || !requestAction.equals("GetLayer3ServiceDetailsRequest")) { + String status = record.getRequestStatus(); + if (status != null && status.equals("COMPLETED")) { + return returnRecord = record; + } + } + } + return returnRecord; + } +} |