Feature: Publishing GAgent

samples/MessagingGAgent.Client/Program.cs

@@ -2,7 +2,6 @@
 using MessagingGAgent.Grains.Agents.Events;
 using MessagingGAgent.Grains.Agents.Group;
 using MessagingGAgent.Grains.Agents.Messaging;
-using MessagingGAgent.Grains.Agents.Publisher;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.DependencyInjection;

src/Aevatar.Core.Abstractions/IPublishingGAgent.cs

@@ -0,0 +1,6 @@
+namespace Aevatar.Core.Abstractions;
+
+public interface IPublishingGAgent : IGAgent
+{
+    Task PublishEventAsync<T>(T @event, params IGAgent[] agents) where T : EventBase;
+}

test/Aevatar.Core.Tests/TestGAgents/PublishingGAgent.cs → src/Aevatar.Core/PublishingGAgent.cs

@@ -1,31 +1,34 @@
 using Aevatar.Core.Abstractions;
-using Aevatar.Core.Tests.TestStateLogEvents;
 using Microsoft.Extensions.Logging;
-using Orleans.Providers;
 
-namespace Aevatar.Core.Tests.TestGAgents;
+namespace Aevatar.Core;
 
 [GenerateSerializer]
 public class PublishingAgentState : StateBase
 {
 }
 
-public class PublishingStateLogEvent : StateLogEventBase<PublishingStateLogEvent>;
+[GenerateSerializer]
+public class PublishingStateLogEvent : StateLogEventBase<PublishingStateLogEvent>
+{
+}
 
-[GAgent("publishing")]
+[GAgent]
 public class PublishingGAgent : GAgentBase<PublishingAgentState, PublishingStateLogEvent>, IPublishingGAgent
 {
     public override Task<string> GetDescriptionAsync()
     {
         return Task.FromResult("Agent to be used for publishing new events.");
     }
 
-    public async Task PublishEventAsync<T>(T @event) where T : EventBase
+    public async Task PublishEventAsync<T>(T @event, params IGAgent[] agents) where T : EventBase
     {
         if (@event == null)
         {
             throw new ArgumentNullException(nameof(@event));
         }
+
+        await RegisterManyAsync(agents.ToList());
 
         Logger.LogInformation($"PublishingAgent publish {@event}");
         await PublishAsync(@event);

test/Aevatar.GAgents.Tests/GAgentFactoryTests.cs

@@ -60,7 +60,7 @@ public async Task CreateGAgentByGenericTypeTest()
             var gAgent = await _gAgentFactory.GetGAgentAsync<IPublishingGAgent>();
             gAgent.ShouldNotBeNull();
             Should.NotThrow(() => gAgent.GetPrimaryKey());
-            gAgent.GetGrainId().ShouldBe(GrainId.Create("Aevatar.Core.Tests.TestGAgents.publishing",
+            gAgent.GetGrainId().ShouldBe(GrainId.Create("Aevatar.Core.PublishingGAgent",
                 gAgent.GetPrimaryKey().ToString("N")));
             await CheckSubscribedEventsAsync(gAgent);
         }