Commit 81418b31 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Device component: 

- Added missing method "SSETelemetrySubscribe" in client
parent 4ac6445a

src/device/client/DeviceClient.py

+8 −0
Original line number Diff line number Diff line
@@ -21,6 +21,7 @@ from common.proto.context_pb2 import ( 
)

from common.proto.device_pb2 import MonitoringSettings

from common.proto.device_pb2_grpc import DeviceServiceStub

from common.proto.monitoring_pb2 import SSEMonitoringSubscriptionConfig, SSEMonitoringSubscriptionResponse

from common.proto.optical_device_pb2_grpc import OpenConfigServiceStub

from common.tools.client.RetryDecorator import retry, delay_exponential

from common.tools.grpc.Tools import grpc_message_to_json_string
@@ -105,3 +106,10 @@ class DeviceClient: 
        response = self.openconfig_stub.DisableOpticalDevice(request)

        LOGGER.debug('DisableOpticalDevice result: {:s}'.format(grpc_message_to_json_string(response)))

        return response



    @RETRY_DECORATOR

    def SSETelemetrySubscribe(self, request : SSEMonitoringSubscriptionConfig) -> SSEMonitoringSubscriptionResponse:

        LOGGER.debug('SSETelemetrySubscribe request: {:s}'.format(grpc_message_to_json_string(request)))

        response = self.stub.SSETelemetrySubscribe(request)

        LOGGER.debug('SSETelemetrySubscribe result: {:s}'.format(grpc_message_to_json_string(response)))

        return response