Merge pull request repejota#69 from repejota/big_subjects

Test for big subjects message publication

Author: repejota

Makefile

@@ -9,11 +9,13 @@ cs: lint
 	./bin/phpcs --standard=PSR2 --warning-severity=0 src tests examples
 	./bin/phpcs --standard=Squiz --sniffs=Squiz.Commenting.FunctionComment,Squiz.Commenting.FunctionCommentThrowTag,Squiz.Commenting.ClassComment,Squiz.Commenting.VariableComment src tests examples
 
-test:
+test: tdd bdd
+
+tdd:
 	./vendor/bin/phpunit test
 
 bdd:
-	./vendor/bin/phpspec run --format=pretty
+	./vendor/bin/phpspec run --format=pretty -v
 
 cover:
 	./vendor/bin/phpunit --coverage-html ./cover test

spec/Nats/ConnectionSpec.php

@@ -41,7 +41,7 @@ function it_is_disconnected()
         $this->isConnected()->shouldBe(false);
     }
 
-    function it_can_connect_and_disconnect_with_default_options()
+    function it_connects_and_disconnects_with_default_options()
     {
         $this->connect();
         $this->shouldHaveType('Nats\Connection');
@@ -59,7 +59,7 @@ function it_increases_reconnects_count_on_each_reconnection()
         $this->close();
     }
 
-    function it_a_ping_is_sent_after_a_successful_connection()
+    function it_sends_ping_after_a_successful_connection()
     {
         $this->connect();
         $this->pingsCount()->shouldBe(1);
@@ -94,5 +94,30 @@ function it_decreases_subscriptions_after_unsubscribing_to_a_topic()
         $this->close();
     }
 
+    function it_sends_a_message_with_a_1024c_subject()
+    {
+        $this->connect();
+        $subject = str_pad("", 1024*1, "x");
+        $this->publish($subject);
+        $this->pubsCount()->shouldBe(1);
+        $this->close();
+    }
+
+    function it_sends_a_message_with_a_1024x10c_subject()
+    {
+        $this->connect();
+        $subject = str_pad("", 1024*10, "x");
+        $this->publish($subject);
+        $this->pubsCount()->shouldBe(1);
+        $this->close();
+    }
 
+    function it_sends_a_message_with_a_1024x100c_subject()
+    {
+        $this->connect();
+        $subject = str_pad("", 1024*100, "x");
+        $this->publish($subject);
+        $this->pubsCount()->shouldBe(1);
+        $this->close();
+    }
 }