Added handling of shutdown request

Author: bstoney

src/Actions/ShutdownAction.php

@@ -3,11 +3,34 @@
 
 namespace Litipk\JupyterPHP\Actions;
 
+use Litipk\JupyterPHP\JupyterBroker;
+use React\ZMQ\SocketWrapper;
 
 final class ShutdownAction implements Action
 {
+    /** @var JupyterBroker */
+    private $broker;
+
+    /** @var SocketWrapper */
+    private $shellSocket;
+
+    /** @var SocketWrapper */
+    private $iopubSocket;
+
+    public function __construct(JupyterBroker $broker, SocketWrapper $iopubSocket, SocketWrapper $shellSocket)
+    {
+        $this->broker = $broker;
+        $this->iopubSocket = $iopubSocket;
+        $this->shellSocket = $shellSocket;
+    }
+
     public function call(array $header, array $content, $zmqId = null)
     {
-        // TODO: Implement call() method.
+        $this->broker->send($this->iopubSocket, 'status', ['execution_state' => 'busy'], $header);
+
+        $replyContent = ['restart' => $content['restart']];
+        $this->broker->send($this->shellSocket, 'shutdown_reply', $replyContent, $header, [], $zmqId);
+
+        $this->broker->send($this->iopubSocket, 'status', ['execution_state' => 'idle'], $header);
     }
 }

src/Handlers/ShellMessagesHandler.php

@@ -3,7 +3,6 @@
 
 namespace Litipk\JupyterPHP\Handlers;
 
-
 use Litipk\JupyterPHP\Actions\ExecuteAction;
 use Litipk\JupyterPHP\Actions\HistoryAction;
 use Litipk\JupyterPHP\Actions\KernelInfoAction;
@@ -15,7 +14,6 @@
 use Psy\Shell;
 use React\ZMQ\SocketWrapper;
 
-
 final class ShellMessagesHandler
 {
     /** @var ExecuteAction */
@@ -44,23 +42,25 @@ final class ShellMessagesHandler
      * @param Logger $logger
      */
     public function __construct(
-        JupyterBroker $broker, SocketWrapper $iopubSocket, SocketWrapper $shellSocket, Logger $logger
-    )
-    {
+        JupyterBroker $broker,
+        SocketWrapper $iopubSocket,
+        SocketWrapper $shellSocket,
+        Logger $logger
+    ) {
         $this->shellSoul = new Shell();
-        
+
         $this->executeAction = new ExecuteAction($broker, $iopubSocket, $shellSocket, $this->shellSoul);
         $this->historyAction = new HistoryAction($broker, $shellSocket);
         $this->kernelInfoAction = new KernelInfoAction($broker, $shellSocket, $iopubSocket);
-        $this->shutdownAction = new ShutdownAction($broker, $shellSocket);
-        
+        $this->shutdownAction = new ShutdownAction($broker, $iopubSocket, $shellSocket);
+
         $this->logger = $logger;
 
         $broker->send(
             $iopubSocket, 'status', ['execution_state' => 'starting'], []
         );
 
-        $this->shellSoul->setOutput( new KernelOutput($this->executeAction, $this->logger->withName('KernelOutput')));
+        $this->shellSoul->setOutput(new KernelOutput($this->executeAction, $this->logger->withName('KernelOutput')));
     }
 
     /**
@@ -74,14 +74,14 @@ public function __invoke(array $msg)
         $content = json_decode($content, true);
 
         $this->logger->debug('Received message', [
-            'processId'    => getmypid(),
-            'zmqId'        => htmlentities($zmqId, ENT_COMPAT, "UTF-8"),
-            'delim'        => $delim,
-            'hmac'         => $hmac,
-            'header'       => $header,
+            'processId' => getmypid(),
+            'zmqId' => htmlentities($zmqId, ENT_COMPAT, "UTF-8"),
+            'delim' => $delim,
+            'hmac' => $hmac,
+            'header' => $header,
             'parentHeader' => $parentHeader,
-            'metadata'     => $metadata,
-            'content'      => $content
+            'metadata' => $metadata,
+            'content' => $content
         ]);
 
         if ('kernel_info_request' === $header['msg_type']) {

src/JupyterBroker.php

@@ -76,7 +76,7 @@ public function send(
             json_encode(empty($content) ? new \stdClass : $content),
         ];
 
-        if ($zmqId !== null) {
+        if (null !== $zmqId) {
             $finalMsg = [$zmqId];
         } else {
             $finalMsg = [];