fix(tests): make tests exit

Author: awlayton

test/Metadata.test.ts

@@ -49,8 +49,7 @@ test('should resume from last rev', async (t) => {
     },
   });
 
-  // eslint-disable-next-line no-new
-  new ListWatch({
+  const watch = new ListWatch({
     path,
     name,
     conn,
@@ -60,6 +59,8 @@ test('should resume from last rev', async (t) => {
   await setTimeout(5);
 
   t.is(conn.watch.firstCall?.args?.[0]?.rev, rev);
+
+  await watch.stop();
 });
 
 test('should persist rev to _meta', async (t) => {
@@ -116,4 +117,6 @@ test('should persist rev to _meta', async (t) => {
     } as PUTRequest),
     `conn.put calls: ${inspect(conn.put.getCalls(), false, undefined, true)}`,
   );
+
+  await watch.stop();
 });

test/deprecated.test.ts

@@ -79,15 +79,16 @@ test('it should detect new item', async (t) => {
     changes: changes(),
   });
 
-  // eslint-disable-next-line no-new
-  new ListWatch(options);
+  const watch = new ListWatch(options);
 
   await setTimeout(delay);
 
   t.is(options.onAddItem.callCount, 1);
   t.is(options.onItem.callCount, 1);
   t.is(options.onChangeItem.callCount, 0);
   t.is(options.onRemoveItem.callCount, 0);
+
+  await watch.stop();
 });
 
 test('it should detect removed item', async (t) => {
@@ -133,15 +134,16 @@ test('it should detect removed item', async (t) => {
     changes: changes(),
   });
 
-  // eslint-disable-next-line no-new
-  new ListWatch(options);
+  const watch = new ListWatch(options);
 
   await setTimeout(delay);
 
   t.is(options.onAddItem.callCount, 0);
   t.is(options.onItem.callCount, 0);
   t.is(options.onChangeItem.callCount, 0);
   t.is(options.onRemoveItem.callCount, 1);
+
+  await watch.stop();
 });
 
 test('it should detect modified item', async (t) => {
@@ -205,13 +207,14 @@ test('it should detect modified item', async (t) => {
     changes: changes(),
   });
 
-  // eslint-disable-next-line no-new
-  new ListWatch(options);
+  const watch = new ListWatch(options);
 
   await setTimeout(delay);
 
   t.is(options.onAddItem.callCount, 0);
   t.is(options.onItem.callCount, 1);
   t.is(options.onChangeItem.callCount, 1);
   t.is(options.onRemoveItem.callCount, 0);
+
+  await watch.stop();
 });

test/index.test.ts

@@ -21,8 +21,8 @@ import test from 'ava';
 
 import { createStub, emptyResponse } from './conn-stub.js';
 
-import { ChangeType, ListWatch } from '@oada/list-lib';
-import type { Change } from '@oada/list-lib';
+// eslint-disable-next-line node/no-extraneous-import
+import { type Change, ChangeType, ListWatch } from '@oada/list-lib';
 
 const name = 'oada-list-lib-test';
 
@@ -32,13 +32,14 @@ test('it should WATCH given path', async (t) => {
   const conn = createStub();
   const path = '/bookmarks/foo/bar';
 
-  // eslint-disable-next-line no-new
-  new ListWatch({ path, name, conn });
+  const watch = new ListWatch({ path, name, conn });
   t.plan(1);
 
   await setTimeout(delay);
 
   t.is(conn.watch.firstCall?.args?.[0]?.path, path);
+
+  await watch.stop();
 });
 
 test.todo('it should reconnect WATCH');
@@ -103,6 +104,8 @@ test('it should detect new item', async (t) => {
   t.is(onItem.callCount, 1);
   t.is(onChangeItem.callCount, 0);
   t.is(onRemoveItem.callCount, 0);
+
+  await watch.stop();
 });
 
 test('it should detect removed item', async (t) => {
@@ -159,6 +162,8 @@ test('it should detect removed item', async (t) => {
   t.is(onItem.callCount, 0);
   t.is(onChangeItem.callCount, 0);
   t.is(onRemoveItem.callCount, 1);
+
+  await watch.stop();
 });
 
 test('it should detect modified item', async (t) => {
@@ -233,4 +238,6 @@ test('it should detect modified item', async (t) => {
   t.is(onItem.callCount, 1);
   t.is(onChangeItem.callCount, 1);
   t.is(onRemoveItem.callCount, 0);
+
+  await watch.stop();
 });

test/promises.test.ts

@@ -75,6 +75,8 @@ test('it should detect new item', async (t) => {
 
   await t.notThrowsAsync(add);
   await t.notThrowsAsync(item);
+
+  await watch.stop();
 });
 
 test('it should detect removed item', async (t) => {
@@ -118,6 +120,8 @@ test('it should detect removed item', async (t) => {
   const removed = watch.once(ChangeType.ItemRemoved);
 
   await t.notThrowsAsync(removed);
+
+  await watch.stop();
 });
 
 test('it should detect modified item', async (t) => {
@@ -181,4 +185,6 @@ test('it should detect modified item', async (t) => {
 
   await t.notThrowsAsync(modified);
   await t.notThrowsAsync(item);
+
+  await watch.stop();
 });