def handle_message()

in src/backend/app.py [0:0]

• 13 lines of code
• 2 McCabe index (conditional complexity)

def handle_message(msg):

    if current_user.is_authenticated:

        ipc_client = awsiot.greengrasscoreipc.connect()

        topic = "{}/publish".format(os.environ["AWS_IOT_THING_NAME"])
        data = {"msg": msg}

        publish_operation = ipc_client.new_publish_to_iot_core()
        publish_operation.activate(
            request=model.PublishToIoTCoreRequest(
                topic_name=topic,
                qos=model.QOS.AT_MOST_ONCE,
                payload=json.dumps(data).encode(),
            )
        )