Add WG bring-up status, runtime log tail, and mermaid image rendering

agent/pipeline_engine.py

@@ -224,6 +224,7 @@ class OvergrowthPipeline:
         # Enable deployment by default; set OG_DEPLOY_ENABLED=0 to disable in restricted envs.
         self.deploy_enabled = strtobool(os.getenv("OG_DEPLOY_ENABLED", "1")) == 1
         self.ssh_on_seed_fail = strtobool(os.getenv("OG_SSH_ON_SEED_FAIL", "0")) == 1
+        self.wg_status = "not_configured"
         self._ensure_wireguard()
 
     def _slugify(self, text: str, length: int = 24) -> str:
@@ -237,6 +238,7 @@ class OvergrowthPipeline:
         """
         If WG_CONFIG_B64 is provided, bring up wg0 using that config.
         """
+        self.wg_status = "not_configured"
         wg_cfg_b64 = os.getenv("WG_CONFIG_B64")
         if not wg_cfg_b64:
             return
@@ -250,6 +252,7 @@ class OvergrowthPipeline:
             )
             if already_up.returncode == 0:
                 logger.info("WireGuard wg0 already up; skipping bring-up")
+                self.wg_status = "up"
                 return
         except Exception:
             pass
@@ -267,10 +270,13 @@ class OvergrowthPipeline:
             )
             if result.returncode != 0:
                 logger.error(f"WireGuard bring-up failed: {result.stderr.strip()}")
+                self.wg_status = f"error: {result.stderr.strip()}"
             else:
                 logger.info("WireGuard wg0 up")
+                self.wg_status = "up"
         except Exception as e:
             logger.error(f"WireGuard setup error: {e}")
+            self.wg_status = f"error: {e}"
 
     def _prepare_lab_info(self, intent: NetworkIntent, create_project: bool = False) -> Dict[str, Any]:
         """
@@ -279,8 +285,8 @@ class OvergrowthPipeline:
         if not self.gns3_server:
             return {}
 
-        project_name = self.gns3_project_name_default or f"og-{self._slugify(intent.description)}-{int(time.time())}"
-        requested_project_id = self.gns3_project_id_default
+        project_name = f"og-{self._slugify(intent.description)}-{int(time.time())}"
+        requested_project_id = None
 
         lab_info: Dict[str, Any] = {
             "api": self.gns3_server,
@@ -551,7 +557,8 @@ class OvergrowthPipeline:
             },
             "intent": asdict(model.intent),
             "questions": [],
-            "import_summary": import_summary
+            "import_summary": import_summary,
+            "wg_status": self.wg_status
         }
         lab_info = self._prepare_lab_info(model.intent, create_project=False)
         if lab_info:
@@ -1636,6 +1643,7 @@ Be specific and practical. Use RFC1918 addressing. Consider scalability and secu
         results['intent'] = asdict(intent)
         results['questions'] = self._generate_clarifying_questions(intent)
         lab_info = self._prepare_lab_info(intent, create_project=True)
+        results['wg_status'] = self.wg_status
         if lab_info:
             results['lab'] = lab_info
 

app.py

@@ -26,6 +26,7 @@ from agent.network_ops import (
 from agent.api_monitor import monitor
 import json
 import time
+import urllib.parse
 import html
 
 VINE_CSS = """
@@ -247,6 +248,11 @@ def build_ui():
                 gr.Markdown("### 📡 Recent API Calls")
                 api_activity = gr.Markdown(value=monitor.format_activity_feed())
                 refresh_activity_btn = gr.Button("🔄 Refresh Activity", size="sm", variant="secondary")
+            
+            with gr.Column(scale=2, elem_classes=["og-panel"]):
+                gr.Markdown("### 📜 Runtime Log (tail)")
+                log_output = gr.Textbox(value="", lines=12, label="Latest Logs", interactive=False)
+                refresh_log_btn = gr.Button("🔄 Refresh Logs", size="sm", variant="secondary")
         
         # Auto-refresh handlers
         def refresh_api_stats():
@@ -257,6 +263,14 @@ def build_ui():
         
         refresh_stats_btn.click(fn=refresh_api_stats, outputs=[api_stats])
         refresh_activity_btn.click(fn=refresh_api_activity, outputs=[api_activity])
+        def refresh_logs():
+            try:
+                import subprocess
+                tail = subprocess.run(["tail", "-n", "60", "app.log"], capture_output=True, text=True)
+                return tail.stdout or "No logs yet."
+            except Exception as e:
+                return f"Failed to read logs: {e}"
+        refresh_log_btn.click(fn=refresh_logs, outputs=[log_output])
         
         gr.Markdown("---")
 
@@ -410,6 +424,11 @@ def build_ui():
                 status += f"- Nebius key: {llm_env.get('nebius_key', 'missing')}\n"
                 status += f"- HuggingFace key: {llm_env.get('huggingface_key', 'missing')}\n"
                 status += f"- Modal key: {llm_env.get('modal_key', 'missing')}\n\n"
+
+                wg_status = results.get("wg_status")
+                if wg_status:
+                    status += "### 🕸️ WireGuard\n"
+                    status += f"- Status: {wg_status}\n\n"
                 
                 mode_info = results.get("mode")
                 if mode_info:
@@ -555,7 +574,9 @@ def build_ui():
                 diagrams = results.get('diagrams', {}) or {}
                 mermaid = diagrams.get('mermaid')
                 if mermaid:
-                    diagram = f'<div class="mermaid og-mermaid">{mermaid}</div><script>window.renderMermaid && window.renderMermaid();</script>'
+                    encoded = urllib.parse.quote(mermaid)
+                    img_url = f"https://mermaid.ink/img/{encoded}"
+                    diagram = f'<img src="{img_url}" alt="Network Diagram" style="max-width:100%;"/>'
                 else:
                     ascii_diagram = diagrams.get('ascii', 'No diagram available')
                     diagram = f"<pre>{html.escape(ascii_diagram)}</pre>"