|
// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
using System.Diagnostics.CodeAnalysis;
namespace Microsoft.AspNetCore.SignalR;
/// <summary>
/// A base class for a SignalR hub.
/// </summary>
public abstract class Hub : IDisposable
{
internal const DynamicallyAccessedMemberTypes DynamicallyAccessedMembers = DynamicallyAccessedMemberTypes.PublicConstructors | DynamicallyAccessedMemberTypes.PublicMethods;
private bool _disposed;
private IHubCallerClients _clients = default!;
private HubCallerContext _context = default!;
private IGroupManager _groups = default!;
/// <summary>
/// Gets or sets an object that can be used to invoke methods on the clients connected to this hub.
/// </summary>
public IHubCallerClients Clients
{
get
{
CheckDisposed();
return _clients;
}
set
{
CheckDisposed();
_clients = value;
}
}
/// <summary>
/// Gets or sets the hub caller context.
/// </summary>
public HubCallerContext Context
{
get
{
CheckDisposed();
return _context;
}
set
{
CheckDisposed();
_context = value;
}
}
/// <summary>
/// Gets or sets the group manager.
/// </summary>
public IGroupManager Groups
{
get
{
CheckDisposed();
return _groups;
}
set
{
CheckDisposed();
_groups = value;
}
}
/// <summary>
/// Called when a new connection is established with the hub.
/// </summary>
/// <returns>A <see cref="Task"/> that represents the asynchronous connect.</returns>
public virtual Task OnConnectedAsync()
{
return Task.CompletedTask;
}
/// <summary>
/// Called when a connection with the hub is terminated.
/// </summary>
/// <returns>A <see cref="Task"/> that represents the asynchronous disconnect.</returns>
public virtual Task OnDisconnectedAsync(Exception? exception)
{
return Task.CompletedTask;
}
/// <summary>
/// Called when the authenticated user on the connection has been refreshed, for example via the
/// SignalR authentication-refresh endpoint. The new <see cref="System.Security.Claims.ClaimsPrincipal"/> is
/// available on <see cref="HubCallerContext.User"/>.
/// </summary>
/// <returns>A <see cref="Task"/> that represents the asynchronous operation.</returns>
/// <remarks>
/// This method is serialized with concurrent hub method invocations using the connection's
/// maximum-parallel-invocation limit. Client-result invocations are not supported from this method.
/// The previous principal is intentionally not exposed because its underlying resources
/// (for example a <see cref="System.Security.Principal.WindowsIdentity"/>'s <c>SafeHandle</c>)
/// may already be disposed by the time this method runs.
/// </remarks>
public virtual Task OnAuthenticationRefreshedAsync()
{
return Task.CompletedTask;
}
/// <summary>
/// Releases all resources currently used by this <see cref="Hub"/> instance.
/// </summary>
/// <param name="disposing"><c>true</c> if this method is being invoked by the <see cref="Dispose()"/> method,
/// otherwise <c>false</c>.</param>
protected virtual void Dispose(bool disposing)
{
}
/// <inheritdoc />
public void Dispose()
{
if (_disposed)
{
return;
}
Dispose(true);
_disposed = true;
}
private void CheckDisposed()
{
ObjectDisposedException.ThrowIf(_disposed, this);
}
}
|