NotS1mp/Musify
0
0
Fork 0
Code Issues 23 Pull Requests Actions Packages Projects Releases Wiki Activity

IEventBus

Browse Source
This commit is contained in:
Admin
2026-03-20 09:53:54 +01:00
parent 18da740e08
commit 676910e462
3 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Application/PlayLists/Commands/CreatePlayList/CreatePlayListCommandHandler.cs
+2 -2
View File
@@ -11,7 +11,7 @@ using Musify.Domain.Entities;
namespace Musify.Application.PlayLists.Commands.CreatePlayList namespace Musify.Application.PlayLists.Commands.CreatePlayList
{ {
public class CreatePlayListCommandHandler(IPublishEndpoint publishEndpoint, IDatabase database, IStorageHandler storageHandler, public class CreatePlayListCommandHandler(IEventBus eventBus, IDatabase database, IStorageHandler storageHandler,
ILogger<CreatePlayListCommandHandler> logger, StorageSettings storageConfiguration, PlayListConfiguration playListConfiguration) ILogger<CreatePlayListCommandHandler> logger, StorageSettings storageConfiguration, PlayListConfiguration playListConfiguration)
: IRequestHandler<CreatePlayListCommand, Task<Result<PlayListResponse>> > : IRequestHandler<CreatePlayListCommand, Task<Result<PlayListResponse>> >
{ {
@@ -61,7 +61,7 @@ namespace Musify.Application.PlayLists.Commands.CreatePlayList
try try
{ {
await publishEndpoint.Publish(new ResizePictureEvent( await eventBus.PublishAsync(new ResizePictureEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
originalImageStorageKey, originalImageStorageKey,
[ [
Application/PlayLists/Commands/DeletePlayList/DeletePlayListCommandHandler.cs
+5 -5
View File
@@ -9,7 +9,7 @@ using Musify.Application.PlayLists;
namespace Musify.Application.PlayLists.Commands.DeletePlayList namespace Musify.Application.PlayLists.Commands.DeletePlayList
{ {
public class DeletePlayListCommandHandler(IDatabase database, IPublishEndpoint publishEndpoint, public class DeletePlayListCommandHandler(IDatabase database, IEventBus eventBus,
StorageSettings storageConfiguration, PlayListConfiguration playListConfiguration, ILogger<DeletePlayListCommandHandler> logger) StorageSettings storageConfiguration, PlayListConfiguration playListConfiguration, ILogger<DeletePlayListCommandHandler> logger)
: IRequestHandler<DeletePlayListCommand, Task<Result>> : IRequestHandler<DeletePlayListCommand, Task<Result>>
{ {
@@ -35,7 +35,7 @@ namespace Musify.Application.PlayLists.Commands.DeletePlayList
try try
{ {
await publishEndpoint.Publish(new RemoveFileEvent( await eventBus.PublishAsync(new RemoveFileEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
originalImageStorageKey, originalImageStorageKey,
Guid.NewGuid()), cancellationToken); Guid.NewGuid()), cancellationToken);
@@ -50,7 +50,7 @@ namespace Musify.Application.PlayLists.Commands.DeletePlayList
{ {
try try
{ {
await publishEndpoint.Publish(new RemoveFileEvent( await eventBus.PublishAsync(new RemoveFileEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
playList.SmallPictureKeyName, playList.SmallPictureKeyName,
Guid.NewGuid()), cancellationToken); Guid.NewGuid()), cancellationToken);
@@ -66,7 +66,7 @@ namespace Musify.Application.PlayLists.Commands.DeletePlayList
{ {
try try
{ {
await publishEndpoint.Publish(new RemoveFileEvent( await eventBus.PublishAsync(new RemoveFileEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
playList.MediumPictureKeyName, playList.MediumPictureKeyName,
Guid.NewGuid()), cancellationToken); Guid.NewGuid()), cancellationToken);
@@ -82,7 +82,7 @@ namespace Musify.Application.PlayLists.Commands.DeletePlayList
{ {
try try
{ {
await publishEndpoint.Publish(new RemoveFileEvent( await eventBus.PublishAsync(new RemoveFileEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
playList.LargePictureKeyName, playList.LargePictureKeyName,
Guid.NewGuid()), cancellationToken); Guid.NewGuid()), cancellationToken);
Application/PlayLists/Commands/UpdatePlayList/UpdatePlayListCommandHandler.cs
+6 -6
View File
@@ -10,7 +10,7 @@ using Musify.Application.PlayLists.Contracts;
namespace Musify.Application.PlayLists.Commands.UpdatePlayList namespace Musify.Application.PlayLists.Commands.UpdatePlayList
{ {
public class UpdatePlayListCommandHandler(IPublishEndpoint publishEndpoint, IDatabase database, IStorageHandler storageHandler, public class UpdatePlayListCommandHandler(IEventBus eventBus, IDatabase database, IStorageHandler storageHandler,
ILogger<UpdatePlayListCommandHandler> logger, StorageSettings storageConfiguration, PlayListConfiguration playListConfiguration) ILogger<UpdatePlayListCommandHandler> logger, StorageSettings storageConfiguration, PlayListConfiguration playListConfiguration)
: IRequestHandler<UpdatePlayListCommand, Task<Result<PlayListResponse>> > : IRequestHandler<UpdatePlayListCommand, Task<Result<PlayListResponse>> >
{ {
@@ -53,7 +53,7 @@ namespace Musify.Application.PlayLists.Commands.UpdatePlayList
try try
{ {
await publishEndpoint.Publish(new RemoveFileEvent( await eventBus.PublishAsync(new RemoveFileEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
originalImageStorageKey, originalImageStorageKey,
Guid.NewGuid()), cancellationToken); Guid.NewGuid()), cancellationToken);
@@ -71,7 +71,7 @@ namespace Musify.Application.PlayLists.Commands.UpdatePlayList
{ {
try try
{ {
await publishEndpoint.Publish(new RemoveFileEvent( await eventBus.PublishAsync(new RemoveFileEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
playList.SmallPictureKeyName, playList.SmallPictureKeyName,
Guid.NewGuid()), cancellationToken); Guid.NewGuid()), cancellationToken);
@@ -87,7 +87,7 @@ namespace Musify.Application.PlayLists.Commands.UpdatePlayList
{ {
try try
{ {
await publishEndpoint.Publish(new RemoveFileEvent( await eventBus.PublishAsync(new RemoveFileEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
playList.MediumPictureKeyName, playList.MediumPictureKeyName,
Guid.NewGuid()), cancellationToken); Guid.NewGuid()), cancellationToken);
@@ -103,7 +103,7 @@ namespace Musify.Application.PlayLists.Commands.UpdatePlayList
{ {
try try
{ {
await publishEndpoint.Publish(new RemoveFileEvent( await eventBus.PublishAsync(new RemoveFileEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
playList.LargePictureKeyName, playList.LargePictureKeyName,
Guid.NewGuid()), cancellationToken); Guid.NewGuid()), cancellationToken);
@@ -138,7 +138,7 @@ namespace Musify.Application.PlayLists.Commands.UpdatePlayList
try try
{ {
await publishEndpoint.Publish(new ResizePictureEvent( await eventBus.PublishAsync(new ResizePictureEvent(
storageConfiguration.BucketName, storageConfiguration.BucketName,
newImageStorageKey, newImageStorageKey,
[ [