Merge branch 'ISSUE-198' of github.com:neo4j-php/neo4j-php-client into ISSUE-198

Author: transistive

.github/workflows/integration-test-cluster-neo4j-4.yml

@@ -12,10 +12,12 @@ jobs:
   tests:
     runs-on: ubuntu-latest
     env:
-      CONNECTION: neo4j://neo4j:testtest@core1:7688
+      CONNECTION: neo4j://neo4j:testtest@localhost:7688
     name: "Running on PHP 8.1 in a Neo4j 4.4 cluster"
 
     steps:
+      - name: Ports
+        run: netstat -tulpn | grep LISTEN ; lsof -i -P -n | grep LISTEN
       - uses: actions/checkout@v2
       - name: Cache Composer dependencies
         uses: actions/cache@v2

src/Bolt/BoltConnection.php

@@ -201,10 +201,6 @@ public function begin(?string $database, ?float $timeout, BookmarkHolder $holder
      */
     public function discard(?int $qid): void
     {
-        if (!in_array($this->protocol()->serverState, [ServerState::STREAMING, ServerState::TX_STREAMING], true)) {
-            throw new Neo4jException([Neo4jError::fromMessageAndCode('Neo.ClientError.Request.Invalid', 'Message \'DISCARD\' cannot be handled by a session which isn\'t in the STREAMING|TX_STREAMING state.')]);
-        }
-
         $extra = $this->buildResultExtra(null, $qid);
         $response = $this->protocol()
             ->discard($extra)
@@ -221,10 +217,6 @@ public function discard(?int $qid): void
      */
     public function run(string $text, array $parameters, ?string $database, ?float $timeout, BookmarkHolder $holder, ?AccessMode $mode): array
     {
-        if (!in_array($this->protocol()->serverState, [ServerState::READY, ServerState::TX_READY, ServerState::TX_STREAMING], true)) {
-            throw new Neo4jException([Neo4jError::fromMessageAndCode('Neo.ClientError.Request.Invalid', 'Message \'RUN\' cannot be handled by a session which isn\'t in the READY|TX_READY|TX_STREAMING state.')]);
-        }
-
         $extra = $this->buildRunExtra($database, $timeout, $holder, $mode);
         $response = $this->protocol()
             ->run($text, $parameters, $extra)
@@ -243,10 +235,6 @@ public function commit(): void
     {
         $this->consumeResults();
 
-        if ($this->protocol()->serverState !== ServerState::TX_READY) {
-            throw new Neo4jException([Neo4jError::fromMessageAndCode('Neo.ClientError.Request.Invalid', 'Message \'COMMIT\' cannot be handled by a session which isn\'t in the TX_READY state.')]);
-        }
-
         $response = $this->protocol()
             ->commit()
             ->getResponse();
@@ -286,10 +274,6 @@ public function protocol(): V4_4|V5|V5_3|V5_4
      */
     public function pull(?int $qid, ?int $fetchSize): array
     {
-        if (!in_array($this->protocol()->serverState, [ServerState::STREAMING, ServerState::TX_STREAMING], true)) {
-            throw new Neo4jException([Neo4jError::fromMessageAndCode('Neo.ClientError.Request.Invalid', 'Message \'PULL\' cannot be handled by a session which isn\'t in the STREAMING|TX_STREAMING state.')]);
-        }
-
         $extra = $this->buildResultExtra($fetchSize, $qid);
 
         $tbr = [];