fix(close): enqueue operation

Author: Daniele Briggi

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@sqlitecloud/drivers",
-  "version": "1.0.437",
+  "version": "1.0.438",
   "description": "SQLiteCloud drivers for Typescript/Javascript in edge, web and node clients",
   "main": "./lib/index.js",
   "types": "./lib/index.d.ts",

src/drivers/database.ts

@@ -128,13 +128,17 @@ export class Database extends EventEmitter {
 
       // we don't wont to silently open a new connection after a disconnession
       if (this.connection && this.connection.connected) {
-        this.connection.sendCommands(command, callback)
+        this.connection.sendCommands(command, (error, results) => {
+          callback?.call(this, null, results)
+          done(error)
+        })
       } else {
         error = new SQLiteCloudError('Connection unavailable. Maybe it got disconnected?', { errorCode: 'ERR_CONNECTION_NOT_ESTABLISHED' })
-        this.handleError(error, callback)
+        this.handleError(error, (error: Error | null) => {
+          callback?.call(this, error, null)
+          done(error)
+        })
       }
-
-      done(error)
     })
   }
 
@@ -382,11 +386,15 @@ export class Database extends EventEmitter {
    * parameters is emitted, regardless of whether a callback was provided or not.
    */
   public close(callback?: ConnectionCallback): void {
-    this.operations.clear()
-    this.connection?.close()
+    this.operations.enqueue(done => {
+      this.connection?.close()
+  
+      callback?.call(this, null)
+      this.emitEvent('close')
 
-    callback?.call(this, null)
-    this.emitEvent('close')
+      this.operations.clear()
+      done(null)
+    })
   }
 
   /**

test/database.test.ts

@@ -246,6 +246,33 @@ describe('Database.get', () => {
       })
     })
   })
+
+  it.only('close() is executed after the previous commands', done => {
+    // the database enqueue the close command
+    const chinook = getChinookDatabase()
+    chinook.get('SELECT * FROM tracks', (err: Error, row?: SQLiteCloudRow) => {
+      expect(err).toBeNull()
+      expect(row).toBeDefined()
+      expect(row).toMatchObject({
+        AlbumId: 1,
+        Bytes: 11170334,
+        Composer: 'Angus Young, Malcolm Young, Brian Johnson',
+        GenreId: 1,
+        MediaTypeId: 1,
+        Milliseconds: 343719,
+        Name: 'For Those About To Rock (We Salute You)',
+        TrackId: 1,
+        UnitPrice: 0.99
+      })
+    })
+
+    // call close() right after the execution 
+    // of the query not in its callback
+    chinook.close(error => {
+      expect(error).toBeNull()
+      done()
+    })
+  })
 })
 
 describe('Database.each', () => {