Merge "Cherry Maintenance Doc updates"

[sim/a1-interface.git] / near-rt-ric-simulator / src / STD_1.1.3 / main.py

diff --git a/near-rt-ric-simulator/src/STD_1.1.3/main.py b/near-rt-ric-simulator/src/STD_1.1.3/main.py
index c46d950..7db215a 100644 (file)
--- a/near-rt-ric-simulator/src/STD_1.1.3/main.py
+++ b/near-rt-ric-simulator/src/STD_1.1.3/main.py
@@ -1,5 +1,5 @@
 #  ============LICENSE_START===============================================
 #  ============LICENSE_START===============================================

-#  Copyright (C) 2020 Nordix Foundation. All rights reserved.
+#  Copyright (C) 2021 Nordix Foundation. 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.
 #  ========================================================================
 #  Licensed under the Apache License, Version 2.0 (the "License");
 #  you may not use this file except in compliance with the License.


@@ -25,19 +25,23 @@ import requests
 from pathlib import Path
 from flask import Flask, escape, request, Response
 from jsonschema import validate
 from pathlib import Path
 from flask import Flask, escape, request, Response
 from jsonschema import validate

-from var_declaration import policy_instances, policy_status, callbacks, forced_settings, policy_fingerprint, hosts_set
-from maincommon import *
+from var_declaration import policy_instances, policy_status, callbacks, forced_settings, policy_fingerprint, hosts_set, app
+from maincommon import check_apipath, apipath, get_supported_interfaces_response, extract_host_name

 
 

+#Constants
+TEXT_PLAIN='text/plain'

 
 check_apipath()
 
 
 check_apipath()
 

-app = connexion.App(__name__, specification_dir=apipath)
+# app is created in var_declarations
+
+import payload_logging   # app var need to be initialized

 
 #Check alive function
 @app.route('/', methods=['GET'])
 def test():
 
 
 #Check alive function
 @app.route('/', methods=['GET'])
 def test():
 

-  return Response("OK", 200, mimetype='text/plain')
+  return Response("OK", 200, mimetype=TEXT_PLAIN)

 
 #Return the current and all supported yamls for the this container
 @app.route('/container_interfaces', methods=['GET'])
 
 #Return the current and all supported yamls for the this container
 @app.route('/container_interfaces', methods=['GET'])


@@ -55,7 +59,7 @@ def delete_instances():
   forced_settings['code']=None
   forced_settings['delay']=None
   policy_fingerprint.clear()
   forced_settings['code']=None
   forced_settings['delay']=None
   policy_fingerprint.clear()

-  return Response("All policy instances deleted", 200, mimetype='text/plain')
+  return Response("All policy instances deleted", 200, mimetype=TEXT_PLAIN)

 
 #Delete all - all reset
 #(same as delete_instances but kept to in order to use the same interface as other version of the simulator)
 
 #Delete all - all reset
 #(same as delete_instances but kept to in order to use the same interface as other version of the simulator)


@@ -70,9 +74,9 @@ def forceresponse():
 
   try:
     forced_settings['code']=request.args.get('code')
 
   try:
     forced_settings['code']=request.args.get('code')

-  except:
+  except Exception:

     forced_settings['code']=None
     forced_settings['code']=None

-  return Response("Force response code: " + str(forced_settings['code']) + " set for one single A1 response", 200, mimetype='text/plain')
+  return Response("Force response code: " + str(forced_settings['code']) + " set for one single A1 response", 200, mimetype=TEXT_PLAIN)

 
 #Set force delay response, in seconds, for all A1 responses
 #/froceesponse?delay=<seconds>
 
 #Set force delay response, in seconds, for all A1 responses
 #/froceesponse?delay=<seconds>


@@ -81,9 +85,9 @@ def forcedelay():
 
   try:
     forced_settings['delay']=request.args.get('delay')
 
   try:
     forced_settings['delay']=request.args.get('delay')

-  except:
+  except Exception:

     forced_settings['delay']=None
     forced_settings['delay']=None

-  return Response("Force delay: " + str(forced_settings['delay']) + " sec set for all A1 responses", 200, mimetype='text/plain')
+  return Response("Force delay: " + str(forced_settings['delay']) + " sec set for all A1 responses", 200, mimetype=TEXT_PLAIN)

 
 
 #Set status and reason
 
 
 #Set status and reason


@@ -91,14 +95,14 @@ def forcedelay():
 @app.route('/status', methods=['PUT'])
 def setstatus():
 
 @app.route('/status', methods=['PUT'])
 def setstatus():
 

-  policyId=request.args.get('policyid')
-  if (policyId is None):
-    return Response('Parameter <policyid> missing in request', status=400, mimetype='text/plain')
-  if policyId not in policy_instances.keys():
-    return Response('Policyid: '+policyId+' not found.', status=404, mimetype='text/plain')
+  policy_id=request.args.get('policyid')
+  if (policy_id is None):
+    return Response('Parameter <policyid> missing in request', status=400, mimetype=TEXT_PLAIN)
+  if policy_id not in policy_instances.keys():
+    return Response('Policyid: '+policy_id+' not found.', status=404, mimetype=TEXT_PLAIN)

   status=request.args.get('status')
   if (status is None):
   status=request.args.get('status')
   if (status is None):

-    return Response('Parameter <status> missing in request', status=400, mimetype='text/plain')
+    return Response('Parameter <status> missing in request', status=400, mimetype=TEXT_PLAIN)

   reason=request.args.get('reason')
   ps = {}
   ps["enforceStatus"] = status
   reason=request.args.get('reason')
   ps = {}
   ps["enforceStatus"] = status


@@ -106,9 +110,9 @@ def setstatus():
   if (reason is not None):
     ps["enforceReason"] = reason
     msg=msg+" and "+reason
   if (reason is not None):
     ps["enforceReason"] = reason
     msg=msg+" and "+reason

-  policy_status[policyId] = ps
-  msg=msg+" for policy: " + policyId
-  return Response(msg, 200, mimetype='text/plain')
+  policy_status[policy_id] = ps
+  msg=msg+" for policy: " + policy_id
+  return Response(msg, 200, mimetype=TEXT_PLAIN)

 
 #Send status
 #/status?policyid=<policyid>
 
 #Send status
 #/status?policyid=<policyid>


@@ -116,19 +120,19 @@ def setstatus():
 def sendstatus():
   policyid=request.args.get('policyid')
   if (policyid is None):
 def sendstatus():
   policyid=request.args.get('policyid')
   if (policyid is None):

-    return Response('Parameter <policyid> missing in request', status=400, mimetype='text/plain')
+    return Response('Parameter <policyid> missing in request', status=400, mimetype=TEXT_PLAIN)

 
   if (policyid not in policy_status.keys()):
 
   if (policyid not in policy_status.keys()):

-    return Response('Policyid: '+policyid+' not found.', status=404, mimetype='text/plain')
+    return Response('Policyid: '+policyid+' not found.', status=404, mimetype=TEXT_PLAIN)

 
   ps=policy_status[policyid]
   cb=callbacks[policyid]
   try:
 
   ps=policy_status[policyid]
   cb=callbacks[policyid]
   try:

-    resp=requests.post(cb,json=json.dumps(ps), verify=False)
-  except:
-    return Response('Post status failed, could not send to: '+str(cb), status=500, mimetype='text/plain')
+    resp=requests.post(cb,json=json.dumps(ps), verify=False) # NOSONAR
+  except Exception:
+    return Response('Post status failed, could not send to: '+str(cb), status=500, mimetype=TEXT_PLAIN)

   if (resp.status_code<199 & resp.status_code > 299):
   if (resp.status_code<199 & resp.status_code > 299):

-    return Response('Post status failed with code: '+resp.status_code, status=500, mimetype='text/plain')
+    return Response('Post status failed with code: '+resp.status_code, status=500, mimetype=TEXT_PLAIN)

 
   data = resp.json()
   return Response(data, 200, mimetype='application/json')
 
   data = resp.json()
   return Response(data, 200, mimetype='application/json')


@@ -140,42 +144,38 @@ def statustest():
   try:
     data = request.data
     data = json.loads(data)
   try:
     data = request.data
     data = json.loads(data)

-  except:
-    return Response("The status data is corrupt or missing.", 400, mimetype='text/plain')
+  except Exception:
+    return Response("The status data is corrupt or missing.", 400, mimetype=TEXT_PLAIN)

 
   return Response(json.dumps(data), 200, mimetype='application/json')
 
 #Metrics function
 #Get a named counter
 @app.route('/counter/<string:countername>', methods=['GET'])
 
   return Response(json.dumps(data), 200, mimetype='application/json')
 
 #Metrics function
 #Get a named counter
 @app.route('/counter/<string:countername>', methods=['GET'])

-def getCounter(countername):
+def getcounter(countername):

 
   if (countername == "num_instances"):
 
   if (countername == "num_instances"):

-    return Response(str(len(policy_instances)), 200, mimetype='text/plain')
+    return Response(str(len(policy_instances)), 200, mimetype=TEXT_PLAIN)

   elif (countername == "num_types"):
   elif (countername == "num_types"):

-    return Response("0",200, mimetype='text/plain')
+    return Response("0",200, mimetype=TEXT_PLAIN)

   elif (countername == "interface"):
     p=Path(os.getcwd())
     pp=p.parts
   elif (countername == "interface"):
     p=Path(os.getcwd())
     pp=p.parts

-    return Response(str(pp[len(pp)-1]),200, mimetype='text/plain')
+    return Response(str(pp[len(pp)-1]),200, mimetype=TEXT_PLAIN)

   elif (countername == "remote_hosts"):
     hosts=",".join(hosts_set)
     return str(hosts),200
   elif (countername == "remote_hosts"):
     hosts=",".join(hosts_set)
     return str(hosts),200

+  elif (countername == "datadelivery"):
+    return Response(str(0),200, mimetype=TEXT_PLAIN)

   else:
   else:

-    return Response("Counter name: "+countername+" not found.",404, mimetype='text/plain')
+    return Response("Counter name: "+countername+" not found.",404, mimetype=TEXT_PLAIN)

 
 

-port_number = 8085
+port_number = 2222

 if len(sys.argv) >= 2:
   if isinstance(sys.argv[1], int):
     port_number = sys.argv[1]
 
 if len(sys.argv) >= 2:
   if isinstance(sys.argv[1], int):
     port_number = sys.argv[1]
 

-port_number_secure=8185
-

 app.add_api('STD_A1.yaml')
 app.add_api('STD_A1.yaml')

-context=get_security_context()
-if (context == None):
-  print("Start on non-secure port: "+str(port_number))
-  app.run(port=port_number, host="::")
-else:
-  print("Start on secure port: "+str(port_number_secure))
-  app.run(port=port_number_secure, host="::", ssl_context=context)
+
+if __name__ == '__main__':
+  app.run(port=port_number, host="127.0.0.1", threaded=False)
\ No newline at end of file