NodeActionMessageEventHandler

Complexity

Total Complexity

2

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	handle()	0	37	2

"""
Enarksh

Copyright 2013-2016 Set Based IT Consultancy

Licence MIT
"""
import sys
import traceback

from enarksh.DataLayer import DataLayer
from enarksh.controller.event_handler.NodeActionMessageBaseEventHandler import NodeActionMessageBaseEventHandler


class NodeActionMessageEventHandler(NodeActionMessageBaseEventHandler):
    """
    An event handler for a NodeActionMessage received events.
    """

    # ------------------------------------------------------------------------------------------------------------------
    @staticmethod
    def handle(_event, message, controller):
        """
        Handles a NodeActionMessage received event.

        :param * _event: Not used.
        :param enarksh.controller.message.NodeActionMessage.NodeActionMessage message: The message.
        :param enarksh.controller.Controller.Controller controller: The controller.
        """
        del _event

        # Compose a response message for client.
        response = {'ret':     0,
                    'message': ''}

        try:
            run_node = DataLayer.enk_back_run_node_get_by_uri(message.uri)

            NodeActionMessageBaseEventHandler.base_handle(controller,
                                                          response,
                                                          run_node['sch_id'],
                                                          run_node['rnd_id'],
                                                          message.act_id,
                                                          '',
                                                          False,
                                                          False)
        except Exception as exception:

Catching very general exceptions such as Exception is usually not recommended.

            print(exception, file=sys.stderr)
            traceback.print_exc(file=sys.stderr)

            response['ret'] = -1
            response['message'] = 'Internal error'

            DataLayer.rollback()

        # Send response message to the CLI client.
        controller.message_controller.send_message('lockstep', response)

# ----------------------------------------------------------------------------------------------------------------------