aboutsummaryrefslogtreecommitdiffstats
path: root/tests/dcaegen2/bbs-testcases/resources/simulator/AAI.py
diff options
context:
space:
mode:
Diffstat (limited to 'tests/dcaegen2/bbs-testcases/resources/simulator/AAI.py')
-rw-r--r--tests/dcaegen2/bbs-testcases/resources/simulator/AAI.py108
1 files changed, 0 insertions, 108 deletions
diff --git a/tests/dcaegen2/bbs-testcases/resources/simulator/AAI.py b/tests/dcaegen2/bbs-testcases/resources/simulator/AAI.py
deleted file mode 100644
index ba32582d..00000000
--- a/tests/dcaegen2/bbs-testcases/resources/simulator/AAI.py
+++ /dev/null
@@ -1,108 +0,0 @@
-import re
-import time
-from http.server import BaseHTTPRequestHandler
-import httpServerLib
-
-import json
-
-pnfs = []
-services = []
-pnf_not_found = '[{}]'
-
-class AAISetup(BaseHTTPRequestHandler):
-
- def do_PUT(self):
- global pnfs
- global services
- global pnf_not_found
- if re.search('/set_pnfs', self.path):
- content_length = int(self.headers['Content-Length'])
- pnfs = self.rfile.read(content_length)
- pnfs = pnfs.decode()
- httpServerLib.header_200_and_json(self)
- elif re.search('/set_services', self.path):
- content_length = int(self.headers['Content-Length'])
- services = self.rfile.read(content_length)
- services = services.decode()
- httpServerLib.header_200_and_json(self)
- elif re.search('/set_pnf_not_found', self.path):
- content_length = int(self.headers['Content-Length'])
- pnf_not_found = self.rfile.read(content_length)
- pnf_not_found = pnf_not_found.decode()
- httpServerLib.header_200_and_json(self)
-
- return
-
- def do_POST(self):
- if re.search('/reset', self.path):
- httpServerLib.header_200_and_json(self)
-
- return
-
-
-class AAIHandler(BaseHTTPRequestHandler):
-
- def do_GET(self):
- global pnfs
- global services
- global pnf_not_found
- pnf_path = '/aai/v14/network/pnfs/pnf/'
- service_path = '/aai/v14/nodes/service-instances/service-instance/'
- found_resource = None
- if re.search(pnf_path, self.path):
- try:
- python_pnfs = json.loads(pnfs)
- except AttributeError:
- python_pnfs = []
- for pnf_instance in python_pnfs:
- try:
- pnf_name = pnf_path + pnf_instance.get("pnf-name")
- except AttributeError:
- pnf_name = "PNF not found"
- if re.search(pnf_name, self.path):
- found_resource = pnf_instance
- break
- elif re.search(service_path, self.path):
- try:
- python_services = json.loads(services)
- except AttributeError:
- python_services = []
- for service_instance in python_services:
- try:
- service_name = service_path + service_instance.get("service-instance-id")
- except AttributeError:
- pnf_name = "Service not found"
- if re.search(service_name, self.path):
- found_resource = service_instance
- break
-
- if found_resource is not None:
- # Prepare the response for DMaaP (byte encoded JSON Object)
- found_resource = json.dumps(found_resource)
- found_resource = found_resource.encode()
- httpServerLib.header_200_and_json(self)
- self.wfile.write(found_resource)
- else:
- # Send a 404 message for not found
- pnf_resp = pnf_not_found
- # We have to replace the request line data
- err_pnf_template = "nodes/pnfs/pnf/Wrong-PNF-Name"
- pnf_resp = pnf_resp.replace(err_pnf_template, self.path)
- pnf_resp = pnf_resp.encode()
- httpServerLib.header_404_and_json(self)
- self.wfile.write(pnf_resp)
-
-
- return
-
-def _main_(handler_class=AAIHandler, protocol="HTTP/1.0"):
- handler_class.protocol_version = protocol
- httpServerLib.start_http_endpoint(3333, AAIHandler)
- httpServerLib.start_https_endpoint(3334, AAIHandler, keyfile="certs/org.onap.aai.key", certfile="certs/aai_aai.onap.org.cer", ca_certs="certs/ca_local_0.cer")
- httpServerLib.start_http_endpoint(3335, AAISetup)
- while 1:
- time.sleep(10)
-
-
-if __name__ == '__main__':
- _main_()