aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--packages/apex-pdp-docker/pom.xml27
-rw-r--r--packages/apex-pdp-docker/src/main/docker/Dockerfile35
-rw-r--r--packages/apex-pdp-docker/src/main/docker/suse.Dockerfile37
-rw-r--r--packages/apex-pdp-package-full/pom.xml96
-rw-r--r--packages/apex-pdp-package-full/src/main/package/control/control27
-rw-r--r--packages/apex-pdp-package-full/src/main/package/control/postinst59
-rw-r--r--packages/apex-pdp-package-full/src/main/package/control/postrm73
-rw-r--r--packages/apex-pdp-package-full/src/main/package/control/preinst53
-rw-r--r--packages/apex-pdp-package-full/src/main/package/control/prerm38
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/pom.xml44
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/main/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelper.java122
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/main/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperParameters.java30
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/CommonTestData.java115
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperMarshalTest.java133
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperUnmarshalTest.java166
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/data/commonHeader.json6
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/data/measurementGroups.json34
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderTypeWithOptional.json23
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderType_draft04.json24
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderType_draft07.json52
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/measurementGroupsType.json61
-rw-r--r--plugins/plugins-context/plugins-context-schema/pom.xml8
22 files changed, 886 insertions, 377 deletions
diff --git a/packages/apex-pdp-docker/pom.xml b/packages/apex-pdp-docker/pom.xml
index 23c8b1075..ed5733bb5 100644
--- a/packages/apex-pdp-docker/pom.xml
+++ b/packages/apex-pdp-docker/pom.xml
@@ -3,6 +3,7 @@
Copyright (C) 2018 Ericsson. All rights reserved.
Modifications Copyright (C) 2019-2020 Bell Canada.
Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
+ Modifications Copyright (C) 2022 Nordix Foundation.
================================================================================
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
@@ -61,6 +62,31 @@
</execution>
</executions>
</plugin>
+
+ <plugin>
+ <groupId>io.github.git-commit-id</groupId>
+ <artifactId>git-commit-id-maven-plugin</artifactId>
+ <version>5.0.0</version>
+ <executions>
+ <execution>
+ <id>get-the-git-infos</id>
+ <goals>
+ <goal>revision</goal>
+ </goals>
+ <phase>initialize</phase>
+ </execution>
+ </executions>
+ <configuration>
+ <skipPoms>false</skipPoms>
+ <generateGitPropertiesFile>true</generateGitPropertiesFile>
+ <includeOnlyProperties>
+ <includeOnlyProperty>^git.build.(time|version)$</includeOnlyProperty>
+ <includeOnlyProperty>^git.commit.id.abbrev$</includeOnlyProperty>
+ </includeOnlyProperties>
+ <commitIdGenerationMode>full</commitIdGenerationMode>
+ </configuration>
+ </plugin>
+
<plugin>
<groupId>io.fabric8</groupId>
<artifactId>docker-maven-plugin</artifactId>
@@ -128,6 +154,7 @@
</execution>
</executions>
</plugin>
+
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-deploy-plugin</artifactId>
diff --git a/packages/apex-pdp-docker/src/main/docker/Dockerfile b/packages/apex-pdp-docker/src/main/docker/Dockerfile
index b788c7fbd..08bcddb05 100644
--- a/packages/apex-pdp-docker/src/main/docker/Dockerfile
+++ b/packages/apex-pdp-docker/src/main/docker/Dockerfile
@@ -1,6 +1,6 @@
#-------------------------------------------------------------------------------
# ============LICENSE_START=======================================================
-# Copyright (C) 2020 Nordix Foundation.
+# Copyright (C) 2020-2022 Nordix Foundation.
# Modification Copyright (C) 2020-2021 AT&T Foundation.
# Modifications Copyright (C) 2021 Bell Canada.
# ================================================================================
@@ -20,12 +20,22 @@
# ============LICENSE_END=========================================================
#-------------------------------------------------------------------------------
-#
-# Docker file to build an image that runs APEX on Java 11 or better in alpine
-#
+FROM busybox AS tarball
+RUN mkdir /packages /extracted
+COPY /maven/apex-pdp-package-full.tar.gz /packages/
+RUN tar xvzf /packages/apex-pdp-package-full.tar.gz --directory /extracted/
+
FROM onap/policy-jdk-alpine:2.4.3
LABEL maintainer="Policy Team"
+LABEL org.opencontainers.image.title="Policy APEX PDP"
+LABEL org.opencontainers.image.description="Policy APEX PDP image based on Alpine"
+LABEL org.opencontainers.image.url="https://github.com/onap/policy-apex-pdp"
+LABEL org.opencontainers.image.vendor="ONAP Policy Team"
+LABEL org.opencontainers.image.licenses="Apache-2.0"
+LABEL org.opencontainers.image.created="${git.build.time}"
+LABEL org.opencontainers.image.version="${git.build.version}"
+LABEL org.opencontainers.image.revision="${git.commit.id.abbrev}"
ARG POLICY_LOGS=/var/log/onap/policy/apex-pdp
ENV POLICY_HOME=/opt/app/policy/apex-pdp
@@ -36,20 +46,11 @@ RUN apk update \
vim \
iputils \
&& addgroup -S apexuser && adduser -S apexuser -G apexuser \
- && mkdir -p $POLICY_HOME \
- && mkdir -p $POLICY_LOGS \
- && chown -R apexuser:apexuser $POLICY_LOGS \
- && mkdir /packages
+ && mkdir -p $POLICY_HOME $POLICY_LOGS \
+ && chown -R apexuser:apexuser $POLICY_HOME $POLICY_LOGS
-COPY /maven/apex-pdp-package-full.tar.gz /packages
-RUN tar xvfz /packages/apex-pdp-package-full.tar.gz --directory $POLICY_HOME \
- && rm /packages/apex-pdp-package-full.tar.gz \
- && find /opt/app -type d -perm 755 \
- && find /opt/app -type f -perm 644 \
- && chmod 755 $POLICY_HOME/bin/* \
- && cp -pr $POLICY_HOME/examples /home/apexuser \
- && chown -R apexuser:apexuser /home/apexuser/* $POLICY_HOME \
- && chmod 755 $POLICY_HOME/etc/*
+COPY --chown=apexuser:apexuser --from=tarball /extracted $POLICY_HOME
+RUN cp -pr $POLICY_HOME/examples /home/apexuser
USER apexuser
ENV PATH $POLICY_HOME/bin:$PATH
diff --git a/packages/apex-pdp-docker/src/main/docker/suse.Dockerfile b/packages/apex-pdp-docker/src/main/docker/suse.Dockerfile
index 653760cd6..d947a3cc7 100644
--- a/packages/apex-pdp-docker/src/main/docker/suse.Dockerfile
+++ b/packages/apex-pdp-docker/src/main/docker/suse.Dockerfile
@@ -18,12 +18,22 @@
# ============LICENSE_END=========================================================
#-------------------------------------------------------------------------------
-#
-# Docker file to build an image that runs APEX on Java 11 or better in OpenSuse
-#
-FROM opensuse/leap:15.3
+FROM busybox AS tarball
+RUN mkdir /packages /extracted
+COPY /maven/apex-pdp-package-full.tar.gz /packages/
+RUN tar xvzf /packages/apex-pdp-package-full.tar.gz --directory /extracted/
+
+FROM opensuse/leap:15.4
LABEL maintainer="Policy Team"
+LABEL org.opencontainers.image.title="Policy APEX PDP"
+LABEL org.opencontainers.image.description="Policy APEX PDP image based on OpenSuse"
+LABEL org.opencontainers.image.url="https://github.com/onap/policy-apex-pdp"
+LABEL org.opencontainers.image.vendor="ONAP Policy Team"
+LABEL org.opencontainers.image.licenses="Apache-2.0"
+LABEL org.opencontainers.image.created="${git.build.time}"
+LABEL org.opencontainers.image.version="${git.build.version}"
+LABEL org.opencontainers.image.revision="${git.commit.id.abbrev}"
ARG POLICY_LOGS=/var/log/onap/policy/apex-pdp
ENV POLICY_HOME=/opt/app/policy/apex-pdp
@@ -31,23 +41,14 @@ ENV POLICY_LOGS=$POLICY_LOGS
ENV LANG=en_US.UTF-8 LANGUAGE=en_US:en LC_ALL=en_US.UTF-8
ENV JAVA_HOME=/usr/lib64/jvm/java-11-openjdk-11
-RUN zypper -n -q install --no-recommends gzip java-11-openjdk-devel netcat-openbsd tar \
+RUN zypper -n -q install --no-recommends java-11-openjdk-devel netcat-openbsd \
&& zypper -n -q update && zypper -n -q clean --all \
&& groupadd --system apexuser && useradd --system --shell /bin/sh -G apexuser apexuser \
- && mkdir -p $POLICY_HOME \
- && mkdir -p $POLICY_LOGS \
- && chown -R apexuser:apexuser $POLICY_HOME $POLICY_LOGS \
- && mkdir /packages
+ && mkdir -p $POLICY_HOME $POLICY_LOGS \
+ && chown -R apexuser:apexuser $POLICY_HOME $POLICY_LOGS
-COPY /maven/apex-pdp-package-full.tar.gz /packages
-RUN tar xvfz /packages/apex-pdp-package-full.tar.gz --directory $POLICY_HOME \
- && rm /packages/apex-pdp-package-full.tar.gz \
- && find /opt/app -type d -perm 755 \
- && find /opt/app -type f -perm 644 \
- && chmod 755 $POLICY_HOME/bin/* \
- && cp -pr $POLICY_HOME/examples /home/apexuser \
- && chown -R apexuser:apexuser /home/apexuser/* $POLICY_HOME \
- && chmod 755 $POLICY_HOME/etc/*
+COPY --chown=apexuser:apexuser --from=tarball /extracted $POLICY_HOME
+RUN cp -pr $POLICY_HOME/examples /home/apexuser
USER apexuser
ENV PATH $POLICY_HOME/bin:$PATH
diff --git a/packages/apex-pdp-package-full/pom.xml b/packages/apex-pdp-package-full/pom.xml
index e5afa813f..e6e7b6aaf 100644
--- a/packages/apex-pdp-package-full/pom.xml
+++ b/packages/apex-pdp-package-full/pom.xml
@@ -2,7 +2,7 @@
============LICENSE_START=======================================================
Copyright (C) 2018 Ericsson. All rights reserved.
Modifications Copyright (C) 2019-2020, 2022 Nordix Foundation
- Modifications Copyright (C) 2019-2020 Bell Canada.
+ Modifications Copyright (C) 2019-2020, 2022 Bell Canada.
Modifications Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
================================================================================
Licensed under the Apache License, Version 2.0 (the "License");
@@ -30,6 +30,7 @@
</parent>
<artifactId>apex-pdp-package-full</artifactId>
+ <packaging>pom</packaging>
<name>${project.artifactId}</name>
<description>[${project.parent.artifactId}] packaging, with all optional functionality, clients, servlets, and examples included</description>
@@ -79,6 +80,11 @@
<artifactId>plugins-context-schema-avro</artifactId>
<version>${project.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.onap.policy.apex-pdp.plugins.plugins-context.plugins-context-schema</groupId>
+ <artifactId>plugins-context-schema-json</artifactId>
+ <version>${project.version}</version>
+ </dependency>
<!-- Plugins for Executors -->
<dependency>
@@ -476,94 +482,6 @@
</execution>
</executions>
</plugin>
- <plugin>
- <artifactId>maven-antrun-plugin</artifactId>
- <executions>
- <execution>
- <phase>package</phase>
- <configuration>
- <tasks>
- <untar
- src="${project.build.directory}/${project.artifactId}-${project.version}.tar.gz"
- dest="${project.build.directory}/install_hierarchy" compression="gzip" />
- </tasks>
- </configuration>
- <goals>
- <goal>run</goal>
- </goals>
- </execution>
- <execution>
- <id>fix-permissions</id>
- <phase>package</phase>
- <configuration>
- <tasks>
- <chmod file="${project.build.directory}/install_hierarchy/bin/*" perm="755" />
- </tasks>
- </configuration>
- <goals>
- <goal>run</goal>
- </goals>
- </execution>
- </executions>
- </plugin>
- <!-- Build the dpkg distribution -->
- <plugin>
- <groupId>org.vafer</groupId>
- <artifactId>jdeb</artifactId>
- <version>1.5</version>
- <executions>
- <execution>
- <phase>package</phase>
- <goals>
- <goal>jdeb</goal>
- </goals>
- <configuration>
- <deb>${project.build.directory}/${project.artifactId}-${project.version}.deb</deb>
- <controlDir>${basedir}/src/main/package/control</controlDir>
- <dataSet>
- <!-- Copy the Apex run time configuration -->
- <data>
- <src>${project.build.directory}/install_hierarchy/lib</src>
- <type>directory</type>
- <dst>lib</dst>
- <mapper>
- <type>perm</type>
- <prefix>/opt/app/policy/${project.artifactId}-${project.version}/lib</prefix>
- <filemode>755</filemode>
- </mapper>
- </data>
- <data>
- <src>${project.build.directory}/install_hierarchy/bin</src>
- <type>directory</type>
- <dst>etc</dst>
- <mapper>
- <type>perm</type>
- <prefix>/opt/app/policy/${project.artifactId}-${project.version}/bin</prefix>
- </mapper>
- </data>
- <data>
- <src>${project.build.directory}/install_hierarchy/etc</src>
- <type>directory</type>
- <dst>etc</dst>
- <mapper>
- <type>perm</type>
- <prefix>/opt/app/policy/${project.artifactId}-${project.version}/etc</prefix>
- </mapper>
- </data>
- <data>
- <src>${project.build.directory}/install_hierarchy/examples</src>
- <type>directory</type>
- <dst>etc</dst>
- <mapper>
- <type>perm</type>
- <prefix>/opt/app/policy/${project.artifactId}-${project.version}/examples</prefix>
- </mapper>
- </data>
- </dataSet>
- </configuration>
- </execution>
- </executions>
- </plugin>
</plugins>
</build>
<profiles>
diff --git a/packages/apex-pdp-package-full/src/main/package/control/control b/packages/apex-pdp-package-full/src/main/package/control/control
deleted file mode 100644
index 25226d89b..000000000
--- a/packages/apex-pdp-package-full/src/main/package/control/control
+++ /dev/null
@@ -1,27 +0,0 @@
-#-------------------------------------------------------------------------------
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. All rights reserved.
-# ================================================================================
-# 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.
-#
-# SPDX-License-Identifier: Apache-2.0
-# ============LICENSE_END=========================================================
-#-------------------------------------------------------------------------------
-Package: [[install.package.name]]
-Version: [[version]]
-Section: misc
-Priority: optional
-Architecture: all
-Maintainer: Liam Fallon <liam.fallon@ericsson.com>
-Description: Apex Microservice
-Distribution: development
diff --git a/packages/apex-pdp-package-full/src/main/package/control/postinst b/packages/apex-pdp-package-full/src/main/package/control/postinst
deleted file mode 100644
index 1b12f5f2a..000000000
--- a/packages/apex-pdp-package-full/src/main/package/control/postinst
+++ /dev/null
@@ -1,59 +0,0 @@
-#! /bin/sh
-
-#-------------------------------------------------------------------------------
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. All rights reserved.
-# ================================================================================
-# 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.
-#
-# SPDX-License-Identifier: Apache-2.0
-# ============LICENSE_END=========================================================
-#-------------------------------------------------------------------------------
-
-#
-# This script is called after package software is installed
-#
-
-echo "********************postinst****************"
-echo "arguments $*"
-echo "***********************************************"
-
-# Check for debian abort-remove case which calls postinst, in which we do nothing
-if [ "$1" = "abort-remove" ]
-then
- exit 0
-fi
-
-# Check if a soft link for latest version of Apex already exists
-if [ -L "/opt/app/policy/apex-pdp" ]; then
- rm /opt/app/policy/apex-pdp
-fi
-
-# Add soft link for latest version of Apex
-ln -s `ls /opt/app/policy | grep -i '^apex-*' | sort | tail -1` /opt/app/policy/apex-pdp
-
-# Add Apex-specific directories and set ownership as the Apex admin user
-mkdir -p /var/log/onap/policy/apex-pdp
-chown -R apexuser:apexuser /var/log/onap/policy/apex-pdp
-
-# Ensure everything has the correct permissions
-find /opt/app -type d -perm 755
-find /opt/app -type f -perm 644
-chmod a+x /opt/app/policy/apex-pdp/bin/*
-
-# Copy examples to Apex user area
-if [ -e /home/apexuser/examples ]
-then
- rm -rf /home/apexuser/examples
-fi
-cp -pr /opt/app/policy/apex-pdp/examples /home/apexuser
diff --git a/packages/apex-pdp-package-full/src/main/package/control/postrm b/packages/apex-pdp-package-full/src/main/package/control/postrm
deleted file mode 100644
index 2383820e5..000000000
--- a/packages/apex-pdp-package-full/src/main/package/control/postrm
+++ /dev/null
@@ -1,73 +0,0 @@
-#! /bin/sh
-
-#-------------------------------------------------------------------------------
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. All rights reserved.
-# ================================================================================
-# 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.
-#
-# SPDX-License-Identifier: Apache-2.0
-# ============LICENSE_END=========================================================
-#-------------------------------------------------------------------------------
-
-#
-# This script is called after package software is removed
-#
-
-echo "********************postrm*******************"
-echo "arguments $*"
-echo "*********************************************"
-
-# Check for debian upgrade case which calls postrm, in which we do nothing
-if [ "$1" = "upgrade" ]
-then
- exit 0
-fi
-
-# Check if a soft link for apex exists, if so remove it
-if [ -L "/opt/app/policy/apex-pdp" ]; then
- rm /opt/app/policy/apex-pdp
-fi
-
-DIRS_TO_DELETE="
- /var/log/onap/policy/apex-pdp
- /opt/app/policy/apex-pdp
-"
-
-for DIR in $DIRS_TO_DELETE
-do
- if [ -e $DIR ]
- then
- rm -rf $DIR
- echo Directory $DIR removed
- fi
-done
-
-if [ -e "/home/apexuser" ]
-then
- echo "deleting home directory of user apexuser . . ."
- rm -fr /home/apexuser
-fi
-
-if getent passwd "apexuser" >/dev/null 2>&1
-then
- echo "deleting user apexuser . . ."
- userdel apexuser
-fi
-
-if getent group "apexuser" >/dev/null 2>&1
-then
- echo "deleting group apexuser . . ."
- groupdel apexuser
-fi
-
diff --git a/packages/apex-pdp-package-full/src/main/package/control/preinst b/packages/apex-pdp-package-full/src/main/package/control/preinst
deleted file mode 100644
index 58257c5a2..000000000
--- a/packages/apex-pdp-package-full/src/main/package/control/preinst
+++ /dev/null
@@ -1,53 +0,0 @@
-#! /bin/sh
-
-#-------------------------------------------------------------------------------
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. All rights reserved.
-# ================================================================================
-# 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.
-#
-# SPDX-License-Identifier: Apache-2.0
-# ============LICENSE_END=========================================================
-#-------------------------------------------------------------------------------
-
-#
-# This script is called before package software is installed
-#
-
-echo "********************preinst*******************"
-echo "arguments $*"
-echo "**********************************************"
-
-# Check if Apex is running
-running_check=`ps -ef | egrep "org.onap.policy.apex.service.engine.main.ApexMain" | egrep -v grep`
-if [ ! -z "$running_check" -a "$running_check" != "" ]
-then
- echo "Apex processes are running, stop Apex prior to package upgrade"
- exit 1
-fi
-
-if ! getent group "apexuser" >/dev/null 2>&1
-then
- echo "creating group apexuser . . ."
- groupadd apexuser
-fi
-
-if ! getent passwd "apexuser" >/dev/null 2>&1
-then
- echo "creating user apexuser . . ."
- useradd -g apexuser apexuser
-fi
-
-# Create the Apex user home directory
-mkdir -p /home/apexuser
-chown -R apexuser:apexuser /home/apexuser
diff --git a/packages/apex-pdp-package-full/src/main/package/control/prerm b/packages/apex-pdp-package-full/src/main/package/control/prerm
deleted file mode 100644
index 3729af6a2..000000000
--- a/packages/apex-pdp-package-full/src/main/package/control/prerm
+++ /dev/null
@@ -1,38 +0,0 @@
-#! /bin/sh
-
-#-------------------------------------------------------------------------------
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. All rights reserved.
-# ================================================================================
-# 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.
-#
-# SPDX-License-Identifier: Apache-2.0
-# ============LICENSE_END=========================================================
-#-------------------------------------------------------------------------------
-
-#
-# This script is called before package software is removed
-#
-
-echo "**********************prerm********************"
-echo "arguments $*"
-echo "***********************************************"
-
-
-# Check if Apex is running
-running_check=`ps -ef | egrep "org.onap.policy.apex.service.engine.main.ApexMain" | egrep -v grep`
-if [ ! -z "$running_check" -a "$running_check" != "" ]
-then
- echo "Apex processes are running, stop Apex prior to package removal"
- exit 1
-fi
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/pom.xml b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/pom.xml
new file mode 100644
index 000000000..75c42fa48
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/pom.xml
@@ -0,0 +1,44 @@
+<!--
+ ============LICENSE_START=======================================================
+ Copyright (C) 2022 Bell Canada. All rights reserved.
+ ================================================================================
+ 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.
+
+ SPDX-License-Identifier: Apache-2.0
+ ============LICENSE_END=========================================================
+-->
+<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.onap.policy.apex-pdp.plugins.plugins-context.plugins-context-schema</groupId>
+ <artifactId>plugins-context-schema</artifactId>
+ <version>2.8.0-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>plugins-context-schema-json</artifactId>
+ <name>${project.artifactId}</name>
+ <description>[${project.parent.artifactId}] Plugin for schemas using JSON</description>
+
+ <dependencies>
+ <dependency>
+ <groupId>com.worldturner.medeia</groupId>
+ <artifactId>medeia-validator-gson</artifactId>
+ <version>1.1.1</version>
+ </dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
+</project>
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/main/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelper.java b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/main/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelper.java
new file mode 100644
index 000000000..4896e5d4a
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/main/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelper.java
@@ -0,0 +1,122 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2022 Bell Canada. All rights reserved.
+ * ================================================================================
+ * 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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.plugins.context.schema.json;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonElement;
+import com.google.gson.stream.JsonReader;
+import com.google.gson.stream.JsonWriter;
+import com.worldturner.medeia.api.SchemaSource;
+import com.worldturner.medeia.api.StringInputSource;
+import com.worldturner.medeia.api.StringSchemaSource;
+import com.worldturner.medeia.api.gson.MedeiaGsonApi;
+import com.worldturner.medeia.schema.validation.SchemaValidator;
+import java.io.StringWriter;
+import java.util.List;
+import java.util.Map;
+import org.onap.policy.apex.context.ContextRuntimeException;
+import org.onap.policy.apex.context.impl.schema.AbstractSchemaHelper;
+import org.onap.policy.apex.model.basicmodel.concepts.AxKey;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchema;
+
+/**
+ * This class is the implementation of the {@link org.onap.policy.apex.context.SchemaHelper} interface for JSON schema.
+ */
+public class JsonSchemaHelper extends AbstractSchemaHelper {
+
+ private static final Gson gson = new Gson();
+
+ private MedeiaGsonApi api = new MedeiaGsonApi();
+ private SchemaValidator validator;
+
+ @Override
+ public void init(final AxKey userKey, final AxContextSchema schema) {
+ super.init(userKey, schema);
+
+ try {
+ SchemaSource source = new StringSchemaSource(schema.getSchema());
+ validator = api.loadSchema(source);
+ } catch (final Exception e) {
+ final String resultSting = userKey.getId() + ": json context schema \"" + schema.getId()
+ + "\" schema is invalid, schema: " + schema.getSchema();
+ throw new ContextRuntimeException(resultSting, e);
+ }
+ }
+
+ @Override
+ public Object createNewInstance(final String stringValue) {
+ return unmarshal(stringValue);
+ }
+
+ @Override
+ public Object createNewInstance(final Object incomingObject) {
+ if (incomingObject instanceof JsonElement) {
+ final var elementJsonString = gson.toJson((JsonElement) incomingObject);
+
+ return createNewInstance(elementJsonString);
+ } else {
+ final var returnString =
+ getUserKey().getId() + ": the object \"" + incomingObject + "\" is not an instance of JsonObject";
+ throw new ContextRuntimeException(returnString);
+ }
+ }
+
+ @Override
+ public Object unmarshal(Object object) {
+ // If an object is already in the correct format, just carry on
+ if (passThroughObject(object)) {
+ return object;
+ }
+ var objectString = (String) object;
+ JsonReader reader = api.createJsonReader(validator, new StringInputSource(objectString));
+ return gson.fromJson(reader, Object.class);
+ }
+
+ @Override
+ public String marshal2String(Object schemaObject) {
+ StringWriter stringWriter = new StringWriter();
+ validateAndDecode(schemaObject, stringWriter);
+ return stringWriter.toString();
+ }
+
+ @Override
+ public Object marshal2Object(Object schemaObject) {
+ return validateAndDecode(schemaObject, new StringWriter());
+ }
+
+ private JsonElement validateAndDecode(Object schemaObject, StringWriter stringWriter) {
+ JsonWriter jsonWriter = api.createJsonWriter(validator, stringWriter);
+ jsonWriter.setIndent(" "); // to enable pretty print
+ JsonElement jsonObj = gson.toJsonTree(schemaObject);
+ gson.toJson(jsonObj, jsonWriter);
+ return jsonObj;
+ }
+
+ /**
+ * Check if we can pass this object straight through encoding or decoding.
+ *
+ * @param object the object to check
+ * @return true if it's a straight pass through
+ */
+ private boolean passThroughObject(final Object object) {
+ return (object instanceof JsonElement || object instanceof Map || object instanceof List);
+ }
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/main/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperParameters.java b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/main/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperParameters.java
new file mode 100644
index 000000000..0e275130d
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/main/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperParameters.java
@@ -0,0 +1,30 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2022 Bell Canada. All rights reserved.
+ * ================================================================================
+ * 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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.plugins.context.schema.json;
+
+import org.onap.policy.apex.context.parameters.SchemaHelperParameters;
+
+public class JsonSchemaHelperParameters extends SchemaHelperParameters {
+
+ public JsonSchemaHelperParameters() {
+ this.setSchemaHelperPluginClass(JsonSchemaHelper.class.getName());
+ }
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/CommonTestData.java b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/CommonTestData.java
new file mode 100644
index 000000000..ce03678c9
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/CommonTestData.java
@@ -0,0 +1,115 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2022 Bell Canada. All rights reserved.
+ * ================================================================================
+ * 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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.plugins.context.schema.json;
+
+import java.io.IOException;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.onap.policy.apex.context.SchemaHelper;
+import org.onap.policy.apex.context.impl.schema.SchemaHelperFactory;
+import org.onap.policy.apex.context.parameters.ContextParameterConstants;
+import org.onap.policy.apex.context.parameters.SchemaParameters;
+import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+import org.onap.policy.apex.model.basicmodel.concepts.AxKey;
+import org.onap.policy.apex.model.basicmodel.service.ModelService;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchema;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchemas;
+import org.onap.policy.common.parameters.ParameterService;
+import org.onap.policy.common.utils.coder.StandardCoder;
+import org.onap.policy.common.utils.resources.TextFileUtils;
+
+public class CommonTestData {
+
+ protected static final String VERSION = "0.0.1";
+ protected static final String JSON = "JSON";
+ protected static final String TEST_ID = "testId";
+ protected final AxKey testKey = new AxArtifactKey("JsonTest", VERSION);
+ protected AxContextSchemas schemas;
+ protected final StandardCoder coder = new StandardCoder();
+
+ protected static final String BOOLEAN_SCHEMA =
+ "{\"$schema\": \"http://json-schema.org/draft-07/schema#\",\"type\": \"boolean\"}";
+ protected static final String BOOLEAN_DATA = "true";
+ protected static final String NULL_SCHEMA =
+ "{\"$schema\":\"http://json-schema.org/draft-07/schema#\",\"type\":\"null\"}";
+ protected static final String NULL_DATA = "null";
+ protected static String COMMONHEADERTYPE_DRAFT04;
+ protected static String COMMONHEADERTYPE_DRAFT07;
+ protected static String COMMONHEADERTYPE_WITH_OPTIONAL;
+ protected static String COMMONHEADER;
+ protected static String MEASUREMENTGROUPS_TYPE;
+ protected static String MEASUREMENTGROUPS;
+
+ /**
+ * Setup before all tests.
+ */
+ @BeforeClass
+ public static void setUpBeforeClass() throws IOException {
+ COMMONHEADERTYPE_DRAFT04 =
+ TextFileUtils.getTextFileAsString("src/test/resources/schema/commonHeaderType_draft04.json");
+ COMMONHEADERTYPE_DRAFT07 =
+ TextFileUtils.getTextFileAsString("src/test/resources/schema/commonHeaderType_draft07.json");
+ COMMONHEADERTYPE_WITH_OPTIONAL =
+ TextFileUtils.getTextFileAsString("src/test/resources/schema/commonHeaderTypeWithOptional.json");
+ COMMONHEADER =
+ TextFileUtils.getTextFileAsString("src/test/resources/data/commonHeader.json").replaceAll("\r", "").trim();
+ MEASUREMENTGROUPS_TYPE =
+ TextFileUtils.getTextFileAsString("src/test/resources/schema/measurementGroupsType.json");
+ MEASUREMENTGROUPS = TextFileUtils.getTextFileAsString("src/test/resources/data/measurementGroups.json")
+ .replaceAll("\r", "").trim();
+ }
+
+ /**
+ * Setup before test.
+ */
+ @Before
+ public void setUp() {
+ schemas = new AxContextSchemas(new AxArtifactKey("JsonSchema", VERSION));
+ ModelService.registerModel(AxContextSchemas.class, schemas);
+
+ SchemaParameters schemaParameters = new SchemaParameters();
+ schemaParameters.setName(ContextParameterConstants.SCHEMA_GROUP_NAME);
+ schemaParameters.getSchemaHelperParameterMap().put(JSON, new JsonSchemaHelperParameters());
+ ParameterService.register(schemaParameters);
+ }
+
+ /**
+ * Teardown after test.
+ */
+ @After
+ public void tearDown() {
+ ParameterService.deregister(ContextParameterConstants.SCHEMA_GROUP_NAME);
+ ModelService.clear();
+ }
+
+ /**
+ * Method to create JsonSchemaHelper instance from schema content.
+ *
+ * @param schema the schema content as string
+ * @return schemaHelper instance
+ */
+ protected SchemaHelper createSchema(String schema) {
+ final AxContextSchema jsonSchema = new AxContextSchema(new AxArtifactKey("SchemaTest", VERSION), JSON, schema);
+ schemas.getSchemasMap().put(jsonSchema.getKey(), jsonSchema);
+ return new SchemaHelperFactory().createSchemaHelper(testKey, jsonSchema.getKey());
+ }
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperMarshalTest.java b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperMarshalTest.java
new file mode 100644
index 000000000..15458199a
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperMarshalTest.java
@@ -0,0 +1,133 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2022 Bell Canada. All rights reserved.
+ * ================================================================================
+ * 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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.plugins.context.schema.json;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
+import com.worldturner.medeia.api.ValidationFailedException;
+import java.util.ArrayList;
+import java.util.Map;
+import org.junit.Test;
+import org.onap.policy.common.utils.coder.CoderException;
+
+public class JsonSchemaHelperMarshalTest extends CommonTestData {
+
+ /**
+ * Test Boolean.
+ */
+ @Test
+ public void testBooleanMarshal() {
+ var schemaHelper = createSchema(BOOLEAN_SCHEMA);
+ assertThat(schemaHelper.marshal2String(Boolean.TRUE)).isEqualTo("true");
+ }
+
+ /**
+ * Test null.
+ */
+ @Test
+ public void testNullMarshal() {
+ var schemaHelper = createSchema(NULL_SCHEMA);
+ assertThat(schemaHelper.marshal2String(null)).isEqualTo("null");
+ }
+
+ /**
+ * Test Array.
+ *
+ * @throws CoderException the coder exception
+ */
+ @Test
+ public void testArrayMarshal() throws CoderException {
+ var schemaHelper = createSchema(MEASUREMENTGROUPS_TYPE);
+ var object = coder.decode(MEASUREMENTGROUPS, Object.class);
+ assertThat(object).isInstanceOf(ArrayList.class);
+ var marshalledString = schemaHelper.marshal2String(object);
+ assertThat(marshalledString).isEqualTo(MEASUREMENTGROUPS);
+ var marshalledObject = schemaHelper.marshal2Object(object);
+ assertThat(marshalledObject).isInstanceOf(JsonArray.class);
+ }
+
+ /**
+ * Test Object marshal valid scenario using JSON Schema draft 04.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchemaDraft04_valid() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, Map.class);
+ var dataReturned = validateAndMarshal(COMMONHEADERTYPE_DRAFT04, dataAsObject, true);
+ assertThat(dataReturned).isEqualTo(COMMONHEADER);
+ }
+
+ /**
+ * Test Object marshal valid scenario using JSON Schema draft 07.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchemaDraft07_valid() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, Map.class);
+ var dataReturned = validateAndMarshal(COMMONHEADERTYPE_DRAFT07, dataAsObject, true);
+ assertThat(dataReturned).isEqualTo(COMMONHEADER);
+ assertThat(validateAndMarshal(COMMONHEADERTYPE_DRAFT07, dataAsObject, false)).isInstanceOf(JsonObject.class);
+ }
+
+ /**
+ * Test Object marshal invalid - required field missing scenario.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchema_fieldMissing() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, Map.class);
+ dataAsObject.remove(TEST_ID);
+ assertThatThrownBy(() -> validateAndMarshal(COMMONHEADERTYPE_DRAFT07, dataAsObject, true))
+ .isInstanceOf(ValidationFailedException.class)
+ .hasMessageContaining("Required property testId is missing from object");
+ }
+
+ /**
+ * Test Object marshal with optional field.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchema_OptionalField() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, Map.class);
+ var dataAsjsonObject = coder.decode(COMMONHEADER, JsonObject.class);
+ dataAsObject.remove(TEST_ID);
+ dataAsjsonObject.remove(TEST_ID);
+ var dataReturned = validateAndMarshal(COMMONHEADERTYPE_WITH_OPTIONAL, dataAsObject, false);
+ assertThat(dataReturned).isEqualTo(dataAsjsonObject);
+ }
+
+ private Object validateAndMarshal(String schemaDef, Object obj, boolean marshalAsString) {
+ var schemaHelper = createSchema(schemaDef);
+ if (marshalAsString) {
+ return schemaHelper.marshal2String(obj);
+ } else {
+ return schemaHelper.marshal2Object(obj);
+ }
+ }
+
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperUnmarshalTest.java b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperUnmarshalTest.java
new file mode 100644
index 000000000..11c8638de
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/java/org/onap/policy/apex/plugins/context/schema/json/JsonSchemaHelperUnmarshalTest.java
@@ -0,0 +1,166 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2022 Bell Canada. All rights reserved.
+ * ================================================================================
+ * 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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.plugins.context.schema.json;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+import com.google.gson.JsonObject;
+import com.worldturner.medeia.api.ValidationFailedException;
+import java.util.ArrayList;
+import java.util.Map;
+import org.junit.Test;
+import org.onap.policy.apex.context.ContextRuntimeException;
+import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchema;
+import org.onap.policy.common.utils.coder.CoderException;
+
+public class JsonSchemaHelperUnmarshalTest extends CommonTestData {
+
+ /**
+ * Test Boolean.
+ */
+ @Test
+ public void testBooleanUnmarshal() {
+ var schemaHelper = createSchema(BOOLEAN_SCHEMA);
+ assertThat(schemaHelper.createNewInstance(BOOLEAN_DATA)).isInstanceOf(Boolean.class).isEqualTo(Boolean.TRUE);
+ }
+
+ /**
+ * Test null.
+ */
+ @Test
+ public void testNullUnmarshal() {
+ var schemaHelper = createSchema(NULL_SCHEMA);
+ assertThat(schemaHelper.createNewInstance(NULL_DATA)).isEqualTo(null);
+ }
+
+ /**
+ * Test Array.
+ */
+ @Test
+ public void testArrayUnmarshal() {
+ var schemaHelper = createSchema(MEASUREMENTGROUPS_TYPE);
+ var obj = schemaHelper.createNewInstance(MEASUREMENTGROUPS);
+ assertThat(obj).isInstanceOf(ArrayList.class);
+ }
+
+ /**
+ * Test invlaid schema.
+ */
+ @Test
+ public void testSchemaInvalid() {
+ String schemaDef = "{\"type\": \"object\"}";
+ final AxContextSchema jsonSchema =
+ new AxContextSchema(new AxArtifactKey("JsonObject", VERSION), JSON, schemaDef);
+ assertThatThrownBy(() -> new JsonSchemaHelper().init(testKey, jsonSchema))
+ .isInstanceOf(ContextRuntimeException.class).hasMessageContaining("schema is invalid");
+ }
+
+ /**
+ * Test Object unmarshal valid scenario using JSON Schema draft 04.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchemaDraft04_valid() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, Map.class);
+ var dataReturned = validateAndUnmarshal(COMMONHEADERTYPE_DRAFT04, COMMONHEADER);
+ assertThat(dataReturned).isEqualTo(dataAsObject);
+ }
+
+ /**
+ * Test Object unmarshal valid scenario using JSON Schema draft 07.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchemaDraft07_valid() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, Map.class);
+ var dataReturned = validateAndUnmarshal(COMMONHEADERTYPE_DRAFT07, COMMONHEADER);
+ assertThat(dataReturned).isEqualTo(dataAsObject);
+ }
+
+ /**
+ * Test Object unmarshal invalid scenario using JSON Schema draft 07.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchemaDraft07_invalid() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, JsonObject.class);
+ dataAsObject.addProperty("requestId", "abcd");
+ assertThatThrownBy(() -> validateAndUnmarshal(COMMONHEADERTYPE_DRAFT07, dataAsObject))
+ .isInstanceOf(ValidationFailedException.class)
+ .hasMessageContaining("Pattern ^[0-9]*-[0-9]*$ is not contained in text");
+ }
+
+ /**
+ * Test createInstance using invalid format data.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testCreateNewInstanceInvalid() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, Map.class);
+ assertThatThrownBy(() -> validateAndUnmarshal(COMMONHEADERTYPE_DRAFT07, dataAsObject))
+ .isInstanceOf(ContextRuntimeException.class).hasMessageContaining("not an instance of JsonObject");
+ }
+
+ /**
+ * Test Object unmarshal invalid - required field missing scenario.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchema_fieldMissing() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, JsonObject.class);
+ dataAsObject.remove(TEST_ID);
+ assertThatThrownBy(() -> validateAndUnmarshal(COMMONHEADERTYPE_DRAFT07, dataAsObject))
+ .isInstanceOf(ValidationFailedException.class)
+ .hasMessageContaining("Required property testId is missing from object");
+ }
+
+ /**
+ * Test Object unmarshal with optional field.
+ *
+ * @throws CoderException the coderException
+ */
+ @Test
+ public void testObjectSchema_OptionalField() throws CoderException {
+ var dataAsObject = coder.decode(COMMONHEADER, Map.class);
+ var dataAsjsonObject = coder.decode(COMMONHEADER, JsonObject.class);
+ dataAsObject.remove(TEST_ID);
+ dataAsjsonObject.remove(TEST_ID);
+ var dataReturned = validateAndUnmarshal(COMMONHEADERTYPE_WITH_OPTIONAL, dataAsjsonObject);
+ assertThat(dataReturned).isEqualTo(dataAsObject);
+ }
+
+ private Object validateAndUnmarshal(String schemaDef, Object data) {
+ var schemaHelper = createSchema(schemaDef);
+ if (data instanceof String) {
+ return schemaHelper.createNewInstance((String) data);
+ } else {
+ return schemaHelper.createNewInstance(data);
+ }
+ }
+
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/data/commonHeader.json b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/data/commonHeader.json
new file mode 100644
index 000000000..d3393cc63
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/data/commonHeader.json
@@ -0,0 +1,6 @@
+{
+ "requestId": "123456-1000",
+ "subRequestId": "sub-123456-1000",
+ "originatorId": "sdnc",
+ "testId": 212.2
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/data/measurementGroups.json b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/data/measurementGroups.json
new file mode 100644
index 000000000..e615968ac
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/data/measurementGroups.json
@@ -0,0 +1,34 @@
+[
+ {
+ "measurementGroup": {
+ "measurementTypes": [
+ {
+ "measurementType": "countera"
+ },
+ {
+ "measurementType": "counterb"
+ }
+ ],
+ "managedObjectDNsBasic": [
+ {
+ "DN": "dna"
+ },
+ {
+ "DN": "dnb"
+ }
+ ]
+ }
+ },
+ {
+ "measurementGroup": {
+ "measurementTypes": [
+ {
+ "measurementType": "counterc"
+ },
+ {
+ "measurementType": "counterd"
+ }
+ ]
+ }
+ }
+]
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderTypeWithOptional.json b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderTypeWithOptional.json
new file mode 100644
index 000000000..d8d994fda
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderTypeWithOptional.json
@@ -0,0 +1,23 @@
+{
+ "$schema": "http://json-schema.org/draft-04/schema#",
+ "type": "object",
+ "properties": {
+ "requestId": {
+ "type": "string"
+ },
+ "subRequestId": {
+ "type": "string"
+ },
+ "originatorId": {
+ "type": "string"
+ },
+ "testId": {
+ "type": "integer"
+ }
+ },
+ "required": [
+ "requestId",
+ "subRequestId",
+ "originatorId"
+ ]
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderType_draft04.json b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderType_draft04.json
new file mode 100644
index 000000000..de1c05b6f
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderType_draft04.json
@@ -0,0 +1,24 @@
+{
+ "$schema": "http://json-schema.org/draft-04/schema#",
+ "type": "object",
+ "properties": {
+ "requestId": {
+ "type": "string"
+ },
+ "subRequestId": {
+ "type": "string"
+ },
+ "originatorId": {
+ "type": "string"
+ },
+ "testId": {
+ "type": "number"
+ }
+ },
+ "required": [
+ "requestId",
+ "subRequestId",
+ "originatorId",
+ "testId"
+ ]
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderType_draft07.json b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderType_draft07.json
new file mode 100644
index 000000000..94558ffe5
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/commonHeaderType_draft07.json
@@ -0,0 +1,52 @@
+{
+ "$schema": "http://json-schema.org/draft-07/schema#",
+ "title": "Root",
+ "type": "object",
+ "required": [
+ "requestId",
+ "subRequestId",
+ "originatorId",
+ "testId"
+ ],
+ "properties": {
+ "requestId": {
+ "$id": "#root/requestId",
+ "title": "Requestid",
+ "type": "string",
+ "default": "",
+ "examples": [
+ "123456-1000"
+ ],
+ "pattern": "^[0-9]*-[0-9]*$"
+ },
+ "subRequestId": {
+ "$id": "#root/subRequestId",
+ "title": "Subrequestid",
+ "type": "string",
+ "default": "",
+ "examples": [
+ "sub-123456-1000"
+ ],
+ "pattern": "^.*$"
+ },
+ "originatorId": {
+ "$id": "#root/originatorId",
+ "title": "Originatorid",
+ "type": "string",
+ "default": "",
+ "examples": [
+ "sdnc"
+ ],
+ "pattern": "^.*$"
+ },
+ "testId": {
+ "$id": "#root/testId",
+ "title": "Testid",
+ "type": "number",
+ "examples": [
+ 212.2
+ ],
+ "default": 0
+ }
+ }
+}
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/measurementGroupsType.json b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/measurementGroupsType.json
new file mode 100644
index 000000000..41e598f93
--- /dev/null
+++ b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-json/src/test/resources/schema/measurementGroupsType.json
@@ -0,0 +1,61 @@
+{
+ "$schema": "http://json-schema.org/draft-07/schema#",
+ "type": "array",
+ "default": [],
+ "items": {
+ "type": "object",
+ "required": [
+ "measurementGroup"
+ ],
+ "properties": {
+ "measurementGroup": {
+ "type": "object",
+ "required": [
+ "measurementTypes"
+ ],
+ "properties": {
+ "measurementTypes": {
+ "type": "array",
+ "default": [],
+ "items": {
+ "type": "object",
+ "required": [
+ "measurementType"
+ ],
+ "properties": {
+ "measurementType": {
+ "type": "string",
+ "default": "",
+ "examples": [
+ "countera"
+ ],
+ "pattern": "^.*$"
+ }
+ }
+ }
+ },
+ "managedObjectDNsBasic": {
+ "type": "array",
+ "default": [],
+ "items": {
+ "type": "object",
+ "required": [
+ "DN"
+ ],
+ "properties": {
+ "DN": {
+ "type": "string",
+ "default": "",
+ "examples": [
+ "dna"
+ ],
+ "pattern": "^.*$"
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+}
diff --git a/plugins/plugins-context/plugins-context-schema/pom.xml b/plugins/plugins-context/plugins-context-schema/pom.xml
index e3fc13ab7..462bbaf81 100644
--- a/plugins/plugins-context/plugins-context-schema/pom.xml
+++ b/plugins/plugins-context/plugins-context-schema/pom.xml
@@ -1,19 +1,20 @@
<!--
============LICENSE_START=======================================================
Copyright (C) 2016-2018 Ericsson. All rights reserved.
+ Modifications Copyright (C) 2022 Bell Canada. All rights reserved.
================================================================================
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.
-
+
SPDX-License-Identifier: Apache-2.0
============LICENSE_END=========================================================
-->
@@ -33,5 +34,6 @@
<description>Plugins for 3pps that handle context schemas</description>
<modules>
<module>plugins-context-schema-avro</module>
+ <module>plugins-context-schema-json</module>
</modules>
</project>