Commit 40b6c338 authored by Pelayo Torres's avatar Pelayo Torres
Browse files

Check eventFilters

parent 30169a2b

services/TS29222_CAPIF_Events_API/capif_events/core/events_apis.py

+48 −1
Original line number Diff line number Diff line
@@ -39,6 +39,30 @@ class EventSubscriptionsOperations(Resource): 


        return None

    

    def __check_event_filters(self, events, filters):

        current_app.logger.debug("Checking event filters.")

        valid_filters = {

            "SERVICE_API_UPDATE": ["api_ids"],

            "SERVICE_API_AVAILABLE" : ["api_ids"],

            "SERVICE_API_UNAVAILABLE" : ["api_ids"],

            "API_INVOKER_ONBOARDED": ["api_invoker_ids"],

            "API_INVOKER_OFFBOARDED": ["api_invoker_ids"],

            "API_INVOKER_UPDATED": ["api_invoker_ids"],

            "ACCESS_CONTROL_POLICY_UPDATE":["api_invoker_ids", "api_ids"],

            "SERVICE_API_INVOCATION_SUCCESS": ["api_invoker_ids", "api_ids", "aef_ids"],

            "SERVICE_API_INVOCATION_FAILURE": ["api_invoker_ids", "api_ids", "aef_ids"],

            "API_TOPOLOGY_HIDING_CREATED": [],

            "API_TOPOLOGY_HIDING_REVOKED": []

        }



        for event, filter in zip(events, filters):

            invalid_filters = set(filter.keys()) - set(valid_filters.get(event, []))



            if invalid_filters:

                 current_app.logger.debug(f"The eventFilter {invalid_filters} for event {event} are not applicable.")

                 return bad_request_error(detail="Bad Param", cause = f"Invalid eventFilter for event {event}", invalid_params=[{"param": "eventFilter", "reason": f"The eventFilter {invalid_filters} for event {event} are not applicable."}])

        return None



    def __init__(self):

        Resource.__init__(self)

        self.auth_manager = AuthManager()
@@ -65,11 +89,16 @@ class EventSubscriptionsOperations(Resource): 


            result = self.__check_subscriber_id(subscriber_id)





            if  isinstance(result, Response):



                return result

            

            if EventSubscription.return_supp_feat_dict(event_subscription.supported_features)["EnhancedEventReport"] and event_subscription.event_filters:

                current_app.logger.debug(event_subscription.event_filters)

                result = self.__check_event_filters(event_subscription.events, clean_empty(event_subscription.to_dict()["event_filters"]))

                if  isinstance(result, Response):

                    return result



            # Generate subscriptionID

            subscription_id = secrets.token_hex(15)

            evnt = dict()
@@ -144,6 +173,11 @@ class EventSubscriptionsOperations(Resource): 
            if  isinstance(result, Response):

                return result

            

            if EventSubscription.return_supp_feat_dict(event_subscription.supported_features)["EnhancedEventReport"] and event_subscription.event_filters:

                result = self.__check_event_filters(event_subscription.events, clean_empty(event_subscription.to_dict()["event_filters"]))

                if  isinstance(result, Response):

                    return result



            my_query = {'subscriber_id': subscriber_id,

                    'subscription_id': subscription_id}

            eventdescription = mycol.find_one(my_query)
@@ -189,6 +223,19 @@ class EventSubscriptionsOperations(Resource): 
                current_app.logger.error("Event subscription not found")

                return not_found_error(detail="Event subscription not exist", cause="Event API subscription id not found")



            if EventSubscription.return_supp_feat_dict(eventdescription.get("supported_features"))["EnhancedEventReport"]:

                current_app.logger.debug(event_subscription)

                if event_subscription.events and event_subscription.event_filters:

                    result = self.__check_event_filters(event_subscription.events, clean_empty(event_subscription.to_dict()["event_filters"]))

                elif event_subscription.events and  event_subscription.event_filters is None and eventdescription.get("event_filters", None):

                    result = self.__check_event_filters(event_subscription.events, eventdescription.get("event_filters"))

                elif event_subscription.events is None and event_subscription.event_filters:

                    current_app.logger.debug(clean_empty(event_subscription.to_dict()["event_filters"]))

                    result = self.__check_event_filters(eventdescription.get("events"), clean_empty(event_subscription.to_dict()["event_filters"]))



                if  isinstance(result, Response):

                    return result



            body = clean_empty(event_subscription.to_dict())

            document = mycol.update_one(my_query, {"$set":body})

            document = mycol.find_one(my_query)