more get tests

Author: jmwski

firebase-database/src/androidTest/java/com/google/firebase/database/QueryTest.java

@@ -23,6 +23,8 @@
 
 import androidx.annotation.NonNull;
 import androidx.test.ext.junit.runners.AndroidJUnit4;
+
+import com.google.android.gms.tasks.Continuation;
 import com.google.android.gms.tasks.OnCompleteListener;
 import com.google.android.gms.tasks.Task;
 import com.google.firebase.database.core.DatabaseConfig;
@@ -3406,7 +3408,6 @@ public void onComplete(DatabaseError error, DatabaseReference ref) {
 
   @Test
   public void emptyQueryGet() throws DatabaseException, InterruptedException {
-    assertTrue(false);
     DatabaseReference node = IntegrationTestHelpers.getRandomNode();
     final Semaphore semaphore = new Semaphore(0);
     node.get()
@@ -3423,6 +3424,75 @@ public void onComplete(@NonNull Task<DataSnapshot> task) {
     IntegrationTestHelpers.waitFor(semaphore);
   }
 
+  @Test
+  public void offlineQueryGet() throws DatabaseException {
+    DatabaseConfig cfg = IntegrationTestHelpers.newTestConfig();
+    IntegrationTestHelpers.goOffline(cfg);
+    DatabaseReference node = IntegrationTestHelpers.getRandomNode();
+    node.get()
+      .addOnCompleteListener(new OnCompleteListener<DataSnapshot>() {
+        @Override
+        public void onComplete(@NonNull Task<DataSnapshot> task) {
+          assertFalse(task.isSuccessful());
+          assertTrue(task.isCanceled());
+          assertNotNull(task.getException());
+          assertEquals(task.getException().getMessage(), "Client offline with empty cache!");
+        }
+      });
+  }
+
+  @Test
+  public void getQueryBasic() throws DatabaseException, InterruptedException {
+    DatabaseReference ref = IntegrationTestHelpers.getRandomNode();
+    final Semaphore semaphore = new Semaphore(0);
+    ref.setValue(42).continueWithTask(new Continuation<Void, Task<DataSnapshot>>() {
+      @Override
+      public Task<DataSnapshot> then(@NonNull Task<Void> task) throws Exception {
+        assertTrue(task.isSuccessful());
+        return ref.get()
+          .addOnCompleteListener(new OnCompleteListener<DataSnapshot>() {
+            @Override
+            public void onComplete(@NonNull Task<DataSnapshot> task) {
+              assertTrue(task.isSuccessful());
+              DataSnapshot snap = task.getResult();
+              assertNotNull(snap);
+              assertEquals(42, snap.getValue());
+              semaphore.release();
+            }
+          });
+      }
+    });
+    IntegrationTestHelpers.waitFor(semaphore);
+  }
+
+  @Test
+  public void getQueryCached() throws DatabaseException, InterruptedException, TimeoutException, TestFailure {
+    DatabaseReference ref = IntegrationTestHelpers.getRandomNode();
+    DatabaseConfig cfg = IntegrationTestHelpers.newTestConfig();
+    ReadFuture future = ReadFuture.untilNonNull(ref);
+    ref.setValue(42);
+    assertEquals(42, future.waitForLastValue());
+    IntegrationTestHelpers.goOffline(cfg);
+    final Semaphore semaphore = new Semaphore(0);
+    ref.get().addOnCompleteListener(new OnCompleteListener<DataSnapshot>() {
+      @Override
+      public void onComplete(@NonNull Task<DataSnapshot> task) {
+        assertTrue(task.isSuccessful());
+        DataSnapshot snapshot = task.getResult();
+        assertNotNull(snapshot);
+        assertEquals(42, snapshot.getValue());
+        semaphore.release();
+      }
+    });
+    IntegrationTestHelpers.waitFor(semaphore);
+  }
+
+  @Test
+  public void getQuerySkipsCache() throws DatabaseException {
+    DatabaseReference ref = IntegrationTestHelpers.getRandomNode();
+    DatabaseConfig cfg = IntegrationTestHelpers.newTestConfig();
+  }
+
   @Test
   public void querySnapshotChildrenRespectDefaultOrdering()
       throws DatabaseException, ExecutionException, TimeoutException, TestFailure,