| 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 |