|
@@ -1,4 +1,3 @@
|
|
|
-const { ReadPreference } = require('mongodb')
|
|
|
|
|
const _ = require('lodash')
|
|
const _ = require('lodash')
|
|
|
const { formatTokenUsageStats } = require('./format-usage-stats')
|
|
const { formatTokenUsageStats } = require('./format-usage-stats')
|
|
|
|
|
|
|
@@ -26,12 +25,14 @@ async function reEncryptTokens(accessTokenEncryptor, encryptedJson) {
|
|
|
* @param {AccessTokenEncryptor} accessTokenEncryptor
|
|
* @param {AccessTokenEncryptor} accessTokenEncryptor
|
|
|
* @param {Collection} collection
|
|
* @param {Collection} collection
|
|
|
* @param {Object} paths
|
|
* @param {Object} paths
|
|
|
|
|
+ * @param {Object} queryOptions
|
|
|
* @return {Promise<{}>}
|
|
* @return {Promise<{}>}
|
|
|
*/
|
|
*/
|
|
|
async function reEncryptTokensInCollection({
|
|
async function reEncryptTokensInCollection({
|
|
|
accessTokenEncryptor,
|
|
accessTokenEncryptor,
|
|
|
collection,
|
|
collection,
|
|
|
paths,
|
|
paths,
|
|
|
|
|
+ queryOptions,
|
|
|
}) {
|
|
}) {
|
|
|
const { collectionName } = collection
|
|
const { collectionName } = collection
|
|
|
const stats = {}
|
|
const stats = {}
|
|
@@ -56,7 +57,7 @@ async function reEncryptTokensInCollection({
|
|
|
const cursor = collection.find(
|
|
const cursor = collection.find(
|
|
|
{},
|
|
{},
|
|
|
{
|
|
{
|
|
|
- readPreference: ReadPreference.secondaryPreferred,
|
|
|
|
|
|
|
+ ...queryOptions,
|
|
|
projection,
|
|
projection,
|
|
|
}
|
|
}
|
|
|
)
|
|
)
|