A lot of fixes, now this kernel is able to execute code

Author: castarco

.gitattributes

@@ -0,0 +1,6 @@
+* text=auto
+
+/.gitattributes export-ignore
+/.gitignore export-ignore
+/.scrutinizer.yml export-ignore
+/.travis.yml export-ignore

composer.json

@@ -5,11 +5,13 @@
     "license": "MIT",
     "require": {
         "php": ">=5.5.9",
+        "composer/composer": "1.0.0-alpha11",
         "ext-zmq": "*",
+        "monolog/monolog": "^1.9",
         "psy/psysh": "0.7.*",
-        "composer/composer": "1.0.0-alpha11",
+        "ramsey/uuid": "^3.2",
         "react/zmq": "^0.3.0",
-        "ramsey/uuid": "^3.2"
+        "symfony/polyfill-php70": "^1.1"
     },
     "require-dev": {
 

src/Actions/Action.php

@@ -6,5 +6,5 @@
 
 interface Action
 {
-    public function call($header, $content);
+    public function call(array $header, array $content);
 }

src/Actions/ExecuteAction.php

@@ -33,7 +33,7 @@ public function __construct(JupyterBroker $broker, SocketWrapper $iopubSocket, S
         $this->shellSocket = $shellSocket;
     }
 
-    public function call($header, $content)
+    public function call(array $header, array $content)
     {
         $this->broker->send(
             $this->iopubSocket, 'status', ['execution_state' => 'busy'], $header
@@ -44,7 +44,7 @@ public function call($header, $content)
         //  TODO: Here is where PsySH goes
         $vars_before = get_defined_vars();
         ob_start();
-        $result = eval($content->code);
+        $result = eval($content['code']);
         $stdOut = ob_get_contents();
         ob_end_clean();
         $vars_after = get_defined_vars();

src/Actions/HistoryAction.php

@@ -28,8 +28,8 @@ public function __construct(JupyterBroker $broker, SocketWrapper $shellSocket)
         $this->shellSocket = $shellSocket;
     }
 
-    public function call($header, $content)
+    public function call(array $header, array $content)
     {
-        $this->broker->send($this->shellSocket, 'history_reply', ['history' => array()], $header);
+        $this->broker->send($this->shellSocket, 'history_reply', ['history' => []], $header);
     }
 }

src/Actions/KernelInfoAction.php

@@ -6,7 +6,7 @@
 
 final class KernelInfoAction implements Action
 {
-    public function call($header, $content)
+    public function call(array $header, array $content)
     {
         // TODO: Implement call() method.
     }

src/Actions/ShutdownAction.php

@@ -6,7 +6,7 @@
 
 final class ShutdownAction implements Action
 {
-    public function call($header, $content)
+    public function call(array $header, array $content)
     {
         // TODO: Implement call() method.
     }

src/ConnectionSettings.php

@@ -17,13 +17,13 @@ public static function get()
         }
 
         if (is_array($argv) && count($argv) > 1) {
-            $connectionFileContents = file_get_contents($argv[1], false, true, 0, 2048);
+            $connectionFileContents = file_get_contents($argv[1], null, null, 0, 2048);
 
             if (false === $connectionFileContents) {
                 throw new \RuntimeException('Connection Settings: Unable to open the connection file.');
             }
 
-            $connectionSettings = json_decode($connectionFileContents);
+            $connectionSettings = json_decode($connectionFileContents, true);
 
             if (json_last_error() !== JSON_ERROR_NONE) {
                 throw new \RuntimeException('Connection Settings: Corrupted connection file.');

src/Handlers/ShellMessagesHandler.php

@@ -48,16 +48,16 @@ public function __invoke(array $msg)
     {
         list($zmqId, $delim, $hmac, $header, $parentHeader, $metadata, $content) = $msg;
 
-        $header = json_decode($header);
-        $content = json_decode($content);
+        $header = json_decode($header, true);
+        $content = json_decode($content, true);
 
-        if ('kernel_info_request' === $header->msg_type) {
+        if ('kernel_info_request' === $header['msg_type']) {
             $this->kernelInfoAction->call($header, $content);
-        } elseif ('execute_request' === $header->msg_type) {
+        } elseif ('execute_request' === $header['msg_type']) {
             $this->executeAction->call($header, $content);
-        } elseif ('history_request' === $header->msg_type) {
+        } elseif ('history_request' === $header['msg_type']) {
             $this->historyAction->call($header, $content);
-        } elseif ('shutdown_request' === $header->msg_type) {
+        } elseif ('shutdown_request' === $header['msg_type']) {
             $this->shutdownAction->call($header, $content);
         } else {
             // TODO: Add logger!

src/kernel.php

@@ -5,21 +5,38 @@
 namespace Litipk\JupyterPHP;
 
 
-require (__DIR__.'/../vendor/autoload.php');
+require (__DIR__.DIRECTORY_SEPARATOR.'..'.DIRECTORY_SEPARATOR.'vendor'.DIRECTORY_SEPARATOR.'autoload.php');
 
 
 use Ramsey\Uuid\Uuid;
 
 
-// Obtain settings
-$connectionSettings = ConnectionSettings::get();
-$connUris = ConnectionSettings::getConnectionUris($connectionSettings);
-
-$kernelCore = new KernelCore(
-    new JupyterBroker(
-        $connectionSettings['key'], $connectionSettings['signature_scheme'], Uuid::uuid4()
-    ),
-    $connUris
-);
-
-$kernelCore->run();
+try {
+    // Obtain settings
+    $connectionSettings = ConnectionSettings::get();
+    $connUris = ConnectionSettings::getConnectionUris($connectionSettings);
+
+    $kernelCore = new KernelCore(
+        new JupyterBroker(
+            $connectionSettings['key'], $connectionSettings['signature_scheme'], Uuid::uuid4()
+        ),
+        $connUris
+    );
+
+    $kernelCore->run();
+} catch (\Exception $e) {
+    if (
+        'linux' === strtolower(PHP_OS) &&
+        preg_match('#^(/home/([a-zA-Z0-9_]+)/\.jupyter-php)/pkgs#', __DIR__, $execDirMatch) > 0
+    ) {
+        if (!file_exists($execDirMatch[1])) {
+            mkdir($execDirMatch[1].'/logs', 0755, true);
+        }
+
+        file_put_contents(
+            $execDirMatch[1].'/logs/error.log',
+            $e->getFile().' : '.$e->getLine().' :: '.$e->getMessage()."\n\t".
+            $e->getTraceAsString()
+        );
+    }
+}