Robotframework python files to be used in tests.
At this moment it tests nothing
Issue-ID: INT-510
Change-Id: Icbd6a6ffcbdb28755b26cad3a2b8c6d163f77c38
Signed-off-by: Mariusz Wagner <mariusz.wagner@nokia.com>
--- /dev/null
+{"event":
+ {"correlationID":"NOKQTFCOC540002E",
+ "pnfOamIpv4Address":"10.16.123.234",
+ "pnfOamIpv6Address":"2001:0db8:85a3:0000:0000:8a2e:0370:7334"
+ }
+}
--- /dev/null
+{"event":
+ {"commonEventHeader":
+ {"sourceId":"QTFCOC540002E",
+ "startEpochMicrosec":1519837825682,
+ "eventId":"QTFCOC540002E-reg",
+ "nfcNamingCode":"5DU",
+ "internalHeaderFields":{"collectorTimeStamp":"Fri, 04 27 2018 09:01:10 GMT"},
+ "eventType":"pnfRegistration",
+ "priority":"Normal",
+ "version":3,
+ "reportingEntityName":"5GRAN_DU",
+ "sequence":0,
+ "domain":"other",
+ "lastEpochMicrosec":1519837825682,
+ "eventName":"pnfRegistration_5GDU",
+ "sourceName":"5GRAN_DU",
+ "nfNamingCode":"5GRAN"
+ },
+ "otherFields":
+ {"pnfLastServiceDate":1517206400,
+ "pnfOamIpv6Address":"2001:0db8:85a3:0000:0000:8a2e:0370:7334",
+ "pnfVendorName":"Nokia",
+ "pnfModelNumber":"AJ02",
+ "pnfFamily":"BBU",
+ "pnfType":"AirScale",
+ "otherFieldsVersion":1,
+ "pnfOamIpv4Address":"10.16.123.234",
+ "pnfSoftwareVersion":"v4.5.0.1",
+ "pnfSerialNumber":"QTFCOC540002E",
+ "pnfManufactureDate":1516406400
+ }
+ }
+}
--- /dev/null
+*** Settings ***
+Documentation Testing PRH with various use scenarios
+Suite Setup PRH Suite Setup
+Suite Teardown PRH Suite Shutdown
+Library Collections
+Library resources/PrhLibrary.py
+Resource resources/prh_keywords.robot
+
+*** Variables ***
+${DMaaP_URL} http://localhost:3904
+${AAI_URL} http://localhost:3905
+${PNF_READY} %{WORKSPACE}/test/csit/tests/dcaegen2/prh_testcases/assets/json_events/pnf_ready.json
+
+*** Test Cases ***
+New test
+ [Documentation] First positive TC
+ [Tags] PRH
+ #First TC will be added after initial commit
+ Should Be True True
--- /dev/null
+'''
+Created on Apr 27, 2018
+
+@author: mwagner9
+'''
+
+import threading
+import time
+
+from robot.api import logger
+
+import PrhVariables
+import Simulator
+
+st = '{"event":{"correlationID":"NOKQTFCOC540002E", "pnfOamIpv4Address":"10.16.123.234", "pnfOamIpv6Address":"2001:0db8:85a3:0000:0000:8a2e:0370:7334"}}'
+
+class PrhLibrary(object):
+ def __init__(self):
+ pass
+
+ def setup_dmaap_server(self):
+ return _setup(PrhVariables.DMaaPHttpServerThread, 'DMaaP', PrhVariables.DMaaPIsRobotRun, Simulator, 3904)
+
+ def setup_aai_server(self):
+ return _setup(PrhVariables.AAIHttpServerThread, 'AAI', PrhVariables.AAIIsRobotRun, Simulator, 3905)
+
+ def shutdown_dmaap_server(self):
+ return _shutdown(PrhVariables.DMaaPHTTPD, 'DMaaP')
+
+ def shutdown_aai_server(self):
+ return _shutdown(PrhVariables.AAIHTTPD, 'AAI')
+
+ def is_json_empty(self, response):
+ logger.info("Enter is_json_empty: response.text: " + response.text)
+ if response.text is None or len(response.text) < 2:
+ return 'True'
+ return 'False'
+
+ def dmaap_collectorTimeStamp_receive(self, search, response):
+ return _find_element(search, response)
+
+ def AAI_Ipv4_receive(self, search, response):
+ return _find_element(search, response)
+
+ def AAI_Ipv6_receive(self, search, response):
+ return _find_element(search, response)
+
+ def check_pnf_ready(self):
+ if st in Simulator.prh_ready:
+ return 'true'
+ return 'false'
+
+def _setup(serverthread, servername, isrobotrun, module, portNum):
+ if serverthread is not None:
+ logger.console('{} Mockup Sever started'.format(servername))
+ return "true"
+
+ isrobotrun = True
+
+ module_handler = module.AAIHandler if servername is 'AAI' else module.DMaaPHandler
+
+ module.run_server(module_handler, portNum)
+ try:
+ serverthread = threading.Thread(name='{}_HTTPServer'.format(servername), target=module.Httpd.serve_forever)
+ serverthread.start()
+ logger.console('{} Mockup Sever started'.format(servername))
+ time.sleep(2)
+ return "true"
+ except Exception as e:
+ print (str(e))
+ return "false"
+
+def _shutdown(server, name):
+ if server is not None:
+ server.shutdown()
+ logger.console("{} Server shut down".format(name))
+ time.sleep(3)
+ return "true"
+ else:
+ return "false"
+
+def _find_element(search, response):
+ while response is not None:
+ json_data = str(response)
+ if search in json_data:
+ return 'true'
+ return 'false'
+
+if __name__ == '__main__':
+ lib = PrhLibrary()
+ ret = lib.setup_dmaap_server()
+ print ret
+ ret = lib.setup_aai_server()
+ print ret
+ time.sleep(10)
--- /dev/null
+'''
+Created on Apr 27, 2018
+
+@author: mwagner9
+'''
+
+import os
+
+def GetEnvironmentVariable(envVarstr):
+ return os.environ.get(envVarstr)
+
+DMaaPHttpServerThread = None
+DMaaPHTTPD = None
+DMaaPIsRobotRun = False
+
+AAIHttpServerThread = None
+AAIHTTPD = None
+AAIIsRobotRun = False
--- /dev/null
+'''
+Created on May 10, 2018
+
+@author: mwagner9
+'''
+
+import BaseHTTPServer
+import re
+import sys
+
+from robot.api import logger
+
+import PrhVariables
+
+Httpd = None
+prh_ready = ''
+
+class BaseHandler(BaseHTTPServer.BaseHTTPRequestHandler, object):
+ def do_GET(self, param1, param2):
+ """Serve a GET request."""
+ #prepare GET response
+ logger.console(self.raw_requestlinel)
+ json_string = param1
+ if re.search(param2, self.path) is not None:
+ self.send_response(200)
+ self.send_header("Content-type", "application/json")
+ self.end_headers()
+ self.wfile.write(json_string)
+
+class AAIHandler(BaseHandler):
+ def do_PATCH(self):
+ #prepare PATCH response
+ logger.console('========')
+ logger.console(self.raw_requestline)
+ logger.console('========')
+ if re.search('/aai/v12/network/pnfs/pnf/NOKQTFCOC540002E', self.path)is not None:
+ st = '{"ipaddress-v6-oam": "2001:0db8:85a3:0000:0000:8a2e:0370:7334","ipaddress-v4-oam": "11.22.33.156"}'
+ logger.console('========')
+ logger.console(self.raw_requestline)
+ logger.console('========')
+ self.send_response(200)
+
+ def do_GET(self):
+ param1 = '{"pnf-name":"NOKQTFCOC540002E", "pnf-id":"NOKQTFCOC540002E","ipaddress-v4-oam":"10.16.123.234","ipaddress-v6-oam":"2001:0db8:85a3:0000:0000:8a2e:0370:7334"}'
+ param2 = '/aai/v12/network/pnfs/pnf/NOKQTFCOC540002E'
+ super(self.__class__, self).do_GET(param1, param2)
+
+class DMaaPHandler(BaseHandler):
+ def do_GET(self):
+ param1 = '{"event": {"commonEventHeader": {"sourceId":"QTFCOC540002E", "startEpochMicrosec":1519837825682, "eventId":"QTFCOC540002E-reg", "nfcNamingCode":"5DU", "internalHeaderFields":{"collectorTimeStamp":"Fri, 04 27 2018 09:01:10 GMT"}, "eventType":"pnfRegistration", "priority":"Normal", "version":3, "reportingEntityName":"5GRAN_DU", "sequence":0, "domain":"other", "lastEpochMicrosec":1519837825682, "eventName":"pnfRegistration_5GDU", "sourceName":"5GRAN_DU", "nfNamingCode":"5GRAN"}, "otherFields": {"pnfLastServiceDate":1517206400, "pnfOamIpv6Address":"2001:0db8:85a3:0000:0000:8a2e:0370:7334", "pnfVendorName":"Nokia", "pnfModelNumber":"AJ02", "pnfFamily":"BBU", "pnfType":"AirScale", "otherFieldsVersion":1, "pnfOamIpv4Address":"10.16.123.234", "pnfSoftwareVersion":"v4.5.0.1", "pnfSerialNumber":"QTFCOC540002E", "pnfManufactureDate":1516406400}}}'
+ param2 = '/events/unauthenticated.SEC_OTHER_OUTPUT/OpenDCAE-c12/c12'
+ super(self.__class__, self).do_GET(param1, param2)
+
+ def do_POST(self):
+ #Prepare POST response
+ logger.console('========')
+ logger.console(self.raw_requestline)
+ logger.console('========')
+ if re.search('/events/unauthenticated.PNF_READY', self.path) is not None:
+ global prh_ready
+ prh_ready = '{"event":{"correlationID":"NOKQTFCOC540002E", "pnfOamIpv4Address":"10.16.123.234", "pnfOamIpv6Address":"2001:0db8:85a3:0000:0000:8a2e:0370:7334"}}'
+ self.send_response(200)
+
+def run_server(HandlerClass, port, ServerClass = BaseHTTPServer.HTTPServer, protocol="HTTP/1.0"):
+ server_address = ('', port)
+
+ HandlerClass.protocol_version = protocol
+ httpd = ServerClass(server_address, HandlerClass)
+
+ global Httpd
+ Httpd = httpd
+ if HandlerClass is DMaaPHandler:
+ PrhVariables.DMaaPHTTPD = httpd
+ else:
+ PrhVariables.AAIHTTPD = httpd
+
+ sa = httpd.socket.getsockname()
+ print "Serving HTTP on", sa[0], "port", sa[1], "..."
+
+def _main_ (HandlerClass, port, ServerClass = BaseHTTPServer.HTTPServer, protocol="HTTP/1.0"):
+ server_address = ('', port)
+
+ HandlerClass.protocol_version = protocol
+ httpd = ServerClass(server_address, HandlerClass)
+
+ sa = httpd.socket.getsockname()
+ print "Serving HTTP on", sa[0], "port", sa[1], "..."
+ httpd.serve_forever()
+
+if __name__ == '__main__':
+ _main_(DMaaPHandler, 3904)
--- /dev/null
+*** Settings ***
+Documentation The main interface for interacting with PRH. It handles low level stuff like managing the http request library
+Library PrhLibrary.py
+Library RequestsLibrary
+
+*** Variables ***
+
+*** Keywords ***
+PRH Suite Setup
+ [Documentation] Start DMaaP and AAI Mockup Server
+ ${ret}= Setup DMaaP Server
+ Should Be Equal As Strings ${ret} true
+ ${ret}= Setup AAI Server
+ Should Be Equal As Strings ${ret} true
+
+PRH Suite Shutdown
+ [Documentation] Shutdown DMaaP and AAI Mockup Server
+ ${ret}= Shutdown DMaap Server
+ Should Be Equal As Strings ${ret} true
+ ${ret}= Shutdown AAI Server
+ Should Be Equal As Strings ${ret} true
+
+Get event from DMaaP
+ [Arguments] ${ip} ${endpoint}
+ [Documentation] Get an event from DMaaP
+ ${url}= Catenate SEPARATOR= ${ip} ${endpoint}
+ Log Creating session ${url}
+ Create Session prh-d1 ${url}
+ ${resp}= Get Request prh-d1 ${url}
+ Log Received response from dcae ${resp.json()}
+ [Return] ${resp}
+
+Send patch from AAI
+ [Arguments] ${ip} ${endpoint}
+ [Documentation] Get patch from AAI
+ ${url}= Catenate SEPARATOR= ${ip} ${endpoint}
+ Log Creating session ${url}
+ Create Session prh-d1 ${url}
+ ${resp}= Patch Request prh-d1 ${url}
+ Log ${resp}
+ [Return] ${resp}
+
+Get json from AAI
+ [Arguments] ${ip} ${endpoint}
+ [Documentation] Get json from AAI
+ ${url}= Catenate SEPARATOR= ${ip} ${endpoint}
+ Log Creating session ${url}
+ Create Session prh-d1 ${url}
+ ${resp}= Get Request prh-d1 ${url}
+ Log Received response from dcae ${resp.json()}
+ [Return] ${resp}
+
+Post json to DMaaP
+ [Arguments] ${ip} ${endpoint} ${PNF_READY}
+ [Documentation] Get json from AAI
+ ${url}= Catenate SEPARATOR= ${ip} ${endpoint}
+ Log Creating session ${url}
+ Create Session prh-d1 ${url}
+ ${resp}= Post Request prh-d1 ${url} data=${PNF_READY}
+ Log ${resp}
+ [Return] ${resp}
Code Review / integration.git / commitdiff