Subsystem 1b-ii: live connection lifecycle, failover & #info status (#6)

* feat(connections): reshape ConnectionState with status + player count

Replace IsHealthy (bool) with Status (ConnectionStatus enum) and add
nullable PlayerCount; generate LiveConnections migration and schema test.

* feat(events): add ConnectionStatusChangedEvent

* feat(connections): add IConnectionStore for live-connection state and pool

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* refactor(discord): extract IUserDmSender and reuse it in DiscordOwnerNotifier

Introduces IUserDmSender (Discord project) as a reusable DM primitive and
replaces DiscordOwnerNotifier's direct DiscordSocketClient usage with it;
fixes PairingRegistrationTests to supply a substitute IUserDmSender.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* feat(connections): scaffold Features.Connections project and socket seam

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* feat(connections): add RustPlusApi socket adapter shim

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* feat(connections): add ConnectionSupervisor (connect, heartbeat, failover, restart-survival)

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

* feat(connections): add ConnectionHostedService

Drives IConnectionSupervisor: StartAllAsync on startup, reacts to
ServerRegisteredEvent to call EnsureConnectionAsync, StopAllAsync on
shutdown. Added InternalsVisibleTo DynamicProxyGenAssembly2 to allow
NSubstitute to proxy the internal IConnectionSupervisor.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* feat(workspace): live status and swap select on #info

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* feat(workspace): re-render #info on ConnectionStatusChangedEvent

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* feat(connections): swap module, AddConnections wiring, host registration

- Add ConnectionComponentModule handling workspace:info:swap:* select menus
- Add ConnectionServiceCollectionExtensions.AddConnections() DI extension
- Wire ConnectionOptions validation and AddConnections() into Program.cs
- Add project reference for Connections in Host.csproj
- Add ConnectionRegistrationTests verifying IConnectionSupervisor and IConnectionStore resolve

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* refactor(connections): align UpsertStatus guild filter; validate heartbeat timeout < interval

* style: apply ReSharper ReformatAndReorder (CI format gate)

* fix(connections): address review — stable heartbeat fake, Ensure race gate, no token leak, swap value validation

---------

Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: HandyS11

Directory.Packages.props

@@ -11,6 +11,7 @@
     <PackageVersion Include="Microsoft.Extensions.Hosting" Version="10.0.9" />
     <PackageVersion Include="Microsoft.Extensions.Hosting.Abstractions" Version="10.0.9" />
     <PackageVersion Include="Persistord.Core" Version="1.0.0-beta.1" />
+    <PackageVersion Include="RustPlusApi" Version="2.0.0-beta.1" />
     <PackageVersion Include="RustPlusApi.Fcm" Version="2.0.0-beta.1" />
   </ItemGroup>
   <ItemGroup>

RustPlusBot.slnx

@@ -4,12 +4,14 @@
     <Project Path="src/RustPlusBot.Discord/RustPlusBot.Discord.csproj" />
     <Project Path="src/RustPlusBot.Domain/RustPlusBot.Domain.csproj" />
     <Project Path="src/RustPlusBot.Host/RustPlusBot.Host.csproj" />
+    <Project Path="src/RustPlusBot.Features.Connections/RustPlusBot.Features.Connections.csproj" />
     <Project Path="src/RustPlusBot.Features.Pairing/RustPlusBot.Features.Pairing.csproj" />
     <Project Path="src/RustPlusBot.Features.Workspace/RustPlusBot.Features.Workspace.csproj" />
     <Project Path="src/RustPlusBot.Persistence/RustPlusBot.Persistence.csproj" />
   </Folder>
   <Folder Name="/tests/">
     <Project Path="tests/RustPlusBot.Abstractions.Tests/RustPlusBot.Abstractions.Tests.csproj" />
+    <Project Path="tests/RustPlusBot.Features.Connections.Tests/RustPlusBot.Features.Connections.Tests.csproj" />
     <Project Path="tests/RustPlusBot.Features.Pairing.Tests/RustPlusBot.Features.Pairing.Tests.csproj" />
     <Project Path="tests/RustPlusBot.Features.Workspace.Tests/RustPlusBot.Features.Workspace.Tests.csproj" />
     <Project Path="tests/RustPlusBot.Persistence.Tests/RustPlusBot.Persistence.Tests.csproj" />

src/RustPlusBot.Abstractions/Events/ConnectionStatusChangedEvent.cs

@@ -0,0 +1,6 @@
+namespace RustPlusBot.Abstractions.Events;
+
+/// <summary>Published when a server's live-connection state changes, so #info can re-render.</summary>
+/// <param name="GuildId">The owning guild snowflake.</param>
+/// <param name="ServerId">The server whose connection state changed.</param>
+public sealed record ConnectionStatusChangedEvent(ulong GuildId, Guid ServerId);

src/RustPlusBot.Discord/DiscordServiceCollectionExtensions.cs

@@ -2,6 +2,7 @@
 using Discord.Interactions;
 using Discord.WebSocket;
 using Microsoft.Extensions.DependencyInjection;
+using RustPlusBot.Discord.Notifications;
 
 namespace RustPlusBot.Discord;
 
@@ -28,6 +29,7 @@ public static IServiceCollection AddDiscordBot(this IServiceCollection services)
             {
                 DefaultRunMode = RunMode.Async
             }));
+        services.AddSingleton<IUserDmSender, DiscordUserDmSender>();
         services.AddHostedService<DiscordBotService>();
 
         return services;

src/RustPlusBot.Discord/Notifications/DiscordUserDmSender.cs

@@ -0,0 +1,44 @@
+using System.Diagnostics.CodeAnalysis;
+using Discord.WebSocket;
+using Microsoft.Extensions.Logging;
+
+namespace RustPlusBot.Discord.Notifications;
+
+/// <summary>Discord-backed <see cref="IUserDmSender"/>.</summary>
+/// <param name="client">The socket client.</param>
+/// <param name="logger">The logger.</param>
+[SuppressMessage("Performance", "CA1812:Avoid uninstantiated internal classes",
+    Justification = "Instantiated by the DI container via IUserDmSender registration.")]
+internal sealed partial class DiscordUserDmSender(DiscordSocketClient client, ILogger<DiscordUserDmSender> logger)
+    : IUserDmSender
+{
+    /// <inheritdoc />
+    public async Task SendAsync(ulong userId, string message, CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            // Discord.Net uses RequestOptions, not CancellationToken, for per-call cancellation, so the token is not forwarded.
+            var user = await client.GetUserAsync(userId).ConfigureAwait(false);
+            if (user is null)
+            {
+                LogUserNotFound(logger, userId);
+                return;
+            }
+
+            var dmChannel = await user.CreateDMChannelAsync().ConfigureAwait(false);
+            await dmChannel.SendMessageAsync(message).ConfigureAwait(false);
+        }
+#pragma warning disable CA1031 // Broad catch is intentional: a closed DM (or any send failure) must not break callers.
+        catch (Exception ex)
+#pragma warning restore CA1031
+        {
+            LogDmFailed(logger, ex, userId);
+        }
+    }
+
+    [LoggerMessage(Level = LogLevel.Warning, Message = "Cannot DM user {UserId}: user not found.")]
+    private static partial void LogUserNotFound(ILogger logger, ulong userId);
+
+    [LoggerMessage(Level = LogLevel.Warning, Message = "Failed to DM user {UserId}.")]
+    private static partial void LogDmFailed(ILogger logger, Exception ex, ulong userId);
+}

src/RustPlusBot.Discord/Notifications/IUserDmSender.cs

@@ -0,0 +1,12 @@
+namespace RustPlusBot.Discord.Notifications;
+
+/// <summary>Sends a direct message to a Discord user. A closed DM (or any send failure) is swallowed and logged.</summary>
+public interface IUserDmSender
+{
+    /// <summary>Best-effort DM to <paramref name="userId"/>; never throws.</summary>
+    /// <param name="userId">The Discord user snowflake.</param>
+    /// <param name="message">The message text.</param>
+    /// <param name="cancellationToken">A cancellation token.</param>
+    /// <returns>A task that completes when the send was attempted.</returns>
+    Task SendAsync(ulong userId, string message, CancellationToken cancellationToken = default);
+}

src/RustPlusBot.Domain/Connections/ConnectionState.cs

@@ -1,6 +1,6 @@
 namespace RustPlusBot.Domain.Connections;
 
-/// <summary>Persisted last-known connection state per server, so the active identity survives restarts.</summary>
+/// <summary>Persisted last-known connection state per server, so the active identity and status survive restarts.</summary>
 public sealed class ConnectionState
 {
     /// <summary>The server this state belongs to (primary key, one row per server).</summary>
@@ -12,8 +12,11 @@ public sealed class ConnectionState
     /// <summary>The credential currently selected as active, if any.</summary>
     public Guid? ActiveCredentialId { get; set; }
 
-    /// <summary>Whether the connection was healthy at last check.</summary>
-    public bool IsHealthy { get; set; }
+    /// <summary>The live-connection status.</summary>
+    public ConnectionStatus Status { get; set; }
+
+    /// <summary>Last heartbeat player count, or null if unknown.</summary>
+    public int? PlayerCount { get; set; }
 
     /// <summary>When the state was last updated (UTC).</summary>
     public DateTimeOffset UpdatedAt { get; set; }

src/RustPlusBot.Domain/Connections/ConnectionStatus.cs

@@ -0,0 +1,17 @@
+namespace RustPlusBot.Domain.Connections;
+
+/// <summary>Live-connection lifecycle state for a server's socket.</summary>
+public enum ConnectionStatus
+{
+    /// <summary>Attempting to connect (initial, after a swap, or after a drop).</summary>
+    Connecting = 0,
+
+    /// <summary>Socket up and the last heartbeat was healthy.</summary>
+    Connected = 1,
+
+    /// <summary>A valid active credential exists but the server is not answering; retrying with backoff.</summary>
+    Unreachable = 2,
+
+    /// <summary>No eligible credential (pool empty or every credential is Invalid).</summary>
+    NoCredentials = 3,
+}

src/RustPlusBot.Features.Connections/ConnectionOptions.cs

@@ -0,0 +1,20 @@
+namespace RustPlusBot.Features.Connections;
+
+/// <summary>Connection feature configuration, bound from the "Connections" config section.</summary>
+public sealed class ConnectionOptions
+{
+    /// <summary>How long to wait for a socket to connect before treating the server as unreachable.</summary>
+    public TimeSpan ConnectTimeout { get; set; } = TimeSpan.FromSeconds(30);
+
+    /// <summary>First delay before retrying after an unreachable result.</summary>
+    public TimeSpan InitialRetryDelay { get; set; } = TimeSpan.FromSeconds(5);
+
+    /// <summary>Cap on the exponential backoff between reconnect attempts.</summary>
+    public TimeSpan MaxRetryDelay { get; set; } = TimeSpan.FromMinutes(5);
+
+    /// <summary>How often to send a heartbeat on a connected socket.</summary>
+    public TimeSpan HeartbeatInterval { get; set; } = TimeSpan.FromSeconds(60);
+
+    /// <summary>How long a single heartbeat may take before the socket is considered unreachable.</summary>
+    public TimeSpan HeartbeatTimeout { get; set; } = TimeSpan.FromSeconds(10);
+}

src/RustPlusBot.Features.Connections/ConnectionServiceCollectionExtensions.cs

@@ -0,0 +1,29 @@
+using Microsoft.Extensions.DependencyInjection;
+using RustPlusBot.Discord;
+using RustPlusBot.Features.Connections.Hosting;
+using RustPlusBot.Features.Connections.Listening;
+using RustPlusBot.Features.Connections.Supervisor;
+
+namespace RustPlusBot.Features.Connections;
+
+/// <summary>DI registration for the live-connection feature.</summary>
+public static class ConnectionServiceCollectionExtensions
+{
+    /// <summary>Registers the socket source, supervisor, module seam, and hosted service.</summary>
+    /// <param name="services">The service collection to add to.</param>
+    /// <returns>The same service collection, for chaining.</returns>
+    public static IServiceCollection AddConnections(this IServiceCollection services)
+    {
+        ArgumentNullException.ThrowIfNull(services);
+
+        services.AddSingleton<IRustSocketSource, RustPlusSocketSource>();
+        services.AddSingleton<IConnectionSupervisor, ConnectionSupervisor>();
+
+        // Contribute this assembly's interaction modules to the Discord layer.
+        services.AddSingleton(new InteractionModuleAssembly(typeof(ConnectionServiceCollectionExtensions).Assembly));
+
+        services.AddHostedService<ConnectionHostedService>();
+
+        return services;
+    }
+}