def on_stream_event()

in src/streamHandlers.py [0:0]

• 8 lines of code
• 3 McCabe index (conditional complexity)

    def on_stream_event(self, event: SubscriptionResponseMessage) -> None:
        """
        When we receive a message over IPC on the token response topic, load in the InfluxDB parameters

        Parameters
        ----------
            event(SubscriptionResponseMessage): The received IPC message

        Returns
        -------
            None
        """
        try:
            self.influxdb_parameters = event.json_message.message
            if len(self.influxdb_parameters) == 0:
                raise ValueError("Retrieved Influxdb parameters are empty!")
        except Exception:
            logging.error('Failed to load telemetry event JSON!', exc_info=True)
            exit(1)