Skip to content

Commit af7a792

Browse files
Merge branch 'mrschmidt/indexfree-4' into mrschmidt/indexfree-5
2 parents aef7dc6 + fb7fabf commit af7a792

File tree

1 file changed

+2
-35
lines changed
  • firebase-firestore/ktx/src/test/java/com/google/firebase/firestore

1 file changed

+2
-35
lines changed

firebase-firestore/ktx/src/test/java/com/google/firebase/firestore/TestUtil.java

Lines changed: 2 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -19,21 +19,17 @@
1919
import static com.google.firebase.firestore.testutil.TestUtil.key;
2020
import static org.mockito.Mockito.mock;
2121

22-
import androidx.annotation.Nullable;
2322
import com.google.android.gms.tasks.Task;
2423
import com.google.firebase.database.collection.ImmutableSortedSet;
2524
import com.google.firebase.firestore.core.DocumentViewChange;
2625
import com.google.firebase.firestore.core.DocumentViewChange.Type;
2726
import com.google.firebase.firestore.core.ViewSnapshot;
28-
import com.google.firebase.firestore.local.QueryData;
2927
import com.google.firebase.firestore.model.Document;
3028
import com.google.firebase.firestore.model.DocumentKey;
3129
import com.google.firebase.firestore.model.DocumentSet;
3230
import com.google.firebase.firestore.model.ResourcePath;
3331
import com.google.firebase.firestore.model.value.ObjectValue;
34-
import com.google.firebase.firestore.remote.WatchChangeAggregator;
3532
import java.util.ArrayList;
36-
import java.util.HashMap;
3733
import java.util.List;
3834
import java.util.Map;
3935
import org.junit.Assert;
@@ -133,41 +129,12 @@ public static QuerySnapshot querySnapshot(
133129
documentChanges,
134130
isFromCache,
135131
mutatedKeys,
136-
true,
132+
/* synced= */ true,
133+
/* didSyncStateChange= */ true,
137134
/* excludesMetadataChanges= */ false);
138135
return new QuerySnapshot(query(path), viewSnapshot, FIRESTORE);
139136
}
140137

141-
/**
142-
* An implementation of TargetMetadataProvider that provides controlled access to the
143-
* `TargetMetadataProvider` callbacks. Any target accessed via these callbacks must be registered
144-
* beforehand via `setSyncedKeys()`.
145-
*/
146-
public static class TestTargetMetadataProvider
147-
implements WatchChangeAggregator.TargetMetadataProvider {
148-
final Map<Integer, ImmutableSortedSet<DocumentKey>> syncedKeys = new HashMap<>();
149-
final Map<Integer, QueryData> queryData = new HashMap<>();
150-
151-
@Override
152-
public ImmutableSortedSet<DocumentKey> getRemoteKeysForTarget(int targetId) {
153-
return syncedKeys.get(targetId) != null
154-
? syncedKeys.get(targetId)
155-
: DocumentKey.emptyKeySet();
156-
}
157-
158-
@Nullable
159-
@Override
160-
public QueryData getQueryDataForTarget(int targetId) {
161-
return queryData.get(targetId);
162-
}
163-
164-
/** Sets or replaces the local state for the provided query data. */
165-
public void setSyncedKeys(QueryData queryData, ImmutableSortedSet<DocumentKey> keys) {
166-
this.queryData.put(queryData.getTargetId(), queryData);
167-
this.syncedKeys.put(queryData.getTargetId(), keys);
168-
}
169-
}
170-
171138
public static <T> T waitFor(Task<T> task) {
172139
if (!task.isComplete()) {
173140
Robolectric.flushBackgroundThreadScheduler();

0 commit comments

Comments
 (0)