Merge pull request #53 from clue-labs/parse-newlines

Support parsing messages with multiple newlines between messages

Author: clue

src/Protocol/Parser.php

@@ -32,15 +32,18 @@ public function push($chunk)
             $message = substr($this->buffer, 0, $pos);
             $this->buffer = (string)substr($this->buffer, $pos + self::LEOM);
 
-            $messages []= $this->parseMessage($message);
+            $parsed = $this->parseMessage($message);
+            if ($parsed->getFields()) {
+                $messages []= $parsed;
+            }
         }
 
         return $messages;
     }
 
     private function parseMessage($message)
     {
-        $lines = explode(self::EOL, $message);
+        $lines = array_filter(explode(self::EOL, $message));
         $last  = count($lines) - 1;
         $fields = array();
 

tests/Protocol/ParserTest.php

@@ -156,4 +156,19 @@ public function testParsingMissingSpaceEmptyValue()
         $this->assertInstanceOf('Clue\React\Ami\Protocol\Response', $first);
         $this->assertEquals('', $first->getFieldValue('Response'));
     }
+
+    public function testParsingExcessiveNewlines()
+    {
+        $parser = new Parser();
+        $this->assertEquals(array(), $parser->push("Asterisk Call Manager/1.3\r\n"));
+
+        $ret = $parser->push("First: 1\r\n\r\nSecond: 2\r\n\r\n\r\nThird: 3\r\n\r\n\r\n\r\nFourth: 4\r\n\r\n");
+        $this->assertCount(4, $ret);
+
+        $last = $ret[count($ret) - 1];
+        /* @var $last \Clue\React\Ami\Protocol\Response */
+
+        $this->assertInstanceOf('Clue\React\Ami\Protocol\Response', $last);
+        $this->assertEquals('4', $last->getFieldValue('Fourth'));
+    }
 }