Using GoogleCredentials and ApiFutures in sample snippets

Author: hiranya911

auth/src/main/java/com/google/firebase/quickstart/AuthSnippets.java

@@ -1,15 +1,15 @@
 package com.google.firebase.quickstart;
 
+import com.google.auth.oauth2.GoogleCredentials;
 import com.google.firebase.FirebaseApp;
 import com.google.firebase.FirebaseOptions;
 import com.google.firebase.auth.FirebaseAuth;
-import com.google.firebase.auth.FirebaseCredentials;
 import com.google.firebase.auth.UserRecord;
 import com.google.firebase.auth.UserRecord.CreateRequest;
 import com.google.firebase.auth.UserRecord.UpdateRequest;
-import com.google.firebase.tasks.Task;
 import java.io.FileInputStream;
 import java.io.IOException;
+import java.util.concurrent.ExecutionException;
 
 /**
  * Auth snippets for documentation.
@@ -19,52 +19,32 @@
  */
 public class AuthSnippets {
 
-  public static Task<UserRecord> getUserById(String uid) {
+  public static void getUserById(String uid) throws InterruptedException, ExecutionException {
     // [START get_user_by_id]
-    Task<UserRecord> task = FirebaseAuth.getInstance().getUser(uid)
-        .addOnSuccessListener(userRecord -> {
-          // See the UserRecord reference doc for the contents of userRecord.
-          System.out.println("Successfully fetched user data: " + userRecord.getUid());
-        })
-        .addOnFailureListener(e -> {
-          System.err.println("Error fetching user data: " + e.getMessage());
-        });
+    UserRecord userRecord = FirebaseAuth.getInstance().getUserAsync(uid).get();
+    // See the UserRecord reference doc for the contents of userRecord.
+    System.out.println("Successfully fetched user data: " + userRecord.getUid());
     // [END get_user_by_id]
-
-    return task;
   }
 
-  public static Task<UserRecord> getUserByEmail(String email) {
+  public static void getUserByEmail(String email) throws InterruptedException, ExecutionException {
     // [START get_user_by_email]
-    Task<UserRecord> task = FirebaseAuth.getInstance().getUserByEmail(email)
-        .addOnSuccessListener(userRecord -> {
-          // See the UserRecord reference doc for the contents of userRecord.
-          System.out.println("Successfully fetched user data: " + userRecord.getEmail());
-        })
-        .addOnFailureListener(e -> {
-          System.err.println("Error fetching user data: " + e.getMessage());
-        });
+    UserRecord userRecord = FirebaseAuth.getInstance().getUserByEmailAsync(email).get();
+    // See the UserRecord reference doc for the contents of userRecord.
+    System.out.println("Successfully fetched user data: " + userRecord.getEmail());
     // [END get_user_by_email]
-
-    return task;
   }
 
-  public static Task<UserRecord> getUserByPhoneNumber(String phoneNumber) {
+  public static void getUserByPhoneNumber(
+      String phoneNumber) throws InterruptedException, ExecutionException {
     // [START get_user_by_phone]
-    Task<UserRecord> task = FirebaseAuth.getInstance().getUserByPhoneNumber(phoneNumber)
-        .addOnSuccessListener(userRecord -> {
-          // See the UserRecord reference doc for the contents of userRecord.
-          System.out.println("Successfully fetched user data: " + userRecord.getPhoneNumber());
-        })
-        .addOnFailureListener(e -> {
-          System.err.println("Error fetching user data: " + e.getMessage());
-        });
+    UserRecord userRecord = FirebaseAuth.getInstance().getUserByPhoneNumberAsync(phoneNumber).get();
+    // See the UserRecord reference doc for the contents of userRecord.
+    System.out.println("Successfully fetched user data: " + userRecord.getPhoneNumber());
     // [END get_user_by_phone]
-
-    return task;
   }
 
-  public static Task<UserRecord> createUser() {
+  public static void createUser() throws InterruptedException, ExecutionException {
     // [START create_user]
     CreateRequest request = new CreateRequest()
         .setEmail("[email protected]")
@@ -75,40 +55,24 @@ public static Task<UserRecord> createUser() {
         .setPhotoUrl("http://www.example.com/12345678/photo.png")
         .setDisabled(false);
 
-    Task<UserRecord> task = FirebaseAuth.getInstance().createUser(request)
-        .addOnSuccessListener(userRecord -> {
-          // See the UserRecord reference doc for the contents of userRecord.
-          System.out.println("Successfully created new user: " + userRecord.getUid());
-        })
-        .addOnFailureListener(e -> {
-          System.err.println("Error creating new user: " + e.getMessage());
-        });
+    UserRecord userRecord = FirebaseAuth.getInstance().createUserAsync(request).get();
+    System.out.println("Successfully created new user: " + userRecord.getUid());
     // [END create_user]
-
-    return task;
   }
 
-  public static Task<UserRecord> createUserWithUid() {
+  public static void createUserWithUid() throws InterruptedException, ExecutionException {
     // [START create_user_with_uid]
     CreateRequest request = new CreateRequest()
         .setUid("some-uid")
         .setEmail("[email protected]")
         .setPhoneNumber("+11234567890");
 
-    Task<UserRecord> task = FirebaseAuth.getInstance().createUser(request)
-        .addOnSuccessListener(userRecord -> {
-          // See the UserRecord reference doc for the contents of userRecord.
-          System.out.println("Successfully created new user: " + userRecord.getUid());
-        })
-        .addOnFailureListener(e -> {
-          System.err.println("Error creating new user: " + e.getMessage());
-        });
+    UserRecord userRecord = FirebaseAuth.getInstance().createUserAsync(request).get();
+    System.out.println("Successfully created new user: " + userRecord.getUid());
     // [END create_user_with_uid]
-
-    return task;
   }
 
-  public static Task<UserRecord> updateUser(String uid) {
+  public static void updateUser(String uid) throws InterruptedException, ExecutionException {
     // [START update_user]
     UpdateRequest request = new UpdateRequest(uid)
         .setEmail("[email protected]")
@@ -119,38 +83,27 @@ public static Task<UserRecord> updateUser(String uid) {
         .setPhotoUrl("http://www.example.com/12345678/photo.png")
         .setDisabled(true);
 
-    Task<UserRecord> task = FirebaseAuth.getInstance().updateUser(request)
-        .addOnSuccessListener(userRecord -> {
-          // See the UserRecord reference doc for the contents of userRecord.
-          System.out.println("Successfully updated user: " + userRecord.getUid());
-        })
-        .addOnFailureListener(e -> {
-          System.err.println("Error updating user: " + e.getMessage());
-        });
+    UserRecord userRecord = FirebaseAuth.getInstance().updateUserAsync(request).get();
+    System.out.println("Successfully updated user: " + userRecord.getUid());
     // [END update_user]
-
-    return task;
   }
 
-  public static Task<Void> deleteUser(String uid) {
+  public static void deleteUser(String uid) throws InterruptedException, ExecutionException {
     // [START delete_user]
-    Task<Void> task = FirebaseAuth.getInstance().deleteUser(uid)
-        .addOnSuccessListener(aVoid -> System.out.println("Successfully deleted user."))
-        .addOnFailureListener(e -> System.err.println("Error updating user: " + e.getMessage()));
+    FirebaseAuth.getInstance().deleteUserAsync(uid).get();
+    System.out.println("Successfully deleted user.");
     // [END delete_user]
-
-    return task;
   }
 
-  public static void main(String[] args) {
+  public static void main(String[] args) throws InterruptedException, ExecutionException {
     System.out.println("Hello, AuthSnippets!");
 
     // Initialize Firebase
     try {
       // [START initialize]
       FileInputStream serviceAccount = new FileInputStream("service-account.json");
       FirebaseOptions options = new FirebaseOptions.Builder()
-          .setCredential(FirebaseCredentials.fromCertificate(serviceAccount))
+          .setCredentials(GoogleCredentials.fromStream(serviceAccount))
           .build();
       FirebaseApp.initializeApp(options);
       // [END initialize]
@@ -162,13 +115,13 @@ public static void main(String[] args) {
     }
 
     // Smoke test
-    createUserWithUid()
-        .continueWithTask(task -> getUserById("some-uid"))
-        .continueWithTask(task -> getUserByEmail("[email protected]"))
-        .continueWithTask(task -> getUserByPhoneNumber("+11234567890"))
-        .continueWithTask(task -> updateUser("some-uid"))
-        .continueWithTask(task -> deleteUser("some-uid"))
-        .addOnCompleteListener(task -> System.out.println("Done! Success: " + task.isSuccessful()));
+    createUserWithUid();
+    getUserById("some-uid");
+    getUserByEmail("[email protected]");
+    getUserByPhoneNumber("+11234567890");
+    updateUser("some-uid");
+    deleteUser("some-uid");
+    System.out.println("Done!");
   }
 
 }

database/src/main/java/com/google/firebase/quickstart/Database.java

@@ -15,17 +15,17 @@
  */
 package com.google.firebase.quickstart;
 
+import com.google.auth.oauth2.GoogleCredentials;
 import com.google.firebase.FirebaseApp;
 import com.google.firebase.FirebaseOptions;
-import com.google.firebase.auth.FirebaseCredentials;
 import com.google.firebase.database.*;
 import com.google.firebase.quickstart.email.MyEmailer;
 import com.google.firebase.quickstart.model.Post;
 import com.google.firebase.quickstart.model.User;
+import java.io.IOException;
 import org.knowm.sundial.SundialJobScheduler;
 
 import java.io.FileInputStream;
-import java.io.FileNotFoundException;
 
 /**
  * Firebase Database quickstart sample for the Java Admin SDK.
@@ -184,12 +184,12 @@ public static void main(String[] args) {
             // [START initialize]
             FileInputStream serviceAccount = new FileInputStream("service-account.json");
             FirebaseOptions options = new FirebaseOptions.Builder()
-                    .setCredential(FirebaseCredentials.fromCertificate(serviceAccount))
+                    .setCredentials(GoogleCredentials.fromStream(serviceAccount))
                     .setDatabaseUrl(DATABASE_URL)
                     .build();
             FirebaseApp.initializeApp(options);
             // [END initialize]
-        } catch (FileNotFoundException e) {
+        } catch (IOException e) {
             System.out.println("ERROR: invalid service account credentials. See README.");
             System.out.println(e.getMessage());