avvio - npm Package Compare versions

Comparing version 7.0.0-alpha.1 to 7.0.0-alpha.2

package.json

 {
   "name": "avvio",
-  "version": "7.0.0-alpha.1",
+  "version": "7.0.0-alpha.2",
   "description": "Asynchronous bootstrapping of Node applications",
@@ -5,0 +5,0 @@ "main": "boot.js",

plugin.js

@@ -148,2 +148,3 @@ 'use strict'
     this.server.after((err, cb) => {
+      this._error = err
       this.q.pause()
@@ -150,0 +151,0 @@ debug('resuming asyncQ', this.name)

test/after-pass-through.test.js

@@ -11,6 +11,8 @@ 'use strict'
 
+const e = new Error('kaboom')
+
 app.use(function (f, opts) {
-  return Promise.reject(new Error('kaboom'))
+  return Promise.reject(e)
 }).after(function (err, cb) {
-  t.pass('this is just called')
+  t.is(err, e)
   cb(err)
@@ -20,3 +22,3 @@ }).after(function () {
 }).after(function (err, cb) {
-  t.pass('this is just called')
+  t.is(err, e)
   cb(err)
@@ -23,0 +25,0 @@ })

test/await-after.test.js

@@ -141,4 +141,6 @@ 'use strict'
 
-  t.plan(1)
+  t.plan(2)
 
+  const e = new Error('kaboom')
+
   app.use(async (f, opts) => {
@@ -148,5 +150,5 @@ throw Error('kaboom')
 
-  await app.after()
+  await t.rejects(app.after(), e)
 
-  t.rejects(() => app.ready(), Error('kaboom'))
+  await t.rejects(() => app.ready(), Error('kaboom'))
 })
@@ -158,12 +160,14 @@
 
-  t.plan(1)
+  t.plan(2)
 
+  const e = new Error('kaboom')
+
   app.use(async (f, opts) => {
     app.use(async (f, opts) => {
-      throw Error('kaboom')
+      throw e
     })
   })
-  await app.after()
 
-  t.rejects(() => app.ready(), Error('kaboom'))
+  await t.rejects(app.after())
+  await t.rejects(() => app.ready(), e)
 })
@@ -175,3 +179,3 @@
 
-  t.plan(1)
+  t.plan(2)
 
@@ -181,4 +185,4 @@ app.use((f, opts, cb) => {
   })
-  await app.after()
-  t.rejects(() => app.ready(), Error('kaboom'))
+  await t.rejects(app.after())
+  await t.rejects(app.ready(), Error('kaboom'))
 })
@@ -190,3 +194,3 @@
 
-  t.plan(1)
+  t.plan(2)
 
@@ -199,4 +203,5 @@ app.use((f, opts, cb) => {
   })
-  await app.after()
-  t.rejects(() => app.ready(), Error('kaboom'))
+
+  await t.rejects(app.after())
+  await t.rejects(app.ready(), Error('kaboom'))
 })
@@ -208,3 +213,3 @@
 
-  t.plan(1)
+  t.plan(2)
 
@@ -214,4 +219,5 @@ app.use((f, opts, cb) => {
   })
-  await app.after()
-  t.rejects(() => app.ready(), Error('kaboom'))
+
+  await t.rejects(app.after())
+  await t.rejects(app.ready(), Error('kaboom'))
 })
@@ -223,3 +229,3 @@
 
-  t.plan(1)
+  t.plan(2)
 
@@ -232,4 +238,4 @@ app.use((f, opts, cb) => {
   })
-  await app.after()
-  t.rejects(() => app.ready(), Error('kaboom'))
+  await t.rejects(app.after(), Error('kaboom'))
+  await t.rejects(app.ready(), Error('kaboom'))
 })
@@ -346,2 +352,4 @@
 test('stop processing after errors', async (t) => {
+  t.plan(2)
+
   const app = boot()
@@ -348,0 +356,0 @@

test/await-use.test.js

@@ -107,2 +107,6 @@ 'use strict'
 
+function thenableRejects (t, thenable, err) {
+  return t.rejects(async () => { await thenable }, err)
+}
+
 test('await use - error handling, async throw', async (t) => {
@@ -112,9 +116,9 @@ const app = {}
 
-  t.plan(1)
+  t.plan(2)
 
-  await app.use(async (f, opts) => {
+  await thenableRejects(t, app.use(async (f, opts) => {
     throw Error('kaboom')
-  })
+  }), Error('kaboom'))
 
-  t.rejects(() => app.ready(), Error('kaboom'))
+  await t.rejects(app.ready(), Error('kaboom'))
 })
@@ -126,9 +130,9 @@
 
-  t.plan(1)
+  t.plan(3)
 
-  await app.use(async (f, opts) => {
-    await app.use(async (f, opts) => {
+  await thenableRejects(t, app.use(async (f, opts) => {
+    await thenableRejects(t, app.use(async (f, opts) => {
       throw Error('kaboom')
-    })
-  })
+    }), Error('kaboom'))
+  }, Error('kaboom')))
 
@@ -142,7 +146,7 @@ t.rejects(() => app.ready(), Error('kaboom'))
 
-  t.plan(1)
+  t.plan(2)
 
-  await app.use((f, opts, cb) => {
+  await thenableRejects(t, app.use((f, opts, cb) => {
     cb(Error('kaboom'))
-  })
+  }), Error('kaboom'))
 
@@ -156,5 +160,5 @@ t.rejects(() => app.ready(), Error('kaboom'))
 
-  t.plan(1)
+  t.plan(2)
 
-  await app.use((f, opts, cb) => {
+  await thenableRejects(t, app.use((f, opts, cb) => {
     app.use((f, opts, cb) => {
@@ -164,3 +168,3 @@ cb(Error('kaboom'))
     cb()
-  })
+  }), Error('kaboom'))
 
@@ -174,7 +178,7 @@ t.rejects(() => app.ready(), Error('kaboom'))
 
-  t.plan(1)
+  t.plan(2)
 
-  await app.use((f, opts, cb) => {
+  await thenableRejects(t, app.use((f, opts, cb) => {
     setImmediate(() => { cb(Error('kaboom')) })
-  })
+  }), Error('kaboom'))
 
@@ -188,5 +192,5 @@ t.rejects(() => app.ready(), Error('kaboom'))
 
-  t.plan(1)
+  t.plan(2)
 
-  await app.use((f, opts, cb) => {
+  await thenableRejects(t, app.use((f, opts, cb) => {
     app.use((f, opts, cb) => {
@@ -196,3 +200,3 @@ setImmediate(() => { cb(Error('kaboom')) })
     cb()
-  })
+  }), Error('kaboom'))
 
@@ -199,0 +203,0 @@ t.rejects(() => app.ready(), Error('kaboom'))

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

123861

increased by0.8%

Number of package files

38

increased by2.7%

Lines of code

4189

increased by0.7%

No dependency changes