+++ /dev/null
-{
- "delivery":{
- "url":"http://dcae-pm-mapper:8081/delivery",
- "user":"username",
- "password":"password",
- "use100":true
- },
- "follow_redirect":false,
- "metadataOnly":false,
- "suspend":false,
- "groupid":0,
- "links":{
- "self": "https://dmaap-dr-prov/subscribe/1",
- "log": "https://dmaap-dr-prov/feedlog/1",
- "feed": "https://dmaap-dr-prov/feed/1"
- },
- "subscriber":"pmmapper",
- "decompress":true,
- "privilegedSubscriber": true
- }
\ No newline at end of file
+++ /dev/null
-{
- "ID": "cbs",
- "Name": "config_binding_service",
- "Tags": ["cbs"],
- "Address": "ipaddress",
- "Port": 10000
-}
\ No newline at end of file
+++ /dev/null
-{
- "pm-mapper-filter": { "filters":[]},
- "key_store_path": "/opt/app/pm-mapper/etc/certs/cert.jks",
- "key_store_pass_path": "/opt/app/pm-mapper/etc/certs/jks.pass",
- "trust_store_path": "/opt/app/pm-mapper/etc/certs/trust.jks",
- "trust_store_pass_path": "/opt/app/pm-mapper/etc/certs/trust.pass",
- "dmaap_dr_delete_endpoint": "https://dmaap-dr-node:8443/delete",
- "dmaap_dr_feed_name": "1",
- "aaf_identity": "aaf_admin@people.osaaf.org",
- "aaf_password": "demo123456!",
- "enable_http": true,
- "streams_publishes": {
- "dmaap_publisher": {
- "type": "message_router",
- "dmaap_info": {
- "topic_url": "http://message-router:3904/events/org.onap.dmaap.mr.VES_PM",
- "client_role": "org.onap.dcae.pmPublisher",
- "location": "csit-pmmapper",
- "client_id": "1562763644939"
- }
- }
- },
- "streams_subscribes": {
- "dmaap_subscriber": {
- "type": "data_router",
- "dmaap_info": {
- "username": "username",
- "password": "password",
- "location": "csit-pmmapper",
- "delivery_url": "http://dcae-pm-mapper:8081/delivery",
- "subscriber_id": 1
- }
- }
- }
-}
\ No newline at end of file
+++ /dev/null
-{
- "name": "PM Mapper Feed",
- "version": "m1.0",
- "description": "PM Mapper Feed",
- "business_description": "PM Mapper",
- "suspend": false,
- "deleted": false,
- "changeowner": true,
- "authorization": {
- "classification": "unclassified",
- "endpoint_addrs": [],
- "endpoint_ids": [
- {
- "password": "pmmapper",
- "id": "pmmapper"
- }]
- }
- }
\ No newline at end of file
+++ /dev/null
-Er1tmip;T4w[%1}YE?x{fN9v
\ No newline at end of file
+++ /dev/null
-var httpServer = function () {
- var http = require('http'),
- url = require('url'),
- fs = require('fs'),
-
- start = function (port) {
- var server = http.createServer(function (req, res) {
- processHttpRequest(res);
- });
- server.listen(port, function () {
- console.log('Listening on ' + port + '...');
- });
- },
-
- processHttpRequest = function (res) {
- res.writeHead(200, {'Content-Type': 'text/plain'});
- console.log('received message');
- setTimeout(() => {
- res.end('Published Successfully.\n');
- }, 100);
- };
-
- return {
- start: start
- }
-}();
-
-httpServer.start(3904);
+++ /dev/null
-#-------------------------------------------------------------------------------
-# ============LICENSE_START==================================================
-# * org.onap.dmaap
-# * ===========================================================================
-# * Copyright � 2017 AT&T Intellectual Property. All rights reserved.
-# * ===========================================================================
-# * Modifications Copyright (C) 2021 Nokia 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.
-# * ============LICENSE_END====================================================
-# *
-# * ECOMP is a trademark and service mark of AT&T Intellectual Property.
-# *
-#-------------------------------------------------------------------------------
-#
-# Configuration parameters set at startup for the DataRouter node
-#
-# URL to retrieve dynamic configuration
-ProvisioningURL = https://dmaap-dr-prov:8443/internal/prov
-#
-# URL to upload PUB/DEL/EXP logs
-LogUploadURL = https://dmaap-dr-prov:8443/internal/logs
-#
-# The port number for http as seen within the server
-IntHttpPort = 8080
-#
-# The port number for https as seen within the server
-IntHttpsPort = 8443
-#
-# The external port number for https taking port mapping into account
-ExtHttpsPort = 443
-#
-# The minimum interval between fetches of the dynamic configuration from the provisioning server
-MinProvFetchInterval = 10000
-#
-# The minimum interval between saves of the redirection data file
-MinRedirSaveInterval = 10000
-#
-# The path to the directory where log files are stored
-LogDir = /opt/app/datartr/logs
-#
-# The retention interval (in days) for log files
-LogRetention = 30
-#
-# The path to the directories where data and meta data files are stored
-SpoolDir = /opt/app/datartr/spool
-#
-# The path to the redirection data file
-RedirectionFile = etc/redirections.dat
-#
-# The type of keystore for https
-KeyStoreType = PKCS12
-#
-# The type of truststore for https
-TrustStoreType = jks
-#
-# The path to the file used to trigger an orderly shutdown
-QuiesceFile = etc/SHUTDOWN
-#
-# The key used to generate passwords for node to node transfers
-NodeAuthKey = Node123!
-#
-# DR_NODE DEFAULT ENABLED TLS PROTOCOLS
-NodeHttpsProtocols = TLSv1.1|TLSv1.2
-#
-# AAF type to generate permission string
-AAFType = org.onap.dmaap-dr.feed
-#
-# AAF default instance to generate permission string - default should be legacy
-AAFInstance = legacy
-#
-# AAF action to generate permission string - default should be publish
-AAFAction = publish
-#
-# AAF CADI enabled flag
-CadiEnabled = false
-#
-# AAF Props file path
-AAFPropsFilePath = /opt/app/osaaf/local/org.onap.dmaap-dr.props
+++ /dev/null
-#-------------------------------------------------------------------------------
-# ============LICENSE_START==================================================
-# * org.onap.dmaap
-# * ===========================================================================
-# * Copyright � 2017 AT&T Intellectual Property. All rights reserved.
-# * ===========================================================================
-# * Modifications Copyright (C) 2021 Nokia 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.
-# * ============LICENSE_END====================================================
-# *
-# * ECOMP is a trademark and service mark of AT&T Intellectual Property.
-# *
-#-------------------------------------------------------------------------------
-
-#Jetty Server properties
-org.onap.dmaap.datarouter.provserver.http.port = 8080
-org.onap.dmaap.datarouter.provserver.https.port = 8443
-org.onap.dmaap.datarouter.provserver.https.relaxation = true
-
-org.onap.dmaap.datarouter.provserver.aafprops.path = /opt/app/osaaf/local/org.onap.dmaap-dr.props
-
-org.onap.dmaap.datarouter.provserver.accesslog.dir = /opt/app/datartr/logs
-org.onap.dmaap.datarouter.provserver.spooldir = /opt/app/datartr/spool
-org.onap.dmaap.datarouter.provserver.dbscripts = /opt/app/datartr/etc/misc
-org.onap.dmaap.datarouter.provserver.logretention = 30
-
-#DMAAP-597 (Tech Dept) REST request source IP auth
-# relaxation to accommodate OOM kubernetes deploy
-org.onap.dmaap.datarouter.provserver.isaddressauthenabled = false
-
-#Localhost address config
-org.onap.dmaap.datarouter.provserver.localhost = 127.0.0.1
-
-# Database access
-org.onap.dmaap.datarouter.db.driver = org.mariadb.jdbc.Driver
-org.onap.dmaap.datarouter.db.url = jdbc:mariadb://datarouter-mariadb:3306/datarouter
-org.onap.dmaap.datarouter.db.login = datarouter
-org.onap.dmaap.datarouter.db.password = datarouter
-
-# PROV - DEFAULT ENABLED TLS PROTOCOLS
-org.onap.dmaap.datarouter.provserver.https.include.protocols = TLSv1.1|TLSv1.2
-
-# AAF config
-org.onap.dmaap.datarouter.provserver.cadi.enabled = false
-
-org.onap.dmaap.datarouter.provserver.passwordencryption = PasswordEncryptionKey#@$%^&1234#
-org.onap.dmaap.datarouter.provserver.aaf.feed.type = org.onap.dmaap-dr.feed
-org.onap.dmaap.datarouter.provserver.aaf.sub.type = org.onap.dmaap-dr.sub
-org.onap.dmaap.datarouter.provserver.aaf.instance = legacy
-org.onap.dmaap.datarouter.provserver.aaf.action.publish = publish
-org.onap.dmaap.datarouter.provserver.aaf.action.subscribe = subscribe
+++ /dev/null
-583Ls;XF(qDQu3p!L22gyh1t
\ No newline at end of file
+++ /dev/null
-version: '3.3'
-
-services:
- datarouter-prov:
- image: nexus3.onap.org:10001/onap/dmaap/datarouter-prov
- container_name: datarouter-prov
- hostname: dmaap-dr-prov
- ports:
- - "443:8443"
- - "8443:8443"
- - "8080:8080"
- volumes:
- - /var/tmp/provserver.properties:/opt/app/datartr/etc/provserver.properties
- depends_on:
- - mariadb
- healthcheck:
- test: ["CMD", "curl", "-f", "http://dmaap-dr-prov:8080/internal/prov"]
- interval: 10s
- timeout: 10s
- retries: 5
- networks:
- pmmapper-network:
- ipv4_address: $DR_PROV_IP
- extra_hosts:
- - "dmaap-dr-node:$DR_NODE_IP"
- - "dcae-pm-mapper:$PMMAPPER_IP"
-
- datarouter-node:
- image: nexus3.onap.org:10001/onap/dmaap/datarouter-node
- container_name: datarouter-node
- hostname: dmaap-dr-node
- ports:
- - "9443:8443"
- - "9090:8080"
- volumes:
- - /var/tmp/node.properties:/opt/app/datartr/etc/node.properties
- depends_on:
- - datarouter-prov
- networks:
- pmmapper-network:
- ipv4_address: $DR_NODE_IP
- extra_hosts:
- - "dmaap-dr-prov:$DR_PROV_IP"
- - "dcae-pm-mapper:$PMMAPPER_IP"
-
- node:
- image: nexus3.onap.org:10001/node:10-slim
- container_name: mr-simulator
- volumes:
- - /var/tmp/mrserver.js:/tmp/mrserver.js
- command:
- nodejs /tmp/mrserver.js
- networks:
- pmmapper-network:
- ipv4_address: $NODE_IP
-
- mariadb:
- image: nexus3.onap.org:10001/mariadb:10.2.14
- container_name: mariadb
- ports:
- - "3306:3306"
- environment:
- MYSQL_ROOT_PASSWORD: datarouter
- MYSQL_DATABASE: datarouter
- MYSQL_USER: datarouter
- MYSQL_PASSWORD: datarouter
- healthcheck:
- test: ["CMD", "mysqladmin" ,"ping", "-h", "localhost", "--silent"]
- interval: 10s
- timeout: 30s
- retries: 5
- networks:
- pmmapper-network:
- ipv4_address: $MARIADB_IP
-
- consul:
- container_name: consul
- image: nexus3.onap.org:10001/consul:latest
- networks:
- pmmapper-network:
- ipv4_address: $CONSUL_IP
-
- cbs:
- container_name: cbs
- image: nexus3.onap.org:10001/onap/org.onap.dcaegen2.platform.configbinding.app-app:latest
- environment:
- CONSUL_HOST: $CONSUL_IP
- networks:
- pmmapper-network:
- ipv4_address: $CBS_IP
-
- pmmapper:
- container_name: pmmapper
- image: nexus3.onap.org:10001/onap/org.onap.dcaegen2.services.pm-mapper:latest
- ports:
- - "8081:8081"
- volumes:
- - /var/tmp/:/opt/app/pm-mapper/etc/certs/
- depends_on:
- - datarouter-prov
- environment:
- CONFIG_BINDING_SERVICE_SERVICE_HOST: $CBS_IP
- CONFIG_BINDING_SERVICE_SERVICE_PORT: 10000
- HOSTNAME: pmmapper
- networks:
- pmmapper-network:
- ipv4_address: $PMMAPPER_IP
- extra_hosts:
- - "dmaap-dr-node:$DR_NODE_IP"
- - "message-router:$NODE_IP"
-
-
-networks:
- pmmapper-network:
- driver: bridge
- ipam:
- config:
- - subnet: 172.18.0.0/16
-
+++ /dev/null
-#!/bin/bash
-# Place the scripts in run order:
-source ${SCRIPTS}/common_functions.sh
-
-docker login -u docker -p docker nexus3.onap.org:10001
-
-TEST_PLANS_DIR=$WORKSPACE/plans/dcaegen2-pmmapper/files-processing-config-pmmapper
-
-export GATEWAY_IP=172.18.0.1
-export DR_NODE_IP=172.18.0.2
-export DR_PROV_IP=172.18.0.3
-export CONSUL_IP=172.18.0.4
-export CBS_IP=172.18.0.5
-export MARIADB_IP=172.18.0.6
-export NODE_IP=172.18.0.7
-export PMMAPPER_IP=172.18.0.8
-
-for asset in provserver.properties node.properties cbs.json mrserver.js cert.jks jks.pass trust.jks trust.pass; do
- cp $TEST_PLANS_DIR/assets/${asset} /var/tmp/
-done
-
-sed -i 's/datarouter-mariadb/'$MARIADB_IP'/g' /var/tmp/provserver.properties
-sed -i 's/ipaddress//g' /var/tmp/cbs.json
-
-# ------------------------------------
-#Prepare enviroment for client
-#install docker sdk
-echo "Uninstall docker-py and reinstall docker."
-pip uninstall -y docker-py
-pip uninstall -y docker
-pip install -U docker==2.7.0
-
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml up -d mariadb consul cbs node
-
-echo "Waiting for MariaDB to come up healthy..."
-for i in {1..30}; do
- mariadb_state=$(docker inspect --format='{{json .State.Health.Status}}' mariadb)
- if [ $mariadb_state = '"healthy"' ]
- then
- break
- else
- sleep 2
- fi
-done
-[ "$mariadb_state" != '"healthy"' ] && echo "Error: MariaDB container state not healthy" && exit 1
-
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml up -d datarouter-node datarouter-prov
-
-unset http_proxy
-unset https_proxy
-curl --request PUT --data @/var/tmp/cbs.json http://$CONSUL_IP:8500/v1/agent/service/register
-curl 'http://'$CONSUL_IP':8500/v1/kv/pmmapper?dc=dc1' -X PUT \
- -H 'Accept: application/json' \
- -H 'Content-Type: application/json' \
- -H 'X-Requested-With: XMLHttpRequest' \
- --data @$TEST_PLANS_DIR/assets/config.json
-
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml up -d pmmapper
-sleep 2
-
-# Wait for initialization of Docker container for datarouter-node, datarouter-prov and mariadb, Consul, CBS
-containers_ok=false
-for i in {1..5}; do
- if [ $(docker inspect --format '{{ .State.Running }}' datarouter-node) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' datarouter-prov) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' mariadb) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' mr-simulator) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' consul) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' cbs) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' pmmapper) ]
- then
- echo "All required docker containers are up."
- containers_ok=true
- break
- else
- sleep $i
- fi
-done
-[ "$containers_ok" = "false" ] && echo "Error: required container not running." && exit 1
-
-# Data Router Configuration.
-docker exec -i datarouter-prov sh -c \
- "curl -k -X PUT https://$DR_PROV_IP:8443/internal/api/NODES?val=dmaap-dr-node\|$GATEWAY_IP"
-docker exec -i datarouter-prov sh -c \
- "curl -k -X PUT https://$DR_PROV_IP:8443/internal/api/PROV_AUTH_ADDRESSES?val=dmaap-dr-prov\|$GATEWAY_IP"
-
-# Create PM Mapper feed and create PM Mapper subscriber on data router
-curl -v -X POST -H "Content-Type:application/vnd.dmaap-dr.feed" -H "X-DMAAP-DR-ON-BEHALF-OF:pmmapper" \
- --data-ascii @$TEST_PLANS_DIR/assets/createFeed.json \
- --post301 --location-trusted -k https://${DR_PROV_IP}:8443
-curl -v -X POST -H "Content-Type:application/vnd.dmaap-dr.subscription" -H "X-DMAAP-DR-ON-BEHALF-OF:pmmapper" \
- --data-ascii @$TEST_PLANS_DIR/assets/addSubscriber.json \
- --post301 --location-trusted -k https://${DR_PROV_IP}:8443/subscribe/1
-
-docker cp pmmapper:/var/log/ONAP/dcaegen2/services/pm-mapper/pm-mapper_output.log /tmp/pmmapper.log
-sleep 10
-docker exec -it datarouter-prov sh -c "curl http://dmaap-dr-node:8080/internal/fetchProv"
-curl -k https://$DR_PROV_IP:8443/internal/prov
-
-#Pass any variables required by Robot test suites in ROBOT_VARIABLES
-ROBOT_VARIABLES="-v CONSUL_IP:${CONSUL_IP} -v DR_PROV_IP:${DR_PROV_IP} -v DMAAP_MR_IP:${DMAAP_MR_IP} -v CBS_IP:${CBS_IP} -v PMMAPPER_IP:${PMMAPPER_IP} -v DR_NODE_IP:${DR_NODE_IP} -v NODE_IP:${NODE_IP}"
+++ /dev/null
-#!/bin/bash
-echo "Starting teardown script"
-TEST_PLANS_DIR=$WORKSPACE/plans/dcaegen2-pmmapper/files-processing-config-pmmapper
-mkdir -p $WORKSPACE/archives
-docker exec pmmapper /bin/sh -c "cat /var/log/ONAP/dcaegen2/services/pm-mapper/pm-mapper_output.log"
-kill-instance.sh pmmapper
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml logs > $WORKSPACE/archives/files-processing-config-pmmapper-docker-compose.log
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml down -v
+++ /dev/null
-# Test suites are relative paths under [integration/csit.git]/tests/.
-# Place the suites in run order.
-dcaegen2-pmmapper/files-processing-config-pmmapper
+++ /dev/null
-#-------------------------------------------------------------------------------
-# ============LICENSE_START==================================================
-# * org.onap.dmaap
-# * ===========================================================================
-# * Copyright © 2017 AT&T Intellectual Property. 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.
-# * ============LICENSE_END====================================================
-# *
-# * ECOMP is a trademark and service mark of AT&T Intellectual Property.
-# *
-#-------------------------------------------------------------------------------
-{
- "name": "Jettydemo",
- "version": "m1.0",
- "description": "Jettydemo",
- "business_description": "Jettydemo",
- "suspend": false,
- "deleted": false,
- "changeowner": true,
- "authorization": {
- "classification": "unclassified",
- "endpoint_addrs": [
- "<kafka-ip>",
- ],
- "endpoint_ids": [
- {
- "password": "rs873m",
- "id": "rs873m"
- }
- ]
- },
-}
-
+++ /dev/null
-{
- "delivery":{
- "url":"http://dcae-pm-mapper:8081/delivery",
- "user":"username",
- "password":"password",
- "use100":true
- },
- "follow_redirect":false,
- "metadataOnly":false,
- "suspend":false,
- "groupid":0,
- "links":{
- "self": "https://dmaap-dr-prov/subscribe/1",
- "log": "https://dmaap-dr-prov/feedlog/1",
- "feed": "https://dmaap-dr-prov/feed/1"
- },
- "subscriber":"pmmapper",
- "decompress":true,
- "privilegedSubscriber": true
- }
\ No newline at end of file
+++ /dev/null
-#-------------------------------------------------------------------------------
-# ============LICENSE_START==================================================
-# * org.onap.dmaap
-# * ===========================================================================
-# * Copyright © 2017 AT&T Intellectual Property. 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.
-# * ============LICENSE_END====================================================
-# *
-# * ECOMP is a trademark and service mark of AT&T Intellectual Property.
-# *
-#-------------------------------------------------------------------------------
-{
-"delivery" :
- {
- "url" : "http://<kafka-ip>:7070/",
- "user" : "datarouter",
- "password" : "datarouter",
- "use100" : true
- },
-"metadataOnly" : false,
-"suspend" : false,
-"groupid" : 29,
-"subscriber" : "sg481n"
-}
+++ /dev/null
-{
- "ID": "cbs",
- "Name": "config_binding_service",
- "Tags": ["cbs"],
- "Address": "ipaddress",
- "Port": 10000
-}
\ No newline at end of file
+++ /dev/null
-{
- "pm-mapper-filter": { "filters":[]},
- "key_store_path": "/opt/app/pm-mapper/etc/certs/cert.jks",
- "key_store_pass_path": "/opt/app/pm-mapper/etc/certs/jks.pass",
- "trust_store_path": "/opt/app/pm-mapper/etc/certs/trust.jks",
- "trust_store_pass_path": "/opt/app/pm-mapper/etc/certs/trust.pass",
- "dmaap_dr_delete_endpoint": "https://dmaap-dr-node:8443/delete",
- "dmaap_dr_feed_name": "1",
- "aaf_identity": "aaf_admin@people.osaaf.org",
- "aaf_password": "demo123456!",
- "enable_http": true,
- "streams_publishes": {
- "dmaap_publisher": {
- "type": "message_router",
- "dmaap_info": {
- "topic_url": "http://message-router:3904/events/org.onap.dmaap.mr.VES_PM",
- "client_role": "org.onap.dcae.pmPublisher",
- "location": "csit-pmmapper",
- "client_id": "1562763644939"
- }
- }
- },
- "streams_subscribes": {
- "dmaap_subscriber": {
- "type": "data_router",
- "dmaap_info": {
- "username": "username",
- "password": "password",
- "location": "csit-pmmapper",
- "delivery_url": "http://dcae-pm-mapper:8081/delivery",
- "subscriber_id": 1
- }
- }
- }
-}
\ No newline at end of file
+++ /dev/null
-{
- "name": "PM Mapper Feed",
- "version": "m1.0",
- "description": "PM Mapper Feed",
- "business_description": "PM Mapper",
- "suspend": false,
- "deleted": false,
- "changeowner": true,
- "authorization": {
- "classification": "unclassified",
- "endpoint_addrs": [],
- "endpoint_ids": [
- {
- "password": "pmmapper",
- "id": "pmmapper"
- }]
- }
- }
\ No newline at end of file
+++ /dev/null
-Er1tmip;T4w[%1}YE?x{fN9v
\ No newline at end of file
+++ /dev/null
-var httpServer = function() {
-var http = require('http'),
-url = require('url'),
-fs = require('fs'),
-
-start = function(port) {
- var server = http.createServer(function(req, res) {
- processHttpRequest(res);
- });
- server.listen(port, function() {
- console.log('Listening on ' + port + '...');
- });
-},
-
-processHttpRequest = function(res) {
- res.writeHead(200, {'Content-Type': 'text/plain'});
- res.end('Published Successfully.\n');
-};
-
-return {
- start: start
-}
-}();
-
-httpServer.start(3904);
\ No newline at end of file
+++ /dev/null
-#-------------------------------------------------------------------------------
-# ============LICENSE_START==================================================
-# * org.onap.dmaap
-# * ===========================================================================
-# * Copyright � 2017 AT&T Intellectual Property. 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.
-# * ============LICENSE_END====================================================
-# *
-# * ECOMP is a trademark and service mark of AT&T Intellectual Property.
-# *
-#-------------------------------------------------------------------------------
-#
-# Configuration parameters set at startup for the DataRouter node
-#
-# URL to retrieve dynamic configuration
-ProvisioningURL = https://dmaap-dr-prov:8443/internal/prov
-#
-# URL to upload PUB/DEL/EXP logs
-LogUploadURL = https://dmaap-dr-prov:8443/internal/logs
-#
-# The port number for http as seen within the server
-IntHttpPort = 8080
-#
-# The port number for https as seen within the server
-IntHttpsPort = 8443
-#
-# The external port number for https taking port mapping into account
-ExtHttpsPort = 443
-#
-# The minimum interval between fetches of the dynamic configuration from the provisioning server
-MinProvFetchInterval = 10000
-#
-# The minimum interval between saves of the redirection data file
-MinRedirSaveInterval = 10000
-#
-# The path to the directory where log files are stored
-LogDir = /opt/app/datartr/logs
-#
-# The retention interval (in days) for log files
-LogRetention = 30
-#
-# The path to the directories where data and meta data files are stored
-SpoolDir = /opt/app/datartr/spool
-#
-# The path to the redirection data file
-RedirectionFile = etc/redirections.dat
-#
-# The type of keystore for https
-KeyStoreType = PKCS12
-#
-# The type of truststore for https
-TrustStoreType = jks
-#
-# The path to the file used to trigger an orderly shutdown
-QuiesceFile = etc/SHUTDOWN
-#
-# The key used to generate passwords for node to node transfers
-NodeAuthKey = Node123!
-#
-# DR_NODE DEFAULT ENABLED TLS PROTOCOLS
-NodeHttpsProtocols = TLSv1.1|TLSv1.2
-#
-# AAF type to generate permission string
-AAFType = org.onap.dmaap-dr.feed
-#
-# AAF default instance to generate permission string - default should be legacy
-AAFInstance = legacy
-#
-# AAF action to generate permission string - default should be publish
-AAFAction = publish
-#
-# AAF CADI enabled flag
-CadiEnabled = false
-#
-# AAF Props file path
-AAFPropsFilePath = /opt/app/osaaf/local/org.onap.dmaap-dr.props
\ No newline at end of file
+++ /dev/null
-#-------------------------------------------------------------------------------
-# ============LICENSE_START==================================================
-# * org.onap.dmaap
-# * ===========================================================================
-# * Copyright � 2017 AT&T Intellectual Property. 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.
-# * ============LICENSE_END====================================================
-# *
-# * ECOMP is a trademark and service mark of AT&T Intellectual Property.
-# *
-#-------------------------------------------------------------------------------
-
-#Jetty Server properties
-org.onap.dmaap.datarouter.provserver.http.port = 8080
-org.onap.dmaap.datarouter.provserver.https.port = 8443
-org.onap.dmaap.datarouter.provserver.https.relaxation = true
-
-org.onap.dmaap.datarouter.provserver.aafprops.path = /opt/app/osaaf/local/org.onap.dmaap-dr.props
-
-org.onap.dmaap.datarouter.provserver.accesslog.dir = /opt/app/datartr/logs
-org.onap.dmaap.datarouter.provserver.spooldir = /opt/app/datartr/spool
-org.onap.dmaap.datarouter.provserver.dbscripts = /opt/app/datartr/etc/misc
-org.onap.dmaap.datarouter.provserver.logretention = 30
-
-#DMAAP-597 (Tech Dept) REST request source IP auth
-# relaxation to accommodate OOM kubernetes deploy
-org.onap.dmaap.datarouter.provserver.isaddressauthenabled = false
-
-#Localhost address config
-org.onap.dmaap.datarouter.provserver.localhost = 127.0.0.1
-
-# Database access
-org.onap.dmaap.datarouter.db.driver = org.mariadb.jdbc.Driver
-org.onap.dmaap.datarouter.db.url = jdbc:mariadb://datarouter-mariadb:3306/datarouter
-org.onap.dmaap.datarouter.db.login = datarouter
-org.onap.dmaap.datarouter.db.password = datarouter
-
-# PROV - DEFAULT ENABLED TLS PROTOCOLS
-org.onap.dmaap.datarouter.provserver.https.include.protocols = TLSv1.1|TLSv1.2
-
-# AAF config
-org.onap.dmaap.datarouter.provserver.cadi.enabled = false
-
-org.onap.dmaap.datarouter.provserver.passwordencryption = PasswordEncryptionKey#@$%^&1234#
-org.onap.dmaap.datarouter.provserver.aaf.feed.type = org.onap.dmaap-dr.feed
-org.onap.dmaap.datarouter.provserver.aaf.sub.type = org.onap.dmaap-dr.sub
-org.onap.dmaap.datarouter.provserver.aaf.instance = legacy
-org.onap.dmaap.datarouter.provserver.aaf.action.publish = publish
-org.onap.dmaap.datarouter.provserver.aaf.action.subscribe = subscribe
\ No newline at end of file
+++ /dev/null
-583Ls;XF(qDQu3p!L22gyh1t
\ No newline at end of file
+++ /dev/null
-version: '3.3'
-
-services:
- datarouter-prov:
- image: nexus3.onap.org:10001/onap/dmaap/datarouter-prov
- container_name: datarouter-prov
- hostname: dmaap-dr-prov
- ports:
- - "443:8443"
- - "8443:8443"
- - "8080:8080"
- volumes:
- - /var/tmp/provserver.properties:/opt/app/datartr/etc/provserver.properties
- - /var/tmp/addSubscriber.txt:/opt/app/datartr/addSubscriber.txt
- - /var/tmp/addFeed3.txt:/opt/app/datartr/addFeed3.txt
- depends_on:
- - mariadb
- healthcheck:
- test: ["CMD", "curl", "-f", "http://dmaap-dr-prov:8080/internal/prov"]
- interval: 10s
- timeout: 10s
- retries: 5
- networks:
- pmmapper-network:
- ipv4_address: $DR_PROV_IP
- extra_hosts:
- - "dmaap-dr-node:$DR_NODE_IP"
- - "dcae-pm-mapper:$PMMAPPER_IP"
-
- datarouter-node:
- image: nexus3.onap.org:10001/onap/dmaap/datarouter-node
- container_name: datarouter-node
- hostname: dmaap-dr-node
- ports:
- - "9443:8443"
- - "9090:8080"
- volumes:
- - /var/tmp/node.properties:/opt/app/datartr/etc/node.properties
- depends_on:
- - datarouter-prov
- networks:
- pmmapper-network:
- ipv4_address: $DR_NODE_IP
- extra_hosts:
- - "dmaap-dr-prov:$DR_PROV_IP"
- - "dcae-pm-mapper:$PMMAPPER_IP"
-
- node:
- image: node:10-slim
- container_name: mr-simulator
- volumes:
- - /var/tmp/mrserver.js:/tmp/mrserver.js
- command:
- nodejs /tmp/mrserver.js
- networks:
- pmmapper-network:
- ipv4_address: $NODE_IP
-
- mariadb:
- image: mariadb:10.2.14
- container_name: mariadb
- ports:
- - "3306:3306"
- environment:
- MYSQL_ROOT_PASSWORD: datarouter
- MYSQL_DATABASE: datarouter
- MYSQL_USER: datarouter
- MYSQL_PASSWORD: datarouter
- healthcheck:
- test: ["CMD", "mysqladmin" ,"ping", "-h", "localhost", "--silent"]
- interval: 10s
- timeout: 30s
- retries: 5
- networks:
- pmmapper-network:
- ipv4_address: $MARIADB_IP
-
- consul:
- container_name: consul
- image: nexus3.onap.org:10001/consul:latest
- networks:
- pmmapper-network:
- ipv4_address: $CONSUL_IP
-
- cbs:
- container_name: cbs
- image: nexus3.onap.org:10001/onap/org.onap.dcaegen2.platform.configbinding.app-app:latest
- environment:
- CONSUL_HOST: $CONSUL_IP
- networks:
- pmmapper-network:
- ipv4_address: $CBS_IP
-
- pmmapper:
- container_name: pmmapper
- image: nexus3.onap.org:10001/onap/org.onap.dcaegen2.services.pm-mapper:latest
- ports:
- - "8081:8081"
- volumes:
- - /var/tmp/:/opt/app/pm-mapper/etc/certs/
- depends_on:
- - datarouter-prov
- environment:
- CONFIG_BINDING_SERVICE_SERVICE_HOST: $CBS_IP
- CONFIG_BINDING_SERVICE_SERVICE_PORT: 10000
- HOSTNAME: pmmapper
- networks:
- pmmapper-network:
- ipv4_address: $PMMAPPER_IP
- extra_hosts:
- - "dmaap-dr-node:$DR_NODE_IP"
- - "message-router:$NODE_IP"
-
-
-networks:
- pmmapper-network:
- driver: bridge
- ipam:
- config:
- - subnet: 172.18.0.0/16
-
+++ /dev/null
-#!/bin/bash
-# Place the scripts in run order:
-source ${SCRIPTS}/common_functions.sh
-
-docker login -u docker -p docker nexus3.onap.org:10001
-
-TEST_PLANS_DIR=$WORKSPACE/plans/dcaegen2-pmmapper/pmmapper
-
-export GATEWAY_IP=172.18.0.1
-export DR_NODE_IP=172.18.0.2
-export DR_PROV_IP=172.18.0.3
-export CONSUL_IP=172.18.0.4
-export CBS_IP=172.18.0.5
-export MARIADB_IP=172.18.0.6
-export NODE_IP=172.18.0.7
-export PMMAPPER_IP=172.18.0.8
-
-for asset in provserver.properties addSubscriber.txt addFeed3.txt node.properties cbs.json mrserver.js cert.jks jks.pass trust.jks trust.pass; do
- cp $TEST_PLANS_DIR/assets/${asset} /var/tmp/
-done
-
-sed -i 's/datarouter-mariadb/'$MARIADB_IP'/g' /var/tmp/provserver.properties
-#sed -i 's/<kafka-ip>/'$KAFKA_IP'/g' /var/tmp/addSubscriber.txt
-#sed -i 's/<kafka-ip>/'$KAFKA_IP'/g' /var/tmp/addFeed3.txt
-#sed -i 's/ipaddress/'$CBS_IP'/g' /var/tmp/cbs.json
-sed -i 's/ipaddress//g' /var/tmp/cbs.json
-
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml up -d mariadb consul cbs node
-
-echo "Waiting for MariaDB to come up healthy..."
-for i in {1..30}; do
- mariadb_state=$(docker inspect --format='{{json .State.Health.Status}}' mariadb)
- if [ $mariadb_state = '"healthy"' ]
- then
- break
- else
- sleep 2
- fi
-done
-[ "$mariadb_state" != '"healthy"' ] && echo "Error: MariaDB container state not healthy" && exit 1
-
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml up -d datarouter-node datarouter-prov
-
-curl --request PUT --data @/var/tmp/cbs.json http://$CONSUL_IP:8500/v1/agent/service/register
-curl 'http://'$CONSUL_IP':8500/v1/kv/pmmapper?dc=dc1' -X PUT \
- -H 'Accept: application/json' \
- -H 'Content-Type: application/json' \
- -H 'X-Requested-With: XMLHttpRequest' \
- --data @$TEST_PLANS_DIR/assets/config.json
-
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml up -d pmmapper
-sleep 2
-
-# Wait for initialization of Docker container for datarouter-node, datarouter-prov and mariadb, Consul, CBS
-containers_ok=false
-for i in {1..5}; do
- if [ $(docker inspect --format '{{ .State.Running }}' datarouter-node) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' datarouter-prov) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' mariadb) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' mr-simulator) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' consul) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' cbs) ] && \
- [ $(docker inspect --format '{{ .State.Running }}' pmmapper) ]
- then
- echo "All required docker containers are up."
- containers_ok=true
- break
- else
- sleep $i
- fi
-done
-[ "$containers_ok" = "false" ] && echo "Error: required container not running." && exit 1
-
-# Data Router Configuration.
-docker exec -i datarouter-prov sh -c \
- "curl -k -X PUT https://$DR_PROV_IP:8443/internal/api/NODES?val=dmaap-dr-node\|$GATEWAY_IP"
-docker exec -i datarouter-prov sh -c \
- "curl -k -X PUT https://$DR_PROV_IP:8443/internal/api/PROV_AUTH_ADDRESSES?val=dmaap-dr-prov\|$GATEWAY_IP"
-
-# Create PM Mapper feed and create PM Mapper subscriber on data router
-curl -v -X POST -H "Content-Type:application/vnd.dmaap-dr.feed" -H "X-DMAAP-DR-ON-BEHALF-OF:pmmapper" \
- --data-ascii @$TEST_PLANS_DIR/assets/createFeed.json \
- --post301 --location-trusted -k https://${DR_PROV_IP}:8443
-curl -v -X POST -H "Content-Type:application/vnd.dmaap-dr.subscription" -H "X-DMAAP-DR-ON-BEHALF-OF:pmmapper" \
- --data-ascii @$TEST_PLANS_DIR/assets/addSubscriber.json \
- --post301 --location-trusted -k https://${DR_PROV_IP}:8443/subscribe/1
-
-docker cp pmmapper:/var/log/ONAP/dcaegen2/services/pm-mapper/pm-mapper_output.log /tmp/pmmapper.log
-sleep 10
-docker exec -it datarouter-prov sh -c "curl http://dmaap-dr-node:8080/internal/fetchProv"
-curl -k https://$DR_PROV_IP:8443/internal/prov
-
-#Pass any variables required by Robot test suites in ROBOT_VARIABLES
-ROBOT_VARIABLES="-v CONSUL_IP:${CONSUL_IP} -v DR_PROV_IP:${DR_PROV_IP} -v DMAAP_MR_IP:${DMAAP_MR_IP} -v CBS_IP:${CBS_IP} -v PMMAPPER_IP:${PMMAPPER_IP} -v DR_NODE_IP:${DR_NODE_IP}"
+++ /dev/null
-#!/bin/bash
-echo "Starting teardown script"
-TEST_PLANS_DIR=$WORKSPACE/plans/dcaegen2-pmmapper/pmmapper
-mkdir -p $WORKSPACE/archives
-docker exec pmmapper /bin/sh -c "cat /var/log/ONAP/dcaegen2/services/pm-mapper/pm-mapper_output.log"
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml logs > $WORKSPACE/archives/pmmapper-docker-compose.log
-docker-compose -f $TEST_PLANS_DIR/docker-compose.yml down -v
+++ /dev/null
-# Test suites are relative paths under [integration/csit.git]/tests/.
-# Place the suites in run order.
-dcaegen2-pmmapper/pmmapper
+++ /dev/null
-*** Settings ***
-Documentation Files Processing Config PM Mapper Testcases
+++ /dev/null
-*.gz binary
+++ /dev/null
-<?xml version="1.0" encoding="UTF-8"?>
-<?xml-stylesheet type="text/xsl" href="MeasDataCollection.xsl"?>
-<measCollecFile xmlns="http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec"
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-xsi:schemaLocation="http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec">
- <fileHeader fileFormatVersion="32.435 V7.0" vendorName="Company NN" dnPrefix="DC=a1.companyNN.com,SubNetwork=1,IRPAgent=1">
- <fileSender localDn="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1" elementType="RNC"/>
- <measCollec beginTime="2000-03-01T14:00:00+02:00"/>
- </fileHeader>
- <measData>
- <managedElement localDn="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1" userLabel="RNC Telecomville"/>
- <measInfo>
- <job jobId="1231"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures</measType>
- <measType p="2">succTCHSeizures</measType>
- <measType p="3">attImmediateAssignProcs</measType>
- <measType p="4">succImmediateAssignProcs</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">234</r>
- <r p="2">345</r>
- <r p="3">567</r>
- <r p="4">789</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">890</r>
- <r p="2">901</r>
- <r p="3">123</r>
- <r p="4">234</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">456</r>
- <r p="2">567</r>
- <r p="3">678</r>
- <r p="4">789</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- <measInfo measInfoId="ENodeBFunction">
- <job jobId="1232"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures1</measType>
- <measType p="2">succTCHSeizures2</measType>
- <measType p="3">attImmediateAssignProcs3</measType>
- <measType p="4">succImmediateAssignProcs4</measType>
- <measValue measObjLdn="ManagedElement=RNC-Gbg-1,ENodeBFunction=1">
- <r p="1">4</r>
- <r p="2">86,87,2,6,77,96,75,33,24</r>
- <r p="3">40</r>
- <r p="4">90</r>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- <measInfo>
- <job jobId="1233"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures5</measType>
- <measType p="2">succTCHSeizures6</measType>
- <measType p="3">attImmediateAssignProcs7</measType>
- <measType p="4">succImmediateAssignProcs8</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">238</r>
- <r p="2">344</r>
- <r p="3">563</r>
- <r p="4">787</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">898</r>
- <r p="2">905</r>
- <r p="3">127</r>
- <r p="4">238</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">454</r>
- <r p="2">569</r>
- <r p="3">672</r>
- <r p="4">785</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- </measData>
- <measData>
- <managedElement localDn="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1" userLabel="RNC Telecomville"/>
- <measInfo>
- <job jobId="1231"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures</measType>
- <measType p="2">succTCHSeizures</measType>
- <measType p="3">attImmediateAssignProcs</measType>
- <measType p="4">succImmediateAssignProcs</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">234</r>
- <r p="2">345</r>
- <r p="3">567</r>
- <r p="4">789</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">890</r>
- <r p="2">901</r>
- <r p="3">123</r>
- <r p="4">234</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">456</r>
- <r p="2">567</r>
- <r p="3">678</r>
- <r p="4">789</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- <measInfo measInfoId="ENodeBFunction">
- <job jobId="1232"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures1</measType>
- <measType p="2">succTCHSeizures2</measType>
- <measType p="3">attImmediateAssignProcs3</measType>
- <measType p="4">succImmediateAssignProcs4</measType>
- <measValue measObjLdn="ManagedElement=RNC-Gbg-1,ENodeBFunction=1">
- <r p="1">4</r>
- <r p="2">86,87,2,6,77,96,75,33,24</r>
- <r p="3">40</r>
- <r p="4">90</r>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- <measInfo>
- <job jobId="1233"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures5</measType>
- <measType p="2">succTCHSeizures6</measType>
- <measType p="3">attImmediateAssignProcs7</measType>
- <measType p="4">succImmediateAssignProcs8</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">238</r>
- <r p="2">344</r>
- <r p="3">563</r>
- <r p="4">787</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">898</r>
- <r p="2">905</r>
- <r p="3">127</r>
- <r p="4">238</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">454</r>
- <r p="2">569</r>
- <r p="3">672</r>
- <r p="4">785</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- </measData>
- <fileFooter>
- <measCollec endTime="2000-03-01T14:15:00+02:00"/>
- </fileFooter>
-</measCollecFile>
+++ /dev/null
-PROCESSING_LIMIT_RATE=10
-THREADS_MULTIPLIER=1
-PROCESSING_THREADS_COUNT=1
+++ /dev/null
-PROCESSING_LIMIT_RATE=1
-THREADS_MULTIPLIER=1
-PROCESSING_THREADS_COUNT=1
+++ /dev/null
-PROCESSING_LIMIT_RATE=1
-THREADS_MULTIPLIER=1
-PROCESSING_THREADS_COUNT=10
+++ /dev/null
-{
- "productName": "gnb",
- "vendorName": "Ericsson",
- "lastEpochMicrosec": "1538478000000",
- "sourceName": "oteNB5309",
- "startEpochMicrosec": "1538478900000",
- "timeZoneOffset": "UTC+05.00",
- "location": "ftpes://192.168.0.101:22/ftp/rop/A20161224.1045-1100.bin.gz",
- "compression": "gzip",
- "fileFormatType": "org.3GPP.32.435#measCollec",
- "fileFormatVersion": "V9"
- }
\ No newline at end of file
+++ /dev/null
-*** Settings ***
-Documentation Testing PM Mapper functionality
-Library Collections
-Library OperatingSystem
-Library RequestsLibrary
-Library Process
-Library String
-Library libraries/DockerContainerManager.py
-Library libraries/LogReader.py
-
-*** Variables ***
-
-${NR_VALID_METADATA_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/assets/valid_metadata.json
-${CLI_EXEC_CLI_PM_LOG_CLEAR} docker exec pmmapper /bin/sh -c "echo -n "" > /var/log/ONAP/dcaegen2/services/pm-mapper/pm-mapper_output.log"
-${PUBLISH_NODE_URL} https://${DR_NODE_IP}:8443/publish/1
-${CLI_EXEC_LOGS_LIST} docker exec datarouter-node /bin/sh -c "ls /opt/app/datartr/logs"
-${DOCKER_CLIENT_IMAGE} nexus3.onap.org:10001/onap/org.onap.dcaegen2.services.pm-mapper:latest
-${CLIENT_CONTAINER_NAME} pmmapper
-${FILE_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/assets/ABigFile.xml
-${CONFIG_ENVS_1_1} %{WORKSPACE}/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/assets/config_1_1.env
-${CONFIG_ENVS_4_1} %{WORKSPACE}/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/assets/config_4_1.env
-${CONFIG_ENVS_10_1} %{WORKSPACE}/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/assets/config_10_1.env
-${CONFIG_ENVS_1_10} %{WORKSPACE}/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/assets/config_1_10.env
-
-*** Test Cases ***
-
-Verify that PM Mapper rejects 6-9 messages when limitRate is 1 and threads count is 1
- [Tags] FILES_PROCESSING_CONFIG_PM_MAPPER_1
- [Documentation] Verify that PM Mapper rejects 6-9/10 messages. Configuration: limitRate=1, threadsCount=1
- [Timeout] 15 minute
-
- RestartPmmapper ${CONFIG_ENVS_1_1}
-
- ${testname}= Set Variable Afirst-
-
- SendFilesToDatarouter ${testname}
- ${alllogs}= GetLogsOutput
- ${filtered_logs}= GetFilteredLogs ${alllogs} ${testname}
- ${dropped_nr}= GetDroppedNumber ${filtered_logs}
-
- Sleep 40s
- ${isCorrectDroppedCount}= Evaluate ${5} < ${dropped_nr} < ${10}
- SavePmMapperLogsAndDroppedCount config_1_1 ${dropped_nr}
- Should Be True ${isCorrectDroppedCount} Pm-mapper drop: ${dropped_nr} messages. Expected drop count: 6-9
- ClearLogs
-
-Verify that PM Mapper rejects 0 messages when limitRate is 10 and threads count is 1
- [Tags] FILES_PROCESSING_CONFIG_PM_MAPPER_2
- [Documentation] Verify that PM Mapper rejects 0/10 messages. Configuration: limitRate=10, threadsCount=1
- [Timeout] 25 minute
-
- RestartPmmapper ${CONFIG_ENVS_10_1}
-
- ${testname}= Set Variable Athird-
-
- SendFilesToDatarouter ${testname}
- ${alllogs}= GetLogsOutput
- ${filtered_logs}= GetFilteredLogs ${alllogs} ${testname}
- ${dropped_nr}= GetDroppedNumber ${filtered_logs}
-
- Sleep 15s
- SavePmMapperLogsAndDroppedCount config_10_1 ${dropped_nr}
- Should Be Equal As Numbers ${dropped_nr} 0 Pm-mapper drop: ${dropped_nr} messages. Expected drop count: 0
- ClearLogs
-
-Verify that PM Mapper rejects 0 messages when limitRate is 1 and threads count is 10
- [Tags] FILES_PROCESSING_CONFIG_PM_MAPPER_3
- [Documentation] Verify that PM Mapper rejects 0/10 messages. Configuration: limitRate=1, threadsCount=10
- [Timeout] 25 minute
-
- RestartPmmapper ${CONFIG_ENVS_1_10}
-
- ${testname}= Set Variable Afourth-
-
- SendFilesToDatarouter ${testname}
- ${alllogs}= GetLogsOutput
- ${filtered_logs}= GetFilteredLogs ${alllogs} ${testname}
- ${dropped_nr}= GetDroppedNumber ${filtered_logs}
-
- Sleep 15s
- SavePmMapperLogsAndDroppedCount config_1_10 ${dropped_nr}
- Should Be Equal As Numbers ${dropped_nr} 0 Pm-mapper drop: ${dropped_nr} messages. Expected drop count: 0
- ClearLogs
-
-*** Keywords ***
-
-SendFilesToDatarouter
- [Arguments] ${testnr}
- FOR ${i} IN RANGE 10
- SendToDatarouter ${FILE_PATH} ${NR_VALID_METADATA_PATH} X-ONAP-RequestID=${i} ${testnr} ${i}
- END
- Sleep 20s
-
-SendToDatarouter
- [Arguments] ${filepath} ${metadatapath} ${request_id} ${testnr} ${i}
- ${pmdata}= Get File ${filepath}
- ${metatdata} Get File ${metadatapath}
- ${newFilename} Catenate SEPARATOR= ${testnr} ${i} .xml
- ${resp}= PutCall ${PUBLISH_NODE_URL}/${newFilename} ${request_id} ${pmdata} ${metatdata.replace("\n","")} pmmapper
- VerifyResponse ${resp.status_code} 204
-
-PutCall
- [Arguments] ${url} ${request_id} ${data} ${meta} ${user}
- ${headers}= Create Dictionary X-ONAP-RequestID=${request_id} X-DMAAP-DR-META=${meta} Content-Type=application/octet-stream X-DMAAP-DR-ON-BEHALF-OF=${user} Authorization=Basic cG1tYXBwZXI6cG1tYXBwZXI=
- ${resp}= Evaluate requests.put('${url}', data="""${data}""", headers=${headers}, verify=False, allow_redirects=False) requests
- [Return] ${resp}
-
-VerifyResponse
- [Arguments] ${actual_response_value} ${expected_response_value}
- Should Be Equal As Strings ${actual_response_value} ${expected_response_value}
-
-ClearLogs
- Run Process ${CLI_EXEC_CLI_PM_LOG_CLEAR} shell=yes
-
-GetLogsOutput
- ${filesString}= Run Process ${CLI_EXEC_LOGS_LIST} shell=yes
- ${filesList}= Get Log Files List ${filesString.stdout}
- ${output}= Set Variable ${EMPTY}
- FOR ${file} IN @{filesList}
- ${file_path}= Catenate SEPARATOR= "cat /opt/app/datartr/logs/ ${file} "
- ${exec}= Catenate docker exec datarouter-node /bin/sh -c ${file_path}
- ${single_file}= Run Process ${exec} shell=yes
- ${output}= Catenate SEPARATOR=\n ${output} ${single_file.stdout}
- END
- [Return] ${output}
-
-GetFilteredLogs
- [Arguments] ${all_logs} ${testname}
- ${filtered_logs}= Filter Unique ${all_logs} ${testname}
- [Return] ${filtered_logs}
-
-GetDroppedNumber
- [Arguments] ${logs_output}
- ${number}= Get Number Of Dropped Messages ${logs_output}
- [Return] ${number}
-
-RestartPmmapper
- [Arguments] ${envs}
- Remove Container ${CLIENT_CONTAINER_NAME}
- Sleep 5s
- Run Pmmapper Container ${DOCKER_CLIENT_IMAGE} ${CLIENT_CONTAINER_NAME} ${envs} ${DR_NODE_IP} ${NODE_IP}
- Sleep 15s
-
-SavePmMapperLogsAndDroppedCount
- [Arguments] ${test_name} ${dropped_count}
- Run Process echo "Dropped: ${dropped_count}" > %{WORKSPACE}/archives/${test_name}_dropped_count.log shell=yes
- Run Process docker logs ${CLIENT_CONTAINER_NAME} > %{WORKSPACE}/archives/${test_name}_pm_mapper_container_logs.log shell=yes
-
+++ /dev/null
-import docker
-from EnvsReader import EnvsReader
-from docker.types import Mount
-
-class DockerContainerManager:
-
- def run_pmmapper_container(self, client_image, container_name, path_to_env, dr_node_ip, mr_ip):
- client = docker.from_env()
- environment = EnvsReader().read_env_list_from_file(path_to_env)
- environment.append("CONFIG_BINDING_SERVICE_SERVICE_HOST=172.18.0.5")
- environment.append("CONFIG_BINDING_SERVICE_SERVICE_PORT=10000")
- environment.append("HOSTNAME=pmmapper")
- client.containers.run(
- image=client_image,
- name=container_name,
- environment=environment,
- ports={'8081': 8081},
- network='filesprocessingconfigpmmapper_pmmapper-network',
- extra_hosts={'dmaap-dr-node': dr_node_ip, 'message-router': mr_ip},
- user='root',
- mounts=[Mount(target='/opt/app/pm-mapper/etc/certs/', source='/var/tmp/', type='bind')],
- detach=True
- )
-
- def remove_container(self, container_name):
- client = docker.from_env()
- container = client.containers.get(container_name)
- container.stop()
- container.remove()
+++ /dev/null
-
-class EnvsReader:
-
- def read_env_list_from_file(self, path):
- f = open(path, "r")
- r_list = []
- for line in f:
- line = line.strip()
- if line[0] != "#":
- r_list.append(line)
- return r_list
+++ /dev/null
-import re
-
-class LogReader:
-
- def filter_unique(self, merged_logs_output, testname):
- logs = merged_logs_output.splitlines()
- del_logs = list(filter(lambda line: "|DEL|" in line, logs))
- nrs_set = set()
- ret_logs = set()
- for log in del_logs:
- filename = re.findall(testname + "\d", log)
- if len(filename) > 0 and filename[0] not in nrs_set:
- ret_logs.add(log)
- nrs_set.add(filename[0])
- return ret_logs
-
- def get_number_of_dropped_messages(self, logs_output):
- return len(list(filter(lambda line: "|429|" in line, logs_output)))
-
- def get_log_files_list(self, fileNames):
- files = fileNames.split()
- return files
+++ /dev/null
-*** Settings ***
-Documentation PM Mapper Testcases
+++ /dev/null
-*.gz binary
+++ /dev/null
-<?xml version="1.0" encoding="UTF-8"?>
-<?xml-stylesheet type="text/xsl" href="MeasDataCollection.xsl"?>
-<measCollecFile xmlns="http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec"
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-xsi:schemaLocation="http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec">
- <fileHeader fileFormatVersion="32.435 V7.0" vendorName="Company NN" dnPrefix="DC=a1.companyNN.com,SubNetwork=1,IRPAgent=1">
- <fileSender localDn="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1" elementType="RNC"/>
- <measCollec beginTime="2000-03-01T14:00:00+02:00"/>
- </fileHeader>
- <measData>
- <managedElement localDn="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1" userLabel="RNC Telecomville"/>
- <measInfo>
- <job jobId="1231"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures</measType>
- <measType p="2">succTCHSeizures</measType>
- <measType p="3">attImmediateAssignProcs</measType>
- <measType p="4">succImmediateAssignProcs</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">234</r>
- <r p="2">345</r>
- <r p="3">567</r>
- <r p="4">789</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">890</r>
- <r p="2">901</r>
- <r p="3">123</r>
- <r p="4">234</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">456</r>
- <r p="2">567</r>
- <r p="3">678</r>
- <r p="4">789</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- <measInfo measInfoId="ENodeBFunction">
- <job jobId="1232"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures1</measType>
- <measType p="2">succTCHSeizures2</measType>
- <measType p="3">attImmediateAssignProcs3</measType>
- <measType p="4">succImmediateAssignProcs4</measType>
- <measValue measObjLdn="ManagedElement=RNC-Gbg-1,ENodeBFunction=1">
- <r p="1">4</r>
- <r p="2">86,87,2,6,77,96,75,33,24</r>
- <r p="3">40</r>
- <r p="4">90</r>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- <measInfo>
- <job jobId="1233"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures5</measType>
- <measType p="2">succTCHSeizures6</measType>
- <measType p="3">attImmediateAssignProcs7</measType>
- <measType p="4">succImmediateAssignProcs8</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">238</r>
- <r p="2">344</r>
- <r p="3">563</r>
- <r p="4">787</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">898</r>
- <r p="2">905</r>
- <r p="3">127</r>
- <r p="4">238</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">454</r>
- <r p="2">569</r>
- <r p="3">672</r>
- <r p="4">785</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- </measData>
- <fileFooter>
- <measCollec endTime="2000-03-01T14:15:00+02:00"/>
- </fileFooter>
-</measCollecFile>
+++ /dev/null
-<?xml version="1.0" encoding="UTF-8"?>
-<measCollecFile xmlns="http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec">
- <fileHeader dnPrefix="some dnPrefix" vendorName="FooBar Ltd"
- fileFormatVersion="32.435 V10.0">
- <fileSender localDn="Dublin"/>
- <measCollec beginTime="2018-10-02T12:00:00+01:00"/>
- </fileHeader>
- <measData>
- <measInfo measInfoId="some measInfoId">
- <job jobId="some job Id"/>
- <granPeriod endTime="2018-10-02T12:15:00Z" duration="some duration"/>
- <repPeriod duration="PT900S"/>
- <measType p="1">a</measType>
- <measType p="2">b</measType>
- <measType p="3">c</measType>
- <measValue measObjLdn="some measObjLdn">
- <r p="1">86</r>
- <r p="2">67</r>
- <r p="3">14</r>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- </measData>
- <fileFooter>
- <measCollec endTime="2018-10-02T12:15:00+01:00"/>
- </fileFooter>
-</measCollecFile>
\ No newline at end of file
+++ /dev/null
-<?xml version="1.0" encoding="UTF-8"?>
-<measCollecFile xmlns="http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec">
- <fileHeader dnPrefix="some dnPrefix" vendorName="FooBar Ltd"
- fileFormatVersion="32.435 V10.0">
- <fileSender localDn="Dublin"/>
- <measCollec beginTime="2018-10-02T12:00:00+01:00"/>
- </fileHeader>
- <fileFooter>
- <measCollec endTime="2018-10-02T12:15:00+01:00"/>
- </fileFooter>
-</measCollecFile>
+++ /dev/null
-<measCollecFile xmlns="http://www.3gpp.org/ftp/specs/archive/32_series/32.435#measCollec">
- <fileHeader dnPrefix="some dnPrefix" vendorName="FooBar Ltd"
- fileFormatVersion="32.435 V10.0">
- <fileSender localDn="Dublin"/>
- <measCollec beginTime="2018-10-02T12:00:00+01:00"/>
- </fileHeader>
- <measData>
- <managedElement swVersion="r0.1" localDn="Dublin1"/>
- <measInfo measInfoId="measInfoId1">
- <job jobId="jobId1"/>
- <granPeriod endTime="2001-10-02T12:15:00Z" duration="PT100S"/>
- <repPeriod duration="PT100S"/>
- <measTypes>z1 a1 zz1 b1</measTypes>
- <measValue measObjLdn="objLdn">
- <measResults>1 11 111 1111</measResults>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- </measData>
- <measData>
- <managedElement swVersion="r0.2" localDn="Dublin2"/>
- <measInfo measInfoId="measInfoId2">
- <job jobId="jobId"/>
- <granPeriod endTime="2002-10-02T12:15:00Z" duration="PT200S"/>
- <repPeriod duration="PT200S"/>
- <measTypes>z2 a2 zz2 b2</measTypes>
- <measValue measObjLdn="objLdn">
- <measResults>2 22 222 2222</measResults>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- </measData>
- <measData>
- <managedElement swVersion="r0.3" localDn="Dublin3"/>
- <measInfo measInfoId="measInfoId3">
- <job jobId="jobId"/>
- <granPeriod endTime="2003-10-02T12:15:00Z" duration="PT300S"/>
- <repPeriod duration="PT300S"/>
- <measTypes>z3 a3 zz3 b3</measTypes>
- <measValue measObjLdn="objLdn">
- <measResults>3 33 333 3333</measResults>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- </measData>
- <fileFooter>
- <measCollec endTime="2018-10-02T12:15:00+01:00"/>
- </fileFooter>
-</measCollecFile>
+++ /dev/null
-{
- "productName": "gnb",
- "vendorName": "Anon",
- "lastEpochMicrosec": "1538478000000",
- "sourceName": "oteNB5309",
- "startEpochMicrosec": "1538478900000",
- "timeZoneOffset": "UTC+05.00",
- "location": "ftpes://192.168.0.101:22/ftp/rop/A20161224.1045-1100.bin.gz",
- "compression": "gzip",
- "fileFormatType": "org.3GPP.32.435#measCollec",
- "fileFormatVersion": "V9"
- }
\ No newline at end of file
+++ /dev/null
-<?xml version="1.0" encoding="UTF-8"?>
-<?xml-stylesheet type="text/xsl" href="MeasDataCollection.xsl"?>
-<measDataFile xmlns="http://www.3gpp.org/ftp/specs/archive/28_series/28.532#measData"
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-xsi:schemaLocation="http://www.3gpp.org/ftp/specs/archive/28_series/28.532#measData http://www.3gpp.org/ftp/specs/archive/28_series/28.532#measData">
- <fileHeader fileFormatVersion="28.532 V7.0" vendorName="Company NN" dnPrefix="DC=a1.companyNN.com,SubNetwork=1,IRPAgent=1">
- <fileSender senderName="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1"/>
- <measData beginTime="2000-03-01T14:00:00+02:00"/>
- </fileHeader>
- <measData>
- <measEntity localDn="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1" userLabel="RNC Telecomville"/>
- <measInfo>
- <job jobId="1231"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures</measType>
- <measType p="2">succTCHSeizures</measType>
- <measType p="3">attImmediateAssignProcs</measType>
- <measType p="4">succImmediateAssignProcs</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">234</r>
- <r p="2">345</r>
- <r p="3">567</r>
- <r p="4">789</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">890</r>
- <r p="2">901</r>
- <r p="3">123</r>
- <r p="4">234</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">456</r>
- <r p="2">567</r>
- <r p="3">678</r>
- <r p="4">789</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- <measInfo measInfoId="ENodeBFunction">
- <job jobId="1232"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures1</measType>
- <measType p="2">succTCHSeizures2</measType>
- <measType p="3">attImmediateAssignProcs3</measType>
- <measType p="4">succImmediateAssignProcs4</measType>
- <measValue measObjLdn="ManagedElement=RNC-Gbg-1,ENodeBFunction=1">
- <r p="1">4</r>
- <r p="2">86,87,2,6,77,96,75,33,24</r>
- <r p="3">40</r>
- <r p="4">90</r>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- <measInfo>
- <job jobId="1233"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures5</measType>
- <measType p="2">succTCHSeizures6</measType>
- <measType p="3">attImmediateAssignProcs7</measType>
- <measType p="4">succImmediateAssignProcs8</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">238</r>
- <r p="2">344</r>
- <r p="3">563</r>
- <r p="4">787</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">898</r>
- <r p="2">905</r>
- <r p="3">127</r>
- <r p="4">238</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">454</r>
- <r p="2">569</r>
- <r p="3">672</r>
- <r p="4">785</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- </measData>
- <fileFooter>
- <measData endTime="2000-03-01T14:15:00+02:00"/>
- </fileFooter>
-</measDataFile>
+++ /dev/null
-<measDataFile xmlns="http://www.3gpp.org/ftp/specs/archive/28_series/28.532#measData">
- <fileHeader dnPrefix="some dnPrefix" vendorName="FooBar Ltd"
- fileFormatVersion="28.532 V1.0">
- <fileSender senderName="Dublin"/>
- <measData beginTime="2018-10-02T12:00:00+01:00"/>
- </fileHeader>
- <measData>
- <measEntity swVersion="r0.1" localDn="Dublin1"/>
- <measInfo measInfoId="measInfoId1">
- <job jobId="jobId1"/>
- <granPeriod endTime="2001-10-02T12:15:00Z" duration="PT100S"/>
- <repPeriod duration="PT100S"/>
- <measTypes>z1 a1 zz1 b1</measTypes>
- <measValue measObjLdn="objLdn">
- <measResults>1 11 111 1111</measResults>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- </measData>
- <measData>
- <measEntity swVersion="r0.2" localDn="Dublin2"/>
- <measInfo measInfoId="measInfoId2">
- <job jobId="jobId"/>
- <granPeriod endTime="2002-10-02T12:15:00Z" duration="PT200S"/>
- <repPeriod duration="PT200S"/>
- <measTypes>attTCHSeizures succTCHSeizures2 zz2 b2</measTypes>
- <measValue measObjLdn="objLdn">
- <measResults>2 22 222 2222</measResults>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- </measData>
- <measData>
- <measEntity swVersion="r0.3" localDn="Dublin3"/>
- <measInfo measInfoId="measInfoId3">
- <job jobId="jobId"/>
- <granPeriod endTime="2003-10-02T12:15:00Z" duration="PT300S"/>
- <repPeriod duration="PT300S"/>
- <measTypes>z3 a3 zz3 succImmediateAssignProcs8</measTypes>
- <measValue measObjLdn="objLdn">
- <measResults>3 33 333 3333</measResults>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- </measData>
- <fileFooter>
- <measData endTime="2018-10-02T12:15:00+01:00"/>
- </fileFooter>
-</measDataFile>
+++ /dev/null
-<?xml version="1.0" encoding="UTF-8"?>
-<?xml-stylesheet type="text/xsl" href="MeasDataCollection.xsl"?>
-<measDataFile xmlns="http://www.3gpp.org/ftp/specs/archive/28_series/28.532#measData"
-xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-xsi:schemaLocation="http://www.3gpp.org/ftp/specs/archive/28_series/28.532#measData http://www.3gpp.org/ftp/specs/archive/28_series/28.532#measData">
- <fileHeader fileFormatVersion="28.532 V7.0" vendorName="Company NN" dnPrefix="DC=a1.companyNN.com,SubNetwork=1,IRPAgent=1">
- <fileSender senderName="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1"/>
- <measData beginTime="2000-03-01T14:00:00+02:00"/>
- </fileHeader>
- <measData>
- <measEntity localDn="SubNetwork=CountryNN,MeContext=MEC-Gbg-1,ManagedElement=RNC-Gbg-1" userLabel="RNC Telecomville"/>
- <measInfo>
- <job jobId="1231"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures</measType>
- <measType p="2">succTCHSeizures</measType>
- <measType p="3">attImmediateAssignProcs</measType>
- <measType p="4">succImmediateAssignProcs</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">234</r>
- <r p="2">345</r>
- <r p="3">567</r>
- <r p="4">789</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">890</r>
- <r p="2">901</r>
- <r p="3">123</r>
- <r p="4">234</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">456</r>
- <r p="2">567</r>
- <r p="3">678</r>
- <r p="4">789</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- <measInfo measInfoId="ENodeBFunction">
- <job jobId="1232"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures1</measType>
- <measType p="2">succTCHSeizures2</measType>
- <measType p="3">attImmediateAssignProcs3</measType>
- <measType p="4">succImmediateAssignProcs4</measType>
- <measValue measObjLdn="ManagedElement=RNC-Gbg-1,ENodeBFunction=1">
- <r p="1">4</r>
- <r p="2">86,87,2,6,77,96,75,33,24</r>
- <r p="3">40</r>
- <r p="4">90</r>
- <suspect>false</suspect>
- </measValue>
- </measInfo>
- <measInfo>
- <job jobId="1233"/>
- <granPeriod duration="PT900S" endTime="2000-03-01T14:14:30+02:00"/>
- <repPeriod duration="PT1800S"/>
- <measType p="1">attTCHSeizures5</measType>
- <measType p="2">succTCHSeizures6</measType>
- <measType p="3">attImmediateAssignProcs7</measType>
- <measType p="4">succImmediateAssignProcs8</measType>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-997">
- <r p="1">238</r>
- <r p="2">344</r>
- <r p="3">563</r>
- <r p="4">787</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-998">
- <r p="1">898</r>
- <r p="2">905</r>
- <r p="3">127</r>
- <r p="4">238</r>
- </measValue>
- <measValue measObjLdn="RncFunction=RF-1,UtranCell=Gbg-999">
- <r p="1">454</r>
- <r p="2">569</r>
- <r p="3">672</r>
- <r p="4">785</r>
- <suspect>true</suspect>
- </measValue>
- </measInfo>
- </measData>
- <fileFooter>
- <measData endTime="2000-03-01T14:15:00+02:00"/>
- </fileFooter>
-</measDataFile>
+++ /dev/null
-{
- "productName": "gnb",
- "vendorName": "Ericsson",
- "lastEpochMicrosec": "1538478000000",
- "sourceName": "oteNB5309",
- "startEpochMicrosec": "1538478900000",
- "timeZoneOffset": "UTC+05.00",
- "location": "ftpes://192.168.0.101:22/ftp/rop/A20161224.1045-1100.bin.gz",
- "compression": "gzip",
- "fileFormatType": "org.3GPP.28.532#measData",
- "fileFormatVersion": "V9"
-}
+++ /dev/null
-{
- "pm-mapper-filter": {
- "filters":[{
- "pmDefVsn": "1.0",
- "nfType": "gnb",
- "vendor": "Ericsson",
- "measTypes": ["attTCHSeizures","succTCHSeizures2","succImmediateAssignProcs8"]
- }]
- },
- "key_store_path": "/opt/app/pm-mapper/etc/cert.jks",
- "key_store_pass_path": "/opt/app/pm-mapper/etc/jks.pass",
- "trust_store_path": "/opt/app/pm-mapper/etc/trust.jks",
- "trust_store_pass_path": "/opt/app/pm-mapper/etc/trust.pass",
- "dmaap_dr_delete_endpoint": "https://dmaap-dr-node:8443/delete",
- "dmaap_dr_feed_name": "1",
- "aaf_identity": "aaf_admin@people.osaaf.org",
- "aaf_password": "demo123456!",
- "enable_http": true,
- "streams_publishes": {
- "dmaap_publisher": {
- "type": "message_router",
- "dmaap_info": {
- "topic_url": "http://message-router:3904/events/org.onap.dmaap.mr.VES_PM",
- "client_role": "org.onap.dcae.pmPublisher",
- "location": "csit-pmmapper",
- "client_id": "1562763644939"
- }
- }
- },
- "streams_subscribes": {
- "dmaap_subscriber": {
- "type": "data_router",
- "dmaap_info": {
- "username": "username",
- "password": "password",
- "location": "csit-pmmapper",
- "delivery_url": "http://dcae-pm-mapper:8081/delivery",
- "subscriber_id": 1
- }
- }
- }
-}
\ No newline at end of file
+++ /dev/null
-{
- "pm-mapper-filter": {
- "filters":[{
- "pmDefVsn": "1.0",
- "nfType": "gnb",
- "vendor": "Ericsson",
- "measTypes": ["att.*"]
- }]
- },
- "key_store_path": "/opt/app/pm-mapper/etc/cert.jks.b64",
- "key_store_pass_path": "/opt/app/pm-mapper/etc/jks.pass",
- "trust_store_path": "/opt/app/pm-mapper/etc/trust.jks.b64",
- "trust_store_pass_path": "/opt/app/pm-mapper/etc/trust.pass",
- "dmaap_dr_delete_endpoint": "https://dmaap-dr-node:8443/delete",
- "dmaap_dr_feed_name": "1",
- "aaf_identity": "aaf_admin@people.osaaf.org",
- "aaf_password": "demo123456!",
- "enable_http": true,
- "streams_publishes": {
- "dmaap_publisher": {
- "type": "message_router",
- "dmaap_info": {
- "topic_url": "http://message-router:3904/events/org.onap.dmaap.mr.VES_PM",
- "client_role": "org.onap.dcae.pmPublisher",
- "location": "csit-pmmapper",
- "client_id": "1562763644939"
- }
- }
- },
- "streams_subscribes": {
- "dmaap_subscriber": {
- "type": "data_router",
- "dmaap_info": {
- "username": "username",
- "password": "password",
- "location": "csit-pmmapper",
- "delivery_url": "http://dcae-pm-mapper:8081/delivery",
- "subscriber_id": 1
- }
- }
- }
-}
\ No newline at end of file
+++ /dev/null
-{
- "productName": "gnb",
- "vendorName": "Ericsson",
- "lastEpochMicrosec": "1538478000000",
- "sourceName": "oteNB5309",
- "startEpochMicrosec": "1538478900000",
- "timeZoneOffset": "UTC+05.00",
- "location": "ftpes://192.168.0.101:22/ftp/rop/A20161224.1045-1100.bin.gz",
- "compression": "gzip",
- "fileFormatType": "org.3GPP.32.435#measCollec",
- "fileFormatVersion": "V9"
- }
\ No newline at end of file
+++ /dev/null
-{
- "pm-mapper-filter": {
- "filters":[{
- "pmDefVsn": "1.0",
- "nfType": "gnb",
- "vendor": "Ericsson",
- "measTypes": []
- }]
- },
- "key_store_path": "/opt/app/pm-mapper/etc/cert.jks",
- "key_store_pass_path": "/opt/app/pm-mapper/etc/jks.pass",
- "trust_store_path": "/opt/app/pm-mapper/etc/trust.jks",
- "trust_store_pass_path": "/opt/app/pm-mapper/etc/trust.pass",
- "dmaap_dr_delete_endpoint": "https://dmaap-dr-node:8443/delete",
- "dmaap_dr_feed_name": "1",
- "aaf_identity": "aaf_admin@people.osaaf.org",
- "aaf_password": "demo123456!",
- "enable_http": true,
- "streams_publishes": {
- "dmaap_publisher": {
- "type": "message_router",
- "dmaap_info": {
- "topic_url": "http://message-router:3904/events/org.onap.dmaap.mr.VES_PM",
- "client_role": "org.onap.dcae.pmPublisher",
- "location": "csit-pmmapper",
- "client_id": "1562763644939"
- }
- }
- },
- "streams_subscribes": {
- "dmaap_subscriber": {
- "type": "data_router",
- "dmaap_info": {
- "username": "username",
- "password": "password",
- "location": "csit-pmmapper",
- "delivery_url": "http://dcae-pm-mapper:8081/delivery",
- "subscriber_id": 1
- }
- }
- }
-}
\ No newline at end of file
+++ /dev/null
-*** Settings ***
-Documentation Testing PM Mapper functionality
-Library Collections
-Library OperatingSystem
-Library RequestsLibrary
-Library Process
-Library String
-
-Test Setup Create Session mapper_session ${PMMAPPER_BASE_URL}
-Test Teardown CleanSessionsAndLogs
-
-*** Variables ***
-${CLI_EXEC_CLI_CONFIG} { head -n 100 | tail -50;} < /tmp/pmmapper.log
-${CLI_EXEC_CLI_SUBS} curl -k https://${DR_PROV_IP}:8443/internal/prov
-${PMMAPPER_BASE_URL} http://${PMMAPPER_IP}:8081
-${DELIVERY_ENDPOINT} /delivery
-${HEALTHCHECK_ENDPOINT} /healthcheck
-${RECONFIGURE_ENDPOINT} /reconfigure
-${NO_MANAGED_ELEMENT_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/A_no_managed_element.xml
-${NO_MEASDATA_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/A_no_measdata.xml
-${VALID_METADATA_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/valid_metadata.json
-${NR_VALID_METADATA_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/new_radio/valid_metadata.json
-${DIFF_VENDOR_METADATA} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/diff_vendor_metadata.json
-${NON_XML_FILE} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/diff_vendor_metadata.json
-${CLI_EXEC_CLI_PM_LOG} docker exec pmmapper /bin/sh -c "cat /var/log/ONAP/dcaegen2/services/pm-mapper/pm-mapper_output.log"
-${CLI_EXEC_CLI_PM_LOG_CLEAR} docker exec pmmapper /bin/sh -c "echo -n "" > /var/log/ONAP/dcaegen2/services/pm-mapper/pm-mapper_output.log"
-${PUBLISH_NODE_URL} https://${DR_NODE_IP}:8443/publish/1
-${TYPE-A_PM_DATA_FILE_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/A20181002.0000-1000-0015-1000_5G.xml
-${TYPE-C_PM_DATA_FILE_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/C20190328.0000-0015.xml
-${NR-TYPE-A_PM_DATA_FILE_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/new_radio/A20181004.0000-1000-0015-1000_5G.xml
-${NR-TYPE-C_PM_DATA_FILE_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/new_radio/C20190329.0000-0015.xml
-${NR-TYPE-PM_DATA_FILE_PATH} %{WORKSPACE}/tests/dcaegen2-pmmapper/pmmapper/assets/new_radio/PM202007171301+020024C202007171207+0200-1215+0200_45678.xml
-${CLI_EXEC_VENDOR_FILTER} curl 'http://${CONSUL_IP}:8500/v1/kv/pmmapper?dc=dc1' -X PUT -H 'Accept: application/^Con' -H 'Content-Type: application/json' -H 'X-Requested-With: XMLHttpRequest' --data @$WORKSPACE/tests/dcaegen2-pmmapper/pmmapper/assets/vendor_filter_config.json
-${CLI_EXEC_PM_FILTER} curl 'http://${CONSUL_IP}:8500/v1/kv/pmmapper?dc=dc1' -X PUT -H 'Accept: application/^Con' -H 'Content-Type: application/json' -H 'X-Requested-With: XMLHttpRequest' --data @$WORKSPACE/tests/dcaegen2-pmmapper/pmmapper/assets/pm_filter_config.json
-${CLI_EXEC_PM_FILTER_regex} curl 'http://${CONSUL_IP}:8500/v1/kv/pmmapper?dc=dc1' -X PUT -H 'Accept: application/^Con' -H 'Content-Type: application/json' -H 'X-Requested-With: XMLHttpRequest' --data @$WORKSPACE/tests/dcaegen2-pmmapper/pmmapper/assets/pm_filter_regex_config.json
-${CLI_MESSAGE_ROUTER_TOPIC} curl http://${DMAAP_MR_IP}:3904/events/PM_MAPPER/CG1/C1?timeout=1000 > /tmp/mr.log
-${CLI_MR_LOG} cat /tmp/mr.log
-
-
-*** Test Cases ***
-Verify PM Mapper Receive Configuraton From Config Binding Service
- [Tags] PM_MAPPER_01
- [Documentation] Verify 3gpp pm mapper successfully receive config data from CBS
- CheckLog ${CLI_EXEC_CLI_CONFIG} Received pm-mapper configuration from ConfigBinding Service
-
-Verify Health Check returns 200 when a REST GET request to healthcheck url
- [Tags] PM_MAPPER_02
- [Documentation] Verify Health Check returns 200 when a REST GET request to healthcheck url
- [Timeout] 1 minute
- ${resp}= Get Request mapper_session ${HEALTHCHECK_ENDPOINT}
- VerifyResponse ${resp.status_code} 200
-
-Verify 3GPP PM Mapper responds appropriately when no metadata is provided
- [Tags] PM_MAPPER_03
- [Documentation] Verify 3GPP PM Mapper responds 400 with the message "Missing Metadata." when no metadata is provided
- [Timeout] 1 minute
- ${headers}= Create Dictionary X-ONAP-RequestID=3 Content-Type=application/xml
- ${resp}= Put Request mapper_session ${DELIVERY_ENDPOINT}/filename data='${EMPTY}' headers=${headers}
- VerifyResponse ${resp.status_code} 400
- VerifyResponse ${resp.content} Missing Metadata.
- CheckLog ${CLI_EXEC_CLI_PM_LOG} RequestID=3
-
-Verify 3GPP PM Mapper responds appropriately when invalid metadata is provided
- [Tags] PM_MAPPER_04
- [Documentation] Verify 3GPP PM Mapper responds 400 with the message "Malformed Metadata." when invalid metadata is provided
- [Timeout] 1 minute
- ${headers}= Create Dictionary X-ONAP-RequestID=4 X-DMAAP-DR-META='not metadata' Content-Type=application/xml
- ${resp}= Put Request mapper_session ${DELIVERY_ENDPOINT}/filename data='${EMPTY}' headers=${headers}
- VerifyResponse ${resp.status_code} 400
- VerifyResponse ${resp.content} Malformed Metadata.
- CheckLog ${CLI_EXEC_CLI_PM_LOG} RequestID=4
-
-Verify that PM Mapper logs successful when a file that contains no measdata is provided
- [Tags] PM_MAPPER_05
- [Documentation] Verify that PM Mapper logs successful when a file that contains no measdata is provided
- [Timeout] 1 minute
- SendToDatarouter ${NO_MEASDATA_PATH} ${VALID_METADATA_PATH} X-ONAP-RequestID=5
- CheckLog ${CLI_EXEC_CLI_PM_LOG} MeasData is empty
- CheckLog ${CLI_EXEC_CLI_PM_LOG} RequestID=5
-
-Verify that PM Mapper throws Event failed validation against schema error when no managed element content is provided
- [Tags] PM_MAPPER_06
- [Documentation] Verify 3gpp pm mapper responds with an error when no managed element content is provided
- [Timeout] 1 minute
- SendToDatarouter ${NO_MANAGED_ELEMENT_PATH} ${VALID_METADATA_PATH} X-ONAP-RequestID=6
- CheckLog ${CLI_EXEC_CLI_PM_LOG} XML validation failed
- CheckLog ${CLI_EXEC_CLI_PM_LOG} RequestID=6
-
-Verify that PM Mapper maps Type-C xml file and publish 3gpp perf VES evnets to message router
- [Tags] PM_MAPPER_07
- [Documentation] Verify that PM Mapper maps Type-C xml file and publish 3gpp perf VES evnets to message router.
- [Timeout] 1 minute
- SendToDatarouter ${TYPE-C_PM_DATA_FILE_PATH} ${VALID_METADATA_PATH} X-ONAP-RequestID=7
- CheckLog ${CLI_EXEC_CLI_PM_LOG} Successfully published VES events to messagerouter
-
-Verify 3GPP PM Mapper maps Type-A file based on counter filtering and publish 3gpp perf VES evnets to message router
- [Tags] PM_MAPPER_08
- [Documentation] Verify 3GPP PM Mapper maps Type-A file and publish 3gpp perf VES evnets to message router.
- [Timeout] 1 minute
- ${cli_cmd_output}= Run Process ${CLI_EXEC_PM_FILTER} shell=yes
- ${resp}= Get Request mapper_session ${RECONFIGURE_ENDPOINT}
- Sleep 5s
- SendToDatarouter ${TYPE-A_PM_DATA_FILE_PATH} ${VALID_METADATA_PATH} X-ONAP-RequestID=8
- CheckLog ${CLI_EXEC_CLI_PM_LOG} Successfully published VES events to messagerouter
-
-Verify that PM Mapper correctly identifies a file that should not be mapped based on metadata filtering.
- [Tags] PM_MAPPER_09
- [Documentation] Verify that PM Mapper correctly identifies a file that should not be mapped based on metadata filtering.
- [Timeout] 1 minute
- ${cli_cmd_output}= Run Process ${CLI_EXEC_VENDOR_FILTER} shell=yes
- Should Be Equal As Strings ${cli_cmd_output.rc} 0
- ${resp}= Get Request mapper_session ${RECONFIGURE_ENDPOINT}
- Sleep 5s
- SendToDatarouter ${TYPE-A_PM_DATA_FILE_PATH} ${DIFF_VENDOR_METADATA} X-ONAP-RequestID=9
- CheckLog ${CLI_EXEC_CLI_PM_LOG} RequestID=9
- CheckLog ${CLI_EXEC_CLI_PM_LOG} Metadata does not match any filters
-
-Verify that PM Mapper correctly identifies a non-xml file.
- [Tags] PM_MAPPER_10
- [Documentation] Verify that PM Mapper correctly identifies a non-xml file.
- [Timeout] 1 minute
- SendToDatarouter ${NON_XML_FILE} ${VALID_METADATA_PATH} X-ONAP-RequestID=10
- CheckLog ${CLI_EXEC_CLI_PM_LOG} PM measurement file must have an extension of .xml
- CheckLog ${CLI_EXEC_CLI_PM_LOG} RequestID=10
-
-Verify that PM Mapper correctly maps an NR Type-A file based on counter filtering and publish 3gpp perf VES events to message router.
- [Tags] PM_MAPPER_11
- [Documentation] Verify 3GPP PM Mapper maps an NR Type-A file and publish 3gpp perf VES evnets to message router.
- [Timeout] 1 minute
- ${cli_cmd_output}= Run Process ${CLI_EXEC_PM_FILTER} shell=yes
- ${resp}= Get Request mapper_session ${RECONFIGURE_ENDPOINT}
- Sleep 5s
- SendToDatarouter ${NR-TYPE-A_PM_DATA_FILE_PATH} ${NR_VALID_METADATA_PATH} X-ONAP-RequestID=11
- CheckLog ${CLI_EXEC_CLI_PM_LOG} Successfully published VES events to messagerouter
-
-Verify that PM Mapper correctly maps an NR Type-C file based on counter filtering and publish 3gpp perf VES events to message router.
- [Tags] PM_MAPPER_12
- [Documentation] Verify that PM Mapper maps an NR Type-C xml file and publish 3gpp perf VES evnets to message router.
- [Timeout] 1 minute
- SendToDatarouter ${NR-TYPE-C_PM_DATA_FILE_PATH} ${NR_VALID_METADATA_PATH} X-ONAP-RequestID=12
- CheckLog ${CLI_EXEC_CLI_PM_LOG} Successfully published VES events to messagerouter
-
-Verify 3GPP PM Mapper maps Type-A file based on counter filtering with regexp
- [Tags] PM_MAPPER_13
- [Documentation] Verify 3GPP PM Mapper maps Type-A file based on counter filtering with wildcards/regexp and publish 3gpp perf VES evnets to message router.
- [Timeout] 1 minute
- ${cli_cmd_output}= Run Process ${CLI_EXEC_PM_FILTER_regex} shell=yes
- ${resp}= Get Request mapper_session ${RECONFIGURE_ENDPOINT}
- Sleep 5s
- SendToDatarouter ${TYPE-A_PM_DATA_FILE_PATH} ${VALID_METADATA_PATH} X-ONAP-RequestID=13
- CheckLog ${CLI_EXEC_CLI_PM_LOG} Successfully published VES events to messagerouter
-
-Verify that password receive from CBS are successfully encrypted
- [Tags] PM_MAPPER_14
- [Documentation] Verify that password receive from CBS are successfully encrypted.
- CheckLog ${CLI_EXEC_CLI_CONFIG} "aaf_password": *****
- CheckLog ${CLI_EXEC_CLI_CONFIG} "password": *****
-
-Verify that PM Mapper correctly maps an NR Type-PM file based on counter filtering and publish 3gpp perf VES events to message router.
- [Tags] PM_MAPPER_15
- [Documentation] Verify that PM Mapper maps an NR Type-PM xml file and publish 3gpp perf VES evnets to message router.
- [Timeout] 1 minute
- SendToDatarouter ${NR-TYPE-PM_DATA_FILE_PATH} ${NR_VALID_METADATA_PATH} X-ONAP-RequestID=15
- CheckLog ${CLI_EXEC_CLI_PM_LOG} RequestID=15
- CheckLog ${CLI_EXEC_CLI_PM_LOG} Successfully published VES events to messagerouter
-
-*** Keywords ***
-
-SendToDatarouter
- [Arguments] ${filepath} ${metadatapath} ${request_id}
- ${pmdata}= Get File ${filepath}
- ${metatdata} Get File ${metadatapath}
- ${filename} Fetch From Right ${filepath} /
- ${resp}= PutCall ${PUBLISH_NODE_URL}/${filename} ${request_id} ${pmdata} ${metatdata.replace("\n","")} pmmapper
- VerifyResponse ${resp.status_code} 204
- Sleep 10s
-
-PutCall
- [Arguments] ${url} ${request_id} ${data} ${meta} ${user}
- ${headers}= Create Dictionary X-ONAP-RequestID=${request_id} X-DMAAP-DR-META=${meta} Content-Type=application/octet-stream X-DMAAP-DR-ON-BEHALF-OF=${user} Authorization=Basic cG1tYXBwZXI6cG1tYXBwZXI=
- ${resp}= Evaluate requests.put('${url}', data="""${data}""", headers=${headers}, verify=False, allow_redirects=False) requests
- [Return] ${resp}
-
-CheckLog
- [Arguments] ${cli_exec_log_Path} ${string_to_check_in_log}
- ${cli_cmd_output}= Run Process ${cli_exec_log_Path} shell=yes
- Log ${cli_cmd_output.stdout}
- Should Be Equal As Strings ${cli_cmd_output.rc} 0
- Should Contain ${cli_cmd_output.stdout} ${string_to_check_in_log}
-
-VerifyResponse
- [Arguments] ${actual_response_value} ${expected_response_value}
- Should Be Equal As Strings ${actual_response_value} ${expected_response_value}
-
-ClearLogs
- Run Process ${CLI_EXEC_CLI_PM_LOG_CLEAR} shell=yes
-
-CleanSessionsAndLogs
- Delete All Sessions
- ClearLogs
Code Review / integration / csit.git / commitdiff