Merge branch 'dev' into agent/rex/CUB-44-task-progress-bar
This commit is contained in:
@@ -6,13 +6,19 @@
|
||||
<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 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>
|
||||
|
||||
@@ -37,6 +37,33 @@ public class AgentStatusHub : Hub<IAgentStatusClient>
|
||||
_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
|
||||
|
||||
@@ -72,6 +72,80 @@ public record TaskProgressUpdate(
|
||||
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.
|
||||
|
||||
72
backend/ControlCenter/Models/AgentMinionMapping.cs
Normal file
72
backend/ControlCenter/Models/AgentMinionMapping.cs
Normal 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
|
||||
);
|
||||
@@ -52,6 +52,11 @@ builder.Services.AddSignalR();
|
||||
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 ──────────────────────────────────────────────
|
||||
|
||||
193
backend/ControlCenter/Services/AgentMinionMapperService.cs
Normal file
193
backend/ControlCenter/Services/AgentMinionMapperService.cs
Normal 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
|
||||
);
|
||||
}
|
||||
}
|
||||
19
backend/Models/AgentState.cs
Normal file
19
backend/Models/AgentState.cs
Normal 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; }
|
||||
}
|
||||
@@ -1,5 +1,6 @@
|
||||
using ControlCenter.Api.Data;
|
||||
using ControlCenter.Api.Hubs;
|
||||
using ControlCenter.Api.Repositories;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
|
||||
var builder = WebApplication.CreateBuilder(args);
|
||||
@@ -10,6 +11,9 @@ 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 =>
|
||||
{
|
||||
|
||||
76
backend/Repositories/AgentStateRepository.cs
Normal file
76
backend/Repositories/AgentStateRepository.cs
Normal 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,
|
||||
};
|
||||
}
|
||||
27
backend/Repositories/IAgentStateRepository.cs
Normal file
27
backend/Repositories/IAgentStateRepository.cs
Normal 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);
|
||||
}
|
||||
@@ -0,0 +1,82 @@
|
||||
<!-- ========================================================================== -->
|
||||
<!-- AgentCard — per spec Section 7.3 -->
|
||||
<!-- Integrates: Status Badge · Task Progress Bar · Quick‑Jump Button -->
|
||||
<!-- Left‑border accent matches status color. role="article" + aria‑labels. -->
|
||||
<!-- ========================================================================== -->
|
||||
<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 + quick‑jump ── -->
|
||||
<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>
|
||||
|
||||
<!-- Quick‑Jump 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>
|
||||
@@ -0,0 +1,234 @@
|
||||
// ============================================================================
|
||||
// AgentCard — M3 tactical dark styling
|
||||
// Per spec Section 7.3: left‑border accent, status‑aware coloring,
|
||||
// responsive card layout with 320px min‑width.
|
||||
// ============================================================================
|
||||
|
||||
.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);
|
||||
|
||||
// Per‑status 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);
|
||||
}
|
||||
|
||||
// ── Quick‑Jump 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;
|
||||
}
|
||||
}
|
||||
|
||||
// ── Status‑specific 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;
|
||||
}
|
||||
}
|
||||
@@ -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 Quick‑Jump Button into a card with left‑border 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 left‑border accent */
|
||||
@Input({ required: true }) status!: AgentStatus;
|
||||
|
||||
/** Current task description, e.g. "Reviewing PR #42" */
|
||||
@Input() task = '';
|
||||
|
||||
/** Task progress percentage 0–100 */
|
||||
@Input() progress = 0;
|
||||
|
||||
/** Full session key for quick‑jump 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 left‑border 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)';
|
||||
});
|
||||
|
||||
/** Human‑readable 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`;
|
||||
});
|
||||
|
||||
/** Quick‑jump route derived from sessionKey */
|
||||
readonly jumpRoute = computed(() => `/sessions/${this.sessionKey}`);
|
||||
}
|
||||
1
frontend/src/app/command-hub/components/index.ts
Normal file
1
frontend/src/app/command-hub/components/index.ts
Normal file
@@ -0,0 +1 @@
|
||||
export * from './agent-card/agent-card.component';
|
||||
@@ -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>
|
||||
@@ -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);
|
||||
}
|
||||
}
|
||||
@@ -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);
|
||||
}
|
||||
}
|
||||
1
frontend/src/app/components/agent-status-badge/index.ts
Normal file
1
frontend/src/app/components/agent-status-badge/index.ts
Normal file
@@ -0,0 +1 @@
|
||||
export { AgentStatusBadgeComponent } from './agent-status-badge.component';
|
||||
1
frontend/src/app/components/index.ts
Normal file
1
frontend/src/app/components/index.ts
Normal file
@@ -0,0 +1 @@
|
||||
export { AgentStatusBadgeComponent } from './agent-status-badge/agent-status-badge.component';
|
||||
28
frontend/src/app/pages/hub/hub-page.component.scss
Normal file
28
frontend/src/app/pages/hub/hub-page.component.scss
Normal 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);
|
||||
}
|
||||
}
|
||||
@@ -9,18 +9,7 @@ import { ChangeDetectionStrategy, Component } from '@angular/core';
|
||||
<p class="hub-page__placeholder">Command Hub — Fleet status grid will render here</p>
|
||||
</div>
|
||||
`,
|
||||
styles: [`
|
||||
.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;
|
||||
}
|
||||
`],
|
||||
styleUrl: './hub-page.component.scss',
|
||||
changeDetection: ChangeDetectionStrategy.OnPush,
|
||||
})
|
||||
export class HubPageComponent {}
|
||||
@@ -48,6 +48,17 @@ html {
|
||||
// These are NOT part of the M3 tonal palette; they are semantic overrides.
|
||||
// ---------------------------------------------------------------------------
|
||||
: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-active: #38BDF8;
|
||||
--status-idle: #2DD4BF;
|
||||
@@ -90,7 +101,7 @@ html {
|
||||
// Global Body Styles
|
||||
// ---------------------------------------------------------------------------
|
||||
body {
|
||||
background-color: var(--cc-background);
|
||||
background-color: var(--color-surface);
|
||||
color: var(--cc-on-surface);
|
||||
font-family: 'Inter', 'Roboto', sans-serif;
|
||||
margin: 0;
|
||||
|
||||
Reference in New Issue
Block a user