fix(tests): skip stress tests

Author: Daniele Briggi

package.json

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

test/1brc.test.ts

@@ -78,7 +78,7 @@ async function createDatabaseAsync(numberOfRows: number): Promise<{ connection:
   const createSql = `UNUSE DATABASE; CREATE DATABASE ${database}; USE DATABASE ${database};`
   const createResults = await sendCommandsAsync(connection, createSql)
   expect(createResults).toBe('OK')
-  return { database, connection }
+  return { connection, database }
 }
 
 async function destroyDatabaseAsync(connection: SQLiteCloudConnection, database: string) {
@@ -207,7 +207,7 @@ async function testChallenge(numberOfRows: number, insertChunks = BRC_INSERT_CHU
       throw error
     }
   } finally {
-    // await destroyDatabaseAsync(connection, database)
+    await destroyDatabaseAsync(connection, database)
     connection?.close()
   }
 }

test/database.test.ts

@@ -2,19 +2,17 @@
  * database.test.ts - test driver api
  */
 
-import { SQLiteCloudRowset, SQLiteCloudRow, SQLiteCloudError, sanitizeSQLiteIdentifier } from '../src/index'
+import { describe, expect, it } from '@jest/globals'
+import { RowCountCallback } from '../src/drivers/types'
+import { SQLiteCloudError, SQLiteCloudRow, SQLiteCloudRowset, sanitizeSQLiteIdentifier } from '../src/index'
 import {
+  LONG_TIMEOUT,
+  getChinookDatabase,
   getTestingDatabase,
   getTestingDatabaseAsync,
-  getChinookDatabase,
   removeDatabase,
-  removeDatabaseAsync,
-  LONG_TIMEOUT,
-  getChinookWebsocketConnection
+  removeDatabaseAsync
 } from './shared'
-import { RowCountCallback } from '../src/drivers/types'
-import { expect, describe, it } from '@jest/globals'
-import { Database } from 'sqlite3'
 
 //
 // utility methods to setup and destroy temporary test databases
@@ -55,6 +53,7 @@ describe('Database.run', () => {
         expect(error).toBeNull()
         database.run(updateSql, plainCallbackNotALambda)
       })
+      removeDatabase(database)
     },
     LONG_TIMEOUT
   )
@@ -114,6 +113,7 @@ describe('Database.run', () => {
         expect(error).toBeNull()
         database.run(insertSql, plainCallbackNotALambdaOne)
       })
+      removeDatabase(database)
     },
     LONG_TIMEOUT
   )
@@ -317,7 +317,7 @@ describe('Database.sql (async)', () => {
       const results = await database.sql('SELECT * FROM people WHERE name = ?', 'Emma Johnson')
       expect(results).toHaveLength(1)
     } finally {
-      database?.close()
+      await removeDatabaseAsync(database)
     }
   })
 
@@ -337,7 +337,7 @@ describe('Database.sql (async)', () => {
         hobby: 'Collecting clouds'
       })
     } finally {
-      database?.close()
+      await removeDatabaseAsync(database)
     }
   })
 
@@ -487,30 +487,45 @@ describe('Database.sql (async)', () => {
 
   describe('should sanitize identifiers', () => {
     it('should sanitize database name and run the query', async () => {
-      const database = await getTestingDatabaseAsync()
+      let database
+      try {
+        database = await getTestingDatabaseAsync()
 
-      const databaseName = sanitizeSQLiteIdentifier(database.getConfiguration().database || '')
-      await expect(database.sql(`USE DATABASE ${databaseName}`)).resolves.toBe('OK')
+        const databaseName = sanitizeSQLiteIdentifier(database.getConfiguration().database || '')
+        await expect(database.sql(`USE DATABASE ${databaseName}`)).resolves.toBe('OK')
+      } finally {
+        await removeDatabaseAsync(database)
+      }
     })
 
     it('should sanitize table name and run the query', async () => {
-      const database = await getTestingDatabaseAsync()
+      let database
+      try {
+        database = await getTestingDatabaseAsync()
 
-      const table = sanitizeSQLiteIdentifier('people')
-      await expect(database.sql(`SELECT id FROM ${table} LIMIT 1`)).resolves.toMatchObject([{ id: 1 }])
+        const table = sanitizeSQLiteIdentifier('people')
+        await expect(database.sql(`SELECT id FROM ${table} LIMIT 1`)).resolves.toMatchObject([{ id: 1 }])
+      } finally {
+        await removeDatabaseAsync(database)
+      }
     })
 
     it('should sanitize SQL Injection as table name', async () => {
-      const database = await getTestingDatabaseAsync()
-      const databaseName = database.getConfiguration().database
+      let database
+      try {
+        database = await getTestingDatabaseAsync()
+        const databaseName = database.getConfiguration().database
 
-      const sanitizedDBName = sanitizeSQLiteIdentifier(`${databaseName}; SELECT * FROM people; -- `)
-      await expect(database.sql(`USE DATABASE ${sanitizedDBName}`)).rejects.toThrow(
-        `Database name contains invalid characters (${databaseName}; SELECT * FROM people; --).`
-      )
+        const sanitizedDBName = sanitizeSQLiteIdentifier(`${databaseName}; SELECT * FROM people; -- `)
+        await expect(database.sql(`USE DATABASE ${sanitizedDBName}`)).rejects.toThrow(
+          `Database name contains invalid characters (${databaseName}; SELECT * FROM people; --).`
+        )
 
-      const table = sanitizeSQLiteIdentifier('people; -- ')
-      await expect(database.sql(`SELECT * FROM ${table} WHERE people = 1`)).rejects.toThrow('no such table: people; --')
+        const table = sanitizeSQLiteIdentifier('people; -- ')
+        await expect(database.sql(`SELECT * FROM ${table} WHERE people = 1`)).rejects.toThrow('no such table: people; --')
+      } finally {
+        await removeDatabaseAsync(database)
+      }
     })
   })
 

test/stress.test.ts

@@ -14,7 +14,7 @@ import {
   EXPECT_SPEED_MS
 } from './shared'
 
-describe('stress testing', () => {
+describe.skip('stress testing', () => {
   it(
     'should do lots of read connections in sequence',
     async () => {