Check if socket is already closed

Author: gionatamettifogo

package-lock.json

@@ -45,7 +45,7 @@
     "lz4js": "^0.2.0"
   },
   "devDependencies": {
-    "@types/jest": "^29.5.7",
+    "@types/jest": "^29.5.11",
     "@types/lz4": "^0.6.3",
     "@types/node": "^12.20.55",
     "@typescript-eslint/eslint-plugin": "^4.22.0",
@@ -59,7 +59,7 @@
     "prettier": "^2.2.1",
     "sqlite3": "^5.1.6",
     "ts-jest": "^29.1.1",
-    "ts-node": "^10.9.1",
+    "ts-node": "^10.9.2",
     "typedoc": "^0.25.3",
     "typedoc-plugin-markdown": "^3.17.1",
     "typescript": "^4.9.5"

package.json

@@ -9,7 +9,6 @@ const lz4 = require('lz4js')
 import { SQLiteCloudConfig, SQLCloudRowsetMetadata, SQLiteCloudError, SQLiteCloudDataTypes, ErrorCallback, ResultsCallback } from './types'
 import { SQLiteCloudRowset } from './rowset'
 import { parseConnectionString, parseBoolean } from './utilities'
-import { Socket } from 'net'
 
 /**
  * The server communicates with clients via commands defined
@@ -163,9 +162,9 @@ export class SQLiteCloudConnection {
           this.socket.removeAllListeners('data')
           this.socket.removeAllListeners('error')
           this.socket.removeAllListeners('close')
-        }
-        if (error) {
-          this.close()
+          if (error) {
+            this.close()
+          }
         }
         done(error)
       }
@@ -190,7 +189,7 @@ export class SQLiteCloudConnection {
           console.assert(this.socket, 'Connection already closed')
           const commands = this.initializationCommands
           this.processCommands(commands, error => {
-            if (error) {
+            if (error && this.socket) {
               this.close()
             }
             if (callback) {
@@ -357,7 +356,7 @@ export class SQLiteCloudConnection {
 
   /** Disconnect from server, release connection. */
   public close(): this {
-    console.assert(this.socket !== undefined, 'SQLiteCloudConnection.close - connection already closed')
+    console.assert(this.socket !== null, 'SQLiteCloudConnection.close - connection already closed')
     if (this.socket) {
       this.socket.destroy()
       this.socket = null