Implemented StockfishAsyncTask

src/Command/Game/Cli.php

@@ -34,7 +34,7 @@ public function __construct(Pool $pool, Db $db)
         $this->commands->attach(new ResignCommand($db));
         $this->commands->attach(new RestartCommand($db));
         $this->commands->attach(new StartCommand($db));
-        $this->commands->attach(new StockfishCommand());
+        $this->commands->attach((new StockfishCommand())->setPool($pool));
         $this->commands->attach(new TutorFenCommand());
     }
 

src/Command/Game/StockfishAsyncTask.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace ChessServer\Command\Game;
+
+use Spatie\Async\Task;
+
+class StockfishAsyncTask extends Task
+{
+    private $params;
+
+    private $gameMode;
+
+    private $command;
+
+    public function __construct($params, $gameMode, $command)
+    {
+        $this->params = $params;
+        $this->gameMode = $gameMode;
+        $this->command = $command;
+
+    }
+
+    public function configure()
+    {
+    }
+
+    public function run()
+    {
+        return $this->gameMode->res($this->params, $this->command);
+    }
+}

src/Command/Game/StockfishCommand.php

@@ -26,8 +26,13 @@ public function run(AbstractSocket $socket, array $argv, int $id)
         $params = json_decode(stripslashes($argv[1]), true);
         $gameMode = $socket->getGameModeStorage()->getById($id);
 
-        return $socket->getClientStorage()->send([$id],
-            $gameMode->res($params, $this)
-        );
+        $this->pool->add(new StockfishAsyncTask($params, $gameMode, $this))
+            ->then(function ($result) use ($socket, $id) {
+                return $socket->getClientStorage()->send([$id], [
+                    $this->name => $result,
+                ]);
+            });
+
+        // $this->pool->wait();
     }
 }