|
// 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;
using System.Globalization;
using System.Runtime.CompilerServices;
using System.Text;
using System.Threading.Channels;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http.Metadata;
using Microsoft.Extensions.DependencyInjection;
using Newtonsoft.Json.Serialization;
namespace Microsoft.AspNetCore.SignalR.Tests;
public class MethodHub : TestHub
{
public Task GroupRemoveMethod(string groupName)
{
return Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName);
}
public Task ClientSendMethod(string userId, string message)
{
return Clients.User(userId).SendAsync("Send", message);
}
public Task SendToMultipleUsers(IReadOnlyList<string> userIds, string message)
{
return Clients.Users(userIds).SendAsync("Send", message);
}
public Task ConnectionSendMethod(string connectionId, string message)
{
return Clients.Client(connectionId).SendAsync("Send", message);
}
public Task SendToMultipleClients(string message, IReadOnlyList<string> connectionIds)
{
return Clients.Clients(connectionIds).SendAsync("Send", message);
}
public Task GroupAddMethod(string groupName)
{
return Groups.AddToGroupAsync(Context.ConnectionId, groupName);
}
public Task GroupSendMethod(string groupName, string message)
{
return Clients.Group(groupName).SendAsync("Send", message);
}
public Task GroupExceptSendMethod(string groupName, string message, IReadOnlyList<string> excludedConnectionIds)
{
return Clients.GroupExcept(groupName, excludedConnectionIds).SendAsync("Send", message);
}
public Task SendToMultipleGroups(string message, IReadOnlyList<string> groupNames)
{
return Clients.Groups(groupNames).SendAsync("Send", message);
}
public Task SendToOthersInGroup(string groupName, string message)
{
return Clients.OthersInGroup(groupName).SendAsync("Send", message);
}
public Task BroadcastMethod(string message)
{
return Clients.All.SendAsync("Broadcast", message);
}
public Task BroadcastItem()
{
return Clients.All.SendAsync("Broadcast", new Result { Message = "test", paramName = "param" });
}
public Task SendArray()
{
return Clients.All.SendAsync("Array", new[] { 1, 2, 3 });
}
public Task<int> TaskValueMethod()
{
return Task.FromResult(42);
}
public int ValueMethod()
{
return 43;
}
public ValueTask ValueTaskMethod()
{
return new ValueTask(Task.CompletedTask);
}
public ValueTask<int> ValueTaskValueMethod()
{
return new ValueTask<int>(43);
}
[HubMethodName("RenamedMethod")]
public int ATestMethodThatIsRenamedByTheAttribute()
{
return 43;
}
public string Echo(string data)
{
return data;
}
public void VoidMethod()
{
}
public string ConcatString(byte b, int i, char c, string s)
{
return $"{b}, {i}, {c}, {s}";
}
public Task SendAnonymousObject()
{
return Clients.Client(Context.ConnectionId).SendAsync("Send", new { });
}
public override Task OnDisconnectedAsync(Exception e)
{
return Task.CompletedTask;
}
public void MethodThatThrows()
{
throw new InvalidOperationException("BOOM!");
}
public void ThrowHubException()
{
throw new HubException("This is a hub exception");
}
public Task MethodThatYieldsFailedTask()
{
return Task.FromException(new InvalidOperationException("BOOM!"));
}
public static void StaticMethod()
{
}
[Authorize("test")]
public void AuthMethod()
{
}
[Authorize("test")]
public void MultiParamAuthMethod(string s1, string s2)
{
}
public Task SendToAllExcept(string message, IReadOnlyList<string> excludedConnectionIds)
{
return Clients.AllExcept(excludedConnectionIds).SendAsync("Send", message);
}
public bool HasHttpContext()
{
return Context.GetHttpContext() != null;
}
public Task SendToOthers(string message)
{
return Clients.Others.SendAsync("Send", message);
}
public Task SendToCaller(string message)
{
return Clients.Caller.SendAsync("Send", message);
}
public Task ProtocolError()
{
return Clients.Caller.SendAsync("Send", new SelfRef());
}
public void InvalidArgument(CancellationToken token)
{
}
public async Task<string> StreamingConcat(ChannelReader<string> source)
{
var sb = new StringBuilder();
while (await source.WaitToReadAsync())
{
while (source.TryRead(out var item))
{
sb.Append(item);
}
}
return sb.ToString();
}
public async Task StreamDontRead(ChannelReader<string> source)
{
while (await source.WaitToReadAsync())
{
}
}
public async Task<int> StreamingSum(ChannelReader<int> source)
{
var total = 0;
while (await source.WaitToReadAsync())
{
while (source.TryRead(out var item))
{
total += item;
}
}
return total;
}
public async Task<List<object>> UploadArray(ChannelReader<object> source)
{
var results = new List<object>();
while (await source.WaitToReadAsync())
{
while (source.TryRead(out var item))
{
results.Add(item);
}
}
return results;
}
[Authorize("test")]
public async Task<List<object>> UploadArrayAuth(ChannelReader<object> source)
{
var results = new List<object>();
while (await source.WaitToReadAsync())
{
while (source.TryRead(out var item))
{
results.Add(item);
}
}
return results;
}
public async Task<string> TestTypeCastingErrors(ChannelReader<int> source)
{
try
{
await source.WaitToReadAsync();
}
catch (Exception)
{
return "error identified and caught";
}
return "wrong type accepted, this is bad";
}
public async Task<bool> TestCustomErrorPassing(ChannelReader<int> source)
{
try
{
await source.WaitToReadAsync();
}
catch (Exception ex)
{
return ex.Message == HubConnectionHandlerTests.CustomErrorMessage;
}
return false;
}
public Task UploadIgnoreItems(ChannelReader<string> source)
{
// Wait for an item to appear first then return from the hub method to end the invocation
return source.WaitToReadAsync().AsTask();
}
public ChannelReader<string> StreamAndUploadIgnoreItems(ChannelReader<string> source)
{
var channel = Channel.CreateUnbounded<string>();
_ = ChannelFunc(channel.Writer, source);
return channel.Reader;
async Task ChannelFunc(ChannelWriter<string> output, ChannelReader<string> input)
{
// Wait for an item to appear first then return from the hub method to end the invocation
await input.WaitToReadAsync();
output.Complete();
}
}
public async Task UploadDoesWorkOnComplete(ChannelReader<string> source)
{
var tcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Context.Items[nameof(UploadDoesWorkOnComplete)] = tcs.Task;
try
{
while (await source.WaitToReadAsync())
{
while (source.TryRead(out var item))
{
}
}
}
catch (Exception ex)
{
tcs.SetException(ex);
}
finally
{
tcs.TrySetResult(42);
}
}
public async Task BlockingMethod()
{
var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Context.ConnectionAborted.Register(state => ((TaskCompletionSource)state).SetResult(), tcs);
await tcs.Task;
}
public async Task<int> GetClientResult(int num)
{
var sum = await Clients.Caller.InvokeAsync<int>("Sum", num, cancellationToken: default);
return sum;
}
public void BackgroundClientResult(TcsService tcsService)
{
var caller = Clients.Caller;
_ = Task.Run(async () =>
{
try
{
await tcsService.StartedMethod.Task;
var result = await caller.InvokeAsync<int>("GetResult", 1, CancellationToken.None);
tcsService.EndMethod.SetResult(result);
}
catch (Exception ex)
{
tcsService.EndMethod.SetException(ex);
}
});
}
public async Task<int> GetClientResultWithStream(ChannelReader<int> channelReader)
{
var sum = await Clients.Caller.InvokeAsync<int>("Sum", 1, cancellationToken: default);
return sum;
}
public async IAsyncEnumerable<int> StreamWithClientResult()
{
var sum = await Clients.Caller.InvokeAsync<int>("Sum", 1, cancellationToken: default);
yield return sum;
}
public void ActivityMethod(TestActivitySource testActivitySource)
{
var activity = testActivitySource.ActivitySource.StartActivity("inner", ActivityKind.Server);
activity.Stop();
}
}
internal class SelfRef
{
public SelfRef()
{
Self = this;
}
public SelfRef Self { get; set; }
}
public class TestActivitySource
{
public ActivitySource ActivitySource { get; set; }
}
public abstract class TestHub : Hub
{
public override Task OnConnectedAsync()
{
var tcs = (TaskCompletionSource)Context.Items["ConnectedTask"];
tcs?.TrySetResult();
return base.OnConnectedAsync();
}
}
public class DynamicTestHub : DynamicHub
{
public override Task OnConnectedAsync()
{
var tcs = (TaskCompletionSource)Context.Items["ConnectedTask"];
tcs?.TrySetResult();
return base.OnConnectedAsync();
}
public string Echo(string data)
{
return data;
}
public Task ClientSendMethod(string userId, string message)
{
return Clients.User(userId).Send(message);
}
public Task SendToMultipleUsers(List<string> userIds, string message)
{
return Clients.Users(userIds).Send(message);
}
public Task ConnectionSendMethod(string connectionId, string message)
{
return Clients.Client(connectionId).Send(message);
}
public Task SendToMultipleClients(string message, IReadOnlyList<string> connectionIds)
{
return Clients.Clients(connectionIds).Send(message);
}
public Task GroupAddMethod(string groupName)
{
return Groups.AddToGroupAsync(Context.ConnectionId, groupName);
}
public Task GroupSendMethod(string groupName, string message)
{
return Clients.Group(groupName).Send(message);
}
public Task GroupExceptSendMethod(string groupName, string message, IReadOnlyList<string> excludedConnectionIds)
{
return Clients.GroupExcept(groupName, excludedConnectionIds).Send(message);
}
public Task SendToOthersInGroup(string groupName, string message)
{
return Clients.OthersInGroup(groupName).Send(message);
}
public Task SendToMultipleGroups(string message, IReadOnlyList<string> groupNames)
{
return Clients.Groups(groupNames).Send(message);
}
public Task BroadcastMethod(string message)
{
return Clients.All.Broadcast(message);
}
public Task SendToAllExcept(string message, IReadOnlyList<string> excludedConnectionIds)
{
return Clients.AllExcept(excludedConnectionIds).Send(message);
}
public Task SendToOthers(string message)
{
return Clients.Others.Send(message);
}
public Task SendToCaller(string message)
{
return Clients.Caller.Send(message);
}
}
public class HubT : Hub<ITest>
{
public override Task OnConnectedAsync()
{
var tcs = (TaskCompletionSource)Context.Items["ConnectedTask"];
tcs?.TrySetResult();
return base.OnConnectedAsync();
}
public string Echo(string data)
{
return data;
}
public Task ClientSendMethod(string userId, string message)
{
return Clients.User(userId).Send(message);
}
public Task SendToMultipleUsers(List<string> userIds, string message)
{
return Clients.Users(userIds).Send(message);
}
public Task ConnectionSendMethod(string connectionId, string message)
{
return Clients.Client(connectionId).Send(message);
}
public Task SendToMultipleClients(string message, IReadOnlyList<string> connectionIds)
{
return Clients.Clients(connectionIds).Send(message);
}
public async Task DelayedSend(string connectionId, string message)
{
await Task.Delay(100);
await Clients.Client(connectionId).Send(message);
}
public Task GroupAddMethod(string groupName)
{
return Groups.AddToGroupAsync(Context.ConnectionId, groupName);
}
public Task GroupSendMethod(string groupName, string message)
{
return Clients.Group(groupName).Send(message);
}
public Task GroupExceptSendMethod(string groupName, string message, IReadOnlyList<string> excludedConnectionIds)
{
return Clients.GroupExcept(groupName, excludedConnectionIds).Send(message);
}
public Task SendToMultipleGroups(string message, IReadOnlyList<string> groupNames)
{
return Clients.Groups(groupNames).Send(message);
}
public Task SendToOthersInGroup(string groupName, string message)
{
return Clients.OthersInGroup(groupName).Send(message);
}
public Task BroadcastMethod(string message)
{
return Clients.All.Broadcast(message);
}
public Task SendToAllExcept(string message, IReadOnlyList<string> excludedConnectionIds)
{
return Clients.AllExcept(excludedConnectionIds).Send(message);
}
public Task SendToOthers(string message)
{
return Clients.Others.Send(message);
}
public Task SendToCaller(string message)
{
return Clients.Caller.Send(message);
}
public async Task<ClientResults> GetClientResultTwoWays(int clientValue, int callerValue) =>
new ClientResults(
await Clients.Client(Context.ConnectionId).GetClientResult(clientValue),
await Clients.Caller.GetClientResult(callerValue));
}
public interface ITest
{
Task Send(string message);
Task Broadcast(string message);
Task<int> GetClientResult(int value);
Task<int> GetClientResultWithCancellation(int value, CancellationToken cancellationToken);
}
public record ClientResults(int ClientResult, int CallerResult);
public class OnConnectedThrowsHub : Hub
{
public override Task OnConnectedAsync()
{
var tcs = new TaskCompletionSource();
tcs.SetException(new InvalidOperationException("Hub OnConnected failed."));
return tcs.Task;
}
}
public class OnDisconnectedThrowsHub : TestHub
{
public override Task OnDisconnectedAsync(Exception exception)
{
var tcs = new TaskCompletionSource();
tcs.SetException(new InvalidOperationException("Hub OnDisconnected failed."));
return tcs.Task;
}
}
public class InheritedHub : BaseHub
{
public override int VirtualMethod(int num)
{
return num - 10;
}
public override int VirtualMethodRenamed()
{
return 34;
}
}
public class BaseHub : TestHub
{
public string BaseMethod(string message)
{
return message;
}
public virtual int VirtualMethod(int num)
{
return num;
}
[HubMethodName("RenamedVirtualMethod")]
public virtual int VirtualMethodRenamed()
{
return 43;
}
}
public class InvalidHub : TestHub
{
public void OverloadedMethod(int num)
{
}
public void OverloadedMethod(string message)
{
}
}
public class GenericMethodHub : Hub
{
public void GenericMethod<T>()
{
}
}
public class DisposeTrackingHub : TestHub
{
private readonly TrackDispose _trackDispose;
public DisposeTrackingHub(TrackDispose trackDispose)
{
_trackDispose = trackDispose;
}
protected override void Dispose(bool dispose)
{
if (dispose)
{
_trackDispose.DisposeCount++;
}
}
}
public class HubWithAsyncDisposable : TestHub
{
private readonly AsyncDisposable _disposable;
public HubWithAsyncDisposable(AsyncDisposable disposable)
{
_disposable = disposable;
}
public void Test()
{
}
}
public class AbortHub : Hub
{
public void Kill()
{
Context.Abort();
}
}
public class StreamingHub : TestHub
{
public ChannelReader<string> CounterChannel(int count)
{
var channel = Channel.CreateUnbounded<string>();
_ = Task.Run(async () =>
{
for (int i = 0; i < count; i++)
{
await channel.Writer.WriteAsync(i.ToString(CultureInfo.InvariantCulture));
}
channel.Writer.Complete();
});
return channel.Reader;
}
public async Task<ChannelReader<string>> CounterChannelAsync(int count)
{
await Task.Yield();
return CounterChannel(count);
}
[HubMethodName("RenamedCounterChannel")]
public async Task<ChannelReader<string>> CounterChannelAsync2(int count)
{
await Task.Yield();
return CounterChannel(count);
}
public async ValueTask<ChannelReader<string>> CounterChannelValueTaskAsync(int count)
{
await Task.Yield();
return CounterChannel(count);
}
public async IAsyncEnumerable<string> CounterAsyncEnumerable(int count)
{
for (int i = 0; i < count; i++)
{
await Task.Yield();
yield return i.ToString(CultureInfo.InvariantCulture);
}
}
public async IAsyncEnumerable<string> ExceptionAsyncEnumerable()
{
await Task.Yield();
throw new Exception("Exception from async enumerable");
#pragma warning disable CS0162 // Unreachable code detected
yield break;
#pragma warning restore CS0162 // Unreachable code detected
}
public async Task<IAsyncEnumerable<string>> CounterAsyncEnumerableAsync(int count)
{
await Task.Yield();
return CounterAsyncEnumerable(count);
}
public AsyncEnumerableImpl<string> CounterAsyncEnumerableImpl(int count)
{
return new AsyncEnumerableImpl<string>(CounterAsyncEnumerable(count));
}
public AsyncEnumerableImplChannelThrows<string> AsyncEnumerableIsPreferredOverChannelReader(int count)
{
return new AsyncEnumerableImplChannelThrows<string>(CounterChannel(count));
}
public ChannelReader<string> BlockingStream()
{
return Channel.CreateUnbounded<string>().Reader;
}
public ChannelReader<int> ExceptionStream()
{
var channel = Channel.CreateUnbounded<int>();
channel.Writer.TryComplete(new Exception("Exception from channel"));
return channel.Reader;
}
public ChannelReader<int> ChannelClosedExceptionStream()
{
var channel = Channel.CreateUnbounded<int>();
channel.Writer.TryComplete(new ChannelClosedException("ChannelClosedException from channel"));
return channel.Reader;
}
public ChannelReader<int> ChannelClosedExceptionInnerExceptionStream()
{
var channel = Channel.CreateUnbounded<int>();
channel.Writer.TryComplete(new ChannelClosedException(new Exception("ChannelClosedException from channel")));
return channel.Reader;
}
public ChannelReader<int> ThrowStream()
{
throw new Exception("Throw from hub method");
}
public ChannelReader<int> NullStream()
{
return null;
}
public int NonStream()
{
return 42;
}
public ChannelReader<string> StreamEcho(ChannelReader<string> source)
{
Channel<string> output = Channel.CreateUnbounded<string>();
_ = Task.Run(async () =>
{
while (await source.WaitToReadAsync())
{
while (source.TryRead(out string item))
{
await output.Writer.WriteAsync("echo:" + item);
}
}
output.Writer.TryComplete();
});
return output.Reader;
}
public async IAsyncEnumerable<string> DerivedParameterInterfaceAsyncEnumerable(IDerivedParameterTestObject param)
{
await Task.Yield();
yield return param.Value;
}
public async IAsyncEnumerable<string> DerivedParameterBaseClassAsyncEnumerable(DerivedParameterTestObjectBase param)
{
await Task.Yield();
yield return param.Value;
}
public async IAsyncEnumerable<string> DerivedParameterInterfaceAsyncEnumerableWithCancellation(IDerivedParameterTestObject param, [EnumeratorCancellation] CancellationToken token)
{
await Task.Yield();
yield return param.Value;
}
public async IAsyncEnumerable<string> DerivedParameterBaseClassAsyncEnumerableWithCancellation(DerivedParameterTestObjectBase param, [EnumeratorCancellation] CancellationToken token)
{
await Task.Yield();
yield return param.Value;
}
public class AsyncEnumerableImpl<T> : IAsyncEnumerable<T>
{
private readonly IAsyncEnumerable<T> _inner;
public AsyncEnumerableImpl(IAsyncEnumerable<T> inner)
{
_inner = inner;
}
public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default)
{
return _inner.GetAsyncEnumerator(cancellationToken);
}
}
public class AsyncEnumerableImplChannelThrows<T> : ChannelReader<T>, IAsyncEnumerable<T>
{
private readonly ChannelReader<T> _inner;
public AsyncEnumerableImplChannelThrows(ChannelReader<T> inner)
{
_inner = inner;
}
public override bool TryRead(out T item)
{
// Not implemented to verify this is consumed as an IAsyncEnumerable<T> instead of a ChannelReader<T>.
throw new NotImplementedException();
}
public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken = default)
{
// Not implemented to verify this is consumed as an IAsyncEnumerable<T> instead of a ChannelReader<T>.
throw new NotImplementedException();
}
public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default)
{
return new ChannelAsyncEnumerator(_inner, cancellationToken);
}
// Copied from AsyncEnumeratorAdapters
private class ChannelAsyncEnumerator : IAsyncEnumerator<T>
{
/// <summary>The channel being enumerated.</summary>
private readonly ChannelReader<T> _channel;
/// <summary>Cancellation token used to cancel the enumeration.</summary>
private readonly CancellationToken _cancellationToken;
/// <summary>The current element of the enumeration.</summary>
private T _current;
public ChannelAsyncEnumerator(ChannelReader<T> channel, CancellationToken cancellationToken)
{
_channel = channel;
_cancellationToken = cancellationToken;
}
public T Current => _current;
public ValueTask<bool> MoveNextAsync()
{
var result = _channel.ReadAsync(_cancellationToken);
if (result.IsCompletedSuccessfully)
{
_current = result.Result;
return new ValueTask<bool>(true);
}
return new ValueTask<bool>(MoveNextAsyncAwaited(result));
}
private async Task<bool> MoveNextAsyncAwaited(ValueTask<T> channelReadTask)
{
try
{
_current = await channelReadTask;
}
catch (ChannelClosedException ex) when (ex.InnerException == null)
{
return false;
}
return true;
}
public ValueTask DisposeAsync()
{
return default;
}
}
}
public interface IDerivedParameterTestObject
{
public string Value { get; set; }
}
public abstract class DerivedParameterTestObjectBase : IDerivedParameterTestObject
{
public string Value { get; set; }
}
public class DerivedParameterTestObject : DerivedParameterTestObjectBase { }
public class DerivedParameterKnownTypesBinder : ISerializationBinder
{
private static readonly IEnumerable<Type> _knownTypes = new List<Type>()
{
typeof(DerivedParameterTestObject)
};
public static ISerializationBinder Instance { get; } = new DerivedParameterKnownTypesBinder();
public void BindToName(Type serializedType, out string assemblyName, out string typeName)
{
assemblyName = null;
typeName = serializedType.Name;
}
public Type BindToType(string assemblyName, string typeName) =>
_knownTypes.Single(type => type.Name == typeName);
}
}
public class SimpleHub : Hub
{
public override async Task OnConnectedAsync()
{
await Clients.All.SendAsync("Send", $"{Context.ConnectionId} joined");
await base.OnConnectedAsync();
}
}
public class SimpleVoidReturningTypedHub : Hub<IVoidReturningTypedHubClient>
{
public override Task OnConnectedAsync()
{
// Derefernce Clients, to force initialization of the TypedHubClient
Clients.All.Send("herp");
return Task.CompletedTask;
}
}
public class SimpleTypedHub : Hub<ITypedHubClient>
{
public override async Task OnConnectedAsync()
{
await Clients.All.Send($"{Context.ConnectionId} joined");
await base.OnConnectedAsync();
}
}
public class LongRunningHub : Hub
{
private readonly TcsService _tcsService;
public LongRunningHub(TcsService tcsService)
{
_tcsService = tcsService;
}
public async Task<int> LongRunningMethod()
{
_tcsService.StartedMethod.TrySetResult(null);
await _tcsService.EndMethod.Task;
return 12;
}
public async Task<ChannelReader<string>> LongRunningStream()
{
_tcsService.StartedMethod.TrySetResult(null);
await _tcsService.EndMethod.Task;
// Never ending stream
return Channel.CreateUnbounded<string>().Reader;
}
public ChannelReader<int> CancelableStreamSingleParameter(CancellationToken token)
{
var channel = Channel.CreateBounded<int>(10);
Task.Run(async () =>
{
_tcsService.StartedMethod.SetResult(null);
await token.WaitForCancellationAsync();
channel.Writer.TryComplete();
_tcsService.EndMethod.SetResult(null);
});
return channel.Reader;
}
public ChannelReader<int> CancelableStreamMultiParameter(int ignore, int ignore2, CancellationToken token)
{
var channel = Channel.CreateBounded<int>(10);
Task.Run(async () =>
{
_tcsService.StartedMethod.SetResult(null);
await token.WaitForCancellationAsync();
channel.Writer.TryComplete();
_tcsService.EndMethod.SetResult(null);
});
return channel.Reader;
}
public ChannelReader<int> CancelableStreamNullableParameter(int x, string y, CancellationToken token)
{
var channel = Channel.CreateBounded<int>(10);
Task.Run(async () =>
{
_tcsService.StartedMethod.SetResult(x);
await token.WaitForCancellationAsync();
channel.Writer.TryComplete();
_tcsService.EndMethod.SetResult(y);
});
return channel.Reader;
}
public ChannelReader<int> StreamNullableParameter(int x, int? input)
{
var channel = Channel.CreateBounded<int>(10);
Task.Run(() =>
{
_tcsService.StartedMethod.SetResult(x);
channel.Writer.TryComplete();
_tcsService.EndMethod.SetResult(input);
return Task.CompletedTask;
});
return channel.Reader;
}
public ChannelReader<int> CancelableStreamMiddleParameter(int ignore, CancellationToken token, int ignore2)
{
var channel = Channel.CreateBounded<int>(10);
Task.Run(async () =>
{
_tcsService.StartedMethod.SetResult(null);
await token.WaitForCancellationAsync();
channel.Writer.TryComplete();
_tcsService.EndMethod.SetResult(null);
});
return channel.Reader;
}
public async IAsyncEnumerable<int> CancelableStreamGeneratedAsyncEnumerable([EnumeratorCancellation] CancellationToken token)
{
_tcsService.StartedMethod.SetResult(null);
await token.WaitForCancellationAsync();
_tcsService.EndMethod.SetResult(null);
yield break;
}
public async IAsyncEnumerable<int> CountingCancelableStreamGeneratedAsyncEnumerable(int count, [EnumeratorCancellation] CancellationToken token)
{
for (int i = 0; i < count; i++)
{
await Task.Yield();
yield return i;
}
_tcsService.StartedMethod.SetResult(null);
await token.WaitForCancellationAsync();
_tcsService.EndMethod.SetResult(null);
yield break;
}
public ChannelReader<int> CountingCancelableStreamGeneratedChannel(int count, CancellationToken token)
{
var channel = Channel.CreateBounded<int>(10);
Task.Run(async () =>
{
for (int i = 0; i < count; i++)
{
await Task.Yield();
await channel.Writer.WriteAsync(i);
}
_tcsService.StartedMethod.SetResult(null);
await token.WaitForCancellationAsync();
channel.Writer.TryComplete();
_tcsService.EndMethod.SetResult(null);
});
return channel.Reader;
}
public IAsyncEnumerable<int> CancelableStreamCustomAsyncEnumerable()
{
return new CustomAsyncEnumerable(_tcsService);
}
public int SimpleMethod()
{
return 21;
}
public async Task Upload(ChannelReader<string> stream)
{
_tcsService.StartedMethod.SetResult(null);
_ = await stream.ReadAndCollectAllAsync();
_tcsService.EndMethod.SetResult(null);
}
private class CustomAsyncEnumerable : IAsyncEnumerable<int>
{
private readonly TcsService _tcsService;
public CustomAsyncEnumerable(TcsService tcsService)
{
_tcsService = tcsService;
}
public IAsyncEnumerator<int> GetAsyncEnumerator(CancellationToken cancellationToken = default)
{
return new CustomAsyncEnumerator(_tcsService, cancellationToken);
}
private class CustomAsyncEnumerator : IAsyncEnumerator<int>
{
private readonly TcsService _tcsService;
private readonly CancellationToken _cancellationToken;
public CustomAsyncEnumerator(TcsService tcsService, CancellationToken cancellationToken)
{
_tcsService = tcsService;
_cancellationToken = cancellationToken;
}
public int Current => throw new NotImplementedException();
public ValueTask DisposeAsync()
{
return default;
}
public async ValueTask<bool> MoveNextAsync()
{
_tcsService.StartedMethod.SetResult(null);
await _cancellationToken.WaitForCancellationAsync();
_tcsService.EndMethod.SetResult(null);
return false;
}
}
}
}
public class TcsService
{
public TaskCompletionSource<object> StartedMethod;
public TaskCompletionSource<object> EndMethod;
public TcsService()
{
Reset();
}
public void Reset()
{
StartedMethod = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
EndMethod = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
}
}
public interface ITypedHubClient
{
Task Send(string message);
}
public interface IVoidReturningTypedHubClient
{
void Send(string message);
}
public class ErrorInAbortedTokenHub : Hub
{
public override Task OnConnectedAsync()
{
Context.Items[nameof(OnConnectedAsync)] = true;
Context.ConnectionAborted.Register(() =>
{
throw new InvalidOperationException("BOOM");
});
return base.OnConnectedAsync();
}
public override Task OnDisconnectedAsync(Exception exception)
{
Context.Items[nameof(OnDisconnectedAsync)] = true;
return base.OnDisconnectedAsync(exception);
}
}
public class ConnectionLifetimeHub : Hub
{
private readonly ConnectionLifetimeState _state;
public ConnectionLifetimeHub(ConnectionLifetimeState state)
{
_state = state;
}
public override Task OnConnectedAsync()
{
_state.TokenStateInConnected = Context.ConnectionAborted.IsCancellationRequested;
Context.ConnectionAborted.Register(() =>
{
_state.TokenCallbackTriggered = true;
});
return base.OnConnectedAsync();
}
public Task ProtocolErrorSelf()
{
return Clients.Caller.SendAsync("Send", new SelfRef());
}
public Task ProtocolErrorAll()
{
return Clients.All.SendAsync("Send", new SelfRef());
}
public override Task OnDisconnectedAsync(Exception exception)
{
_state.TokenStateInDisconnected = Context.ConnectionAborted.IsCancellationRequested;
_state.DisconnectedException = exception;
return base.OnDisconnectedAsync(exception);
}
}
public class ConnectionLifetimeState
{
public bool TokenCallbackTriggered { get; set; }
public bool TokenStateInConnected { get; set; }
public bool TokenStateInDisconnected { get; set; }
public Exception DisconnectedException { get; set; }
}
public class OnConnectedClientResultHub : Hub
{
public override async Task OnConnectedAsync()
{
await Clients.Caller.InvokeAsync<int>("Test", cancellationToken: default);
}
}
public class OnDisconnectedClientResultHub : Hub
{
public override async Task OnDisconnectedAsync(Exception ex)
{
await Clients.Caller.InvokeAsync<int>("Test", cancellationToken: default);
}
}
public class CallerServiceHub : Hub
{
private readonly CallerService _service;
public CallerServiceHub(CallerService service)
{
_service = service;
}
public override Task OnConnectedAsync()
{
_service.SetCaller(Clients.Caller);
var tcs = (TaskCompletionSource)Context.Items["ConnectedTask"];
tcs?.TrySetResult();
return base.OnConnectedAsync();
}
}
public class CallerService
{
public IClientProxy Caller { get; private set; }
public void SetCaller(IClientProxy caller)
{
Caller = caller;
}
}
[AttributeUsage(AttributeTargets.Parameter, AllowMultiple = false, Inherited = true)]
public class FromService : Attribute, IFromServiceMetadata
{ }
public class Service1
{ }
public class Service2
{ }
public class Service3
{ }
public class ServicesHub : TestHub
{
public bool SingleService([FromService] Service1 service)
{
return true;
}
public bool MultipleServices([FromService] Service1 service, [FromService] Service2 service2, [FromService] Service3 service3)
{
return true;
}
public async Task<int> ServicesAndParams(int value, [FromService] Service1 service, ChannelReader<int> channelReader, [FromService] Service2 service2, bool value2)
{
int total = 0;
while (await channelReader.WaitToReadAsync())
{
total += await channelReader.ReadAsync();
}
return total + value;
}
public int ServiceWithoutAttribute(Service1 service)
{
return 1;
}
public int ServiceWithAndWithoutAttribute(Service1 service, [FromService] Service2 service2)
{
return 1;
}
public int IEnumerableOfServiceWithoutAttribute(IEnumerable<Service1> services)
{
return 1;
}
public async Task Stream(ChannelReader<int> channelReader)
{
while (await channelReader.WaitToReadAsync())
{
await channelReader.ReadAsync();
}
}
}
public class KeyedServicesHub : TestHub
{
public int MultipleSameKeyedServices([FromKeyedServices("service1")] Service1 service, [FromKeyedServices("service1")] Service1 service2)
{
Assert.Same(service, service2);
return 445;
}
public int KeyedService([FromKeyedServices("service1")] Service1 service)
{
return 43;
}
public int KeyedServiceWithParam(int input, [FromKeyedServices("service1")] Service1 service)
{
return 13 * input;
}
public int KeyedServiceNonKeyedService(Service2 service2, [FromKeyedServices("service1")] Service1 service)
{
return 11;
}
public int MultipleKeyedServices([FromKeyedServices("service1")] Service1 service, [FromKeyedServices("service2")] Service1 service2)
{
Assert.NotEqual(service, service2);
return 45;
}
}
public class BadServicesHub : Hub
{
public void BadMethod([FromKeyedServices("service1")] [FromService] Service1 service)
{
}
}
public class TooManyParamsHub : Hub
{
public void ManyParams(int a1, string a2, bool a3, float a4, string a5, int a6, int a7, int a8, int a9, int a10, int a11,
int a12, int a13, int a14, int a15, int a16, int a17, int a18, int a19, int a20, int a21, int a22, int a23, int a24,
int a25, int a26, int a27, int a28, int a29, int a30, int a31, int a32, int a33, int a34, int a35, int a36, int a37,
int a38, int a39, int a40, int a41, int a42, int a43, int a44, int a45, int a46, int a47, int a48, int a49, int a50,
int a51, int a52, int a53, int a54, int a55, int a56, int a57, int a58, int a59, int a60, int a61, int a62, int a63,
int a64, [FromService] Service1 service)
{ }
}
public class OnConnectedSendToClientHub : Hub
{
public override async Task OnConnectedAsync()
{
string id = Context.GetHttpContext()?.Request.Query["client"] ?? string.Empty;
if (!string.IsNullOrEmpty(id))
{
await Clients.Client(id).SendAsync("Test", 1);
}
}
}
|