Don't keep coursier progress bars on screen

Author: alexarchambault

modules/build/src/main/scala/scala/build/Artifacts.scala

@@ -19,6 +19,7 @@ import scala.build.errors.{
 }
 import scala.build.internal.Constants
 import scala.build.internal.Constants._
+import scala.build.internal.CsLoggerUtil._
 import scala.build.internal.Util.ScalaDependencyOps
 
 final case class Artifacts(
@@ -94,6 +95,8 @@ object Artifacts {
         Seq(
           dep"org.scala-lang:scala-compiler:${params.scalaVersion}"
         )
+    val compilerDependenciesMessage =
+      s"Downloading Scala ${params.scalaVersion} compiler"
 
     val jvmRunnerDependencies =
       if (addJvmRunner.getOrElse(true))
@@ -146,13 +149,35 @@ object Artifacts {
         nativeTestInterfaceDependencies.map(Positioned.none(_)) ++
         jmhDependencies.map(Positioned.none(_))
 
+    val updatedDependenciesMessage = {
+      val b           = new StringBuilder("Downloading ")
+      val depLen      = dependencies.length
+      val extraDepLen = updatedDependencies.length - depLen
+      depLen match {
+        case 1          => b.append("one dependency")
+        case n if n > 1 => b.append(s"$n dependencies")
+        case _          =>
+      }
+
+      if (depLen > 0 && extraDepLen > 0)
+        b.append(" and ")
+
+      extraDepLen match {
+        case 1          => b.append("one internal dependency")
+        case n if n > 1 => b.append(s"$n internal dependencies")
+        case _          =>
+      }
+
+      b.result()
+    }
+
     val compilerArtifacts = value {
       artifacts(
         Positioned.none(compilerDependencies),
         allExtraRepositories,
         params,
         logger,
-        cache
+        cache.withMessage(compilerDependenciesMessage)
       )
     }
 
@@ -162,7 +187,7 @@ object Artifacts {
         allExtraRepositories,
         params,
         logger,
-        cache,
+        cache.withMessage(updatedDependenciesMessage),
         classifiersOpt = Some(Set("_") ++ (if (fetchSources) Set("sources") else Set.empty))
       )
     }
@@ -176,7 +201,7 @@ object Artifacts {
               allExtraRepositories,
               params,
               logger,
-              cache,
+              cache.withMessage("Downloading Scala Native CLI"),
               None
             )
           }
@@ -199,7 +224,7 @@ object Artifacts {
             allExtraRepositories,
             params,
             logger,
-            cache
+            cache.withMessage("Downloading internal stub dependency")
           ).map(_.map(_._2))
         }
       else
@@ -210,8 +235,13 @@ object Artifacts {
         .map { posDep =>
           val posDep0 =
             posDep.map(dep => dep.copy(userParams = dep.userParams + ("intransitive" -> None)))
-          artifacts(posDep0.map(Seq(_)), allExtraRepositories, params, logger, cache)
-            .map(_.map { case (url, path) => (posDep0.value, url, path) })
+          artifacts(
+            posDep0.map(Seq(_)),
+            allExtraRepositories,
+            params,
+            logger,
+            cache.withMessage(s"Downloading compiler plugin ${posDep.value.render}")
+          ).map(_.map { case (url, path) => (posDep0.value, url, path) })
         }
         .sequence
         .left.map(CompositeBuildException(_))
@@ -221,7 +251,8 @@ object Artifacts {
     val javacPlugins0 = value {
       javacPluginDependencies
         .map { posDep =>
-          artifacts(posDep.map(Seq(_)), allExtraRepositories, params, logger, cache)
+          val cache0 = cache.withMessage(s"Downloading javac plugin ${posDep.value.render}")
+          artifacts(posDep.map(Seq(_)), allExtraRepositories, params, logger, cache0)
             .map(_.map { case (url, path) => (posDep.value, url, path) })
         }
         .sequence
@@ -253,12 +284,12 @@ object Artifacts {
     cache: FileCache[Task],
     classifiersOpt: Option[Set[String]] = None
   ): Either[BuildException, Seq[(String, Path)]] = either {
-    val result =
-      value(fetch(dependencies, extraRepositories, params, logger, cache, classifiersOpt))
-        .artifacts
-        .iterator
-        .map { case (a, f) => (a.url, f.toPath) }
-        .toList
+    val res = value(fetch(dependencies, extraRepositories, params, logger, cache, classifiersOpt))
+    val result = res
+      .artifacts
+      .iterator
+      .map { case (a, f) => (a.url, f.toPath) }
+      .toList
     logger.debug {
       val elems = Seq(s"Found ${result.length} artifacts:") ++
         result.map("  " + _._2) ++

modules/build/src/main/scala/scala/build/Bloop.scala

@@ -11,6 +11,7 @@ import java.io.File
 import scala.build.EitherCps.{either, value}
 import scala.build.blooprifle.BloopRifleConfig
 import scala.build.errors.{BuildException, ModuleFormatError}
+import scala.build.internal.CsLoggerUtil._
 import scala.concurrent.duration.FiniteDuration
 import scala.jdk.CollectionConverters._
 
@@ -51,8 +52,16 @@ object Bloop {
     cache: FileCache[Task]
   ): Either[BuildException, Seq[File]] =
     either {
-      value(Artifacts.artifacts(Positioned.none(Seq(dep)), Nil, params, logger, cache))
-        .map(_._2.toFile)
+      val res = value {
+        Artifacts.artifacts(
+          Positioned.none(Seq(dep)),
+          Nil,
+          params,
+          logger,
+          cache.withMessage(s"Downloading compilation server ${dep.version}")
+        )
+      }
+      res.map(_._2.toFile)
     }
 
   def bloopClassPath(logger: Logger, cache: FileCache[Task]): Either[BuildException, Seq[File]] =

modules/build/src/main/scala/scala/build/Logger.scala

@@ -26,7 +26,7 @@ trait Logger {
   def log(ex: BuildException): Unit
   def exit(ex: BuildException): Nothing
 
-  def coursierLogger: coursier.cache.CacheLogger
+  def coursierLogger(printBefore: String): coursier.cache.CacheLogger
   def bloopRifleLogger: BloopRifleLogger
   def scalaJsLogger: ScalaJsLogger
   def scalaNativeTestLogger: sn.Logger
@@ -47,7 +47,7 @@ object Logger {
     def exit(ex: BuildException): Nothing =
       throw new Exception(ex)
 
-    def coursierLogger: coursier.cache.CacheLogger =
+    def coursierLogger(printBefore: String): coursier.cache.CacheLogger =
       coursier.cache.CacheLogger.nop
     def bloopRifleLogger: BloopRifleLogger =
       BloopRifleLogger.nop

modules/build/src/main/scala/scala/build/PersistentDiagnosticLogger.scala

@@ -27,7 +27,8 @@ class PersistentDiagnosticLogger(parent: Logger) extends Logger {
   def log(ex: BuildException): Unit     = parent.log(ex)
   def exit(ex: BuildException): Nothing = parent.exit(ex)
 
-  def coursierLogger: coursier.cache.CacheLogger        = parent.coursierLogger
+  def coursierLogger(printBefore: String): coursier.cache.CacheLogger =
+    parent.coursierLogger(printBefore)
   def bloopRifleLogger: BloopRifleLogger                = parent.bloopRifleLogger
   def scalaJsLogger: ScalaJsLogger                      = parent.scalaJsLogger
   def scalaNativeTestLogger: sn.Logger                  = parent.scalaNativeTestLogger

modules/build/src/main/scala/scala/build/ReplArtifacts.scala

@@ -8,6 +8,7 @@ import java.nio.file.Path
 
 import scala.build.EitherCps.{either, value}
 import scala.build.errors.BuildException
+import scala.build.internal.CsLoggerUtil._
 
 final case class ReplArtifacts(
   replArtifacts: Seq[(String, Path)],
@@ -46,14 +47,19 @@ object ReplArtifacts {
   ): Either[BuildException, ReplArtifacts] = either {
     val localRepoOpt = LocalRepo.localRepo(directories.localRepoDir)
     val allDeps      = dependencies ++ Seq(dep"com.lihaoyi:::ammonite:$ammoniteVersion")
-    val replArtifacts =
-      Artifacts.artifacts(Positioned.none(allDeps), localRepoOpt.toSeq, scalaParams, logger, cache)
+    val replArtifacts = Artifacts.artifacts(
+      Positioned.none(allDeps),
+      localRepoOpt.toSeq,
+      scalaParams,
+      logger,
+      cache.withMessage(s"Downloading Ammonite $ammoniteVersion")
+    )
     val replSourceArtifacts = Artifacts.artifacts(
       Positioned.none(allDeps),
       localRepoOpt.toSeq,
       scalaParams,
       logger,
-      cache,
+      cache.withMessage(s"Downloading Ammonite $ammoniteVersion sources"),
       classifiersOpt = Some(Set("sources"))
     )
     ReplArtifacts(
@@ -85,7 +91,7 @@ object ReplArtifacts {
         repositories,
         scalaParams,
         logger,
-        cache
+        cache.withMessage(s"Downloading Scala compiler ${scalaParams.scalaVersion}")
       )
     val mainClass =
       if (isScala2) "scala.tools.nsc.MainGenericRunner"

modules/build/src/main/scala/scala/build/internal/CsLoggerUtil.scala

@@ -0,0 +1,42 @@
+package scala.build.internal
+
+import coursier.cache.FileCache
+import coursier.cache.loggers.RefreshLogger
+import coursier.jvm.JavaHome
+import coursier.util.Task
+
+object CsLoggerUtil {
+
+  // All of these methods are a bit flaky…
+
+  implicit class CsCacheExtensions(private val cache: FileCache[Task]) extends AnyVal {
+    def withMessage(message: String): FileCache[Task] =
+      cache.logger match {
+        case _: RefreshLogger =>
+          var displayed = false
+          val logger = RefreshLogger.create(
+            CustomProgressBarRefreshDisplay.create(
+              keepOnScreen = false,
+              if (!displayed) {
+                System.err.println(message)
+                displayed = true
+              },
+              ()
+            )
+          )
+          cache.withLogger(logger)
+        case _ => cache
+      }
+  }
+  implicit class CsJavaHomeExtensions(private val javaHome: JavaHome) extends AnyVal {
+    def withMessage(message: String): JavaHome =
+      javaHome.cache.map(_.archiveCache.cache) match {
+        case Some(f: FileCache[Task]) =>
+          val cache0 = f.withMessage(message)
+          javaHome.withCache(
+            javaHome.cache.map(c => c.withArchiveCache(c.archiveCache.withCache(cache0)))
+          )
+        case _ => javaHome
+      }
+  }
+}