git branch (monday.com)

Author: 123kiran17

src/Configuration.php

@@ -0,0 +1,89 @@
+<?php
+
+namespace Neo4j\QueryAPI;
+
+class Configuration
+{
+    private string $baseUrl;
+    private string $authToken;
+    private array $defaultHeaders;
+
+    public function __construct(
+        string $baseUrl = 'https://localhost:7474',
+        string $authToken = '',
+        array $defaultHeaders = []
+    ) {
+        $this->baseUrl = $baseUrl;
+        $this->authToken = $authToken;
+        $this->defaultHeaders = $defaultHeaders;
+    }
+
+    /**
+     * Set the base URL of the API.
+     *
+     * @param string $baseUrl
+     * @return self
+     */
+    public function setBaseUrl(string $baseUrl): self
+    {
+        $this->baseUrl = $baseUrl;
+        return $this;
+    }
+
+    /**
+     * Set the authentication token.
+     *
+     * @param string $authToken
+     * @return self
+     */
+    public function setAuthToken(string $authToken): self
+    {
+        $this->authToken = $authToken;
+        return $this;
+    }
+
+    /**
+     * Set default headers for API requests.
+     *
+     * @param array $headers
+     * @return self
+     */
+    public function setDefaultHeaders(array $headers): self
+    {
+        $this->defaultHeaders = $headers;
+        return $this;
+    }
+
+    /**
+     * Get the base URL of the API.
+     *
+     * @return string
+     */
+    public function getBaseUrl(): string
+    {
+        return $this->baseUrl;
+    }
+
+    /**
+     * Get the authentication token.
+     *
+     * @return string
+     */
+    public function getAuthToken(): string
+    {
+        return $this->authToken;
+    }
+
+    /**
+     * Get the default headers for API requests.
+     *
+     * @return array
+     */
+    public function getDefaultHeaders(): array
+    {
+        return array_merge($this->defaultHeaders, [
+            'Authorization' => 'Bearer ' . $this->authToken,
+            'Content-Type' => 'application/json',
+        ]);
+    }
+}

src/Neo4jQueryAPI.php

@@ -2,150 +2,83 @@
 
 namespace Neo4j\QueryAPI;
 
-use Exception;
 use GuzzleHttp\Client;
-use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Exception\RequestException;
-use InvalidArgumentException;
-use Neo4j\QueryAPI\Objects\ChildQueryPlan;
-use Neo4j\QueryAPI\Objects\QueryArguments;
-use Neo4j\QueryAPI\Objects\ResultCounters;
-use Neo4j\QueryAPI\Objects\ProfiledQueryPlan;
-use Neo4j\QueryAPI\Results\ResultRow;
+use Neo4j\QueryAPI\Enums\AccessMode;
+use Neo4j\QueryAPI\Objects\Bookmarks;
 use Neo4j\QueryAPI\Results\ResultSet;
 use Neo4j\QueryAPI\Exception\Neo4jException;
 use Psr\Http\Client\RequestExceptionInterface;
-use RuntimeException;
-use stdClass;
-use Neo4j\QueryAPI\Objects\Bookmarks;
-use Neo4j\QueryAPI\Enums\AccessMode;
-
+use Psr\Http\Message\ResponseInterface;
 
 class Neo4jQueryAPI
 {
-
     private Client $client;
+    private Configuration $config;
+    private ResponseParser $responseParser;
 
-    public function __construct(Client $client)
+    public function __construct(Configuration $config, ResponseParser $responseParser)
     {
-        $this->client = $client;
+        $this->config = $config;
+        $this->responseParser = $responseParser;
+
+        $this->client = new Client([
+            'base_uri' => rtrim($this->config->getBaseUrl(), '/'),
+            'timeout' => 10.0,
+            'headers' => $this->config->getDefaultHeaders(),
+        ]);
     }
+
     /**
-     * @api
+     * Static method to create an instance with login details.
      */
     public static function login(string $address, string $username, string $password): self
     {
+        $authToken = base64_encode("$username:$password");
+        $config = (new Configuration())
+            ->setBaseUrl($address)
+            ->setAuthToken($authToken);
 
-
-        $client = new Client([
-            'base_uri' => rtrim($address, '/'),
-            'timeout' => 10.0,
-            'headers' => [
-                'Authorization' => 'Basic ' . base64_encode("$username:$password"),
-                'Content-Type' => 'application/vnd.neo4j.query',
-                'Accept' => 'application/vnd.neo4j.query',
-            ],
-        ]);
-
-        return new self($client);
+        return new self($config, new ResponseParser(new OGM()));
     }
 
     /**
-     * @throws Neo4jException
-     * @throws RequestExceptionInterface
-     * @api
+     * Executes a Cypher query.
+     *
+     * @throws Neo4jException|RequestExceptionInterface
      */
     public function run(string $cypher, array $parameters = [], string $database = 'neo4j', Bookmarks $bookmark = null, ?string $impersonatedUser = null, AccessMode $accessMode = AccessMode::WRITE): ResultSet
     {
         try {
             $payload = [
                 'statement' => $cypher,
-                'parameters' => empty($parameters) ? new stdClass() : $parameters,
+                'parameters' => empty($parameters) ? new \stdClass() : $parameters,
                 'includeCounters' => true,
                 'accessMode' => $accessMode->value,
             ];
 
-
             if ($bookmark !== null) {
                 $payload['bookmarks'] = $bookmark->getBookmarks();
             }
+
             if ($impersonatedUser !== null) {
                 $payload['impersonatedUser'] = $impersonatedUser;
             }
 
-            $response = $this->client->post('/db/' . $database . '/query/v2', [
-                'json' => $payload,
-            ]);
+            $response = $this->client->post("/db/{$database}/query/v2", ['json' => $payload]);
 
-            $data = json_decode($response->getBody()->getContents(), true);
-
-            $ogm = new OGM();
-
-            $keys = $data['data']['fields'];
-            $values = $data['data']['values'];
-
-            $rows = array_map(function ($resultRow) use ($ogm, $keys) {
-                $data = [];
-                foreach ($keys as $index => $key) {
-                    $fieldData = $resultRow[$index] ?? null;
-                    $data[$key] = $ogm->map($fieldData);
-                }
-                return new ResultRow($data);
-            }, $values);
-
-            $profile = null;
-            if (isset($data['profiledQueryPlan'])) {
-                $profile = $this->createProfileData($data['profiledQueryPlan']);
-            }
-
-            $resultCounters = new ResultCounters(
-                containsUpdates: $data['counters']['containsUpdates'] ?? false,
-                nodesCreated: $data['counters']['nodesCreated'] ?? 0,
-                nodesDeleted: $data['counters']['nodesDeleted'] ?? 0,
-                propertiesSet: $data['counters']['propertiesSet'] ?? 0,
-                relationshipsCreated: $data['counters']['relationshipsCreated'] ?? 0,
-                relationshipsDeleted: $data['counters']['relationshipsDeleted'] ?? 0,
-                labelsAdded: $data['counters']['labelsAdded'] ?? 0,
-                labelsRemoved: $data['counters']['labelsRemoved'] ?? 0,
-                indexesAdded: $data['counters']['indexesAdded'] ?? 0,
-                indexesRemoved: $data['counters']['indexesRemoved'] ?? 0,
-                constraintsAdded: $data['counters']['constraintsAdded'] ?? 0,
-                constraintsRemoved: $data['counters']['constraintsRemoved'] ?? 0,
-                containsSystemUpdates: $data['counters']['containsSystemUpdates'] ?? false,
-                systemUpdates: $data['counters']['systemUpdates'] ?? 0
-            );
-
-            return new ResultSet(
-                $rows,
-                $resultCounters,
-                new Bookmarks($data['bookmarks'] ?? []),
-                $profile,
-                $accessMode
-            );
-        } catch (RequestExceptionInterface $e) {
-            error_log("Request Exception: " . $e->getMessage());
-
-            $response = $e->getResponse();
-            if ($response !== null) {
-                $contents = $response->getBody()->getContents();
-                $errorResponse = json_decode($contents, true);
-                throw Neo4jException::fromNeo4jResponse($errorResponse, $e);
-            }
-
-
-            throw new Neo4jException(['message' => $e->getMessage()], 500, $e);
+            return $this->responseParser->parseRunQueryResponse($response);
+        } catch (RequestException $e) {
+            $this->handleRequestException($e);
         }
     }
 
-
-
     /**
-     * @api
+     * Starts a transaction.
      */
     public function beginTransaction(string $database = 'neo4j'): Transaction
     {
-        unset($database);
-        $response = $this->client->post("/db/neo4j/query/v2/tx");
+        $response = $this->client->post("/db/{$database}/query/v2/tx");
 
         $clusterAffinity = $response->getHeaderLine('neo4j-cluster-affinity');
         $responseData = json_decode($response->getBody(), true);
@@ -154,49 +87,19 @@ public function beginTransaction(string $database = 'neo4j'): Transaction
         return new Transaction($this->client, $clusterAffinity, $transactionId);
     }
 
-    private function createProfileData(array $data): ProfiledQueryPlan
+    /**
+     * Handles request exceptions by parsing error details and throwing a Neo4jException.
+     *
+     * @throws Neo4jException
+     */
+    private function handleRequestException(RequestExceptionInterface $e): void
     {
-        $arguments = $data['arguments'];
-
-        $queryArguments = new QueryArguments(
-            $arguments['globalMemory'] ?? 0,
-            $arguments['plannerImpl'] ?? '',
-            $arguments['memory'] ?? 0,
-            $arguments['stringRepresentation'] ?? '',
-            is_string($arguments['runtime'] ?? '') ? $arguments['runtime'] : json_encode($arguments['runtime']),
-            $arguments['runtimeImpl'] ?? '',
-            $arguments['dbHits'] ?? 0,
-            $arguments['batchSize'] ?? 0,
-            $arguments['details'] ?? '',
-            $arguments['plannerVersion'] ?? '',
-            $arguments['pipelineInfo'] ?? '',
-            $arguments['runtimeVersion'] ?? '',
-            $arguments['id'] ?? 0,
-            $arguments['estimatedRows'] ?? 0.0,
-            is_string($arguments['planner'] ?? '') ? $arguments['planner'] : json_encode($arguments['planner']),
-            $arguments['rows'] ?? 0
-        );
-
-        $profiledQueryPlan = new ProfiledQueryPlan(
-            $data['dbHits'],
-            $data['records'],
-            $data['hasPageCacheStats'],
-            $data['pageCacheHits'],
-            $data['pageCacheMisses'],
-            $data['pageCacheHitRatio'],
-            $data['time'],
-            $data['operatorType'],
-            $queryArguments
-        );
-
-        foreach($data['children'] as $child) {
-            $childQueryPlan = $this->createProfileData($child);
-
-            $profiledQueryPlan->addChild($childQueryPlan);
+        $response = $e->getResponse();
+        if ($response instanceof ResponseInterface) {
+            $errorResponse = json_decode((string)$response->getBody(), true);
+            throw Neo4jException::fromNeo4jResponse($errorResponse, $e);
         }
 
-        return $profiledQueryPlan;
+        throw new Neo4jException(['message' => $e->getMessage()], 500, $e);
     }
-
-
 }