import org.onap.logging.ref.slf4j.ONAPLogAdapter;\r
import org.onap.sdnc.apps.pomba.networkdiscovery.ApplicationException;\r
\r
+import org.slf4j.Logger;\r
+\r
public class OSAuthentication {\r
\r
private static final String CONFIG_AUTH_DIR = "config/auth";\r
OperationResult result = openstackClient.post(openstackIdentityUrl, payload, headers,\r
MediaType.APPLICATION_JSON_TYPE, MediaType.APPLICATION_JSON_TYPE);\r
\r
- adapter.unwrap().info("request at url = {} resulted in http response: {}", openstackIdentityUrl,\r
- result.getResult());\r
+ Logger log = adapter.unwrap();\r
+\r
+ if (result.wasSuccessful()) {\r
+ log.info("request at url = {} resulted in http response code: {}", \r
+ openstackIdentityUrl, result.getResultCode());\r
+ } else {\r
+ log.error("request at url = {} resulted in http response code: {}. Failure cause: {}", \r
+ openstackIdentityUrl, result.getResultCode(), result.getFailureCause());\r
+ }\r
+\r
\r
String token = result.getHeaders().getFirst(X_SUBJECT_TOKEN);\r
\r
throw new ApplicationException(UNAUTHORIZED, Status.UNAUTHORIZED);\r
}\r
\r
- adapter.unwrap().debug("Got token: {}", token);\r
+ log.debug("Got token: {}", token);\r
\r
return token;\r
}\r
import javax.ws.rs.core.MultivaluedHashMap;
import javax.ws.rs.core.MultivaluedMap;
import javax.ws.rs.core.Response;
+import javax.ws.rs.core.Response.StatusType;
import javax.ws.rs.core.Response.Status;
+import javax.ws.rs.core.Response.Status.Family;
import javax.xml.parsers.ParserConfigurationException;
import org.onap.aai.restclient.client.OperationResult;
Logger log = adapter.unwrap();
adapter.invoke(new RequestBuilderWrapper(request), InvocationMode.SYNCHRONOUS);
try {
- adapter.unwrap().info("Posting notfication to url = {} , payload: {}", url,
+ log.info("Posting notfication to url = {} , payload: {}", url,
JsonUtils.toJsonString(Entity.json(notification).getEntity()));
Response result = request.post(Entity.json(notification));
- adapter.unwrap().info("request at url = {} resulted in http status {} and response: {}", url,
- result.getStatus(), result.getEntity());
+ StatusType status = result.getStatusInfo();
+
+ if (status.getFamily().equals(Family.SUCCESSFUL)) {
+ log.info("request at url = {} resulted in http status code {}",
+ url, status.getStatusCode());
+ } else {
+ log.error("request at url = {} resulted in http status code {}, reason: {}",
+ url, status.getStatusCode(), status.getReasonPhrase());
+ }
+
} catch (Exception x) {
log.error("Error during {} operation to endpoint at url = {} with error = {}", "POST", url,
OperationResult result = SpringServiceImpl.this.openstackClient.get(url, headers,
MediaType.APPLICATION_JSON_TYPE);
- adapter.unwrap().info("Openstack GET result: {}", result.getResult());
-
Resource resource = new Resource();
resource.setType(this.resourceType);
resource.setId(resourceId);
}
resources.add(resource);
+ Logger log = adapter.unwrap();
+
if (result.wasSuccessful()) {
+ log.info("Openstack GET result code: {}", result.getResultCode());
+
String transformedOutput = TransformationUtil.transform(result.getResult(), this.resourceType);
- adapter.unwrap().info("Jolt transformed output: {}", transformedOutput);
+ log.debug("Jolt transformed output: {}", transformedOutput);
resource.setDataQuality(DataQuality.ok());
List<Attribute> attributeList = TransformationUtil.toAttributeList(transformedOutput);
resource.setAttributeList(attributeList);
} else {
+ log.error("Openstack GET result code: {}. Failure cause: {}",
+ result.getResultCode(), result.getFailureCause());
resource.setDataQuality(DataQuality.error(result.getFailureCause()));
}
}