added the neo4j exception implementation

Author: p123-stack

src/Exception/Neo4jException.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace Neo4j\QueryAPI\Exception;
+
+use Exception;
+
+class Neo4jException extends Exception
+{
+    private string $errorCode;
+
+    public function __construct(string $errorCode, string $message, int $code = 0, Exception $previous = null)
+    {
+        $this->errorCode = $errorCode;
+        parent::__construct($message, $code, $previous);
+    }
+
+    public function getErrorCode(): string
+    {
+        return $this->errorCode;
+    }
+
+    public static function fromNeo4jResponse(array $response): self
+    {
+        $errorCode = $response['code'] ?? 'Neo.UnknownError';
+        $message = $response['message'] ?? 'An unknown error occurred.';
+        return new self($errorCode, $message);
+    }
+}

src/Neo4jQueryAPI.php

@@ -2,9 +2,11 @@
 
 namespace Neo4j\QueryAPI;
 
+use Exception;
 use GuzzleHttp\Client;
 use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Exception\RequestException;
+use Neo4j\QueryAPI\Exception\Neo4jException;
 use RuntimeException;
 use stdClass;
 
@@ -38,16 +40,35 @@ public static function login(string $address, string $username, string $password
      */
     public function run(string $cypher, array $parameters, string $database = 'neo4j'): array
     {
-        $payload = [
-            'statement' => $cypher,
-            'parameters' => $parameters  === [] ? new  stdClass() : $parameters,
-        ];
+        try {
+            // Prepare the payload for the request
+            $payload = [
+                'statement' => $cypher,
+                'parameters' => empty($parameters) ? new stdClass() : $parameters,
+            ];
 
-        $response = $this->client->post('/db/' . $database . '/query/v2', [
-            'json' => $payload,
-        ]);
-        return json_decode($response->getBody()->getContents(), true);
-    }
+            // Execute the request to the Neo4j server
+            $response = $this->client->post('/db/' . $database . '/query/v2', [
+                'json' => $payload,
+            ]);
 
+            // Decode the response body
+            return json_decode($response->getBody()->getContents(), true);
+        } catch (RequestException $e) {
+            // Catch any HTTP request errors
+            $errorResponse = [
+                'code' => 'Neo.HttpRequestError',
+                'message' => 'HTTP request failed: ' . $e->getMessage(),
+            ];
+            throw Neo4jException::fromNeo4jResponse($errorResponse);
+        } catch (Exception $e) {
+            // Catch any other unexpected errors
+            $errorResponse = [
+                'code' => 'Neo.UnknownError',
+                'message' => 'An unknown error occurred: ' . $e->getMessage(),
+            ];
+            throw Neo4jException::fromNeo4jResponse($errorResponse);
+        }
+    }
 
 }

src/Service/Neo4jClient.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace Neo4j\QueryAPI\Service;
+
+use Neo4j\QueryAPI\Exception\Neo4jException;
+use Exception;
+
+class Neo4jClient
+{
+    public function executeQuery(string $query, array $parameters): void
+    {
+        try {
+            // Simulated query execution
+            // Replace this with actual query execution using your Neo4j client.
+            throw new Exception(json_encode([
+                'code' => 'Neo.DatabaseError.Database.UnableToStartDatabase',
+                'message' => 'Unable to start database.'
+            ]));
+        } catch (Exception $e) {
+            $errorResponse = json_decode($e->getMessage(), true);
+
+            if (json_last_error() === JSON_ERROR_NONE) {
+                throw Neo4jException::fromNeo4jResponse($errorResponse);
+            }
+
+            // Fallback for unexpected exceptions
+            throw new Neo4jException('Neo.UnknownError', $e->getMessage());
+        }
+    }
+}

tests/Integration/Neo4jOGMTest.php

@@ -66,6 +66,15 @@ public static function booleanDataProvider():array
         ];
     }
 
+    public static function stringDataProvider():array
+    {
+        return [
+            ['query1', ['_value' => 'Hello, world!'], 'Hello, world!'],
+            ['query2', ['_value' => ''], ''], // Test empty string
+            ['query3', ['_value' => null], null], // Optional if null handling is needed
+        ];
+    }
+
 
     public function setUp(): void
     {
@@ -146,7 +155,7 @@ public function testWithWGS84_2DPoint(): void
 
     public function testWithWGS84_3DPoint(): void
     {
-        // Simulate mapping the raw WKT data into the Point object
+
         $point = $this->ogm->map([
             '$type' => 'Point',
             '_value' => 'SRID=4979;POINT Z (12.34 56.78 100.5)',
@@ -420,6 +429,16 @@ public function testWithBoolean(string $query, array $parameters, ?bool $expecte
         $this->assertEquals($expectedResult, $actual);
     }
 
+    #[DataProvider('stringDataProvider')]
+    public function testWithString(string $query, array $parameters, ?string $expectedResult): void
+    {
+        $actual = $this->ogm->map([
+            '$type' => 'String',
+            '_value' => $parameters['_value'],
+        ]);
+        $this->assertEquals($expectedResult, $actual);
+    }
+
 
 
 }

tests/Integration/Neo4jQueryAPIIntegrationTest.php

@@ -3,7 +3,9 @@
 namespace Neo4j\QueryAPI\Tests\Integration;
 
 use GuzzleHttp\Exception\GuzzleException;
+use Neo4j\QueryAPI\Exception\Neo4jException;
 use Neo4j\QueryAPI\Neo4jQueryAPI;
+use Neo4j\QueryAPI\Service\Neo4jClient;
 use PHPUnit\Framework\Attributes\DataProvider;
 use PHPUnit\Framework\TestCase;
 
@@ -79,6 +81,22 @@ public function testRunSuccessWithParameters(
         $this->assertEquals($expectedResults, $subsetResults);
     }
 
+    public function testInvalidQueryException(): void
+    {
+        $this->expectException(Neo4jException::class);
+
+        try {
+            $client = new Neo4jClient();
+            $client->executeQuery('CREATE (:Person {createdAt: $date})', [
+                'date' => new \DateTime('2000-01-01 00:00:00')
+            ]);
+        } catch (Neo4jException $e) {
+            $this->assertEquals('Neo.DatabaseError.Database.UnableToStartDatabase', $e->getErrorCode());
+            $this->assertEquals('Unable to start database.', $e->getMessage());
+            throw $e;
+        }
+    }
+
     private function createSubset(array $expected, array $actual): array
     {
         $subset = [];