Merge pull request #37 from makinde/session_support

martin-css · web-flow · commit 905cccb1efea · 2020-05-04T15:02:00.000+01:00
Adding session support
diff --git a/lib/id-validator.js b/lib/id-validator.js
@@ -119,6 +119,10 @@ function validateId (
     }
     var refModel = connection.model(refModelName)
     var query = refModel.countDocuments({_id: value})
+    var session = doc.$session && doc.$session()
+    if (session) {
+        query.session(session)
+    }
     executeQuery(query, conditions, 1, resolve, reject)
 }
 
@@ -140,6 +144,10 @@ function validateIdArray (
 
     var refModel = connection.model(refModelName)
     var query = refModel.countDocuments().where('_id')['in'](checkValues)
+    var session = doc.$session && doc.$session()
+    if (session) {
+        query.session(session)
+    }
 
     executeQuery(query, conditions, checkValues.length, resolve, reject)
 }

Original file line number	Diff line number	Diff line change
`@@ -119,6 +119,10 @@ function validateId (`
`119`	`119`	`}`
`120`	`120`	`var refModel = connection.model(refModelName)`
`121`	`121`	`var query = refModel.countDocuments({_id: value})`
	`122`	`+ var session = doc.$session && doc.$session()`
	`123`	`+ if (session) {`
	`124`	`+ query.session(session)`
	`125`	`+ }`
`122`	`126`	`executeQuery(query, conditions, 1, resolve, reject)`
`123`	`127`	`}`
`124`	`128`
`@@ -140,6 +144,10 @@ function validateIdArray (`
`140`	`144`
`141`	`145`	`var refModel = connection.model(refModelName)`
`142`	`146`	`var query = refModel.countDocuments().where('_id')['in'](checkValues)`
	`147`	`+ var session = doc.$session && doc.$session()`
	`148`	`+ if (session) {`
	`149`	`+ query.session(session)`
	`150`	`+ }`
`143`	`151`
`144`	`152`	`executeQuery(query, conditions, checkValues.length, resolve, reject)`
`145`	`153`	`}`