Laravel Octane optimization

phpstan-baseline.neon

@@ -1,4 +1,6 @@
 parameters:
     treatPhpDocTypesAsCertain: false
     ignoreErrors:
+        - identifier: missingType.iterableValue
+        - identifier: missingType.generics
         - '#Variable method call on RichanFongdasen\\Turso\\TursoClient.#'

phpstan.neon.dist

@@ -9,5 +9,3 @@ parameters:
     tmpDir: build/phpstan
     checkOctaneCompatibility: true
     checkModelProperties: true
-    checkMissingIterableValueType: false
-    checkGenericClassInNonGenericObjectType: false

src/TursoClient.php

@@ -36,13 +36,9 @@ public function __construct(array $config = [])
 
         $this->queryLog = new Collection();
 
-        $this->enableQueryLog();
+        $this->disableQueryLog();
         $this->resetHttpClientState();
-    }
-
-    public function __destruct()
-    {
-        $this->close();
+        $this->httpRequest();
     }
 
     public function close(): void

src/TursoLaravelServiceProvider.php

@@ -71,7 +71,7 @@ public function register(): void
     {
         parent::register();
 
-        $this->app->scoped(TursoManager::class, function () {
+        $this->app->singleton(TursoManager::class, function () {
             return new TursoManager(config('database.connections.turso', []));
         });
 

tests/Unit/TursoClientTest.php

@@ -139,3 +139,48 @@
 
     expect(Turso::getBaseUrl())->toBe('http://base-url-example.turso.io');
 })->group('TursoClient', 'UnitTest');
+
+test('it can close the existing http connection', function () {
+    fakeHttpRequest([
+        'baton'    => 'baton-string-example',
+        'base_url' => 'http://base-url-example.turso.io',
+        'results'  => [
+            [
+                'type'     => 'ok',
+                'response' => [
+                    'result' => [
+                        'affected_row_count' => 1,
+                        'last_insert_rowid'  => '1',
+                        'replication_index'  => 0,
+                    ],
+                ],
+            ],
+            [
+                'type'     => 'ok',
+                'response' => [
+                    'result' => [
+                        'affected_row_count' => 1,
+                        'last_insert_rowid'  => '1',
+                        'replication_index'  => 0,
+                    ],
+                ],
+            ],
+        ],
+    ]);
+
+    $statement = 'SELECT * FROM "users" WHERE "id" = ?';
+    $bindings = [
+        [
+            'type'  => 'integer',
+            'value' => 1,
+        ],
+    ];
+
+    Turso::query($statement, $bindings);
+
+    expect(Turso::getBaton())->toBe('baton-string-example');
+
+    Turso::close();
+
+    expect(Turso::getBaton())->toBeNull();
+})->group('TursoClient', 'UnitTest');

turso-sync.mjs

@@ -1,5 +1,7 @@
 import { createClient } from "@libsql/client";
 
+const startTime = Date.now();
+
 let databaseURL = process.argv.slice(2)[0];
 const accessToken = process.argv.slice(2)[1];
 const replicaPath = process.argv.slice(2)[2];
@@ -18,4 +20,4 @@ console.log('Syncing database to replica ' + replicaPath + ' from ' + databaseUR
 
 await client.sync();
 
-console.log('Sync completed.');
+console.log('Sync completed in ' + (Date.now() - startTime) + 'ms.');