2 * ============LICENSE_START=======================================================
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.onap.so.client.sdno;
23 import java.io.FileNotFoundException;
24 import java.io.IOException;
25 import java.util.ArrayList;
26 import java.util.Collections;
27 import java.util.List;
28 import java.util.Optional;
30 import org.onap.so.client.dmaap.DmaapConsumer;
31 import org.onap.so.client.dmaap.DmaapPublisher;
32 import org.onap.so.client.sdno.beans.AAIParamList;
33 import org.onap.so.client.sdno.beans.Body;
34 import org.onap.so.client.sdno.beans.Input;
35 import org.onap.so.client.sdno.beans.RequestHdCustom;
36 import org.onap.so.client.sdno.beans.SDNO;
37 import org.onap.so.client.sdno.dmaap.SDNOHealthCheckDmaapConsumer;
38 import org.onap.so.client.sdno.dmaap.SDNOHealthCheckDmaapPublisher;
40 import com.fasterxml.jackson.core.JsonProcessingException;
41 import com.fasterxml.jackson.databind.ObjectMapper;
43 public class SDNOHealthCheckClient {
45 private static final String NODE_TYPE = "VROUTER";
46 private static final String API_OPERATION_TYPE = "health-diagnostic-custom";
47 private static final String MIRRORING_CHECK = "mirroring_check";
48 private static final String CLIENT_NAME = "MSO";
49 private static final String PRE_CHECK_CODE = "VROUTER000003";
50 private static final String POST_CHECK_CODE = "VROUTER000004";
51 private static final String LPORT_MIRRORING_CHECK = "lport_mirroring_check";
52 private static final String CONFIGURATION_ID = "configuration-id";
55 public boolean lPortMirrorHealthPreCheck(String userId, String requestId, Optional<String>clliCode, String configurationId, String interfaceId) throws Exception{
56 String request = buildLPortMirrorCheckPreRequest(userId, requestId, clliCode, configurationId, interfaceId);
57 return this.execute(requestId, request);
60 public boolean lPortMirrorHealthPostCheck(String userId, String requestId, Optional<String>clliCode, String configurationId, String interfaceId) throws Exception{
61 String request = buildLPortMirrorCheckPostRequest(userId, requestId, clliCode, configurationId, interfaceId);
62 return this.execute(requestId, request);
65 public boolean portMirrorHealthPreCheck(String userId, String requestId, Optional<String> clliCode, String configurationId) throws Exception {
66 final String request = this.buildPortMirrorPreCheckRequest(userId, requestId, clliCode, configurationId);
67 return this.execute(requestId, request);
70 public boolean portMirrorHealthPostCheck(String userId, String requestId, Optional<String> clliCode, String configurationId) throws Exception {
71 final String request = this.buildPortMirrorPostCheckRequest(userId, requestId, clliCode, configurationId);
72 return this.execute(requestId, request);
75 protected String buildLPortMirrorCheckPreRequest(String userId, String requestId, Optional<String> clliCode, String configurationId, String interfaceId) throws JsonProcessingException{
76 return this.buildLPortMirrorCheckRequest(userId, requestId, clliCode, configurationId, interfaceId, PRE_CHECK_CODE);
79 protected String buildLPortMirrorCheckPostRequest(String userId, String requestId, Optional<String> clliCode, String configurationId, String interfaceId) throws JsonProcessingException{
80 return this.buildLPortMirrorCheckRequest(userId, requestId, clliCode, configurationId, interfaceId, POST_CHECK_CODE);
83 protected String buildPortMirrorPreCheckRequest(String userId, String requestId, Optional<String> clliCode, String configurationId) throws JsonProcessingException {
84 return this.buildPortMirrorCheckRequest(userId, requestId, clliCode, configurationId, PRE_CHECK_CODE);
87 protected String buildPortMirrorPostCheckRequest(String userId, String requestId, Optional<String> clliCode, String configurationId) throws JsonProcessingException {
88 return this.buildPortMirrorCheckRequest(userId, requestId, clliCode, configurationId, POST_CHECK_CODE);
91 protected String buildPortMirrorCheckRequest(String userId, String requestId, Optional<String> clliCode, String configurationId, String diagnosticCode) throws JsonProcessingException {
92 final AAIParamList list = new AAIParamList();
93 list.setKey(CONFIGURATION_ID);
94 list.setValue(configurationId);
96 return this.buildRequest(userId, requestId, clliCode, diagnosticCode, MIRRORING_CHECK, Collections.singletonList(list));
99 protected String buildLPortMirrorCheckRequest(String userId, String requestId, Optional<String> clliCode, String configurationId, String interfaceId, String diagnosticCode) throws JsonProcessingException {
101 final AAIParamList configurationIdParam = new AAIParamList();
102 configurationIdParam.setKey(CONFIGURATION_ID);
103 configurationIdParam.setValue(configurationId);
104 final AAIParamList interfaceIdParam = new AAIParamList();
105 interfaceIdParam.setKey("interface-id");
106 interfaceIdParam.setValue(interfaceId);
107 final List<AAIParamList> list = new ArrayList<>();
108 list.add(configurationIdParam);
109 list.add(interfaceIdParam);
110 return this.buildRequest(userId, requestId, clliCode, diagnosticCode, LPORT_MIRRORING_CHECK, list);
114 protected String buildRequest(String userId, String requestId, Optional<String> clliCode, String diagnosticCode, String operationType, List<AAIParamList> paramList) throws JsonProcessingException {
116 final RequestHdCustom hdCustom = new RequestHdCustom();
117 hdCustom.withRequestUserId(userId)
118 .withRequestId(requestId)
119 .withRequestClientName(CLIENT_NAME)
120 .withHealthDiagnosticCode(diagnosticCode)
121 .withOperationType(operationType)
122 .withAaiParamList(paramList);
124 final Input input = new Input();
125 input.setRequestHdCustom(hdCustom);
126 final Body body = new Body();
127 body.setInput(input);
128 final SDNO request = new SDNO();
129 request.withBody(body).withOperation(API_OPERATION_TYPE).withNodeType(NODE_TYPE);
130 if (clliCode.isPresent()) {
131 request.setNodeLoc(clliCode.get());
133 return this.getJson(request);
136 protected String getJson(SDNO obj) throws JsonProcessingException {
137 final ObjectMapper mapper = new ObjectMapper();
138 return mapper.writeValueAsString(obj);
141 protected DmaapPublisher getPublisher() throws FileNotFoundException, IOException {
142 return new SDNOHealthCheckDmaapPublisher();
145 protected DmaapConsumer getConsumer(String requestId) throws FileNotFoundException, IOException {
146 return new SDNOHealthCheckDmaapConsumer(requestId);
149 protected boolean execute(String requestId, String request) throws Exception {
150 final DmaapPublisher publisher = this.getPublisher();
151 publisher.send(request);
153 final DmaapConsumer consumer = this.getConsumer(requestId);
155 return consumer.consume();