Skip to content

Commit 6412884

Browse files
committed
Add pick message
1 parent cdc7a5f commit 6412884

2 files changed

Lines changed: 7 additions & 2 deletions

File tree

manager/libs/applications/compatibility/exercise_wrapper.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,10 @@ def send_freq(self, exercise_connection, is_alive):
6161
exercise_connection.send(
6262
"""#freq{"brain": 20, "gui": 10, "rtf": 100}""")
6363
time.sleep(1)
64+
65+
def send_pick(self, data):
66+
self.gui_connection.send("#pick" + json.dumps(data))
67+
print("#pick" + json.dumps(data))
6468

6569
def start_send_freq_thread(self):
6670
"""Start a thread to send the frequency of the brain and gui to the exercise server"""

manager/manager/manager.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,8 +59,6 @@ class Manager:
5959
# Global transitions
6060
{'trigger': 'disconnect', 'source': '*',
6161
'dest': 'idle', 'before': 'on_disconnect'},
62-
#{'trigger': 'get_state', 'source': '*', 'dest': '='},
63-
6462
]
6563

6664
def __init__(self, host: str, port: int):
@@ -281,6 +279,9 @@ def signal_handler(sign, frame):
281279
self.process_messsage(message)
282280
except Exception as e:
283281
if message is not None:
282+
if message.command is "#pick":
283+
print(message)
284+
self.application.send_pick(message.data)
284285
ex = ManagerConsumerMessageException(
285286
id=message.id, message=str(e))
286287
else:

0 commit comments

Comments
 (0)