Refactored

app.py

@@ -189,7 +189,7 @@ class KnowledgeBase:
 
         # Split texts into chunks
                 # Split texts into chunks
-        splits = self.splitter.split_text("".join(texts))
+        splits = self.splitter.split_text("\n\n".join(texts))
         if not splits:
             log_workflow(f"No splits generated for domain '{self.domain}' and country '{country}'")
             with self.lock:
@@ -289,28 +289,29 @@ class CoordinatorAgent:
         advice = {d: self.specialists[d].run(query, country) for d in self.specialists}
         # 2. plan (omitted)
         # 3. synthesis
-        output = ["## Your Personalized Financial Advice\n"]
-
-        # If there’s truly unique content per domain:
-        for domain, txt in specialist_advice.items():
-            output.append(f"### {domain.capitalize()}\n{txt.strip()}\n")
-
-        # If you want to dedupe truly identical advice, you could:
-        # seen = set()
-        # for domain, txt in specialist_advice.items():
-        #     if txt not in seen:
-        #         seen.add(txt)
-        #         output.append(f"### {domain.capitalize()}\n{txt.strip()}\n")
+       # 4. Synthesize and pretty–print
+        lines = ["# Your Personalized Financial Advice\n"]
+
+        # Add each specialist’s section
+        for domain, text in specialist_advice.items():
+            lines.append(f"## {domain.capitalize()}\n")
+            # Indent each paragraph for readability
+            for para in text.strip().split("\n\n"):
+                lines.append("    " + para.strip().replace("\n", "\n    "))
+            lines.append("")  # blank line
+
+        # Append Multi-Path Plans as a JSON code block
+        lines.append("## Multi-Path Financial Plans\n")
+        lines.append("```json")
+        lines.append(json.dumps(plans, indent=2))
+        lines.append("```")
+
+        formatted = "\n".join(lines)
+        log_workflow("Synthesis complete")
 
-        # Append your plans in a code‐block
-        output.append("## Multi-Path Plans\n```json\n")
-        output.append(json.dumps(plans, indent=2))
-        output.append("\n```")
+        # 5. Return formatted advice + workflow log
+        return formatted + "\n\n---\n" + get_workflow_log()
 
-        synthesis = "\n".join(output)
-        log_workflow("Synthesis complete")
-        # 4. return
-        return synthesis
 
 # =======================================
 # Main Portal Interface