Add test 'bloom filter should correctly encode special unicode characters' to query.test.ts

Author: dconeybe

packages/firestore/test/integration/api/query.test.ts

@@ -32,6 +32,7 @@ import {
   doc,
   DocumentChange,
   DocumentChangeType,
+  DocumentData,
   documentId,
   enableNetwork,
   endAt,
@@ -2197,6 +2198,122 @@ apiDescribe('Queries', persistence => {
       });
     });
   }).timeout('90s');
+
+  // TODO(b/270731363): Re-enable this test once the Firestore emulator is fixed
+  //  to send an existence filter.
+  // eslint-disable-next-line no-restricted-properties
+  (USE_EMULATOR ? it.skip : it.only)(
+    'bloom filter should correctly encode special unicode characters',
+    async () => {
+      const testDocIds = [
+        'DocumentToDelete',
+        'LowercaseEWithAcuteAccent_\u00E9',
+        'LowercaseEWithAcuteAccent_\u0065\u0301',
+        'LowercaseEWithMultipleAccents_\u0065\u0301\u0327',
+        'LowercaseEWithMultipleAccents_\u0065\u0327\u0301',
+        'Smiley_\u{1F600}'
+      ];
+      const testDocs = testDocIds.reduce((map, docId) => {
+        map[docId] = { foo: 42 };
+        return map;
+      }, {} as { [key: string]: DocumentData });
+
+      // Ensure that the local cache is configured to use LRU garbage
+      // collection (rather than eager garbage collection) so that the resume
+      // token and document data does not get prematurely evicted.
+      const lruPersistence = persistence.toLruGc();
+
+      return withRetry(async attemptNumber => {
+        return withTestCollection(
+          lruPersistence,
+          testDocs,
+          async (coll, db) => {
+            // Run a query to populate the local cache with documents that have
+            // names with complex Unicode characters.
+            const snapshot1 = await getDocs(coll);
+            const snapshot1DocumentIds = snapshot1.docs.map(
+              documentSnapshot => documentSnapshot.id
+            );
+            expect(
+              snapshot1DocumentIds,
+              'snapshot1DocumentIds'
+            ).to.have.members(testDocIds);
+
+            // Delete one of the documents so that the next call to getDocs() will
+            // experience an existence filter mismatch. Do this deletion in a
+            // transaction, rather than using deleteDoc(), to avoid affecting the
+            // local cache.
+            await runTransaction(db, async txn => {
+              const snapshotOfDocumentToDelete = await txn.get(
+                doc(coll, 'DocumentToDelete')
+              );
+              expect(
+                snapshotOfDocumentToDelete.exists(),
+                'snapshotOfDocumentToDelete.exists()'
+              ).to.be.true;
+              txn.delete(snapshotOfDocumentToDelete.ref);
+            });
+
+            // Wait for 10 seconds, during which Watch will stop tracking the
+            // query and will send an existence filter rather than "delete" events
+            // when the query is resumed.
+            await new Promise(resolve => setTimeout(resolve, 10000));
+
+            // Resume the query and save the resulting snapshot for verification.
+            // Use some internal testing hooks to "capture" the existence filter
+            // mismatches.
+            const [existenceFilterMismatches, snapshot2] =
+              await captureExistenceFilterMismatches(() => getDocs(coll));
+            const snapshot2DocumentIds = snapshot2.docs.map(
+              documentSnapshot => documentSnapshot.id
+            );
+            const testDocIdsMinusDeletedDocId = testDocIds.filter(
+              documentId => documentId !== 'DocumentToDelete'
+            );
+            expect(
+              snapshot2DocumentIds,
+              'snapshot2DocumentIds'
+            ).to.have.members(testDocIdsMinusDeletedDocId);
+
+            // Verify that Watch sent an existence filter with the correct counts.
+            expect(
+              existenceFilterMismatches,
+              'existenceFilterMismatches'
+            ).to.have.length(1);
+            const { localCacheCount, existenceFilterCount, bloomFilter } =
+              existenceFilterMismatches[0];
+            expect(localCacheCount, 'localCacheCount').to.equal(
+              testDocIds.length
+            );
+            expect(existenceFilterCount, 'existenceFilterCount').to.equal(
+              testDocIds.length - 1
+            );
+
+            // Verify that Watch sent a valid bloom filter.
+            if (!bloomFilter) {
+              expect.fail(
+                'The existence filter should have specified a bloom filter ' +
+                  'in its `unchanged_names` field.'
+              );
+              throw new Error('should never get here');
+            }
+
+            // Verify that the bloom filter was successfully used to avert a full
+            // requery. If a false positive occurred, which is statistically rare,
+            // but technically possible, then retry the entire test.
+            if (attemptNumber === 1 && !bloomFilter.applied) {
+              throw new RetryError();
+            }
+
+            expect(
+              bloomFilter.applied,
+              `bloomFilter.applied with attemptNumber=${attemptNumber}`
+            ).to.be.true;
+          }
+        );
+      });
+    }
+  ).timeout('90s');
 });
 
 function verifyDocumentChange<T>(