def publish_message()

in src/main.py [0:0]

• 14 lines of code
• 5 McCabe index (conditional complexity)

    def publish_message(self, sdk, topic, message):
        '''
            Single callback for all PubSub (IPC / MQTT) message publisher.
        '''

        try:
            
            # Log the publish 
            log.info('Publishing PubSub Message. Topic: {} - Message: {}'.format(topic, message))

            # Publish the message to the AWS Greengrass IPC or MQTT sdks
            if sdk == 'ipc':
                self.ipc_pubsub.publish_to_topic(topic, message)

            elif sdk == 'mqtt':
                self.mqtt_pubsub.publish_to_mqtt(topic, message)

            else:
                raise Exception('Publish for unknown publish_sdk: {} sent to topic: {}'.format(sdk, topic))
        
        except Exception as err:
            log.error('EXCEPTION: Error Publishing ERROR: {} - PUBLISH_SDK: {} - TOPIC: {} - MESSAGE: {}'.format(err, sdk, topic, message))