Update textual. Bugfixes

dependencies.hspd

@@ -10,7 +10,7 @@
 /* HSPyLib projects */
 package: hspylib, version: 1.12.53, mode: ge
 package: hspylib-datasource, version: 0.9.82, mode: ge
-package: hspylib-clitt, version: 0.9.140, mode: ge
+package: hspylib-clitt, version: 0.9.141, mode: ge
 package: hspylib-setman, version: 0.10.43, mode: ge
 
 /* General */
@@ -46,7 +46,7 @@ package: html2text, version: 2024.2.26, mode: eq
 
 /* CLI/TUI */
 package: rich, version: 13.9.4, mode: eq
-package: textual, version: 0.89.1, mode: eq
+package: textual, version: 1.0.0, mode: eq
 
 /* Audio */
 package: soundfile, version: 0.12.1, mode: eq

gradle/dependencies.gradle

@@ -38,7 +38,10 @@ ext {
   reqsFile = "$project.projectDir/src/main/requirements.txt"
   os = OperatingSystem.current().getName()
   python = detectPython()
+  space = detectSpace()  // the user space to install packages
   pyrcc = 'pyrcc5'
+  deps = []  // List of project dependencies
+  apps = []  // List of project applications
 }
 
 /* Version compatibility mode map */
@@ -54,18 +57,17 @@ def modesMap = [
 
 /* Detect the package space to install dependencies. */
 String detectSpace() {
-
   def output = new ByteArrayOutputStream()
-  exec {
-    commandLine 'sh', '-c', "${project.ext.python} -c \"from sys import prefix, base_prefix; print(prefix != base_prefix);\""
+  project.exec {
+    commandLine project.ext.python, '-c', "from sys import prefix, base_prefix; print(prefix != base_prefix)"
     standardOutput = output
   }
-  def is_venv = Boolean.parseBoolean(output.toString())
+  def is_venv = Boolean.parseBoolean(output.toString().trim())
   println("> Build is" + (is_venv ? ' ' : ' NOT ') + "running under a virtual environment (venv).")
-
   return is_venv ? '--global' : '--user'
 }
 
+
 /* Read .hspd files using the defined HSPD syntax. Added \[\] as valid package names. */
 void readDependencies() {
   def depsFile = new File(depsFile)
@@ -115,12 +117,6 @@ void readDependencies() {
   }
 }
 
-ext {
-  deps = []  // List of project dependencies
-  apps = []  // List of project applications
-  space = detectSpace()  // the user space to install packages
-}
-
 /* Tasks ------------------------------------------------------------------- */
 
 /* List project dependencies */

gradle/pypi-publish.gradle

@@ -28,12 +28,15 @@ String dirName(File file) {
 /* Cleanup distribution files from buildDir */
 task cleanDist(type: Task) {
   group = 'Build'
-  description = "Cleanup distribution files from buildDir"
+  description = "Cleanup distribution files from buildDir and sourceRoot"
   doLast {
-    println("Cleanup distribution files \n\t from ${buildDir}")
+    println("Cleanup distribution files from buildDir and sourceRoot")
     delete dirsByPattern("$buildDir", /.*dist$/)
     delete dirsByPattern("$buildDir", /.*build$/)
-    delete dirsByPattern("$buildDir", /.*egg-info$/)
+    delete dirsByPattern("$buildDir", /.*\.egg-info$/)
+    delete dirsByPattern("$sourceRoot", /.*dist$/)
+    delete dirsByPattern("$sourceRoot", /.*build$/)
+    delete dirsByPattern("$sourceRoot", /.*\.egg-info$/)
   }
 }
 

src/demo/components/camera_demo.py

@@ -30,7 +30,7 @@
 if __name__ == "__main__":
     init_context("camera-demo")
     photo: ImageMetadata
-    while opt := line_input(MENU, placeholder="Select an option"):
+    while opt := line_input(MENU, placeholder="Select an option", markdown=True):
         cursor.writeln()
         if opt == "1" and (name := strip_escapes(line_input("Photo name: "))):
             pic_file, pic_data = camera.capture(name)

src/main/askai/core/model/action_plan.py

@@ -69,13 +69,15 @@ def _parse_response(question: str, response: str) -> "ActionPlan":
 
         # fmt: off
         if direct and len(direct) > 1:
-            plan = ActionPlan._direct_answer(question, direct, primary_goal, ModelResult.default())
+            plan = ActionPlan._direct_answer(question, direct, primary_goal, ModelResult.final_answer())
         elif (direct and len(direct) > 1) or len(tasks) == 1:
             plan = ActionPlan._direct_task(question, speak, primary_goal, tasks[0], ModelResult.default())
         elif tasks:
             plan = ActionPlan(question, speak, primary_goal, False, sub_goals, tasks)
         elif not speak and not primary_goal:
             plan = ActionPlan._direct_task(question, "", "", response, ModelResult.default())
+        elif speak and primary_goal:
+            plan = ActionPlan._direct_answer(question, speak, primary_goal, ModelResult.final_answer())
         else:
             raise InaccurateResponse("AI provided an invalid action plan!")
         # fmt: on

src/main/askai/core/model/model_result.py

@@ -15,10 +15,13 @@
 from dataclasses import dataclass
 from functools import lru_cache
 
+from askai.core.enums.response_model import ResponseModel
+
 
 @dataclass
 class ModelResult:
-    """Keep track of the model select responses."""
+    """Track and store the responses from the selected model. This class is used to encapsulate the model selection
+    returned by the LLM, including any relevant data associated with the model's response."""
 
     mid: str = None
     goal: str = None
@@ -27,12 +30,21 @@ class ModelResult:
     @staticmethod
     @lru_cache
     def default() -> "ModelResult":
-        """Track and store the responses from the selected model.
-        This class is used to encapsulate the model selection returned by the LLM, including any relevant data
-        associated with the model's response.
+        """Creates and returns the default ModelResult instance.
+        :return: A default ModelResult instance with predefined values.
+        """
+        return ModelResult(
+            ResponseModel.NEUTRAL.model, "Default model", "Provide the answer as received by the AI"
+        )
+
+    @staticmethod
+    @lru_cache
+    def final_answer() -> "ModelResult":
+        """Generates and returns the final answer model result.
+        :return: An instance of ModelResult representing the final answer model.
         """
         return ModelResult(
-            "ASK_000", "Default model", "Provide the answer as received by the AI"
+            ResponseModel.FINAL_ANSWER.model, "Final Answer model", "Provide the answer as received by the AI"
         )
 
     def __str__(self):

src/main/askai/core/processors/splitter/splitter_executor.py

@@ -65,10 +65,10 @@ def interrupt(self, ev: Event) -> None:
     def run(self) -> None:
         """Execute the splitter pipeline."""
 
-        try:
-            with Live(
-                Spinner("dots", f"[green]{self.pipeline.state}…[/green]", style="green"), console=tf.console
-            ) as live:
+        with Live(
+            Spinner("dots", f"[green]{self.pipeline.state}…[/green]", style="green"), console=tf.console
+        ) as live:
+            try:
                 while not (self._interrupted or self.pipeline.state == States.COMPLETE):
                     self.pipeline.track_previous()
                     if 1 < configs.max_router_retries < 1 + self.pipeline.failures[self.pipeline.state.value]:
@@ -126,9 +126,9 @@ def run(self) -> None:
                     self.display(f"[green]{execution_status_str}[/green]")
                     live.update(Spinner("dots", f"[green]{self.pipeline.state}…[/green]", style="green"))
                     self.pipeline.iteractions += 1
-            cursor.erase_line()
-        except InaccurateResponse:
-            live.update(Spinner("dots", f"[red]AI failed to respond. Retrying…[/red]", style="green"))
+                cursor.erase_line()
+            except InaccurateResponse:
+                live.update(Spinner("dots", f"[red]AI failed to respond. Retrying…[/red]", style="green"))
 
         final_state: States = self.pipeline.state