mongojs - npm Package Compare versions

Comparing version 2.5.0 to 2.6.0

index.js

@@ -0,0 +0,0 @@ var Database = require('./lib/database')

lib/bulk.js

@@ -0,0 +0,0 @@ var mongodb = require('mongodb')

lib/collection.js

@@ -0,0 +0,0 @@ var mongodb = require('mongodb')

lib/cursor.js

@@ -5,2 +5,6 @@ var util = require('util')
 
+try {
+  var hooks = require('async_hooks')
+} catch (err) {}
+
 var Cursor = function (getCursor) {
@@ -12,2 +16,5 @@ Readable.call(this, {objectMode: true, highWaterMark: 0})
   var self = this
+
+  this._destroyed = false
+  this._hook = hooks && new hooks.AsyncResource('mongojs:cursor')
   this._get = thunky(function (cb) {
@@ -32,2 +39,6 @@ getCursor(function (err, cursor) {
 Cursor.prototype.next = function (cb) {
+  if (this._hook) cb = wrapHook(this, cb)
+
+  var self = this
+
   this._get(function (err, cursor) {
@@ -37,2 +48,3 @@ if (err) return cb(err)
     if (cursor.cursorState.dead || cursor.cursorState.killed) {
+      destroy(self)
       return cb(null, null)
@@ -48,2 +60,4 @@ } else {
 Cursor.prototype.rewind = function (cb) {
+  if (this._hook) cb = wrapHook(this, cb)
+
   this._get(function (err, cursor) {
@@ -123,2 +137,4 @@ if (err) return cb(err)
 Cursor.prototype.count = function (cb) {
+  if (this._hook) cb = wrapHook(this, cb)
+
   var self = this
@@ -133,2 +149,4 @@
 Cursor.prototype.size = function (cb) {
+  if (this._hook) cb = wrapHook(this, cb)
+
   var self = this
@@ -143,2 +161,4 @@
 Cursor.prototype.explain = function (cb) {
+  if (this._hook) cb = wrapHook(this, cb)
+
   this._get(function (err, cursor) {
@@ -153,9 +173,12 @@ if (err) { return cb(err) }
   this._get(function (err, cursor) {
-    if (err) return self.emit('error', err)
+    if (err) return done(err)
     if (cursor.close) {
-      cursor.close(function (err) {
-        if (err) { self.emit('error', err) }
-      })
+      cursor.close(done)
     }
   })
+
+  function done (err) {
+    if (err) { self.emit('error', err) }
+    destroy(self)
+  }
 }
@@ -172,1 +195,23 @@
 module.exports = Cursor
+
+function destroy (self) {
+  if (self._destroyed) return
+  self._destroyed = true
+  if (self._hook) self._hook.emitDestroy()
+}
+
+function runInAsyncScope (self, cb, err, val) {
+  if (self._hook.runInAsyncScope) {
+    self._hook.runInAsyncScope(cb, null, err, val)
+  } else {
+    self._hook.emitBefore()
+    cb(err, val)
+    self._hook.emitAfter()
+  }
+}
+
+function wrapHook (self, cb) {
+  return function (err, val) {
+    runInAsyncScope(self, cb, err, val)
+  }
+}

lib/database.js

@@ -0,0 +0,0 @@ var Collection = require('./collection')

package.json

@@ -9,3 +9,3 @@ {
   ],
-  "version": "2.5.0",
+  "version": "2.6.0",
   "repository": "git://github.com/mafintosh/mongojs.git",
@@ -12,0 +12,0 @@ "author": "Mathias Buus Madsen <[e-mail]>",

README.md

@@ -0,0 +0,0 @@ # mongojs

test/crash.js

@@ -0,0 +0,0 @@ var mongojs = require('../index')

test/insert.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/tape.js

@@ -0,0 +0,0 @@ var test = require('tape')

test/test-aggregate-options.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-aggregate-pipeline.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-aggregate.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-bulk-replace-one.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-bulk-updates.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-chained-collection-names.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-close-unopened.js

@@ -0,0 +0,0 @@ var test = require('tape')

test/test-connect-non-existing-db.js

@@ -0,0 +0,0 @@ var test = require('tape')

test/test-connection-strings.js

@@ -0,0 +0,0 @@ var test = require('tape')

test/test-crash.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-create-collection.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-cursor-count.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-cursor-explain.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-cursor-foreach.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-cursor-map.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-cursor-rewind.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-cursor-size.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-db-stats.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-disinct.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-drop-database.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-drop-indexes.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-empty-bulk.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-eval.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-event-close.js

@@ -0,0 +0,0 @@ var test = require('tape')

test/test-event-connect.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-excessive-bulk-operations.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-excessive-bulk-update.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-expose-bson-types.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-find-and-modify.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-and-select.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-by-objectid.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-cursor-options.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-cursor.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-dot-collection.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-find-large-collection.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-limit.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-one.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-query.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-sort-many.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-sort.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-find-tailable.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-find.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-get-collection-names.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-group.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-insert-duplicate-key.js

@@ -0,0 +0,0 @@ var test = require('tape')

test/test-insert.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-iscapped.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-map-reduce.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-mongojs-exports.js

@@ -0,0 +0,0 @@ var mongojs = require('../')

test/test-optional-callback.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-pass-mongodb.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-pass-mongojs.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-proxy.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-remove.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-rename-collection.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-runcommand.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-save.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-simple.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-stats.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-streaming-cursor.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-to-json-bulk.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-to-string-bulk.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-to-string-mongos.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-to-string-replica-set.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-to-string.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-update-and-callback.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-update-multi.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-update.js

@@ -0,0 +0,0 @@ var insert = require('./insert')

test/test-user-create.js

@@ -0,0 +0,0 @@ var test = require('./tape')

test/test-user-drop.js

@@ -0,0 +0,0 @@ var test = require('./tape')

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

Debug access

Supply chain risk

Uses debug, reflection and dynamic code execution features.

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

Lines of code

2261

increased by1.48%

Worsened metrics

Total package byte prevSize

168575

decreased by-0.82%

Number of low supply chain risk alerts

2

increased by100%

No dependency changes