Passing test without nats

Author: jgil

phpunit.xml.dist

@@ -9,9 +9,10 @@
          processIsolation="false"
          stopOnFailure="false"
          syntaxCheck="false">
+
     <testsuites>
         <testsuite name="PHPNats Test Suite">
-            <directory suffix=".php">./tests/</directory>
+            <directory suffix=".php">./tests/Unit/</directory>
         </testsuite>
     </testsuites>
     <logging>

tests/Unit/ConnectionTest.php

@@ -18,10 +18,8 @@
 use Nats;
 use Cocur\BackgroundProcess\BackgroundProcess;
 
-
-
 /**
- * Class TestConnection.
+ * Class ConnectionTest.
  *
  * @category Class
  *
@@ -36,35 +34,24 @@ class ConnectionTest extends \PHPUnit_Framework_TestCase
 
     private static $_process;
 
-    private static $_port;
-
     public static function setUpBeforeClass()
     {
-
-        self::$_process = new BackgroundProcess('/usr/bin/php tests/Unit/ListeningServerStub.php &');
+        self::$_process = new BackgroundProcess('/usr/bin/php ./tests/Util/ListeningServerStub.php ');
         self::$_process->run();
-
     }
 
     public static function tearDownAfterClass()
     {
         self::$_process->stop();
-        //socket_close(self::$_server);
     }
 
     public function setUp()
     {
+        time_nanosleep(0, 100000000);
         $this->_c = new Nats\Connection('localhost', 55555);
         $this->_c->connect();
     }
 
-    /**
-     * Test Dummy.
-     */
-    public function testDummy()
-    {
-        $this->assertTrue(true);
-    }
 
     /**
      * Test Connection.
@@ -97,6 +84,7 @@ public function testPing()
      */
     public function testPublish()
     {
+        $this->_c->ping();
         $this->_c->publish('foo', 'bar');
         $count = $this->_c->pubsCount();
         $this->assertInternalType('int', $count);
@@ -132,10 +120,9 @@ public function testSubscription()
 
         $this->_c->publish('foo', 'bar');
         $this->assertEquals(1, $this->_c->pubsCount());
-        // $this->_c->wait(1);
-    }
+        $process = new BackgroundProcess('/usr/bin/php ./tests/Util/ClientServerStub.php ');
+        $process->run();
 
-    public function testWait()
-    {
+        $this->_c->wait(1);
     }
 }

tests/Unit/ClientServerStub.php renamed to tests/Util/ClientServerStub.php

@@ -1,9 +1,8 @@
 <?php
 
-namespace Nats\tests\Unit;
+namespace Nats\tests\Util;
 
 require 'vendor/autoload.php';
-use Cocur\BackgroundProcess\BackgroundProcess;
 
 
 class ClientServerStub
@@ -24,7 +23,7 @@ public function __construct()
 
     public function write()
     {
-        socket_write($this->sock, "PUBLISH");
+        socket_write($this->sock, "PING");
 
     }
 
@@ -36,7 +35,7 @@ public function close()
     public function read()
     {
         // Read the input from the client &#8211; 1024 bytes
-        $input = socket_read($client, 1024);
+        $input = socket_read($this->sock, 1024);
 
         return $input;
     }
@@ -58,6 +57,10 @@ public function getSock()
 }
 
 $client = new ClientServerStub();
+sleep(1);
 $client->write();
 
+// echo $client->read(100);
+
 $client->close();
+

tests/Unit/ListeningServerStub.php renamed to tests/Util/ListeningServerStub.php

@@ -1,10 +1,12 @@
 <?php
 
-namespace Nats\tests\Unit;
+namespace Nats\tests\Util;
 
 require 'vendor/autoload.php';
 
 
+use Nats\tests\Util\ClientServerStub;
+
 class ListeningServerStub
 {
     protected $client;
@@ -23,18 +25,16 @@ public function __construct()
             } else {
                 echo "Socket created\n";
             }
-
             socket_getsockname($this->sock, $this->addr, $this->port);
+            time_nanosleep(0, 100);
+        
         } catch (\Exception $e) {
             echo $e->getMessage();
         }
     }
 
     public function listen()
     {
-
-        // Bind the socket to an address/port
-
         // Start listening for connections
         socket_listen($this->sock);
 
@@ -72,15 +72,38 @@ public function getSock()
 }
 
 $server = new ListeningServerStub();
+$time=8;
+
+/*
+$client = new ClientServerStub();
+*/
+
 
-while (true) {
+while ($time>0) {
+    time_nanosleep(1, 100);
     $clientSocket = socket_accept($server->getSock());
-    if (false == $clientSocket) {
+var_dump($clientSocket);
+
+
+file_put_contents("/tmp/a.txt", "aaaa\n", FILE_APPEND);
+    if(!is_null($clientSocket)) {
+        $lll = socket_read($clientSocket, 100000);
+        $line = "MSG OK 55966a4463383 10";
+        $line = "PING";
+        socket_write($clientSocket, $line);
+    } else {
+        $client->write();
+        $line = "PING";
+echo $line;
+file_put_contents("/tmp/a.txt", $line."\n", FILE_APPEND);
+        socket_write($server->getSock(), $line);
+//        echo $client->write(100);
+        time_nanosleep(0, 20000);
         continue;
+    
     }
-    var_dump($clientSocket);
+    $time--;
 }
 
+$client->close();
 $server->close();
-// echo "Start listening...";
-// $server->listen();