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