Merge branch 'temp-branch' into migrate/3.0

.github/workflows/testsuite.yml

@@ -12,8 +12,7 @@ jobs:
     strategy:
       matrix:
         meteorRelease:
-          - '--release 3.0.3'
-          # Latest version
+          - '--release 3.0.2'
     steps:
       - name: Checkout code
         uses: actions/checkout@v4
@@ -27,6 +26,7 @@ jobs:
         run: |
           curl https://install.meteor.com | /bin/sh
           npm i -g @zodern/mtest
+
       - name: Run Tests
         run: |
           mtest --package ./ --once ${{ matrix.meteorRelease }}

package.js

@@ -8,7 +8,7 @@ Package.describe({
 })
 
 Package.onUse(function (api) {
-  api.versionsFrom(['3.0.3'])
+  api.versionsFrom(['3.0.2'])
 
   api.use([
     'mongo',
@@ -29,12 +29,12 @@ Package.onUse(function (api) {
 })
 
 Package.onTest(function (api) {
-  api.versionsFrom(['3.0.3'])
+  api.versionsFrom(['3.0.2'])
 
   api.use([
     'matb33:collection-hooks',
     'accounts-base',
-    'accounts-password@3.0.1',
+    'accounts-password',
     'mongo',
     'ddp',
     'tinytest',

tests/find_after_hooks.js

@@ -52,3 +52,37 @@ Tinytest.addAsync('issue #296 - after insert hook always finds all inserted', as
   test.equal(beforeCalled, true)
   test.equal(afterCalled, true)
 })
+
+Tinytest.addAsync('async find hook - after insert hook always finds all inserted', async function (test, next) {
+  const collection = new Mongo.Collection(null)
+
+  collection.before.find(async (userId, selector) => {
+    await new Promise(resolve => setTimeout(resolve, 10)) // Simulate async operation
+    selector.removedAt = { $exists: false }
+    return true
+  })
+
+  let beforeCalled = false
+  collection.before.insert(() => {
+    beforeCalled = true
+  })
+
+  let afterCalled = false
+  collection.after.insert(() => {
+    afterCalled = true
+  })
+
+  await collection.insertAsync({ removedAt: new Date() })
+
+  // Wait for a short time to ensure async find hook has completed
+  await new Promise(resolve => setTimeout(resolve, 20))
+
+  test.equal(beforeCalled, true)
+  test.equal(afterCalled, true)
+
+  // Verify that the find hook is working
+  const result = await collection.findOneAsync({})
+  test.isUndefined(result, 'Document should not be found due to async find hook')
+
+  next()
+})