Add fine-grained logging to LocalGcdHelper

mziccard · mziccard · commit b0a88f5d5129 · 2015-09-17T14:32:34.000+02:00
diff --git a/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/LocalGcdHelper.java b/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/LocalGcdHelper.java
@@ -55,11 +55,16 @@
 import java.util.zip.ZipEntry;
 import java.util.zip.ZipInputStream;
 
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
 /**
  * Utility to start and stop local Google Cloud Datastore process.
  */
 public class LocalGcdHelper {
   
+  private static final Logger log = Logger.getLogger(LocalGcdHelper.class.getName());
+
   private final String projectId;
   private Path gcdPath;
   private ProcessStreamReader processReader;
@@ -99,14 +104,27 @@ private static Path installedGcdPath() {
     Path gcloudPath = executablePath(gcloudExecutableName);
     gcloudPath = (gcloudPath == null) ? null : gcloudPath.getParent();
     if (gcloudPath == null) {
+      if (log.isLoggable(Level.FINE)) {
+        log.fine("SDK not found");
+      }
       return null;
     }
+    if (log.isLoggable(Level.FINE)) {
+      log.fine("SDK found, looking for datastore emulator");
+    }
     Path installedGcdPath = gcloudPath.resolve("platform").resolve("gcd");
     if (Files.exists(installedGcdPath)) {
       try {
         String installedVersion = installedGcdVersion();
         if (installedVersion != null && installedVersion.startsWith(GCD_VERSION)) {
+          if (log.isLoggable(Level.FINE)) {
+            log.fine("SDK datastore emulator found");
+          }
           return installedGcdPath;
+        } else {
+          if (log.isLoggable(Level.FINE)) {
+            log.fine("SDK datastore emulator found but version mismatch");
+          }
         }
       } catch (IOException | InterruptedException ignore) {
         // ignore
@@ -308,14 +326,23 @@ private void downloadGcd() throws IOException {
     // check if we already have a local copy of the gcd utility and download it if not.
     File gcdZipFile = new File(System.getProperty("java.io.tmpdir"), GCD_FILENAME);
     if (!gcdZipFile.exists() || !MD5_CHECKSUM.equals(md5(gcdZipFile))) {
+      if (log.isLoggable(Level.FINE)) {
+        log.fine("Fetching datastore emulator");
+      }
       ReadableByteChannel rbc = Channels.newChannel(GCD_URL.openStream());
       try (FileOutputStream fos = new FileOutputStream(gcdZipFile)) {
         fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
       }
+    } else {
+      if (log.isLoggable(Level.FINE)) {
+        log.fine("Using cached datastore emulator");
+      }      
     }
-    
     // unzip the gcd
     try (ZipInputStream zipIn = new ZipInputStream(new FileInputStream(gcdZipFile))) {
+      if (log.isLoggable(Level.FINE)) {
+        log.fine("Unzipping datastore emulator");
+      }
       ZipEntry entry = zipIn.getNextEntry();
       while (entry != null) {
         File filePath = new File(gcdPath.toFile(), entry.getName());
@@ -350,6 +377,9 @@ private void startGcd(Path executablePath) throws IOException, InterruptedExcept
     }
 
     // create the datastore for the project
+    if (log.isLoggable(Level.FINE)) {
+      log.log(Level.FINE, "Creating datastore for the project: {0}", projectId);
+    }
     Process temp = gcdCreateCommand.command(gcdAbsolutePath.toString(), "create", "-p", projectId,
             projectId)
             .redirectErrorInherit()
@@ -359,6 +389,9 @@ private void startGcd(Path executablePath) throws IOException, InterruptedExcept
     temp.waitFor();
 
     // start the datastore for the project
+    if (log.isLoggable(Level.FINE)) {
+      log.log(Level.FINE, "Starting datastore emulator for the project: {0}", projectId);
+    }
     temp = gcdStartCommand.command(gcdAbsolutePath.toString(), "start", "--testing",
             "--allow_remote_shutdown", projectId)
             .directory(gcdPath)
