Implemented TutorFenCommand as an async command

src/Command/Game/Sync/TutorFenCommand.php → src/Command/Game/Async/TutorFenCommand.php

@@ -1,15 +1,11 @@
 <?php
 
-namespace ChessServer\Command\Game\Sync;
+namespace ChessServer\Command\Game\Async;
 
-use Chess\FenToBoardFactory;
-use Chess\Function\CompleteFunction;
-use Chess\Tutor\FenEvaluation;
-use Chess\Variant\Classical\Board;
-use ChessServer\Command\AbstractSyncCommand;
+use ChessServer\Command\AbstractAsyncCommand;
 use ChessServer\Socket\AbstractSocket;
 
-class TutorFenCommand extends AbstractSyncCommand
+class TutorFenCommand extends AbstractAsyncCommand
 {
     public function __construct()
     {
@@ -28,11 +24,12 @@ public function validate(array $argv)
     public function run(AbstractSocket $socket, array $argv, int $id)
     {
         $params = json_decode(stripslashes($argv[1]), true);
-        $board = FenToBoardFactory::create($params['fen'], new Board());
-        $paragraph = (new FenEvaluation(new CompleteFunction(), $board))->paragraph;
 
-        return $socket->getClientStorage()->send([$id], [
-            $this->name => implode(' ', $paragraph),
-        ]);
+        $this->pool->add(new TutorFenTask($params))
+            ->then(function ($result) use ($socket, $id) {
+                return $socket->getClientStorage()->send([$id], [
+                    $this->name => $result,
+                ]);
+            });
     }
 }

src/Command/Game/Async/TutorFenTask.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace ChessServer\Command\Game\Async;
+
+use Chess\FenToBoardFactory;
+use Chess\Function\CompleteFunction;
+use Chess\Tutor\FenEvaluation;
+use Chess\Variant\Classical\Board;
+use Spatie\Async\Task;
+
+class TutorFenTask extends Task
+{
+    private array $params;
+
+    public function __construct(array $params)
+    {
+        $this->params = $params;
+    }
+
+    public function configure()
+    {
+    }
+
+    public function run()
+    {
+        $board = FenToBoardFactory::create($this->params['fen'], new Board());
+        $paragraph = (new FenEvaluation(new CompleteFunction(), $board))->paragraph;
+
+        return $paragraph;
+    }
+}

src/Command/Game/Cli.php

@@ -10,6 +10,7 @@
 use ChessServer\Command\Game\Async\ResignCommand;
 use ChessServer\Command\Game\Async\RestartCommand;
 use ChessServer\Command\Game\Async\StockfishCommand;
+use ChessServer\Command\Game\Async\TutorFenCommand;
 use ChessServer\Command\Game\Sync\AcceptPlayRequestCommand;
 use ChessServer\Command\Game\Sync\DrawCommand;
 use ChessServer\Command\Game\Sync\EvalNamesCommand;
@@ -19,7 +20,6 @@
 use ChessServer\Command\Game\Sync\RematchCommand;
 use ChessServer\Command\Game\Sync\StartCommand;
 use ChessServer\Command\Game\Sync\TakebackCommand;
-use ChessServer\Command\Game\Sync\TutorFenCommand;
 use ChessServer\Command\Game\Sync\UndoCommand;
 use Spatie\Async\Pool;
 
@@ -49,6 +49,6 @@ public function __construct(Pool $pool)
         $this->commands->attach((new RestartCommand())->setPool($pool));
         $this->commands->attach(new StartCommand());
         $this->commands->attach((new StockfishCommand())->setPool($pool));
-        $this->commands->attach(new TutorFenCommand());
+        $this->commands->attach((new TutorFenCommand())->setPool($pool));
     }
 }