Merge remote-tracking branch 'origin/main' into pratiksha

Author: p123-stack

composer.lock

@@ -6,6 +6,7 @@
 use GuzzleHttp\Client;
 use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Exception\RequestException;
+use Neo4j\QueryAPI\Results\ResultSet;
 use Neo4j\QueryAPI\Exception\Neo4jException;
 use Psr\Http\Client\RequestExceptionInterface;
 use RuntimeException;
@@ -40,7 +41,7 @@ public static function login(string $address, string $username, string $password
      * @throws Neo4jException
      * @throws RequestExceptionInterface
      */
-    public function run(string $cypher, array $parameters, string $database = 'neo4j'): array
+    public function run(string $cypher, array $parameters, string $database = 'neo4j'): ResultSet
     {
         try {
             // Prepare the payload for the request
@@ -55,7 +56,10 @@ public function run(string $cypher, array $parameters, string $database = 'neo4j
             ]);
 
             // Decode the response body
-            return json_decode($response->getBody()->getContents(), true);
+            $data = json_decode($response->getBody()->getContents(), true);
+            $ogm = new OGM();
+
+            return new ResultSet($data['data']['fields'], $data['data']['values'], $ogm);
         } catch (RequestExceptionInterface $e) {
             $response = $e->getResponse();
             if ($response !== null) {

src/Neo4jQueryAPI.php

@@ -9,6 +9,10 @@
 
 class OGM
 {
+    /**
+     * @param array{'$type': string, '_value': mixed} $object
+     * @return mixed
+     */
     public function map(array $object): mixed
     {
         return match ($object['$type']) {

src/OGM.php

@@ -0,0 +1,73 @@
+<?php
+
+//namespace Neo4j\QueryAPI\Results;
+//
+//use Neo4j\QueryAPI\OGM;
+//
+//class ResultRow
+//{
+//    public function __construct(private array $keys, private array $resultRow, private OGM $ogm)
+//    {
+//        $this->values = [];
+//        foreach ($this->resultRow as $index => $value) {
+//            $this->values[$this->keys[$index]] = $value['_value'];
+//        }
+//    }
+//
+//    public function get(string $column): mixed
+//    {
+//        return $this->values[$column] ?? null;
+//    }
+//}
+
+
+
+
+namespace Neo4j\QueryAPI\Results;
+
+
+use BadMethodCallException;
+use Neo4j\QueryAPI\OGM;
+use OutOfBoundsException;
+use ArrayAccess;
+
+class ResultRow implements ArrayAccess
+{
+    public function __construct(private array $data)
+    {
+    }
+
+
+    public function offsetExists($offset): bool
+    {
+        return isset($this->data[$offset]);
+    }
+
+    public function offsetGet($offset): mixed
+    {
+        if (!$this->offsetExists($offset)) {
+            throw new OutOfBoundsException("Column {$offset} not found.");
+        }
+        return $this->data[$offset];
+    }
+
+    public function offsetSet($offset, $value): void
+    {
+        throw new BadMethodCallException("You cant set the value of column {$offset}.");
+    }
+    public function offsetUnset($offset): void
+    {
+            throw new BadMethodCallException("You cant Unset {$offset}.");
+
+    }
+
+
+    public function get(string $row): mixed
+    {
+        return $this->offsetGet($row);
+    }
+
+
+}
+
+