Merge branch 'Issue-#2'

src/Client.php

@@ -75,7 +75,7 @@ private function receiveData(int $timeout, int $size, string $previousData = '')
         }
         $data = $previousData . $data;
 
-        if (strlen($data) != $size) {
+        if (strlen($data) < $size) {
             usleep(self::SLEEP_TIME);
             return $this->receiveData($timeout, $size, $data);
         }

src/Protocol/ExtensionResponseStructure.php

@@ -35,7 +35,7 @@ public function decode(string $data): Response
         $extensionSize = $baseData['res'];
         $fullSize = $extensionSize + Response::BASE_SIZE;
 
-        if (strlen($data) != $fullSize) {
+        if (strlen($data) < $fullSize) {
             throw new IncompleteDataException("Received data is incomplete => expected $fullSize bytes, but got " . strlen($data), $fullSize);
         }
 

tests/ClientTest.php

@@ -7,6 +7,7 @@
 use Volantus\Pigpio\Client;
 use Volantus\Pigpio\Protocol\DefaultRequest;
 use Volantus\Pigpio\Protocol\DefaultResponseStructure;
+use Volantus\Pigpio\Protocol\ExtensionResponseStructure;
 use Volantus\Pigpio\Protocol\IncompleteDataException;
 use Volantus\Pigpio\Protocol\Response;
 use Volantus\Pigpio\Protocol\ResponseStructure;
@@ -34,7 +35,7 @@ protected function setUp()
         $this->service = new Client($this->socket);
     }
 
-    public function test_sendRaw_correct()
+    public function test_sendRaw_correct_defaultRequest()
     {
         $expectedResponse = new Response(0, null);
 
@@ -59,6 +60,31 @@ public function test_sendRaw_correct()
         self::assertSame($result, $expectedResponse);
     }
 
+    public function test_sendRaw_correct_extensionRequest()
+    {
+        $expectedResponse = new Response(0, ['Q', 'R']);
+
+        $responseStructure = $this->getMockBuilder(ExtensionResponseStructure::class)->disableOriginalConstructor()->getMock();
+        $responseStructure->expects(self::once())
+            ->method('decode')
+            ->with(self::equalTo('ABCDEFGHIJKLMNOPQR'))
+            ->willReturn($expectedResponse);
+
+        $request = new DefaultRequest(8, 21, 1500, $responseStructure);
+
+        $this->socket->expects(self::once())
+            ->method('send')
+            ->with(self::equalTo($request->encode()));
+
+        $this->socket->expects(self::once())
+            ->method('listen')
+            ->willReturn('ABCDEFGHIJKLMNOPQR');
+
+        $result = $this->service->sendRaw($request);
+
+        self::assertSame($result, $expectedResponse);
+    }
+
     public function test_sendRaw_headerNotComplete()
     {
         $expectedResponse = new Response(0, null);