Trying to test with a process in background, but i couldn't

Author: jgil

composer.json

@@ -10,6 +10,7 @@
         "homepage": "http://repejota.com"
     }],
     "require": {
+        "cocur/background-process": "dev-master"
     },
     "require-dev": {
         "phpunit/phpunit": "4.7.*",

phpunit.xml.dist

@@ -16,5 +16,7 @@
     </testsuites>
     <logging>
         <log type="coverage-clover" target="build/logs/clover.xml"/>
+        <log type="coverage-html" target="./build/coverage" lowUpperBound="35"
+             highLowerBound="70"/>
     </logging>
 </phpunit>

tests/Unit/ClientServerStub.php

@@ -0,0 +1,63 @@
+<?php
+
+namespace Nats\tests\Unit;
+
+require 'vendor/autoload.php';
+use Cocur\BackgroundProcess\BackgroundProcess;
+
+
+class ClientServerStub
+{
+    protected $client;
+
+    protected $sock;
+
+    protected $addr;
+
+    protected $port;
+
+    public function __construct()
+    {
+        $this->sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+        socket_connect($this->sock, 'localhost', 55555);
+    }
+
+    public function write()
+    {
+        socket_write($this->sock, "PUBLISH");
+
+    }
+
+    public function close()
+    {
+        socket_close($this->sock);
+    }
+
+    public function read()
+    {
+        // Read the input from the client &#8211; 1024 bytes
+        $input = socket_read($client, 1024);
+
+        return $input;
+    }
+
+    public function getAddr()
+    {
+        return $this->addr;
+    }
+
+    public function getPort()
+    {
+        return $this->port;
+    }
+
+    public function getSock()
+    {
+        return $this->sock;
+    }
+}
+
+$client = new ClientServerStub();
+$client->write();
+
+$client->close();

tests/Unit/ConnectionTest.php

@@ -1,57 +1,73 @@
 <?php
+
 /**
- * TestConnection Class
+ * TestConnection Class.
  *
  * PHP version 5
  *
  * @category Class
- * @package  Nats\Tests\Unit
+ *
  * @author   Raül Përez <[email protected]>
  * @license  http://opensource.org/licenses/MIT The MIT License (MIT)
+ *
  * @link     https://github.com/repejota/phpnats
  */
-namespace Nats\Tests\Unit;
+
+namespace Nats\tests\Unit;
 
 use Nats;
+use Cocur\BackgroundProcess\BackgroundProcess;
+
+
 
 /**
- * Class TestConnection
+ * Class TestConnection.
  *
  * @category Class
- * @package  Nats\Tests\Unit
+ *
  * @author   Raül Përez <[email protected]>
  * @license  http://opensource.org/licenses/MIT The MIT License (MIT)
+ *
  * @link     https://github.com/repejota/phpnats
  */
-class TestConnection extends \PHPUnit_Framework_TestCase
+class ConnectionTest extends \PHPUnit_Framework_TestCase
 {
     private $_c;
 
-    /**
-     * Setup tests
-     *
-     * @return null
-     */
+    private static $_process;
+
+    private static $_port;
+
+    public static function setUpBeforeClass()
+    {
+
+        self::$_process = new BackgroundProcess('/usr/bin/php tests/Unit/ListeningServerStub.php &');
+        self::$_process->run();
+
+    }
+
+    public static function tearDownAfterClass()
+    {
+        self::$_process->stop();
+        //socket_close(self::$_server);
+    }
+
     public function setUp()
     {
-        $this->_c = new Nats\Connection();
+        $this->_c = new Nats\Connection('localhost', 55555);
         $this->_c->connect();
     }
 
     /**
-     * Test Dummy
-     *
-     * @return null
+     * Test Dummy.
      */
     public function testDummy()
     {
         $this->assertTrue(true);
     }
 
     /**
-     * Test Connection
-     *
-     * @return null
+     * Test Connection.
      */
     public function testConnection()
     {
@@ -65,66 +81,61 @@ public function testConnection()
     }
 
     /**
-     * Test Ping command
-     *
-     * @return null
+     * Test Ping command.
      */
     public function testPing()
     {
         $this->_c->ping();
         $count = $this->_c->pingsCount();
-        $this->assertInternalType("int", $count);
+        $this->assertInternalType('int', $count);
         $this->assertGreaterThan(0, $count);
         $this->_c->close();
     }
 
     /**
-     * Test Publish command
-     *
-     * @return null
+     * Test Publish command.
      */
     public function testPublish()
     {
-        $this->_c->publish("foo", "bar");
+        $this->_c->publish('foo', 'bar');
         $count = $this->_c->pubsCount();
-        $this->assertInternalType("int", $count);
+        $this->assertInternalType('int', $count);
         $this->assertGreaterThan(0, $count);
         $this->_c->close();
     }
 
     /**
-     * Test Server reconnection
-     *
-     * @return null
+     * Test Reconnect command.
      */
     public function testReconnect()
     {
         $this->_c->reconnect();
         $count = $this->_c->reconnectsCount();
-        $this->assertInternalType("int", $count);
+        $this->assertInternalType('int', $count);
         $this->assertGreaterThan(0, $count);
         $this->_c->close();
     }
 
     /**
-     * Test Server subscription
-     *
-     * @return null
+     * Test Subscription command.
      */
     public function testSubscription()
     {
         $callback = function ($message) {
             $this->assertNotNull($message);
-            $this->assertEquals($message, "bar");
+            $this->assertEquals($message, 'bar');
         };
-        $this->_c->subscribe("foo", $callback);
+        $this->_c->subscribe('foo', $callback);
         $this->assertGreaterThan(0, $this->_c->subscriptionsCount());
-
         $subscriptions = $this->_c->getSubscriptions();
-        $this->assertInternalType("array", $subscriptions);
+        $this->assertInternalType('array', $subscriptions);
 
-        $this->_c->publish("foo", "bar");
-        $this->_c->wait(1);
+        $this->_c->publish('foo', 'bar');
+        $this->assertEquals(1, $this->_c->pubsCount());
+        // $this->_c->wait(1);
     }
 
+    public function testWait()
+    {
+    }
 }

tests/Unit/ListeningServerStub.php

@@ -0,0 +1,86 @@
+<?php
+
+namespace Nats\tests\Unit;
+
+require 'vendor/autoload.php';
+
+
+class ListeningServerStub
+{
+    protected $client;
+
+    protected $sock;
+
+    protected $addr;
+
+    protected $port;
+
+    public function __construct()
+    {
+        try {
+            if (($this->sock = socket_create_listen(55555)) === false) {
+                echo socket_strerror(socket_last_error());
+            } else {
+                echo "Socket created\n";
+            }
+
+            socket_getsockname($this->sock, $this->addr, $this->port);
+        } catch (\Exception $e) {
+            echo $e->getMessage();
+        }
+    }
+
+    public function listen()
+    {
+
+        // Bind the socket to an address/port
+
+        // Start listening for connections
+        socket_listen($this->sock);
+
+        // Accept incoming requests and handle them as child processes.
+        $this->client = socket_accept($this->sock);
+    }
+
+    public function close()
+    {
+        socket_close($this->sock);
+    }
+
+    public function read()
+    {
+        // Read the input from the client &#8211; 1024 bytes
+        $input = socket_read($client, 1024);
+
+        return $input;
+    }
+
+    public function getAddr()
+    {
+        return $this->addr;
+    }
+
+    public function getPort()
+    {
+        return $this->port;
+    }
+
+    public function getSock()
+    {
+        return $this->sock;
+    }
+}
+
+$server = new ListeningServerStub();
+
+while (true) {
+    $clientSocket = socket_accept($server->getSock());
+    if (false == $clientSocket) {
+        continue;
+    }
+    var_dump($clientSocket);
+}
+
+$server->close();
+// echo "Start listening...";
+// $server->listen();