Implemented ChessServer\Command\Binary\TransmitCommand

.gitignore

@@ -9,6 +9,8 @@
 /ssl/*.key
 
 /storage/*.log
+/storage/tmp/*
+!/storage/tmp/.gitkeep
 
 /.phpunit.result.cache
 

src/Command/Binary/TransmitCommand.php

@@ -2,11 +2,15 @@
 
 namespace ChessServer\Command\Binary;
 
+use Chess\Media\BoardToPng;
+use Chess\Variant\Classical\FEN\StrToBoard as ClassicalStrToBoard;
 use ChessServer\Command\AbstractCommand;
 use ChessServer\Socket\AbstractSocket;
 
 class TransmitCommand extends AbstractCommand
 {
+    const OUTPUT_FOLDER = __DIR__.'/../../../storage/tmp';
+
     public function __construct()
     {
         $this->name = '/transmit';
@@ -25,10 +29,11 @@ public function run(AbstractSocket $socket, array $argv, int $id)
     {
         $params = json_decode(stripslashes($argv[1]), true);
 
-        // TODO
+        $board = (new ClassicalStrToBoard($params['fen']))->create();
+        $filename = (new BoardToPng($board, $params['flip']))->output(self::OUTPUT_FOLDER);
+        $contents = file_get_contents(self::OUTPUT_FOLDER . "/$filename");
+        $base64 = base64_encode($contents);
 
-        return $socket->getClientStorage()->sendToOne($id, [
-            $this->name => 'TODO',
-        ]);
+        return $socket->getClientStorage()->sendToOne($id, $base64);
     }
 }

src/Socket/Workerman/ClientStorage.php

@@ -35,10 +35,11 @@ public function sendToOne(int $id, $res): void
         $this->rewind();
         while ($this->valid()) {
             if ($id === $this->current()->id) {
-                $this->current()->send(json_encode($res));
+                $res = is_array($res) ? json_encode($res) : $res;
+                $this->current()->send($res);
                 $this->logger->info('Sent message', [
                     'id' => $id,
-                    'cmd' => array_keys($res),
+                    'cmd' => is_array($res) ? array_keys($res) : [$res],
                 ]);
             }
             $this->next();
@@ -47,14 +48,14 @@ public function sendToOne(int $id, $res): void
 
     public function sendToMany(array $ids, $res): void
     {
-        $json = json_encode($res);
+        $res = is_array($res) ? json_encode($res) : $res;
         $this->rewind();
         while ($this->valid()) {
             if (in_array($this->current()->id, $ids)) {
-                $this->current()->send($json);
+                $this->current()->send($res);
                 $this->logger->info('Sent message', [
                     'ids' => $ids,
-                    'cmd' => array_keys($res),
+                    'cmd' => is_array($res) ? array_keys($res) : [$res],
                 ]);
             }
             $this->next();
@@ -63,10 +64,10 @@ public function sendToMany(array $ids, $res): void
 
     public function sendToAll($res): void
     {
-        $json = json_encode($res);
+        $res = is_array($res) ? json_encode($res) : $res;
         $this->rewind();
         while ($this->valid()) {
-            $this->current()->send($json);
+            $this->current()->send($res);
             $this->next();
         }
     }