pg-query-stream/test/error: remove semicolons

brianc · Oct 11, 2023 · cd51583 · cd51583
1 parent 0017970
commit cd51583
Showing 1 changed file with 38 additions and 38 deletions.
diff --git a/packages/pg-query-stream/test/error.ts b/packages/pg-query-stream/test/error.ts
@@ -91,81 +91,81 @@ describe('error recovery', () => {
   })
 
   it('should work if used after timeout error', async () => {
-    const pool = new Pool({ max: 1, connectionTimeoutMillis: 400, statement_timeout: 400 });
+    const pool = new Pool({ max: 1, connectionTimeoutMillis: 400, statement_timeout: 400 })
 
-    const res1 = await pool.query('SELECT 1 AS a');
-    assert.deepStrictEqual(res1.rows, [ { a:1 } ]);
+    const res1 = await pool.query('SELECT 1 AS a')
+    assert.deepStrictEqual(res1.rows, [ { a:1 } ])
 
-    const query = new QueryStream('SELECT 2 AS b');
-    const client = await pool.connect();
-    const stream = await client.query(query);
+    const query = new QueryStream('SELECT 2 AS b')
+    const client = await pool.connect()
+    const stream = await client.query(query)
 
-    await assert.rejects(() => pool.query('SELECT TRUE'), { message: 'timeout exceeded when trying to connect' });
+    await assert.rejects(() => pool.query('SELECT TRUE'), { message: 'timeout exceeded when trying to connect' })
 
-    await stream.destroy();
-    await client.release();
+    await stream.destroy()
+    await client.release()
 
-    const res2 = await pool.query('SELECT 4 AS d');
-    assert.deepStrictEqual(res2.rows, [ { d:4 } ]);
+    const res2 = await pool.query('SELECT 4 AS d')
+    assert.deepStrictEqual(res2.rows, [ { d:4 } ])
 
-    await pool.end();
+    await pool.end()
   })
 
   it('should work if used after syntax error', async () => {
     const pool = new Pool({ max: 1, statement_timeout: 100 }); // statement_timeout is required here, so maybe this is just another timeout error?
 
-    const res1 = await pool.query('SELECT 1 AS a');
-    assert.deepStrictEqual(res1.rows, [ { a:1 } ]);
+    const res1 = await pool.query('SELECT 1 AS a')
+    assert.deepStrictEqual(res1.rows, [ { a:1 } ])
 
-    const query = new QueryStream('SELECT 2 AS b');
-    const client = await pool.connect();
-    const stream = await client.query(query);
+    const query = new QueryStream('SELECT 2 AS b')
+    const client = await pool.connect()
+    const stream = await client.query(query)
 
-    await new Promise((resolve) => setTimeout(resolve, 10));
+    await new Promise((resolve) => setTimeout(resolve, 10))
 
-    await stream.destroy();
-    await client.release();
+    await stream.destroy()
+    await client.release()
 
-    const res2 = await pool.query('SELECT 4 AS d');
-    assert.deepStrictEqual(res2.rows, [ { d:4 } ]);
+    const res2 = await pool.query('SELECT 4 AS d')
+    assert.deepStrictEqual(res2.rows, [ { d:4 } ])
 
-    await pool.end();
+    await pool.end()
   })
 
   it('should work after cancelling query', async () => {
-    const pool = new Pool();
-    const conn = await pool.connect();
+    const pool = new Pool()
+    const conn = await pool.connect()
 
     // Get connection PID for sake of pg_cancel_backend() call
-    const result = await conn.query('SELECT pg_backend_pid() AS pid;');
-    const { pid } = result.rows[0];
+    const result = await conn.query('SELECT pg_backend_pid() AS pid;')
+    const { pid } = result.rows[0]
 
-    const stream = conn.query(new QueryStream('SELECT pg_sleep(10);'));
+    const stream = conn.query(new QueryStream('SELECT pg_sleep(10);'))
     stream.on('data', (chunk) => {
       // Switches stream into readableFlowing === true mode
-    });
+    })
     stream.on('error', (err) => {
       // Errors are expected due to pg_cancel_backend() call
-    });
+    })
 
     // Create a promise that is resolved when the stream is closed
     const closed = new Promise((res) => {
-      stream.on('close', res);
-    });
+      stream.on('close', res)
+    })
 
     // Wait 100ms before cancelling the query
-    await new Promise((res) => setTimeout(res, 100));
+    await new Promise((res) => setTimeout(res, 100))
 
     // Cancel pg_sleep(10) query
-    await pool.query('SELECT pg_cancel_backend($1);', [pid]);
+    await pool.query('SELECT pg_cancel_backend($1);', [pid])
 
     // Destroy stream and wait for it to be closed
-    stream.destroy();
-    await closed;
+    stream.destroy()
+    await closed
 
     // Subsequent query on same connection should succeed
-    const res = await conn.query('SELECT 1 AS a;');
-    assert.deepStrictEqual(res.rows, [ { a:1 } ]);
+    const res = await conn.query('SELECT 1 AS a;')
+    assert.deepStrictEqual(res.rows, [ { a:1 } ])
 
     conn.release()
     await pool.end()