chore: bump version to v0.2.42 [skip ci]

- Messages aus result.details.messages extrahieren
- Content = Array von {type, text} blocks → nur text extrahieren
- Thinking-Blocks + REPLY_SKIP + ANNOUNCE_SKIP herausfiltern

VERSION

@@ -1 +1 @@
-0.2.31
+0.2.42

backend/Controllers/DashboardController.cs

@@ -0,0 +1,208 @@
+using Microsoft.AspNetCore.Mvc;
+using Nexus.Api.Models;
+using Nexus.Api.Services;
+
+namespace Nexus.Api.Controllers;
+
+[ApiController]
+[Route("api/dashboard")]
+public class DashboardController(OpenClawGatewayClient gateway, ILogger<DashboardController> logger)
+    : ControllerBase
+{
+    /// <summary>
+    /// Gateway health + session_status + subagents count.
+    /// Returns HTTP 200 even when gateway is down (gatewayOk: false).
+    /// </summary>
+    [HttpGet("status")]
+    public async Task<DashboardStatus> GetStatus()
+    {
+        try
+        {
+            return await gateway.GetStatusAsync();
+        }
+        catch (Exception ex)
+        {
+            logger.LogWarning(ex, "Dashboard status check failed");
+            return new DashboardStatus(false, "Offline", 0, 0);
+        }
+    }
+
+    /// <summary>
+    /// Returns all agents with their current status.
+    /// Combines sessions_list + sub_agents_list.
+    /// </summary>
+    [HttpGet("agents")]
+    public async Task<List<DashboardAgentInfo>> GetAgents()
+    {
+        try
+        {
+            return await gateway.GetAgentsAsync();
+        }
+        catch (Exception ex)
+        {
+            logger.LogWarning(ex, "Dashboard agents fetch failed");
+            return new List<DashboardAgentInfo>();
+        }
+    }
+
+    /// <summary>
+    /// Returns the latest assistant messages (operations/feed) from the Iris session.
+    /// Filtered to role == "assistant" — those are the work feed entries.
+    /// </summary>
+    [HttpGet("operations")]
+    public async Task<List<FeedEntry>> GetOperations([FromQuery] int limit = 20)
+    {
+        try
+        {
+            var messages = await gateway.GetSessionHistoryAsync("iris", Math.Clamp(limit, 1, 100));
+            var feed = new List<FeedEntry>();
+
+            foreach (var msg in messages)
+            {
+                if (!string.Equals(msg.Role, "assistant", StringComparison.OrdinalIgnoreCase))
+                    continue;
+
+                if (string.IsNullOrWhiteSpace(msg.Content))
+                    continue;
+
+                // Parse timestamp for display-friendly "time ago"
+                var ts = ParseTimestamp(msg.Timestamp);
+                var timeAgo = FormatTimeAgo(ts);
+
+                // Extract a short agent indicator and action from content
+                var (agent, action) = ExtractAgentAction(msg.Content);
+
+                feed.Add(new FeedEntry(agent, action, msg.Timestamp, timeAgo));
+            }
+
+            return feed;
+        }
+        catch (Exception ex)
+        {
+            logger.LogWarning(ex, "Dashboard operations fetch failed");
+            return new List<FeedEntry>();
+        }
+    }
+
+    /// <summary>
+    /// Send a chat message to the Iris session.
+    /// </summary>
+    [HttpPost("chat/send")]
+    public async Task<ChatResponse> SendChat([FromBody] ChatRequest request)
+    {
+        if (string.IsNullOrWhiteSpace(request.Message))
+            return new ChatResponse(false, null, "Message is required");
+
+        try
+        {
+            var agentId = string.IsNullOrWhiteSpace(request.AgentId)
+                ? "iris"
+                : request.AgentId.Trim();
+
+            return await gateway.SendChatMessageAsync(agentId, request.Message.Trim());
+        }
+        catch (Exception ex)
+        {
+            logger.LogWarning(ex, "Dashboard chat send failed");
+            return new ChatResponse(false, null, "Gateway nicht erreichbar");
+        }
+    }
+
+    /// <summary>
+    /// Returns chat messages (user + assistant only, not tool messages).
+    /// </summary>
+    [HttpGet("chat/messages")]
+    public async Task<List<MessageEntry>> GetMessages(
+        [FromQuery] string? sessionKey,
+        [FromQuery] int limit = 50,
+        [FromQuery] int offset = 0)
+    {
+        try
+        {
+            var key = string.IsNullOrWhiteSpace(sessionKey) ? "agent:iris:main" : sessionKey.Trim();
+            var messages = await gateway.GetSessionHistoryAsync(key, Math.Clamp(limit, 1, 200), Math.Max(0, offset));
+
+            // Filter: only user and assistant messages (exclude tool/system)
+            return messages
+                .Where(m => string.Equals(m.Role, "user", StringComparison.OrdinalIgnoreCase)
+                         || string.Equals(m.Role, "assistant", StringComparison.OrdinalIgnoreCase))
+                .ToList();
+        }
+        catch (Exception ex)
+        {
+            logger.LogWarning(ex, "Dashboard messages fetch failed");
+            return new List<MessageEntry>();
+        }
+    }
+
+    /// <summary>
+    /// Returns the cron queue / pending tasks.
+    /// </summary>
+    [HttpGet("queue")]
+    public async Task<List<QueueItem>> GetQueue()
+    {
+        try
+        {
+            return await gateway.GetQueueAsync();
+        }
+        catch (Exception ex)
+        {
+            logger.LogWarning(ex, "Dashboard queue fetch failed");
+            return new List<QueueItem>();
+        }
+    }
+
+    // ========== Helpers ==========
+
+    private static DateTimeOffset ParseTimestamp(string timestamp)
+    {
+        if (DateTimeOffset.TryParse(timestamp, null, System.Globalization.DateTimeStyles.None, out var dt))
+            return dt;
+        return DateTimeOffset.UtcNow;
+    }
+
+    private static string FormatTimeAgo(DateTimeOffset ts)
+    {
+        var diff = DateTimeOffset.UtcNow - ts;
+        if (diff.TotalMinutes < 1) return "just now";
+        if (diff.TotalMinutes < 60) return $"{(int)diff.TotalMinutes}m ago";
+        if (diff.TotalHours < 24) return $"{(int)diff.TotalHours}h ago";
+        if (diff.TotalDays < 7) return $"{(int)diff.TotalDays}d ago";
+        return ts.ToString("MMM dd");
+    }
+
+    private static (string Agent, string Action) ExtractAgentAction(string content)
+    {
+        // Take first line or first ~80 chars as the action summary
+        var firstLine = content.Split('\n', 2)[0].Trim();
+        var summary = firstLine.Length > 80 ? firstLine[..80] + "…" : firstLine;
+
+        // Try to identify which agent this came from
+        var agent = "Iris";
+        foreach (var marker in new[] { "**Agent:**", "**Agent:** ", "*Agent:* ", "Agent:" })
+        {
+            var idx = content.IndexOf(marker, StringComparison.OrdinalIgnoreCase);
+            if (idx >= 0)
+            {
+                var after = content[(idx + marker.Length)..].TrimStart();
+                var end = after.IndexOfAny(['\n', '\r', ',', '.']);
+                var found = end > 0 ? after[..end].Trim() : after.Split('\n', 2)[0].Trim();
+                if (!string.IsNullOrWhiteSpace(found) && found.Length < 30)
+                {
+                    agent = found;
+                    break;
+                }
+            }
+        }
+
+        // Try to find agent name at the start in brackets like [Agent: Iris]
+        if (agent == "Iris")
+        {
+            var bracketMatch = System.Text.RegularExpressions.Regex.Match(content, @"\[Agent:\s*([^\]]+)\]");
+            if (bracketMatch.Success)
+                agent = bracketMatch.Groups[1].Value.Trim();
+        }
+
+        return (agent, summary);
+    }
+}

backend/Models/Dashboard.cs

@@ -0,0 +1,47 @@
+namespace Nexus.Api.Models;
+
+public sealed record DashboardAgentInfo(
+    string Id,
+    string Name,
+    string Role,
+    string Model,
+    bool IsActive,
+    string? CurrentTask
+);
+
+public sealed record MessageEntry(
+    string Role,
+    string Content,
+    string Timestamp
+);
+
+public sealed record ChatRequest(
+    string Message,
+    string? AgentId
+);
+
+public sealed record ChatResponse(
+    bool Ok,
+    string? Reply,
+    string? Error
+);
+
+public sealed record FeedEntry(
+    string Agent,
+    string Action,
+    string Timestamp,
+    string Time
+);
+
+public sealed record DashboardStatus(
+    bool GatewayOk,
+    string IrisStatus,
+    int ActiveAgents,
+    int PendingTasks
+);
+
+public sealed record QueueItem(
+    string Id,
+    string Name,
+    string Status
+);

backend/Program.cs

@@ -112,6 +112,13 @@ builder.Services.AddHttpClient("gateway", client =>
     client.Timeout = TimeSpan.FromSeconds(5);
 });
 
+builder.Services.AddHttpClient<OpenClawGatewayClient>(client =>
+{
+    client.BaseAddress = new(builder.Configuration["Integrations:OpenClaw:BaseUrl"]
+        ?? "http://127.0.0.1:18789");
+    client.Timeout = TimeSpan.FromSeconds(5);
+});
+
 // --- Application Services ---
 builder.Services.AddTransient<ModelRoutingService>();
 builder.Services.AddScoped<IAuthService, AuthService>();

backend/Services/OpenClawGatewayClient.cs

@@ -0,0 +1,321 @@
+using System.Net.Http.Headers;
+using System.Net.Http.Json;
+using System.Text.Json;
+using System.Text.Json.Nodes;
+using Nexus.Api.Models;
+
+namespace Nexus.Api.Services;
+
+public sealed class OpenClawGatewayClient(HttpClient httpClient, IConfiguration configuration)
+{
+    private static readonly JsonSerializerOptions JsonOptions = new()
+    {
+        PropertyNameCaseInsensitive = true,
+        PropertyNamingPolicy = JsonNamingPolicy.CamelCase
+    };
+
+    private string? GetPassword()
+    {
+        var password = configuration["Integrations:OpenClaw:Password"];
+        if (string.IsNullOrWhiteSpace(password))
+            password = configuration["Integrations:OpenClaw:Token"];
+        return string.IsNullOrWhiteSpace(password) ? null : password;
+    }
+
+    private void ApplyAuth(HttpRequestMessage request)
+    {
+        var password = GetPassword();
+        if (password is not null)
+            request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", password);
+    }
+
+    public async Task<JsonNode?> InvokeToolAsync(string tool, object? args = null)
+    {
+        try
+        {
+            using var request = new HttpRequestMessage(HttpMethod.Post, "/tools/invoke");
+            ApplyAuth(request);
+
+            var body = new Dictionary<string, object?> { ["tool"] = tool };
+            if (args is not null)
+                body["args"] = args;
+
+            request.Content = JsonContent.Create(body);
+
+            using var response = await httpClient.SendAsync(request);
+            if (!response.IsSuccessStatusCode)
+                return null;
+
+            var json = await response.Content.ReadAsStringAsync();
+            if (string.IsNullOrWhiteSpace(json))
+                return null;
+
+            var node = JsonNode.Parse(json);
+            // Unwrap the { ok: true, result: ... } envelope
+            if (node?["ok"]?.GetValue<bool>() == true && node["result"] is not null)
+                return node["result"];
+            return node;
+        }
+        catch
+        {
+            return null;
+        }
+    }
+
+    /// <summary>
+    /// Extracts useful data from a tool response that may embed JSON in content[0].text.
+    /// Returns the unwrapped "details" object if present, otherwise the raw result.
+    /// </summary>
+    private static JsonNode? ExtractToolData(JsonNode? result)
+    {
+        if (result is null) return null;
+        // Some tools return { details: {...}, content: [...] }
+        if (result["details"] is JsonNode details && details is not JsonValue)
+            return details;
+        // Some tools wrap in content[0].text as JSON string
+        if (result["content"] is JsonArray content && content.Count > 0)
+        {
+            var text = content[0]?["text"]?.GetValue<string>();
+            if (!string.IsNullOrWhiteSpace(text))
+            {
+                try { return JsonNode.Parse(text); }
+                catch { /* fall through */ }
+            }
+        }
+        return result;
+    }
+
+    public async Task<List<DashboardAgentInfo>> GetAgentsAsync()
+    {
+        // Hardcoded agent list (known from OpenClaw config).
+        // Tools/invoke visibility is restricted to agent:main scope,
+        // so we can't enumerate Iris sessions programmatically.
+        var agentDefs = new[]
+        {
+            new { Id = "iris", Name = "Iris", Model = "GPT-5.4" },
+            new { Id = "programmer", Name = "Programmer", Model = "DeepSeek V4 Flash" },
+            new { Id = "reviewer", Name = "Reviewer", Model = "DeepSeek V4 Pro" },
+            new { Id = "architekt", Name = "DevOps", Model = "DeepSeek V4 Pro" },
+            new { Id = "executor", Name = "Executor", Model = "DeepSeek V4 Flash" },
+            new { Id = "researcher", Name = "Researcher", Model = "DeepSeek V4 Pro" },
+        };
+
+        var agents = new List<DashboardAgentInfo>();
+        foreach (var def in agentDefs)
+        {
+            var isActive = false;
+            string? currentTask = null;
+
+            // Check workspace activity via file timestamps
+            var memDir = $"/mnt/workspace-{def.Id}/memory";
+            try
+            {
+                if (Directory.Exists(memDir))
+                {
+                    var latestFile = Directory.GetFiles(memDir, "*", SearchOption.AllDirectories)
+                        .Select(f => new FileInfo(f))
+                        .OrderByDescending(f => f.LastWriteTimeUtc)
+                        .FirstOrDefault();
+
+                    if (latestFile is not null)
+                    {
+                        var age = DateTime.UtcNow - latestFile.LastWriteTimeUtc;
+                        isActive = age.TotalMinutes < 15;
+                        if (isActive)
+                            currentTask = $"Modified: {latestFile.Name}";
+                    }
+                }
+            }
+            catch { /* workspace not mounted or inaccessible */ }
+
+            agents.Add(new DashboardAgentInfo(
+                Id: def.Id,
+                Name: def.Name,
+                Role: DeriveRole(def.Id),
+                Model: def.Model,
+                IsActive: isActive,
+                CurrentTask: currentTask
+            ));
+        }
+
+        return agents;
+    }
+
+    public async Task<List<MessageEntry>> GetSessionHistoryAsync(string sessionKey, int limit = 50, int offset = 0)
+    {
+        try
+        {
+            var result = await InvokeToolAsync("sessions_history", new {
+                sessionKey, limit, offset,
+                includeTools = false
+            });
+            if (result is null) return new List<MessageEntry>();
+
+            // sessions_history returns { details: { messages: [...] } }
+            var messageArray = result["details"]?["messages"] as JsonArray;
+            if (messageArray is null) return new List<MessageEntry>();
+
+            var messages = new List<MessageEntry>();
+            foreach (var msg in messageArray.Cast<JsonNode?>())
+            {
+                if (msg is null) continue;
+                var role = msg["role"]?.GetValue<string>() ?? "";
+                // Skip non-user/assistant roles
+                if (role is not ("user" or "assistant")) continue;
+
+                // Content is an array of blocks: [{type: "text"/"thinking", text: "..."}]
+                // Extract only pure text blocks, skip thinking-only messages
+                var contentBlocks = msg["content"] as JsonArray;
+                if (contentBlocks is null) continue;
+
+                var visibleTexts = new List<string>();
+                foreach (var block in contentBlocks.Cast<JsonNode?>())
+                {
+                    if (block is null) continue;
+                    var type = block["type"]?.GetValue<string>() ?? "";
+                    var text = block["text"]?.GetValue<string>() ?? "";
+                    if (type == "text" && !string.IsNullOrWhiteSpace(text))
+                        visibleTexts.Add(text);
+                }
+
+                var visibleContent = string.Join(" ", visibleTexts).Trim();
+                if (string.IsNullOrWhiteSpace(visibleContent)) continue;
+
+                // Skip system-only replies
+                if (visibleContent is "REPLY_SKIP" or "ANNOUNCE_SKIP") continue;
+
+                var timestamp = msg["timestamp"]?.GetValue<string>()
+                    ?? DateTimeOffset.UtcNow.ToString("o");
+
+                messages.Add(new MessageEntry(role, visibleContent, timestamp));
+            }
+
+            return messages;
+        }
+        catch
+        {
+            return new List<MessageEntry>();
+        }
+    }
+
+    public async Task<ChatResponse> SendChatMessageAsync(string agentId, string message)
+    {
+        try
+        {
+            var result = await InvokeToolAsync("sessions_send", new { agentId, message });
+            if (result is null) return new ChatResponse(false, null, "Gateway nicht erreichbar");
+
+            // sessions_send reply is in details.reply or content[0].text
+            var details = result["details"];
+            var ok = (details?["status"]?.GetValue<string>() ?? result["status"]?.GetValue<string>()) == "ok";
+            var reply = details?["reply"]?.GetValue<string>()
+                ?? result["reply"]?.GetValue<string>()
+                ?? result["response"]?.GetValue<string>()
+                ?? result["content"]?[0]?["text"]?.GetValue<string>();
+            var error = details?["error"]?.GetValue<string>() ?? result["error"]?.GetValue<string>();
+
+            return new ChatResponse(ok, reply, error);
+        }
+        catch (Exception ex)
+        {
+            return new ChatResponse(false, null, $"Fehler: {ex.Message}");
+        }
+    }
+
+    public async Task<List<QueueItem>> GetQueueAsync()
+    {
+        try
+        {
+            var result = await InvokeToolAsync("cron", new { action = "list" });
+            var data = ExtractToolData(result);
+            if (data is null) return new List<QueueItem>();
+
+            var items = new List<QueueItem>();
+            var jobs = data["jobs"] as JsonArray ?? data.AsArray();
+            if (jobs is null) return items;
+
+            foreach (var j in jobs)
+            {
+                if (j is null) continue;
+                var id = j["id"]?.GetValue<string>() ?? "";
+                var name = j["name"]?.GetValue<string>() ?? id;
+                var status = j["state"]?["lastStatus"]?.GetValue<string>()
+                    ?? j["status"]?.GetValue<string>()
+                    ?? "unknown";
+
+                items.Add(new QueueItem(id, name, status));
+            }
+            return items;
+        }
+        catch
+        {
+            return new List<QueueItem>();
+        }
+    }
+
+    public async Task<DashboardStatus> GetStatusAsync()
+    {
+        var gatewayOk = false;
+        var irisStatus = "Offline";
+        var activeAgents = 0;
+        var pendingTasks = 0;
+
+        // Step 1: Health check (no auth needed)
+        try
+        {
+            using var pingRequest = new HttpRequestMessage(HttpMethod.Get, "/health");
+            using var pingResponse = await httpClient.SendAsync(pingRequest);
+            gatewayOk = pingResponse.IsSuccessStatusCode;
+        }
+        catch
+        {
+            // gatewayOk stays false
+        }
+
+        if (gatewayOk)
+        {
+            // Step 2: Session status
+            try
+            {
+                var sessionResult = await InvokeToolAsync("session_status");
+                if (sessionResult is not null)
+                {
+                    irisStatus = sessionResult["status"]?.GetValue<string>()
+                        ?? sessionResult["sessionKey"]?.GetValue<string>()
+                        ?? "Active";
+                }
+            }
+            catch { }
+
+            // Step 3: Active agents
+            try
+            {
+                var agents = await GetAgentsAsync();
+                activeAgents = agents.Count(a => a.IsActive);
+            }
+            catch { }
+
+            // Step 4: Queue items
+            try
+            {
+                var queue = await GetQueueAsync();
+                pendingTasks = queue.Count;
+            }
+            catch { }
+        }
+
+        return new DashboardStatus(gatewayOk, irisStatus, activeAgents, pendingTasks);
+    }
+
+    private static string DeriveRole(string agentId) => agentId.ToLowerInvariant() switch
+    {
+        "iris" => "Orchestrator",
+        "programmer" => "Developer",
+        "reviewer" => "Reviewer",
+        "architekt" => "Architect",
+        "executor" => "Executor",
+        "researcher" => "Researcher",
+        "main" => "Assistant",
+        _ => "Custom"
+    };
+}

frontend/src/components/dashboard/ChatPanel.vue

@@ -2,6 +2,7 @@
 import { ref, nextTick, watch } from 'vue'
 import { Bot, Send, LoaderCircle, Maximize2, X } from '@lucide/vue'
 import type { ChatMessage } from '../../composables/useDashboardData'
+import { useDashboardData } from '../../composables/useDashboardData'
 
 const props = defineProps<{
   messages: ChatMessage[]
@@ -9,9 +10,7 @@ const props = defineProps<{
   irisFocus: string
 }>()
 
-const emit = defineEmits<{
-  send: [text: string]
-}>()
+const { sendChatMessage } = useDashboardData()
 
 const inputText = ref('')
 const chatListRef = ref<HTMLElement | null>(null)
@@ -20,7 +19,7 @@ const chatModalOpen = ref(false)
 
 function sendMessage(): void {
   if (!inputText.value.trim()) return
-  emit('send', inputText.value)
+  sendChatMessage(inputText.value)
   inputText.value = ''
 }
 

frontend/src/composables/useDashboardData.ts

@@ -1,4 +1,13 @@
-import { ref, reactive, computed } from 'vue'
+import { ref, computed } from 'vue'
+
+// ── Shared State (singleton: same state regardless of how many times useDashboardData() is called) ──
+const sessionStart = Date.now()
+
+// Intervals registry for cleanup
+const intervals: ReturnType<typeof setInterval>[] = []
+let cleanupRegistered = false
+
+// ── Interfaces (exported for components) ──
 
 export interface AgentNodeData {
   id: string
@@ -49,242 +58,315 @@ export interface QueueItem {
   waitTime: string
 }
 
-const now = Date.now()
+// ── API Response Interfaces ──
 
-export function useDashboardData() {
-  const sessionStart = Date.now()
-
-  // Runtime counter
-  const runtimeSeconds = ref(0)
-  let runtimeInterval: ReturnType<typeof setInterval> | null = null
-
-  function startRuntime() {
-    const startTs = sessionStart
-    runtimeSeconds.value = Math.floor((Date.now() - startTs) / 1000)
-    runtimeInterval = setInterval(() => {
-      runtimeSeconds.value = Math.floor((Date.now() - startTs) / 1000)
-    }, 1000)
+interface DashboardStatusResponse {
+  gatewayOk: boolean
+  irisStatus: string
+  activeAgents: number
+  pendingTasks: number
 }
 
-  function stopRuntime() {
-    if (runtimeInterval) {
-      clearInterval(runtimeInterval)
-      runtimeInterval = null
-    }
+interface DashboardAgentInfo {
+  id: string
+  name: string
+  role: string
+  model: string
+  isActive: boolean
+  currentTask: string
 }
 
-  const formatRuntime = (seconds: number): string => {
-    const m = Math.floor(seconds / 60)
-    const s = seconds % 60
-    return `${String(m).padStart(2, '0')}:${String(s).padStart(2, '0')}`
+interface DashboardOperationEntry {
+  agent: string
+  action: string
+  timestamp: string
+  time: string
 }
 
-  const irisRuntime = computed(() => formatRuntime(runtimeSeconds.value))
-
-  // Agent runtimes (simulated)
-  const agentStartTimes = reactive<Record<string, number>>({
-    iris: now - 28800000,
-    developer: now - 3600000,
-    devops: now - 1800000,
-    researcher: now - 2700000,
-    reviewer: now - 900000,
-  })
-
-  const getAgentRuntime = (id: string): string => {
-    const start = agentStartTimes[id]
-    if (!start) return '00:00'
-    const secs = Math.floor((now - start) / 1000)
-    const m = Math.floor(secs / 60)
-    const s = secs % 60
-    return `${String(m).padStart(2, '0')}:${String(s).padStart(2, '0')}`
+interface DashboardChatMessage {
+  role: 'user' | 'assistant'
+  content: string
+  timestamp: string
 }
 
-  // Agents
-  const agents = ref<AgentNodeData[]>([
-    {
-      id: 'iris',
-      name: 'Iris',
-      role: 'Chief of Staff',
+interface DashboardSendResponse {
+  ok: boolean
+  reply?: string
+  error?: string
+}
+
+interface DashboardQueueItem {
+  id: string
+  name: string
+  status: string
+}
+
+// ── Agent Catalog (static enrichment) ──
+
+const AGENT_CATALOG: Record<string, Partial<AgentNodeData>> = {
+  iris: {
     description: 'Koordiniert, delegiert, hält das Team tight. Die erste Anlaufstelle zwischen Boss und Maschine.',
     tags: ['Orchestration', 'Delegation', 'Approval'],
     color: '#8b7cf6',
     icon: 'bot',
     hero: true,
-      currentTask: 'Orchestrating Nexus Dashboard redesign',
     goal: 'Complete Mission Control v3',
     progress: 85,
     workload: 55,
-      active: true,
-      runtimeSeconds: 28800,
-      model: 'GPT-5.4',
-      workingFeed: [
-        { time: '22:38', text: 'Analyzed user feedback on Dashboard' },
-        { time: '22:36', text: 'Delegated card redesign to Developer' },
-        { time: '22:34', text: 'Verifying full-width layout deployment' },
-        { time: '22:32', text: 'Reviewing AgentModal integration' },
-      ],
-      thinkingStream: [
-        { time: '22:24', text: 'Analysing constraint: full-width layout' },
-        { time: '22:25', text: 'Removing max-width from global CSS' },
-        { time: '22:26', text: 'Verifying Dashboard grid reflow' },
-      ],
+    workingFeed: [],
+    thinkingStream: [],
   },
-    {
-      id: 'developer',
-      name: 'Developer',
-      role: 'Backend & Frontend',
+  developer: {
     description: 'Implements features across the stack with TypeScript, C#, and Vue.',
     tags: ['Coding', 'Development', 'Builds'],
     color: '#3b82f6',
     icon: 'code',
-      currentTask: 'Building Dungeon System API endpoints',
     goal: 'Complete Dungeon CRUD + room generation',
     progress: 62,
     workload: 65,
-      active: true,
-      runtimeSeconds: 3600,
-      workingFeed: [
-        { time: '22:30', text: 'Created DungeonController' },
-        { time: '22:28', text: 'Defined dungeon schema' },
-        { time: '22:26', text: 'Implementing room generation algorithm' },
-        { time: '22:24', text: 'Writing unit tests for RoomFactory' },
-      ],
-      thinkingStream: [
-        { time: '22:22', text: 'Parsing dungeon spec from Iris' },
-        { time: '22:23', text: 'Designing RoomFactory interface' },
-        { time: '22:24', text: 'Implementing corridor connection logic' },
-      ],
-      model: 'DeepSeek V4 Flash',
+    workingFeed: [],
+    thinkingStream: [],
   },
-    {
-      id: 'devops',
-      name: 'DevOps',
-      role: 'Infrastructure & CI/CD',
+  devops: {
     description: 'Manages Docker, deployment pipelines, and system reliability.',
     tags: ['Deployment', 'Docker', 'CI/CD'],
     color: '#eab308',
     icon: 'server',
-      currentTask: 'Optimizing Docker Compose caching',
     goal: 'Reduce build times by 40%',
     progress: 45,
     workload: 40,
-      active: false,
-      runtimeSeconds: 1800,
-      workingFeed: [
-        { time: '22:20', text: 'Analyzed Docker layer cache' },
-        { time: '22:18', text: 'Optimized COPY order in Dockerfile' },
-        { time: '22:16', text: 'Added .dockerignore for node_modules' },
-        { time: '22:14', text: 'Testing incremental builds' },
-      ],
-      thinkingStream: [
-        { time: '22:20', text: 'Checking build cache hit rates' },
-        { time: '22:21', text: 'Benchmarking multi-stage vs single-stage' },
-        { time: '22:22', text: 'Calculating potential speedup from caching' },
-      ],
-      model: 'DeepSeek V4 Pro',
+    workingFeed: [],
+    thinkingStream: [],
   },
-    {
-      id: 'researcher',
-      name: 'Researcher',
-      role: 'Analysis & Documentation',
+  researcher: {
     description: 'Researches APIs, patterns, and best practices. Maintains docs.',
     tags: ['Research', 'Analysis', 'Docs'],
     color: '#22c55e',
     icon: 'search',
-      currentTask: 'Analyzing WebSocket alternatives',
     goal: 'Recommend real-time communication strategy',
     progress: 30,
     workload: 25,
-      active: true,
-      runtimeSeconds: 2700,
-      workingFeed: [
-        { time: '22:18', text: 'Evaluated WebSocket vs SSE vs WebRTC' },
-        { time: '22:17', text: 'Documented SignalR limitations' },
-        { time: '22:16', text: 'Prototyping WebSocket fallback' },
-      ],
-      thinkingStream: [
-        { time: '22:18', text: 'Cross-referencing WebSocket latency benchmarks' },
-        { time: '22:19', text: 'Checking SSE browser support matrix' },
-        { time: '22:20', text: 'Drafting recommendation summary' },
-      ],
-      model: 'DeepSeek V4 Pro',
+    workingFeed: [],
+    thinkingStream: [],
   },
-    {
-      id: 'reviewer',
-      name: 'Reviewer',
-      role: 'Code Quality & Testing',
+  reviewer: {
     description: 'Reviews pull requests, enforces standards, runs test suites.',
     tags: ['Code Review', 'Testing', 'Quality'],
     color: '#a855f7',
     icon: 'shield',
-      currentTask: 'Reviewing Dungeon System PR',
     goal: 'Zero critical findings before merge',
     progress: 80,
     workload: 50,
-      active: false,
-      runtimeSeconds: 900,
-      workingFeed: [
-        { time: '22:15', text: 'Reviewed DungeonController.cs' },
-        { time: '22:14', text: 'Found 3 minor style issues' },
-        { time: '22:13', text: 'Approved RoomValidator' },
-        { time: '22:12', text: 'Running integration tests' },
-      ],
-      thinkingStream: [
-        { time: '22:15', text: 'Analyzing DungeonController PR diff' },
-        { time: '22:16', text: 'Checking RoomValidator edge cases' },
-        { time: '22:17', text: 'Verifying integration test coverage' },
-      ],
-      model: 'DeepSeek V4 Pro',
+    workingFeed: [],
+    thinkingStream: [],
   },
-  ])
+}
 
-  // Open Tasks
+function enrichAgent(api: DashboardAgentInfo): AgentNodeData {
+  const catalog = AGENT_CATALOG[api.id] ?? AGENT_CATALOG['developer']
+  return {
+    id: api.id,
+    name: api.name,
+    role: api.role,
+    model: api.model,
+    currentTask: api.currentTask ?? 'Idle',
+    active: api.isActive,
+    description: catalog.description ?? '',
+    tags: catalog.tags ?? [],
+    color: catalog.color ?? '#6b7385',
+    icon: catalog.icon ?? 'bot',
+    hero: catalog.hero ?? false,
+    goal: catalog.goal ?? 'No goal set',
+    progress: catalog.progress ?? 0,
+    workload: catalog.workload ?? 0,
+    runtimeSeconds: 0,
+    workingFeed: catalog.workingFeed ?? [],
+    thinkingStream: catalog.thinkingStream ?? [],
+  }
+}
+
+// ── Helper: API Fetch with auth ──
+
+async function apiFetch(path: string, init: RequestInit = {}): Promise<Response> {
+  const base = '' // same-origin proxy
+  return fetch(`${base}${path}`, {
+    ...init,
+    credentials: 'include',
+    headers: {
+      'Content-Type': 'application/json',
+      ...(init.headers as Record<string, string> ?? {}),
+    },
+  })
+}
+
+// ── State ──
+
+// Status
+const gatewayOk = ref(true)
+const irisStatus = ref('Active')
+const activeAgents = ref(0)
+const pendingTasks = ref(0)
+
+// Agents
+const agents = ref<AgentNodeData[]>([])
+
+// Chat
+const chatMessages = ref<ChatMessage[]>([])
+const irisBusy = ref(false)
+const irisFocus = ref('')
+
+// Operations Feed
+const feedEntries = ref<FeedEntry[]>([])
+
+// Open Tasks (mock only – no API endpoint)
 const openTasks = ref<OpenTask[]>([
   { id: 't1', title: 'Agent Thinking Panel visualisieren', detail: 'Live-Animation der Denkprozesse im AgentModal', source: 'iris', createdAt: '22:30' },
   { id: 't2', title: 'CI/CD Pipeline Monitoring Dashboard', detail: 'Echtzeit-Status der Gitea Actions im Dashboard', source: 'iris', createdAt: '21:15' },
   { id: 't3', title: 'Dungeon System Dokumentation', detail: 'API-Doku für Room-Generation-Endpunkte schreiben', source: 'bao', createdAt: '20:00' },
 ])
 
-  // Feed
-  const ts = (offset: number) => new Date(now + offset).toISOString()
-  const feedEntries = ref<FeedEntry[]>([
-    { time: '22:50', agent: 'Developer', action: 'Created DungeonController endpoints', timestamp: ts(-120000) },
-    { time: '22:46', agent: 'DevOps', action: 'Optimized Docker COPY order for layer caching', timestamp: ts(-360000) },
-    { time: '22:42', agent: 'Iris', action: 'Delegated room generation to Developer with spec', timestamp: ts(-600000) },
-    { time: '22:35', agent: 'Researcher', action: 'Documented WebSocket vs SSE analysis results', timestamp: ts(-960000) },
-    { time: '22:28', agent: 'Reviewer', action: 'Approved RoomValidator PR with minor fixes', timestamp: ts(-1200000) },
-    { time: '22:18', agent: 'DevOps', action: 'Added .dockerignore for node_modules and build artifacts', timestamp: ts(-1500000) },
-    { time: '22:08', agent: 'Iris', action: 'Broke down Dungeon System tasks into sub-tasks', timestamp: ts(-1800000) },
-    { time: '21:55', agent: 'Developer', action: 'Defined dungeon schema models with validation', timestamp: ts(-2400000) },
-  ])
-
-  // Chat
-  const chatMessages = ref<ChatMessage[]>([
-    { id: 'm1', sender: 'iris', text: 'Guten Abend, Bao. Ready to continue the Dungeon System?', timestamp: now - 600000 },
-    { id: 'm2', sender: 'user', text: "Yes, what's the status?", timestamp: now - 540000 },
-    { id: 'm3', sender: 'iris', text: "Developer is at 62% on room generation. Reviewer approved the schema. I'd recommend focusing on the room connection logic next.", timestamp: now - 480000 },
-  ])
-
-  const irisBusy = ref(true)
-  const irisFocus = ref('Breaking down Dungeon System for DevOps and Developer')
-
 // Queue
-  const queue = ref<QueueItem[]>([
-    { id: 'q1', text: 'Deploy latest dashboard build to preview', priority: 'high', waitTime: '2 min' },
-    { id: 'q2', text: 'Review infrastructure cost analysis', priority: 'medium', waitTime: '8 min' },
-    { id: 'q3', text: 'Schedule B2 German lesson review', priority: 'low', waitTime: '15 min' },
-    { id: 'q4', text: 'Update project roadmap document', priority: 'medium', waitTime: '12 min' },
-  ])
+const queue = ref<QueueItem[]>([])
 
-  function sendChat(text: string): void {
+// Runtime
+const runtimeSeconds = ref(0)
+let runtimeInterval: ReturnType<typeof setInterval> | null = null
+
+// ── Fetch Functions ──
+
+async function fetchStatus(): Promise<void> {
+  try {
+    const res = await apiFetch('/api/dashboard/status')
+    if (!res.ok) return
+    const data: DashboardStatusResponse = await res.json()
+    gatewayOk.value = data.gatewayOk
+    irisStatus.value = data.irisStatus
+    activeAgents.value = data.activeAgents
+    pendingTasks.value = data.pendingTasks
+  } catch {
+    // API unreachable – keep current values
+  }
+}
+
+async function fetchAgents(): Promise<void> {
+  try {
+    const res = await apiFetch('/api/dashboard/agents')
+    if (!res.ok) return
+    const data: DashboardAgentInfo[] = await res.json()
+    agents.value = data.map(enrichAgent)
+  } catch {
+    // API unreachable – keep current values
+  }
+}
+
+async function fetchOperations(): Promise<void> {
+  try {
+    const res = await apiFetch('/api/dashboard/operations?limit=20')
+    if (!res.ok) return
+    const data: DashboardOperationEntry[] = await res.json()
+    feedEntries.value = data.map((entry) => ({
+      time: entry.time,
+      agent: entry.agent,
+      action: entry.action,
+      timestamp: entry.timestamp,
+    }))
+  } catch {
+    // API unreachable – keep current values
+  }
+}
+
+async function fetchChatMessages(): Promise<void> {
+  try {
+    const res = await apiFetch('/api/dashboard/chat/messages?limit=50')
+    if (!res.ok) return
+    const data: DashboardChatMessage[] = await res.json()
+    // Merge instead of replace — only add messages not already present
+    const existingTexts = new Set(chatMessages.value.map(m => m.text))
+    const existingTimestamps = new Set(chatMessages.value.map(m => m.timestamp))
+    for (const msg of data) {
+      const msgTime = new Date(msg.timestamp).getTime()
+      if (existingTexts.has(msg.content) && existingTimestamps.has(msgTime)) continue
+      chatMessages.value.push({
+        id: `msg-${msgTime}-${msg.role}`,
+        sender: msg.role === 'assistant' ? 'iris' : 'user',
+        text: msg.content,
+        timestamp: msgTime,
+      })
+    }
+  } catch {
+    // API unreachable – keep current values
+  }
+}
+
+async function fetchQueue(): Promise<void> {
+  try {
+    const res = await apiFetch('/api/dashboard/queue')
+    if (!res.ok) return
+    const data: DashboardQueueItem[] = await res.json()
+    queue.value = data.map((item) => ({
+      id: item.id,
+      text: item.name,
+      priority: (item.status === 'high' || item.status === 'medium' || item.status === 'low')
+        ? item.status as 'high' | 'medium' | 'low'
+        : 'medium',
+      waitTime: '--',
+    }))
+  } catch {
+    // API unreachable – keep current values
+  }
+}
+
+// ── Chat Send ──
+
+async function sendChatMessage(text: string): Promise<void> {
   if (!text.trim()) return
+
+  // Optimistic add
   chatMessages.value.push({
     id: `user-${Date.now()}`,
     sender: 'user',
     text: text.trim(),
     timestamp: Date.now(),
   })
+
+  irisBusy.value = true
+
+  try {
+    const res = await apiFetch('/api/dashboard/chat/send', {
+      method: 'POST',
+      body: JSON.stringify({ message: text.trim() }),
+    })
+    const data: DashboardSendResponse = await res.json()
+
+    if (data.ok && data.reply) {
+      chatMessages.value.push({
+        id: `iris-${Date.now()}`,
+        sender: 'iris',
+        text: data.reply,
+        timestamp: Date.now(),
+      })
+    } else if (data.error) {
+      chatMessages.value.push({
+        id: `error-${Date.now()}`,
+        sender: 'iris',
+        text: `⚠️ ${data.error}`,
+        timestamp: Date.now(),
+      })
     }
+  } catch {
+    chatMessages.value.push({
+      id: `error-${Date.now()}`,
+      sender: 'iris',
+      text: '⚠️ Connection error. Please try again.',
+      timestamp: Date.now(),
+    })
+  } finally {
+    irisBusy.value = false
+    irisFocus.value = text.trim()
+  }
+}
+
+// ── Queue Operations ──
 
 function removeQueueItem(id: string): void {
   const idx = queue.value.findIndex(q => q.id === id)
@@ -302,7 +384,73 @@ export function useDashboardData() {
   if (item) item.priority = priority
 }
 
+// ── Runtime ──
+
+function startRuntime(): void {
+  const startTs = sessionStart
+  runtimeSeconds.value = Math.floor((Date.now() - startTs) / 1000)
+  runtimeInterval = setInterval(() => {
+    runtimeSeconds.value = Math.floor((Date.now() - startTs) / 1000)
+  }, 1000)
+}
+
+function stopRuntime(): void {
+  if (runtimeInterval) {
+    clearInterval(runtimeInterval)
+    runtimeInterval = null
+  }
+}
+
+const formatRuntime = (seconds: number): string => {
+  const m = Math.floor(seconds / 60)
+  const s = seconds % 60
+  return `${String(m).padStart(2, '0')}:${String(s).padStart(2, '0')}`
+}
+
+const irisRuntime = computed(() => formatRuntime(runtimeSeconds.value))
+
+const getAgentRuntime = (_id: string): string => {
+  // Could be extended to track per-agent runtimes from API
+  return formatRuntime(runtimeSeconds.value)
+}
+
+// ── Polling starten (nur einmal) ──
+
+function startPolling(): void {
+  if (cleanupRegistered) return
+  cleanupRegistered = true
+
+  // Initial fetches
+  fetchStatus()
+  fetchAgents()
+  fetchOperations()
+  fetchChatMessages()
+  fetchQueue()
+
+  // Polling intervals
+  intervals.push(setInterval(fetchStatus, 5000))
+  intervals.push(setInterval(fetchAgents, 10000))
+  intervals.push(setInterval(fetchOperations, 10000))
+  intervals.push(setInterval(fetchChatMessages, 3000))
+  intervals.push(setInterval(fetchQueue, 10000))
+}
+
+function stopPolling(): void {
+  for (const interval of intervals) {
+    clearInterval(interval)
+  }
+  intervals.length = 0
+  cleanupRegistered = false
+}
+
+// ── Composable Export ──
+
+export function useDashboardData() {
+  // Start polling on first call
+  startPolling()
+
   return {
+    // State
     agents,
     openTasks,
     feedEntries,
@@ -311,14 +459,29 @@ export function useDashboardData() {
     irisFocus,
     irisRuntime,
     queue,
+    gatewayOk,
+    irisStatus,
+    pendingTasks,
+    activeAgents,
+
+    // Runtime
     runtimeSeconds,
     getAgentRuntime,
     startRuntime,
     stopRuntime,
     formatRuntime,
-    sendChat,
+
+    // Actions
+    sendChatMessage,
     removeQueueItem,
     moveQueueItem,
     changeQueuePriority,
+
+    // Fetch (for manual refresh)
+    fetchStatus,
+    fetchAgents,
+    fetchOperations,
+    fetchChatMessages,
+    fetchQueue,
   }
 }

frontend/src/views/DashboardView.vue

@@ -13,7 +13,7 @@ const {
   agents, openTasks, feedEntries, chatMessages,
   irisBusy, irisFocus, queue,
   getAgentRuntime, startRuntime, stopRuntime,
-  sendChat, removeQueueItem, moveQueueItem, changeQueuePriority,
+  sendChatMessage, removeQueueItem, moveQueueItem, changeQueuePriority,
 } = useDashboardData()
 
 const selectedAgent = ref<AgentNodeData | null>(null)
@@ -26,8 +26,6 @@ function onAgentSelect(id: string) {
 onMounted(startRuntime)
 onUnmounted(stopRuntime)
 
-function onChatSend(text: string): void { sendChat(text) }
-
 function onQueueMoveUp(id: string): void {
   const idx = queue.value.findIndex(q => q.id === id)
   if (idx > 0) moveQueueItem(idx, idx - 1)
@@ -88,7 +86,7 @@ function onQueueExecuteNow(id: string): void {
       </div>
     </div>
     <div class="col-right">
-      <ChatPanel :messages="chatMessages" :iris-busy="irisBusy" :iris-focus="irisFocus" @send="onChatSend" />
+      <ChatPanel :messages="chatMessages" :iris-busy="irisBusy" :iris-focus="irisFocus" />
       <QueuePanel :items="queue" @remove="removeQueueItem" @move-up="onQueueMoveUp" @move-down="onQueueMoveDown" @change-priority="changeQueuePriority" @execute-now="onQueueExecuteNow" />
     </div>