Skip to content

Commit 2165415

Browse files
committed
fix onQuery
1 parent 8e7ed6b commit 2165415

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

index.js

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -60,17 +60,18 @@ module.exports = function(store) {
6060

6161
};
6262

63-
store.onQuery = function(collectionName, source, cb) {
63+
store.onQuery = function(collectionName, cb) {
6464
return this.shareClient.use('query', function(shareRequest, next) {
6565
var session;
66-
if (shareRequest.options.backend !== source) {
67-
return next();
68-
}
66+
6967
session = shareRequest.agent.connectSession;
70-
shareRequest.query = deepCopy(shareRequest.query);
68+
7169
if (collectionName === '*') {
7270
return cb(shareRequest.collection, shareRequest.query, session, next);
7371
} else {
72+
if (shareRequest.collection !== collectionName) {
73+
return next();
74+
}
7475
return cb(shareRequest.query, session, next);
7576
}
7677
});
@@ -101,4 +102,4 @@ function lookup(segments, doc) {
101102
}
102103
}
103104
return curr;
104-
};
105+
};

0 commit comments

Comments
 (0)