feat: better logging when no connectors found

lensesio · Sep 14, 2017 · 6186acd · 6186acd
1 parent b28f7b7
commit 6186acd
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/build.gradle b/build.gradle
@@ -107,7 +107,7 @@ tasks.withType(Tar) {
 }
 
 task compile(dependsOn: 'compileScala')
-task fatJar(dependsOn : ['test', 'shadowJar'])
+task fatJar(dependsOn : ['clean', 'test', 'shadowJar'])
 
 task fatJarNoTest(dependsOn : 'shadowJar')
 
@@ -121,7 +121,7 @@ tasks.withType(Jar) {
     }
 }
 
-task buildCli(type: Exec, dependsOn: [shadowJar]) {
+task buildCli(type: Exec, dependsOn: [fatJar]) {
    commandLine "bin/package.sh", version
 }
 

diff --git a/src/main/scala/com/datamountaineer/connect/tools/Formatters.scala b/src/main/scala/com/datamountaineer/connect/tools/Formatters.scala
@@ -29,6 +29,7 @@ class HumanFormatter extends Formatter {
     * @return A formatted string
     */
   override def connectorNames(connectorNames: Seq[String]): String = connectorNames.mkString("\n")
+
   /**
     * Formats a ConnectorInfo as a string
     * @param connectorInfo the ConnectorInfo to format

diff --git a/src/main/scala/com/datamountaineer/connect/tools/RestKafkaConnectApi.scala b/src/main/scala/com/datamountaineer/connect/tools/RestKafkaConnectApi.scala
@@ -145,7 +145,15 @@ class RestKafkaConnectApi(baseUrl: java.net.URI, httpClient: HttpClient = Scalaj
     */
   def activeConnectorNames(): Try[Seq[String]] = {
     import MyJsonProtocol._
-    Try(req[List[String]]("/connectors").get)
+    Try({
+        val names = req[List[String]]("/connectors").get
+        if (names.isEmpty) {
+          println(s"${Console.YELLOW}No running connectors${Console.RESET}")
+          names
+        } else {
+          names
+        }
+    })
   }
 
   /**