CUB-54: implement AgentState entity, repository, and DI registration

- Add AgentState entity mapping to 'agents' table (snake_case columns)
- Add IAgentStateRepository interface (GetAllAsync, GetBySessionKeyAsync, UpdateStatusAsync)
- Add AgentStateRepository with EF Core implementation
- Add ControlCenterDbContext with ApplyConfigurationsFromAssembly
- Add AgentStateConfiguration with snake_case column mappings and indexes
- Register DbContext (Npgsql) and repository in Program.cs DI
- Add ConnectionStrings to appsettings.json
- Add EF Core 9.0.7 and Npgsql.EntityFrameworkCore.PostgreSQL 9.0.4 packages

backend/.gitignore

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

backend/Configurations/AgentConfiguration.cs

@@ -1,88 +0,0 @@
-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 (0–100)
-        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 0–100 if present
-        builder.ToTable(t => t.HasCheckConstraint("ck_agents_progress_range", "progress IS NULL OR (progress >= 0 AND progress <= 100)"));
-    }
-}

backend/ControlCenter.Api.csproj

@@ -1,18 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk.Web">
-
-  <PropertyGroup>
-    <TargetFramework>net9.0</TargetFramework>
-    <Nullable>enable</Nullable>
-    <ImplicitUsings>enable</ImplicitUsings>
-  </PropertyGroup>
-
-  <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" />
-  </ItemGroup>
-
-</Project>

backend/ControlCenter.Api.http

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

backend/ControlCenter/ControlCenter.csproj

@@ -11,6 +11,8 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.7" />
+    <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="9.0.4" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="10.1.7" />
   </ItemGroup>
 

backend/ControlCenter/Data/Configurations/AgentStateConfiguration.cs

@@ -0,0 +1,69 @@
+using ControlCenter.Models;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+namespace ControlCenter.Data.Configurations;
+
+/// <summary>
+/// EF Core entity configuration for <see cref="AgentState"/>.
+///
+/// <para>Maps to the <c>agents</c> table with snake_case column naming,
+/// consistent with the Extrudex project conventions.</para>
+///
+/// <para>CUB-56 will create the migration; this configuration only
+/// defines the entity-to-table mapping and constraints.</para>
+/// </summary>
+public class AgentStateConfiguration : IEntityTypeConfiguration<AgentState>
+{
+    public void Configure(EntityTypeBuilder<AgentState> builder)
+    {
+        // Table name
+        builder.ToTable("agents");
+
+        // Primary key
+        builder.HasKey(a => a.Id);
+
+        // Properties with snake_case column names
+        builder.Property(a => a.Id)
+            .HasColumnName("id")
+            .ValueGeneratedOnAdd();
+
+        builder.Property(a => a.Status)
+            .HasColumnName("status")
+            .IsRequired()
+            .HasMaxLength(20)
+            .HasDefaultValue("idle");
+
+        builder.Property(a => a.Task)
+            .HasColumnName("task")
+            .IsRequired(false)
+            .HasMaxLength(500);
+
+        builder.Property(a => a.Progress)
+            .HasColumnName("progress")
+            .IsRequired(false);
+
+        builder.Property(a => a.SessionKey)
+            .HasColumnName("session_key")
+            .IsRequired()
+            .HasMaxLength(255);
+
+        builder.Property(a => a.Channel)
+            .HasColumnName("channel")
+            .IsRequired()
+            .HasMaxLength(50);
+
+        builder.Property(a => a.LastActivity)
+            .HasColumnName("last_activity")
+            .IsRequired()
+            .HasDefaultValueSql("NOW()");
+
+        // Indexes
+        builder.HasIndex(a => a.SessionKey)
+            .IsUnique()
+            .HasDatabaseName("ix_agents_session_key");
+
+        builder.HasIndex(a => a.Status)
+            .HasDatabaseName("ix_agents_status");
+    }
+}

backend/ControlCenter/Data/ControlCenterDbContext.cs

@@ -0,0 +1,39 @@
+using ControlCenter.Models;
+using Microsoft.EntityFrameworkCore;
+
+namespace ControlCenter.Data;
+
+/// <summary>
+/// EF Core DbContext for the Control Center database.
+///
+/// <para>Provides <see cref="DbSet{T}"/> access to all persistent entities.
+/// Uses snake_case naming conventions for PostgreSQL columns,
+/// applied via <see cref="Configurations.AgentStateConfiguration"/>.</para>
+///
+/// <para>Connection string is configured in <c>appsettings.json</c>
+/// under <c>ConnectionStrings:ControlCenterDb</c>.</para>
+/// </summary>
+public class ControlCenterDbContext : DbContext
+{
+    /// <summary>
+    /// Agent state records — one row per active or recently active agent.
+    /// Maps to the <c>agents</c> table.
+    /// </summary>
+    public DbSet<AgentState> AgentStates => Set<AgentState>();
+
+    public ControlCenterDbContext(DbContextOptions<ControlCenterDbContext> options)
+        : base(options)
+    {
+    }
+
+    protected override void OnModelCreating(ModelBuilder modelBuilder)
+    {
+        // Apply all entity configurations from this assembly
+        modelBuilder.ApplyConfigurationsFromAssembly(
+            typeof(Configurations.AgentStateConfiguration).Assembly);
+
+        // Global snake_case naming convention for any unmapped columns
+        // (explicit configurations take precedence)
+        base.OnModelCreating(modelBuilder);
+    }
+}

backend/ControlCenter/Models/AgentState.cs

@@ -0,0 +1,59 @@
+namespace ControlCenter.Models;
+
+/// <summary>
+/// Persistent state for an agent in the Control Center.
+/// Maps to the <c>agents</c> table in PostgreSQL.
+///
+/// <para>Tracks the operational status, current task, progress,
+/// session identity, and last activity timestamp for each agent
+/// in the minion fleet.</para>
+///
+/// <para>The <see cref="Status"/> property uses string values matching
+/// the AgentStatus enum: "active", "idle", "thinking", "error".
+/// Stored as <c>varchar</c> rather than a DB enum for schema flexibility.</para>
+/// </summary>
+public class AgentState
+{
+    /// <summary>
+    /// Unique identifier for the agent state record.
+    /// Defaults to a new <see cref="Guid"/> on creation.
+    /// </summary>
+    public Guid Id { get; set; } = Guid.NewGuid();
+
+    /// <summary>
+    /// Operational status of the agent.
+    /// Valid values: "active", "idle", "thinking", "error".
+    /// Maps to the AgentStatus enum used by SignalR.
+    /// </summary>
+    public string Status { get; set; } = "idle";
+
+    /// <summary>
+    /// Description of the agent's current task, if any.
+    /// Null when the agent is idle with no active assignment.
+    /// </summary>
+    public string? Task { get; set; }
+
+    /// <summary>
+    /// Task progress percentage (0–100).
+    /// Null when progress is not trackable for the current task.
+    /// </summary>
+    public int? Progress { get; set; }
+
+    /// <summary>
+    /// Full session key identifying the agent's active session.
+    /// Format: <c>agent:{agentId}:{channel}:...</c>
+    /// Used to correlate SignalR events with persistent state.
+    /// </summary>
+    public string SessionKey { get; set; } = string.Empty;
+
+    /// <summary>
+    /// The channel the agent is operating on (e.g., "telegram", "discord", "slack").
+    /// </summary>
+    public string Channel { get; set; } = string.Empty;
+
+    /// <summary>
+    /// Timestamp of the agent's last recorded activity.
+    /// Updated on every status change or task progress event.
+    /// </summary>
+    public DateTime LastActivity { get; set; } = DateTime.UtcNow;
+}

backend/ControlCenter/Program.cs

@@ -1,6 +1,9 @@
 using System.Reflection;
+using ControlCenter.Data;
 using ControlCenter.Hubs;
+using ControlCenter.Repositories;
 using ControlCenter.Services;
+using Microsoft.EntityFrameworkCore;
 
 var builder = WebApplication.CreateBuilder(args);
 
@@ -25,6 +28,19 @@ builder.Services.AddSwaggerGen(c =>
     }
 });
 
+// ── Database ────────────────────────────────────────────────
+// PostgreSQL via EF Core with Npgsql.
+// Connection string from appsettings.json or environment variable.
+builder.Services.AddDbContext<ControlCenterDbContext>(options =>
+    options.UseNpgsql(
+        builder.Configuration.GetConnectionString("ControlCenterDb")
+            ?? throw new InvalidOperationException(
+                "Connection string 'ControlCenterDb' not found. " +
+                "Add it to appsettings.json or set the environment variable.")));
+
+// ── Repositories ────────────────────────────────────────────
+builder.Services.AddScoped<IAgentStateRepository, AgentStateRepository>();
+
 // ── 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

backend/ControlCenter/Repositories/AgentStateRepository.cs

@@ -0,0 +1,62 @@
+using ControlCenter.Data;
+using ControlCenter.Models;
+using Microsoft.EntityFrameworkCore;
+
+namespace ControlCenter.Repositories;
+
+/// <summary>
+/// EF Core implementation of <see cref="IAgentStateRepository"/>.
+///
+/// <para>Queries the <c>agents</c> table via <see cref="ControlCenterDbContext"/>
+/// using snake_case column mappings defined in the <see cref="Data.Configurations.AgentStateConfiguration"/>.
+/// All write operations call <c>SaveChangesAsync</c> immediately.</para>
+/// </summary>
+public class AgentStateRepository : IAgentStateRepository
+{
+    private readonly ControlCenterDbContext _context;
+    private readonly ILogger<AgentStateRepository> _logger;
+
+    public AgentStateRepository(
+        ControlCenterDbContext context,
+        ILogger<AgentStateRepository> logger)
+    {
+        _context = context;
+        _logger = logger;
+    }
+
+    /// <inheritdoc />
+    public async Task<IEnumerable<AgentState>> GetAllAsync()
+    {
+        _logger.LogDebug("Fetching all agent states");
+        return await _context.AgentStates.ToListAsync();
+    }
+
+    /// <inheritdoc />
+    public async Task<AgentState?> GetBySessionKeyAsync(string sessionKey)
+    {
+        _logger.LogDebug("Looking up agent state by session key: {SessionKey}", sessionKey);
+        return await _context.AgentStates
+            .FirstOrDefaultAsync(a => a.SessionKey == sessionKey);
+    }
+
+    /// <inheritdoc />
+    public async Task<AgentState?> UpdateStatusAsync(Guid id, string status)
+    {
+        _logger.LogDebug("Updating agent status: {Id} → {Status}", id, status);
+
+        var entity = await _context.AgentStates.FindAsync(id);
+        if (entity is null)
+        {
+            _logger.LogWarning("Agent state not found: {Id}", id);
+            return null;
+        }
+
+        entity.Status = status;
+        entity.LastActivity = DateTime.UtcNow;
+
+        _context.AgentStates.Update(entity);
+        await _context.SaveChangesAsync();
+
+        return entity;
+    }
+}

backend/ControlCenter/Repositories/IAgentStateRepository.cs

@@ -0,0 +1,38 @@
+using ControlCenter.Models;
+
+namespace ControlCenter.Repositories;
+
+/// <summary>
+/// Repository interface for querying and updating agent state.
+///
+/// <para>Provides the data-access contract used by controllers,
+/// background services, and SignalR hubs to read and mutate
+/// persistent agent state.</para>
+///
+/// <para>Implementation should use <see cref="Data.ControlCenterDbContext"/>
+/// via EF Core with PostgreSQL (snake_case columns).</para>
+/// </summary>
+public interface IAgentStateRepository
+{
+    /// <summary>
+    /// Returns all agent states from the database.
+    /// </summary>
+    /// <returns>A collection of all <see cref="AgentState"/> records.</returns>
+    Task<IEnumerable<AgentState>> GetAllAsync();
+
+    /// <summary>
+    /// Finds an agent state by its session key.
+    /// </summary>
+    /// <param name="sessionKey">The full session key, e.g. "agent:dex:telegram:direct:...".</param>
+    /// <returns>The matching <see cref="AgentState"/>, or null if not found.</returns>
+    Task<AgentState?> GetBySessionKeyAsync(string sessionKey);
+
+    /// <summary>
+    /// Updates the status of an agent state record.
+    /// Also updates <c>LastActivity</c> to <see cref="DateTime.UtcNow"/>.
+    /// </summary>
+    /// <param name="id">The unique identifier of the agent state record.</param>
+    /// <param name="status">The new status value ("active", "idle", "thinking", "error").</param>
+    /// <returns>The updated <see cref="AgentState"/>, or null if the record was not found.</returns>
+    Task<AgentState?> UpdateStatusAsync(Guid id, string status);
+}

backend/ControlCenter/appsettings.json

@@ -8,6 +8,10 @@
   },
   "AllowedHosts": "*",
 
+  "ConnectionStrings": {
+    "ControlCenterDb": "Host=localhost;Port=5432;Database=control_center;Username=control_center;Password=changeme"
+  },
+
   "Gateway": {
     "WebSocketUrl": "ws://localhost:3271/ws",
     "AuthToken": ""

backend/Data/AppDbContext.cs

@@ -1,29 +0,0 @@
-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);
-    }
-}

backend/Data/AppDbContextFactory.cs

@@ -1,27 +0,0 @@
-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);
-    }
-}

backend/Dtos/AgentStatusUpdateDto.cs

@@ -1,75 +0,0 @@
-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 (0–100).
-    /// 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; }
-}

backend/Entities/Agent.cs

@@ -1,59 +0,0 @@
-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 (0–100).
-    /// 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;
-}

backend/Entities/AgentStatus.cs

@@ -1,13 +0,0 @@
-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
-}

backend/Hubs/AgentStatusHub.cs

@@ -1,155 +0,0 @@
-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);
-    }
-}

backend/Migrations/20260426101703_CreateAgentsTable.Designer.cs

@@ -1,94 +0,0 @@
-// <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
-        }
-    }
-}

backend/Migrations/20260426101703_CreateAgentsTable.cs

@@ -1,61 +0,0 @@
-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");
-        }
-    }
-}

backend/Migrations/AppDbContextModelSnapshot.cs

@@ -1,91 +0,0 @@
-// <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
-        }
-    }
-}

backend/Program.cs

@@ -1,38 +0,0 @@
-using ControlCenter.Api.Data;
-using ControlCenter.Api.Hubs;
-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 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();

backend/Properties/launchSettings.json

@@ -1,23 +0,0 @@
-{
-  "$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"
-      }
-    }
-  }
-}

backend/appsettings.Development.json

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

backend/appsettings.json

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

frontend/src/app/components/index.ts

@@ -1 +0,0 @@
-export * from './quick-jump-button/quick-jump-button.component';

frontend/src/app/components/quick-jump-button/quick-jump-button.component.html

@@ -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>

frontend/src/app/components/quick-jump-button/quick-jump-button.component.scss

@@ -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);
-  }
-}

frontend/src/app/components/quick-jump-button/quick-jump-button.component.ts

@@ -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);
-  }
-}