diff --git a/Masa.Framework.sln b/Masa.Framework.sln index 13b2b5682..e3b329e32 100644 --- a/Masa.Framework.sln +++ b/Masa.Framework.sln @@ -699,6 +699,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.BuildingBlocks.StackSd EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Masa.Contrib.StackSdks.Alert.Tests", "src\Contrib\StackSdks\Tests\Masa.Contrib.StackSdks.Alert.Tests\Masa.Contrib.StackSdks.Alert.Tests.csproj", "{1221F32F-7310-49FF-94DD-2BCF570E03F2}" EndProject +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent", "src\Contrib\Dispatcher\Tests\Scenes\Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent\Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent.csproj", "{D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}" +EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution Debug|Any CPU = Debug|Any CPU @@ -2523,6 +2525,14 @@ Global {1221F32F-7310-49FF-94DD-2BCF570E03F2}.Release|Any CPU.Build.0 = Release|Any CPU {1221F32F-7310-49FF-94DD-2BCF570E03F2}.Release|x64.ActiveCfg = Release|Any CPU {1221F32F-7310-49FF-94DD-2BCF570E03F2}.Release|x64.Build.0 = Release|Any CPU + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}.Debug|Any CPU.ActiveCfg = Debug|Any CPU + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}.Debug|Any CPU.Build.0 = Debug|Any CPU + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}.Debug|x64.ActiveCfg = Debug|Any CPU + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}.Debug|x64.Build.0 = Debug|Any CPU + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}.Release|Any CPU.ActiveCfg = Release|Any CPU + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}.Release|Any CPU.Build.0 = Release|Any CPU + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}.Release|x64.ActiveCfg = Release|Any CPU + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71}.Release|x64.Build.0 = Release|Any CPU EndGlobalSection GlobalSection(SolutionProperties) = preSolution HideSolutionNode = FALSE @@ -2868,6 +2878,7 @@ Global {30A143AF-4E9D-457E-BDAE-DFBC5A262F4A} = {383995FF-B661-4E15-A830-640FC5BA8A1F} {EEACDE24-9D4A-4F65-B13A-644E89A7918D} = {8A9DBB76-6618-4982-87D7-6CBD8375EB15} {1221F32F-7310-49FF-94DD-2BCF570E03F2} = {EC7A08E9-3355-486B-BA30-41A1F8CAC5F5} + {D1BC6F22-430A-4C5A-BDA8-5F8CC49D8E71} = {08B138B5-2599-4F42-9584-6AE736673882} EndGlobalSection GlobalSection(ExtensibilityGlobals) = postSolution SolutionGuid = {40383055-CC50-4600-AD9A-53C14F620D03} diff --git a/src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain/Events/IDomainEventBus.cs b/src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain/Events/IDomainEventBus.cs index f34878152..763c25f2b 100644 --- a/src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain/Events/IDomainEventBus.cs +++ b/src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain/Events/IDomainEventBus.cs @@ -5,8 +5,14 @@ namespace Masa.BuildingBlocks.Ddd.Domain.Events; public interface IDomainEventBus : IEventBus { +#pragma warning disable S1133 + [Obsolete("Enqueue has expired, please use EnqueueAsync instead, it will be removed in 1.0")] Task Enqueue(TDomainEvent @event) where TDomainEvent : IDomainEvent; +#pragma warning restore S1133 + + Task EnqueueAsync(TDomainEvent @event) + where TDomainEvent : IDomainEvent; Task PublishQueueAsync(); diff --git a/src/Contrib/Ddd/Domain/Masa.Contrib.Ddd.Domain/DomainEventBus.cs b/src/Contrib/Ddd/Domain/Masa.Contrib.Ddd.Domain/DomainEventBus.cs index b0c622b66..76aa4c010 100644 --- a/src/Contrib/Ddd/Domain/Masa.Contrib.Ddd.Domain/DomainEventBus.cs +++ b/src/Contrib/Ddd/Domain/Masa.Contrib.Ddd.Domain/DomainEventBus.cs @@ -51,6 +51,10 @@ bool IsAssignableFromDomainQuery(Type? type) } public Task Enqueue(TDomainEvent @event) where TDomainEvent : IDomainEvent + => EnqueueAsync(@event); + + public Task EnqueueAsync(TDomainEvent @event) + where TDomainEvent : IDomainEvent { _eventQueue.Enqueue(@event); return Task.CompletedTask; diff --git a/src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents/Extensions/ServiceCollectionExtensions.cs b/src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents/Extensions/ServiceCollectionExtensions.cs index df86145b6..eca4a2fba 100644 --- a/src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents/Extensions/ServiceCollectionExtensions.cs +++ b/src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents/Extensions/ServiceCollectionExtensions.cs @@ -60,7 +60,14 @@ internal static IServiceCollection TryAddIntegrationEventBus( serviceProvider => Microsoft.Extensions.Options.Options.Create(dispatcherOptions)); LocalQueueProcessor.SetLogger(services); - services.AddScoped(); + services.AddScoped(serviceProvider => new IntegrationEventBus( + new Lazy(serviceProvider.GetService), + serviceProvider.GetRequiredService(), + serviceProvider.GetService(), + serviceProvider.GetService>(), + serviceProvider.GetService>(), + serviceProvider.GetService() + )); action?.Invoke(); if (services.Any(d => d.ServiceType == typeof(IIntegrationEventLogService))) diff --git a/src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents/IntegrationEventBus.cs b/src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents/IntegrationEventBus.cs index b14f3f125..80c35926e 100644 --- a/src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents/IntegrationEventBus.cs +++ b/src/Contrib/Dispatcher/IntegrationEvents/Masa.Contrib.Dispatcher.IntegrationEvents/IntegrationEventBus.cs @@ -5,25 +5,29 @@ namespace Masa.Contrib.Dispatcher.IntegrationEvents; public class IntegrationEventBus : IIntegrationEventBus { + private readonly Lazy _lazyEventBus; + + private IEventBus? EventBus => _lazyEventBus.Value; + private readonly IPublisher _publisher; private readonly ILogger? _logger; private readonly IIntegrationEventLogService? _eventLogService; private readonly IOptionsMonitor? _masaAppConfigureOptions; - private readonly IEventBus? _eventBus; private readonly IUnitOfWork? _unitOfWork; - public IntegrationEventBus(IPublisher publisher, + public IntegrationEventBus( + Lazy eventBusLazy, + IPublisher publisher, IIntegrationEventLogService? eventLogService = null, IOptionsMonitor? masaAppConfigureOptions = null, ILogger? logger = null, - IEventBus? eventBus = null, IUnitOfWork? unitOfWork = null) { + _lazyEventBus = eventBusLazy; _publisher = publisher; _eventLogService = eventLogService; _masaAppConfigureOptions = masaAppConfigureOptions; _logger = logger; - _eventBus = eventBus; _unitOfWork = unitOfWork; } @@ -34,9 +38,9 @@ public async Task PublishAsync(TEvent @event, CancellationToken cancella { await PublishIntegrationAsync(integrationEvent, cancellationToken); } - else if (_eventBus != null) + else if (EventBus != null) { - await _eventBus.PublishAsync(@event, cancellationToken); + await EventBus.PublishAsync(@event, cancellationToken); } else { diff --git a/src/Contrib/Dispatcher/IntegrationEvents/Tests/Masa.Contrib.Dispatcher.IntegrationEvents.Tests/IntegrationEventBusTest.cs b/src/Contrib/Dispatcher/IntegrationEvents/Tests/Masa.Contrib.Dispatcher.IntegrationEvents.Tests/IntegrationEventBusTest.cs index d415f31e0..4382436d5 100644 --- a/src/Contrib/Dispatcher/IntegrationEvents/Tests/Masa.Contrib.Dispatcher.IntegrationEvents.Tests/IntegrationEventBusTest.cs +++ b/src/Contrib/Dispatcher/IntegrationEvents/Tests/Masa.Contrib.Dispatcher.IntegrationEvents.Tests/IntegrationEventBusTest.cs @@ -48,9 +48,15 @@ public void Initialize() public void TestDispatcherOption() { var services = new ServiceCollection(); - var options = new IntegrationEventOptions(services, new[] { typeof(IntegrationEventBusTest).Assembly }); + var options = new IntegrationEventOptions(services, new[] + { + typeof(IntegrationEventBusTest).Assembly + }); Assert.IsTrue(options.Services.Equals(services)); - var allEventTypes = new[] { typeof(IntegrationEventBusTest).Assembly }.SelectMany(assembly => assembly.GetTypes()) + var allEventTypes = new[] + { + typeof(IntegrationEventBusTest).Assembly + }.SelectMany(assembly => assembly.GetTypes()) .Where(type => type.IsClass && type != typeof(IntegrationEvent) && typeof(IEvent).IsAssignableFrom(type)).ToList(); Assert.IsTrue(options.AllEventTypes.Count == allEventTypes.Count()); } @@ -61,11 +67,11 @@ public void TestDispatcherOption() public async Task TestPublishIntegrationEventAsync(bool useLogger) { var integrationEventBus = new IntegrationEventBus( + new Lazy(_eventBus.Object), _publisher.Object, _eventLog.Object, _masaAppConfigureOptions.Object, useLogger ? _logger.Object : null, - _eventBus.Object, _uoW.Object); RegisterUserIntegrationEvent @event = new RegisterUserIntegrationEvent() { @@ -90,11 +96,11 @@ public async Task TestPublishIntegrationEventAsync(bool useLogger) public async Task TestPublishIntegrationEventAndNotUoWAsync(bool useLogger) { var integrationEventBus = new IntegrationEventBus( + new Lazy(_eventBus.Object), _publisher.Object, _eventLog.Object, _masaAppConfigureOptions.Object, - useLogger ? _logger.Object : null, - _eventBus.Object); + useLogger ? _logger.Object : null); RegisterUserIntegrationEvent @event = new RegisterUserIntegrationEvent() { Account = "masa", @@ -119,11 +125,11 @@ public async Task TestNotUseTransactionAsync(bool useLogger) { _uoW.Setup(uoW => uoW.UseTransaction).Returns(false); var integrationEventBus = new IntegrationEventBus( + new Lazy(_eventBus.Object), _publisher.Object, _eventLog.Object, _masaAppConfigureOptions.Object, useLogger ? _logger.Object : null, - _eventBus.Object, _uoW.Object); RegisterUserIntegrationEvent @event = new RegisterUserIntegrationEvent() { @@ -150,11 +156,11 @@ public async Task TestSaveEventFailedAsync(bool useLogger) _eventLog.Setup(eventLog => eventLog.SaveEventAsync(It.IsAny(), null!, default)) .Callback(() => throw new Exception("custom exception")); var integrationEventBus = new IntegrationEventBus( + new Lazy(_eventBus.Object), _publisher.Object, _eventLog.Object, _masaAppConfigureOptions.Object, useLogger ? _logger.Object : null, - _eventBus.Object, _uoW.Object); RegisterUserIntegrationEvent @event = new RegisterUserIntegrationEvent() { @@ -169,11 +175,11 @@ public async Task TestPublishLocalEventAsync() { _eventBus.Setup(eventBus => eventBus.PublishAsync(It.IsAny(), default)).Verifiable(); var integrationEventBus = new IntegrationEventBus( + new Lazy(_eventBus.Object), _publisher.Object, _eventLog.Object, _masaAppConfigureOptions.Object, _logger.Object, - _eventBus.Object, _uoW.Object); CreateUserEvent @event = new CreateUserEvent() { @@ -188,31 +194,29 @@ public async Task TestPublishLocalEventAsync() public async Task TestPublishEventAndNotEventBusAsync() { var integrationEventBus = new IntegrationEventBus( + new Lazy(_eventBus.Object), _publisher.Object, _eventLog.Object, _masaAppConfigureOptions.Object, _logger.Object, - null, _uoW.Object); - CreateUserEvent @event = new CreateUserEvent() + var @event = new CreateUserEvent() { Name = "Tom" }; - await Assert.ThrowsExceptionAsync(async () => - { - await integrationEventBus.PublishAsync(@event); - }); + await integrationEventBus.PublishAsync(@event); + _eventBus.Verify(bus=>bus.PublishAsync(It.IsAny(),It.IsAny()), Times.Once); } [TestMethod] public async Task TestCommitAsync() { var integrationEventBus = new IntegrationEventBus( + new Lazy(_eventBus.Object), _publisher.Object, _eventLog.Object, _masaAppConfigureOptions.Object, _logger.Object, - _eventBus.Object, _uoW.Object); await integrationEventBus.CommitAsync(default); @@ -223,11 +227,11 @@ public async Task TestCommitAsync() public async Task TestNotUseUowCommitAsync() { var integrationEventBus = new IntegrationEventBus( + new Lazy(_eventBus.Object), _publisher.Object, _eventLog.Object, _masaAppConfigureOptions.Object, _logger.Object, - _eventBus.Object, null); await Assert.ThrowsExceptionAsync(async () => await integrationEventBus.CommitAsync()); diff --git a/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Extensions/ServiceCollectionExtensions.cs b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Extensions/ServiceCollectionExtensions.cs index 30cfffbfb..dcc6e06a4 100644 --- a/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Extensions/ServiceCollectionExtensions.cs +++ b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Extensions/ServiceCollectionExtensions.cs @@ -29,7 +29,8 @@ public static IServiceCollection AddEventBus( services.AddSingleton(); - services.TryAddEnumerable(new ServiceDescriptor(typeof(IEventMiddleware<>), typeof(TransactionEventMiddleware<>), ServiceLifetime.Transient)); + services.TryAddEnumerable(new ServiceDescriptor(typeof(IEventMiddleware<>), typeof(TransactionEventMiddleware<>), + ServiceLifetime.Transient)); var builder = new EventBusBuilder(services); eventBusBuilder?.Invoke(builder); @@ -45,7 +46,11 @@ public static IServiceCollection AddEventBus( services.TryAddSingleton(); services.TryAdd(typeof(IExecutionStrategy), typeof(ExecutionStrategy), ServiceLifetime.Singleton); services.TryAddScoped(); - services.AddScoped(typeof(IEventBus), typeof(EventBus)); + + services.AddScoped(); + services.AddScoped(serviceProvider => new EventBus( + serviceProvider.GetRequiredService(), + new Lazy(serviceProvider.GetService()))); MasaApp.TrySetServiceCollection(services); return services; } @@ -75,7 +80,7 @@ public static IServiceCollection AddTestEventBus( services.TryAdd(typeof(IExecutionStrategy), typeof(ExecutionStrategy), ServiceLifetime.Singleton); services.TryAddScoped(); services.AddTransient(typeof(IEventMiddleware<>), typeof(TransactionEventMiddleware<>)); - services.AddScoped(typeof(IEventBus), typeof(EventBus)); + services.AddScoped(typeof(IEventBus), typeof(LocalEventBus)); return services; } diff --git a/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Internal/EventBus.cs b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Internal/EventBus.cs new file mode 100644 index 000000000..12f23724b --- /dev/null +++ b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Internal/EventBus.cs @@ -0,0 +1,38 @@ +// Copyright (c) MASA Stack All rights reserved. +// Licensed under the MIT License. See LICENSE.txt in the project root for license information. + +[assembly: InternalsVisibleTo("Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent")] + +// ReSharper disable once CheckNamespace + +namespace Masa.Contrib.Dispatcher.Events; + +internal class EventBus : IEventBus +{ + private readonly ILocalEventBus _localEventBus; + + private readonly Lazy _lazyIntegrationEventBus; + private IIntegrationEventBus? IntegrationEventBus => _lazyIntegrationEventBus.Value; + + public EventBus(ILocalEventBus localEventBus, Lazy integrationEventBusLazy) + { + _localEventBus = localEventBus; + _lazyIntegrationEventBus = integrationEventBusLazy; + } + + public Task PublishAsync(TEvent @event, CancellationToken cancellationToken = default) where TEvent : IEvent + { + if (@event is IIntegrationEvent _) + { + if (IntegrationEventBus == null) + throw new NotSupportedException("Integration events are not supported, please ensure integration events are registered"); + + return IntegrationEventBus.PublishAsync(@event, cancellationToken); + } + + return _localEventBus.PublishAsync(@event, cancellationToken); + } + + public Task CommitAsync(CancellationToken cancellationToken = default) + => _localEventBus.CommitAsync(cancellationToken); +} diff --git a/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Internal/ILocalEventBus.cs b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Internal/ILocalEventBus.cs new file mode 100644 index 000000000..88741f923 --- /dev/null +++ b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/Internal/ILocalEventBus.cs @@ -0,0 +1,14 @@ +// Copyright (c) MASA Stack All rights reserved. +// Licensed under the MIT License. See LICENSE.txt in the project root for license information. + +[assembly: InternalsVisibleTo("Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent")] +[assembly: InternalsVisibleTo("DynamicProxyGenAssembly2")] + +// ReSharper disable once CheckNamespace + +namespace Masa.Contrib.Dispatcher.Events; + +internal interface ILocalEventBus : IEventBus +{ + +} diff --git a/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/EventBus.cs b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/LocalEventBus.cs similarity index 90% rename from src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/EventBus.cs rename to src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/LocalEventBus.cs index f946a1928..4f5d00df5 100644 --- a/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/EventBus.cs +++ b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/LocalEventBus.cs @@ -3,7 +3,7 @@ namespace Masa.Contrib.Dispatcher.Events; -public class EventBus : IEventBus +public class LocalEventBus : ILocalEventBus { private readonly IServiceProvider _serviceProvider; @@ -19,7 +19,7 @@ public class EventBus : IEventBus private readonly IInitializeServiceProvider _initializeServiceProvider; - public EventBus(IServiceProvider serviceProvider, + public LocalEventBus(IServiceProvider serviceProvider, IOptions options, IInitializeServiceProvider initializeServiceProvider, IUnitOfWork? unitOfWork = null) @@ -61,11 +61,13 @@ public async Task PublishAsync(TEvent @event, CancellationToken cancella await middlewares.Reverse().Aggregate(eventHandlerDelegate, (next, middleware) => () => middleware.HandleAsync(@event, next))(); } +#pragma warning disable S3928 public async Task CommitAsync(CancellationToken cancellationToken = default) { if (_unitOfWork is null) - throw new ArgumentNullException("You need to UseUoW when adding services"); + throw new ArgumentNullException(nameof(IUnitOfWork), "You need to UseUoW when adding services"); await _unitOfWork.CommitAsync(cancellationToken); } +#pragma warning restore S3928 } diff --git a/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/_Imports.cs b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/_Imports.cs index d25477cf5..72c140c9d 100644 --- a/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/_Imports.cs +++ b/src/Contrib/Dispatcher/Masa.Contrib.Dispatcher.Events/_Imports.cs @@ -20,4 +20,5 @@ global using Microsoft.Extensions.Options; global using System.Linq.Expressions; global using System.Reflection; +global using System.Runtime.CompilerServices; global using System.Runtime.ExceptionServices; diff --git a/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/EventBusTest.cs b/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/EventBusTest.cs new file mode 100644 index 000000000..e1a44f92a --- /dev/null +++ b/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/EventBusTest.cs @@ -0,0 +1,35 @@ +// Copyright (c) MASA Stack All rights reserved. +// Licensed under the MIT License. See LICENSE.txt in the project root for license information. + +namespace Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent; + +[TestClass] +public class EventBusTest +{ + [TestMethod] + public async Task TestPublishIntegrationEventAsync() + { + Mock localEventBus = new(); + Mock integrationEventBus = new(); + var eventBus = new EventBus(localEventBus.Object, new Lazy(integrationEventBus.Object)); + var @event = new RegisterUserIntegrationEvent() + { + Account = "masa" + }; + await eventBus.PublishAsync(@event); + localEventBus.Verify(bus => bus.PublishAsync(@event, It.IsAny()), Times.Never); + integrationEventBus.Verify(bus => bus.PublishAsync(@event, It.IsAny()), Times.Once); + } + + [TestMethod] + public async Task TestPublishIntegrationEventByIntegrationEventBusIsNullAsync() + { + Mock localEventBus = new(); + var eventBus = new EventBus(localEventBus.Object, new Lazy(() => null)); + var @event = new RegisterUserIntegrationEvent() + { + Account = "masa" + }; + await Assert.ThrowsExceptionAsync(async () => await eventBus.PublishAsync(@event)); + } +} diff --git a/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent.csproj b/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent.csproj new file mode 100644 index 000000000..25ba8bfa2 --- /dev/null +++ b/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent.csproj @@ -0,0 +1,33 @@ + + + + net6.0 + false + enable + Full + enable + + + + + all + runtime; build; native; contentfiles; analyzers; buildtransitive + + + + + + + all + runtime; build; native; contentfiles; analyzers; buildtransitive + + + + + + + + + + + diff --git a/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/RegisterUserIntegrationEvent.cs b/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/RegisterUserIntegrationEvent.cs new file mode 100644 index 000000000..ae70f80dd --- /dev/null +++ b/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/RegisterUserIntegrationEvent.cs @@ -0,0 +1,9 @@ +// Copyright (c) MASA Stack All rights reserved. +// Licensed under the MIT License. See LICENSE.txt in the project root for license information. + +namespace Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent; + +public record RegisterUserIntegrationEvent : Masa.BuildingBlocks.Dispatcher.IntegrationEvents.IntegrationEvent +{ + public string Account { get; set; } +} diff --git a/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/_Imports.cs b/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/_Imports.cs new file mode 100644 index 000000000..e4557e006 --- /dev/null +++ b/src/Contrib/Dispatcher/Tests/Scenes/Masa.Contrib.Dispatcher.Events.Tests.Scenes.IntegrationEvent/_Imports.cs @@ -0,0 +1,13 @@ +// Copyright (c) MASA Stack All rights reserved. +// Licensed under the MIT License. See LICENSE.txt in the project root for license information. + +global using Masa.BuildingBlocks.Data.UoW; +global using Masa.BuildingBlocks.Dispatcher.Events; +global using Masa.BuildingBlocks.Dispatcher.IntegrationEvents; +global using Masa.Contrib.Dispatcher.Events.Enums; +global using Microsoft.Extensions.DependencyInjection; +global using Microsoft.Extensions.DependencyInjection.Extensions; +global using Microsoft.Extensions.Logging; +global using Microsoft.VisualStudio.TestTools.UnitTesting; +global using Moq; +global using System.Reflection;