alex/canvasManagement
1
0
Fork 0
mirror of https://github.com/alexmickelson/canvasManagement.git synced 2026-03-25 23:28:33 -06:00
Code Issues Packages Projects Releases Wiki Activity

removed akka.net

Browse Source
This commit is contained in:
Alex Mickelson
2024-05-03 15:03:12 -06:00
parent b3ee8560ef
commit 353bd6df82
15 changed files with 27 additions and 248 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
Management.Web/AkkaService.cs
View File

@@ -1,62 +0,0 @@
using Akka.Actor;
using Akka.DependencyInjection;
namespace Management.Actors;
public class AkkaService : IHostedService, IActorBridge
{
private ActorSystem? _actorSystem;
private readonly IConfiguration _configuration;
private readonly IServiceProvider _serviceProvider;
private IActorRef? _canvasApiActor;
private readonly IHostApplicationLifetime _applicationLifetime;
public AkkaService(IServiceProvider serviceProvider, IHostApplicationLifetime appLifetime, IConfiguration configuration)
{
_serviceProvider = serviceProvider;
_applicationLifetime = appLifetime;
_configuration = configuration;
}
public Task StartAsync(CancellationToken cancellationToken)
{
var bootstrap = BootstrapSetup.Create();
var dependencyInjectionSetup = DependencyResolverSetup.Create(_serviceProvider);
var mergedSystemSetup = bootstrap.And(dependencyInjectionSetup);
_actorSystem = ActorSystem.Create("canvas-managment-actors", mergedSystemSetup);
// start top level supervisor actor
// working here https://getakka.net/articles/actors/dependency-injection.html#integrating-with-microsoftextensionsdependencyinjection
var apiActorProps = DependencyResolver.For(_actorSystem).Props<CanvasApiActor>();
_canvasApiActor = _actorSystem.ActorOf(apiActorProps, "canvas-api");
// crash if the actor system crashes, awaiting never returns...
#pragma warning disable CA2016 // Forward the 'CancellationToken' parameter to methods
_actorSystem.WhenTerminated.ContinueWith(tr =>
{
_applicationLifetime.StopApplication();
});
#pragma warning restore CA2016 // Forward the 'CancellationToken' parameter to methods
return Task.CompletedTask;
}
public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
// add more methods to interact with actor processes, make them part of an interface
// these are the most generic forwarding of messages
public void Tell(object message)
{
_canvasApiActor.Tell(message);
}
public Task<T> Ask<T>(object message)
{
return _canvasApiActor.Ask<T>(message);
}
}

7
Management.Web/IActorBridge.cs
View File

@@ -1,7 +0,0 @@
namespace Management.Actors;
public interface IActorBridge
{
void Tell(object message);
Task<T> Ask<T>(object message);
}

2
Management.Web/Management.Web.csproj
View File

@@ -5,8 +5,6 @@
</ItemGroup>
<ItemGroup>
<PackageReference Include="Akka" Version="1.5.18" />
<PackageReference Include="Akka.DependencyInjection" Version="1.5.18" />
<PackageReference Include="BlazorMonaco" Version="3.0.0" />
<PackageReference Include="dotenv.net" Version="3.1.2" />
<PackageReference Include="Markdig" Version="0.31.0" />

53
Management.Web/Pages/CanvasRequestsQueue.razor
View File

@@ -1,64 +1,11 @@
@page "/test"
@rendermode InteractiveServer
@using Microsoft.AspNetCore.SignalR.Client
@inject CanvasService canvas
@inject CoursePlanner planner
@inject FileStorageManager fileStorageManager
@inject IActorBridge bridge
@inject NavigationManager Navigation
@code {
private HubConnection? hubConnection;
public string? CourseName = "1400";
@* private bool loading = true; *@
protected override async Task OnInitializedAsync()
{
if (planner.LocalCourse == null)
{
System.Diagnostics.Activity.Current = null;
using var activity = DiagnosticsConfig.Source?.StartActivity("Loading Course");
activity?.AddTag("CourseName", CourseName);
var courses = await fileStorageManager.LoadSavedCourses();
planner.LocalCourse = courses.First(c => c.Settings.Name == CourseName);
}
@* Console.WriteLine(Navigation.BaseUri + "SignalRHub"); *@
hubConnection = new HubConnectionBuilder()
.WithUrl(Navigation.BaseUri + "SignalRHub")
.WithAutomaticReconnect()
.Build();
hubConnection.On("SentFromActor", () =>
{
Console.WriteLine("recieved from actor");
});
await hubConnection.StartAsync();
base.OnInitialized();
@* loading = false; *@
}
private async Task SendAkkaMessage()
{
System.Diagnostics.Activity.Current = null;
using var activity = DiagnosticsConfig.Source?.StartActivity("sending akka message from blazor");
if (planner.LocalCourse != null && planner.LocalCourse.Settings.CanvasId != null && hubConnection?.ConnectionId != null)
{
ulong id = (ulong)planner.LocalCourse.Settings.CanvasId;
var message = new GetModulesMessage(0, id, (string)hubConnection.ConnectionId, activity?.TraceId, ParentSpan:
activity?.SpanId);
var response = await bridge.Ask<CanvasModulesMessage>(message);
Console.WriteLine(response);
}
}
}
<button @onclick=SendAkkaMessage>test akka</button>

8
Management.Web/Program.cs
View File

@@ -11,7 +11,6 @@ global using Management.Services.Canvas;
global using Management.Web.Shared;
global using Management.Web.Shared.Components;
using dotenv.net;
using Management.Actors;
using Microsoft.AspNetCore.Hosting.Server;
using Microsoft.AspNetCore.Hosting.Server.Features;
using Microsoft.AspNetCore.ResponseCompression;
@@ -93,13 +92,6 @@ builder.Services.AddScoped<DragContainer>();
builder.Services.AddSingleton<FileConfiguration>();
// exposing actor service to controllers
builder.Services.AddSingleton<IActorBridge, AkkaService>();
// starting actor service while enabling it to use dependency injection
builder.Services.AddHostedService<AkkaService>(sp => (AkkaService)sp.GetRequiredService<IActorBridge>());
builder.Services.AddResponseCompression(opts =>
{
opts.MimeTypes = ResponseCompressionDefaults.MimeTypes.Concat(new[] { "application/octet-stream" });

1
Management.Web/_Imports.razor
View File

@@ -8,5 +8,4 @@
@using Microsoft.JSInterop
@using Management.Web
@using Management.Web.Shared
@using Management.Actors
@using static Microsoft.AspNetCore.Components.Web.RenderMode