Merge pull request #33 from SOFTNETWORK-APP/fix/repl

fix repl bugs

Author: fupelaqu

build.sbt

@@ -20,7 +20,7 @@ ThisBuild / organization := "app.softnetwork"
 
 name := "softclient4es"
 
-ThisBuild / version := "0.16.0"
+ThisBuild / version := "0.16.1"
 
 ThisBuild / scalaVersion := scala213
 

core/src/main/scala/app/softnetwork/elastic/client/GatewayApi.scala

@@ -1181,7 +1181,7 @@ class TableExecutor(
             val pipeline = IngestPipeline(
               name = pipelineName,
               json = maybePipeline.get,
-              pipelineType = Some(IngestPipelineType.Default)
+              pipelineType = Some(pipelineType)
             )
             // compute diff for pipeline update
             val pipelineDiff: List[PipelineDiff] = pipeline.diff(table.defaultPipeline)
@@ -1438,7 +1438,7 @@ class TableExecutor(
                 .indexSettings
             )
             .toEither
-        } else Right(false)
+        } else Right(true)
       }
 
     steps ++= Seq(

core/src/main/scala/app/softnetwork/elastic/client/repl/Repl.scala

@@ -138,8 +138,8 @@ class Repl(
         multilineBuffer.clear()
         handleMetaCommand(trimmed)
 
-      // Backslash commands: \h, \q, \t, etc.
-      case _ if firstChar == 104 =>
+      // Backslash commands: JLine strips the leading \ and delivers just the letter(s)
+      case _ if backslashCommands.contains(firstWord) =>
         multilineBuffer.clear()
         handleBackslashCommand(trimmed)
 
@@ -572,17 +572,20 @@ class Repl(
   private def formatLigne(value: String, size: Int): String = {
     // Supprime les espaces en début et fin de ligne
     val trimmedValue = value.trim
+    val visibleLength = stripAnsi(trimmedValue).length
 
     // Vérifie la longueur du texte
-    if (trimmedValue.length > size) {
+    if (visibleLength > size) {
       // Si le texte est trop long, le tronquer avec '...'
       trimmedValue.take(size - 3) + "..."
     } else {
       // Sinon, on complète avec des espaces
-      trimmedValue + " " * (size - trimmedValue.length)
+      trimmedValue + " " * (size - visibleLength)
     }
   }
 
+  private def stripAnsi(s: String): String = s.replaceAll("\u001B\\[[;\\d]*m", "")
+
   private def printGoodbyeBanner(): Unit = {
     println(s"\n${emoji("👋")} ${cyan("Goodbye!")}\n")
   }

core/src/main/scala/app/softnetwork/elastic/client/result/ResultRenderer.scala

@@ -199,7 +199,7 @@ object ResultRenderer {
     if (success) {
       s"${emoji("✅")} ${green("Success")} ${gray(s"(${executionTime.toMillis}ms)")}"
     } else {
-      s"${emoji("❌")} ${red("Failed")} ${gray(s"(${executionTime.toMillis}ms)")}"
+      s"${emoji("ℹ️")} ${gray("No changes")} ${gray(s"(${executionTime.toMillis}ms)")}"
     }
   }
 

sql/src/main/scala/app/softnetwork/elastic/sql/schema/package.scala

@@ -1237,7 +1237,10 @@ package object schema {
   }
 
   case class ColumnNotFound(column: String, table: String)
-      extends Exception(s"Column $column  does not exist in table $table")
+      extends Exception(s"Column $column does not exist in table $table")
+
+  case class ColumnAlreadyExists(column: String, table: String)
+      extends Exception(s"Column $column already exists in table $table")
 
   case class TableAlias(
     table: String,
@@ -1522,7 +1525,7 @@ package object schema {
               if (ifNotExists && table.cols.contains(column.name)) table
               else if (!table.cols.contains(column.name))
                 table.copy(columns = table.columns :+ column)
-              else throw ColumnNotFound(column.name, table.name)
+              else throw ColumnAlreadyExists(column.name, table.name)
             case DropColumn(columnName, ifExists) =>
               if (ifExists && !table.cols.contains(columnName)) table
               else if (table.cols.contains(columnName))