added neo4j error codes to exceptions

Author: transistive

src/Bolt/BoltUnmanagedTransaction.php

@@ -17,6 +17,7 @@
 use Bolt\error\MessageException;
 use Ds\Vector;
 use Exception;
+use Laudis\Neo4j\Common\TransactionHelper;
 use Laudis\Neo4j\Contracts\FormatterInterface;
 use Laudis\Neo4j\Contracts\UnmanagedTransactionInterface;
 use Laudis\Neo4j\Databags\Neo4jError;
@@ -62,7 +63,8 @@ public function commit(iterable $statements = []): CypherList
             $this->bolt->commit();
             $this->finished = true;
         } catch (Exception $e) {
-            throw new Neo4jException(new Vector([new Neo4jError('', $e->getMessage())]), $e);
+            $code = TransactionHelper::extractCode($e);
+            throw new Neo4jException(new Vector([new Neo4jError($code ?? '', $e->getMessage())]), $e);
         }
 
         return $tbr;
@@ -78,7 +80,8 @@ public function rollback(): void
             $this->bolt->rollback();
             $this->finished = true;
         } catch (Exception $e) {
-            throw new Neo4jException(new Vector([new Neo4jError('', $e->getMessage())]), $e);
+            $code = TransactionHelper::extractCode($e) ?? '';
+            throw new Neo4jException(new Vector([new Neo4jError($code, $e->getMessage())]), $e);
         }
     }
 
@@ -115,7 +118,8 @@ public function runStatements(iterable $statements): CypherList
                 $results = $this->bolt->pullAll();
             } catch (Throwable $e) {
                 if ($e instanceof MessageException) {
-                    throw new Neo4jException(new Vector([new Neo4jError('', $e->getMessage())]), $e);
+                    $code = TransactionHelper::extractCode($e) ?? '';
+                    throw new Neo4jException(new Vector([new Neo4jError($code, $e->getMessage())]), $e);
                 }
                 throw $e;
             }

src/Bolt/Session.php

@@ -165,7 +165,8 @@ private function startTransaction(TransactionConfiguration $config, SessionConfi
             if ($e instanceof Neo4jException) {
                 throw $e;
             }
-            throw new Neo4jException(new Vector([new Neo4jError('', $e->getMessage())]), $e);
+            $code = TransactionHelper::extractCode($e) ?? '';
+            throw new Neo4jException(new Vector([new Neo4jError($code, $e->getMessage())]), $e);
         }
 
         return new BoltUnmanagedTransaction($this->config->getDatabase(), $this->formatter, $bolt);

src/Common/TransactionHelper.php

@@ -21,6 +21,9 @@
 use Laudis\Neo4j\Databags\TransactionConfiguration;
 use Laudis\Neo4j\Exception\Neo4jException;
 use function microtime;
+use function preg_match;
+use const PREG_OFFSET_CAPTURE;
+use Throwable;
 
 final class TransactionHelper
 {
@@ -73,4 +76,19 @@ public static function enableSsl(string $host, string $sslConfig, StreamSocket $
             $sock->setSslContextOptions($options);
         }
     }
+
+    public static function extractCode(Throwable $throwable): ?string
+    {
+        $message = $throwable->getMessage();
+        $matches = [];
+        preg_match('/\(Neo\.([\w]+\.?)+\)/', $message, $matches, PREG_OFFSET_CAPTURE);
+        /** @var list<array{0: string, 1: int}> $matches */
+        if (isset($matches[0])) {
+            $code = $matches[0][0];
+
+            return str_replace(['(', ')'], '', $code);
+        }
+
+        return null;
+    }
 }

src/Exception/Neo4jException.php

@@ -42,4 +42,9 @@ public function getErrors(): Vector
     {
         return $this->errors;
     }
+
+    public function getNeo4jCode(): string
+    {
+        return $this->errors->first()->getCode();
+    }
 }

tests/Integration/TransactionIntegrationTest.php

@@ -64,6 +64,7 @@ public function testInvalidRun(string $alias): void
             $transaction->run('MERGE (x:Tes0342hdm21.())', ['test' => 'a', 'otherTest' => 'b']);
         } catch (Neo4jException $e) {
             $exception = true;
+            self::assertEquals('Neo.ClientError.Statement.SyntaxError', $e->getNeo4jCode());
         }
         self::assertTrue($exception);
     }