eventFilter SERVICE_API_UPDATE (980c1091) · Commits · OCF / capif

services/TS29222_CAPIF_Events_API/capif_events/core/notifications.py

+12 −0

Original line number	Diff line number	Diff line
		@@ -58,6 +58,8 @@ class Notifications():
		event_detail["apiIds"]=event_detail_redis.get('apiIds', None)
		if EventSubscription.return_supp_feat_dict(sub["supported_features"])["ApiStatusMonitoring"]:
		event_detail["serviceAPIDescriptions"]=event_detail_redis.get('serviceAPIDescriptions', None)
		else:
		continue
		else:
		event_detail["apiIds"]=event_detail_redis.get('apiIds', None)
		if EventSubscription.return_supp_feat_dict(sub["supported_features"])["ApiStatusMonitoring"]:
		@@ -67,11 +69,17 @@ class Notifications():
		api_ids_list = event_filter.get("api_ids", None)
		if api_ids_list and event_detail_redis.get('serviceAPIDescriptions', {})[0].get('apiId') in api_ids_list:
		event_detail["serviceAPIDescriptions"]=event_detail_redis.get('serviceAPIDescriptions', None)
		else:
		continue
		else:
		event_detail["serviceAPIDescriptions"]=event_detail_redis.get('serviceAPIDescriptions', None)
		elif event in ["API_INVOKER_ONBOARDED", "API_INVOKER_OFFBOARDED", "API_INVOKER_UPDATED"]:
		if event_filter:
		invoker_ids_list = event_filter.get("api_invoker_ids", None)
		if invoker_ids_list and event_detail_redis.get('apiInvokerIds', None)[0] in invoker_ids_list:
		event_detail["apiInvokerIds"]=event_detail_redis.get('apiInvokerIds', None)
		else:
		continue
		else:
		event_detail["apiInvokerIds"]=event_detail_redis.get('apiInvokerIds', None)
		elif event in ["ACCESS_CONTROL_POLICY_UPDATE"]:
		@@ -80,6 +88,8 @@ class Notifications():
		api_ids_list = event_filter.get("api_ids", None)
		if invoker_ids_list and (event_detail_redis.get('apiInvokerIds', None)[0] in invoker_ids_list or event_detail_redis.get('api_ids', None)[0] in api_ids_list):
		event_detail["accCtrlPolList"]=event_detail_redis.get('accCtrlPolList', None)
		else:
		continue
		else:
		event_detail["accCtrlPolList"]=event_detail_redis.get('accCtrlPolList', None)
		elif event in ["SERVICE_API_INVOCATION_SUCCESS", "SERVICE_API_INVOCATION_FAILURE"]:
		@@ -91,6 +101,8 @@ class Notifications():
		event_detail_redis.get('apiIds', None)[0] in api_ids_list or
		event_detail_redis.get('aefIds', None)[0] in aef_ids_list ):
		event_detail["invocationLogs"]=event_detail_redis.get('invocationLogs', None)
		else:
		continue
		else:
		event_detail["invocationLogs"]=event_detail_redis.get('invocationLogs', None)
		elif event in ["API_TOPOLOGY_HIDING_CREATED", "API_TOPOLOGY_HIDING_REVOKED"]:

Admin message