1 files changed, 120 insertions, 0 deletions
diff --git a/src/main/java/org/onap/dcae/common/model/VesEvent.java b/src/main/java/org/onap/dcae/common/model/VesEvent.java
new file mode 100644
index 00000000..ce709d1c
--- /dev/null
+++ b/src/main/java/org/onap/dcae/common/model/VesEvent.java
@@ -0,0 +1,120 @@
+/*
+ * ============LICENSE_START=======================================================
+ * VES Collector
+ * ================================================================================
+ * Copyright (C) 2020 Nokia. All rights reserved.s
+ * ================================================================================
+ * 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.onap.dcae.common.model;
+
+import org.json.JSONObject;
+
+/**
+ * This class is a wrapper for JSONObject, that represents VES event.
+ * It contains Strings that represents key, that can be found in VES event.
+ *
+ * @author Zebek
+ */
+public class VesEvent {
+
+    private static final String EVENT_LITERAL = "event";
+    private static final String COMMON_EVENT_HEADER = "commonEventHeader";
+    private static final String VES_UNIQUE_ID = "VESuniqueId";
+    private static final String DOMAIN = "domain";
+    private static final String STND_DEFINED_NAMESPACE = "stndDefinedNamespace";
+    private static final String STND_DEFINED_DOMAIN = "stndDefined";
+
+    private final JSONObject event;
+
+    public VesEvent(JSONObject event) {
+        this.event = event;
+    }
+
+    /**
+     * Returns stream ID from VES event.
+     *
+     * @return stream ID
+     */
+    public String getStreamId() {
+        String retVal = getDomain();
+
+        if (isStdDefinedDomain(retVal)) {
+            retVal = resolveDomainForStndDefinedEvent();
+        }
+
+        return retVal;
+    }
+
+    /**
+     * Returns Domain name from VES event.
+     *
+     * @return domain
+     */
+    public String getDomain() {
+        return getEventHeader().getString(DOMAIN);
+    }
+
+    private String resolveDomainForStndDefinedEvent() {
+        final JSONObject eventHeader = getEventHeader();
+        if(eventHeader.has(STND_DEFINED_NAMESPACE)) {
+            final String domain = eventHeader
+                    .getString(STND_DEFINED_NAMESPACE);
+            if(domain.isEmpty()) {
+                throw new StndDefinedNamespaceParameterHasEmptyValueException();
+            }
+            return domain;
+        } else {
+            throw new StndDefinedNamespaceParameterNotDefinedException();
+        }
+    }
+
+    private JSONObject getEventHeader() {
+        return event
+                .getJSONObject(EVENT_LITERAL)
+                .getJSONObject(COMMON_EVENT_HEADER);
+    }
+
+    private boolean isStdDefinedDomain(String domain) {
+        return domain.equals(STND_DEFINED_DOMAIN);
+    }
+
+    /**
+     * Returns unique ID of VES event.
+     *
+     * @return unique ID
+     */
+    public Object getUniqueId() {
+        return event.get(VES_UNIQUE_ID);
+    }
+
+    /**
+     * Returns VES event in form of JSON object.
+     *
+     * @return event in form of json Object
+     */
+    public JSONObject asJsonObject() {
+        return new JSONObject(event.toString());
+    }
+
+    /**
+     * Checks if type of event is same as given in paramaters.
+     *
+     * @param type name that will be compared with event type
+     * @return true or false depending if type given in parameter is same as VES event type
+     */
+    public boolean hasType(String type) {
+        return this.event.has(type);
+    }
+}