Total Complexity | 3 |
Total Lines | 39 |
Duplicated Lines | 0 % |
Coverage | 0% |
Changes | 1 | ||
Bugs | 0 | Features | 0 |
1 | """ |
||
14 | class PossibleNodeActionsWebMessageEventHandler: |
||
15 | """ |
||
16 | An event handler for a PossibleNodeActionsWebMessage received events. |
||
17 | """ |
||
18 | |||
19 | # ------------------------------------------------------------------------------------------------------------------ |
||
20 | @staticmethod |
||
21 | def handle(_event, message, controller): |
||
22 | """ |
||
23 | Handles a PossibleNodeActionsWebMessage received event. |
||
24 | |||
25 | :param * _event: Not used. |
||
26 | :param enarksh.controller.message.PossibleNodeActionsWebMessage.PossibleNodeActionsWebMessage message: |
||
27 | The message. |
||
28 | :param enarksh.controller.Controller.Controller controller: The controller. |
||
29 | """ |
||
30 | del _event |
||
31 | |||
32 | log = logging.getLogger('enarksh') |
||
33 | |||
34 | try: |
||
35 | schedule = controller.get_schedule_by_sch_id(message.sch_id) |
||
36 | if schedule: |
||
37 | response = schedule.request_possible_node_actions(message.rnd_id) |
||
38 | else: |
||
39 | response = Schedule.get_response_template() |
||
40 | |||
41 | DataLayer.commit() |
||
42 | except Exception: |
||
43 | log.exception('Error') |
||
44 | |||
45 | response = dict() |
||
46 | response['ret'] = -1 |
||
47 | response['message'] = 'Internal error' |
||
48 | |||
49 | DataLayer.rollback() |
||
50 | |||
51 | # Send the message to the web interface. |
||
52 | controller.message_controller.send_message('lockstep', response, True) |
||
53 | |||
55 |