aboutsummaryrefslogtreecommitdiffstats
path: root/cmso-optimizer/src/main/java/org/onap/observations/Mdc.java
diff options
context:
space:
mode:
authorJerry Flood <jflood@att.com>2019-04-19 07:09:34 -0400
committerJerry Flood <jflood@att.com>2019-04-19 10:07:39 -0400
commit9407eccc5c8347c7c92d2f25590d8867213107aa (patch)
treecf97b388f99b64bac36e60ac95147fd933380116 /cmso-optimizer/src/main/java/org/onap/observations/Mdc.java
parentee1816bf02d5f76548b78c46c39537ec8c1d23b0 (diff)
Rename classes to avoid duplicates
Copy jacoco exec files for upload to sonar Handle ending midnight in time window Issue-ID: OPTFRA-474 Change-Id: Id5df25e404a08e039537e4eb987838835ee12f11 Signed-off-by: Jerry Flood <jflood@att.com>
Diffstat (limited to 'cmso-optimizer/src/main/java/org/onap/observations/Mdc.java')
-rw-r--r--cmso-optimizer/src/main/java/org/onap/observations/Mdc.java279
1 files changed, 0 insertions, 279 deletions
diff --git a/cmso-optimizer/src/main/java/org/onap/observations/Mdc.java b/cmso-optimizer/src/main/java/org/onap/observations/Mdc.java
deleted file mode 100644
index 5dea5aa..0000000
--- a/cmso-optimizer/src/main/java/org/onap/observations/Mdc.java
+++ /dev/null
@@ -1,279 +0,0 @@
-/*
- * Copyright © 2019 AT&T Intellectual Property.
- *
- * 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.
- *
- *
- * Unless otherwise specified, all documentation contained herein is licensed under the Creative
- * Commons License, Attribution 4.0 Intl. (the "License"); you may not use this documentation except
- * in compliance with the License. You may obtain a copy of the License at
- *
- * https://creativecommons.org/licenses/by/4.0/
- *
- * Unless required by applicable law or agreed to in writing, documentation 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.
- */
-
-package org.onap.observations;
-
-import static com.att.eelf.configuration.Configuration.MDC_BEGIN_TIMESTAMP;
-import static com.att.eelf.configuration.Configuration.MDC_END_TIMESTAMP;
-import static com.att.eelf.configuration.Configuration.MDC_KEY_REQUEST_ID;
-import static com.att.eelf.configuration.Configuration.MDC_PARTNER_NAME;
-import static com.att.eelf.configuration.Configuration.MDC_REMOTE_HOST;
-import static com.att.eelf.configuration.Configuration.MDC_RESPONSE_CODE;
-import static com.att.eelf.configuration.Configuration.MDC_RESPONSE_DESC;
-import static com.att.eelf.configuration.Configuration.MDC_STATUS_CODE;
-import static com.att.eelf.configuration.Configuration.MDC_TARGET_ENTITY;
-import static com.att.eelf.configuration.Configuration.MDC_TARGET_SERVICE_NAME;
-
-import com.att.eelf.utils.Stopwatch;
-import java.net.URI;
-import java.util.Date;
-import java.util.Map;
-import java.util.UUID;
-import javax.servlet.http.HttpServletRequest;
-import javax.ws.rs.client.ClientRequestContext;
-import javax.ws.rs.client.ClientResponseContext;
-import javax.ws.rs.container.ContainerRequestContext;
-import javax.ws.rs.container.ContainerResponseContext;
-import javax.ws.rs.core.MultivaluedMap;
-import javax.ws.rs.core.Response.StatusType;
-import org.onap.observations.MessageHeaders.HeadersEnum;
-import org.slf4j.MDC;
-
-/**
- * EELF logging MDC fields not defined in the MDC Configuration (i.e. MDC_ALERT_SEVERITY)
- **/
-public class Mdc {
-
- /** The Constant SERVICE_NAME. */
- public static final String SERVICE_NAME = "CSS-Scheduler";
-
- /**
- * The Enum Enum.
- */
- public enum Enum {
- // BeginTimestamp,
- // EndTimeStamp,
- // RequestId,
- // ServiceInstanceId,
- VirtualServerName,
- // ServiceName,
- // PartnerName,
- // StatusCOde,
- // ResponseCode,
- // ResponseDescription,
- // InstanceUUID,
- // AlertSeverity,
- // ServerIPAddress,
- // ElapsedTime,
- // ServerFQDN,
- // RemoteHost,
- ClassName,
- Unused,
- // ProcessKey,
- CustomField1,
- CustomField2,
- CustomField3,
- CustomField4,
- // TargetVirtualEntity,
- // TargetEntity,
- // TargetServiceName,
- ErrorCode,
- ErrorDescription,
- Timer,
- }
-
- /**
- * Gets the caller.
- *
- * @param back the back
- * @return the caller
- */
- public static String getCaller(int back) {
- StackTraceElement[] stackTraceElements = Thread.currentThread().getStackTrace();
- return stackTraceElements[back].getClassName() + "." + stackTraceElements[back].getMethodName();
- }
-
- /**
- * Sets the caller.
- *
- * @param back the new caller
- */
- public static void setCaller(int back) {
- String caller = MDC.get(Enum.ClassName.name());
- if (caller == null) {
- MDC.put(Enum.ClassName.name(), getCaller(back));
- }
- }
-
- /**
- * Sets the observation.
- *
- * @param obs the new observation
- */
- public static void setObservation(ObservationInterface obs) {
- MDC.put(Enum.CustomField4.name(), obs.name());
- }
-
- /**
- * Clear caller.
- */
- public static void clearCaller() {
- MDC.remove(Enum.ClassName.name());
- }
-
-
- /**
- * Save.
- *
- * @return the map
- */
- public static Map<String, String> save() {
- Map<String, String> save = MDC.getCopyOfContextMap();
- return save;
- }
-
- /**
- * Restore.
- *
- * @param mdcSave the mdc save
- */
- public static void restore(Map<String, String> mdcSave) {
- MDC.clear();
- for (String name : mdcSave.keySet()) {
- MDC.put(name, mdcSave.get(name));
- }
- }
-
-
-
- /**
- * Sets the request id if not set.
- *
- * @param requestId the new request id if not set
- */
- public static void setRequestIdIfNotSet(String requestId) {
- if (MDC.get(MDC_KEY_REQUEST_ID) == null || MDC.get(MDC_KEY_REQUEST_ID).equals("")) {
- setRequestId(requestId);
- }
- }
-
- /**
- * Sets the request id.
- *
- * @param requestId the new request id
- */
- public static void setRequestId(String requestId) {
- MDC.put(MDC_KEY_REQUEST_ID, requestId);
- }
-
- /**
- * Metric start.
- *
- * @param requestContext the request context
- */
- public static void metricStart(ClientRequestContext requestContext) {
- MDC.put(MDC_BEGIN_TIMESTAMP, Stopwatch.isoFormatter.format(new Date()));
- MDC.put(MDC_END_TIMESTAMP, MDC.get(MDC_BEGIN_TIMESTAMP));
- setPartnerTargetFromUri(requestContext.getUri());
- }
-
- /**
- * Metric end.
- *
- * @param response the response
- */
- public static void metricEnd(ClientResponseContext response) {
-
- Date now = new Date();
- // MDC.put(MDC_BEGIN_TIMESTAMP, Stopwatch.isoFormatter.format(now));
- MDC.put(MDC_END_TIMESTAMP, Stopwatch.isoFormatter.format(now));
- setResponseInfo(response.getStatusInfo());
-
- }
-
- /**
- * Audit start.
- *
- * @param requestContext the request context
- * @param servletRequest the servlet request
- */
- public static void auditStart(ContainerRequestContext requestContext, HttpServletRequest servletRequest) {
- MDC.put(MDC_BEGIN_TIMESTAMP, Stopwatch.isoFormatter.format(new Date()));
- MDC.put(MDC_END_TIMESTAMP, MDC.get(MDC_BEGIN_TIMESTAMP));
- MDC.put(MDC_REMOTE_HOST, servletRequest.getRemoteHost());
- MDC.put(Enum.ClassName.name(), getCaller(4));
- MultivaluedMap<String, String> headers = requestContext.getHeaders();
- String transactionId = headers.getFirst(HeadersEnum.TransactionID.toString());
- if (transactionId != null) {
- setRequestId(transactionId);
- } else {
- setRequestId(UUID.randomUUID().toString());
- }
-
- }
-
- /**
- * Audit end.
- *
- * @param requestContext the request context
- * @param response the response
- */
- public static void auditEnd(ContainerRequestContext requestContext, ContainerResponseContext response) {
- Date now = new Date();
- // MDC.put(MDC_BEGIN_TIMESTAMP, Stopwatch.isoFormatter.format(now));
- MDC.put(MDC_END_TIMESTAMP, Stopwatch.isoFormatter.format(now));
- MDC.put(Enum.ClassName.name(), getCaller(4));
-
- setResponseInfo(response.getStatusInfo());
-
- }
-
- private static void setResponseInfo(StatusType statusInfo) {
- Integer status = statusInfo.getStatusCode();
- String completed = "ERROR";
- if (status >= 200 && status < 300) {
- completed = "COMPLETE";
- }
- MDC.put(MDC_RESPONSE_CODE, status.toString());
- MDC.put(MDC_RESPONSE_DESC, statusInfo.getReasonPhrase());
- MDC.put(MDC_STATUS_CODE, completed);
- }
-
- /**
- * Sets the event.
- *
- * @param requestId the new event
- */
- public static void setEvent(String requestId) {
- MDC.put(MDC_BEGIN_TIMESTAMP, Stopwatch.isoFormatter.format(new Date()));
- MDC.put(MDC_END_TIMESTAMP, MDC.get(MDC_BEGIN_TIMESTAMP));
- setRequestId(requestId);
- }
-
- private static void setPartnerTargetFromUri(URI uri) {
- try {
- MDC.put(MDC_PARTNER_NAME, uri.getHost());
- MDC.put(MDC_TARGET_ENTITY, uri.getScheme() + "://" + uri.getHost() + ":" + uri.getPort());
- MDC.put(MDC_TARGET_SERVICE_NAME, uri.getPath());
- } catch (Exception e) {
- MDC.put(MDC_PARTNER_NAME, "UNKNOWN");
- MDC.put(MDC_TARGET_ENTITY, "UNKNOWN");
- MDC.put(MDC_TARGET_SERVICE_NAME, "UNKNOWN");
- }
- }
-
-
-}