Fix override

cult-of-coders · Apr 10, 2024 · 24abd09 · 24abd09
1 parent 051591f
commit 24abd09
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 10 deletions.
diff --git a/lib/cache/ObservableCollection.js b/lib/cache/ObservableCollection.js
@@ -69,7 +69,7 @@ export default class ObservableCollection {
             );
         }
 
-        this.cursor = this.collection.find(
+        this.cursor = this.collection._redisOplogCollectionMethods.find(
             cursorDescription.selector,
             cursorDescription.options
         );
@@ -155,7 +155,7 @@ export default class ObservableCollection {
      */
     isEligibleByDB(_id) {
         if (this.matcher) {
-            return !!this.collection.findOne(
+            return !!this.collection._redisOplogCollectionMethods.findOne(
                 Object.assign({}, this.selector, { _id }),
                 { fields: { _id: 1 } }
             );
@@ -214,7 +214,7 @@ export default class ObservableCollection {
      */
     addById(docId) {
         const { limit, skip, ...cleanedOptions } = this.options;
-        const doc = this.collection.findOne({ _id: docId }, cleanedOptions);
+        const doc = this.collection._redisOplogCollectionMethods.findOne({ _id: docId }, cleanedOptions);
 
         this.store.set(docId, doc);
 

diff --git a/lib/mongo/mongoCollectionNames.js b/lib/mongo/mongoCollectionNames.js
@@ -4,7 +4,7 @@ const constructor = Mongo.Collection;
 const proto = Mongo.Collection.prototype;
 
 const hook = function() {
-    let ret = constructor.apply(this, arguments);
+    const ret = constructor.apply(this, arguments);
     map[arguments[0]] = this;
     return ret;
 };
@@ -17,9 +17,7 @@ hook.__getCollectionByName = function (name) {
     const collection = map[name];
 
     // Use 'direct', if available, to skip all collection hooks
-    if (collection.direct) {
-        Object.assign(collection, collection.direct);
-    }
+    collection._redisOplogCollectionMethods = collection.direct ?? collection;
 
     return collection;
 };

diff --git a/lib/processors/actions/requery.js b/lib/processors/actions/requery.js
@@ -12,7 +12,7 @@ export default function (observableCollection, newcomer, event, modifiedFields)
     const { store, selector, options } = observableCollection;
 
     const newStore = new MongoIDMap();
-    const freshIds = observableCollection.collection.find(selector, { ...options, fields: { _id: 1 } }).fetch();
+    const freshIds = observableCollection.collection._redisOplogCollectionMethods.find(selector, { ...options, fields: { _id: 1 } }).fetch();
     freshIds.forEach((doc) => newStore.set(doc._id, doc));
 
     let added = false;

diff --git a/lib/redis/RedisSubscriptionManager.js b/lib/redis/RedisSubscriptionManager.js
@@ -209,9 +209,9 @@ class RedisSubscriptionManager {
         const fieldsOfInterest = getFieldsOfInterestFromAll(subscribers);
 
         if (fieldsOfInterest === true) {
-            doc = collection.findOne(doc._id);
+            doc = collection._redisOplogCollectionMethods.findOne(doc._id);
         } else {
-            doc = collection.findOne(doc._id, { fields: fieldsOfInterest });
+            doc = collection._redisOplogCollectionMethods.findOne(doc._id, { fields: fieldsOfInterest });
         }
 
         return doc;