Compare commits

..

34 Commits

Author SHA1 Message Date
44b4758747 Merge branch 'dev' into agent/rex/CUB-50-adaptive-navigation 2026-04-27 17:44:59 -04:00
45b9068acc Merge pull request 'CUB-44: Implement Task Progress Bar Component' (#15) from agent/rex/CUB-44-task-progress-bar into dev
Reviewed-on: #15
Reviewed-by: Otto the Minion <otto@code.cubecraftcreations.com>
2026-04-27 17:44:46 -04:00
e39fd45018 Merge branch 'dev' into agent/rex/CUB-44-task-progress-bar 2026-04-27 17:44:35 -04:00
5fd37b556a Merge pull request 'feat(CUB-45): AgentCard Component Final Integration' (#19) from agent/rex/CUB-45-agent-card-final into dev
Reviewed-on: #19
Reviewed-by: Otto the Minion <otto@code.cubecraftcreations.com>
Reviewed-by: Joshua <joshua@cnjmail.com>
2026-04-27 17:44:16 -04:00
a2567dd3aa Merge branch 'dev' into agent/rex/CUB-45-agent-card-final 2026-04-27 17:43:54 -04:00
512a3364cf Merge pull request 'CUB-54: Implement Agent State Repository (EF Core)' (#23) from agent/dex/CUB-54-agent-state-repository into dev
Reviewed-on: #23
2026-04-27 17:42:57 -04:00
bca3bf7677 Merge branch 'dev' into agent/dex/CUB-54-agent-state-repository 2026-04-27 17:42:41 -04:00
1c012de47b Merge pull request 'feat(CUB-62): [Control Center] Agent-to-Minion Mapping Service' (#24) from agent/dex/CUB-62-agent-minion-mapper into dev
Reviewed-on: #24
2026-04-27 17:42:30 -04:00
ea603c3552 Merge branch 'dev' into agent/dex/CUB-62-agent-minion-mapper 2026-04-27 17:42:16 -04:00
bcaf85c369 Merge pull request 'CUB-55: Add SendStatusUpdate method to AgentStatusHub' (#25) from agent/dex/CUB-55-signalr-broadcast into dev
Reviewed-on: #25
2026-04-27 17:42:10 -04:00
84e3d5420e Merge branch 'dev' into agent/dex/CUB-55-signalr-broadcast 2026-04-27 17:40:52 -04:00
8bdbcae13a Merge pull request 'CUB-48: Agent Status Badge component with pulse animations' (#26) from agent/rex/CUB-48-agent-status-badge into dev
Reviewed-on: #26
2026-04-27 17:40:37 -04:00
db91c8bde9 Merge branch 'dev' into agent/rex/CUB-48-agent-status-badge 2026-04-27 17:40:21 -04:00
53454e0635 Merge pull request 'CUB-47: Implement Tactical Dark Mode CSS Variables' (#13) from agent/rex/CUB-47-dark-mode-variables into dev
Reviewed-on: #13
Reviewed-by: Otto the Minion <otto@code.cubecraftcreations.com>
2026-04-27 16:07:10 -04:00
d06caeab8e Merge branch 'dev' into agent/rex/CUB-47-dark-mode-variables 2026-04-27 16:06:56 -04:00
49a9a95086 Merge pull request 'feat(CUB-52): Responsive Hub Grid CSS' (#12) from agent/rex/CUB-52-responsive-hub-grid into dev
Reviewed-on: #12
Reviewed-by: Otto the Minion <otto@code.cubecraftcreations.com>
Reviewed-by: Joshua <joshua@cnjmail.com>
2026-04-27 16:06:34 -04:00
2a21cad431 feat(CUB-45): [Control Center] AgentCard Component Final Integration 2026-04-27 14:36:14 +00:00
5375d11792 CUB-48: Agent Status Badge component with pulse animations 2026-04-27 14:17:04 +00:00
cubecraft-agents[bot]
c8ca182af0 CUB-52: responsive hub grid CSS — extract styles to SCSS, add 2-col desktop / 1-col mobile breakpoint 2026-04-27 12:40:29 +00:00
cubecraft-agents[bot]
fb88eab4d1 feat(CUB-55): add SendStatusUpdate method to AgentStatusHub 2026-04-27 10:07:07 +00:00
cubecraft-agents[bot]
82c12554d0 feat(CUB-62): [Control Center] Agent-to-Minion Mapping Service 2026-04-27 09:11:30 +00:00
cubecraft-agents[bot]
f170def0ea feat(CUB-54): implement Agent State Repository with EF Core
- Add AgentState read model (Models/AgentState.cs)
- Add IAgentStateRepository interface with GetAllAsync,
  GetBySessionKeyAsync, UpdateStatusAsync
- Add AgentStateRepository EF Core implementation
  mapping Agent entity → AgentState model
- Register IAgentStateRepository in DI (Program.cs)
- Exclude ControlCenter sub-project from Api compilation

Build: 0 warnings, 0 errors
2026-04-27 04:10:18 +00:00
cubecraft-agents[bot]
040d4cb54d fix(CUB-56): Restore Program.cs deletion - PR should only add Swashbuckle package 2026-04-27 02:24:51 +00:00
cubecraft-agents[bot]
47cbeed456 feat(CUB-56): [Control Center] Agent State Database Migration 2026-04-26 22:07:05 +00:00
cubecraft-agents[bot]
d2da0c160f CUB-50: Implement Adaptive Navigation Component 2026-04-26 13:32:59 +00:00
cubecraft-agents[bot]
14b3dab88b CUB-44: add task-progress-bar component with determinate mode and elapsed time 2026-04-26 13:09:18 +00:00
cubecraft-agents[bot]
d5a85c4ed0 CUB-47: Implement Tactical Dark Mode CSS Variables 2026-04-26 12:54:25 +00:00
8d0adeb2e9 Merge pull request 'feat(CUB-19): Implement AgentStatus SignalR Hub for Real-time Updates' (#1) from feat/CUB-19-agentstatus-signalr-hub into dev
Reviewed-on: #1
Reviewed-by: Joshua <joshua@cnjmail.com>
2026-04-26 08:02:58 -04:00
a79ab6dbd5 Merge branch 'dev' into feat/CUB-19-agentstatus-signalr-hub 2026-04-26 08:02:48 -04:00
6668da04d4 Merge pull request 'feat(CUB-55): SignalR Broadcast State Method' (#3) from agent/dex/CUB-55-signalr-broadcast into dev
Reviewed-on: #3
Reviewed-by: Joshua <joshua@cnjmail.com>
2026-04-26 08:00:19 -04:00
cubecraft-agents[bot]
6cf8d7fe5f feat(CUB-55): add SignalR broadcast state method with AgentStatusHub and DTO 2026-04-26 11:25:31 +00:00
cubecraft-agents[bot]
7b7b070dac feat(CUB-56): Agent State Database Migration 2026-04-26 10:18:06 +00:00
cubecraft-agents[bot]
69df1562c7 chore(CUB-19): add .gitignore and remove build artifacts from tracking 2026-04-25 22:11:09 +00:00
cubecraft-agents[bot]
1c5d982cd9 feat(CUB-19): implement AgentStatus SignalR hub for real-time updates
- Add AgentStatusHub with typed IAgentStatusClient interface
  - Hub at /hubs/agent-status (matches design spec)
  - Fleet group + per-agent group subscription
  - AgentStatusChanged and AgentTaskProgress push events
  - Extension methods for server-side push via IHubContext

- Add GatewayEventBridgeService background service
  - Connects to OpenClaw Gateway WebSocket (v3 protocol)
  - Handles challenge → connect → hello-ok handshake
  - Bridges sessions.changed, session.message, session.tool events
  - Translates Gateway session status to AgentStatus enum
  - Maintains in-memory fleet state for snapshot queries

- Add REST API controllers
  - GET /api/agents — fleet status snapshot
  - GET /api/agents/{agentId} — single agent status
  - GET /api/logs/{agentId} — agent session logs (stub)
  - POST /api/command/stop/{agentId} — stop agent
  - POST /api/command/restart/{agentId} — restart agent
  - POST /api/command/steer/{agentId} — inject message

- Add models matching TypeScript spec interfaces
  - AgentStatusUpdate, TaskProgressUpdate, AgentCardData
  - AgentStatus enum (active/idle/thinking/error)

- Configure CORS with credentials for SignalR WebSocket
- Configure Swagger/OpenAPI with XML doc comments
- Agent role map matching frontend AGENT_ROLES constant
2026-04-25 22:10:51 +00:00
65 changed files with 3979 additions and 1806 deletions

21
backend/.gitignore vendored Normal file
View File

@@ -0,0 +1,21 @@
## .NET
bin/
obj/
*.user
*.suo
*.cache
*.dll
*.pdb
## IDE
.vs/
.idea/
*.swp
*~
## OS
.DS_Store
Thumbs.db
## Environment
.env

View File

@@ -0,0 +1,88 @@
using ControlCenter.Api.Entities;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Metadata.Builders;
namespace ControlCenter.Api.Configurations;
/// <summary>
/// EF Core entity type configuration for the agents table.
/// Enforces snake_case naming, required fields, and index design.
/// </summary>
public class AgentConfiguration : IEntityTypeConfiguration<Agent>
{
public void Configure(EntityTypeBuilder<Agent> builder)
{
// Table name — snake_case
builder.ToTable("agents");
// Primary key
builder.HasKey(a => a.Id);
builder.Property(a => a.Id)
.HasColumnName("id")
.ValueGeneratedOnAdd();
// Status — stored as PostgreSQL enum via Npgsql
builder.Property(a => a.Status)
.HasColumnName("status")
.HasColumnType("agent_status")
.IsRequired();
// Task — nullable text
builder.Property(a => a.Task)
.HasColumnName("task")
.HasColumnType("text");
// Progress — nullable integer (0100)
builder.Property(a => a.Progress)
.HasColumnName("progress");
// Session key — required, not null
builder.Property(a => a.SessionKey)
.HasColumnName("session_key")
.HasColumnType("text")
.IsRequired();
// Channel — required, not null
builder.Property(a => a.Channel)
.HasColumnName("channel")
.HasColumnType("text")
.IsRequired();
// Last activity — required, defaults to now()
builder.Property(a => a.LastActivity)
.HasColumnName("last_activity")
.HasColumnType("timestamptz")
.IsRequired();
// Created at — auto-set on insert
builder.Property(a => a.CreatedAt)
.HasColumnName("created_at")
.HasColumnType("timestamptz")
.IsRequired()
.HasDefaultValueSql("now()");
// Updated at — auto-set on insert and update
builder.Property(a => a.UpdatedAt)
.HasColumnName("updated_at")
.HasColumnType("timestamptz")
.IsRequired()
.HasDefaultValueSql("now()");
// Indexes
// Sessions are looked up by session_key frequently
builder.HasIndex(a => a.SessionKey)
.HasDatabaseName("ix_agents_session_key")
.IsUnique();
// Agents are filtered by channel for channel-specific queries
builder.HasIndex(a => a.Channel)
.HasDatabaseName("ix_agents_channel");
// Agents are filtered by status for fleet health monitoring
builder.HasIndex(a => a.Status)
.HasDatabaseName("ix_agents_status");
// Check constraint: progress must be 0100 if present
builder.ToTable(t => t.HasCheckConstraint("ck_agents_progress_range", "progress IS NULL OR (progress >= 0 AND progress <= 100)"));
}
}

View File

@@ -0,0 +1,24 @@
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>net9.0</TargetFramework>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup>
<!-- Exclude the separate ControlCenter sub-project from this project's compilation -->
<ItemGroup>
<Compile Remove="ControlCenter/**/*.cs" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.14" />
<PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.4">
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
<PrivateAssets>all</PrivateAssets>
</PackageReference>
<PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="9.0.4" />
<PackageReference Include="Swashbuckle.AspNetCore" Version="10.1.7" />
</ItemGroup>
</Project>

View File

@@ -0,0 +1,6 @@
@ControlCenter.Api_HostAddress = http://localhost:5178
GET {{ControlCenter.Api_HostAddress}}/weatherforecast/
Accept: application/json
###

18
backend/ControlCenter/.gitignore vendored Normal file
View File

@@ -0,0 +1,18 @@
## .NET
bin/
obj/
*.user
*.suo
*.cache
*.dll
*.pdb
*.xml
## IDE
.vs/
.vscode/
.idea/
## OS
.DS_Store
Thumbs.db

View File

@@ -0,0 +1,17 @@
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>net9.0</TargetFramework>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
<GenerateDocumentationFile>true</GenerateDocumentationFile>
<NoWarn>CS1591</NoWarn>
<RootNamespace>ControlCenter</RootNamespace>
<AssemblyName>ControlCenter</AssemblyName>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Swashbuckle.AspNetCore" Version="10.1.7" />
</ItemGroup>
</Project>

View File

@@ -0,0 +1,71 @@
using Microsoft.AspNetCore.Mvc;
using ControlCenter.Services;
namespace ControlCenter.Controllers;
/// <summary>
/// REST API for querying agent fleet status.
/// Provides the initial data load for the Command Hub,
/// while real-time updates flow through the AgentStatus SignalR hub.
///
/// <para>API contract for Rex (Frontend):</para>
/// <list type="bullet">
/// <item><c>GET /api/agents</c> — Returns all known agents with current status</item>
/// <item><c>GET /api/agents/{agentId}</c> — Returns a specific agent's status</item>
/// </list>
/// </summary>
[ApiController]
[Route("api/[controller]")]
public class AgentsController : ControllerBase
{
private readonly ILogger<AgentsController> _logger;
private readonly GatewayEventBridgeService _bridgeService;
public AgentsController(
ILogger<AgentsController> logger,
GatewayEventBridgeService bridgeService)
{
_logger = logger;
_bridgeService = bridgeService;
}
/// <summary>
/// Gets the current fleet status — all known agents with their latest state.
/// This is the initial load endpoint; subsequent updates arrive via SignalR.
/// </summary>
/// <returns>An array of agent card data for the entire fleet.</returns>
/// <response code="200">Returns the fleet snapshot.</response>
[HttpGet]
[ProducesResponseType(typeof(AgentCardData[]), StatusCodes.Status200OK)]
public IActionResult GetAgents()
{
var snapshot = _bridgeService.GetFleetSnapshot();
_logger.LogDebug("Fleet snapshot requested: {Count} agents", snapshot.Length);
return Ok(snapshot);
}
/// <summary>
/// Gets the current status of a specific agent.
/// </summary>
/// <param name="agentId">The agent identifier, e.g. "otto", "dex".</param>
/// <returns>The agent's current card data.</returns>
/// <response code="200">Returns the agent's status.</response>
/// <response code="404">Agent not found in the fleet state.</response>
[HttpGet("{agentId}")]
[ProducesResponseType(typeof(AgentCardData), StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status404NotFound)]
public IActionResult GetAgent(string agentId)
{
var snapshot = _bridgeService.GetFleetSnapshot();
var agent = snapshot.FirstOrDefault(a =>
a.Id.Equals(agentId, StringComparison.OrdinalIgnoreCase));
if (agent is null)
{
_logger.LogWarning("Agent not found: {AgentId}", agentId);
return NotFound(new { error = $"Agent '{agentId}' not found" });
}
return Ok(agent);
}
}

View File

@@ -0,0 +1,122 @@
using Microsoft.AspNetCore.Mvc;
namespace ControlCenter.Controllers;
/// <summary>
/// REST API for sending control commands to agents.
/// Provides the Command Hub's action endpoints for agent lifecycle control.
///
/// <para>API contract for Rex (Frontend):</para>
/// <list type="bullet">
/// <item><c>POST /api/command/stop/{agentId}</c> — Stop/abort an agent's active session</item>
/// <item><c>POST /api/command/restart/{agentId}</c> — Restart an agent</item>
/// <item><c>POST /api/command/steer/{agentId}</c> — Inject a message into an agent's session</item>
/// </list>
///
/// <para>Commands are forwarded to the OpenClaw Gateway via the
/// WebSocket bridge service. The Gateway handles the actual execution.</para>
/// </summary>
[ApiController]
[Route("api/[controller]")]
public class CommandController : ControllerBase
{
private readonly ILogger<CommandController> _logger;
public CommandController(ILogger<CommandController> logger)
{
_logger = logger;
}
/// <summary>
/// Stops (aborts) an agent's active session.
/// Sends an abort command to the OpenClaw Gateway.
/// </summary>
/// <param name="agentId">The agent identifier to stop.</param>
/// <returns>Confirmation of the stop command.</returns>
/// <response code="200">Stop command sent successfully.</response>
/// <response code="404">No active session found for the agent.</response>
[HttpPost("stop/{agentId}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status404NotFound)]
public IActionResult StopAgent(string agentId)
{
_logger.LogInformation("Stop command received for agent {AgentId}", agentId);
// TODO: Forward to Gateway via bridge service
// await _bridgeService.SendRpcAsync("sessions.abort", new { sessionKey = ... });
return Ok(new
{
agentId,
command = "stop",
status = "sent",
timestamp = DateTime.UtcNow.ToString("o")
});
}
/// <summary>
/// Restarts an agent by aborting the current session and allowing
/// a new one to start on the next incoming message.
/// </summary>
/// <param name="agentId">The agent identifier to restart.</param>
/// <returns>Confirmation of the restart command.</returns>
/// <response code="200">Restart command sent successfully.</response>
[HttpPost("restart/{agentId}")]
[ProducesResponseType(StatusCodes.Status200OK)]
public IActionResult RestartAgent(string agentId)
{
_logger.LogInformation("Restart command received for agent {AgentId}", agentId);
// TODO: Forward to Gateway — abort current session + signal restart
return Ok(new
{
agentId,
command = "restart",
status = "sent",
timestamp = DateTime.UtcNow.ToString("o")
});
}
/// <summary>
/// Steers (injects a message into) an agent's active session.
/// Used by operators to redirect an agent's task mid-execution.
/// </summary>
/// <param name="agentId">The agent identifier to steer.</param>
/// <param name="request">The steering message to inject.</param>
/// <returns>Confirmation of the steer command.</returns>
/// <response code="200">Steer command sent successfully.</response>
/// <response code="400">Missing or empty message.</response>
[HttpPost("steer/{agentId}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
public IActionResult SteerAgent(string agentId, [FromBody] SteerRequest request)
{
if (string.IsNullOrWhiteSpace(request.Message))
{
return BadRequest(new { error = "Message is required" });
}
_logger.LogInformation("Steer command received for agent {AgentId}: {Message}",
agentId, request.Message.Length > 100
? request.Message[..100] + "..." : request.Message);
// TODO: Forward to Gateway via bridge service
// await _bridgeService.SendRpcAsync("sessions.steer", new { sessionKey = ..., message = request.Message });
return Ok(new
{
agentId,
command = "steer",
message = request.Message,
status = "sent",
timestamp = DateTime.UtcNow.ToString("o")
});
}
}
/// <summary>
/// Request body for the steer command.
/// </summary>
/// <param name="Message">The message to inject into the agent's session.</param>
public record SteerRequest(string Message);

View File

@@ -0,0 +1,87 @@
using Microsoft.AspNetCore.Mvc;
namespace ControlCenter.Controllers;
/// <summary>
/// REST API for querying agent session logs.
/// Provides historical message and tool call logs for a specific agent.
///
/// <para>API contract for Rex (Frontend):</para>
/// <list type="bullet">
/// <item><c>GET /api/logs/{agentId}</c> — Returns recent logs for an agent</item>
/// <item><c>GET /api/logs/{agentId}/tools</c> — Returns recent tool calls for an agent</item>
/// </list>
///
/// <para>Log data is sourced from the OpenClaw Gateway's transcript files.
/// The Gateway's <c>logs.tail</c> RPC provides the raw data, and this
/// controller formats it for the frontend.</para>
/// </summary>
[ApiController]
[Route("api/[controller]")]
public class LogsController : ControllerBase
{
private readonly ILogger<LogsController> _logger;
public LogsController(ILogger<LogsController> logger)
{
_logger = logger;
}
/// <summary>
/// Gets recent session logs for a specific agent.
/// Returns the last N messages from the agent's active session transcript.
/// </summary>
/// <param name="agentId">The agent identifier, e.g. "otto", "dex".</param>
/// <param name="limit">Maximum number of log entries to return (default: 50, max: 200).</param>
/// <returns>An array of log entries for the agent.</returns>
/// <response code="200">Returns the agent's recent logs.</response>
/// <response code="404">No active session found for the agent.</response>
[HttpGet("{agentId}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status404NotFound)]
public IActionResult GetLogs(string agentId, [FromQuery] int limit = 50)
{
limit = Math.Clamp(limit, 1, 200);
_logger.LogDebug("Logs requested for agent {AgentId}, limit {Limit}", agentId, limit);
// TODO: Implement log retrieval by calling the Gateway's logs.tail RPC
// or reading transcript files. For now, return an empty array as the
// bridge service will provide this data when fully integrated.
return Ok(new
{
agentId,
logs = Array.Empty<object>(),
count = 0,
hasMore = false
});
}
/// <summary>
/// Gets recent tool call logs for a specific agent.
/// Returns the last N tool invocations from the agent's session.
/// </summary>
/// <param name="agentId">The agent identifier.</param>
/// <param name="limit">Maximum number of tool entries to return (default: 20, max: 100).</param>
/// <returns>An array of tool call entries for the agent.</returns>
/// <response code="200">Returns the agent's recent tool calls.</response>
/// <response code="404">No active session found for the agent.</response>
[HttpGet("{agentId}/tools")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status404NotFound)]
public IActionResult GetToolLogs(string agentId, [FromQuery] int limit = 20)
{
limit = Math.Clamp(limit, 1, 100);
_logger.LogDebug("Tool logs requested for agent {AgentId}, limit {Limit}", agentId, limit);
// TODO: Implement tool log retrieval. Return empty for now.
return Ok(new
{
agentId,
tools = Array.Empty<object>(),
count = 0,
hasMore = false
});
}
}

View File

@@ -0,0 +1,211 @@
using Microsoft.AspNetCore.SignalR;
namespace ControlCenter.Hubs;
/// <summary>
/// SignalR hub for real-time agent status updates in the Command Hub.
///
/// <para>Usage flow:</para>
/// <list type="number">
/// <item>Client connects to <c>/hubs/agent-status</c></item>
/// <item>Client calls <see cref="JoinFleet"/> to subscribe to all agent updates</item>
/// <item>Client calls <see cref="JoinAgentGroup"/> to subscribe to a specific agent</item>
/// <item>Server pushes <see cref="IAgentStatusClient.AgentStatusChanged"/>
/// and <see cref="IAgentStatusClient.AgentTaskProgress"/> events</item>
/// <item>Client calls <see cref="GetFleetSnapshot"/> for initial state on connect</item>
/// </list>
///
/// <para>Group naming:</para>
/// <list type="bullet">
/// <item>Fleet group: <c>fleet</c> — receives all agent updates</item>
/// <item>Agent group: <c>agent:{agentId}</c> — receives updates for one agent</item>
/// </list>
///
/// <para>Typed client: <see cref="IAgentStatusClient"/> — all server-to-client
/// calls go through this interface for compile-time safety.</para>
///
/// <para>Architecture note: This hub bridges OpenClaw Gateway WebSocket events
/// to SignalR clients. A background service (<see cref="Services.GatewayEventBridgeService"/>)
/// subscribes to Gateway events and pushes them through this hub's extension methods.</para>
/// </summary>
public class AgentStatusHub : Hub<IAgentStatusClient>
{
private readonly ILogger<AgentStatusHub> _logger;
public AgentStatusHub(ILogger<AgentStatusHub> logger)
{
_logger = logger;
}
/// <summary>
/// Broadcasts an agent status update to all connected clients.
///
/// <para>
/// Any connected client (or server-side caller) can invoke this method
/// to push a status update to every subscriber. The DTO is converted to
/// an <see cref="AgentStatusUpdate"/> record and relayed through the
/// <see cref="IAgentStatusClient.AgentStatusChanged"/> callback.
/// </para>
/// </summary>
/// <param name="update">The agent status update DTO to broadcast.</param>
public async Task SendStatusUpdate(AgentStatusUpdateDto update)
{
_logger.LogInformation(
"Broadcasting status update for agent {AgentId}: {Status}",
update.AgentId, update.Status);
var agentUpdate = update.ToUpdate();
// Broadcast to all connected clients
await Clients.All.AgentStatusChanged(agentUpdate);
// Also push to the specific agent's group
var agentGroup = AgentGroupName(update.AgentId);
await Clients.Group(agentGroup).AgentStatusChanged(agentUpdate);
}
/// <summary>
/// Adds the calling connection to the fleet group.
/// Once joined, the client will receive all agent status changes
/// and task progress updates across the entire fleet.
/// </summary>
public async Task JoinFleet()
{
await Groups.AddToGroupAsync(Context.ConnectionId, FleetGroupName);
_logger.LogDebug("Connection {ConnectionId} joined fleet group", Context.ConnectionId);
}
/// <summary>
/// Removes the calling connection from the fleet group.
/// </summary>
public async Task LeaveFleet()
{
await Groups.RemoveFromGroupAsync(Context.ConnectionId, FleetGroupName);
_logger.LogDebug("Connection {ConnectionId} left fleet group", Context.ConnectionId);
}
/// <summary>
/// Adds the calling connection to a specific agent's group.
/// Once joined, the client will receive updates only for that agent.
/// </summary>
/// <param name="agentId">The agent identifier, e.g. "otto", "dex".</param>
/// <exception cref="HubException">Thrown if agentId is null or empty.</exception>
public async Task JoinAgentGroup(string agentId)
{
if (string.IsNullOrWhiteSpace(agentId))
throw new HubException("agentId is required");
var groupName = AgentGroupName(agentId);
await Groups.AddToGroupAsync(Context.ConnectionId, groupName);
_logger.LogDebug("Connection {ConnectionId} joined agent group {GroupName}",
Context.ConnectionId, groupName);
}
/// <summary>
/// Removes the calling connection from a specific agent's group.
/// </summary>
/// <param name="agentId">The agent identifier.</param>
public async Task LeaveAgentGroup(string agentId)
{
if (string.IsNullOrWhiteSpace(agentId)) return;
var groupName = AgentGroupName(agentId);
await Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName);
}
/// <summary>
/// Returns a snapshot of the current fleet state.
/// Called by clients on initial connection to get the full picture
/// before incremental updates begin arriving.
/// </summary>
/// <returns>An array of <see cref="AgentCardData"/> representing all known agents.</returns>
public Task<AgentCardData[]> GetFleetSnapshot()
{
// The fleet state is managed by the GatewayEventBridgeService.
// For now, return an empty array — the bridge service will push
// updates as they arrive from the Gateway.
_logger.LogDebug("Fleet snapshot requested by {ConnectionId}", Context.ConnectionId);
return Task.FromResult(Array.Empty<AgentCardData>());
}
/// <summary>
/// Overrides <see cref="Hub.OnDisconnectedAsync"/> to perform cleanup.
/// SignalR automatically removes disconnected connections from all groups.
/// </summary>
/// <param name="exception">Exception that caused the disconnection, if any.</param>
public override Task OnDisconnectedAsync(Exception? exception)
{
_logger.LogDebug("Connection {ConnectionId} disconnected", Context.ConnectionId);
return base.OnDisconnectedAsync(exception);
}
/// <summary>
/// The SignalR group name for the entire fleet (all agents).
/// </summary>
internal const string FleetGroupName = "fleet";
/// <summary>
/// Returns the SignalR group name for a specific agent.
/// Format: <c>agent:{agentId}</c> (lowercase for consistency).
/// </summary>
/// <param name="agentId">The agent identifier.</param>
internal static string AgentGroupName(string agentId) =>
$"agent:{agentId.ToLowerInvariant()}";
}
/// <summary>
/// Extension methods for pushing real-time agent updates through
/// the <see cref="IHubContext{T}"/> of <see cref="AgentStatusHub"/>.
///
/// <para>These methods are intended to be called from background services
/// (e.g., <see cref="Services.GatewayEventBridgeService"/>) or other
/// server-side code that detects an agent state change.</para>
/// </summary>
public static class AgentStatusHubExtensions
{
/// <summary>
/// Pushes an agent status change to all clients subscribed to
/// the fleet group and the specific agent's group.
///
/// <para>Call this from any background service when an agent's
/// operational status changes (e.g., the Gateway reports a
/// session transition from "running" to "done").</para>
/// </summary>
/// <param name="hubContext">The hub context injected via DI.</param>
/// <param name="update">The agent status update payload.</param>
/// <returns>A Task that completes when the message has been sent to all group members.</returns>
public static async Task PushAgentStatusAsync(
this IHubContext<AgentStatusHub, IAgentStatusClient> hubContext,
AgentStatusUpdate update)
{
// Broadcast to the fleet group (all subscribers)
await hubContext.Clients.Group(AgentStatusHub.FleetGroupName)
.AgentStatusChanged(update);
// Also push to the specific agent's group
var agentGroup = AgentStatusHub.AgentGroupName(update.AgentId);
await hubContext.Clients.Group(agentGroup)
.AgentStatusChanged(update);
}
/// <summary>
/// Pushes a task progress update to all clients subscribed to
/// the fleet group and the specific agent's group.
/// </summary>
/// <param name="hubContext">The hub context injected via DI.</param>
/// <param name="progress">The task progress update payload.</param>
/// <returns>A Task that completes when the message has been sent to all group members.</returns>
public static async Task PushTaskProgressAsync(
this IHubContext<AgentStatusHub, IAgentStatusClient> hubContext,
TaskProgressUpdate progress)
{
// Broadcast to the fleet group
await hubContext.Clients.Group(AgentStatusHub.FleetGroupName)
.AgentTaskProgress(progress);
// Also push to the specific agent's group
var agentGroup = AgentStatusHub.AgentGroupName(progress.AgentId);
await hubContext.Clients.Group(agentGroup)
.AgentTaskProgress(progress);
}
}

View File

@@ -0,0 +1,30 @@
namespace ControlCenter.Hubs;
/// <summary>
/// Strongly-typed client interface for the AgentStatus SignalR hub.
/// Defines the methods the server can invoke on connected clients
/// to push real-time agent status and task progress updates.
///
/// <para>All server-to-client calls go through this interface for
/// compile-time safety — matching the pattern used by the
/// Extrudex PrinterHub.</para>
/// </summary>
public interface IAgentStatusClient
{
/// <summary>
/// Pushes an agent status change to all subscribed clients.
/// Fired whenever an agent's operational status changes
/// (e.g., idle → active, active → thinking, active → error).
/// </summary>
/// <param name="update">The full status update payload.</param>
/// <returns>A Task that completes when the client has processed the update.</returns>
Task AgentStatusChanged(AgentStatusUpdate update);
/// <summary>
/// Pushes a task progress update to all subscribed clients.
/// Fired when an agent reports progress on its current task.
/// </summary>
/// <param name="progress">The task progress update payload.</param>
/// <returns>A Task that completes when the client has processed the update.</returns>
Task AgentTaskProgress(TaskProgressUpdate progress);
}

View File

@@ -0,0 +1,166 @@
namespace ControlCenter;
/// <summary>
/// Agent operational status derived from OpenClaw Gateway session activity.
/// Maps to the frontend AgentStatus type: 'active' | 'idle' | 'thinking' | 'error'.
/// </summary>
public enum AgentStatus
{
/// <summary>Agent is currently processing a turn.</summary>
Active,
/// <summary>Agent completed its last turn; no active work.</summary>
Idle,
/// <summary>LLM call in flight; tokens streaming.</summary>
Thinking,
/// <summary>Agent encountered an unhandled error.</summary>
Error
}
/// <summary>
/// Extended lifecycle status including offline — not all agents have active sessions.
/// Used internally; clients only see <see cref="AgentStatus"/> (offline maps to idle).
/// </summary>
public enum AgentLifecycleStatus
{
Active,
Idle,
Thinking,
Error,
Offline
}
/// <summary>
/// Pushed to SignalR clients when an agent's status changes.
/// Matches the TypeScript <c>AgentStatusUpdate</c> interface from the design spec.
/// </summary>
/// <param name="AgentId">Agent identifier, e.g. "otto", "dex".</param>
/// <param name="DisplayName">Human-readable name, e.g. "Otto".</param>
/// <param name="Role">Role description, e.g. "Orchestrator Agent".</param>
/// <param name="Status">Current operational status.</param>
/// <param name="CurrentTask">Description of the current task, if any.</param>
/// <param name="SessionKey">Full session key, e.g. "agent:otto:telegram:direct:8787451565".</param>
/// <param name="Channel">Channel the agent is operating on, e.g. "telegram".</param>
/// <param name="LastActivity">ISO 8601 timestamp of last activity.</param>
/// <param name="ErrorMessage">Error message when status is 'error'.</param>
public record AgentStatusUpdate(
string AgentId,
string DisplayName,
string Role,
string Status,
string? CurrentTask,
string SessionKey,
string Channel,
string LastActivity,
string? ErrorMessage = null
);
/// <summary>
/// Pushed to SignalR clients when an agent's task progress updates.
/// Matches the TypeScript <c>TaskProgressUpdate</c> interface from the design spec.
/// </summary>
/// <param name="AgentId">Agent identifier.</param>
/// <param name="TaskDescription">Description of the current task.</param>
/// <param name="Progress">Task progress percentage (0100), if trackable.</param>
/// <param name="Elapsed">Elapsed time string, e.g. "04m 12s".</param>
public record TaskProgressUpdate(
string AgentId,
string TaskDescription,
int? Progress,
string? Elapsed
);
/// <summary>
/// Data transfer object for broadcasting agent status updates
/// to all connected SignalR clients via the hub's SendStatusUpdate method.
///
/// <para>This DTO provides a mutable, serialization-friendly alternative to
/// <see cref="AgentStatusUpdate"/> for callers that construct updates
/// from external data sources (e.g., HTTP API payloads).</para>
/// </summary>
public class AgentStatusUpdateDto
{
/// <summary>
/// Agent identifier, e.g. "otto", "dex", "rex".
/// </summary>
public string AgentId { get; set; } = string.Empty;
/// <summary>
/// Human-readable display name, e.g. "Otto", "Dex".
/// </summary>
public string DisplayName { get; set; } = string.Empty;
/// <summary>
/// Role description, e.g. "Orchestrator Agent", "Backend Specialist".
/// </summary>
public string Role { get; set; } = string.Empty;
/// <summary>
/// Current operational status of the agent as lowercase string:
/// "active", "idle", "thinking", "error".
/// </summary>
public string Status { get; set; } = string.Empty;
/// <summary>
/// Description of the agent's current task, if any.
/// </summary>
public string? CurrentTask { get; set; }
/// <summary>
/// Full session key, e.g. "agent:otto:telegram:direct:8787451565".
/// </summary>
public string SessionKey { get; set; } = string.Empty;
/// <summary>
/// Communication channel, e.g. "telegram", "discord", "slack".
/// </summary>
public string Channel { get; set; } = string.Empty;
/// <summary>
/// ISO 8601 timestamp of the agent's last activity.
/// </summary>
public string LastActivity { get; set; } = string.Empty;
/// <summary>
/// Error message when the agent status is "error".
/// </summary>
public string? ErrorMessage { get; set; }
/// <summary>
/// Converts this DTO to an immutable <see cref="AgentStatusUpdate"/> record
/// for use with the typed SignalR client interface.
/// </summary>
/// <returns>An <see cref="AgentStatusUpdate"/> with equivalent field values.</returns>
public AgentStatusUpdate ToUpdate() => new(
AgentId,
DisplayName,
Role,
Status,
CurrentTask,
SessionKey,
Channel,
LastActivity,
ErrorMessage
);
}
/// <summary>
/// Snapshot of an agent's full card data, sent on initial connection
/// or when the fleet state is requested.
/// Matches the TypeScript <c>AgentCardData</c> interface from the design spec.
/// </summary>
public record AgentCardData(
string Id,
string DisplayName,
string Role,
string Status,
string? CurrentTask,
int? TaskProgress,
string? TaskElapsed,
string SessionKey,
string Channel,
string LastActivity,
string? ErrorMessage
);

View File

@@ -0,0 +1,72 @@
namespace ControlCenter.Models;
/// <summary>
/// Defines which side of the Control Center dashboard a minion occupies.
/// </summary>
public enum MinionSide
{
/// <summary>Development side — Rex, Dex, Hex.</summary>
Dev,
/// <summary>Business side — Larry, Mel, Buzz.</summary>
Business
}
/// <summary>
/// Visual state of a minion sprite, derived from the agent's
/// <see cref="AgentStatus"/>. Maps Active/Idle/Thinking/Error
/// to frontend animation states.
/// </summary>
public enum MinionState
{
/// <summary>Agent is actively processing — minion shows working animation.</summary>
Active,
/// <summary>Agent is idle — minion shows idle/patrolling animation.</summary>
Idle,
/// <summary>Agent is thinking (LLM call in flight) — minion shows thinking animation.</summary>
Thinking,
/// <summary>Agent encountered an error — minion shows error/distress animation.</summary>
Error
}
/// <summary>
/// Static mapping entry that associates an agent ID with a minion's
/// display side and position index within that side.
///
/// <para>Position indices are zero-based within each side. The dev side
/// has Rex at 0, Dex at 1, and Hex at 2. The business side has
/// Larry at 0, Mel at 1, and Buzz at 2.</para>
/// </summary>
/// <param name="AgentId">Agent identifier, e.g. "rex", "dex".</param>
/// <param name="Side">Which side of the dashboard the minion occupies.</param>
/// <param name="PositionIndex">Zero-based position index within the side.</param>
/// <param name="DisplayName">Human-readable name, e.g. "Rex".</param>
public record AgentMinionMapping(
string AgentId,
MinionSide Side,
int PositionIndex,
string DisplayName
);
/// <summary>
/// Real-time minion state update pushed to SignalR clients
/// when an agent's status changes. Combines the static mapping
/// (who/where) with the dynamic state (what the minion is doing).
/// </summary>
/// <param name="AgentId">Agent identifier, e.g. "rex".</param>
/// <param name="DisplayName">Human-readable minion name, e.g. "Rex".</param>
/// <param name="Side">Which side of the dashboard — Dev or Business.</param>
/// <param name="PositionIndex">Position within the side (0-based).</param>
/// <param name="State">Current minion animation state.</param>
/// <param name="Timestamp">ISO 8601 timestamp of the state change.</param>
public record MinionStateUpdate(
string AgentId,
string DisplayName,
MinionSide Side,
int PositionIndex,
MinionState State,
string Timestamp
);

View File

@@ -0,0 +1,77 @@
using System.Reflection;
using ControlCenter.Hubs;
using ControlCenter.Services;
var builder = WebApplication.CreateBuilder(args);
// ── API Services ───────────────────────────────────────────
builder.Services.AddControllers();
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen(c =>
{
c.SwaggerDoc("v1", new()
{
Title = "Control Center API",
Version = "v1",
Description = "OpenClaw Control Center — Command Hub backend with SignalR real-time updates"
});
// Include XML doc comments in Swagger output
var xmlFile = $"{Assembly.GetExecutingAssembly().GetName().Name}.xml";
var xmlPath = Path.Combine(AppContext.BaseDirectory, xmlFile);
if (File.Exists(xmlPath))
{
c.IncludeXmlComments(xmlPath);
}
});
// ── CORS (kiosk + remote browser) ─────────────────────────
// The Control Center frontend runs on a different origin than the backend.
// SignalR requires credentials for WebSocket transport, so we use
// specific origins rather than AllowAnyOrigin.
var corsOrigins = builder.Configuration.GetSection("Cors:AllowedOrigins")
.Get<string[]>() ?? new[] { "http://localhost:4200", "http://localhost:5000" };
builder.Services.AddCors(options =>
{
options.AddDefaultPolicy(policy =>
{
policy.WithOrigins(corsOrigins)
.AllowAnyMethod()
.AllowAnyHeader()
.AllowCredentials(); // Required for SignalR WebSocket
});
});
// ── SignalR (real-time agent status updates) ───────────────
builder.Services.AddSignalR();
// ── Gateway Bridge Service ────────────────────────────────
// Background service that connects to the OpenClaw Gateway WebSocket
// and bridges events to the AgentStatus SignalR hub.
builder.Services.AddSingleton<GatewayEventBridgeService>();
builder.Services.AddHostedService(sp => sp.GetRequiredService<GatewayEventBridgeService>());
// ── Agent-Minion Mapper Service ────────────────────────────
// Maps agents to minion sprites/positions and publishes state
// updates through SignalR.
builder.Services.AddSingleton<AgentMinionMapperService>();
var app = builder.Build();
// ── Middleware ──────────────────────────────────────────────
if (app.Environment.IsDevelopment())
{
app.UseSwagger();
app.UseSwaggerUI();
}
app.UseCors();
app.UseAuthorization();
app.MapControllers();
// ── Hub Endpoints ───────────────────────────────────────────
// Agent status hub at /hubs/agent-status (matches the design spec)
app.MapHub<AgentStatusHub>("/hubs/agent-status");
app.Run();

View File

@@ -0,0 +1,14 @@
{
"$schema": "https://json.schemastore.org/launchsettings.json",
"profiles": {
"http": {
"commandName": "Project",
"dotnetRunMessages": true,
"launchBrowser": false,
"applicationUrl": "http://localhost:5053",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
}
}
}

View File

@@ -0,0 +1,193 @@
using ControlCenter.Hubs;
using ControlCenter.Models;
using Microsoft.AspNetCore.SignalR;
namespace ControlCenter.Services;
/// <summary>
/// Service that maps Linear agents to minion sprites and positions
/// in the Control Center dashboard.
///
/// <para>Static mappings define where each minion appears:</para>
/// <list type="bullet">
/// <item>Dev side: Rex (0), Dex (1), Hex (2)</item>
/// <item>Business side: Larry (0), Mel (1), Buzz (2)</item>
/// </list>
///
/// <para>Dynamic state is derived from the agent's <see cref="AgentStatus"/>:</para>
/// <list type="bullet">
/// <item><c>Active</c> → <see cref="MinionState.Active"/></item>
/// <item><c>Idle</c> → <see cref="MinionState.Idle"/></item>
/// <item><c>Thinking</c> → <see cref="MinionState.Thinking"/></item>
/// <item><c>Error</c> → <see cref="MinionState.Error"/></item>
/// </list>
///
/// <para>State updates are published through the <see cref="AgentStatusHub"/>
/// SignalR hub so that connected clients can animate minion sprites
/// in real time.</para>
/// </summary>
public class AgentMinionMapperService
{
private readonly ILogger<AgentMinionMapperService> _logger;
private readonly IHubContext<AgentStatusHub, IAgentStatusClient> _hubContext;
/// <summary>
/// Static agent-to-minion mapping table. Defines which side and position
/// each agent's minion occupies on the dashboard.
/// </summary>
private static readonly Dictionary<string, AgentMinionMapping> Mappings = new()
{
// ── Dev Side ──────────────────────────────────
["rex"] = new AgentMinionMapping("rex", MinionSide.Dev, 0, "Rex"),
["dex"] = new AgentMinionMapping("dex", MinionSide.Dev, 1, "Dex"),
["hex"] = new AgentMinionMapping("hex", MinionSide.Dev, 2, "Hex"),
// ── Business Side ─────────────────────────────
["larry"] = new AgentMinionMapping("larry", MinionSide.Business, 0, "Larry"),
["mel"] = new AgentMinionMapping("mel", MinionSide.Business, 1, "Mel"),
["buzz"] = new AgentMinionMapping("buzz", MinionSide.Business, 2, "Buzz"),
};
/// <summary>
/// Maps <see cref="AgentStatus"/> string values to <see cref="MinionState"/>.
/// </summary>
private static readonly Dictionary<string, MinionState> StatusToMinionState = new()
{
["active"] = MinionState.Active,
["idle"] = MinionState.Idle,
["thinking"] = MinionState.Thinking,
["error"] = MinionState.Error,
};
public AgentMinionMapperService(
ILogger<AgentMinionMapperService> logger,
IHubContext<AgentStatusHub, IAgentStatusClient> hubContext)
{
_logger = logger;
_hubContext = hubContext;
}
/// <summary>
/// Gets the minion mapping for a given agent ID.
/// Returns null if the agent is not mapped to a minion position.
/// </summary>
/// <param name="agentId">The agent identifier, e.g. "rex", "dex".</param>
/// <returns>The mapping record, or null if unmapped.</returns>
public AgentMinionMapping? GetMapping(string agentId)
{
return Mappings.GetValueOrDefault(agentId?.ToLowerInvariant() ?? string.Empty);
}
/// <summary>
/// Gets all minion mappings, ordered by side then position index.
/// </summary>
/// <returns>All mappings, sorted for consistent display order.</returns>
public IReadOnlyList<AgentMinionMapping> GetAllMappings()
{
return Mappings.Values
.OrderBy(m => m.Side)
.ThenBy(m => m.PositionIndex)
.ToList();
}
/// <summary>
/// Converts an agent status string to a <see cref="MinionState"/>.
/// Falls back to <see cref="MinionState.Idle"/> for unrecognized statuses.
/// </summary>
/// <param name="status">Agent status string: "active", "idle", "thinking", or "error".</param>
/// <returns>The corresponding minion state.</returns>
public MinionState StatusToState(string status)
{
return StatusToMinionState.GetValueOrDefault(
status?.ToLowerInvariant() ?? string.Empty,
MinionState.Idle);
}
/// <summary>
/// Publishes a minion state update through SignalR when an agent's
/// status changes. Only publishes for agents that have a minion mapping.
///
/// <para>This is the primary integration point: the
/// <see cref="GatewayEventBridgeService"/> calls this method
/// whenever it detects a status change from the OpenClaw Gateway.</para>
/// </summary>
/// <param name="agentId">The agent whose status changed, e.g. "dex".</param>
/// <param name="status">The new status string: "active", "idle", "thinking", or "error".</param>
/// <returns>A task that completes when the SignalR message has been sent.</returns>
public async Task PublishMinionStateUpdateAsync(string agentId, string status)
{
var mapping = GetMapping(agentId);
if (mapping is null)
{
_logger.LogDebug("No minion mapping for agent {AgentId}; skipping state update", agentId);
return;
}
var minionState = StatusToState(status);
var update = new MinionStateUpdate(
AgentId: mapping.AgentId,
DisplayName: mapping.DisplayName,
Side: mapping.Side,
PositionIndex: mapping.PositionIndex,
State: minionState,
Timestamp: DateTime.UtcNow.ToString("o")
);
// Broadcast to the fleet group (all subscribers)
await _hubContext.Clients.Group(AgentStatusHub.FleetGroupName)
.AgentStatusChanged(ToAgentStatusUpdate(agentId, status));
// Also push to the specific agent's group
var agentGroup = AgentStatusHub.AgentGroupName(agentId);
await _hubContext.Clients.Group(agentGroup)
.AgentStatusChanged(ToAgentStatusUpdate(agentId, status));
_logger.LogInformation(
"Minion state update: {AgentId} → {State} (Side: {Side}, Position: {Index})",
agentId, minionState, mapping.Side, mapping.PositionIndex);
}
/// <summary>
/// Gets the current minion state for all mapped agents, suitable
/// for building an initial fleet snapshot.
/// </summary>
/// <returns>All minion mappings with their current (idle) state.</returns>
public IReadOnlyList<MinionStateUpdate> GetFullMinionState()
{
return Mappings.Values
.OrderBy(m => m.Side)
.ThenBy(m => m.PositionIndex)
.Select(m => new MinionStateUpdate(
AgentId: m.AgentId,
DisplayName: m.DisplayName,
Side: m.Side,
PositionIndex: m.PositionIndex,
State: MinionState.Idle,
Timestamp: DateTime.UtcNow.ToString("o")))
.ToList();
}
/// <summary>
/// Converts a status string to an <see cref="AgentStatusUpdate"/>
/// for SignalR push. Uses the mapping table for display names and roles.
/// </summary>
private AgentStatusUpdate ToAgentStatusUpdate(string agentId, string status)
{
var mapping = GetMapping(agentId);
var displayName = mapping?.DisplayName ?? char.ToUpperInvariant(agentId[0]) + agentId[1..];
return new AgentStatusUpdate(
AgentId: agentId,
DisplayName: displayName,
Role: mapping is not null
? $"{mapping.Side} Agent"
: "Agent",
Status: status,
CurrentTask: null,
SessionKey: string.Empty,
Channel: string.Empty,
LastActivity: DateTime.UtcNow.ToString("o"),
ErrorMessage: status == "error" ? "Agent encountered an error" : null
);
}
}

View File

@@ -0,0 +1,523 @@
using System.Collections.Concurrent;
using System.Net.WebSockets;
using System.Text;
using System.Text.Json;
using ControlCenter.Hubs;
using Microsoft.AspNetCore.SignalR;
namespace ControlCenter.Services;
/// <summary>
/// Background service that connects to the OpenClaw Gateway WebSocket
/// and bridges Gateway events to the <see cref="Hubs.AgentStatusHub"/>.
///
/// <para>Architecture:</para>
/// <list type="number">
/// <item>Connects to the Gateway WS endpoint (configurable via appsettings)</item>
/// <item>Handles the v3 protocol handshake (challenge → connect → hello-ok)</item>
/// <item>Subscribes to <c>sessions.changed</c> and related events</item>
/// <item>Translates session state changes into <see cref="AgentStatusUpdate"/>
/// and <see cref="TaskProgressUpdate"/> objects</item>
/// <item>Pushes updates through the <see cref="Hubs.AgentStatusHub"/> SignalR hub</item>
/// </list>
///
/// <para>This is the server-side bridge that allows Angular clients to
/// receive real-time updates via SignalR instead of connecting directly
/// to the Gateway WebSocket.</para>
/// </summary>
public class GatewayEventBridgeService : BackgroundService
{
private readonly ILogger<GatewayEventBridgeService> _logger;
private readonly IHubContext<Hubs.AgentStatusHub, Hubs.IAgentStatusClient> _hubContext;
private readonly IConfiguration _configuration;
/// <summary>
/// In-memory fleet state — maps agent IDs to their latest card data.
/// Updated on every <c>sessions.changed</c> event from the Gateway.
/// </summary>
private readonly ConcurrentDictionary<string, AgentCardData> _fleetState = new();
/// <summary>
/// Known agent roles for display in the Command Hub.
/// Maps agent IDs to their functional descriptions.
/// </summary>
private static readonly Dictionary<string, string> AgentRoles = new()
{
["main"] = "Primary Assistant",
["otto"] = "Orchestrator Agent",
["dave"] = "Network Admin Agent",
["bob"] = "Content Writer Agent",
["stuart"] = "Image & Creative Agent",
["phil"] = "Home Automation Agent",
["carl"] = "Security Agent",
["larry"] = "Business Agent",
["mel"] = "E-Commerce Agent",
["norbert"] = "Product Agent",
["jerry"] = "Market Research Agent",
["rex"] = "Frontend Dev Agent",
["dex"] = "Backend Dev Agent",
["hex"] = "Database Agent",
["pip"] = "Raspberry Pi Agent",
["nano"] = "ESP32/Firmware Agent",
["axiom"] = "Utility Agent",
["bonnie"] = "Music Agent",
["sketch"] = "UI/UX Design Agent",
["flip"] = "Mobile Dev Agent",
["buzz"] = "SEO Agent",
["aries"] = "Companion Agent"
};
/// <summary>
/// Maps OpenClaw session status to <see cref="AgentStatus"/>.
/// </summary>
private static string MapSessionStatus(string? sessionStatus) => sessionStatus switch
{
"running" => "active",
"streaming" => "thinking",
"error" or "aborted" => "error",
"done" => "idle",
_ => "idle"
};
public GatewayEventBridgeService(
ILogger<GatewayEventBridgeService> logger,
IHubContext<Hubs.AgentStatusHub, Hubs.IAgentStatusClient> hubContext,
IConfiguration configuration)
{
_logger = logger;
_hubContext = hubContext;
_configuration = configuration;
}
/// <summary>
/// Returns the current fleet state snapshot.
/// Used by the hub's <c>GetFleetSnapshot</c> method and by the
/// <c>AgentsController</c> REST endpoint.
/// </summary>
public AgentCardData[] GetFleetSnapshot() =>
_fleetState.Values.ToArray();
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
_logger.LogInformation("Gateway Event Bridge service starting");
while (!stoppingToken.IsCancellationRequested)
{
try
{
await ConnectAndListenAsync(stoppingToken);
}
catch (OperationCanceledException) when (stoppingToken.IsCancellationRequested)
{
_logger.LogInformation("Gateway Event Bridge service stopping");
break;
}
catch (Exception ex)
{
_logger.LogError(ex, "Gateway connection lost, reconnecting in 5 seconds...");
await Task.Delay(TimeSpan.FromSeconds(5), stoppingToken);
}
}
}
/// <summary>
/// Connects to the OpenClaw Gateway WebSocket and processes events
/// until the connection is lost or cancellation is requested.
/// </summary>
private async Task ConnectAndListenAsync(CancellationToken stoppingToken)
{
var gatewayUrl = _configuration["Gateway:WebSocketUrl"]
?? "ws://localhost:3271/ws";
var authToken = _configuration["Gateway:AuthToken"] ?? string.Empty;
_logger.LogInformation("Connecting to Gateway at {Url}", gatewayUrl);
using var ws = new ClientWebSocket();
// Set auth header if available
if (!string.IsNullOrEmpty(authToken))
{
ws.Options.SetRequestHeader("Authorization", $"Bearer {authToken}");
}
await ws.ConnectAsync(new Uri(gatewayUrl), stoppingToken);
_logger.LogInformation("Connected to Gateway WebSocket");
// Start receiving messages
await ReceiveMessagesAsync(ws, stoppingToken);
}
/// <summary>
/// Receives and processes WebSocket messages from the Gateway.
/// Handles the v3 protocol handshake and dispatches events.
/// </summary>
private async Task ReceiveMessagesAsync(ClientWebSocket ws, CancellationToken stoppingToken)
{
var buffer = new byte[8192];
var messageBuilder = new StringBuilder();
while (ws.State == WebSocketState.Open && !stoppingToken.IsCancellationRequested)
{
WebSocketReceiveResult result;
try
{
result = await ws.ReceiveAsync(buffer, stoppingToken);
}
catch (WebSocketException ex)
{
_logger.LogWarning(ex, "WebSocket receive error");
break;
}
if (result.MessageType == WebSocketMessageType.Close)
{
_logger.LogInformation("Gateway WebSocket closed by server");
break;
}
messageBuilder.Append(Encoding.UTF8.GetString(buffer, 0, result.Count));
if (result.EndOfMessage)
{
var message = messageBuilder.ToString();
messageBuilder.Clear();
await ProcessMessageAsync(ws, message, stoppingToken);
}
}
}
/// <summary>
/// Processes a single WebSocket message from the Gateway.
/// Routes based on the message type: event, response, or challenge.
/// </summary>
private async Task ProcessMessageAsync(
ClientWebSocket ws, string message, CancellationToken stoppingToken)
{
try
{
using var doc = JsonDocument.Parse(message);
var root = doc.RootElement;
var type = root.GetProperty("type").GetString();
switch (type)
{
case "event":
await HandleGatewayEventAsync(root);
break;
case "res":
HandleGatewayResponse(root);
break;
}
// Special handling for connect.challenge events
if (root.TryGetProperty("event", out var eventName) &&
eventName.GetString() == "connect.challenge")
{
await HandleConnectChallengeAsync(ws, root, stoppingToken);
}
}
catch (JsonException ex)
{
_logger.LogWarning(ex, "Failed to parse Gateway message: {Message}",
message.Length > 200 ? message[..200] + "..." : message);
}
}
/// <summary>
/// Handles the Gateway connect.challenge event by sending
/// a connect request with authentication credentials.
/// </summary>
private async Task HandleConnectChallengeAsync(
ClientWebSocket ws, JsonElement root, CancellationToken stoppingToken)
{
_logger.LogInformation("Received connect.challenge from Gateway");
var connectRequest = new
{
type = "req",
id = $"bridge-{Guid.NewGuid():N}",
method = "connect",
@params = new
{
minProtocol = 3,
maxProtocol = 3,
client = new
{
id = "control-center-backend",
version = "1.0.0",
platform = "server",
mode = "operator"
},
role = "operator",
scopes = new[] { "operator.read", "operator.write" },
auth = new
{
token = _configuration["Gateway:AuthToken"] ?? string.Empty
},
locale = "en-US",
userAgent = "control-center-backend/1.0.0"
}
};
var json = JsonSerializer.Serialize(connectRequest);
var bytes = Encoding.UTF8.GetBytes(json);
await ws.SendAsync(bytes, WebSocketMessageType.Text, true, stoppingToken);
}
/// <summary>
/// Handles a Gateway event message by dispatching to the
/// appropriate handler based on event name.
/// </summary>
private async Task HandleGatewayEventAsync(JsonElement root)
{
if (!root.TryGetProperty("event", out var eventProp)) return;
var eventName = eventProp.GetString();
_logger.LogDebug("Gateway event: {Event}", eventName);
switch (eventName)
{
case "sessions.changed":
await HandleSessionsChangedAsync(root);
break;
case "session.message":
HandleSessionMessage(root);
break;
case "session.tool":
HandleSessionTool(root);
break;
case "health":
HandleHealthEvent(root);
break;
}
}
/// <summary>
/// Handles a sessions.changed event from the Gateway.
/// Updates the fleet state and pushes status changes through SignalR.
/// </summary>
private async Task HandleSessionsChangedAsync(JsonElement root)
{
if (!root.TryGetProperty("payload", out var payload)) return;
// The payload may contain a snapshot of all sessions
if (payload.TryGetProperty("snapshot", out var snapshot) &&
snapshot.ValueKind == JsonValueKind.Array)
{
foreach (var session in snapshot.EnumerateArray())
{
var cardData = SessionToCardData(session);
if (cardData is null) continue;
_fleetState[cardData.Id] = cardData;
var update = new AgentStatusUpdate(
AgentId: cardData.Id,
DisplayName: cardData.DisplayName,
Role: cardData.Role,
Status: cardData.Status,
CurrentTask: cardData.CurrentTask,
SessionKey: cardData.SessionKey,
Channel: cardData.Channel,
LastActivity: cardData.LastActivity,
ErrorMessage: cardData.ErrorMessage
);
await _hubContext.PushAgentStatusAsync(update);
}
}
// Handle individual updates/added/removed
if (payload.TryGetProperty("updated", out var updated) &&
updated.ValueKind == JsonValueKind.Array)
{
foreach (var sessionKey in updated.EnumerateArray())
{
_logger.LogDebug("Session updated: {Key}", sessionKey.GetString());
}
}
}
/// <summary>
/// Handles a session.message event. Updates the agent's last activity
/// and pushes a status update if the status changed.
/// </summary>
private void HandleSessionMessage(JsonElement root)
{
if (!root.TryGetProperty("payload", out var payload)) return;
if (!payload.TryGetProperty("sessionKey", out var sessionKeyProp)) return;
var sessionKey = sessionKeyProp.GetString() ?? string.Empty;
var agentId = ExtractAgentId(sessionKey);
if (string.IsNullOrEmpty(agentId)) return;
// Update last activity timestamp
if (_fleetState.TryGetValue(agentId, out var existing))
{
_fleetState[agentId] = existing with
{
LastActivity = DateTime.UtcNow.ToString("o"),
Status = "active"
};
}
}
/// <summary>
/// Handles a session.tool event. Extracts tool progress information
/// and pushes a <see cref="TaskProgressUpdate"/> through SignalR.
/// </summary>
private void HandleSessionTool(JsonElement root)
{
if (!root.TryGetProperty("payload", out var payload)) return;
if (!payload.TryGetProperty("sessionKey", out var sessionKeyProp)) return;
var sessionKey = sessionKeyProp.GetString() ?? string.Empty;
var agentId = ExtractAgentId(sessionKey);
if (string.IsNullOrEmpty(agentId)) return;
var toolName = payload.TryGetProperty("toolName", out var tn) ? tn.GetString() : null;
var toolStatus = payload.TryGetProperty("status", out var ts) ? ts.GetString() : null;
if (toolName is null || toolStatus is null) return;
var progress = toolStatus switch
{
"started" => 0,
"completed" => 100,
_ => (int?)null
};
var update = new TaskProgressUpdate(
AgentId: agentId,
TaskDescription: $"{toolName} ({toolStatus})",
Progress: progress,
Elapsed: null
);
// Fire and forget — don't block the event loop
_ = _hubContext.PushTaskProgressAsync(update);
}
/// <summary>
/// Handles a health event from the Gateway.
/// Logs the health status for diagnostics.
/// </summary>
private void HandleHealthEvent(JsonElement root)
{
if (!root.TryGetProperty("payload", out var payload)) return;
var ok = payload.TryGetProperty("ok", out var okProp) && okProp.GetBoolean();
var status = payload.TryGetProperty("status", out var s) ? s.GetString() : "unknown";
_logger.LogInformation("Gateway health: ok={Ok}, status={Status}", ok, status);
}
/// <summary>
/// Handles a Gateway response message. Currently only logs for diagnostics.
/// </summary>
private void HandleGatewayResponse(JsonElement root)
{
if (root.TryGetProperty("ok", out var okProp) && okProp.GetBoolean())
{
_logger.LogDebug("Gateway RPC response OK");
// Check for hello-ok after connect
if (root.TryGetProperty("payload", out var payload) &&
payload.TryGetProperty("type", out var typeProp) &&
typeProp.GetString() == "hello-ok")
{
_logger.LogInformation("Gateway handshake complete (hello-ok received)");
}
}
else if (root.TryGetProperty("error", out var error))
{
var errorMsg = error.TryGetProperty("message", out var msg)
? msg.GetString() : "unknown error";
_logger.LogWarning("Gateway RPC error: {Error}", errorMsg);
}
}
/// <summary>
/// Converts a raw Gateway session JSON element into an
/// <see cref="AgentCardData"/> record.
/// </summary>
private AgentCardData? SessionToCardData(JsonElement session)
{
// Extract agent ID from session key or agentId field
string? agentId = null;
if (session.TryGetProperty("agentId", out var aid))
agentId = aid.GetString();
else if (session.TryGetProperty("key", out var key))
agentId = ExtractAgentId(key.GetString() ?? string.Empty);
if (string.IsNullOrEmpty(agentId)) return null;
var sessionKey = session.TryGetProperty("key", out var sk)
? sk.GetString() ?? string.Empty : string.Empty;
var status = session.TryGetProperty("status", out var s)
? MapSessionStatus(s.GetString()) : "idle";
var channel = ExtractChannel(session);
var lastActivity = session.TryGetProperty("updatedAt", out var ua)
? DateTimeOffset.FromUnixTimeMilliseconds(ua.GetInt64()).ToString("o")
: DateTime.UtcNow.ToString("o");
var displayName = char.ToUpperInvariant(agentId![0]) + agentId[1..];
var role = AgentRoles.GetValueOrDefault(agentId!, "Agent");
return new AgentCardData(
Id: agentId!,
DisplayName: displayName,
Role: role,
Status: status,
CurrentTask: null,
TaskProgress: null,
TaskElapsed: null,
SessionKey: sessionKey,
Channel: channel,
LastActivity: lastActivity,
ErrorMessage: status == "error" ? "Agent encountered an error" : null
);
}
/// <summary>
/// Extracts the agent ID from a session key.
/// Session key format: "agent:{agentId}:{channel}:..."
/// </summary>
private static string? ExtractAgentId(string sessionKey)
{
if (string.IsNullOrEmpty(sessionKey)) return null;
var parts = sessionKey.Split(':');
if (parts.Length >= 2 && parts[0] == "agent")
return parts[1];
return null;
}
/// <summary>
/// Extracts the channel from a session element.
/// </summary>
private static string ExtractChannel(JsonElement session)
{
// Try direct "channel" property
if (session.TryGetProperty("channel", out var ch))
return ch.GetString() ?? "unknown";
// Try origin.provider
if (session.TryGetProperty("origin", out var origin) &&
origin.TryGetProperty("provider", out var provider))
return provider.GetString() ?? "unknown";
return "unknown";
}
}

View File

@@ -0,0 +1,19 @@
{
"Logging": {
"LogLevel": {
"Default": "Debug",
"Microsoft.AspNetCore": "Information",
"ControlCenter": "Debug"
}
},
"Gateway": {
"WebSocketUrl": "ws://localhost:3271/ws",
"AuthToken": ""
},
"Cors": {
"AllowedOrigins": [
"http://localhost:4200",
"http://localhost:5000"
]
}
}

View File

@@ -0,0 +1,22 @@
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning",
"ControlCenter": "Debug"
}
},
"AllowedHosts": "*",
"Gateway": {
"WebSocketUrl": "ws://localhost:3271/ws",
"AuthToken": ""
},
"Cors": {
"AllowedOrigins": [
"http://localhost:4200",
"http://localhost:5000"
]
}
}

View File

@@ -0,0 +1,29 @@
using ControlCenter.Api.Configurations;
using ControlCenter.Api.Entities;
using Microsoft.EntityFrameworkCore;
namespace ControlCenter.Api.Data;
/// <summary>
/// EF Core DbContext for the Control Center database.
/// All table and column names use snake_case via explicit HasColumnName configuration.
/// </summary>
public class AppDbContext : DbContext
{
public AppDbContext(DbContextOptions<AppDbContext> options) : base(options) { }
public DbSet<Agent> Agents => Set<Agent>();
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
// Apply all entity type configurations from the Configurations namespace
modelBuilder.ApplyConfigurationsFromAssembly(typeof(AgentConfiguration).Assembly);
// Map the AgentStatus enum to a PostgreSQL enum type named "agent_status"
// This must be called after ApplyConfigurations to ensure the model is built
// before the enum mapping is applied.
modelBuilder.HasPostgresEnum<AgentStatus>();
base.OnModelCreating(modelBuilder);
}
}

View File

@@ -0,0 +1,27 @@
using Microsoft.EntityFrameworkCore;
using ControlCenter.Api.Entities;
namespace ControlCenter.Api.Data;
/// <summary>
/// Design-time factory for AppDbContext, used by EF Core tools (dotnet ef)
/// to create migrations without requiring a running application.
/// </summary>
public class AppDbContextFactory : Microsoft.EntityFrameworkCore.Design.IDesignTimeDbContextFactory<AppDbContext>
{
public AppDbContext CreateDbContext(string[] args)
{
var optionsBuilder = new DbContextOptionsBuilder<AppDbContext>();
// Connection string for design-time operations (migrations).
// In production, this comes from appsettings / environment variables.
var connectionString = "Host=localhost;Database=control_center;Username=postgres;Password=postgres";
optionsBuilder.UseNpgsql(connectionString, npgsqlOptions =>
{
npgsqlOptions.MigrationsAssembly(typeof(AppDbContext).Assembly.FullName);
});
return new AppDbContext(optionsBuilder.Options);
}
}

View File

@@ -0,0 +1,75 @@
namespace ControlCenter.Api.Dtos;
/// <summary>
/// Data transfer object for broadcasting agent status updates
/// to all connected SignalR clients.
/// </summary>
public class AgentStatusUpdateDto
{
/// <summary>
/// Agent identifier, e.g. "otto", "dex", "rex".
/// Not null — every update must identify the agent it refers to.
/// </summary>
public string AgentId { get; set; } = string.Empty;
/// <summary>
/// Human-readable display name, e.g. "Otto", "Dex".
/// Not null — used by clients to render agent cards.
/// </summary>
public string DisplayName { get; set; } = string.Empty;
/// <summary>
/// Role description, e.g. "Orchestrator Agent", "Backend Specialist".
/// Not null — provides context for the agent's function.
/// </summary>
public string Role { get; set; } = string.Empty;
/// <summary>
/// Current operational status of the agent.
/// Maps to <see cref="Entities.AgentStatus"/> values as lowercase strings:
/// "active", "idle", "thinking", "error".
/// </summary>
public string Status { get; set; } = string.Empty;
/// <summary>
/// Description of the agent's current task, if any.
/// Null when the agent is idle with no active task.
/// </summary>
public string? CurrentTask { get; set; }
/// <summary>
/// Task progress percentage (0100).
/// Null when progress is not trackable for the current task.
/// </summary>
public int? TaskProgress { get; set; }
/// <summary>
/// Elapsed time string for the current task, e.g. "04m 12s".
/// Null when no task is active.
/// </summary>
public string? TaskElapsed { get; set; }
/// <summary>
/// Full session key, e.g. "agent:otto:telegram:direct:8787451565".
/// Not null — uniquely identifies the agent session.
/// </summary>
public string SessionKey { get; set; } = string.Empty;
/// <summary>
/// Communication channel the agent is operating on, e.g. "telegram", "discord", "slack".
/// Not null — every agent session operates on exactly one channel.
/// </summary>
public string Channel { get; set; } = string.Empty;
/// <summary>
/// ISO 8601 timestamp of the agent's last activity.
/// Not null — used by clients to detect stale connections.
/// </summary>
public string LastActivity { get; set; } = string.Empty;
/// <summary>
/// Error message when the agent status is "error".
/// Null when the agent is not in an error state.
/// </summary>
public string? ErrorMessage { get; set; }
}

59
backend/Entities/Agent.cs Normal file
View File

@@ -0,0 +1,59 @@
namespace ControlCenter.Api.Entities;
/// <summary>
/// Represents an agent's current state in the Control Center.
/// Each row tracks one agent session's status, task, and activity.
/// </summary>
public class Agent
{
/// <summary>
/// Primary key — UUID generated on insert.
/// </summary>
public Guid Id { get; set; }
/// <summary>
/// Current operational status of the agent.
/// Stored as an enum in PostgreSQL via Npgsql.
/// </summary>
public AgentStatus Status { get; set; } = AgentStatus.Idle;
/// <summary>
/// Description of the agent's current task, if any.
/// Nullable — not all agents have an active task.
/// </summary>
public string? Task { get; set; }
/// <summary>
/// Task progress percentage (0100).
/// Nullable — progress is only meaningful when an agent has a trackable task.
/// </summary>
public int? Progress { get; set; }
/// <summary>
/// Full session key, e.g. "agent:otto:telegram:direct:8787451565".
/// Not null — every agent row must be associated with a session.
/// </summary>
public string SessionKey { get; set; } = string.Empty;
/// <summary>
/// Communication channel the agent is operating on, e.g. "telegram", "discord", "slack".
/// Not null — every agent session operates on exactly one channel.
/// </summary>
public string Channel { get; set; } = string.Empty;
/// <summary>
/// Timestamp of the agent's last activity.
/// Default: current UTC timestamp on insert.
/// </summary>
public DateTime LastActivity { get; set; } = DateTime.UtcNow;
/// <summary>
/// Row creation timestamp. Set automatically on insert.
/// </summary>
public DateTime CreatedAt { get; set; } = DateTime.UtcNow;
/// <summary>
/// Row last-update timestamp. Updated automatically on any modification.
/// </summary>
public DateTime UpdatedAt { get; set; } = DateTime.UtcNow;
}

View File

@@ -0,0 +1,13 @@
namespace ControlCenter.Api.Entities;
/// <summary>
/// Agent operational status enum.
/// Maps to the agent_status enum type in PostgreSQL.
/// </summary>
public enum AgentStatus
{
Active = 0,
Idle = 1,
Thinking = 2,
Error = 3
}

View File

@@ -0,0 +1,155 @@
using ControlCenter.Api.Dtos;
using Microsoft.AspNetCore.SignalR;
namespace ControlCenter.Api.Hubs;
/// <summary>
/// SignalR hub for broadcasting agent status updates to connected clients.
///
/// <para>
/// Clients call <see cref="SendStatusUpdate"/> to broadcast a status change,
/// and the hub relays it to all connected clients via the
/// <see cref="IAgentStatusClient.AgentStatusChanged"/> callback.
/// </para>
///
/// <para>
/// Server-side code should use <see cref="AgentStatusHubExtensions.PushStatusUpdateAsync"/>
/// via <c>IHubContext&lt;AgentStatusHub, IAgentStatusClient&gt;</c> for background-service broadcasts.
/// </para>
///
/// <para>
/// Architecture note: This hub bridges OpenClaw Gateway events to SignalR clients.
/// A background service subscribes to Gateway events and pushes them through
/// this hub's extension methods.
/// </para>
/// </summary>
public class AgentStatusHub : Hub<IAgentStatusClient>
{
private readonly ILogger<AgentStatusHub> _logger;
/// <summary>
/// Initializes a new instance of the <see cref="AgentStatusHub"/> class.
/// </summary>
/// <param name="logger">Logger for diagnostic output.</param>
public AgentStatusHub(ILogger<AgentStatusHub> logger)
{
_logger = logger;
}
/// <summary>
/// Broadcasts an agent status update to all connected clients.
///
/// <para>
/// Any connected client (or server-side caller) can invoke this method
/// to push a status update to every subscriber. The update is relayed
/// through the <see cref="IAgentStatusClient.AgentStatusChanged"/> callback.
/// </para>
/// </summary>
/// <param name="update">The agent status update payload to broadcast.</param>
public async Task SendStatusUpdate(AgentStatusUpdateDto update)
{
_logger.LogInformation(
"Broadcasting status update for agent {AgentId}: {Status}",
update.AgentId, update.Status);
await Clients.All.AgentStatusChanged(update);
}
/// <summary>
/// Adds the calling connection to the fleet group.
/// Once joined, the client will receive all agent status updates.
/// </summary>
public async Task JoinFleet()
{
await Groups.AddToGroupAsync(Context.ConnectionId, FleetGroupName);
_logger.LogDebug("Connection {ConnectionId} joined fleet group", Context.ConnectionId);
}
/// <summary>
/// Removes the calling connection from the fleet group.
/// </summary>
public async Task LeaveFleet()
{
await Groups.RemoveFromGroupAsync(Context.ConnectionId, FleetGroupName);
_logger.LogDebug("Connection {ConnectionId} left fleet group", Context.ConnectionId);
}
/// <summary>
/// Overrides <see cref="Hub{T}.OnDisconnectedAsync"/> to log disconnections.
/// SignalR automatically removes disconnected connections from all groups.
/// </summary>
/// <param name="exception">Exception that caused the disconnection, if any.</param>
public override Task OnDisconnectedAsync(Exception? exception)
{
_logger.LogDebug("Connection {ConnectionId} disconnected", Context.ConnectionId);
return base.OnDisconnectedAsync(exception);
}
/// <summary>
/// The SignalR group name for the entire fleet (all agents).
/// </summary>
internal const string FleetGroupName = "fleet";
}
/// <summary>
/// Strongly-typed client interface for the AgentStatus SignalR hub.
/// Defines the methods the server can invoke on connected clients
/// to push real-time agent status updates.
/// </summary>
public interface IAgentStatusClient
{
/// <summary>
/// Pushes an agent status change to all subscribed clients.
/// Fired whenever an agent's operational status changes
/// (e.g., idle → active, active → thinking, active → error).
/// </summary>
/// <param name="update">The full status update payload.</param>
/// <returns>A Task that completes when the client has processed the update.</returns>
Task AgentStatusChanged(AgentStatusUpdateDto update);
}
/// <summary>
/// Extension methods for pushing real-time agent updates through
/// the <see cref="IHubContext{T}"/> of <see cref="AgentStatusHub"/>.
///
/// <para>
/// These methods are intended to be called from background services
/// or other server-side code that detects an agent state change,
/// using the injected <c>IHubContext&lt;AgentStatusHub, IAgentStatusClient&gt;</c>.
/// </para>
/// </summary>
public static class AgentStatusHubExtensions
{
/// <summary>
/// Pushes an agent status update to all connected clients.
///
/// <para>
/// Call this from any background service when an agent's
/// operational status changes (e.g., the Gateway reports a
/// session transition from "running" to "done").
/// </para>
/// </summary>
/// <param name="hubContext">The hub context injected via DI.</param>
/// <param name="update">The agent status update payload.</param>
/// <returns>A Task that completes when the message has been sent to all clients.</returns>
public static async Task PushStatusUpdateAsync(
this IHubContext<AgentStatusHub, IAgentStatusClient> hubContext,
AgentStatusUpdateDto update)
{
await hubContext.Clients.All.AgentStatusChanged(update);
}
/// <summary>
/// Pushes an agent status update to clients subscribed to the fleet group.
/// </summary>
/// <param name="hubContext">The hub context injected via DI.</param>
/// <param name="update">The agent status update payload.</param>
/// <returns>A Task that completes when the message has been sent to the fleet group.</returns>
public static async Task PushStatusUpdateToFleetAsync(
this IHubContext<AgentStatusHub, IAgentStatusClient> hubContext,
AgentStatusUpdateDto update)
{
await hubContext.Clients.Group(AgentStatusHub.FleetGroupName)
.AgentStatusChanged(update);
}
}

View File

@@ -0,0 +1,94 @@
// <auto-generated />
using System;
using ControlCenter.Api.Data;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Infrastructure;
using Microsoft.EntityFrameworkCore.Migrations;
using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
#nullable disable
namespace ControlCenter.Api.Migrations
{
[DbContext(typeof(AppDbContext))]
[Migration("20260426101703_CreateAgentsTable")]
partial class CreateAgentsTable
{
/// <inheritdoc />
protected override void BuildTargetModel(ModelBuilder modelBuilder)
{
#pragma warning disable 612, 618
modelBuilder
.HasAnnotation("ProductVersion", "9.0.4")
.HasAnnotation("Relational:MaxIdentifierLength", 63);
NpgsqlModelBuilderExtensions.HasPostgresEnum(modelBuilder, "agent_status", new[] { "active", "idle", "thinking", "error" });
NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
modelBuilder.Entity("ControlCenter.Api.Entities.Agent", b =>
{
b.Property<Guid>("Id")
.ValueGeneratedOnAdd()
.HasColumnType("uuid")
.HasColumnName("id");
b.Property<string>("Channel")
.IsRequired()
.HasColumnType("text")
.HasColumnName("channel");
b.Property<DateTime>("CreatedAt")
.ValueGeneratedOnAdd()
.HasColumnType("timestamptz")
.HasColumnName("created_at")
.HasDefaultValueSql("now()");
b.Property<DateTime>("LastActivity")
.HasColumnType("timestamptz")
.HasColumnName("last_activity");
b.Property<int?>("Progress")
.HasColumnType("integer")
.HasColumnName("progress");
b.Property<string>("SessionKey")
.IsRequired()
.HasColumnType("text")
.HasColumnName("session_key");
b.Property<int>("Status")
.HasColumnType("agent_status")
.HasColumnName("status");
b.Property<string>("Task")
.HasColumnType("text")
.HasColumnName("task");
b.Property<DateTime>("UpdatedAt")
.ValueGeneratedOnAdd()
.HasColumnType("timestamptz")
.HasColumnName("updated_at")
.HasDefaultValueSql("now()");
b.HasKey("Id");
b.HasIndex("Channel")
.HasDatabaseName("ix_agents_channel");
b.HasIndex("SessionKey")
.IsUnique()
.HasDatabaseName("ix_agents_session_key");
b.HasIndex("Status")
.HasDatabaseName("ix_agents_status");
b.ToTable("agents", null, t =>
{
t.HasCheckConstraint("ck_agents_progress_range", "progress IS NULL OR (progress >= 0 AND progress <= 100)");
});
});
#pragma warning restore 612, 618
}
}
}

View File

@@ -0,0 +1,61 @@
using System;
using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
namespace ControlCenter.Api.Migrations
{
/// <inheritdoc />
public partial class CreateAgentsTable : Migration
{
/// <inheritdoc />
protected override void Up(MigrationBuilder migrationBuilder)
{
migrationBuilder.AlterDatabase()
.Annotation("Npgsql:Enum:agent_status", "active,idle,thinking,error");
migrationBuilder.CreateTable(
name: "agents",
columns: table => new
{
id = table.Column<Guid>(type: "uuid", nullable: false),
status = table.Column<int>(type: "agent_status", nullable: false),
task = table.Column<string>(type: "text", nullable: true),
progress = table.Column<int>(type: "integer", nullable: true),
session_key = table.Column<string>(type: "text", nullable: false),
channel = table.Column<string>(type: "text", nullable: false),
last_activity = table.Column<DateTime>(type: "timestamptz", nullable: false),
created_at = table.Column<DateTime>(type: "timestamptz", nullable: false, defaultValueSql: "now()"),
updated_at = table.Column<DateTime>(type: "timestamptz", nullable: false, defaultValueSql: "now()")
},
constraints: table =>
{
table.PrimaryKey("PK_agents", x => x.id);
table.CheckConstraint("ck_agents_progress_range", "progress IS NULL OR (progress >= 0 AND progress <= 100)");
});
migrationBuilder.CreateIndex(
name: "ix_agents_channel",
table: "agents",
column: "channel");
migrationBuilder.CreateIndex(
name: "ix_agents_session_key",
table: "agents",
column: "session_key",
unique: true);
migrationBuilder.CreateIndex(
name: "ix_agents_status",
table: "agents",
column: "status");
}
/// <inheritdoc />
protected override void Down(MigrationBuilder migrationBuilder)
{
migrationBuilder.DropTable(
name: "agents");
}
}
}

View File

@@ -0,0 +1,91 @@
// <auto-generated />
using System;
using ControlCenter.Api.Data;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Infrastructure;
using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
#nullable disable
namespace ControlCenter.Api.Migrations
{
[DbContext(typeof(AppDbContext))]
partial class AppDbContextModelSnapshot : ModelSnapshot
{
protected override void BuildModel(ModelBuilder modelBuilder)
{
#pragma warning disable 612, 618
modelBuilder
.HasAnnotation("ProductVersion", "9.0.4")
.HasAnnotation("Relational:MaxIdentifierLength", 63);
NpgsqlModelBuilderExtensions.HasPostgresEnum(modelBuilder, "agent_status", new[] { "active", "idle", "thinking", "error" });
NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
modelBuilder.Entity("ControlCenter.Api.Entities.Agent", b =>
{
b.Property<Guid>("Id")
.ValueGeneratedOnAdd()
.HasColumnType("uuid")
.HasColumnName("id");
b.Property<string>("Channel")
.IsRequired()
.HasColumnType("text")
.HasColumnName("channel");
b.Property<DateTime>("CreatedAt")
.ValueGeneratedOnAdd()
.HasColumnType("timestamptz")
.HasColumnName("created_at")
.HasDefaultValueSql("now()");
b.Property<DateTime>("LastActivity")
.HasColumnType("timestamptz")
.HasColumnName("last_activity");
b.Property<int?>("Progress")
.HasColumnType("integer")
.HasColumnName("progress");
b.Property<string>("SessionKey")
.IsRequired()
.HasColumnType("text")
.HasColumnName("session_key");
b.Property<int>("Status")
.HasColumnType("agent_status")
.HasColumnName("status");
b.Property<string>("Task")
.HasColumnType("text")
.HasColumnName("task");
b.Property<DateTime>("UpdatedAt")
.ValueGeneratedOnAdd()
.HasColumnType("timestamptz")
.HasColumnName("updated_at")
.HasDefaultValueSql("now()");
b.HasKey("Id");
b.HasIndex("Channel")
.HasDatabaseName("ix_agents_channel");
b.HasIndex("SessionKey")
.IsUnique()
.HasDatabaseName("ix_agents_session_key");
b.HasIndex("Status")
.HasDatabaseName("ix_agents_status");
b.ToTable("agents", null, t =>
{
t.HasCheckConstraint("ck_agents_progress_range", "progress IS NULL OR (progress >= 0 AND progress <= 100)");
});
});
#pragma warning restore 612, 618
}
}
}

View File

@@ -0,0 +1,19 @@
namespace ControlCenter.Api.Models;
/// <summary>
/// Read-only model representing an agent's current state.
/// Used as the return type from the Agent State Repository
/// to decouple consumers from the persistence layer.
/// </summary>
public class AgentState
{
public Guid Id { get; set; }
public string Status { get; set; } = string.Empty;
public string? Task { get; set; }
public int? Progress { get; set; }
public string SessionKey { get; set; } = string.Empty;
public string Channel { get; set; } = string.Empty;
public DateTime LastActivity { get; set; }
public DateTime CreatedAt { get; set; }
public DateTime UpdatedAt { get; set; }
}

42
backend/Program.cs Normal file
View File

@@ -0,0 +1,42 @@
using ControlCenter.Api.Data;
using ControlCenter.Api.Hubs;
using ControlCenter.Api.Repositories;
using Microsoft.EntityFrameworkCore;
var builder = WebApplication.CreateBuilder(args);
// Add services to the container.
builder.Services.AddOpenApi();
// Register SignalR for real-time agent status updates
builder.Services.AddSignalR();
// Register Agent State Repository
builder.Services.AddScoped<IAgentStateRepository, AgentStateRepository>();
// Register DbContext with PostgreSQL
builder.Services.AddDbContext<AppDbContext>(options =>
{
var connectionString = builder.Configuration.GetConnectionString("DefaultConnection")
?? "Host=localhost;Database=control_center;Username=postgres;Password=postgres";
options.UseNpgsql(connectionString, npgsqlOptions =>
{
npgsqlOptions.MigrationsAssembly(typeof(AppDbContext).Assembly.FullName);
});
});
var app = builder.Build();
// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
app.MapOpenApi();
}
app.UseHttpsRedirection();
// Map SignalR hubs
app.MapHub<AgentStatusHub>("/hubs/agent-status");
app.Run();

View File

@@ -0,0 +1,23 @@
{
"$schema": "https://json.schemastore.org/launchsettings.json",
"profiles": {
"http": {
"commandName": "Project",
"dotnetRunMessages": true,
"launchBrowser": false,
"applicationUrl": "http://localhost:5178",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
},
"https": {
"commandName": "Project",
"dotnetRunMessages": true,
"launchBrowser": false,
"applicationUrl": "https://localhost:7041;http://localhost:5178",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
}
}
}

View File

@@ -0,0 +1,76 @@
using ControlCenter.Api.Data;
using ControlCenter.Api.Entities;
using ControlCenter.Api.Models;
using Microsoft.EntityFrameworkCore;
namespace ControlCenter.Api.Repositories;
/// <summary>
/// EF Core implementation of the Agent State Repository.
/// Maps between the persisted <see cref="Agent"/> entity and the
/// read-oriented <see cref="AgentState"/> model.
/// </summary>
public class AgentStateRepository : IAgentStateRepository
{
private readonly AppDbContext _db;
public AgentStateRepository(AppDbContext db)
{
_db = db;
}
/// <inheritdoc />
public async Task<IReadOnlyList<AgentState>> GetAllAsync(CancellationToken ct = default)
{
var agents = await _db.Agents
.AsNoTracking()
.OrderByDescending(a => a.LastActivity)
.ToListAsync(ct);
return agents.Select(ToModel).ToList();
}
/// <inheritdoc />
public async Task<AgentState?> GetBySessionKeyAsync(string sessionKey, CancellationToken ct = default)
{
var agent = await _db.Agents
.AsNoTracking()
.FirstOrDefaultAsync(a => a.SessionKey == sessionKey, ct);
return agent is null ? null : ToModel(agent);
}
/// <inheritdoc />
public async Task<bool> UpdateStatusAsync(Guid id, string status, CancellationToken ct = default)
{
if (!Enum.TryParse<AgentStatus>(status, ignoreCase: true, out var parsedStatus))
return false;
var agent = await _db.Agents.FindAsync([id], ct);
if (agent is null)
return false;
agent.Status = parsedStatus;
agent.UpdatedAt = DateTime.UtcNow;
agent.LastActivity = DateTime.UtcNow;
await _db.SaveChangesAsync(ct);
return true;
}
/// <summary>
/// Maps a persisted <see cref="Agent"/> entity to a <see cref="AgentState"/> model.
/// </summary>
private static AgentState ToModel(Agent agent) => new()
{
Id = agent.Id,
Status = agent.Status.ToString(),
Task = agent.Task,
Progress = agent.Progress,
SessionKey = agent.SessionKey,
Channel = agent.Channel,
LastActivity = agent.LastActivity,
CreatedAt = agent.CreatedAt,
UpdatedAt = agent.UpdatedAt,
};
}

View File

@@ -0,0 +1,27 @@
using ControlCenter.Api.Models;
namespace ControlCenter.Api.Repositories;
/// <summary>
/// Repository interface for accessing and mutating Agent State.
/// Provides a clean abstraction over the EF Core data access layer.
/// </summary>
public interface IAgentStateRepository
{
/// <summary>
/// Retrieve all agent states.
/// </summary>
Task<IReadOnlyList<AgentState>> GetAllAsync(CancellationToken ct = default);
/// <summary>
/// Retrieve a single agent state by its session key.
/// Returns null if no agent is found with the given session key.
/// </summary>
Task<AgentState?> GetBySessionKeyAsync(string sessionKey, CancellationToken ct = default);
/// <summary>
/// Update the status of an agent by its primary key.
/// Returns true if the agent was found and updated, false otherwise.
/// </summary>
Task<bool> UpdateStatusAsync(Guid id, string status, CancellationToken ct = default);
}

View File

@@ -0,0 +1,8 @@
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
}
}

12
backend/appsettings.json Normal file
View File

@@ -0,0 +1,12 @@
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
},
"AllowedHosts": "*",
"ConnectionStrings": {
"DefaultConnection": "Host=localhost;Database=control_center;Username=postgres;Password=postgres"
}
}

View File

@@ -5,7 +5,6 @@ import { ProjectsPageComponent } from './pages/projects/projects-page.component'
import { SessionsPageComponent } from './pages/sessions/sessions-page.component'; import { SessionsPageComponent } from './pages/sessions/sessions-page.component';
import { LogsPageComponent } from './pages/logs/logs-page.component'; import { LogsPageComponent } from './pages/logs/logs-page.component';
import { SettingsPageComponent } from './pages/settings/settings-page.component'; import { SettingsPageComponent } from './pages/settings/settings-page.component';
import { BreakroomPageComponent } from './pages/breakroom/breakroom-page.component';
export const routes: Routes = [ export const routes: Routes = [
{ {
@@ -18,7 +17,6 @@ export const routes: Routes = [
{ path: 'sessions', component: SessionsPageComponent }, { path: 'sessions', component: SessionsPageComponent },
{ path: 'logs', component: LogsPageComponent }, { path: 'logs', component: LogsPageComponent },
{ path: 'settings', component: SettingsPageComponent }, { path: 'settings', component: SettingsPageComponent },
{ path: 'breakroom', component: BreakroomPageComponent },
], ],
}, },
]; ];

View File

@@ -0,0 +1,82 @@
<!-- ========================================================================== -->
<!-- AgentCard — per spec Section 7.3 -->
<!-- Integrates: Status Badge · Task Progress Bar · QuickJump Button -->
<!-- Leftborder accent matches status color. role="article" + arialabels. -->
<!-- ========================================================================== -->
<article
class="agent-card"
role="article"
[attr.aria-label]="displayName + ' ' + statusLabel()"
[style.border-left-color]="statusBorderColor()"
>
<!-- ── Header: status badge + agent info ── -->
<div class="agent-card__header">
<div class="agent-card__badge" [attr.aria-label]="'Status: ' + statusLabel()">
<span
class="status-dot"
[ngClass]="[statusDotClass()]"
></span>
<span class="agent-card__status-label">{{ statusLabel() }}</span>
</div>
<div class="agent-card__identity">
<span class="agent-card__name">{{ displayName || agentId }}</span>
<span class="agent-card__role">{{ role }}</span>
</div>
</div>
<!-- ── Body: current task ── -->
<div class="agent-card__body" *ngIf="task || status === 'error'">
<p
class="agent-card__task"
[attr.aria-label]="'Current task: ' + (status === 'error' ? errorMessage : task)"
>
{{ status === 'error' ? errorMessage || task : task }}
</p>
</div>
<!-- ── Task Progress Bar ── -->
<div
class="agent-card__progress"
*ngIf="progress > 0 && status !== 'error'"
[attr.aria-label]="'Task progress: ' + progress + '%'"
>
<mat-progress-bar
mode="determinate"
[value]="progress"
[aria-label]="'Progress ' + progress + '% complete'"
></mat-progress-bar>
<span class="agent-card__progress-label text-mono">{{ progress }}%</span>
</div>
<!-- ── Footer: channel + last activity + quickjump ── -->
<div class="agent-card__footer">
<div class="agent-card__meta">
<span
class="agent-card__channel text-mono"
[attr.aria-label]="'Channel: ' + channel"
>
<mat-icon aria-hidden="true">{{ channelIcon() }}</mat-icon>
{{ channel }}
</span>
<span
class="agent-card__last-activity text-mono"
[attr.aria-label]="'Last activity: ' + lastActivityLabel()"
>
{{ lastActivityLabel() }}
</span>
</div>
<!-- QuickJump Button -->
<a
class="agent-card__jump"
mat-button
[routerLink]="jumpRoute()"
[attr.aria-label]="'Jump to session for ' + (displayName || agentId)"
matTooltip="Jump to session"
>
<mat-icon aria-hidden="true">arrow_forward</mat-icon>
</a>
</div>
</article>

View File

@@ -0,0 +1,234 @@
// ============================================================================
// AgentCard — M3 tactical dark styling
// Per spec Section 7.3: leftborder accent, statusaware coloring,
// responsive card layout with 320px minwidth.
// ============================================================================
.agent-card {
display: flex;
flex-direction: column;
min-width: var(--cc-card-min-width);
padding: var(--cc-card-padding);
background-color: var(--cc-surface-container);
border-radius: var(--cc-card-border-radius);
border-left: 4px solid var(--status-offline); // default; overridden by [style]
border-top: 1px solid var(--cc-outline);
border-right: 1px solid var(--cc-outline);
border-bottom: 1px solid var(--cc-outline);
gap: 16px;
transition: border-left-color 0.3s ease, box-shadow 0.2s ease;
cursor: default;
&:hover {
box-shadow: 0 2px 8px rgba(0, 0, 0, 0.3);
}
&:focus-within {
outline: 2px solid var(--status-active);
outline-offset: 2px;
}
}
// ── Header ──
.agent-card__header {
display: flex;
align-items: center;
gap: 12px;
}
.agent-card__badge {
display: flex;
align-items: center;
gap: 6px;
padding: 4px 10px;
border-radius: 12px;
background-color: var(--status-active-bg); // overridden per status below
font-size: 12px;
font-weight: 500;
letter-spacing: 0.02em;
text-transform: uppercase;
color: var(--cc-on-surface);
// Perstatus background tints
.status-dot--active + & {
background-color: var(--status-active-bg);
}
}
.agent-card__status-label {
font-size: 12px;
font-weight: 500;
text-transform: uppercase;
letter-spacing: 0.04em;
color: var(--cc-on-surface-variant);
}
.agent-card__identity {
display: flex;
flex-direction: column;
gap: 2px;
}
.agent-card__name {
font-size: 16px;
font-weight: 600;
color: var(--cc-on-surface);
line-height: 1.2;
}
.agent-card__role {
font-size: 12px;
font-weight: 400;
color: var(--cc-on-surface-variant);
}
// ── Body ──
.agent-card__body {
padding: 4px 0;
}
.agent-card__task {
margin: 0;
font-size: 14px;
font-weight: 400;
color: var(--cc-on-surface);
line-height: 1.4;
// Error messages get distinct styling
.agent-card--error & {
color: var(--status-error);
}
}
// ── Progress Bar ──
.agent-card__progress {
display: flex;
align-items: center;
gap: 8px;
padding: 4px 0;
}
.agent-card__progress-label {
font-size: 12px;
font-weight: 500;
color: var(--cc-on-surface-variant);
white-space: nowrap;
min-width: 36px;
}
// Override mat-progress-bar to match tactical dark theme
.agent-card__progress ::ng-deep .mat-mdc-progress-bar {
height: 4px;
border-radius: 2px;
.mdc-linear-progress__bar-inner {
background-color: var(--status-active);
}
.mdc-linear-progress__track {
background-color: var(--cc-outline);
}
}
// ── Footer ──
.agent-card__footer {
display: flex;
align-items: center;
justify-content: space-between;
gap: 8px;
margin-top: auto; // push footer to bottom
}
.agent-card__meta {
display: flex;
align-items: center;
gap: 12px;
}
.agent-card__channel {
display: inline-flex;
align-items: center;
gap: 4px;
font-size: 12px;
color: var(--cc-on-surface-variant);
}
.agent-card__channel-icon,
.agent-card__channel .mat-icon {
font-size: 14px;
width: 14px;
height: 14px;
}
.agent-card__last-activity {
font-size: 12px;
color: var(--cc-on-surface-variant);
}
// ── QuickJump Button ──
.agent-card__jump {
flex-shrink: 0;
// Match M3 text button sizing
.mat-mdc-button {
min-width: 36px;
padding: 0 8px;
color: var(--status-active);
}
.mat-icon {
font-size: 18px;
width: 18px;
height: 18px;
}
}
// ── Statusspecific background tints for badge ──
// We use the global status-dot classes from styles.scss and pair them
// with contextual background-color overrides here.
.agent-card[data-status="active"] .agent-card__badge,
.agent-card .status-dot--active ~ .agent-card__badge {
background-color: var(--status-active-bg);
}
.agent-card[data-status="idle"] .agent-card__badge {
background-color: var(--status-idle-bg);
}
.agent-card[data-status="thinking"] .agent-card__badge {
background-color: var(--status-thinking-bg);
}
.agent-card[data-status="error"] .agent-card__badge {
background-color: var(--status-error-bg);
}
// ── Responsive ──
@media (max-width: 599px) {
.agent-card {
min-width: unset;
padding: 16px;
}
.agent-card__header {
flex-wrap: wrap;
gap: 8px;
}
.agent-card__footer {
flex-wrap: wrap;
gap: 8px;
}
.agent-card__meta {
gap: 8px;
}
}
// ── Accessibility: reduced motion ──
@media (prefers-reduced-motion: reduce) {
.agent-card {
transition: none;
}
}

View File

@@ -0,0 +1,127 @@
import {
ChangeDetectionStrategy,
Component,
Input,
computed,
} from '@angular/core';
import { CommonModule } from '@angular/common';
import { RouterModule } from '@angular/router';
import { MatIconModule } from '@angular/material/icon';
import { MatButtonModule } from '@angular/material/button';
import { MatProgressBarModule } from '@angular/material/progress-bar';
import { MatTooltipModule } from '@angular/material/tooltip';
import { AgentStatus } from '../../../models/agent.model';
// ============================================================================
// AgentCard Component
// Per spec Section 7.3: Composes Agent Status Badge, Task Progress Bar,
// and QuickJump Button into a card with leftborder status accent.
// ============================================================================
@Component({
selector: 'app-agent-card',
standalone: true,
imports: [
CommonModule,
RouterModule,
MatIconModule,
MatButtonModule,
MatProgressBarModule,
MatTooltipModule,
],
templateUrl: './agent-card.component.html',
styleUrl: './agent-card.component.scss',
changeDetection: ChangeDetectionStrategy.OnPush,
})
export class AgentCardComponent {
// --- Six required inputs per spec ---
/** Agent status — drives badge color and leftborder accent */
@Input({ required: true }) status!: AgentStatus;
/** Current task description, e.g. "Reviewing PR #42" */
@Input() task = '';
/** Task progress percentage 0100 */
@Input() progress = 0;
/** Full session key for quickjump navigation */
@Input({ required: true }) sessionKey = '';
/** Communication channel, e.g. "telegram" */
@Input({ required: true }) channel = '';
/** Timestamp of last agent activity */
@Input({ required: true }) lastActivity!: Date;
// --- Additional display inputs ---
/** Short agent ID, e.g. "otto" */
@Input() agentId = '';
/** Display name, e.g. "Otto" */
@Input() displayName = '';
/** Role description, e.g. "Orchestrator Agent" */
@Input() role = '';
/** Error message (shown only when status is 'error') */
@Input() errorMessage = '';
// --- Computed values ---
/** Map status → CSS custom property for the leftborder accent */
readonly statusBorderColor = computed(() => {
const map: Record<AgentStatus, string> = {
active: 'var(--status-active)',
idle: 'var(--status-idle)',
thinking: 'var(--status-thinking)',
error: 'var(--status-error)',
offline: 'var(--status-offline)',
};
return map[this.status] ?? 'var(--status-offline)';
});
/** Humanreadable status label */
readonly statusLabel = computed(() => {
const labels: Record<AgentStatus, string> = {
active: 'Active',
idle: 'Idle',
thinking: 'Thinking…',
error: 'Error',
offline: 'Offline',
};
return labels[this.status] ?? this.status;
});
/** CSS class suffix for the status badge dot */
readonly statusDotClass = computed(() => `status-dot--${this.status}`);
/** Material icon name for the channel */
readonly channelIcon = computed(() => {
const icons: Record<string, string> = {
telegram: 'telegram', // falls back to font icon if no SVG registered
slack: 'chat',
discord: 'forum',
whatsapp: 'chat',
webchat: 'language',
email: 'email',
};
return icons[this.channel] ?? 'chat';
});
/** Relative time string for lastActivity */
readonly lastActivityLabel = computed(() => {
if (!this.lastActivity) return '';
const now = Date.now();
const then = this.lastActivity.getTime();
const diffSec = Math.max(0, Math.floor((now - then) / 1000));
if (diffSec < 60) return 'just now';
if (diffSec < 3600) return `${Math.floor(diffSec / 60)}m ago`;
if (diffSec < 86400) return `${Math.floor(diffSec / 3600)}h ago`;
return `${Math.floor(diffSec / 86400)}d ago`;
});
/** Quickjump route derived from sessionKey */
readonly jumpRoute = computed(() => `/sessions/${this.sessionKey}`);
}

View File

@@ -0,0 +1 @@
export * from './agent-card/agent-card.component';

View File

@@ -0,0 +1,112 @@
<!-- ======================================================================== -->
<!-- Adaptive Navigation — Desktop sidebar / Mobile header -->
<!-- Desktop (≥768px): 72px sidebar with full navigation items -->
<!-- Mobile (<768px): 56px compact header with hamburger menu -->
<!-- ======================================================================== -->
<!-- ======================= DESKTOP SIDEBAR (≥768px) ======================= -->
<aside class="adaptive-nav__sidebar" aria-label="Navigation sidebar">
<!-- Brand / Toggle header -->
<div class="adaptive-nav__sidebar-header">
<span class="adaptive-nav__brand">OC</span>
</div>
<!-- Navigation destinations -->
<nav class="adaptive-nav__sidebar-nav">
@for (dest of destinations; track dest.route) {
<a
class="adaptive-nav__sidebar-item"
[routerLink]="dest.route"
routerLinkActive="adaptive-nav__sidebar-item--active"
[attr.aria-label]="dest.label"
>
<mat-icon
[matBadge]="dest.badge ?? 0"
[matBadgeHidden]="!dest.badge"
matBadgePosition="above after"
matBadgeSize="small"
>
{{ dest.icon }}
</mat-icon>
<span class="adaptive-nav__sidebar-label">{{ dest.label }}</span>
</a>
}
</nav>
<!-- Sidebar footer: LIVE indicator + action buttons -->
<div class="adaptive-nav__sidebar-footer">
<div class="adaptive-nav__live" [class.adaptive-nav__live--connected]="isConnected()">
<span
class="adaptive-nav__live-dot"
[class.adaptive-nav__live-dot--connected]="isConnected()"
></span>
<mat-chip
class="adaptive-nav__live-chip"
[highlighted]="isConnected()"
[disabled]="!isConnected()"
>
{{ isConnected() ? 'LIVE' : 'OFFLINE' }}
</mat-chip>
</div>
<!-- Action buttons (placeholder) -->
<div class="adaptive-nav__sidebar-actions">
<button mat-icon-button aria-label="Notifications">
<mat-icon>notifications</mat-icon>
</button>
<button mat-icon-button aria-label="Settings">
<mat-icon>settings</mat-icon>
</button>
</div>
</div>
</aside>
<!-- ======================= MOBILE HEADER (<768px) ======================== -->
<header class="adaptive-nav__mobile-header" role="banner">
<!-- Hamburger menu button -->
<button
class="adaptive-nav__hamburger"
mat-icon-button
[attr.aria-label]="mobileMenuOpen() ? 'Close menu' : 'Open menu'"
[attr.aria-expanded]="mobileMenuOpen()"
(click)="toggleMobileMenu()"
>
<mat-icon>{{ mobileMenuOpen() ? 'close' : 'menu' }}</mat-icon>
</button>
<!-- Title -->
<h1 class="adaptive-nav__mobile-title">Command Hub</h1>
<!-- LIVE indicator (always visible on mobile) -->
<div class="adaptive-nav__live adaptive-nav__live--mobile" [class.adaptive-nav__live--connected]="isConnected()">
<span
class="adaptive-nav__live-dot"
[class.adaptive-nav__live-dot--connected]="isConnected()"
></span>
<span class="adaptive-nav__live-text">{{ isConnected() ? 'LIVE' : 'OFFLINE' }}</span>
</div>
<!-- Mobile action buttons (placeholder) -->
<button class="adaptive-nav__mobile-action" mat-icon-button aria-label="Notifications">
<mat-icon>notifications</mat-icon>
</button>
</header>
<!-- ======================= MOBILE DRAWER OVERLAY ========================= -->
@if (mobileMenuOpen()) {
<div class="adaptive-nav__overlay" (click)="closeMobileMenu()" role="presentation"></div>
<nav class="adaptive-nav__mobile-drawer" aria-label="Mobile navigation menu">
@for (dest of destinations; track dest.route) {
<a
class="adaptive-nav__drawer-item"
[routerLink]="dest.route"
routerLinkActive="adaptive-nav__drawer-item--active"
[attr.aria-label]="dest.label"
(click)="closeMobileMenu()"
>
<mat-icon>{{ dest.icon }}</mat-icon>
<span class="adaptive-nav__drawer-label">{{ dest.label }}</span>
</a>
}
</nav>
}

View File

@@ -0,0 +1,316 @@
// ============================================================================
// Adaptive Navigation — Desktop sidebar / Mobile header
// Desktop (≥768px): 72px sidebar with full navigation items
// Mobile (<768px): 56px compact header with hamburger menu
// ============================================================================
// ---------------------------------------------------------------------------
// Desktop Sidebar (visible ≥768px)
// ---------------------------------------------------------------------------
.adaptive-nav__sidebar {
display: flex;
flex-direction: column;
width: var(--cc-nav-rail-collapsed-width, 72px);
min-height: 100vh;
background-color: var(--cc-surface-container-high);
border-right: 1px solid var(--cc-outline);
z-index: 10;
}
.adaptive-nav__sidebar-header {
display: flex;
align-items: center;
justify-content: center;
height: 64px;
border-bottom: 1px solid var(--cc-outline);
}
.adaptive-nav__brand {
font-size: 18px;
font-weight: 700;
color: var(--status-active);
letter-spacing: 0.04em;
}
.adaptive-nav__sidebar-nav {
flex: 1;
padding-top: 8px;
}
.adaptive-nav__sidebar-item {
display: flex;
flex-direction: column;
align-items: center;
justify-content: center;
gap: 4px;
min-height: 56px;
padding: 8px 0;
margin: 2px 8px;
border-radius: 28px;
color: var(--cc-on-surface-variant);
text-decoration: none;
transition: background-color 150ms ease, color 150ms ease;
&:hover {
background-color: rgba(255, 255, 255, 0.08);
color: var(--cc-on-surface);
}
&--active {
background-color: var(--status-active-bg);
color: var(--status-active);
.adaptive-nav__sidebar-label {
font-weight: 500;
}
}
}
.adaptive-nav__sidebar-label {
font-size: 11px;
font-weight: 400;
letter-spacing: 0.02em;
white-space: nowrap;
}
// ---------------------------------------------------------------------------
// Sidebar Footer — LIVE indicator + action buttons
// ---------------------------------------------------------------------------
.adaptive-nav__sidebar-footer {
display: flex;
flex-direction: column;
align-items: center;
gap: 8px;
padding: 12px 0 20px;
border-top: 1px solid var(--cc-outline);
}
.adaptive-nav__sidebar-actions {
display: flex;
gap: 4px;
.mat-mdc-icon-button {
color: var(--cc-on-surface-variant) !important;
--mdc-icon-button-icon-size: 20px;
&:hover {
color: var(--cc-on-surface) !important;
}
}
}
// ---------------------------------------------------------------------------
// LIVE Status Indicator
// ---------------------------------------------------------------------------
.adaptive-nav__live {
display: flex;
align-items: center;
gap: 6px;
padding: 4px 8px;
border-radius: 16px;
transition: background-color 200ms ease;
&--connected {
background-color: var(--status-active-bg);
}
}
.adaptive-nav__live-dot {
display: inline-block;
width: 8px;
height: 8px;
min-width: 8px;
border-radius: 50%;
background-color: var(--status-error);
transition: background-color 200ms ease;
&--connected {
background-color: var(--status-active);
animation: pulse-active 2s ease-in-out infinite;
}
}
.adaptive-nav__live-chip {
font-size: 11px !important;
font-weight: 600 !important;
letter-spacing: 0.06em;
height: 24px !important;
min-height: 24px !important;
padding: 0 8px !important;
color: var(--status-active) !important;
--mdc-chip-elevated-container-color: transparent;
background: transparent !important;
border: none !important;
box-shadow: none !important;
}
.adaptive-nav__live-text {
font-size: 12px;
font-weight: 600;
letter-spacing: 0.06em;
color: var(--status-active);
}
// ---------------------------------------------------------------------------
// Mobile Header (visible <768px)
// ---------------------------------------------------------------------------
.adaptive-nav__mobile-header {
display: none; // Hidden on desktop, shown on mobile via media query
align-items: center;
height: 56px;
padding: 0 12px;
background-color: var(--cc-surface-container-high);
border-bottom: 1px solid var(--cc-outline);
z-index: 20;
gap: 8px;
}
.adaptive-nav__hamburger {
color: var(--cc-on-surface-variant) !important;
&:hover {
color: var(--cc-on-surface) !important;
}
}
.adaptive-nav__mobile-title {
flex: 1;
font-size: 20px;
font-weight: 500;
color: var(--cc-on-surface);
margin: 0;
white-space: nowrap;
overflow: hidden;
text-overflow: ellipsis;
}
.adaptive-nav__live--mobile {
padding: 4px 10px;
border-radius: 16px;
.adaptive-nav__live-text {
font-size: 11px;
font-weight: 700;
}
}
.adaptive-nav__mobile-action {
color: var(--cc-on-surface-variant) !important;
&:hover {
color: var(--cc-on-surface) !important;
}
}
// ---------------------------------------------------------------------------
// Mobile Drawer
// ---------------------------------------------------------------------------
.adaptive-nav__overlay {
position: fixed;
inset: 0;
background-color: rgba(0, 0, 0, 0.5);
z-index: 40;
}
.adaptive-nav__mobile-drawer {
position: fixed;
top: 56px; // Below header
left: 0;
bottom: 0;
width: 280px;
max-width: 80vw;
background-color: var(--cc-surface-container);
border-right: 1px solid var(--cc-outline);
z-index: 50;
padding: 12px 0;
overflow-y: auto;
animation: slide-in-left 200ms cubic-bezier(0.4, 0, 0.2, 1);
}
.adaptive-nav__drawer-item {
display: flex;
align-items: center;
gap: 16px;
min-height: 48px;
padding: 0 20px;
color: var(--cc-on-surface-variant);
text-decoration: none;
transition: background-color 150ms ease, color 150ms ease;
&:hover {
background-color: rgba(255, 255, 255, 0.08);
color: var(--cc-on-surface);
}
&--active {
background-color: var(--status-active-bg);
color: var(--status-active);
.adaptive-nav__drawer-label {
font-weight: 500;
}
}
}
.adaptive-nav__drawer-label {
font-size: 14px;
font-weight: 400;
white-space: nowrap;
}
// ---------------------------------------------------------------------------
// Drawer slide-in animation
// ---------------------------------------------------------------------------
@keyframes slide-in-left {
from {
transform: translateX(-100%);
}
to {
transform: translateX(0);
}
}
// ---------------------------------------------------------------------------
// Media Queries — Layout Switch
// ---------------------------------------------------------------------------
// Desktop (≥768px): Show sidebar, hide mobile header
// Mobile (<768px): Hide sidebar, show compact header
// ---------------------------------------------------------------------------
@media (min-width: 768px) {
.adaptive-nav__sidebar {
display: flex;
}
.adaptive-nav__mobile-header {
display: none;
}
// Hide mobile drawer and overlay on desktop
.adaptive-nav__overlay,
.adaptive-nav__mobile-drawer {
display: none;
}
}
@media (max-width: 767px) {
.adaptive-nav__sidebar {
display: none;
}
.adaptive-nav__mobile-header {
display: flex;
}
}
// ---------------------------------------------------------------------------
// Accessibility: Reduced Motion
// ---------------------------------------------------------------------------
@media (prefers-reduced-motion: reduce) {
.adaptive-nav__live-dot--connected {
animation: none;
}
.adaptive-nav__mobile-drawer {
animation: none;
}
}

View File

@@ -0,0 +1,53 @@
import { ChangeDetectionStrategy, Component, signal } from '@angular/core';
import { RouterLink, RouterLinkActive } from '@angular/router';
import { MatIconModule } from '@angular/material/icon';
import { MatButtonModule } from '@angular/material/button';
import { MatChipsModule } from '@angular/material/chips';
import { MatBadgeModule } from '@angular/material/badge';
import { NAV_DESTINATIONS } from '../../models/nav.model';
/**
* Adaptive Navigation Component — switches between desktop sidebar
* and mobile header layouts using CSS media queries.
*
* Desktop (≥768px): 72px sidebar with full navigation items.
* Mobile (<768px): 56px compact header with hamburger menu.
*
* The LIVE status indicator is visible in both layouts.
* Per spec Section 3.1 (kiosk) and 3.2 (mobile).
*/
@Component({
selector: 'app-adaptive-navigation',
standalone: true,
imports: [
RouterLink,
RouterLinkActive,
MatIconModule,
MatButtonModule,
MatChipsModule,
MatBadgeModule,
],
templateUrl: './adaptive-navigation.component.html',
styleUrl: './adaptive-navigation.component.scss',
changeDetection: ChangeDetectionStrategy.OnPush,
})
export class AdaptiveNavigationComponent {
/** Navigation destinations shared with other nav components */
protected readonly destinations = NAV_DESTINATIONS;
/** Whether the mobile drawer is open */
protected readonly mobileMenuOpen = signal(false);
/** Live connection status */
protected readonly isConnected = signal(true);
/** Toggle mobile menu */
toggleMobileMenu(): void {
this.mobileMenuOpen.update((v) => !v);
}
/** Close mobile menu (e.g. on nav) */
closeMobileMenu(): void {
this.mobileMenuOpen.set(false);
}
}

View File

@@ -0,0 +1 @@
export * from './adaptive-navigation.component';

View File

@@ -0,0 +1,8 @@
<span class="badge"
[class]="statusClass"
[class.badge--pulse]="hasPulse"
[attr.aria-label]="'Agent status: ' + displayLabel"
role="status">
<span class="badge__dot"></span>
<span class="badge__label">{{ displayLabel }}</span>
</span>

View File

@@ -0,0 +1,146 @@
// ============================================================================
// Agent Status Badge — per spec Section 7.3
// Colored pill with dot indicator and optional pulse animation.
// ============================================================================
$badge-height: 24px;
$dot-size: 8px;
$border-radius: 12px;
$font-size: 12px;
$font-weight: 500;
$padding-x: 8px;
$gap: 6px;
@use 'sass:color';
// Status color palette
$color-active: #22c55e; // green-500
$color-idle: #9ca3af; // gray-400
$color-thinking: #3b82f6; // blue-500
$color-error: #ef4444; // red-500
$color-offline: #9ca3af; // gray-400
// Background tints (12% opacity for soft pill background)
$bg-active: rgba($color-active, 0.12);
$bg-idle: rgba($color-idle, 0.12);
$bg-thinking: rgba($color-thinking, 0.12);
$bg-error: rgba($color-error, 0.12);
$bg-offline: rgba($color-offline, 0.12);
// ---------------------------------------------------------------------------
// Base pill
// ---------------------------------------------------------------------------
.badge {
display: inline-flex;
align-items: center;
height: $badge-height;
padding: 0 $padding-x;
border-radius: $border-radius;
gap: $gap;
font-size: $font-size;
font-weight: $font-weight;
line-height: 1;
white-space: nowrap;
user-select: none;
}
// ---------------------------------------------------------------------------
// Dot indicator
// ---------------------------------------------------------------------------
.badge__dot {
width: $dot-size;
height: $dot-size;
border-radius: 50%;
flex-shrink: 0;
}
// ---------------------------------------------------------------------------
// Label text
// ---------------------------------------------------------------------------
.badge__label {
line-height: 1;
}
// ---------------------------------------------------------------------------
// Status color variants
// ---------------------------------------------------------------------------
.badge--active {
background: $bg-active;
color: color.adjust($color-active, $lightness: -10%);
.badge__dot {
background: $color-active;
}
}
.badge--idle {
background: $bg-idle;
color: color.adjust($color-idle, $lightness: -15%);
.badge__dot {
background: $color-idle;
}
}
.badge--thinking {
background: $bg-thinking;
color: color.adjust($color-thinking, $lightness: -10%);
.badge__dot {
background: $color-thinking;
}
}
.badge--error {
background: $bg-error;
color: color.adjust($color-error, $lightness: -10%);
.badge__dot {
background: $color-error;
}
}
.badge--offline {
background: $bg-offline;
color: color.adjust($color-offline, $lightness: -15%);
.badge__dot {
background: $color-offline;
}
}
// ---------------------------------------------------------------------------
// Pulse animation — applied when status is active, thinking, or error
// ---------------------------------------------------------------------------
.badge--pulse {
.badge__dot {
animation: pulse-dot 2s ease-in-out infinite;
}
}
// Active: 2s pulse
.badge--active.badge--pulse .badge__dot {
animation-duration: 2s;
}
// Thinking: 3s pulse
.badge--thinking.badge--pulse .badge__dot {
animation-duration: 3s;
}
// Error: 0.8s pulse (fast, urgent)
.badge--error.badge--pulse .badge__dot {
animation-duration: 0.8s;
}
@keyframes pulse-dot {
0%,
100% {
opacity: 1;
transform: scale(1);
}
50% {
opacity: 0.4;
transform: scale(1.5);
}
}

View File

@@ -0,0 +1,54 @@
import { ChangeDetectionStrategy, Component, input } from '@angular/core';
import { AgentStatus } from '../../models/agent.model';
/**
* Agent Status Badge component.
* Displays a colored pill with a pulse animation indicating the agent's current status.
* Per spec Section 7.3: Agent Card Component Interface — status indicator.
*
* Color mapping:
* - Active → green
* - Idle → gray
* - Thinking → blue
* - Error → red
* - Offline → gray (no pulse)
*
* Pulse animations:
* - Active → 2s
* - Error → 0.8s
* - Thinking → 3s
* - Idle / Offline → no pulse
*/
@Component({
selector: 'app-agent-status-badge',
standalone: true,
imports: [],
templateUrl: './agent-status-badge.component.html',
styleUrl: './agent-status-badge.component.scss',
changeDetection: ChangeDetectionStrategy.OnPush,
})
export class AgentStatusBadgeComponent {
/** Current agent status — binds to the AgentStatus type from the model. */
readonly status = input.required<AgentStatus>();
/** Label text shown inside the badge. Defaults to title-cased status. */
readonly label = input<string>();
get displayLabel(): string {
return this.label() ?? this.titleCase(this.status());
}
/** CSS class driven by the current status value. */
get statusClass(): string {
return `badge--${this.status()}`;
}
/** Whether the pulse animation should be active for the current status. */
get hasPulse(): boolean {
return this.status() === 'active' || this.status() === 'thinking' || this.status() === 'error';
}
private titleCase(value: string): string {
return value.charAt(0).toUpperCase() + value.slice(1);
}
}

View File

@@ -0,0 +1 @@
export { AgentStatusBadgeComponent } from './agent-status-badge.component';

View File

@@ -0,0 +1 @@
export { AgentStatusBadgeComponent } from './agent-status-badge/agent-status-badge.component';

View File

@@ -1,120 +0,0 @@
<!-- ============================================================================
Minion Component Template — 16-bit Breakroom Minion
Per CUB-60: Minion State & Animation System
============================================================================ -->
<div
class="minion"
[ngClass]="[stateClass(), sideClass()]"
[style.--desk-index]="deskPosition()"
[attr.aria-label]="displayLabel() + ' ' + stateLabel()"
role="img"
>
<!-- Progress bar (only shown when working) -->
@if (showProgress()) {
<div class="minion__progress-bar">
<mat-progress-bar
mode="determinate"
[value]="currentProgress()"
[attr.aria-label]="'Task progress: ' + currentProgress() + '%'"
></mat-progress-bar>
</div>
}
<!-- Name label above the minion -->
<div class="minion__label">{{ displayLabel() }}</div>
<!-- Minion sprite container -->
<div
class="minion__sprite"
(animationend)="onAnimationEnd($event)"
>
<!-- Idle state: banana-eating / TV-watching minion -->
@if (currentState() === 'idle') {
<div class="minion__character minion__character--idle">
<div class="minion__body">
<div class="minion__head">
<div class="minion__eye minion__eye--left"></div>
<div class="minion__eye minion__eye--right"></div>
<div class="minion__mouth minion__mouth--smile"></div>
</div>
<div class="minion__torso"></div>
<div class="minion__arm minion__arm--left minion__arm--eating"></div>
<div class="minion__arm minion__arm--right"></div>
<div class="minion__leg minion__leg--left"></div>
<div class="minion__leg minion__leg--right"></div>
</div>
<!-- Banana in hand -->
<div class="minion__banana minion__banana--idle"></div>
</div>
}
<!-- Walking state: minion walking to desk -->
@if (currentState() === 'walking') {
<div class="minion__character minion__character--walking">
<div class="minion__body">
<div class="minion__head">
<div class="minion__eye minion__eye--left"></div>
<div class="minion__eye minion__eye--right"></div>
<div class="minion__mouth minion__mouth--determined"></div>
</div>
<div class="minion__torso"></div>
<div class="minion__arm minion__arm--left minion__arm--swing"></div>
<div class="minion__arm minion__arm--right minion__arm--swing minion__arm--swing-alt"></div>
<div class="minion__leg minion__leg--left minion__leg--walk"></div>
<div class="minion__leg minion__leg--right minion__leg--walk minion__leg--walk-alt"></div>
</div>
</div>
}
<!-- Working state: minion at desk typing -->
@if (currentState() === 'working') {
<div class="minion__character minion__character--working">
<div class="minion__body">
<div class="minion__head">
<div class="minion__eye minion__eye--left minion__eye--focused"></div>
<div class="minion__eye minion__eye--right minion__eye--focused"></div>
<div class="minion__mouth minion__mouth--focused"></div>
</div>
<div class="minion__torso"></div>
<div class="minion__arm minion__arm--left minion__arm--typing"></div>
<div class="minion__arm minion__arm--right minion__arm--typing minion__arm--typing-alt"></div>
</div>
<!-- Laptop -->
<div class="minion__laptop">
<div class="minion__laptop-screen">
<div class="minion__laptop-code minion__laptop-code--1"></div>
<div class="minion__laptop-code minion__laptop-code--2"></div>
<div class="minion__laptop-code minion__laptop-code--3"></div>
</div>
<div class="minion__laptop-base"></div>
</div>
</div>
}
<!-- Returning state: minion walking back to breakroom -->
@if (currentState() === 'returning') {
<div class="minion__character minion__character--returning">
<div class="minion__body">
<div class="minion__head">
<div class="minion__eye minion__eye--left"></div>
<div class="minion__eye minion__eye--right"></div>
<div class="minion__mouth minion__mouth--happy"></div>
</div>
<div class="minion__torso"></div>
<div class="minion__arm minion__arm--left minion__arm--swing minion__arm--swing-alt"></div>
<div class="minion__arm minion__arm--right minion__arm--swing"></div>
<div class="minion__leg minion__leg--left minion__leg--walk minion__leg--walk-alt"></div>
<div class="minion__leg minion__leg--right minion__leg--walk"></div>
</div>
<!-- Banana (excited to be back!) -->
<div class="minion__banana minion__banana--carried"></div>
</div>
}
</div>
<!-- Task description (shown when working) -->
@if (currentState() === 'working' && currentTaskLabel()) {
<div class="minion__task-label">{{ currentTaskLabel() }}</div>
}
</div>

View File

@@ -1,747 +0,0 @@
// ============================================================================
// Minion Component Styles — 16-bit Breakroom Animation System
// Per CUB-60: Minion State & Animation System
// ============================================================================
// ---------------------------------------------------------------------------
// Pixel Art Scale & Dimensions
// ---------------------------------------------------------------------------
$pixel: 4px; // Base pixel unit for 16-bit aesthetic
$minion-width: 48px;
$minion-height: 64px;
$head-size: 24px;
$body-width: 32px;
$body-height: 24px;
$leg-width: 8px;
$leg-height: 16px;
$arm-width: 6px;
$arm-height: 16px;
// ---------------------------------------------------------------------------
// Colors — Retro Palette
// ---------------------------------------------------------------------------
$minion-skin: #FFD93D;
$minion-skin-shadow: #E6B800;
$minion-overalls: #4169E1;
$minion-overalls-shadow: #2E4FA0;
$minion-goggle: #C0C0C0;
$minion-goggle-strap: #333333;
$minion-eye: #FFFFFF;
$minion-pupil: #1A1A1A;
$minion-mouth: #8B0000;
$minion-banana: #FFE135;
$minion-banana-shadow: #DAA520;
$minion-laptop: #2D2D2D;
$minion-laptop-screen: #0A1628;
$minion-laptop-code: #38BDF8;
$walk-duration: 2s;
$type-duration: 0.4s;
$eat-duration: 1.2s;
$return-duration: 2s;
// ---------------------------------------------------------------------------
// Keyframe Animations
// ---------------------------------------------------------------------------
// Walking animation — bounce + translate right
@keyframes minionWalkRight {
0% {
transform: translateX(0) translateY(0);
}
12.5% {
transform: translateX(12.5%) translateY(-3px);
}
25% {
transform: translateX(25%) translateY(0);
}
37.5% {
transform: translateX(37.5%) translateY(-3px);
}
50% {
transform: translateX(50%) translateY(0);
}
62.5% {
transform: translateX(62.5%) translateY(-3px);
}
75% {
transform: translateX(75%) translateY(0);
}
87.5% {
transform: translateX(87.5%) translateY(-3px);
}
100% {
transform: translateX(100%) translateY(0);
}
}
// Returning animation — bounce + translate left
@keyframes minionWalkLeft {
0% {
transform: translateX(0) translateY(0);
}
12.5% {
transform: translateX(-12.5%) translateY(-3px);
}
25% {
transform: translateX(-25%) translateY(0);
}
37.5% {
transform: translateX(-37.5%) translateY(-3px);
}
50% {
transform: translateX(-50%) translateY(0);
}
62.5% {
transform: translateX(-62.5%) translateY(-3px);
}
75% {
transform: translateX(-75%) translateY(0);
}
87.5% {
transform: translateX(-87.5%) translateY(-3px);
}
100% {
transform: translateX(-100%) translateY(0);
}
}
// Typing animation — alternate arm bob
@keyframes minionType {
0%, 100% {
transform: translateY(0);
}
50% {
transform: translateY(-2px);
}
}
// Arm swing during walking
@keyframes armSwing {
0%, 100% {
transform: rotate(0deg);
}
25% {
transform: rotate(25deg);
}
75% {
transform: rotate(-25deg);
}
}
// Alternate arm swing (opposite phase)
@keyframes armSwingAlt {
0%, 100% {
transform: rotate(0deg);
}
25% {
transform: rotate(-25deg);
}
75% {
transform: rotate(25deg);
}
}
// Leg walk cycle
@keyframes legWalk {
0%, 100% {
transform: translateY(0);
}
50% {
transform: translateY(-4px);
}
}
// Alternate leg walk cycle
@keyframes legWalkAlt {
0%, 100% {
transform: translateY(-4px);
}
50% {
transform: translateY(0);
}
}
// Banana eating — arm to mouth bob
@keyframes bananaEat {
0%, 100% {
transform: rotate(-15deg) translateY(0);
}
50% {
transform: rotate(-15deg) translateY(-4px);
}
}
// Mouth chewing
@keyframes mouthChew {
0%, 40%, 100% {
transform: scaleY(1);
}
20% {
transform: scaleY(0.6);
}
}
// Happy mouth (returning)
@keyframes mouthHappy {
0%, 100% {
transform: scaleY(1);
}
50% {
transform: scaleY(1.15);
}
}
// Laptop code blink
@keyframes codeBlink {
0%, 40%, 100% {
opacity: 1;
}
50% {
opacity: 0.3;
}
}
// Determined face blink
@keyframes eyeBlink {
0%, 90%, 100% {
transform: scaleY(1);
}
95% {
transform: scaleY(0.1);
}
}
// Idle float (subtle bounce)
@keyframes idleFloat {
0%, 100% {
transform: translateY(0);
}
50% {
transform: translateY(-2px);
}
}
// ---------------------------------------------------------------------------
// Minion Root Container
// ---------------------------------------------------------------------------
.minion {
display: flex;
flex-direction: column;
align-items: center;
position: relative;
width: 80px;
image-rendering: pixelated;
}
// ---------------------------------------------------------------------------
// Progress Bar (above head)
// ---------------------------------------------------------------------------
.minion__progress-bar {
width: 60px;
margin-bottom: 4px;
.mat-mdc-progress-bar {
--mdc-linear-progress-active-indicator-color: var(--status-active);
--mdc-linear-progress-track-color: var(--cc-surface-container-high);
height: 4px;
border-radius: 2px;
}
}
// ---------------------------------------------------------------------------
// Name Label
// ---------------------------------------------------------------------------
.minion__label {
font-size: 11px;
font-weight: 600;
color: var(--cc-on-surface);
text-transform: uppercase;
letter-spacing: 0.05em;
margin-bottom: 2px;
white-space: nowrap;
text-overflow: ellipsis;
overflow: hidden;
max-width: 80px;
text-align: center;
}
// ---------------------------------------------------------------------------
// Sprite Container
// ---------------------------------------------------------------------------
.minion__sprite {
position: relative;
width: $minion-width;
height: $minion-height;
overflow: visible;
}
// ---------------------------------------------------------------------------
// Character Base
// ---------------------------------------------------------------------------
.minion__character {
position: absolute;
width: $minion-width;
height: $minion-height;
}
// ---------------------------------------------------------------------------
// Idle State — Banana eating, gentle bounce
// ---------------------------------------------------------------------------
.minion__character--idle {
animation: idleFloat 3s ease-in-out infinite;
.minion__body {
animation: idleFloat 3s ease-in-out infinite;
}
}
// ---------------------------------------------------------------------------
// Walking State — Move right to desk
// ---------------------------------------------------------------------------
.minion__character--walking {
animation: minionWalkRight $walk-duration ease-in-out forwards;
}
// ---------------------------------------------------------------------------
// Working State — At desk, typing
// ---------------------------------------------------------------------------
.minion__character--working {
// No movement animation — static at desk
}
// ---------------------------------------------------------------------------
// Returning State — Move left back to breakroom
// ---------------------------------------------------------------------------
.minion__character--returning {
animation: minionWalkLeft $return-duration ease-in-out forwards;
}
// ---------------------------------------------------------------------------
// Body Parts — 16-bit Pixel Art
// ---------------------------------------------------------------------------
.minion__body {
position: relative;
width: $minion-width;
height: $minion-height;
}
// Head — yellow capsule with goggles
.minion__head {
position: absolute;
top: 0;
left: 50%;
transform: translateX(-50%);
width: $head-size;
height: $head-size;
background-color: $minion-skin;
border-radius: 50% 50% 40% 40%;
border: 2px solid $minion-skin-shadow;
overflow: hidden;
z-index: 2;
// Goggle strap
&::before {
content: '';
position: absolute;
top: 30%;
left: -2px;
right: -2px;
height: 10px;
background-color: $minion-goggle-strap;
border-radius: 2px;
}
}
// Eyes (inside goggle area)
.minion__eye {
position: absolute;
top: 35%;
width: 8px;
height: 8px;
background-color: $minion-eye;
border-radius: 50%;
border: 1px solid #666;
z-index: 3;
&::after {
content: '';
position: absolute;
top: 50%;
left: 50%;
transform: translate(-50%, -50%);
width: 4px;
height: 4px;
background-color: $minion-pupil;
border-radius: 50%;
}
&--left {
left: 3px;
}
&--right {
right: 3px;
}
// Focused eyes (squint) for working state
&--focused {
height: 6px;
animation: eyeBlink 4s step-end infinite;
}
}
// Mouth expressions
.minion__mouth {
position: absolute;
bottom: 4px;
left: 50%;
transform: translateX(-50%);
width: 8px;
height: 4px;
border-radius: 0 0 4px 4px;
z-index: 3;
&--smile {
background-color: $minion-mouth;
border-radius: 0 0 50% 50%;
animation: mouthChew $eat-duration ease-in-out infinite;
}
&--determined {
background-color: $minion-mouth;
width: 10px;
height: 3px;
border-radius: 0;
}
&--focused {
background-color: $minion-mouth;
width: 6px;
height: 3px;
border-radius: 0;
}
&--happy {
background-color: $minion-mouth;
width: 10px;
height: 5px;
border-radius: 0 0 50% 50%;
animation: mouthHappy 1.5s ease-in-out infinite;
}
}
// Torso / Overalls
.minion__torso {
position: absolute;
top: $head-size - 4px;
left: 50%;
transform: translateX(-50%);
width: $body-width;
height: $body-height;
background-color: $minion-overalls;
border: 2px solid $minion-overalls-shadow;
border-radius: 4px 4px 2px 2px;
z-index: 1;
// Overall strap left
&::before {
content: '';
position: absolute;
top: -4px;
left: 6px;
width: 3px;
height: 8px;
background-color: $minion-overalls;
border-radius: 1px;
}
// Overall strap right
&::after {
content: '';
position: absolute;
top: -4px;
right: 6px;
width: 3px;
height: 8px;
background-color: $minion-overalls;
border-radius: 1px;
}
}
// Arms
.minion__arm {
position: absolute;
top: $head-size;
width: $arm-width;
height: $arm-height;
background-color: $minion-skin;
border: 1px solid $minion-skin-shadow;
border-radius: 3px;
z-index: 0;
transform-origin: top center;
&--left {
left: 2px;
}
&--right {
right: 2px;
}
// Arm swing during walking
&--swing {
animation: armSwing $walk-duration * 0.5 ease-in-out infinite;
}
&--swing-alt {
animation: armSwingAlt $walk-duration * 0.5 ease-in-out infinite;
}
// Arm raised for eating banana
&--eating {
transform: rotate(-15deg);
animation: bananaEat $eat-duration ease-in-out infinite;
}
// Arms typing on laptop
&--typing {
transform: rotate(10deg) translateY(2px);
&.minion__arm--typing-alt {
transform: rotate(-10deg) translateY(2px);
animation: minionType $type-duration ease-in-out infinite;
}
}
}
// Legs
.minion__leg {
position: absolute;
bottom: 0;
width: $leg-width;
height: $leg-height;
background-color: $minion-overalls;
border: 1px solid $minion-overalls-shadow;
border-radius: 2px 2px 3px 3px;
z-index: 0;
&--left {
left: calc(50% - #{$leg-width} - 2px);
}
&--right {
right: calc(50% - #{$leg-width} - 2px);
}
// Walking cycle
&--walk {
animation: legWalk $walk-duration * 0.25 ease-in-out infinite;
&.minion__leg--walk-alt {
animation: legWalkAlt $walk-duration * 0.25 ease-in-out infinite;
}
}
}
// ---------------------------------------------------------------------------
// Banana
// ---------------------------------------------------------------------------
.minion__banana {
position: absolute;
width: 8px;
height: 5px;
z-index: 4;
&::before {
content: '';
position: absolute;
width: 8px;
height: 5px;
background-color: $minion-banana;
border: 1px solid $minion-banana-shadow;
border-radius: 50% 50% 20% 20%;
}
// Banana in hand during idle
&--idle {
top: $head-size - 2px;
right: 0;
}
// Banana carried while returning
&--carried {
top: 8px;
left: -2px;
transform: rotate(20deg);
}
}
// ---------------------------------------------------------------------------
// Laptop (working state)
// ---------------------------------------------------------------------------
.minion__laptop {
position: absolute;
bottom: 0;
left: 50%;
transform: translateX(-50%);
width: 40px;
z-index: 2;
}
.minion__laptop-screen {
width: 36px;
height: 20px;
background-color: $minion-laptop-screen;
border: 2px solid $minion-laptop;
border-radius: 3px 3px 0 0;
margin: 0 auto;
overflow: hidden;
display: flex;
flex-direction: column;
justify-content: center;
gap: 2px;
padding: 3px;
}
.minion__laptop-code {
height: 2px;
background-color: $minion-laptop-code;
border-radius: 1px;
opacity: 0.8;
&--1 {
width: 80%;
animation: codeBlink 2s ease-in-out infinite;
}
&--2 {
width: 60%;
animation: codeBlink 2s ease-in-out infinite 0.3s;
}
&--3 {
width: 70%;
animation: codeBlink 2s ease-in-out infinite 0.6s;
}
}
.minion__laptop-base {
width: 40px;
height: 3px;
background-color: $minion-laptop;
border-radius: 0 0 2px 2px;
margin: 0 auto;
}
// ---------------------------------------------------------------------------
// Task Label (below minion)
// ---------------------------------------------------------------------------
.minion__task-label {
font-size: 9px;
color: var(--cc-on-surface-variant);
text-align: center;
max-width: 80px;
white-space: nowrap;
overflow: hidden;
text-overflow: ellipsis;
margin-top: 2px;
font-family: var(--cc-font-mono);
}
// ---------------------------------------------------------------------------
// Side-specific adjustments
// ---------------------------------------------------------------------------
// Dev minions face right (walk right to desk)
.minion--dev .minion__character--walking {
animation-name: minionWalkRight;
}
// Business minions face left (walk left to desk)
.minion--business .minion__character--walking {
animation-name: minionWalkRight;
transform: scaleX(-1);
}
// Returning always walks back toward breakroom
.minion--dev .minion__character--returning {
animation-name: minionWalkLeft;
}
.minion--business .minion__character--returning {
animation-name: minionWalkLeft;
transform: scaleX(-1);
}
// ---------------------------------------------------------------------------
// Walking sprite shows walking animation
// ---------------------------------------------------------------------------
.minion--walking .minion__sprite {
animation: minionWalkRight $walk-duration ease-in-out forwards;
}
.minion--returning .minion__sprite {
animation: minionWalkLeft $return-duration ease-in-out forwards;
}
// ---------------------------------------------------------------------------
// Accessibility: Reduced Motion
// ---------------------------------------------------------------------------
@media (prefers-reduced-motion: reduce) {
.minion__character--idle,
.minion__character--walking,
.minion__character--returning,
.minion--walking .minion__sprite,
.minion--returning .minion__sprite {
animation: none;
}
.minion__arm--swing,
.minion__arm--swing-alt,
.minion__arm--eating,
.minion__arm--typing.minion__arm--typing-alt,
.minion__leg--walk,
.minion__leg--walk-alt,
.minion__mouth--smile,
.minion__mouth--happy,
.minion__eye--focused,
.minion__laptop-code--1,
.minion__laptop-code--2,
.minion__laptop-code--3 {
animation: none;
}
}
// ---------------------------------------------------------------------------
// Touch-friendly sizing
// ---------------------------------------------------------------------------
.minion {
min-width: 80px;
min-height: 100px;
// Ensure touch targets are at least 48px
.minion__sprite {
min-width: 48px;
min-height: 48px;
}
}
// ---------------------------------------------------------------------------
// Responsive: Smaller on mobile
// ---------------------------------------------------------------------------
@media (max-width: 599px) {
$mobile-scale: 0.85;
.minion {
width: 68px;
}
.minion__sprite {
transform: scale($mobile-scale);
transform-origin: top center;
}
.minion__label {
font-size: 10px;
}
}

View File

@@ -1,182 +0,0 @@
// ============================================================================
// Minion Component — 16-bit Breakroom Minion with State Animations
// Per CUB-60: Minion State & Animation System
// ============================================================================
import {
ChangeDetectionStrategy,
Component,
OnDestroy,
OnInit,
input,
output,
signal,
computed,
effect,
inject,
} from '@angular/core';
import { CommonModule } from '@angular/common';
import { MatIconModule } from '@angular/material/icon';
import { MatProgressBarModule } from '@angular/material/progress-bar';
import { MatTooltipModule } from '@angular/material/tooltip';
import { MinionState, MinionSide } from '../../models/minion.model';
import { MinionStateService } from '../../services/minion-state.service';
/**
* MinionComponent renders a single 16-bit minion character with four visual states:
* - idle: In breakroom — eating bananas, watching TV
* - walking: Moving from breakroom to desk (2s animation, then auto → working)
* - working: At desk — typing on laptop, progress bar overhead
* - returning: Walking back to breakroom (2s animation, then auto → idle)
*
* The component reads its state from MinionStateService and emits events
* when animations complete so the service can advance the state machine.
*/
@Component({
selector: 'app-minion',
standalone: true,
imports: [
CommonModule,
MatIconModule,
MatProgressBarModule,
MatTooltipModule,
],
templateUrl: './minion.component.html',
styleUrl: './minion.component.scss',
changeDetection: ChangeDetectionStrategy.OnPush,
})
export class MinionComponent implements OnInit, OnDestroy {
/** Agent name — used to look up state from MinionStateService */
readonly agentName = input.required<string>();
/** Which side of the office: dev or business */
readonly side = input<MinionSide>('dev');
/** Desk index on the assigned side (0-based) */
readonly deskIndex = input<number>(0);
/** Override state (for standalone demo use, otherwise read from service) */
readonly state = input<MinionState>('idle');
/** Override progress (for standalone demo use) */
readonly progress = input<number>(0);
/** Override display name (for standalone demo use) */
readonly displayName = input<string>('');
/** Override task description (for standalone demo use) */
readonly currentTask = input<string>('');
/** Emits when the walking animation completes */
readonly walkingComplete = output<string>();
/** Emits when the returning animation completes */
readonly returningComplete = output<string>();
private readonly minionStateService = inject(MinionStateService);
/** Track whether to use service data or input data */
private readonly useServiceData = signal(false);
/** Animation state — tracks which animation is active */
readonly animationState = signal<MinionState | 'none'>('none');
/** Computed: current state (from service if available, otherwise input) */
readonly currentState = computed<MinionState>(() => {
if (this.useServiceData()) {
const minion = this.minionStateService.getMinion(this.agentName());
return minion?.state ?? this.state();
}
return this.state();
});
/** Computed: current progress */
readonly currentProgress = computed(() => {
if (this.useServiceData()) {
const minion = this.minionStateService.getMinion(this.agentName());
return minion?.progress ?? this.progress();
}
return this.progress();
});
/** Computed: display name */
readonly displayLabel = computed(() => {
if (this.useServiceData()) {
const minion = this.minionStateService.getMinion(this.agentName());
return minion?.displayName ?? this.displayName() ?? this.agentName();
}
return this.displayName() || this.agentName();
});
/** Computed: current task */
readonly currentTaskLabel = computed(() => {
if (this.useServiceData()) {
const minion = this.minionStateService.getMinion(this.agentName());
return minion?.currentTask ?? this.currentTask() ?? '';
}
return this.currentTask();
});
/** Computed: CSS class based on current state */
readonly stateClass = computed(() => `minion--${this.currentState()}`);
/** Computed: whether to show the progress bar */
readonly showProgress = computed(() => this.currentState() === 'working' && this.currentProgress() > 0);
/** Computed: side class */
readonly sideClass = computed(() => `minion--${this.side()}`);
/** Computed: position style for desk assignment */
readonly deskPosition = computed(() => this.deskIndex());
/** Computed: human-readable state label */
readonly stateLabel = computed(() => {
const labels: Record<MinionState, string> = {
idle: 'On Break',
walking: 'Heading to Desk',
working: 'Working',
returning: 'Returning to Breakroom',
};
return labels[this.currentState()];
});
ngOnInit(): void {
// If the service has data for this agent, use it
const minion = this.minionStateService.getMinion(this.agentName());
if (minion) {
this.useServiceData.set(true);
}
// Sync animation state with current state
this.animationState.set(this.currentState());
}
/**
* Handle animation end events from CSS animations.
* Only fires for walking/returning which have finite durations.
*/
onAnimationEnd(event: AnimationEvent): void {
const state = this.currentState();
if (state === 'walking' && event.animationName === 'minionWalkRight') {
this.walkingComplete.emit(this.agentName());
// Auto-transition walking → working via service
if (this.useServiceData()) {
this.minionStateService.onWalkingComplete(this.agentName());
}
this.animationState.set('working');
}
if (state === 'returning' && event.animationName === 'minionWalkLeft') {
this.returningComplete.emit(this.agentName());
// Auto-transition returning → idle via service
if (this.useServiceData()) {
this.minionStateService.onReturningComplete(this.agentName());
}
this.animationState.set('idle');
}
}
ngOnDestroy(): void {
// Cleanup handled by service if needed
}
}

View File

@@ -0,0 +1,6 @@
// ============================================================================
// Task Progress Bar — Barrel Export
// CUB-44
// ============================================================================
export { TaskProgressBarComponent } from './task-progress-bar.component';

View File

@@ -0,0 +1,18 @@
<!-- Task Progress Bar: determinate progress with optional elapsed time -->
<div class="task-progress-bar">
<!-- Info row: percentage + optional elapsed -->
<div class="task-progress-bar__info">
<span class="task-progress-bar__percent">{{ clampedProgress }}%</span>
<span *ngIf="showElapsed" class="task-progress-bar__elapsed">
{{ elapsedText }}
</span>
</div>
<!-- Angular Material determinate progress bar -->
<mat-progress-bar
class="task-progress-bar__bar"
mode="determinate"
[value]="clampedProgress"
aria-label="Task progress"
></mat-progress-bar>
</div>

View File

@@ -0,0 +1,77 @@
// ============================================================================
// Task Progress Bar — Tactical Dark Theme Styling
// Per CUB-44: Uses --color-primary for bar fill and --color-surface-light
// for track background, mapped to the Control Center's M3 dark tokens.
// ============================================================================
// ---------------------------------------------------------------------------
// Container
// ---------------------------------------------------------------------------
.task-progress-bar {
display: flex;
flex-direction: column;
gap: 6px;
width: 100%;
}
// ---------------------------------------------------------------------------
// Info row: percentage label + elapsed time
// ---------------------------------------------------------------------------
.task-progress-bar__info {
display: flex;
align-items: baseline;
justify-content: space-between;
gap: 8px;
}
.task-progress-bar__percent {
font-family: var(--cc-font-mono, 'Roboto Mono', monospace);
font-size: 14px;
font-weight: 600;
color: var(--cc-on-surface, #E2E8F0);
letter-spacing: 0.02em;
}
.task-progress-bar__elapsed {
font-family: var(--cc-font-mono, 'Roboto Mono', monospace);
font-size: 12px;
font-weight: 400;
color: var(--cc-on-surface-variant, #8A9BB0);
letter-spacing: 0.01em;
}
// ---------------------------------------------------------------------------
// Material Progress Bar Overrides
// ---------------------------------------------------------------------------
// Map the spec's --color-primary and --color-surface-light to the Control
// Center's actual theme tokens. This ensures the bar uses the tactical dark
// palette while respecting the spec's variable naming.
// ---------------------------------------------------------------------------
.task-progress-bar__bar {
// Override the track (background) to use the surface container
--mat-progress-bar-track-height: 6px;
--mat-progress-bar-active-indicator-height: 6px;
// Bar fill color: primary (cyan/sky blue per tactical dark theme)
--mat-progress-bar-active-indicator-color: var(--color-primary, var(--mat-sys-primary, #38BDF8));
// Track background: surface container (dark slate)
--mat-progress-bar-track-color: var(--color-surface-light, var(--cc-surface-container, #1C2027));
// Border radius for a softer bar
border-radius: 3px;
// Smooth transition on value changes
transition: none;
}
// Rounded ends on the progress bar fill
:host ::ng-deep .mdc-linear-progress__bar-inner {
border-radius: 3px;
}
// Rounded track background
:host ::ng-deep .mdc-linear-progress__track {
border-radius: 3px;
}

View File

@@ -0,0 +1,109 @@
// ============================================================================
// Task Progress Bar Component
// Per CUB-44: Determinate progress bar with optional elapsed time display.
// Uses Angular Material mat-progress-bar in determinate mode with tactical
// dark theme styling via CSS custom properties.
// ============================================================================
import {
ChangeDetectionStrategy,
ChangeDetectorRef,
Component,
Input,
OnDestroy,
OnInit,
} from '@angular/core';
import { CommonModule } from '@angular/common';
import { MatProgressBarModule } from '@angular/material/progress-bar';
/**
* Displays a determinate progress bar with an optional elapsed time indicator.
*
* Usage:
* ```html
* <app-task-progress-bar [progress]="65" />
* <app-task-progress-bar [progress]="42" [showElapsed]="true" />
* ```
*/
@Component({
selector: 'app-task-progress-bar',
standalone: true,
imports: [CommonModule, MatProgressBarModule],
templateUrl: './task-progress-bar.component.html',
styleUrl: './task-progress-bar.component.scss',
changeDetection: ChangeDetectionStrategy.OnPush,
})
export class TaskProgressBarComponent implements OnInit, OnDestroy {
// ---------------------------------------------------------------------------
// Inputs
// ---------------------------------------------------------------------------
/** Current progress percentage (0100). Required. */
@Input({ required: true })
progress!: number;
/** Whether to show elapsed time next to the percentage. Defaults to false. */
@Input()
showElapsed = false;
// ---------------------------------------------------------------------------
// Internal state
// ---------------------------------------------------------------------------
/** Timestamp when the component initialized — used for elapsed calculation. */
startTime = Date.now();
/** Formatted elapsed time string, e.g. "2m 15s ago". */
elapsedText = '';
/** Interval timer for updating the elapsed display. */
private timer: ReturnType<typeof setInterval> | null = null;
constructor(private cdr: ChangeDetectorRef) {}
// ---------------------------------------------------------------------------
// Lifecycle
// ---------------------------------------------------------------------------
ngOnInit(): void {
this.updateElapsed();
if (this.showElapsed) {
// Update elapsed time every second
this.timer = setInterval(() => {
this.updateElapsed();
this.cdr.markForCheck();
}, 1000);
}
}
ngOnDestroy(): void {
if (this.timer) {
clearInterval(this.timer);
this.timer = null;
}
}
// ---------------------------------------------------------------------------
// Helpers
// ---------------------------------------------------------------------------
/** Clamp progress to 0100 for safety. */
get clampedProgress(): number {
return Math.max(0, Math.min(100, this.progress ?? 0));
}
/** Recalculate the elapsed time string. */
private updateElapsed(): void {
const elapsedMs = Date.now() - this.startTime;
const totalSeconds = Math.floor(elapsedMs / 1000);
const minutes = Math.floor(totalSeconds / 60);
const seconds = totalSeconds % 60;
if (minutes > 0) {
this.elapsedText = `${minutes}m ${seconds}s ago`;
} else {
this.elapsedText = `${seconds}s ago`;
}
}
}

View File

@@ -1,3 +1,2 @@
export * from './agent.model'; export * from './agent.model';
export * from './minion.model';
export * from './nav.model'; export * from './nav.model';

View File

@@ -1,81 +0,0 @@
// ============================================================================
// Minion State & Animation Types
// Per CUB-60: Minion State & Animation System
// ============================================================================
/**
* The four minion states in the breakroom UI state machine.
*
* State transitions:
* idle → walking → working → returning → idle
*
* idle: In breakroom — eating bananas, watching TV
* walking: Moving from breakroom to desk
* working: At desk — typing on laptop, progress bar overhead
* returning: Walking back to breakroom after task completion
*/
export type MinionState = 'idle' | 'walking' | 'working' | 'returning';
/**
* Which side of the office the minion belongs to.
* Dev minions walk to dev desks, Business minions to business desks.
*/
export type MinionSide = 'dev' | 'business';
/**
* Event types that trigger state transitions in the MinionStateService.
*/
export type MinionEvent = 'spawn' | 'task_complete' | 'task_error' | 'reset';
/**
* Represents the full state of a single minion in the breakroom.
*/
export interface MinionData {
/** Unique agent name, e.g., "otto", "rex" */
agentName: string;
/** Current minion state */
state: MinionState;
/** Task progress percentage (0100), only meaningful when state === 'working' */
progress: number;
/** Which side of the office: dev or business */
side: MinionSide;
/** Desk index on the assigned side (0-based) */
deskIndex: number;
/** Display name for the minion, e.g., "Otto" */
displayName: string;
/** Current task description */
currentTask?: string;
/** Timestamp of last state transition */
lastTransition: Date;
}
/**
* State machine transition map.
* Defines valid transitions: current state → event → next state.
*/
export const MINION_TRANSITIONS: Record<MinionState, Partial<Record<MinionEvent, MinionState>>> = {
idle: {
spawn: 'walking',
},
walking: {
// walking → working happens automatically via animation end
task_error: 'idle',
reset: 'idle',
},
working: {
task_complete: 'returning',
task_error: 'returning',
reset: 'idle',
},
returning: {
// returning → idle happens automatically via animation end
reset: 'idle',
},
};

View File

@@ -1,136 +0,0 @@
<!-- ============================================================================
Breakroom Page — Demo/Test for Minion State & Animation
Per CUB-60: Validation page with spawn/transition/reset controls
============================================================================ -->
<div class="breakroom">
<!-- Breakroom area (idle minions) -->
<section class="breakroom__zone breakroom__zone--breakroom">
<h2 class="breakroom__zone-title">
<mat-icon>weekend</mat-icon>
Breakroom
</h2>
<div class="breakroom__minions breakroom__minions--idle">
@for (minion of minions(); track minion.agentName) {
@if (minion.state === 'idle') {
<app-minion
[agentName]="minion.agentName"
[side]="minion.side"
[deskIndex]="minion.deskIndex"
[state]="minion.state"
[progress]="minion.progress"
[displayName]="minion.displayName"
/>
}
}
</div>
</section>
<!-- Office area (working desks) -->
<section class="breakroom__zone breakroom__zone--office">
<div class="breakroom__office-header">
<h2 class="breakroom__zone-title">
<mat-icon>computer</mat-icon>
Office
</h2>
</div>
<!-- Dev side -->
<div class="breakroom__desk-row">
<h3 class="breakroom__desk-label">Dev Desks</h3>
<div class="breakroom__desks">
@for (minion of minions(); track minion.agentName) {
@if (minion.side === 'dev' && (minion.state === 'working' || minion.state === 'walking')) {
<div class="breakroom__desk" [style.--desk-index]="minion.deskIndex">
<app-minion
[agentName]="minion.agentName"
[side]="minion.side"
[deskIndex]="minion.deskIndex"
[state]="minion.state"
[progress]="minion.progress"
[displayName]="minion.displayName"
[currentTask]="minion.currentTask ?? ''"
/>
</div>
}
}
</div>
</div>
<!-- Business side -->
<div class="breakroom__desk-row">
<h3 class="breakroom__desk-label">Business Desks</h3>
<div class="breakroom__desks">
@for (minion of minions(); track minion.agentName) {
@if (minion.side === 'business' && (minion.state === 'working' || minion.state === 'walking')) {
<div class="breakroom__desk" [style.--desk-index]="minion.deskIndex">
<app-minion
[agentName]="minion.agentName"
[side]="minion.side"
[deskIndex]="minion.deskIndex"
[state]="minion.state"
[progress]="minion.progress"
[displayName]="minion.displayName"
/>
</div>
}
}
</div>
</div>
</section>
<!-- Control panel for testing -->
<section class="breakroom__controls">
<h2 class="breakroom__zone-title">
<mat-icon>gamepad</mat-icon>
Controls
</h2>
<p class="breakroom__controls-hint">Spawn minions and control their state transitions</p>
<div class="breakroom__button-grid">
@for (demo of demoMinions; track demo.agentName) {
<div class="breakroom__control-row">
<span class="breakroom__agent-name">{{ demo.displayName }}</span>
@if (!isSpawned(demo.agentName)) {
<button mat-raised-button color="primary" (click)="spawnMinion(demo)">
<mat-icon>play_arrow</mat-icon>
Spawn
</button>
} @else {
<span class="breakroom__state-chip">{{ getStateLabel(demo.agentName) }}</span>
<button mat-stroked-button
[disabled]="!minionStateService.getMinion(demo.agentName) || minionStateService.getMinion(demo.agentName)!.state !== 'working'"
(click)="completeTask(demo.agentName)">
<mat-icon>check_circle</mat-icon>
Complete
</button>
<button mat-stroked-button
[disabled]="!minionStateService.getMinion(demo.agentName) || minionStateService.getMinion(demo.agentName)!.state !== 'working'"
(click)="taskError(demo.agentName)">
<mat-icon>error</mat-icon>
Error
</button>
<button mat-stroked-button
[disabled]="!minionStateService.getMinion(demo.agentName) || minionStateService.getMinion(demo.agentName)!.state !== 'working'"
(click)="bumpProgress(demo.agentName)">
<mat-icon>trending_up</mat-icon>
+15%
</button>
<button mat-stroked-button color="warn" (click)="resetMinion(demo.agentName)">
<mat-icon>replay</mat-icon>
Reset
</button>
<button mat-icon-button color="warn" (click)="removeMinion(demo.agentName)">
<mat-icon>close</mat-icon>
</button>
}
</div>
}
</div>
</section>
</div>

View File

@@ -1,209 +0,0 @@
// ============================================================================
// Breakroom Page Styles
// Per CUB-60: Demo/test page for minion state & animation
// ============================================================================
.breakroom {
display: flex;
flex-direction: column;
gap: 24px;
padding: var(--cc-section-padding, 24px);
min-height: 100%;
}
// ---------------------------------------------------------------------------
// Zone (breakroom or office area)
// ---------------------------------------------------------------------------
.breakroom__zone {
background-color: var(--cc-surface-container);
border-radius: var(--cc-card-border-radius, 16px);
padding: var(--cc-card-padding, 20px);
}
.breakroom__zone-title {
display: flex;
align-items: center;
gap: 8px;
margin: 0 0 16px;
font-size: 18px;
font-weight: 600;
color: var(--cc-on-surface);
.mat-icon {
font-size: 20px;
width: 20px;
height: 20px;
}
}
// ---------------------------------------------------------------------------
// Breakroom zone (idle minions)
// ---------------------------------------------------------------------------
.breakroom__zone--breakroom {
background: linear-gradient(
135deg,
var(--cc-surface-container) 0%,
rgba(45, 212, 191, 0.06) 100%
);
min-height: 120px;
}
.breakroom__minions--idle {
display: flex;
flex-wrap: wrap;
gap: 16px;
justify-content: center;
min-height: 80px;
align-items: flex-end;
&:empty::after {
content: 'No minions on break 🍌';
color: var(--cc-on-surface-variant);
font-size: 14px;
text-align: center;
padding: 20px;
display: block;
}
}
// ---------------------------------------------------------------------------
// Office zone (working minions)
// ---------------------------------------------------------------------------
.breakroom__zone--office {
background: linear-gradient(
135deg,
var(--cc-surface-container) 0%,
rgba(56, 189, 248, 0.06) 100%
);
}
.breakroom__desk-row {
margin-bottom: 16px;
}
.breakroom__desk-label {
font-size: 13px;
font-weight: 600;
text-transform: uppercase;
letter-spacing: 0.08em;
color: var(--cc-on-surface-variant);
margin: 0 0 8px;
}
.breakroom__desks {
display: flex;
flex-wrap: wrap;
gap: 20px;
min-height: 100px;
padding: 12px;
border: 2px dashed var(--cc-outline);
border-radius: 12px;
background-color: rgba(0, 0, 0, 0.1);
align-items: flex-end;
&:empty::after {
content: 'No minions at their desks 💻';
color: var(--cc-on-surface-variant);
font-size: 14px;
text-align: center;
padding: 20px;
display: block;
width: 100%;
}
}
.breakroom__desk {
display: flex;
flex-direction: column;
align-items: center;
justify-content: flex-end;
min-width: 90px;
min-height: 110px;
background-color: var(--cc-surface-container-high);
border-radius: 8px;
padding: 8px 4px 4px;
border: 1px solid var(--cc-outline);
}
// ---------------------------------------------------------------------------
// Controls section
// ---------------------------------------------------------------------------
.breakroom__controls {
background-color: var(--cc-surface-container);
border-radius: var(--cc-card-border-radius, 16px);
padding: var(--cc-card-padding, 20px);
}
.breakroom__controls-hint {
font-size: 13px;
color: var(--cc-on-surface-variant);
margin: 0 0 16px;
}
.breakroom__button-grid {
display: flex;
flex-direction: column;
gap: 12px;
}
.breakroom__control-row {
display: flex;
align-items: center;
gap: 8px;
flex-wrap: wrap;
padding: 8px 12px;
background-color: var(--cc-surface);
border-radius: 8px;
min-height: 48px;
}
.breakroom__agent-name {
font-weight: 600;
font-size: 14px;
min-width: 60px;
color: var(--cc-on-surface);
}
.breakroom__state-chip {
font-size: 12px;
font-family: var(--cc-font-mono);
padding: 4px 10px;
border-radius: 12px;
background-color: var(--cc-surface-container-high);
color: var(--cc-on-surface-variant);
border: 1px solid var(--cc-outline);
}
// Button sizing for touch
.breakroom__control-row .mat-mdc-raised-button,
.breakroom__control-row .mat-mdc-outlined-button {
min-height: 40px;
min-width: 48px;
font-size: 13px;
.mat-icon {
font-size: 18px;
width: 18px;
height: 18px;
margin-right: 4px;
}
}
// ---------------------------------------------------------------------------
// Responsive
// ---------------------------------------------------------------------------
@media (max-width: 599px) {
.breakroom {
padding: 16px;
gap: 16px;
}
.breakroom__control-row {
flex-wrap: wrap;
gap: 6px;
}
.breakroom__agent-name {
min-width: 50px;
}
}

View File

@@ -1,102 +0,0 @@
// ============================================================================
// Breakroom Page — Demo/Test Page for Minion State & Animation
// Per CUB-60: Validation page with spawn/transition/reset controls
// ============================================================================
import { ChangeDetectionStrategy, Component, inject } from '@angular/core';
import { CommonModule } from '@angular/common';
import { MatButtonModule } from '@angular/material/button';
import { MatIconModule } from '@angular/material/icon';
import { MatChipsModule } from '@angular/material/chips';
import { MinionComponent } from '../../components/minion/minion.component';
import { MinionStateService } from '../../services/minion-state.service';
import { MinionData } from '../../models/minion.model';
interface DemoMinion {
agentName: string;
displayName: string;
side: 'dev' | 'business';
deskIndex: number;
}
@Component({
selector: 'app-breakroom-page',
standalone: true,
imports: [
CommonModule,
MatButtonModule,
MatIconModule,
MatChipsModule,
MinionComponent,
],
templateUrl: './breakroom-page.component.html',
styleUrl: './breakroom-page.component.scss',
changeDetection: ChangeDetectionStrategy.OnPush,
})
export class BreakroomPageComponent {
protected readonly minionStateService = inject(MinionStateService);
/** Predefined demo minions */
readonly demoMinions: DemoMinion[] = [
{ agentName: 'otto', displayName: 'Otto', side: 'dev', deskIndex: 0 },
{ agentName: 'rex', displayName: 'Rex', side: 'dev', deskIndex: 1 },
{ agentName: 'dex', displayName: 'Dex', side: 'dev', deskIndex: 2 },
{ agentName: 'hex', displayName: 'Hex', side: 'dev', deskIndex: 3 },
{ agentName: 'pip', displayName: 'Pip', side: 'business', deskIndex: 0 },
{ agentName: 'nano', displayName: 'Nano', side: 'business', deskIndex: 1 },
{ agentName: 'flip', displayName: 'Flip', side: 'business', deskIndex: 2 },
];
/** All minions currently in the state service */
readonly minions = this.minionStateService.minionList;
/** Spawn a demo minion (idle → walking → working) */
spawnMinion(demo: DemoMinion): void {
this.minionStateService.spawn(demo.agentName, demo.displayName, demo.side, demo.deskIndex);
}
/** Complete a minion's task (working → returning → idle) */
completeTask(agentName: string): void {
this.minionStateService.completeTask(agentName);
}
/** Simulate a task error (working → returning → idle) */
taskError(agentName: string): void {
this.minionStateService.taskError(agentName);
}
/** Reset a minion to idle */
resetMinion(agentName: string): void {
this.minionStateService.resetMinion(agentName);
}
/** Remove a minion entirely */
removeMinion(agentName: string): void {
this.minionStateService.removeMinion(agentName);
}
/** Update progress (simulate for testing) */
bumpProgress(agentName: string): void {
const minion = this.minionStateService.getMinion(agentName);
if (minion) {
this.minionStateService.updateProgress(agentName, Math.min(100, minion.progress + 15));
}
}
/** Get state label for a minion */
getStateLabel(agentName: string): string {
const minion = this.minionStateService.getMinion(agentName);
if (!minion) return '—';
const labels: Record<string, string> = {
idle: '🍌 Idle',
walking: '🚶 Walking',
working: '💻 Working',
returning: '🔙 Returning',
};
return labels[minion.state] ?? minion.state;
}
/** Check if a minion is spawned */
isSpawned(agentName: string): boolean {
return !!this.minionStateService.getMinion(agentName);
}
}

View File

@@ -0,0 +1,28 @@
// ============================================================================
// Hub Page — Responsive AgentCard Grid
// Desktop (≥1024px): 2×2 grid
// Mobile (<1024px): single-column stack
// ============================================================================
.hub-page {
display: grid;
grid-template-columns: 1fr;
gap: 16px;
padding: var(--cc-section-padding, 16px);
min-height: 400px;
overflow-x: hidden;
}
.hub-page__placeholder {
color: var(--cc-on-surface-variant);
font-size: 16px;
text-align: center;
padding: 24px 0;
}
// Desktop / kiosk breakpoint — 2-column grid
@media (min-width: 1024px) {
.hub-page {
grid-template-columns: repeat(2, 1fr);
}
}

View File

@@ -9,18 +9,7 @@ import { ChangeDetectionStrategy, Component } from '@angular/core';
<p class="hub-page__placeholder">Command Hub — Fleet status grid will render here</p> <p class="hub-page__placeholder">Command Hub — Fleet status grid will render here</p>
</div> </div>
`, `,
styles: [` styleUrl: './hub-page.component.scss',
.hub-page {
display: flex;
align-items: center;
justify-content: center;
min-height: 400px;
}
.hub-page__placeholder {
color: var(--cc-on-surface-variant);
font-size: 16px;
}
`],
changeDetection: ChangeDetectionStrategy.OnPush, changeDetection: ChangeDetectionStrategy.OnPush,
}) })
export class HubPageComponent {} export class HubPageComponent {}

View File

@@ -1,213 +0,0 @@
// ============================================================================
// Minion State Service
// Per CUB-60: State machine managing minion transitions
// idle → walking → working → returning → idle
// ============================================================================
import { Injectable, signal, computed } from '@angular/core';
import {
MinionData,
MinionEvent,
MinionState,
MINION_TRANSITIONS,
} from '../models/minion.model';
/**
* Manages the state machine for all minions in the breakroom.
*
* Each minion follows: idle → walking → working → returning → idle
* Transitions are triggered by events (spawn, task_complete, task_error, reset)
* or automatically when walking/returning animations complete.
*
* Usage:
* service.spawn('otto', 'Otto', 'dev', 0); // idle → walking → working
* service.completeTask('otto'); // working → returning → idle
* service.dispatch('otto', 'reset'); // any → idle
*/
@Injectable({ providedIn: 'root' })
export class MinionStateService {
/** Internal map of agent name → minion data */
private readonly _minions = signal<Map<string, MinionData>>(new Map());
/** Readonly map of all minions */
readonly minions = this._minions.asReadonly();
/** Computed array of minions sorted by desk position */
readonly minionList = computed(() => {
const map = this._minions();
return Array.from(map.values()).sort((a, b) => {
if (a.side !== b.side) return a.side.localeCompare(b.side);
return a.deskIndex - b.deskIndex;
});
});
/** Get a single minion by agent name */
getMinion(agentName: string): MinionData | undefined {
return this._minions().get(agentName);
}
/**
* Spawn a minion: creates entry in 'idle' state, then immediately
* transitions to 'walking' (which auto-transitions to 'working').
*/
spawn(agentName: string, displayName: string, side: 'dev' | 'business', deskIndex: number): void {
const minion: MinionData = {
agentName,
displayName,
state: 'idle',
progress: 0,
side,
deskIndex,
lastTransition: new Date(),
};
this._minions.update(map => {
const next = new Map(map);
next.set(agentName, minion);
return next;
});
// Immediately transition idle → walking
this.dispatch(agentName, 'spawn');
}
/**
* Dispatch an event to transition a minion's state.
* Follows the MINION_TRANSITIONS map. Invalid transitions are ignored.
*/
dispatch(agentName: string, event: MinionEvent): void {
this._minions.update(map => {
const minion = map.get(agentName);
if (!minion) return map;
const validTransitions = MINION_TRANSITIONS[minion.state];
const nextState = validTransitions[event];
if (!nextState) return map; // Invalid transition — ignore
const updated: MinionData = {
...minion,
state: nextState,
lastTransition: new Date(),
};
const next = new Map(map);
next.set(agentName, updated);
return next;
});
}
/**
* Complete a task: transitions working → returning.
* After returning animation, the minion auto-transitions to idle.
*/
completeTask(agentName: string): void {
this.dispatch(agentName, 'task_complete');
}
/**
* Report a task error: transitions working → returning (same visual, different reason).
* After returning animation, the minion auto-transitions to idle.
*/
taskError(agentName: string): void {
this.dispatch(agentName, 'task_error');
}
/**
* Called by the MinionComponent when the walking animation completes.
* Transitions walking → working and sets initial progress to 0.
*/
onWalkingComplete(agentName: string): void {
this._minions.update(map => {
const minion = map.get(agentName);
if (!minion || minion.state !== 'walking') return map;
const updated: MinionData = {
...minion,
state: 'working',
progress: 0,
lastTransition: new Date(),
};
const next = new Map(map);
next.set(agentName, updated);
return next;
});
}
/**
* Called by the MinionComponent when the returning animation completes.
* Transitions returning → idle.
*/
onReturningComplete(agentName: string): void {
this._minions.update(map => {
const minion = map.get(agentName);
if (!minion || minion.state !== 'returning') return map;
const updated: MinionData = {
...minion,
state: 'idle',
progress: 0,
currentTask: undefined,
lastTransition: new Date(),
};
const next = new Map(map);
next.set(agentName, updated);
return next;
});
}
/**
* Update task progress for a working minion.
*/
updateProgress(agentName: string, progress: number): void {
this._minions.update(map => {
const minion = map.get(agentName);
if (!minion || minion.state !== 'working') return map;
const updated: MinionData = {
...minion,
progress: Math.min(100, Math.max(0, progress)),
lastTransition: new Date(),
};
const next = new Map(map);
next.set(agentName, updated);
return next;
});
}
/**
* Update the current task description for a minion.
*/
updateTask(agentName: string, taskDescription: string): void {
this._minions.update(map => {
const minion = map.get(agentName);
if (!minion) return map;
const updated: MinionData = {
...minion,
currentTask: taskDescription,
};
const next = new Map(map);
next.set(agentName, updated);
return next;
});
}
/**
* Remove a minion entirely from the state map.
*/
removeMinion(agentName: string): void {
this._minions.update(map => {
const next = new Map(map);
next.delete(agentName);
return next;
});
}
/**
* Reset a minion back to idle state.
*/
resetMinion(agentName: string): void {
this.dispatch(agentName, 'reset');
}
}

View File

@@ -48,6 +48,17 @@ html {
// These are NOT part of the M3 tonal palette; they are semantic overrides. // These are NOT part of the M3 tonal palette; they are semantic overrides.
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
:root { :root {
// --- Tactical Dark Mode color palette (CUB-47) ---
--color-surface: #0F172A;
--color-surface-light: #1E293B;
--color-primary: #38BDF8;
--color-secondary: #2DD4BF;
--color-accent: #A78BFA;
--color-danger: #F87171;
--color-text-primary: #FFFFFF;
--color-text-secondary: #94A3B8;
--color-border: #334155;
// --- Status colors --- // --- Status colors ---
--status-active: #38BDF8; --status-active: #38BDF8;
--status-idle: #2DD4BF; --status-idle: #2DD4BF;
@@ -90,7 +101,7 @@ html {
// Global Body Styles // Global Body Styles
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
body { body {
background-color: var(--cc-background); background-color: var(--color-surface);
color: var(--cc-on-surface); color: var(--cc-on-surface);
font-family: 'Inter', 'Roboto', sans-serif; font-family: 'Inter', 'Roboto', sans-serif;
margin: 0; margin: 0;