A lot of work (based on dawehner/jupyter-php)

Author: castarco

composer.json

@@ -4,10 +4,12 @@
     "type": "project",
     "license": "MIT",
     "require": {
-        "php": "5.*,>=5.4",
+        "php": ">=5.5.9",
         "ext-zmq": "*",
-        "psy/psysh": "0.6.*",
-        "composer/composer": "1.0.0-alpha11"
+        "psy/psysh": "0.7.*",
+        "composer/composer": "1.0.0-alpha11",
+        "react/zmq": "^0.3.0",
+        "ramsey/uuid": "^3.2"
     },
     "require-dev": {
 

src/.gitkeep renamed to src/Actions/ExecuteAction.php

@@ -0,0 +1,58 @@
+<?php
+
+
+namespace Litipk\JupyterPHP;
+
+
+final class ConnectionSettings
+{
+    /**
+     * @return array[string]mixed
+     */
+    public static function get()
+    {
+        global $argv;
+        if (!isset($argv) || empty($argv)) {
+            $argv = $_SERVER['argv'];
+        }
+
+        if (is_array($argv) && count($argv) > 1) {
+            $connectionFileContents = file_get_contents($argv[1], false, true, 0, 2048);
+
+            if (false === $connectionFileContents) {
+                throw new \RuntimeException('Connection Settings: Unable to open the connection file.');
+            }
+
+            $connectionSettings = json_decode($connectionFileContents);
+
+            if (json_last_error() !== JSON_ERROR_NONE) {
+                throw new \RuntimeException('Connection Settings: Corrupted connection file.');
+            }
+
+            return $connectionSettings;
+        } else {
+            throw new \RuntimeException('Connection Settings: Not specified.');
+        }
+    }
+
+    /**
+     * @param null|array $connectionSettings
+     * @return array[string]string
+     */
+    public static function getConnectionUris(array $connectionSettings = null)
+    {
+        if (null === $connectionSettings) {
+            $connectionSettings = self::get();
+        }
+
+        $connectionUri = $connectionSettings['transport'].'://'.$connectionSettings['ip'].':';
+
+        return [
+            'stdin'   => $connectionUri.$connectionSettings['stdin_port'],
+            'control' => $connectionUri.$connectionSettings['control_port'],
+            'hb'      => $connectionUri.$connectionSettings['hb_port'],
+            'shell'   => $connectionUri.$connectionSettings['shell_port'],
+            'iopub'   => $connectionUri.$connectionSettings['iopub_port']
+        ];
+    }
+}

src/Actions/HistoryAction.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace Litipk\JupyterPHP\Handlers;
+
+
+class HbErrorHandler
+{
+    public function __invoke($e)
+    {
+    }
+}

src/Actions/KernelInfoAction.php

@@ -0,0 +1,13 @@
+<?php
+
+
+namespace Litipk\JupyterPHP\Handlers;
+
+
+final class HbMessagesHandler
+{
+    public function __invoke($msg)
+    {
+
+    }
+}

src/Actions/ShutdownAction.php

@@ -0,0 +1,13 @@
+<?php
+
+
+namespace Litipk\JupyterPHP\Handlers;
+
+
+final class IOPubMessagesHandler
+{
+    public function __invoke($msg)
+    {
+        
+    }
+}

src/ConnectionSettings.php

@@ -0,0 +1,28 @@
+<?php
+
+
+namespace Litipk\JupyterPHP\Handlers;
+
+
+final class ShellMessagesHandler
+{
+    public function __invoke($msg)
+    {
+        list($zmqId, $delim, $hmac, $header, $parent_header, $metadata, $content) = $msg;
+
+        $header = json_decode($header);
+        $content = json_decode($content);
+
+        if ('kernel_info_request' === $header->msg_type) {
+
+        } elseif ('execute_request' === $header->msg_type) {
+
+        } elseif ('history_request' === $header->msg_type) {
+
+        } elseif ('shutdown_request' === $header->msg_type) {
+
+        } else {
+            // TODO: Add logger!
+        }
+    }
+}