Removing dependency for activities

firebase-app-distribution/src/main/java/com/google/firebase/appdistribution/AabUpdater.java

@@ -19,6 +19,7 @@
 import static com.google.firebase.appdistribution.TaskUtils.safeSetTaskException;
 
 import android.app.Activity;
+import android.content.Context;
 import android.content.Intent;
 import android.net.Uri;
 import androidx.annotation.GuardedBy;
@@ -48,18 +49,22 @@ class AabUpdater {
   private AppDistributionReleaseInternal aabReleaseInProgress;
 
   private final Object updateAabLock = new Object();
+  private final Context context;
 
-  AabUpdater() {
+  AabUpdater(@NonNull Context context) {
     this(
+        context,
         FirebaseAppDistributionLifecycleNotifier.getInstance(),
         new HttpsUrlConnectionFactory(),
         Executors.newSingleThreadExecutor());
   }
 
   AabUpdater(
+      @NonNull Context context,
       @NonNull FirebaseAppDistributionLifecycleNotifier lifecycleNotifier,
       @NonNull HttpsUrlConnectionFactory httpsUrlConnectionFactory,
       @NonNull Executor executor) {
+    this.context = context;
     this.lifecycleNotifier = lifecycleNotifier;
     this.httpsUrlConnectionFactory = httpsUrlConnectionFactory;
     lifecycleNotifier.addOnActivityStartedListener(this::onActivityStarted);
@@ -134,16 +139,6 @@ private static boolean isRedirectResponse(int responseCode) {
   }
 
   private void redirectToPlayForAabUpdate(String downloadUrl) {
-    synchronized (updateAabLock) {
-      // TODO(rachelprince): change this to getCurrentNonNullActivity
-      if (lifecycleNotifier.getCurrentActivity() == null) {
-        safeSetTaskException(
-            cachedUpdateTask,
-            new FirebaseAppDistributionException(ErrorMessages.APP_BACKGROUNDED, DOWNLOAD_FAILURE));
-        return;
-      }
-    }
-
     // The 302 redirect is obtained here to open the play store directly and avoid opening chrome
     executor.execute( // Execute the network calls on a background thread
         () -> {
@@ -161,7 +156,7 @@ private void redirectToPlayForAabUpdate(String downloadUrl) {
           LogWrapper.getInstance().v(TAG + "Redirecting to play");
 
           synchronized (updateAabLock) {
-            lifecycleNotifier.getCurrentActivity().startActivity(updateIntent);
+            context.startActivity(updateIntent);
             cachedUpdateTask.updateProgress(
                 UpdateProgress.builder()
                     .setApkBytesDownloaded(-1)

firebase-app-distribution/src/main/java/com/google/firebase/appdistribution/ApkUpdater.java

@@ -51,6 +51,7 @@ class ApkUpdater {
   private TaskCompletionSource<File> downloadTaskCompletionSource;
   private final Executor taskExecutor; // Executor to run task listeners on a background thread
   private final FirebaseApp firebaseApp;
+  private final Context applicationContext;
   private final ApkInstaller apkInstaller;
   private final FirebaseAppDistributionNotificationsManager appDistributionNotificationsManager;
   private final HttpsUrlConnectionFactory httpsUrlConnectionFactory;
@@ -81,6 +82,7 @@ public ApkUpdater(
     this.apkInstaller = apkInstaller;
     this.appDistributionNotificationsManager = appDistributionNotificationsManager;
     this.httpsUrlConnectionFactory = httpsUrlConnectionFactory;
+    this.applicationContext = firebaseApp.getApplicationContext();
   }
 
   UpdateTaskImpl updateApk(
@@ -179,7 +181,7 @@ private void makeApkDownloadRequest(
 
     long bytesDownloaded = downloadToDisk(connection, responseLength, fileName, showNotification);
 
-    File apkFile = firebaseApp.getApplicationContext().getFileStreamPath(fileName);
+    File apkFile = applicationContext.getFileStreamPath(fileName);
     validateJarFile(apkFile, responseLength, showNotification, bytesDownloaded);
 
     postUpdateProgress(responseLength, bytesDownloaded, UpdateStatus.DOWNLOADED, showNotification);
@@ -193,13 +195,13 @@ private static boolean isResponseSuccess(int responseCode) {
   private long downloadToDisk(
       HttpsURLConnection connection, long totalSize, String fileName, boolean showNotification)
       throws FirebaseAppDistributionException {
-    Context context = firebaseApp.getApplicationContext();
-    context.deleteFile(fileName);
+    applicationContext.deleteFile(fileName);
     int fileCreationMode =
         VERSION.SDK_INT >= VERSION_CODES.N ? Context.MODE_PRIVATE : Context.MODE_WORLD_READABLE;
     long bytesDownloaded = 0;
     try (BufferedOutputStream outputStream =
-            new BufferedOutputStream(context.openFileOutput(fileName, fileCreationMode));
+            new BufferedOutputStream(
+                applicationContext.openFileOutput(fileName, fileCreationMode));
         InputStream inputStream = connection.getInputStream()) {
       byte[] data = new byte[8 * 1024];
       int readSize = inputStream.read(data);
@@ -241,9 +243,11 @@ private void validateJarFile(
 
   private String getApkFileName() {
     try {
-      Context context = firebaseApp.getApplicationContext();
       String applicationName =
-          context.getApplicationInfo().loadLabel(context.getPackageManager()).toString();
+          applicationContext
+              .getApplicationInfo()
+              .loadLabel(applicationContext.getPackageManager())
+              .toString();
       return applicationName + ".apk";
     } catch (Exception e) {
       LogWrapper.getInstance()

firebase-app-distribution/src/main/java/com/google/firebase/appdistribution/FirebaseAppDistribution.java

@@ -100,7 +100,7 @@ public class FirebaseAppDistribution {
             new FirebaseAppDistributionTesterApiClient(),
             firebaseInstallationsApiProvider),
         new ApkUpdater(firebaseApp, new ApkInstaller()),
-        new AabUpdater(),
+        new AabUpdater(firebaseApp.getApplicationContext()),
         signInStorage,
         lifecycleNotifier);
   }
@@ -148,7 +148,6 @@ public UpdateTask updateIfNewReleaseAvailable() {
         return cachedUpdateIfNewReleaseTask;
       }
     }
-
     showSignInDialog()
         // TODO(rachelprince): Revisit this comment once changes to checkForNewRelease are reviewed
         // Even though checkForNewRelease() calls signInTester(), we explicitly call signInTester

firebase-app-distribution/src/main/java/com/google/firebase/appdistribution/NewReleaseFetcher.java

@@ -50,6 +50,7 @@ class NewReleaseFetcher {
   private final FirebaseApp firebaseApp;
   private final FirebaseAppDistributionTesterApiClient firebaseAppDistributionTesterApiClient;
   private final Provider<FirebaseInstallationsApi> firebaseInstallationsApiProvider;
+  private final Context applicationContext;
   // Maintain an in-memory mapping from source file to APK hash to avoid re-calculating the hash
   private static final ConcurrentMap<String, String> cachedApkHashes = new ConcurrentHashMap<>();
 
@@ -60,10 +61,11 @@ class NewReleaseFetcher {
       @NonNull FirebaseApp firebaseApp,
       @NonNull FirebaseAppDistributionTesterApiClient firebaseAppDistributionTesterApiClient,
       @NonNull Provider<FirebaseInstallationsApi> firebaseInstallationsApiProvider) {
-    this.firebaseApp = firebaseApp;
-    this.firebaseAppDistributionTesterApiClient = firebaseAppDistributionTesterApiClient;
-    this.firebaseInstallationsApiProvider = firebaseInstallationsApiProvider;
-    this.taskExecutor = Executors.newSingleThreadExecutor();
+    this(
+        firebaseApp,
+        firebaseAppDistributionTesterApiClient,
+        firebaseInstallationsApiProvider,
+        Executors.newSingleThreadExecutor());
   }
 
   NewReleaseFetcher(
@@ -75,6 +77,7 @@ class NewReleaseFetcher {
     this.firebaseAppDistributionTesterApiClient = firebaseAppDistributionTesterApiClient;
     this.firebaseInstallationsApiProvider = firebaseInstallationsApiProvider;
     this.taskExecutor = executor;
+    this.applicationContext = firebaseApp.getApplicationContext();
   }
 
   @NonNull
@@ -151,19 +154,17 @@ private long parseBuildVersion(String buildVersion) throws FirebaseAppDistributi
 
   private boolean isOlderBuildVersion(long newReleaseBuildVersion)
       throws FirebaseAppDistributionException {
-    return newReleaseBuildVersion < getInstalledAppVersionCode(firebaseApp.getApplicationContext());
+    return newReleaseBuildVersion < getInstalledAppVersionCode(applicationContext);
   }
 
   private boolean isNewerBuildVersion(long newReleaseBuildVersion)
       throws FirebaseAppDistributionException {
-    return newReleaseBuildVersion > getInstalledAppVersionCode(firebaseApp.getApplicationContext());
+    return newReleaseBuildVersion > getInstalledAppVersionCode(applicationContext);
   }
 
   private boolean hasDifferentAppVersionName(AppDistributionReleaseInternal newRelease)
       throws FirebaseAppDistributionException {
-    return !newRelease
-        .getDisplayVersion()
-        .equals(getInstalledAppVersionName(firebaseApp.getApplicationContext()));
+    return !newRelease.getDisplayVersion().equals(getInstalledAppVersionName(applicationContext));
   }
 
   @VisibleForTesting

firebase-app-distribution/src/main/java/com/google/firebase/appdistribution/TesterSignInManager.java

@@ -141,7 +141,7 @@ public Task<Void> signInTester() {
       firebaseInstallationsApiProvider
           .get()
           .getId()
-          .addOnSuccessListener(getFidGenerationOnSuccessListener(currentActivity))
+          .addOnSuccessListener(getFidGenerationOnSuccessListener())
           .addOnFailureListener(
               e -> {
                 LogWrapper.getInstance().e(TAG + "Fid retrieval failed.", e);
@@ -179,7 +179,7 @@ private void setSuccessfulSignInResult() {
     }
   }
 
-  private OnSuccessListener<String> getFidGenerationOnSuccessListener(Activity currentActivity) {
+  private OnSuccessListener<String> getFidGenerationOnSuccessListener() {
     return fid -> {
       Context context = firebaseApp.getApplicationContext();
       Uri uri =
@@ -190,7 +190,7 @@ private OnSuccessListener<String> getFidGenerationOnSuccessListener(Activity cur
                   fid,
                   getApplicationName(context),
                   context.getPackageName()));
-      openSignInFlowInBrowser(currentActivity, uri);
+      openSignInFlowInBrowser(context, uri);
     };
   }
 
@@ -203,22 +203,22 @@ private static String getApplicationName(Context context) {
     }
   }
 
-  private void openSignInFlowInBrowser(Activity currentActivity, Uri uri) {
+  private void openSignInFlowInBrowser(Context applicationContext, Uri uri) {
     LogWrapper.getInstance().v(TAG + "Opening sign in flow in browser at " + uri);
-    if (supportsCustomTabs(firebaseApp.getApplicationContext())) {
+    if (supportsCustomTabs(applicationContext)) {
       // If we can launch a chrome view, try that.
       CustomTabsIntent customTabsIntent = new CustomTabsIntent.Builder().build();
       Intent intent = customTabsIntent.intent;
       intent.addFlags(Intent.FLAG_ACTIVITY_NO_HISTORY);
       intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
-      customTabsIntent.launchUrl(currentActivity, uri);
+      customTabsIntent.launchUrl(applicationContext, uri);
 
     } else {
       // If we can't launch a chrome view try to launch anything that can handle a URL.
       Intent browserIntent = new Intent(Intent.ACTION_VIEW, uri);
       browserIntent.addFlags(Intent.FLAG_ACTIVITY_NO_HISTORY);
       browserIntent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
-      currentActivity.startActivity(browserIntent);
+      applicationContext.startActivity(browserIntent);
     }
   }
 

firebase-app-distribution/src/test/java/com/google/firebase/appdistribution/AabUpdaterTest.java

@@ -22,7 +22,9 @@
 
 import android.app.Activity;
 import android.net.Uri;
+import androidx.test.core.app.ApplicationProvider;
 import com.google.firebase.FirebaseApp;
+import com.google.firebase.FirebaseOptions;
 import com.google.firebase.appdistribution.FirebaseAppDistributionException.Status;
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
@@ -44,6 +46,9 @@
 
 @RunWith(RobolectricTestRunner.class)
 public class AabUpdaterTest {
+  private static final String TEST_API_KEY = "AIzaSyabcdefghijklmnopqrstuvwxyz1234567";
+  private static final String TEST_APP_ID_1 = "1:123456789:android:abcdef";
+  private static final String TEST_PROJECT_ID = "777777777777";
   private static final String TEST_URL = "https://test-url";
   private static final String REDIRECT_TO_PLAY = "https://redirect-to-play-url";
   private static final ExecutorService testExecutor = Executors.newSingleThreadExecutor();
@@ -72,6 +77,15 @@ public void setup() throws IOException, FirebaseAppDistributionException {
 
     FirebaseApp.clearInstancesForTest();
 
+    FirebaseApp firebaseApp =
+        FirebaseApp.initializeApp(
+            ApplicationProvider.getApplicationContext(),
+            new FirebaseOptions.Builder()
+                .setApplicationId(TEST_APP_ID_1)
+                .setProjectId(TEST_PROJECT_ID)
+                .setApiKey(TEST_API_KEY)
+                .build());
+
     activity =
         Robolectric.buildActivity(FirebaseAppDistributionTest.TestActivity.class).create().get();
     shadowActivity = shadowOf(activity);
@@ -84,7 +98,11 @@ public void setup() throws IOException, FirebaseAppDistributionException {
 
     aabUpdater =
         Mockito.spy(
-            new AabUpdater(mockLifecycleNotifier, mockHttpsUrlConnectionFactory, testExecutor));
+            new AabUpdater(
+                firebaseApp.getApplicationContext(),
+                mockLifecycleNotifier,
+                mockHttpsUrlConnectionFactory,
+                testExecutor));
     when(mockLifecycleNotifier.getCurrentActivity()).thenReturn(activity);
   }