teardown bases that use tmpDir

test/fast-forward.js

@@ -47,6 +47,11 @@ test('fast-forward - simple', async t => {
 
   await b.ready()
 
+  t.teardown(() => Promise.all([
+    a.close(),
+    b.close()
+  ]))
+
   for (let i = 0; i < 1000; i++) {
     await a.append('a' + i)
   }
@@ -72,6 +77,12 @@ test('fast-forward - migrate', async t => {
     storage: () => tmpDir(t)
   })
 
+  t.teardown(() => Promise.all([
+    a.close(),
+    b.close(),
+    c.close()
+  ]))
+
   for (let i = 0; i < 2000; i++) {
     await a.append('a' + i)
   }
@@ -103,6 +114,12 @@ test('fast-forward - fast forward after migrate', async t => {
     storage: () => tmpDir(t)
   })
 
+  t.teardown(() => Promise.all([
+    a.close(),
+    b.close(),
+    c.close()
+  ]))
+
   for (let i = 0; i < 2000; i++) {
     await a.append('a' + i)
   }
@@ -156,6 +173,13 @@ test('fast-forward - multiple writers added', async t => {
     storage: () => tmpDir(t)
   })
 
+  t.teardown(() => Promise.all([
+    a.close(),
+    b.close(),
+    c.close(),
+    d.close()
+  ]))
+
   await addWriterAndSync(a, b)
   await addWriterAndSync(a, c)
 
@@ -208,6 +232,13 @@ test('fast-forward - multiple queues', async t => {
     storage: () => tmpDir(t)
   })
 
+  t.teardown(() => Promise.all([
+    a.close(),
+    b.close(),
+    c.close(),
+    d.close()
+  ]))
+
   // this value should be long enough that 2 fast-forwards are
   // queued (ie. we don't just replicate the last state), but short
   // enough that the second is queued before the first has completed
@@ -305,6 +336,11 @@ test('fast-forward - open with no remote io', async t => {
 
   await b.ready()
 
+  t.teardown(() => Promise.all([
+    a.close(),
+    b.close()
+  ]))
+
   for (let i = 0; i < 1000; i++) {
     await a.append('a' + i)
   }
@@ -381,6 +417,12 @@ test('fast-forward - force reset then ff', async t => {
     storage: () => tmpDir(t)
   })
 
+  t.teardown(() => Promise.all([
+    a.close(),
+    b.close(),
+    c.close()
+  ]))
+
   await addWriterAndSync(a, b)
   await addWriterAndSync(a, c)
   await confirm([a, b, c])

test/suspend.js

@@ -96,6 +96,11 @@ test('suspend - pass exisiting fs store', async t => {
   const base3 = new Autobase(session3, base1.local.key, { apply, valueEncoding: 'json', ackInterval: 0, ackThreshold: 0, fastForward: false })
   await base3.ready()
 
+  t.teardown(() => Promise.all([
+    base1.close(),
+    base3.close()
+  ])
+
   t.is(base3.activeWriters.size, 2)
 
   await base3.append('final')