made error handling more precise #63

Author: transistive

src/Bolt/BoltUnmanagedTransaction.php

@@ -14,6 +14,7 @@
 namespace Laudis\Neo4j\Bolt;
 
 use Bolt\Bolt;
+use Bolt\error\MessageException;
 use Ds\Vector;
 use Exception;
 use Laudis\Neo4j\Contracts\FormatterInterface;
@@ -81,16 +82,25 @@ public function rollback(): void
         }
     }
 
+    /**
+     * @throws Throwable
+     */
     public function run(string $statement, iterable $parameters = [])
     {
         return $this->runStatement(new Statement($statement, $parameters));
     }
 
+    /**
+     * @throws Throwable
+     */
     public function runStatement(Statement $statement)
     {
         return $this->runStatements([$statement])->first();
     }
 
+    /**
+     * @throws Throwable
+     */
     public function runStatements(iterable $statements): CypherList
     {
         /** @var Vector<T> $tbr */
@@ -104,7 +114,10 @@ public function runStatements(iterable $statements): CypherList
                 /** @var array<array> $results */
                 $results = $this->bolt->pullAll();
             } catch (Throwable $e) {
-                throw new Neo4jException(new Vector([new Neo4jError('', $e->getMessage())]), $e);
+                if ($e instanceof MessageException) {
+                    throw new Neo4jException(new Vector([new Neo4jError('', $e->getMessage())]), $e);
+                }
+                throw $e;
             }
             $tbr->push($this->formatter->formatBoltResult($meta, $results, $this->bolt));
         }