Merge branch 'feat/IO-module' of https://github.com/corail-research/s…

…eahorse into feat/IO-module

src/abalone.py

@@ -36,8 +36,8 @@ async def play(self, current_state: GameState) -> Action:
 def run_multiple_games():
     for _ in range(1):
 
-        player2 = LocalPlayerProxy(RandomPlayerAbalone(piece_type="W"))
-        player1 = LocalPlayerProxy(AlphaPlayerAbalone(piece_type="B"))
+        player2 = RemotePlayerProxy(mimics=RandomPlayerAbalone,piece_type="W",name="marcel")
+        player1 = InteractivePlayerProxy(AlphaPlayerAbalone(piece_type="B"))
 
         list_players = [player1, player2]
         init_scores = {player1.get_id(): 0, player2.get_id(): 0}

src/seahorse/examples/abalone/board_abalone.py

@@ -155,5 +155,5 @@ def from_json(cls, data) -> Serializable:
         for x,y in d["env"].items():
             # TODO eval is unsafe
             del dd["env"][x]
-            dd["env"][eval(x)] = Piece.from_json(**json.dumps(y))
+            dd["env"][eval(x)] = Piece.from_json(json.dumps(y))
         return cls(**dd)

src/seahorse/execution/web/examples/abalone/auto/main.js

@@ -3,7 +3,7 @@ $(document).ready(function () {
   var index = -1;
   const logElement = document.getElementById("log");
   var play = false;
-  const socket = io("ws://localhost:8080");
+  const socket = io("ws://10.200.37.65:16001");
   socket.on("play", (...args) => {
     json = JSON.parse(args[0]);
     //console.log(json);

src/seahorse/execution/web/examples/abalone/interactive/main.js

@@ -3,7 +3,7 @@ $(document).ready(function () {
   var index = -1;
   const logElement = document.getElementById("log");
   var play = false;
-  const socket = io("ws://localhost:16001");
+  const socket = io("ws://10.200.37.65:16001");
 
 
   socket.on("play", (...args) => {

src/seahorse/game/io_stream.py

@@ -260,12 +260,12 @@ def start(self, task: Callable[[None], None], listeners: list[EventSlave]) -> No
         # Sets the runner up and starts the tcp server
         self.event_loop.run_until_complete(self.runner.setup())
         #print(self.port)
-        site = web.TCPSite(self.runner, "localhost", self.port)
+        site = web.TCPSite(self.runner, "10.200.37.65", self.port)
         self.event_loop.run_until_complete(site.start())
 
         async def stop():
             for x in listeners:
-                await x.listen(master_address="http://localhost:"+str(self.port), keep_alive=False)
+                await x.listen(master_address="http://10.200.37.65:"+str(self.port), keep_alive=False)
 
             # Waiting for all listeners
             await self._wait_for_connexion()

src/seahorse/game/master.py

@@ -48,7 +48,7 @@ def __init__(
         self.log_file = log_file
         self.players_iterator = cycle(players_iterator) if isinstance(players_iterator, list) else players_iterator
         next(self.players_iterator)
-        self.emitter = EventMaster.get_instance(3,initial_game_state.__class__,port=port)
+        self.emitter = EventMaster.get_instance(4,initial_game_state.__class__,port=port)
 
     async def step(self) -> GameState:
         """

src/standalone_abalone.py

@@ -4,5 +4,5 @@
 from seahorse.examples.abalone.random_player_abalone import MyPlayer as RandomPlayerAbalone
 from seahorse.player.proxies import LocalPlayerProxy
 
-player1 = LocalPlayerProxy(RandomPlayerAbalone(piece_type="W", name= "bob"),masterless=True,gs=GameStateAbalone)
-asyncio.new_event_loop().run_until_complete(player1.listen(keep_alive=True,master_address="http://localhost:16001"))
+player1 = LocalPlayerProxy(RandomPlayerAbalone(piece_type="W", name= "marcel"),masterless=True,gs=GameStateAbalone)
+asyncio.new_event_loop().run_until_complete(player1.listen(keep_alive=True,master_address="http://10.200.37.65:16001"))