X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=near-rt-ric-simulator%2Fsrc%2FSTD_2.0.0%2Fa1.py;h=1dd085985c2691b63dab0f99450843cd1e50bceb;hb=f13ce01cc75bf9c5d699984a3219da04b5f1ed9f;hp=e70a8edebd8291082a77ee0e5a6831189402957d;hpb=1ef05f94c2b4cc34f4b4b7e891b41548ad9bf446;p=sim%2Fa1-interface.git diff --git a/near-rt-ric-simulator/src/STD_2.0.0/a1.py b/near-rt-ric-simulator/src/STD_2.0.0/a1.py index e70a8ed..1dd0859 100755 --- a/near-rt-ric-simulator/src/STD_2.0.0/a1.py +++ b/near-rt-ric-simulator/src/STD_2.0.0/a1.py @@ -30,8 +30,9 @@ from jsonschema import validate from var_declaration import policy_instances, policy_types, policy_status, callbacks, forced_settings, policy_fingerprint, hosts_set from utils import calcFingerprint from maincommon import check_apipath, apipath, get_supported_interfaces_response, extract_host_name, is_duplicate_check +from models.enforceStatus import EnforceStatus -#Constsants +# Constants APPL_JSON='application/json' APPL_PROB_JSON='application/problem+json' @@ -139,8 +140,8 @@ def put_policy(policyTypeId, policyId): pjson=create_error_response(resp) return Response(json.dumps(pjson), 500, mimetype=APPL_PROB_JSON) - #Callout hooks for external server - #When it fails, break and return 419 HTTP status code + # Callout hooks for external server + # When it fails, break and return HTTP status code 500 if (EXT_SRV_URL is not None): resp = callout_external_server(policy_id, data, 'PUT') if (resp != retcode): @@ -152,16 +153,14 @@ def put_policy(policyTypeId, policyId): policy_fingerprint[fp]=policy_id - noti=request.args.get('notificationDestination') - callbacks[policy_id]=noti + noti = request.args.get('notificationDestination') + callbacks[policy_id] = noti policy_instances[policy_type_id][policy_id]=data if (policy_types[policy_type_id]['statusSchema'] is not None): - ps = {} - ps["enforceStatus"] = "" - ps["enforceReason"] = "" - policy_status[policy_id] = ps + enforceStatus = EnforceStatus("NOT_ENFORCED", "OTHER_REASON") + policy_status[policy_id] = enforceStatus.to_dict() if (retcode == 200): return Response(json.dumps(data), 200, mimetype=APPL_JSON) @@ -217,8 +216,8 @@ def delete_policy(policyTypeId, policyId): pjson=create_error_response(resp) return Response(json.dumps(pjson), 500, mimetype=APPL_PROB_JSON) - #Callout hooks for external server - #When it fails, break and return 419 HTTP status code + # Callout hooks for external server + # When it fails, break and return HTTP status code 500 if (EXT_SRV_URL is not None): resp = callout_external_server(policy_id, None, 'DELETE') if (resp != 204):