Commit 45bd21d6 authored by Jorge Moratinos's avatar Jorge Moratinos
Browse files

Setup common RedisEvent object to all services that sends events to Event Service

parent dece008c

services/TS29222_CAPIF_API_Invoker_Management_API/api_invoker_management/core/redis_event.py

+5 −4
Original line number Diff line number Diff line
@@ -6,7 +6,7 @@ publisher_ops = Publisher() 




class RedisEvent():

    def __init__(self, event, event_detail_key, information) -> None:

    def __init__(self, event, event_detail_key=None, information=None) -> None:

        self.EVENTS_ENUM = [

            'SERVICE_API_AVAILABLE',

            'SERVICE_API_UNAVAILABLE',
@@ -25,10 +25,11 @@ class RedisEvent(): 
            raise Exception(

                "Event (" + event + ") is not on event enum (" + ','.join(self.EVENTS_ENUM) + ")")

        self.redis_event = {

            "event": event,

            "key": event_detail_key,

            "information": information

            "event": event

        }

        if event_detail_key != None and information != None:

            self.redis_event['key'] = event_detail_key

            self.redis_event['information'] = information



    def to_string(self):

        return json.dumps(self.redis_event, cls=JSONEncoder)

services/TS29222_CAPIF_Logging_API_Invocation_API/api_invocation_logs/core/redis_event.py

+5 −4
Original line number Diff line number Diff line
@@ -6,7 +6,7 @@ publisher_ops = Publisher() 




class RedisEvent():

    def __init__(self, event, event_detail_key, information) -> None:

    def __init__(self, event, event_detail_key=None, information=None) -> None:

        self.EVENTS_ENUM = [

            'SERVICE_API_AVAILABLE',

            'SERVICE_API_UNAVAILABLE',
@@ -25,10 +25,11 @@ class RedisEvent(): 
            raise Exception(

                "Event (" + event + ") is not on event enum (" + ','.join(self.EVENTS_ENUM) + ")")

        self.redis_event = {

            "event": event,

            "key": event_detail_key,

            "information": information

            "event": event

        }

        if event_detail_key != None and information != None:

            self.redis_event['key'] = event_detail_key

            self.redis_event['information'] = information



    def to_string(self):

        return json.dumps(self.redis_event, cls=JSONEncoder)

services/TS29222_CAPIF_Publish_Service_API/published_apis/core/redis_event.py

+5 −4
Original line number Diff line number Diff line
@@ -6,7 +6,7 @@ publisher_ops = Publisher() 




class RedisEvent():

    def __init__(self, event, event_detail_key, information) -> None:

    def __init__(self, event, event_detail_key=None, information=None) -> None:

        self.EVENTS_ENUM = [

            'SERVICE_API_AVAILABLE',

            'SERVICE_API_UNAVAILABLE',
@@ -25,10 +25,11 @@ class RedisEvent(): 
            raise Exception(

                "Event (" + event + ") is not on event enum (" + ','.join(self.EVENTS_ENUM) + ")")

        self.redis_event = {

            "event": event,

            "key": event_detail_key,

            "information": information

            "event": event

        }

        if event_detail_key != None and information != None:

            self.redis_event['key'] = event_detail_key

            self.redis_event['information'] = information



    def to_string(self):

        return json.dumps(self.redis_event, cls=JSONEncoder)