update test

firebase · Mar 11, 2024 · a340dd6 · a340dd6
1 parent 0172b64
commit a340dd6
Showing 1 changed file with 21 additions and 22 deletions.
diff --git a/packages/firestore/test/integration/api/snasphot_listener_source.test.ts b/packages/firestore/test/integration/api/snasphot_listener_source.test.ts
@@ -17,7 +17,6 @@
 
 import { expect } from 'chai';
 
-import { ListenerDataSource as Source } from '../../../src/core/event_manager';
 import { EventsAccumulator } from '../util/events_accumulator';
 import {
   addDoc,
@@ -59,7 +58,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeEvent = new EventsAccumulator<QuerySnapshot>();
           const unsubscribe = onSnapshot(
             coll,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeEvent.storeEvent
           );
 
@@ -83,7 +82,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
             const storeEvent = new EventsAccumulator<DocumentSnapshot>();
             const unsubscribe = onSnapshot(
               docRef,
-              { source: Source.Cache },
+              { source: 'cache' },
               storeEvent.storeEvent
             );
 
@@ -107,7 +106,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeEvent = new EventsAccumulator<QuerySnapshot>();
           const unsubscribe = onSnapshot(
             coll,
-            { includeMetadataChanges: true, source: Source.Cache },
+            { includeMetadataChanges: true, source: 'cache' },
             storeEvent.storeEvent
           );
 
@@ -139,13 +138,13 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeEvent = new EventsAccumulator<QuerySnapshot>();
           const unsubscribe1 = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeEvent.storeEvent
           );
 
           const unsubscribe2 = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeEvent.storeEvent
           );
 
@@ -207,15 +206,15 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeLimitEvent = new EventsAccumulator<QuerySnapshot>();
           let limitUnlisten = onSnapshot(
             query(coll, orderBy('sort', 'asc'), limit(2)),
-            { source: Source.Cache },
+            { source: 'cache' },
             storeLimitEvent.storeEvent
           );
 
           // Setup mirroring `limitToLast` query
           const storeLimitToLastEvent = new EventsAccumulator<QuerySnapshot>();
           let limitToLastUnlisten = onSnapshot(
             query(coll, orderBy('sort', 'desc'), limitToLast(2)),
-            { source: Source.Cache },
+            { source: 'cache' },
             storeLimitToLastEvent.storeEvent
           );
 
@@ -235,7 +234,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           limitUnlisten();
           limitUnlisten = onSnapshot(
             query(coll, orderBy('sort', 'asc'), limit(2)),
-            { source: Source.Cache },
+            { source: 'cache' },
             storeLimitEvent.storeEvent
           );
           snapshot = await storeLimitEvent.awaitEvent();
@@ -269,7 +268,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           await updateDoc(doc(coll, 'a'), { k: 'a', sort: -2 });
           limitToLastUnlisten = onSnapshot(
             query(coll, orderBy('sort', 'desc'), limitToLast(2)),
-            { source: Source.Cache },
+            { source: 'cache' },
             storeLimitToLastEvent.storeEvent
           );
 
@@ -320,7 +319,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeCacheEvent = new EventsAccumulator<QuerySnapshot>();
           const cacheUnlisten = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeCacheEvent.storeEvent
           );
           snapshot = await storeCacheEvent.awaitEvent();
@@ -352,7 +351,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
 
           const cacheUnlisten = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeCacheEvent.storeEvent
           );
           let snapshot = await storeCacheEvent.awaitEvent();
@@ -401,7 +400,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeEvent = new EventsAccumulator<QuerySnapshot>();
           const unsubscribe = onSnapshot(
             testQuery,
-            { includeMetadataChanges: true, source: Source.Cache },
+            { includeMetadataChanges: true, source: 'cache' },
             storeEvent.storeEvent
           );
 
@@ -443,7 +442,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeCacheEvent = new EventsAccumulator<QuerySnapshot>();
           const cacheUnlisten = onSnapshot(
             testQuery,
-            { includeMetadataChanges: true, source: Source.Cache },
+            { includeMetadataChanges: true, source: 'cache' },
             storeCacheEvent.storeEvent
           );
           let snapshot = await storeCacheEvent.awaitEvent();
@@ -523,7 +522,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeCacheEvent = new EventsAccumulator<QuerySnapshot>();
           const cacheUnlisten = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeCacheEvent.storeEvent
           );
           await storeCacheEvent.awaitEvent();
@@ -568,7 +567,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeCacheEvent = new EventsAccumulator<QuerySnapshot>();
           const cacheUnlisten = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeCacheEvent.storeEvent
           );
           await storeCacheEvent.awaitEvent();
@@ -617,7 +616,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeCacheEvent = new EventsAccumulator<QuerySnapshot>();
           let cacheUnlisten = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeCacheEvent.storeEvent
           );
           snapshot = await storeCacheEvent.awaitEvent();
@@ -651,7 +650,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
 
           cacheUnlisten = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeCacheEvent.storeEvent
           );
 
@@ -679,7 +678,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeEvent = new EventsAccumulator<QuerySnapshot>();
           const unsubscribe = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeEvent.storeEvent
           );
 
@@ -695,7 +694,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           expect(toDataArray(snapshot)).to.deep.equal([]); // Precondition check.
 
           const storeEvent = new EventsAccumulator<QuerySnapshot>();
-          onSnapshot(coll, { source: Source.Cache }, storeEvent.storeEvent);
+          onSnapshot(coll, { source: 'cache' }, storeEvent.storeEvent);
           snapshot = await storeEvent.awaitEvent();
           expect(snapshot.metadata.fromCache).to.be.true;
           expect(toDataArray(snapshot)).to.deep.equal([]);
@@ -707,7 +706,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const accumulator = new EventsAccumulator<QuerySnapshot>();
           const unsubscribe = onSnapshot(
             coll,
-            { source: Source.Cache },
+            { source: 'cache' },
             accumulator.storeEvent
           );
 
@@ -752,7 +751,7 @@ apiDescribe('Snapshot Listener source options ', persistence => {
           const storeCacheEvent = new EventsAccumulator<QuerySnapshot>();
           const cacheUnlisten = onSnapshot(
             testQuery,
-            { source: Source.Cache },
+            { source: 'cache' },
             storeCacheEvent.storeEvent
           );
           snapshot = await storeCacheEvent.awaitEvent();