reset fix

Author: davidmarkclements

Diff for: subsystems/sidecar/index.js

@@ -53,6 +53,7 @@ const ops = {
   Dump: require('./ops/dump'),
   Info: require('./ops/info'),
   Shift: require('./ops/shift'),
+  Reset: require('./ops/reset'),
   Touch: require('./ops/touch'),
   Data: require('./ops/data'),
   DataReset: require('./ops/data/reset')
@@ -356,6 +357,8 @@ class Sidecar extends ReadyResource {
 
   shift (params, client) { return new ops.Shift(params, client, this) }
 
+  reset (params, client) { return new ops.Reset(params, client, this) }
+
   gc (params, client) { return new ops.GC(params, client) }
 
   touch (params, client) { return new ops.Touch(params, client, this) }

Diff for: subsystems/sidecar/ops/reset.js

@@ -2,9 +2,9 @@
 const path = require('bare-path')
 const crypto = require('hypercore-crypto')
 const { pathToFileURL } = require('url-file-url')
-const { PLATFORM_DIR } = require('../../../constants')
+const { PLATFORM_DIR } = require('pear-api/constants')
+const { ERR_INVALID_INPUT } = require('pear-api/errors')
 const Opstream = require('../lib/opstream')
-const { ERR_INVALID_INPUT } = require('../../../errors')
 
 module.exports = class Reset extends Opstream {
   constructor (...args) {

Diff for: test/08-reset.test.js

@@ -4,7 +4,7 @@ const path = require('bare-path')
 const Helper = require('./helper')
 const storageDir = path.join(Helper.localDir, 'test', 'fixtures', 'storage')
 
-test('reset', async function ({ ok, is, plan, comment, teardown, timeout }) {
+test('reset', async function ({ ok, not, plan, comment, teardown, timeout }) {
   timeout(180000)
   plan(3)
 
@@ -25,19 +25,25 @@ test('reset', async function ({ ok, is, plan, comment, teardown, timeout }) {
 
   const link = `pear://${key}`
 
+  comment('running')
+
   const run = await Helper.run({ link })
   const before = await Helper.untilResult(run.pipe)
   await Helper.untilClose(run.pipe)
 
-  const reset = await helper.reset({ link })
+  comment('resetting')
+
+  const reset = helper.reset({ link })
   const untilReset = await Helper.pick(reset, [{ tag: 'complete' }])
   await untilReset.complete
 
+  comment('running')
+
   const runB = await Helper.run({ link })
   const after = await Helper.untilResult(runB.pipe)
   await Helper.untilClose(runB.pipe)
 
   ok(before)
   ok(after)
-  ok(before !== after)
+  not(before, after)
 })

Diff for: test/index.js

@@ -7,17 +7,17 @@ async function runTests () {
 
   test.pause()
 
-  await import('./01-smoke.test.js')
-  await import('./02-teardown.test.js')
-  await import('./03-worker.test.js')
-  await import('./04-encrypted.test.js')
-  await import('./05-updates.test.js')
-  await import('./06-shutdown.test.js')
-  await import('./07-warmup.test.js')
+  // await import('./01-smoke.test.js')
+  // await import('./02-teardown.test.js')
+  // await import('./03-worker.test.js')
+  // await import('./04-encrypted.test.js')
+  // await import('./05-updates.test.js')
+  // await import('./06-shutdown.test.js')
+  // await import('./07-warmup.test.js')
   await import('./08-reset.test.js')
-  await import('./09-shift.test.js')
-  await import('./10-data.test.js')
-  await import('./11-dump.test.js')
+  // await import('./09-shift.test.js')
+  // await import('./10-data.test.js')
+  // await import('./11-dump.test.js')
 
   test.resume()
 }