From 638b33b830c837deb9fdc17445c13ba46bd92c1a Mon Sep 17 00:00:00 2001
From: Meta Vens <rwvens@hotmail.com>
Date: Sun, 19 Jul 2026 18:53:08 +0100
Subject: [PATCH] Expose TCP schema host health

---
 .../CultNetTcpSchemaTransport.cs                | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/src/GameCult.Networking/CultNetTcpSchemaTransport.cs b/src/GameCult.Networking/CultNetTcpSchemaTransport.cs
index 168ce924..15935b87 100644
--- a/src/GameCult.Networking/CultNetTcpSchemaTransport.cs
+++ b/src/GameCult.Networking/CultNetTcpSchemaTransport.cs
@@ -110,6 +110,8 @@ namespace GameCult.Networking
         private readonly ConcurrentDictionary<Type, Delegate> _handlers = new();
         private readonly ConcurrentDictionary<TcpPeer, byte> _peers = new();
         private readonly CancellationTokenSource _shutdown = new();
+        private readonly TaskCompletionSource<Exception> _backgroundFailure = new(
+            TaskCreationOptions.RunContinuationsAsynchronously);
         private bool _disposed;
 
         public TcpFramedCultNetSchemaServer(TcpListener listener)
@@ -120,7 +122,14 @@ namespace GameCult.Networking
         }
 
         public event Action<ICultNetSchemaServerPeer>? PeerDisconnected;
+        /// <summary>Raised when one peer connection fails without stopping the listener.</summary>
+        public event Action<EndPoint?, Exception>? PeerFailed;
+        /// <summary>Gets the bound TCP endpoint.</summary>
         public IPEndPoint LocalEndPoint => (IPEndPoint)_listener.LocalEndpoint;
+        /// <summary>Gets the number of active TCP peers.</summary>
+        public int PeerCount => _peers.Count;
+        /// <summary>Completes if the background accept loop fails.</summary>
+        public Task<Exception> BackgroundFailure => _backgroundFailure.Task;
 
         public void OnCultNet<TMessage>(Func<TMessage, ICultNetSchemaServerPeer, Task> callback)
             where TMessage : ICultNetSchemaMessage
@@ -162,6 +171,10 @@ namespace GameCult.Networking
             catch (Exception) when (_disposed || cancellationToken.IsCancellationRequested)
             {
             }
+            catch (Exception error)
+            {
+                _backgroundFailure.TrySetResult(error);
+            }
         }
 
         private async Task ServePeerAsync(TcpPeer peer, CancellationToken cancellationToken)
@@ -182,6 +195,10 @@ namespace GameCult.Networking
             catch (Exception) when (_disposed || cancellationToken.IsCancellationRequested || !peer.Connected)
             {
             }
+            catch (Exception error)
+            {
+                PeerFailed?.Invoke(peer.RemoteEndPoint, error);
+            }
             finally
             {
                 if (_peers.TryRemove(peer, out _)) PeerDisconnected?.Invoke(peer);