fix focus

.env

@@ -1,5 +1,10 @@
 OTEL_EXPORTER_OTLP_LOGS_ENDPOINT=http://otel-collector:4318/v1/logs
 OTEL_SERVICE_NAME=sup-agent
-LOG_LEVEL=info
-
+LOG_LEVEL=warn
 LOKI_HOST=http://localhost:3100
+
+
+SUPPORT_AGENT_MODEL=qwen3:8b
+
+
+

apps/cli/chat.ts

@@ -68,6 +68,9 @@ export async function startChat() {
     events: [],
   };
 
+  console.log(` Active Agent: \x1b[1m${AGENT.toUpperCase()}\x1b[0m`);
+  console.log(` Active Model: \x1b[32m${typeof modelSpec === 'object' ? JSON.stringify(modelSpec) : modelSpec}\x1b[0m`);
+
   process.nextTick(() => rl.prompt());
   // logger.debug(`Agent: ${AGENT}`);
   //logger.debug(`Model: ${modelSpec}`);

apps/tui/index.ts

@@ -1,6 +1,5 @@
 import { render } from "@opentui/solid";
-import { createSignal } from "solid-js";
-import { For } from "solid-js";
+import { createSignal, For, onMount } from "solid-js";
 import {
   OpenFeature,
   MultiProvider,
@@ -11,70 +10,92 @@ import { ProtocolResolver } from "@sup/lib/protocol-resolver";
 import { adapters } from "@sup/tools";
 import { JsonFileProvider } from "@sup/infra/adapters/JsonFileProvider";
 
-const AGENT = process.env.AGENT || "support";
-const { agent, modelSpec } = await (async () => {
-  if (AGENT === "coding") {
-    const { codingAgent, codingAgentModelSpec } = await import("@sup/agents/coding-agent");
-    return { agent: codingAgent, modelSpec: codingAgentModelSpec };
-  }
-  const { supportAgent, supportAgentModelSpec } = await import("@sup/agents/support-agent");
-  return { agent: supportAgent, modelSpec: supportAgentModelSpec };
-})();
-
-/* 
-const providers = [];
-if (process.env.POSTHOG_API_KEY) {
-  const { PostHogProvider } = await import("@tapico/node-openfeature-posthog");
-  const { PostHog } = await import("posthog-node");
-  const posthogClient = new PostHog(process.env.POSTHOG_API_KEY, {
-    host: process.env.POSTHOG_HOST || "https://app.posthog.com",
-  });
-  providers.push({ provider: new PostHogProvider({ posthogClient }) });
-}
-providers.push({ provider: new JsonFileProvider("../../config/flags.json") });
-*/ 
-
-const multiProvider = new MultiProvider(providers, new FirstSuccessfulStrategy());
-await OpenFeature.setProviderAndWait(multiProvider);
-
-const session: AgentSession = {
-  id: "tui-session-" + Date.now(),
-  events: [],
+type AgentSession = {
+  id: string;
+  events: any[];
 };
 
 type Message = { role: "user" | "agent"; text: string };
 
+const AGENT = process.env.AGENT || "support";
+
 function App() {
   const [messages, setMessages] = createSignal<Message[]>([]);
   const [streaming, setStreaming] = createSignal("");
   const [activeTool, setActiveTool] = createSignal("");
   const [busy, setBusy] = createSignal(false);
+  const [ready, setReady] = createSignal(false);
+
+  // Keep a reference to the active agent function
+  let currentAgent: any = null;
+
+  onMount(async () => {
+    try {
+      // 1. Setup OpenFeature without stalling root script
+      const providers = [];
+      if (process.env.POSTHOG_API_KEY) {
+        const { PostHogProvider } = await import("@tapico/node-openfeature-posthog");
+        const { PostHog } = await import("posthog-node");
+        const posthogClient = new PostHog(process.env.POSTHOG_API_KEY, {
+          host: process.env.POSTHOG_HOST || "https://app.posthog.com",
+        });
+        providers.push({ provider: new PostHogProvider({ posthogClient }) });
+      }
+      providers.push({ provider: new JsonFileProvider("../../config/flags.json") });
+
+      const multiProvider = new MultiProvider(providers, new FirstSuccessfulStrategy());
+      await OpenFeature.setProviderAndWait(multiProvider);
+
+      // 2. Resolve Agent inside onMount so OpenTUI doesn't lock up module loading
+      if (AGENT === "coding") {
+        const { codingAgent } = await import("@sup/agents/coding-agent");
+        currentAgent = codingAgent;
+      } else {
+        const { supportAgent } = await import("@sup/agents/support-agent");
+        currentAgent = supportAgent;
+      }
+
+      setReady(true);
+    } catch (e) {
+      console.error("Initialization error:", e);
+      setReady(true); // Fallback so UI still draws
+    }
+  });
+
+  const session: AgentSession = {
+    id: "tui-session-" + Date.now(),
+    events: [],
+  };
 
   async function submit(text: string) {
-    if (!text.trim() || busy()) return;
+    if (!text.trim() || busy() || !ready() || !currentAgent) return;
     setBusy(true);
     setMessages((m) => [...m, { role: "user", text }]);
 
-    const generator = agent(text, session, {
-      resolver: ProtocolResolver,
-      tools: adapters,
-    });
-
-    for await (const step of generator) {
-      if (step.type === "text_delta" && step.delta) {
-        setStreaming((s) => s + step.delta);
-      } else if (step.type === "tool_call") {
-        setActiveTool(step.toolId);
-      } else if (step.type === "tool_result") {
-        setActiveTool("");
-      } else if (step.type === "final") {
-        setMessages((m) => [
-          ...m,
-          { role: "agent", text: step.text || streaming() },
-        ]);
-        setStreaming("");
-        setActiveTool("");
+    try {
+      const generator = currentAgent(text, session, {
+        resolver: ProtocolResolver,
+        tools: adapters,
+      });
+
+      for await (const step of generator) {
+        if (step.type === "text_delta" && step.delta) {
+          setStreaming((s) => s + step.delta);
+        } else if (step.type === "tool_call") {
+          setActiveTool(step.toolId);
+        } else if (step.type === "tool_result") {
+          setActiveTool("");
+        } else if (step.type === "final") {
+          setMessages((m) => [
+            ...m,
+            { role: "agent", text: step.text || streaming() },
+          ]);
+          setStreaming("");
+          setActiveTool("");
+        }
       }
+    } catch (err) {
+      setMessages((m) => [...m, { role: "agent", text: `Error: ${err}` }]);
     }
 
     setBusy(false);
@@ -90,7 +111,6 @@ function App() {
                 {msg.role === "user" ? "You" : "Agent"}:{" "}
               </span>
               {msg.text}
-              <br />
             </text>
           )}
         </For>
@@ -108,8 +128,8 @@ function App() {
       </scrollbox>
       <box borderTop width="100%">
         <input
-          placeholder={busy() ? "..." : "You: "}
-          disabled={busy()}
+          placeholder={!ready() ? "Initializing context..." : busy() ? "Thinking..." : "You: "}
+          disabled={busy() || !ready()}
           onSubmit={submit}
           width="100%"
         />
@@ -118,4 +138,4 @@ function App() {
   );
 }
 
-render(() => <App />);
+render(() => <App />);