diff options
author | 2019-04-11 16:14:34 +0000 | |
---|---|---|
committer | 2019-04-11 16:14:34 +0000 | |
commit | ad6135a4855f4daddc67af36bb5a77819b1bb592 (patch) | |
tree | 1be00f8cde960417783ae27758c33d59f639b9a5 /models-interactions/model-impl | |
parent | 891bffd9f13177d96ad26acdfa7148d09e1d682a (diff) | |
parent | 23fc065efe1a2152b6bea3d522039784c3c29488 (diff) |
Merge "Aai Simulator for CQ"
Diffstat (limited to 'models-interactions/model-impl')
-rw-r--r-- | models-interactions/model-impl/aai/src/main/java/org/onap/policy/aai/AaiManager.java | 17 |
1 files changed, 10 insertions, 7 deletions
diff --git a/models-interactions/model-impl/aai/src/main/java/org/onap/policy/aai/AaiManager.java b/models-interactions/model-impl/aai/src/main/java/org/onap/policy/aai/AaiManager.java index f50f0cb9f..891114aa1 100644 --- a/models-interactions/model-impl/aai/src/main/java/org/onap/policy/aai/AaiManager.java +++ b/models-interactions/model-impl/aai/src/main/java/org/onap/policy/aai/AaiManager.java @@ -50,9 +50,10 @@ public final class AaiManager { private final RestManager restManager; /** custom query URLs. */ - private static String cqUrl = "/aai/v16/query?format=resource"; - private static String tenantUrl = "/aai/v16/search/nodes-query?search-node-type=vserver&filter=vserver-name:"; - private static String prefix = "/aai/v16"; + private static final String CQ_URL = "/aai/v16/query?format=resource"; + private static final String TENANT_URL = + "/aai/v16/search/nodes-query?search-node-type=vserver&filter=vserver-name:EQUALS:"; + private static final String PREFIX = "/aai/v16"; /** @@ -83,7 +84,7 @@ public final class AaiManager { return null; } String resourceLink = resultsArray.getJSONObject(0).getString("resource-link"); - String start = resourceLink.replace(prefix, ""); + String start = resourceLink.replace(PREFIX, ""); String query = "query/closed-loop"; JSONObject payload = new JSONObject(); payload.put("start", start); @@ -107,7 +108,8 @@ public final class AaiManager { private String getCustomQueryRequestPayload(String url, String username, String password, UUID requestId, String vserver) { - String urlGet = url + tenantUrl; + String urlGet = url + TENANT_URL; + String getResponse = getStringQuery(urlGet, username, password, requestId, vserver); return createCustomQueryPayload(getResponse); } @@ -129,11 +131,12 @@ public final class AaiManager { final Map<String, String> headers = createHeaders(requestId); - url = url + cqUrl; - logger.debug("RestManager.put before"); String requestJson = getCustomQueryRequestPayload(url, username, password, requestId, vserver); NetLoggerUtil.log(EventType.OUT, CommInfrastructure.REST, url, requestJson); + + url = url + CQ_URL; + Pair<Integer, String> httpDetails = this.restManager.put(url, username, password, headers, "application/json", requestJson); logger.debug("RestManager.put after"); |