Compare commits
3 Commits
agent/rex/
...
f170def0ea
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f170def0ea | ||
|
|
040d4cb54d | ||
|
|
47cbeed456 |
@@ -6,6 +6,11 @@
|
|||||||
<ImplicitUsings>enable</ImplicitUsings>
|
<ImplicitUsings>enable</ImplicitUsings>
|
||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<!-- Exclude the separate ControlCenter sub-project from this project's compilation -->
|
||||||
|
<ItemGroup>
|
||||||
|
<Compile Remove="ControlCenter/**/*.cs" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.14" />
|
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.14" />
|
||||||
<PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.4">
|
<PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.4">
|
||||||
@@ -13,6 +18,7 @@
|
|||||||
<PrivateAssets>all</PrivateAssets>
|
<PrivateAssets>all</PrivateAssets>
|
||||||
</PackageReference>
|
</PackageReference>
|
||||||
<PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="9.0.4" />
|
<PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="9.0.4" />
|
||||||
|
<PackageReference Include="Swashbuckle.AspNetCore" Version="10.1.7" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
</Project>
|
</Project>
|
||||||
|
|||||||
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.Data;
|
||||||
using ControlCenter.Api.Hubs;
|
using ControlCenter.Api.Hubs;
|
||||||
|
using ControlCenter.Api.Repositories;
|
||||||
using Microsoft.EntityFrameworkCore;
|
using Microsoft.EntityFrameworkCore;
|
||||||
|
|
||||||
var builder = WebApplication.CreateBuilder(args);
|
var builder = WebApplication.CreateBuilder(args);
|
||||||
@@ -10,6 +11,9 @@ builder.Services.AddOpenApi();
|
|||||||
// Register SignalR for real-time agent status updates
|
// Register SignalR for real-time agent status updates
|
||||||
builder.Services.AddSignalR();
|
builder.Services.AddSignalR();
|
||||||
|
|
||||||
|
// Register Agent State Repository
|
||||||
|
builder.Services.AddScoped<IAgentStateRepository, AgentStateRepository>();
|
||||||
|
|
||||||
// Register DbContext with PostgreSQL
|
// Register DbContext with PostgreSQL
|
||||||
builder.Services.AddDbContext<AppDbContext>(options =>
|
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);
|
||||||
|
}
|
||||||
@@ -1 +0,0 @@
|
|||||||
export * from './quick-jump-button/quick-jump-button.component';
|
|
||||||
@@ -1,8 +0,0 @@
|
|||||||
<button
|
|
||||||
mat-icon-button
|
|
||||||
class="quick-jump-button"
|
|
||||||
[attr.aria-label]="'Jump to agent session'"
|
|
||||||
(click)="onJumpClick()"
|
|
||||||
>
|
|
||||||
<mat-icon>arrow_forward</mat-icon>
|
|
||||||
</button>
|
|
||||||
@@ -1,68 +0,0 @@
|
|||||||
// ============================================================================
|
|
||||||
// Quick-Jump Button — M3 FilledTonalIconButton
|
|
||||||
// Per spec Section 7.3: Agent Card Quick-Jump action
|
|
||||||
// M3 spec: FilledTonalIconButton uses secondary container color
|
|
||||||
// with 8% state layer overlay for hover/focus.
|
|
||||||
// ============================================================================
|
|
||||||
|
|
||||||
.quick-jump-button {
|
|
||||||
// M3 FilledTonalIconButton: secondary-container background
|
|
||||||
// Angular Material mat-icon-button sets up the base shape (40x40, round).
|
|
||||||
// We override the color tokens to match FilledTonal style.
|
|
||||||
--mdc-icon-button-icon-color: var(--mat-sys-on-secondary-container);
|
|
||||||
background-color: var(--mat-sys-secondary-container);
|
|
||||||
border-radius: 50%;
|
|
||||||
transition: background-color 150ms cubic-bezier(0.4, 0, 0.2, 1);
|
|
||||||
|
|
||||||
// M3 State Layer: 8% overlay on hover
|
|
||||||
&:hover {
|
|
||||||
background-color: var(--mat-sys-secondary-container);
|
|
||||||
// State layer overlay using a pseudo-element for precise 8% opacity
|
|
||||||
&::after {
|
|
||||||
content: '';
|
|
||||||
position: absolute;
|
|
||||||
inset: 0;
|
|
||||||
border-radius: 50%;
|
|
||||||
background-color: var(--mat-sys-on-secondary-container);
|
|
||||||
opacity: 0.08;
|
|
||||||
pointer-events: none;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// M3 State Layer: 12% overlay on focus-visible (slightly stronger for accessibility)
|
|
||||||
&:focus-visible {
|
|
||||||
background-color: var(--mat-sys-secondary-container);
|
|
||||||
outline: 3px solid var(--status-active);
|
|
||||||
outline-offset: 2px;
|
|
||||||
|
|
||||||
&::after {
|
|
||||||
content: '';
|
|
||||||
position: absolute;
|
|
||||||
inset: 0;
|
|
||||||
border-radius: 50%;
|
|
||||||
background-color: var(--mat-sys-on-secondary-container);
|
|
||||||
opacity: 0.12;
|
|
||||||
pointer-events: none;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// M3 State Layer: 12% overlay on active/pressed
|
|
||||||
&:active {
|
|
||||||
background-color: var(--mat-sys-secondary-container);
|
|
||||||
|
|
||||||
&::after {
|
|
||||||
content: '';
|
|
||||||
position: absolute;
|
|
||||||
inset: 0;
|
|
||||||
border-radius: 50%;
|
|
||||||
background-color: var(--mat-sys-on-secondary-container);
|
|
||||||
opacity: 0.12;
|
|
||||||
pointer-events: none;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Icon color stays on-secondary-container across all states
|
|
||||||
.mat-icon {
|
|
||||||
color: var(--mat-sys-on-secondary-container);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,32 +0,0 @@
|
|||||||
import { ChangeDetectionStrategy, Component, EventEmitter, Output } from '@angular/core';
|
|
||||||
import { MatIconButton } from '@angular/material/button';
|
|
||||||
import { MatIcon } from '@angular/material/icon';
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Quick-Jump Button — M3 FilledTonalIconButton
|
|
||||||
*
|
|
||||||
* An icon button that emits a navigation event for jumping to an agent session.
|
|
||||||
* Uses the Material Design 3 FilledTonalIconButton style with 8% state layer
|
|
||||||
* overlay on hover and focus.
|
|
||||||
*
|
|
||||||
* Per spec Section 7.3: Agent Card Component Interface
|
|
||||||
*/
|
|
||||||
@Component({
|
|
||||||
selector: 'app-quick-jump-button',
|
|
||||||
standalone: true,
|
|
||||||
imports: [MatIconButton, MatIcon],
|
|
||||||
templateUrl: './quick-jump-button.component.html',
|
|
||||||
styleUrl: './quick-jump-button.component.scss',
|
|
||||||
changeDetection: ChangeDetectionStrategy.OnPush,
|
|
||||||
})
|
|
||||||
export class QuickJumpButtonComponent {
|
|
||||||
/** Emitted when the button is clicked, carrying the session key for navigation. */
|
|
||||||
@Output() jumpClick = new EventEmitter<string>();
|
|
||||||
|
|
||||||
/** The session key to navigate to. Set by the parent agent card. */
|
|
||||||
sessionKey = '';
|
|
||||||
|
|
||||||
onJumpClick(): void {
|
|
||||||
this.jumpClick.emit(this.sessionKey);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user