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

Renames

Browse Source
This commit is contained in:
Admin
2026-03-27 23:07:05 +01:00
parent 32b83e84a6
commit bc9fdad098
6 changed files with 18 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Infrastructure/Infrastructure.csproj
-1
View File
@@ -43,7 +43,6 @@
<Folder Include="MassTransit\RoutingSlip\Variables\" />
<Folder Include="MassTransit\Filters\" />
<Folder Include="MassTransit\EventBus\" />
<Folder Include="MassTransit\DependencyInjection\" />
</ItemGroup>
</Project>
Infrastructure/MassTransit/Consumers/MessagingHelper.cs → Infrastructure/MassTransit/Consumers/EndpointHelper.cs
+1 -1
View File
@@ -1,6 +1,6 @@
namespace Musify.Infrastructure.MassTransit.Consumers
{
internal static class MessagingHelper
internal static class EndpointHelper
{
internal static Uri BuildExecuteActivityUri(string endpointName) => new($"queue:{endpointName}_execute");
Infrastructure/MassTransit/DependencyInjection/MessagingDependencyInjection.cs → Infrastructure/MassTransit/DependencyInjection/MassTransitDependencyInjection.cs
+2 -2
View File
@@ -14,7 +14,7 @@ using Musify.Infrastructure.MassTransit.Activities.Files;
namespace Musify.Infrastructure.MassTransit
{
public static class MessagingDependencyInjection
public static class MassTransitDependencyInjection
{
public static IServiceCollection AddMassTransitClient(this IServiceCollection serviceDescriptors)
{
@@ -183,7 +183,7 @@ namespace Musify.Infrastructure.MassTransit
{
busFactoryConfigurator.ReceiveEndpoint($"{endpointName}_execute", endpointConfigurator =>
endpointConfigurator.ExecuteActivityHost<TActivity, TArguments>(
MessagingHelper.BuildCompensateActivityUri(endpointName),
EndpointHelper.BuildCompensateActivityUri(endpointName),
busRegistrationContext)
);
Infrastructure/MassTransit/RoutingSlip/Builders/AudioWorkflowRoutingSlipBuilder.cs
+6 -6
View File
@@ -19,19 +19,19 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
routingSlipBuilder.AddVariable(RoutingSlipVariableNames.Workflow.CorrelationId, correlationId ?? Guid.Empty);
routingSlipBuilder.AddSubscription(
MessagingHelper.BuildConsumerUri(RoutingSlipCleanUpConsumer.QueueName),
EndpointHelper.BuildConsumerUri(RoutingSlipCleanUpConsumer.QueueName),
RoutingSlipEvents.Completed | RoutingSlipEvents.Faulted);
routingSlipBuilder.AddActivity(
ActivityNames.GenerateAudioWorkflowPaths,
MessagingHelper.BuildExecuteActivityUri(GenerateAudioWorkflowPathsActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(GenerateAudioWorkflowPathsActivity.ExecuteEndpointName),
new GenerateAudioWorkflowPathsArguments(
workerConfiguration.Routes.TemporaryFilesDirectory,
message.SourceKeyName));
routingSlipBuilder.AddActivity(
ActivityNames.DownloadFile,
MessagingHelper.BuildExecuteActivityUri(DownloadFileFromBucketActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(DownloadFileFromBucketActivity.ExecuteEndpointName),
new DownloadFileFromBucketArguments(
message.SourceBucketName,
message.SourceKeyName,
@@ -39,14 +39,14 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
routingSlipBuilder.AddActivity(
ActivityNames.TranscodeAudio,
MessagingHelper.BuildExecuteActivityUri(TranscodeDashAudioActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(TranscodeDashAudioActivity.ExecuteEndpointName),
new TranscodeDashAudioArguments(
RoutingSlipVariableNames.Audio.SourceFilePath,
RoutingSlipVariableNames.Workflow.TemporalDirectory));
routingSlipBuilder.AddActivity(
ActivityNames.TransferFiles,
MessagingHelper.BuildExecuteActivityUri(TransferFilesToBucketActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(TransferFilesToBucketActivity.ExecuteEndpointName),
new TransferFilesToBucketArguments(
message.DestinationBucketName,
RoutingSlipVariableNames.Audio.TranscodedDirectory,
@@ -54,7 +54,7 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
routingSlipBuilder.AddActivity(
ActivityNames.UpdateTrackAudio,
MessagingHelper.BuildExecuteActivityUri(UpdateTrackAudioActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(UpdateTrackAudioActivity.ExecuteEndpointName),
new UpdateTrackAudioArguments(
message.TrackId,
message.DestinationFolderKeyName));
Infrastructure/MassTransit/RoutingSlip/Builders/PictureWorkflowRoutingSlipBuilder.cs
+7 -7
View File
@@ -30,7 +30,7 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
routingSlipBuilder.AddActivity(
ActivityNames.UpdateTrackPicture,
MessagingHelper.BuildExecuteActivityUri(UpdateTrackPictureActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(UpdateTrackPictureActivity.ExecuteEndpointName),
new UpdateTrackPictureArguments(
message.TrackId,
message.SourceKeyName,
@@ -59,7 +59,7 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
routingSlipBuilder.AddActivity(
ActivityNames.UpdatePlayListPicture,
MessagingHelper.BuildExecuteActivityUri(UpdatePlayListPictureActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(UpdatePlayListPictureActivity.ExecuteEndpointName),
new UpdatePlayListPictureArguments(
message.PlayListId,
message.SourceKeyName,
@@ -87,21 +87,21 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
var routingSlipBuilder = new RoutingSlipBuilder(NewId.NextGuid());
routingSlipBuilder.AddSubscription(
MessagingHelper.BuildConsumerUri(RoutingSlipCleanUpConsumer.QueueName),
EndpointHelper.BuildConsumerUri(RoutingSlipCleanUpConsumer.QueueName),
RoutingSlipEvents.Completed | RoutingSlipEvents.Faulted);
routingSlipBuilder.AddVariable(RoutingSlipVariableNames.Workflow.CorrelationId, correlationId ?? Guid.Empty);
routingSlipBuilder.AddActivity(
ActivityNames.GeneratePictureWorkflowPaths,
MessagingHelper.BuildExecuteActivityUri(GeneratePictureWorkflowPathsActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(GeneratePictureWorkflowPathsActivity.ExecuteEndpointName),
new GeneratePictureWorkflowPathsArguments(
workerConfiguration.Routes.TemporaryFilesDirectory,
sourceKeyName));
routingSlipBuilder.AddActivity(
ActivityNames.DownloadFile,
MessagingHelper.BuildExecuteActivityUri(DownloadFileFromBucketActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(DownloadFileFromBucketActivity.ExecuteEndpointName),
new DownloadFileFromBucketArguments(
bucketName,
sourceKeyName,
@@ -152,7 +152,7 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
{
routingSlipBuilder.AddActivity(
resizeActivityName,
MessagingHelper.BuildExecuteActivityUri(ResizePictureActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(ResizePictureActivity.ExecuteEndpointName),
new ResizePictureLocalArguments(
RoutingSlipVariableNames.Picture.OriginalFilePath,
destinationFilePathVariableName,
@@ -161,7 +161,7 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
routingSlipBuilder.AddActivity(
uploadActivityName,
MessagingHelper.BuildExecuteActivityUri(UploadFileToBucketActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(UploadFileToBucketActivity.ExecuteEndpointName),
new UploadFileToBucketArguments(
destinationFilePathVariableName,
bucketName,
Infrastructure/MassTransit/RoutingSlip/Builders/RemoveFileFromBucketRoutingSlipBuilder.cs
+2 -2
View File
@@ -16,12 +16,12 @@ namespace Musify.Infrastructure.MassTransit.RoutingSlip.Builders
routingSlipBuilder.AddVariable(RoutingSlipVariableNames.Workflow.CorrelationId, correlationId ?? Guid.Empty);
routingSlipBuilder.AddSubscription(
MessagingHelper.BuildConsumerUri(RoutingSlipCleanUpConsumer.QueueName),
EndpointHelper.BuildConsumerUri(RoutingSlipCleanUpConsumer.QueueName),
RoutingSlipEvents.Completed | RoutingSlipEvents.Faulted);
routingSlipBuilder.AddActivity(
ActivityNames.RemoveFile,
MessagingHelper.BuildExecuteActivityUri(RemoveFileFromBucketActivity.ExecuteEndpointName),
EndpointHelper.BuildExecuteActivityUri(RemoveFileFromBucketActivity.ExecuteEndpointName),
new RemoveFileFromBucketArguments(
message.BucketName,
message.KeyName));