Merge pull request #85 from neo4j-php/long-query-fixes

Long query fixes

Author: transistive

.github/workflows/db-tests.yml

@@ -20,6 +20,7 @@ jobs:
         image: neo4j:${{ matrix.neo4j-version }}
         env:
           NEO4J_AUTH: neo4j/nothing
+          NEO4JLABS_PLUGINS: '["apoc"]'
         ports:
           - 7687:7687
           - 7474:7474

src/connection/Socket.php

@@ -153,7 +153,8 @@ private function throwConnectException(): void
             if ($timediff >= $this->timeout) {
                 throw ConnectionTimeoutException::createFromTimeout($this->timeout);
             }
+        } else if ($code !== 0) {
+            throw new ConnectException(socket_strerror($code), $code);
         }
-        throw new ConnectException(socket_strerror($code), $code);
     }
 }

src/connection/StreamSocket.php

@@ -100,9 +100,6 @@ public function read(int $length = 2048): string
         if (stream_get_meta_data($this->stream)["timed_out"])
             throw ConnectionTimeoutException::createFromTimeout($this->timeout);
 
-        if (empty($res))
-            throw new ConnectException('Read error');
-
         if (Bolt::$debug)
             $this->printHex($res, false);
 

src/protocol/AProtocol.php

@@ -71,7 +71,7 @@ protected function read(?int &$signature)
         $msg = '';
         while (true) {
             $header = $this->connection->read(2);
-            if (ord($header[0]) == 0x00 && ord($header[1]) == 0x00)
+            if ($msg !== '' && ord($header[0]) == 0x00 && ord($header[1]) == 0x00)
                 break;
             $length = unpack('n', $header)[1] ?? 0;
             $msg .= $this->connection->read($length);

tests/connection/AConnectionTest.php

@@ -45,6 +45,22 @@ public function testMillisecondTimeout(string $alias): void
         }
     }
 
+
+    /**
+     * @dataProvider provideConnections
+     *
+     * @doesNotPerformAssertions
+     */
+    public function testLongNoTimeout(string $alias): void
+    {
+        $socket = $this->getConnection($alias);
+        $protocol = (new Bolt($socket))->build();
+        $socket->setTimeout(200);
+        $protocol->init(Auth::basic($GLOBALS['NEO_USER'], $GLOBALS['NEO_PASS']));
+
+        $protocol->run('CALL apoc.util.sleep(150000)', [], ['tx_timeout' => 150000]);
+    }
+
     /**
      * @dataProvider provideConnections
      */