notfire/Iceshrimp.NET
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[backend/signalr] Remove ExampleHub

Browse source
This commit is contained in:
Laura Hausmann 2024-07-12 23:50:20 +02:00
parent 7a67b8a472
commit 68867aee90
No known key found for this signature in database
GPG key ID: D044E84C5BE01605
5 changed files with 0 additions and 132 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
Iceshrimp.Backend/SignalR/ExampleHub.cs
View file

@ -1,12 +0,0 @@
using Iceshrimp.Shared.Schemas.SignalR;
using Microsoft.AspNetCore.SignalR;
namespace Iceshrimp.Backend.SignalR;
public class ExampleHub : Hub<IExampleHubClient>, IExampleHubServer
{
public async Task SendMessage(string user, string message)
{
await Clients.All.ReceiveMessage("SignalR", "ping!");
}
}

1
Iceshrimp.Backend/Startup.cs
View file

@ -66,7 +66,6 @@ app.UseCustomMiddleware();
app.MapControllers(); app.MapControllers();
app.MapFallbackToController("/api/{**slug}", "FallbackAction", "Fallback").WithOrder(int.MaxValue - 3); app.MapFallbackToController("/api/{**slug}", "FallbackAction", "Fallback").WithOrder(int.MaxValue - 3);
app.MapHub<ExampleHub>("/hubs/example");
app.MapHub<StreamingHub>("/hubs/streaming"); app.MapHub<StreamingHub>("/hubs/streaming");
app.MapRazorPages(); app.MapRazorPages();
app.MapFrontendRoutes("/Shared/FrontendSPA"); app.MapFrontendRoutes("/Shared/FrontendSPA");

32
Iceshrimp.Frontend/Pages/Hub.razor
View file

@ -1,32 +0,0 @@
@page "/hub"
@inject NavigationManager Navigation
@implements IAsyncDisposable
<PageTitle>Home</PageTitle>
<div class="form-group mb-3">
<label>
User:
<input class="form-control" @bind="_userInput"/>
</label>
</div>
<div class="form-group mb-3">
<label>
Message:
<input class="form-control" @bind="_messageInput" size="50"/>
</label>
</div>
<button class="btn btn-primary" @onclick="Send" disabled="@(!IsConnected)">Send</button>
<hr>
<ul id="messagesList">
@foreach (var message in _messages)
{
<li>@message</li>
}
</ul>
@code {
// See Hub.razor.cs
}

76
Iceshrimp.Frontend/Pages/Hub.razor.cs
View file

@ -1,76 +0,0 @@
using Iceshrimp.Shared.Schemas.SignalR;
using Microsoft.AspNetCore.SignalR.Client;
using TypedSignalR.Client;
namespace Iceshrimp.Frontend.Pages;
public partial class Hub
{
private IExampleHubServer? _hub;
private HubConnection? _hubConnection;
private string _messageInput = "";
private readonly List<string> _messages = [];
private string _userInput = "";
private bool IsConnected => _hubConnection?.State == HubConnectionState.Connected;
public async ValueTask DisposeAsync()
{
if (_hubConnection is not null)
{
await _hubConnection.DisposeAsync();
}
}
protected override async Task OnInitializedAsync()
{
_hubConnection = new HubConnectionBuilder()
.WithUrl(Navigation.ToAbsoluteUri("/hubs/example"))
.AddMessagePackProtocol()
.Build();
// This must be in a .razor.cs file for the code generator to work correctly
_hub = _hubConnection.CreateHubProxy<IExampleHubServer>();
//TODO: authentication is done like this:
//options => { options.AccessTokenProvider = () => Task.FromResult("the_access_token")!; })
_hubConnection.Register<IExampleHubClient>(new ExampleHubClient(this));
await _hubConnection.StartAsync();
}
private async Task Send()
{
if (_hub is not null)
{
await _hub.SendMessage(_userInput, _messageInput);
}
}
private class ExampleHubClient(Hub page) : IExampleHubClient, IHubConnectionObserver
{
public Task ReceiveMessage(string user, string message)
{
var encodedMsg = $"{user}: {message}";
page._messages.Add(encodedMsg);
page.InvokeAsync(page.StateHasChanged);
return Task.CompletedTask;
}
public Task OnClosed(Exception? exception)
{
return ReceiveMessage("System", "Connection closed.");
}
public Task OnReconnected(string? connectionId)
{
return ReceiveMessage("System", "Reconnected.");
}
public Task OnReconnecting(Exception? exception)
{
return ReceiveMessage("System", "Reconnecting...");
}
}
}

11
Iceshrimp.Shared/Schemas/SignalR/ExampleHub.cs
View file

@ -1,11 +0,0 @@
namespace Iceshrimp.Shared.Schemas.SignalR;
public interface IExampleHubServer
{
public Task SendMessage(string user, string message);
}
public interface IExampleHubClient
{
public Task ReceiveMessage(string user, string message);
}