added route message spec

Author: transistive

src/Bolt.php

@@ -2,6 +2,7 @@
 
 namespace Bolt;
 
+use Bolt\protocol\V4_3;
 use Bolt\error\{
     ConnectException,
     PackException,
@@ -11,6 +12,8 @@
 use Bolt\PackStream\{IPacker, IUnpacker};
 use Bolt\protocol\AProtocol;
 use Bolt\connection\IConnection;
+use function get_called_class;
+use function method_exists;
 
 /**
  * Main class Bolt
@@ -388,4 +391,18 @@ public function __destruct()
         $this->connection->disconnect();
     }
 
+    /**
+     * fetch the current routing table, if the message specification allows it.
+     *
+     * @param array $routing
+     * @return array|null
+     */
+    public function route(array $routing): ?array
+    {
+        if (!method_exists($this->protocol, 'route')) {
+            return null;
+        }
+
+        return $this->protocol->route($routing);
+    }
 }

src/protocol/V4_3.php

@@ -2,6 +2,11 @@
 
 namespace Bolt\protocol;
 
+use Bolt\error\MessageException;
+use Bolt\error\PackException;
+use function count;
+use function is_array;
+
 /**
  * Class Protocol version 4.3
  *
@@ -11,5 +16,17 @@
  */
 class V4_3 extends V4_1
 {
+    public function route(array $routing): array
+    {
+        $this->write($this->packer->pack(0x66, $routing));
+
+        $signature = 0;
+        $output = $this->read($signature);
+
+        if ($signature === self::FAILURE) {
+            throw new MessageException($output['message'] . ' (' . $output['code'] . ')');
+        }
 
+        return $signature === self::SUCCESS ? $output : [];
+    }
 }