Query Profile code

Author: p123-stack

.gitignore

@@ -2,4 +2,4 @@
 vendor
 phpunit.xml
 test
-.phpunit.result.cache
+.phpunit.result.cache

src/Profile.php

@@ -0,0 +1,61 @@
+<?php
+
+namespace Neo4j\QueryAPI;
+require __DIR__ . '/../vendor/autoload.php';
+
+
+use GuzzleHttp\Client;
+
+class Profile
+{
+    private $neo4jUrl;
+    private $username;
+    private $password;
+    private $client;
+
+    public function __construct($url, $username, $password)
+    {
+        $this->neo4jUrl = $url;
+        $this->username = $username;
+        $this->password = $password;
+        $this->client = new Client();
+    }
+
+    public function executeQuery($query)
+    {
+        $response = $this->client->post($this->neo4jUrl, [
+            'auth' => [$this->username, $this->password],
+            'json' => [
+                'statement' => $query
+            ]
+        ]);
+
+        return json_decode($response->getBody(), true);
+    }
+
+    public function formatResponse($data): array
+    {
+        $output = [
+            "data" => [
+                "fields" => [],
+                "values" => []
+            ],
+            "profiledQueryPlan" => [],
+            "bookmarks" => $data['bookmarks'] ?? []
+        ];
+
+        if (isset($data['result']['columns']) && isset($data['result']['rows'])) {
+            $output["data"]["fields"] = $data['result']['columns'];
+            foreach ($data['result']['rows'] as $row) {
+                $output["data"]["values"][] = $row;
+            }
+        }
+
+        if (isset($data['profiledQueryPlan'])) {
+            $output["profiledQueryPlan"] = $data['profiledQueryPlan'];
+        }
+
+        return $output;
+    }
+}
+

src/Query_Profile_run.php

@@ -0,0 +1,18 @@
+<?php
+
+use Neo4j\QueryAPI\Profile;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$neo4jUrl = 'https://6f72daa1.databases.neo4j.io/db/neo4j/query/v2';
+$username = 'neo4j';
+$password = '9lWmptqBgxBOz8NVcTJjgs3cHPyYmsy63ui6Spmw1d0';
+
+$client = new Profile($neo4jUrl, $username, $password);
+
+$query = "PROFILE MATCH (n:Person) RETURN n";
+$data = $client->executeQuery($query);
+$formattedResponse = $client->formatResponse($data);
+
+echo json_encode($formattedResponse, JSON_PRETTY_PRINT);
+

tests/Integration/ProfileTest.php

@@ -0,0 +1,73 @@
+<?php
+
+namespace Neo4j\QueryAPI\Tests\Integration;
+
+use GuzzleHttp\Client;
+use GuzzleHttp\Handler\MockHandler;
+use GuzzleHttp\HandlerStack;
+use GuzzleHttp\Psr7\Response;
+use Neo4j\QueryAPI\Profile;
+use PHPUnit\Framework\TestCase;
+
+class ProfileTest extends TestCase
+{
+    public function testExecuteQuery(): void
+    {
+        $mockResponseData = [
+            'result' => [
+                'columns' => ['name'],
+                'rows' => [['John Doe']],
+            ],
+            'bookmarks' => ['bookmark1'],
+        ];
+
+
+        $mock = new MockHandler([
+            new Response(200, [], json_encode($mockResponseData))
+        ]);
+        $handlerStack = HandlerStack::create($mock);
+
+        $mockClient = new Client(['handler' => $handlerStack]);
+
+        $profile = new Profile('http://mock-neo4j-url', 'user', 'password');
+        $reflection = new \ReflectionClass(Profile::class);
+        $clientProperty = $reflection->getProperty('client');
+        $clientProperty->setValue($profile, $mockClient);
+
+        $query = 'MATCH (n:Person) RETURN n.name';
+        $result = $profile->executeQuery($query);
+
+        $this->assertIsArray($result);
+        $this->assertEquals($mockResponseData, $result);
+    }
+
+    public function testFormatResponse(): void
+    {
+        $mockInputData = [
+            'result' => [
+                'columns' => ['name'],
+                'rows' => [['John Doe']],
+            ],
+            'profiledQueryPlan' => [
+                'plan' => 'Mock Plan',
+            ],
+            'bookmarks' => ['bookmark1'],
+        ];
+
+        $expectedOutput = [
+            'data' => [
+                'fields' => ['name'],
+                'values' => [['John Doe']],
+            ],
+            'profiledQueryPlan' => [
+                'plan' => 'Mock Plan',
+            ],
+            'bookmarks' => ['bookmark1'],
+        ];
+
+        $profile = new Profile('http://mock-neo4j-url', 'user', 'password');
+
+        $formattedResponse = $profile->formatResponse($mockInputData);
+        $this->assertEquals($expectedOutput, $formattedResponse);
+    }
+}