Modify socket reading

src/YeePHP.php

@@ -372,7 +372,7 @@ protected function connect(): bool
         $sock = fsockopen($this->lightIP, $this->lightPort, $errCode, $errStr, 30);
         if (!$sock) return false;
 
-        // stream_set_blocking($sock, false);
+        stream_set_blocking($sock, false);
         $this->socket = $sock;
 
         return true;
@@ -451,10 +451,11 @@ protected function makeRequest(array $job): ?array
         fwrite($this->socket, $requestStr);
         fflush($this->socket);
 
-        // usleep(100 * 1000); // 0.7s -> wait for the light response 
+        usleep(100 * 1000); // 0.7s -> wait for the light response 
 
-
-        $res = fgets($this->socket);
+        $res = '';
+        while ($out = stream_get_line($this->socket, 4096, "\r\n"))
+            $res = $out;
 
 
         $result = null;
@@ -464,9 +465,10 @@ protected function makeRequest(array $job): ?array
 
             if (!array_key_exists('error', $res) && array_key_exists('result', $res))
                 $result = $res['result'];
+        } else {
+            throw new Exception('No response received from device !');
         }
 
-
         return $result;
     }
 

tests/LightTest.php

@@ -13,7 +13,7 @@ class LightTest extends TestCase
      *
      * @var string
      */
-    private string $ip = '192.168.0.103';
+    private string $ip = '192.168.1.21';
 
     private YeePHP $light;