google-common: Improve log messages for application default credentia…

…ls (akka#2667)
gkatzioura · May 13, 2021 · c3e5847 · c3e5847
1 parent 622364d
commit c3e5847
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/google-common/src/main/scala/akka/stream/alpakka/google/auth/Credentials.scala b/google-common/src/main/scala/akka/stream/alpakka/google/auth/Credentials.scala
@@ -6,6 +6,7 @@ package akka.stream.alpakka.google.auth
 
 import akka.actor.ClassicActorSystemProvider
 import akka.annotation.DoNotInherit
+import akka.event.Logging
 import akka.http.scaladsl.model.headers.HttpCredentials
 import akka.stream.alpakka.google.RequestSettings
 import akka.util.JavaDurationConverters._
@@ -25,15 +26,22 @@ object Credentials {
    */
   def apply(c: Config)(implicit system: ClassicActorSystemProvider): Credentials = c.getString("provider") match {
     case "application-default" =>
+      val log = Logging(system.classicSystem, getClass)
       try {
-        parseServiceAccount(c)
+        val creds = parseServiceAccount(c)
+        log.info("Using service account credentials")
+        creds
       } catch {
         case NonFatal(ex1) =>
           try {
-            parseComputeEngine(c)
+            val creds = parseComputeEngine(c)
+            log.info("Using Compute Engine credentials")
+            creds
           } catch {
             case NonFatal(ex2) =>
-              system.classicSystem.log.warning("Unable to find application default credentials", ex1, ex2)
+              log.warning("Unable to find Application Default Credentials for Google APIs")
+              log.warning("Service account: {}", ex1.getMessage)
+              log.warning("Compute Engine: {}", ex2.getMessage)
               parseNone(c) // TODO Once credentials are guaranteed to be managed centrally we can throw an error instead
           }
       }