Normalize group hashes for singlestore connections (#225)

Author: jessarcher

composer-dependency-analyser.php

@@ -9,4 +9,5 @@
     ->ignoreErrorsOnPackageAndPath('spatie/laravel-ignition', __DIR__.'/src/Location.php', [ErrorType::DEV_DEPENDENCY_IN_PROD])
     ->ignoreErrorsOnPackageAndPath('livewire/livewire', __DIR__.'/src/NightwatchServiceProvider.php', [ErrorType::DEV_DEPENDENCY_IN_PROD])
     ->ignoreErrorsOnPackageAndPath('livewire/livewire', __DIR__.'/src/Hooks/LivewireListener.php', [ErrorType::DEV_DEPENDENCY_IN_PROD])
+    ->ignoreErrorsOnPath(__DIR__.'/tests/Feature/Sensors/QuerySensorTest.php', [ErrorType::UNKNOWN_CLASS])
     ->ignoreUnknownClasses(['Laravel\Octane\Events\RequestReceived']);

composer.json

@@ -42,6 +42,7 @@
         "phpstan/phpstan": "^1.0",
         "phpunit/phpunit": "^10.0|^11.0",
         "ramsey/uuid": "^4.0",
+        "singlestoredb/singlestoredb-laravel": "^1.0|^2.0",
         "spatie/laravel-ignition": "^2.0",
         "symfony/mailer": "^6.0|^7.0",
         "symfony/mime": "^6.0|^7.0",

src/Sensors/QuerySensor.php

@@ -75,7 +75,7 @@ function () use ($event, $record) {
 
     private function hash(QueryExecuted $event, Query $record): string
     {
-        if (! in_array($event->connection->getDriverName(), ['mariadb', 'mysql', 'pgsql', 'sqlite', 'sqlsrv'], true)) {
+        if (! in_array($event->connection->getDriverName(), ['mariadb', 'mysql', 'pgsql', 'sqlite', 'sqlsrv', 'singlestore'], true)) {
             return hash('xxh128', "{$record->connection},{$record->sql}");
         }
 

tests/Feature/Sensors/QuerySensorTest.php

@@ -17,6 +17,8 @@
 use MongoDB\Laravel\Connection as MongoDbConnection;
 use PDO;
 use PHPUnit\Framework\Attributes\DataProvider;
+use SingleStore\Laravel\Connect\Connection as LegacySingleStoreConnection;
+use SingleStore\Laravel\Connect\SingleStoreConnection;
 use Tests\TestCase;
 
 use function base64_encode;
@@ -207,6 +209,15 @@ public static function whereInQueries(): iterable
             new SqlServerConnection('test', config: ['name' => 'foo', 'driver' => 'sqlsrv']),
         ];
 
+        yield 'singlestore' => [
+            'select * from `users` where `users`.`id` in (1, 2, 3) and `id` in (?, ?, ?)',
+            hash('xxh128', 'foo,select * from `users` where `users`.`id` in (...?) and `id` in (...?)'),
+            match (true) {
+                class_exists(SingleStoreConnection::class) => new SingleStoreConnection('test', config: ['name' => 'foo', 'driver' => 'singlestore']),
+                class_exists(LegacySingleStoreConnection::class) => new LegacySingleStoreConnection('test', config: ['name' => 'foo', 'driver' => 'singlestore']),
+            },
+        ];
+
         yield 'mongodb' => [
             'some mongo query in (1, 2, 3) and [id] in (?, ?, ?)',
             hash('xxh128', 'foo,some mongo query in (1, 2, 3) and [id] in (?, ?, ?)'),
@@ -276,6 +287,15 @@ public static function insertQueries(): iterable
             new SqlServerConnection('test', config: ['name' => 'foo', 'driver' => 'sqlsrv']),
         ];
 
+        yield 'singlestore' => [
+            'insert into `users` (`id`, `name`) values (?, ?)',
+            hash('xxh128', 'foo,insert into `users` (`id`, `name`) values ...'),
+            match (true) {
+                class_exists(SingleStoreConnection::class) => new SingleStoreConnection('test', config: ['name' => 'foo', 'driver' => 'singlestore']),
+                class_exists(LegacySingleStoreConnection::class) => new LegacySingleStoreConnection('test', config: ['name' => 'foo', 'driver' => 'singlestore']),
+            },
+        ];
+
         yield 'mongodb' => [
             'insert some mongo query values (?, ?), (?, ?)',
             hash('xxh128', 'foo,insert some mongo query values (?, ?), (?, ?)'),