diff --git a/docs/ProcessManager.Client/ReleaseNotes/ReleaseNotes.md b/docs/ProcessManager.Client/ReleaseNotes/ReleaseNotes.md index b17bfc4b..fb4c0a6d 100644 --- a/docs/ProcessManager.Client/ReleaseNotes/ReleaseNotes.md +++ b/docs/ProcessManager.Client/ReleaseNotes/ReleaseNotes.md @@ -1,5 +1,9 @@ # ProcessManager.Client Release Notes +## Version 0.14.6 + +- Internal refactoring. + ## Version 0.14.5 - Internal refactoring. diff --git a/docs/ProcessManager.Orchestrations.Abstractions/ReleaseNotes/ReleaseNotes.md b/docs/ProcessManager.Orchestrations.Abstractions/ReleaseNotes/ReleaseNotes.md index 573d0c9d..61888ea0 100644 --- a/docs/ProcessManager.Orchestrations.Abstractions/ReleaseNotes/ReleaseNotes.md +++ b/docs/ProcessManager.Orchestrations.Abstractions/ReleaseNotes/ReleaseNotes.md @@ -1,5 +1,9 @@ # ProcessManager.Orchestrations.Abstractions Release Notes +## Version 0.2.7 + +- Internal refactoring. + ## Version 0.2.6 - Internal refactoring. diff --git a/source/ProcessManager.Abstractions/ProcessManager.Abstractions.csproj b/source/ProcessManager.Abstractions/ProcessManager.Abstractions.csproj index a8d354ff..129e332b 100644 --- a/source/ProcessManager.Abstractions/ProcessManager.Abstractions.csproj +++ b/source/ProcessManager.Abstractions/ProcessManager.Abstractions.csproj @@ -7,7 +7,7 @@ Energinet.DataHub.ProcessManager.Abstractions - 0.14.5$(VersionSuffix) + 0.14.6$(VersionSuffix) DH3 Process Manager Abstractions library Energinet-DataHub Energinet-DataHub diff --git a/source/ProcessManager.Client.Tests/Fixtures/ProcessManagerClientFixture.cs b/source/ProcessManager.Client.Tests/Fixtures/ProcessManagerClientFixture.cs index bea136e0..c27baf92 100644 --- a/source/ProcessManager.Client.Tests/Fixtures/ProcessManagerClientFixture.cs +++ b/source/ProcessManager.Client.Tests/Fixtures/ProcessManagerClientFixture.cs @@ -14,8 +14,8 @@ using Energinet.DataHub.Core.FunctionApp.TestCommon.Azurite; using Energinet.DataHub.Core.FunctionApp.TestCommon.Configuration; -using Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; using Energinet.DataHub.ProcessManager.Core.Tests.Fixtures; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; using Energinet.DataHub.ProcessManager.Tests.Fixtures; using Xunit.Abstractions; @@ -23,7 +23,7 @@ namespace Energinet.DataHub.ProcessManager.Client.Tests.Fixtures; /// /// Support testing the Process Manager Clients by coordinating the startup -/// of the dependent applications Example.Orchestrations and ProcessManager (Api). +/// of the dependent applications ProcessManager.Example.Orchestrations and ProcessManager (Api). /// public class ProcessManagerClientFixture : IAsyncLifetime { diff --git a/source/ProcessManager.Client.Tests/Integration/BRS_X01/Example/V1/MonitorExampleUsingClientScenario.cs b/source/ProcessManager.Client.Tests/Integration/BRS_X01/InputExample/V1/MonitorExampleUsingClientScenario.cs similarity index 95% rename from source/ProcessManager.Client.Tests/Integration/BRS_X01/Example/V1/MonitorExampleUsingClientScenario.cs rename to source/ProcessManager.Client.Tests/Integration/BRS_X01/InputExample/V1/MonitorExampleUsingClientScenario.cs index 52359a61..3ddabe07 100644 --- a/source/ProcessManager.Client.Tests/Integration/BRS_X01/Example/V1/MonitorExampleUsingClientScenario.cs +++ b/source/ProcessManager.Client.Tests/Integration/BRS_X01/InputExample/V1/MonitorExampleUsingClientScenario.cs @@ -14,19 +14,19 @@ using Energinet.DataHub.Core.FunctionApp.TestCommon.FunctionAppHost; using Energinet.DataHub.Core.TestCommon; -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1; -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; using Energinet.DataHub.ProcessManager.Client.Extensions.DependencyInjection; using Energinet.DataHub.ProcessManager.Client.Extensions.Options; using Energinet.DataHub.ProcessManager.Client.Tests.Fixtures; using Energinet.DataHub.ProcessManager.Client.Tests.Fixtures.Extensions; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; using FluentAssertions; using Microsoft.Extensions.DependencyInjection; using Xunit.Abstractions; -namespace Energinet.DataHub.ProcessManager.Client.Tests.Integration.BRS_X01.V1; +namespace Energinet.DataHub.ProcessManager.Client.Tests.Integration.BRS_X01.InputExample.V1; /// /// Test case where we verify the Process Manager clients can be used to start an @@ -88,7 +88,7 @@ public async Task ExampleOrchestration_WhenStarted_CanMonitorLifecycle() ShouldSkipSkippableStep: false); var orchestrationInstanceId = await processManagerClient .StartNewOrchestrationInstanceAsync( - new StartExampleCommandV1( + new StartInputExampleCommandV1( userIdentity, input), CancellationToken.None); @@ -118,7 +118,7 @@ public async Task ExampleOrchestration_WhenStarted_CanMonitorLifecycle() .SearchOrchestrationInstancesByNameAsync( new SearchOrchestrationInstancesByNameQuery( userIdentity, - name: new Brs_X01_Example_V1().Name, + name: new Brs_X01_InputExample_V1().Name, version: null, lifecycleState: OrchestrationInstanceLifecycleStates.Terminated, terminationState: OrchestrationInstanceTerminationStates.Succeeded, @@ -129,7 +129,7 @@ public async Task ExampleOrchestration_WhenStarted_CanMonitorLifecycle() orchestrationInstancesGeneralSearch.Should().Contain(x => x.Id == orchestrationInstanceId); // Step 4: Custom search - var customQuery = new ExampleQuery(userIdentity) + var customQuery = new InputExampleQuery(userIdentity) { SkippedStepTwo = input.ShouldSkipSkippableStep, }; @@ -156,7 +156,7 @@ public async Task ExampleOrchestration_WhenScheduledToRunInThePast_CanMonitorLif // Step 1: Schedule new example orchestration instance var orchestrationInstanceId = await processManagerClient .ScheduleNewOrchestrationInstanceAsync( - new ScheduleExampleCommandV1( + new ScheduleInputExampleCommandV1( userIdentity, runAt: DateTimeOffset.Parse("2024-11-01T06:19:10.0209567+01:00"), inputParameter: new InputV1( @@ -200,7 +200,7 @@ public async Task ExampleOrchestrationScheduledToRunInTheFuture_WhenCanceled_Can // Step 1: Schedule new example orchestration instance var orchestrationInstanceId = await processManagerClient .ScheduleNewOrchestrationInstanceAsync( - new ScheduleExampleCommandV1( + new ScheduleInputExampleCommandV1( userIdentity, runAt: DateTimeOffset.Parse("2050-01-01T12:00:00.0000000+01:00"), inputParameter: new InputV1( diff --git a/source/ProcessManager.Client.Tests/Integration/BRS_X01/NoInputExample/V1/MonitorNoInputExampleUsingClientScenario.cs b/source/ProcessManager.Client.Tests/Integration/BRS_X01/NoInputExample/V1/MonitorNoInputExampleUsingClientScenario.cs index 907d6bc2..8d0de220 100644 --- a/source/ProcessManager.Client.Tests/Integration/BRS_X01/NoInputExample/V1/MonitorNoInputExampleUsingClientScenario.cs +++ b/source/ProcessManager.Client.Tests/Integration/BRS_X01/NoInputExample/V1/MonitorNoInputExampleUsingClientScenario.cs @@ -13,13 +13,13 @@ // limitations under the License. using Energinet.DataHub.Core.TestCommon; -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; using Energinet.DataHub.ProcessManager.Client.Extensions.DependencyInjection; using Energinet.DataHub.ProcessManager.Client.Extensions.Options; using Energinet.DataHub.ProcessManager.Client.Tests.Fixtures; using Energinet.DataHub.ProcessManager.Client.Tests.Fixtures.Extensions; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; using FluentAssertions; using Microsoft.Extensions.DependencyInjection; using Xunit.Abstractions; @@ -84,7 +84,7 @@ public async Task NoInputExampleOrchestration_WhenStarted_CanMonitorLifecycle() // Step 1: Start new orchestration instance var orchestrationInstanceId = await processManagerClient .StartNewOrchestrationInstanceAsync( - new StartNoInputExampleComandV1( + new StartNoInputExampleCommandV1( userIdentity), CancellationToken.None); diff --git a/source/ProcessManager.Client.Tests/ProcessManager.Client.Tests.csproj b/source/ProcessManager.Client.Tests/ProcessManager.Client.Tests.csproj index adc8b18d..28e376d4 100644 --- a/source/ProcessManager.Client.Tests/ProcessManager.Client.Tests.csproj +++ b/source/ProcessManager.Client.Tests/ProcessManager.Client.Tests.csproj @@ -8,8 +8,10 @@ - + + Fixtures\ExampleOrchestrationsAppManager.cs + Fixtures\OrchestrationsAppManager.cs @@ -33,7 +35,7 @@ - + diff --git a/source/ProcessManager.Client/ProcessManager.Client.csproj b/source/ProcessManager.Client/ProcessManager.Client.csproj index 6fe3c399..b650deae 100644 --- a/source/ProcessManager.Client/ProcessManager.Client.csproj +++ b/source/ProcessManager.Client/ProcessManager.Client.csproj @@ -7,7 +7,7 @@ Energinet.DataHub.ProcessManager.Client - 0.14.5$(VersionSuffix) + 0.14.6$(VersionSuffix) DH3 Process Manager Client library Energinet-DataHub Energinet-DataHub diff --git a/source/Example.Orchestrations.Abstrations/Example.Orchestrations.Abstrations.csproj b/source/ProcessManager.Example.Orchestrations.Abstrations/ProcessManager.Example.Orchestrations.Abstrations.csproj similarity index 51% rename from source/Example.Orchestrations.Abstrations/Example.Orchestrations.Abstrations.csproj rename to source/ProcessManager.Example.Orchestrations.Abstrations/ProcessManager.Example.Orchestrations.Abstrations.csproj index d3d1e211..009b7b4b 100644 --- a/source/Example.Orchestrations.Abstrations/Example.Orchestrations.Abstrations.csproj +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/ProcessManager.Example.Orchestrations.Abstrations.csproj @@ -1,8 +1,8 @@  - Energinet.DataHub.Example.Orchestrations.Abstractions - Energinet.DataHub.Example.Orchestrations.Abstractions + Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions + Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions diff --git a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/ExampleQuery.cs b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/InputExampleQuery.cs similarity index 79% rename from source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/ExampleQuery.cs rename to source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/InputExampleQuery.cs index ce72d815..dec2e3cb 100644 --- a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/ExampleQuery.cs +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/InputExampleQuery.cs @@ -12,30 +12,30 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; -namespace Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1; /// /// Query for searching for BRS-X01. /// Must be JSON serializable. /// -public record ExampleQuery - : SearchOrchestrationInstancesByCustomQuery +public record InputExampleQuery + : SearchOrchestrationInstancesByCustomQuery { /// /// Construct query. /// /// Identity of the user executing the query. /// search criteria to check if step two was skipped - public ExampleQuery( + public InputExampleQuery( UserIdentityDto operatingIdentity, bool skippedStepTwo = default) : base( operatingIdentity, - new Brs_X01_Example_V1().Name) + new Brs_X01_InputExample_V1().Name) { SkippedStepTwo = skippedStepTwo; } diff --git a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/ExampleQueryResult.cs b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/InputExampleQueryResult.cs similarity index 69% rename from source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/ExampleQueryResult.cs rename to source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/InputExampleQueryResult.cs index b663aa3e..89d093d9 100644 --- a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/ExampleQueryResult.cs +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/InputExampleQueryResult.cs @@ -12,13 +12,13 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; -namespace Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1; /// /// Query result from searching BRS-X01. /// Must be JSON serializable. /// -public record ExampleQueryResult(OrchestrationInstanceTypedDto OrchestrationInstance); +public record InputExampleQueryResult(OrchestrationInstanceTypedDto OrchestrationInstance); diff --git a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/Brs_X01_InputExample_V1.cs similarity index 74% rename from source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/Brs_X01_InputExample_V1.cs index dc2bb85d..6aebeec1 100644 --- a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/Brs_X01_InputExample_V1.cs @@ -14,7 +14,7 @@ using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationDescription; -namespace Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; -public record Brs_X01_Example_V1() - : OrchestrationDescriptionUniqueNameDto("Brs_X01_Example", 1); +public record Brs_X01_InputExample_V1() + : OrchestrationDescriptionUniqueNameDto("Brs_X01_InputExample", 1); diff --git a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/InputV1.cs b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/InputV1.cs similarity index 87% rename from source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/InputV1.cs rename to source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/InputV1.cs index fcea3495..972e5f56 100644 --- a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/InputV1.cs +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/InputV1.cs @@ -14,7 +14,7 @@ using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; -namespace Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; /// /// An immutable input to start the orchestration instance for BRS_X01 V1. diff --git a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/ScheduleExampleCommandV1.cs b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/ScheduleInputExampleCommandV1.cs similarity index 87% rename from source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/ScheduleExampleCommandV1.cs rename to source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/ScheduleInputExampleCommandV1.cs index 10c8eff3..1e63403b 100644 --- a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/ScheduleExampleCommandV1.cs +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/ScheduleInputExampleCommandV1.cs @@ -15,13 +15,13 @@ using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; -namespace Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; /// /// Command for scheduling the BRS_X01. /// Must be JSON serializable. /// -public record ScheduleExampleCommandV1 +public record ScheduleInputExampleCommandV1 : ScheduleOrchestrationInstanceCommand { /// @@ -30,13 +30,13 @@ public record ScheduleExampleCommandV1 /// Identity of the user executing the command. /// Contains the Durable Functions orchestration input parameter value. /// The time when the orchestration instance should be executed by the Scheduler. - public ScheduleExampleCommandV1( + public ScheduleInputExampleCommandV1( UserIdentityDto operatingIdentity, InputV1 inputParameter, DateTimeOffset runAt) : base( operatingIdentity, - orchestrationDescriptionUniqueName: new Brs_X01_Example_V1(), + orchestrationDescriptionUniqueName: new Brs_X01_InputExample_V1(), inputParameter, runAt) { diff --git a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/StartExampleCommandV1.cs b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/StartInputExampleCommandV1.cs similarity index 86% rename from source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/StartExampleCommandV1.cs rename to source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/StartInputExampleCommandV1.cs index 3bce2e1e..ea8e4340 100644 --- a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/Example/V1/Model/StartExampleCommandV1.cs +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/InputExample/V1/Model/StartInputExampleCommandV1.cs @@ -15,13 +15,13 @@ using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; -namespace Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; /// /// Command for starting the BRS_X01. /// Must be JSON serializable. /// -public record StartExampleCommandV1 +public record StartInputExampleCommandV1 : StartOrchestrationInstanceCommand { /// @@ -29,12 +29,12 @@ public record StartExampleCommandV1 /// /// Identity of the user executing the command. /// contains the Durable Functions orchestration input parameter value. - public StartExampleCommandV1( + public StartInputExampleCommandV1( UserIdentityDto operatingIdentity, InputV1 inputParameter) : base( operatingIdentity, - orchestrationDescriptionUniqueName: new Brs_X01_Example_V1(), + orchestrationDescriptionUniqueName: new Brs_X01_InputExample_V1(), inputParameter) { } diff --git a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/Brs_X01_NoInputExample_V1.cs b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/Brs_X01_NoInputExample_V1.cs similarity index 86% rename from source/Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/Brs_X01_NoInputExample_V1.cs rename to source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/Brs_X01_NoInputExample_V1.cs index b8deddb8..d44a1dcd 100644 --- a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/Brs_X01_NoInputExample_V1.cs +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/Brs_X01_NoInputExample_V1.cs @@ -14,7 +14,7 @@ using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationDescription; -namespace Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; public record Brs_X01_NoInputExample_V1() : OrchestrationDescriptionUniqueNameDto("Brs_X01_NoInputExample_V1", 1); diff --git a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/StartNoInputExampleComandV1.cs b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/StartNoInputExampleCommandV1.cs similarity index 85% rename from source/Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/StartNoInputExampleComandV1.cs rename to source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/StartNoInputExampleCommandV1.cs index 600a4b00..7f8e19ad 100644 --- a/source/Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/StartNoInputExampleComandV1.cs +++ b/source/ProcessManager.Example.Orchestrations.Abstrations/Processes/BRS_X01/NoInputExample/V1/Model/StartNoInputExampleCommandV1.cs @@ -15,20 +15,20 @@ using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; -namespace Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; /// /// Command for starting a BRS-X01 no-input example. /// Must be JSON serializable. /// -public sealed record StartNoInputExampleComandV1 +public sealed record StartNoInputExampleCommandV1 : StartOrchestrationInstanceCommand { /// /// Construct command. /// /// Identity of the user executing the command. - public StartNoInputExampleComandV1( + public StartNoInputExampleCommandV1( UserIdentityDto operatingIdentity) : base( operatingIdentity, diff --git a/source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppCollection.cs b/source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppCollection.cs similarity index 92% rename from source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppCollection.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppCollection.cs index d4339b69..5195249d 100644 --- a/source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppCollection.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppCollection.cs @@ -12,7 +12,7 @@ // See the License for the specific language governing permissions and // limitations under the License. -namespace Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; /// /// A xUnit collection fixture for ensuring tests don't run in parallel. diff --git a/source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppFixture.cs b/source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppFixture.cs similarity index 93% rename from source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppFixture.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppFixture.cs index 9e9b2847..ea68c4b2 100644 --- a/source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppFixture.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppFixture.cs @@ -18,12 +18,12 @@ using Energinet.DataHub.ProcessManager.Tests.Fixtures; using Xunit.Abstractions; -namespace Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; /// -/// Support testing the interactions with Example.Orchestrations and +/// Support testing the interactions with ProcessManager.Example.Orchestrations and /// Process Manager Api, by coordinating the startup of the dependent applications -/// Example.Orchestrations and ProcessManager (Api). +/// ProcessManager.Example.Orchestrations and ProcessManager (Api). /// public class ExampleOrchestrationsAppFixture : IAsyncLifetime { diff --git a/source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppManager.cs b/source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppManager.cs similarity index 97% rename from source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppManager.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppManager.cs index fd007ab4..971998b6 100644 --- a/source/Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppManager.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Fixtures/ExampleOrchestrationsAppManager.cs @@ -22,7 +22,7 @@ using Energinet.DataHub.ProcessManager.Core.Tests.Fixtures; using Xunit.Abstractions; -namespace Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; /// /// Support testing Example Orchestrations app and specifying configuration using inheritance. @@ -101,7 +101,7 @@ public async Task StartAsync() await DatabaseManager.CreateDatabaseAsync(); // Prepare host settings - var appHostSettings = CreateAppHostSettings("Example.Orchestrations"); + var appHostSettings = CreateAppHostSettings("ProcessManager.Example.Orchestrations"); // Create and start host AppHostManager = new FunctionAppHostManager(appHostSettings, TestLogger); diff --git a/source/Example.Orchestrations.Tests/Integration/Monitor/HealthCheckEndpointTests.cs b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Monitor/HealthCheckEndpointTests.cs similarity index 93% rename from source/Example.Orchestrations.Tests/Integration/Monitor/HealthCheckEndpointTests.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Integration/Monitor/HealthCheckEndpointTests.cs index 7c37ce3b..0b1c3008 100644 --- a/source/Example.Orchestrations.Tests/Integration/Monitor/HealthCheckEndpointTests.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Monitor/HealthCheckEndpointTests.cs @@ -13,12 +13,12 @@ // limitations under the License. using System.Net; -using Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; using FluentAssertions; using FluentAssertions.Execution; using Xunit.Abstractions; -namespace Energinet.DataHub.Example.Orchestrations.Tests.Integration.Monitor; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Integration.Monitor; /// /// Tests verifying the configuration and behaviour of Health Checks. diff --git a/source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/MonitorExampleUsingApiScenario.cs b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/MonitorInputExampleUsingApiScenario.cs similarity index 83% rename from source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/MonitorExampleUsingApiScenario.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/MonitorInputExampleUsingApiScenario.cs index f1222e73..23fed5f2 100644 --- a/source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/MonitorExampleUsingApiScenario.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/MonitorInputExampleUsingApiScenario.cs @@ -16,24 +16,24 @@ using System.Text; using System.Text.Json; using Energinet.DataHub.Core.TestCommon; -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; -using Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; using FluentAssertions; using Xunit.Abstractions; -namespace Energinet.DataHub.ProcessManager.Tests.Integration.Processes; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Integration.Processes.BRS_X01.InputExample.V1; /// -/// Test case where we verify the Example.Orchestrations and Process Manager Api +/// Test case where we verify the ProcessManager.Example.Orchestrations and Process Manager Api /// can be used to start an example orchestration (with input parameter) and /// monitor its status during its lifetime. /// [Collection(nameof(ExampleOrchestrationsAppCollection))] -public class MonitorExampleUsingApiScenario : IAsyncLifetime +public class MonitorInputExampleUsingApiScenario : IAsyncLifetime { - public MonitorExampleUsingApiScenario( + public MonitorInputExampleUsingApiScenario( ExampleOrchestrationsAppFixture fixture, ITestOutputHelper testOutputHelper) { @@ -62,10 +62,10 @@ public Task DisposeAsync() [Fact] public async Task ExampleOrchestration_WhenStarted_CanMonitorLifecycle() { - var orchestration = new Brs_X01_Example_V1(); + var orchestration = new Brs_X01_InputExample_V1(); var input = new InputV1(false); - var command = new StartExampleCommandV1( + var command = new StartInputExampleCommandV1( operatingIdentity: new UserIdentityDto( Guid.NewGuid(), Guid.NewGuid()), @@ -114,7 +114,8 @@ public async Task ExampleOrchestration_WhenStarted_CanMonitorLifecycle() var orchestrationInstance = await queryResponse.Content .ReadFromJsonAsync(); - return orchestrationInstance!.Lifecycle.State == OrchestrationInstanceLifecycleStates.Terminated; + return orchestrationInstance!.Lifecycle.State == OrchestrationInstanceLifecycleStates.Terminated + && orchestrationInstance!.Lifecycle.TerminationState == OrchestrationInstanceTerminationStates.Succeeded; }, timeLimit: TimeSpan.FromSeconds(40), delay: TimeSpan.FromSeconds(2)); diff --git a/source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/V1/OrchestrationsCompletionsTests.cs b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/OrchestrationsCompletionsTests.cs similarity index 93% rename from source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/V1/OrchestrationsCompletionsTests.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/OrchestrationsCompletionsTests.cs index 6a212b2e..2e785f9a 100644 --- a/source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/V1/OrchestrationsCompletionsTests.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/OrchestrationsCompletionsTests.cs @@ -15,14 +15,14 @@ // using System.Text; // using System.Text.Json; // using Energinet.DataHub.Core.DurableFunctionApp.TestCommon.DurableTask; -// using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; -// using Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; -// using Energinet.DataHub.Example.Orchestrations.Tests.Models; +// using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; +// using Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; +// using Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Models; // using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; // using FluentAssertions; // using Xunit.Abstractions; // -// namespace Energinet.DataHub.Example.Orchestrations.Tests.Integration.Processes.BRS_X01.Examples.V1; +// namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Integration.Processes.BRS_X01.Examples.V1; // // /// // /// Tests that verify that we can start and finish a "BRS_X01" orchestration. diff --git a/source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/V1/OrchestrationsSearchTests.cs b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/OrchestrationsSearchTests.cs similarity index 91% rename from source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/V1/OrchestrationsSearchTests.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/OrchestrationsSearchTests.cs index d13f84fe..0b2b09ef 100644 --- a/source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/Examples/V1/OrchestrationsSearchTests.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/InputExample/V1/OrchestrationsSearchTests.cs @@ -16,16 +16,16 @@ // using System.Text; // using System.Text.Json; // using Energinet.DataHub.Core.DurableFunctionApp.TestCommon.DurableTask; -// using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1; -// using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; -// using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1; -// using Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; +// using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1; +// using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; +// using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.Example.V1; +// using Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; // using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; // using FluentAssertions; // using NodaTime; // using Xunit.Abstractions; // -// namespace Energinet.DataHub.Example.Orchestrations.Tests.Integration.Processes.BRS_X01.Examples.V1; +// namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Integration.Processes.BRS_X01.Examples.V1; // // /// // /// Tests that verify that we can search in "BRS_X01" orchestrations. diff --git a/source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/NoInputExample/MonitorNoInputExampleUsingApiScenario.cs b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/NoInputExample/V1/MonitorNoInputExampleUsingApiScenario.cs similarity index 85% rename from source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/NoInputExample/MonitorNoInputExampleUsingApiScenario.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/NoInputExample/V1/MonitorNoInputExampleUsingApiScenario.cs index e03689a0..aa04bf67 100644 --- a/source/Example.Orchestrations.Tests/Integration/Processes/BRS_X01/NoInputExample/MonitorNoInputExampleUsingApiScenario.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Integration/Processes/BRS_X01/NoInputExample/V1/MonitorNoInputExampleUsingApiScenario.cs @@ -16,18 +16,18 @@ using System.Text; using System.Text.Json; using Energinet.DataHub.Core.TestCommon; -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; -using Energinet.DataHub.Example.Orchestrations.Tests.Fixtures; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model; using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Fixtures; using FluentAssertions; using Xunit.Abstractions; -namespace Energinet.DataHub.Example.Orchestrations.Tests.Integration.Processes.BRS_X01.NoInputExample; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Integration.Processes.BRS_X01.NoInputExample.V1; /// -/// Test case where we verify the Example.Orchestrations and Process Manager Api -/// can be used to start an example orchestration (with input parameter) and +/// Test case where we verify the ProcessManager.Example.Orchestrations and Process Manager Api +/// can be used to start an example orchestration (with no-input parameter) and /// monitor its status during its lifetime. /// [Collection(nameof(ExampleOrchestrationsAppCollection))] @@ -62,9 +62,7 @@ public Task DisposeAsync() [Fact] public async Task NoInputExampleOrchestration_WhenStarted_CanMonitorLifecycle() { - var orchestration = new Brs_X01_NoInputExample_V1(); - - var command = new StartNoInputExampleComandV1( + var command = new StartNoInputExampleCommandV1( operatingIdentity: new UserIdentityDto( Guid.NewGuid(), Guid.NewGuid())); @@ -112,7 +110,8 @@ public async Task NoInputExampleOrchestration_WhenStarted_CanMonitorLifecycle() var orchestrationInstance = await queryResponse.Content .ReadFromJsonAsync(); - return orchestrationInstance!.Lifecycle.State == OrchestrationInstanceLifecycleStates.Terminated; + return orchestrationInstance!.Lifecycle.State == OrchestrationInstanceLifecycleStates.Terminated + && orchestrationInstance.Lifecycle.TerminationState == OrchestrationInstanceTerminationStates.Succeeded; }, timeLimit: TimeSpan.FromSeconds(40), delay: TimeSpan.FromSeconds(2)); diff --git a/source/Example.Orchestrations.Tests/Models/OrchestrationHistoryItem.cs b/source/ProcessManager.Example.Orchestrations.Tests/Models/OrchestrationHistoryItem.cs similarity index 90% rename from source/Example.Orchestrations.Tests/Models/OrchestrationHistoryItem.cs rename to source/ProcessManager.Example.Orchestrations.Tests/Models/OrchestrationHistoryItem.cs index 3d46c7de..8683056f 100644 --- a/source/Example.Orchestrations.Tests/Models/OrchestrationHistoryItem.cs +++ b/source/ProcessManager.Example.Orchestrations.Tests/Models/OrchestrationHistoryItem.cs @@ -12,7 +12,7 @@ // See the License for the specific language governing permissions and // limitations under the License. -namespace Energinet.DataHub.Example.Orchestrations.Tests.Models; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests.Models; public record OrchestrationHistoryItem( string? EventType, diff --git a/source/Example.Orchestrations.Tests/Example.Orchestrations.Tests.csproj b/source/ProcessManager.Example.Orchestrations.Tests/ProcessManager.Example.Orchestrations.Tests.csproj similarity index 84% rename from source/Example.Orchestrations.Tests/Example.Orchestrations.Tests.csproj rename to source/ProcessManager.Example.Orchestrations.Tests/ProcessManager.Example.Orchestrations.Tests.csproj index 8ea0b1ba..840d3ee0 100644 --- a/source/Example.Orchestrations.Tests/Example.Orchestrations.Tests.csproj +++ b/source/ProcessManager.Example.Orchestrations.Tests/ProcessManager.Example.Orchestrations.Tests.csproj @@ -1,9 +1,8 @@  - Energinet.DataHub.Example.Orchestrations.Tests - Energinet.DataHub.Example.Orchestrations.Tests - + Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests + Energinet.DataHub.ProcessManager.Example.Orchestrations.Tests false true @@ -27,7 +26,7 @@ - + diff --git a/source/Example.Orchestrations.Tests/functionapphost.settings.json b/source/ProcessManager.Example.Orchestrations.Tests/functionapphost.settings.json similarity index 100% rename from source/Example.Orchestrations.Tests/functionapphost.settings.json rename to source/ProcessManager.Example.Orchestrations.Tests/functionapphost.settings.json diff --git a/source/Example.Orchestrations.Tests/integrationtest.local.settings.sample.json b/source/ProcessManager.Example.Orchestrations.Tests/integrationtest.local.settings.sample.json similarity index 100% rename from source/Example.Orchestrations.Tests/integrationtest.local.settings.sample.json rename to source/ProcessManager.Example.Orchestrations.Tests/integrationtest.local.settings.sample.json diff --git a/source/Example.Orchestrations/Monitor/HealthCheckEndpoint.cs b/source/ProcessManager.Example.Orchestrations/Monitor/HealthCheckEndpoint.cs similarity index 94% rename from source/Example.Orchestrations/Monitor/HealthCheckEndpoint.cs rename to source/ProcessManager.Example.Orchestrations/Monitor/HealthCheckEndpoint.cs index 7020d536..6267ed9d 100644 --- a/source/Example.Orchestrations/Monitor/HealthCheckEndpoint.cs +++ b/source/ProcessManager.Example.Orchestrations/Monitor/HealthCheckEndpoint.cs @@ -16,7 +16,7 @@ using Microsoft.Azure.Functions.Worker; using Microsoft.Azure.Functions.Worker.Http; -namespace Energinet.DataHub.Example.Orchestrations.Monitor; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Monitor; public class HealthCheckEndpoint { diff --git a/source/Example.Orchestrations/Example.Orchestrations.csproj b/source/ProcessManager.Example.Orchestrations/ProcessManager.Example.Orchestrations.csproj similarity index 80% rename from source/Example.Orchestrations/Example.Orchestrations.csproj rename to source/ProcessManager.Example.Orchestrations/ProcessManager.Example.Orchestrations.csproj index 09756cfd..b634153f 100644 --- a/source/Example.Orchestrations/Example.Orchestrations.csproj +++ b/source/ProcessManager.Example.Orchestrations/ProcessManager.Example.Orchestrations.csproj @@ -1,7 +1,7 @@  - Energinet.DataHub.Example.Orchestrations - Energinet.DataHub.Example.Orchestrations + Energinet.DataHub.ProcessManager.Example.Orchestrations + Energinet.DataHub.ProcessManager.Example.Orchestrations v4 Exe @@ -12,7 +12,7 @@ - + diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/SearchExampleHandler.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/SearchInputExampleHandler.cs similarity index 83% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/SearchExampleHandler.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/SearchInputExampleHandler.cs index 16a73f00..ad8e4f00 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/SearchExampleHandler.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/SearchInputExampleHandler.cs @@ -12,21 +12,21 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1; -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; using Energinet.DataHub.ProcessManagement.Core.Application.Orchestration; using Energinet.DataHub.ProcessManagement.Core.Domain.OrchestrationInstance; using Energinet.DataHub.ProcessManager.Api.Mappers; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample; -internal class SearchExampleHandler( +internal class SearchInputExampleHandler( IOrchestrationInstanceQueries queries) { private readonly IOrchestrationInstanceQueries _queries = queries; - public async Task> SearchAsync(ExampleQuery query) + public async Task> SearchAsync(InputExampleQuery query) { // * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * // @@ -64,7 +64,7 @@ public async Task> SearchAsync(ExampleQu .ConfigureAwait(false); return calculations - .Select(item => new ExampleQueryResult(item.MapToTypedDto())) + .Select(item => new InputExampleQueryResult(item.MapToTypedDto())) .ToList(); } } diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/SearchTrigger_Brs_X01_Example.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/SearchTrigger_Brs_X01_InputExample.cs similarity index 68% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/SearchTrigger_Brs_X01_Example.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/SearchTrigger_Brs_X01_InputExample.cs index 601842af..a2e1e5e4 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/SearchTrigger_Brs_X01_Example.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/SearchTrigger_Brs_X01_InputExample.cs @@ -12,34 +12,34 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; using Microsoft.Azure.Functions.Worker; using FromBodyAttribute = Microsoft.Azure.Functions.Worker.Http.FromBodyAttribute; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample; -internal class SearchTrigger_Brs_X01_Example( - SearchExampleHandler exampleHandler) +internal class SearchTrigger_Brs_X01_InputExample( + SearchInputExampleHandler handler) { - private readonly SearchExampleHandler _exampleHandler = exampleHandler; + private readonly SearchInputExampleHandler _handler = handler; /// /// Search for instances of BRS-X01. /// - [Function(nameof(SearchTrigger_Brs_X01_Example))] + [Function(nameof(SearchTrigger_Brs_X01_InputExample))] public async Task Run( [HttpTrigger( AuthorizationLevel.Anonymous, "post", - Route = "orchestrationinstance/query/custom/brs_x01_example")] + Route = "orchestrationinstance/query/custom/brs_x01_inputExample")] HttpRequest httpRequest, [FromBody] - ExampleQuery query, + InputExampleQuery query, FunctionContext executionContext) { - var queryResultItems = await _exampleHandler.SearchAsync(query).ConfigureAwait(false); + var queryResultItems = await _handler.SearchAsync(query).ConfigureAwait(false); return new OkObjectResult(queryResultItems); } diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/FirstStepStartActivity_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/FirstStepStartActivity_Brs_X01_InputExample_V1.cs similarity index 83% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/FirstStepStartActivity_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/FirstStepStartActivity_Brs_X01_InputExample_V1.cs index c8c75015..fd8da8f6 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/FirstStepStartActivity_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/FirstStepStartActivity_Brs_X01_InputExample_V1.cs @@ -17,16 +17,16 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Activities; -internal class FirstStepStartActivity_Brs_X01_Example_V1( +internal class FirstStepStartActivity_Brs_X01_InputExample_V1( IClock clock, IOrchestrationInstanceProgressRepository progressRepository) : ProgressActivityBase( clock, progressRepository) { - [Function(nameof(FirstStepStartActivity_Brs_X01_Example_V1))] + [Function(nameof(FirstStepStartActivity_Brs_X01_InputExample_V1))] public async Task Run( [ActivityTrigger] ActivityInput input) { @@ -34,7 +34,7 @@ public async Task Run( .GetAsync(input.OrchestrationInstanceId) .ConfigureAwait(false); - var step = orchestrationInstance.Steps.Single(x => x.Sequence == Orchestration_Brs_X01_Example_V1.FirstStepSequence); + var step = orchestrationInstance.Steps.Single(x => x.Sequence == Orchestration_Brs_X01_InputExample_V1.FirstStepSequence); step.Lifecycle.TransitionToRunning(Clock); await ProgressRepository.UnitOfWork.CommitAsync().ConfigureAwait(false); diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/FirstStepStopActivity_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/FirstStepStopActivity_Brs_X01_InputExample_V1.cs similarity index 83% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/FirstStepStopActivity_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/FirstStepStopActivity_Brs_X01_InputExample_V1.cs index 27581952..d8cb6b5e 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/FirstStepStopActivity_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/FirstStepStopActivity_Brs_X01_InputExample_V1.cs @@ -17,16 +17,16 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Activities; -internal class FirstStepStopActivity_Brs_X01_Example_V1( +internal class FirstStepStopActivity_Brs_X01_InputExample_V1( IClock clock, IOrchestrationInstanceProgressRepository progressRepository) : ProgressActivityBase( clock, progressRepository) { - [Function(nameof(FirstStepStopActivity_Brs_X01_Example_V1))] + [Function(nameof(FirstStepStopActivity_Brs_X01_InputExample_V1))] public async Task Run( [ActivityTrigger] ActivityInput input) { @@ -34,7 +34,7 @@ public async Task Run( .GetAsync(input.OrchestrationInstanceId) .ConfigureAwait(false); - var step = orchestrationInstance.Steps.Single(x => x.Sequence == Orchestration_Brs_X01_Example_V1.FirstStepSequence); + var step = orchestrationInstance.Steps.Single(x => x.Sequence == Orchestration_Brs_X01_InputExample_V1.FirstStepSequence); step.Lifecycle.TransitionToTerminated(Clock, OrchestrationStepTerminationStates.Succeeded); await ProgressRepository.UnitOfWork.CommitAsync().ConfigureAwait(false); diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/InitializeOrchestrationActivity_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/InitializeOrchestrationActivity_Brs_X01_InputExample_V1.cs similarity index 84% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/InitializeOrchestrationActivity_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/InitializeOrchestrationActivity_Brs_X01_InputExample_V1.cs index 7001eca5..adb34986 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/InitializeOrchestrationActivity_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/InitializeOrchestrationActivity_Brs_X01_InputExample_V1.cs @@ -12,22 +12,22 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Model; using Energinet.DataHub.ProcessManagement.Core.Application.Orchestration; using Energinet.DataHub.ProcessManagement.Core.Domain.OrchestrationInstance; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Model; using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Activities; -internal class InitializeOrchestrationActivity_Brs_X01_Example_V1( +internal class InitializeOrchestrationActivity_Brs_X01_InputExample_V1( IClock clock, IOrchestrationInstanceProgressRepository progressRepository) : ProgressActivityBase( clock, progressRepository) { - [Function(nameof(InitializeOrchestrationActivity_Brs_X01_Example_V1))] + [Function(nameof(InitializeOrchestrationActivity_Brs_X01_InputExample_V1))] public async Task Run( [ActivityTrigger] ActivityInput input) { diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/ProgressActivityBase.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/ProgressActivityBase.cs similarity index 89% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/ProgressActivityBase.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/ProgressActivityBase.cs index 0f540286..a8ed3b57 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/ProgressActivityBase.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/ProgressActivityBase.cs @@ -15,7 +15,7 @@ using Energinet.DataHub.ProcessManagement.Core.Application.Orchestration; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Activities; internal abstract class ProgressActivityBase( IClock clock, diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/SecondStepStartActivity_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/SecondStepStartActivity_Brs_X01_InputExample_V1.cs similarity index 84% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/SecondStepStartActivity_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/SecondStepStartActivity_Brs_X01_InputExample_V1.cs index 6b834c07..70bc71b4 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/SecondStepStartActivity_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/SecondStepStartActivity_Brs_X01_InputExample_V1.cs @@ -17,16 +17,16 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Activities; -internal class SecondStepStartActivity_Brs_X01_Example_V1( +internal class SecondStepStartActivity_Brs_X01_InputExample_V1( IClock clock, IOrchestrationInstanceProgressRepository progressRepository) : ProgressActivityBase( clock, progressRepository) { - [Function(nameof(SecondStepStartActivity_Brs_X01_Example_V1))] + [Function(nameof(SecondStepStartActivity_Brs_X01_InputExample_V1))] public async Task Run( [ActivityTrigger] ActivityInput input) { @@ -35,7 +35,7 @@ public async Task Run( .ConfigureAwait(false); var step = orchestrationInstance.Steps - .Single(step => step.Sequence == Orchestration_Brs_X01_Example_V1.SkippableStepSequence); + .Single(step => step.Sequence == Orchestration_Brs_X01_InputExample_V1.SkippableStepSequence); step.Lifecycle.TransitionToRunning(Clock); await ProgressRepository.UnitOfWork.CommitAsync().ConfigureAwait(false); diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/SecondStepStopActivity_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/SecondStepStopActivity_Brs_X01_InputExample_V1.cs similarity index 85% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/SecondStepStopActivity_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/SecondStepStopActivity_Brs_X01_InputExample_V1.cs index e0343643..c8736c64 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/SecondStepStopActivity_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/SecondStepStopActivity_Brs_X01_InputExample_V1.cs @@ -17,16 +17,16 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Activities; -internal class SecondStepStopActivity_Brs_X01_Example_V1( +internal class SecondStepStopActivity_Brs_X01_InputExample_V1( IClock clock, IOrchestrationInstanceProgressRepository progressRepository) : ProgressActivityBase( clock, progressRepository) { - [Function(nameof(SecondStepStopActivity_Brs_X01_Example_V1))] + [Function(nameof(SecondStepStopActivity_Brs_X01_InputExample_V1))] public async Task Run( [ActivityTrigger] ActivityInput input) { @@ -35,7 +35,7 @@ public async Task Run( .ConfigureAwait(false); var step = orchestrationInstance.Steps - .Single(step => step.Sequence == Orchestration_Brs_X01_Example_V1.SkippableStepSequence); + .Single(step => step.Sequence == Orchestration_Brs_X01_InputExample_V1.SkippableStepSequence); step.Lifecycle.TransitionToTerminated(Clock, OrchestrationStepTerminationStates.Succeeded); await ProgressRepository.UnitOfWork.CommitAsync().ConfigureAwait(false); diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/TerminateOrchestrationActivity_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/TerminateOrchestrationActivity_Brs_X01_InputExample_V1.cs similarity index 85% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/TerminateOrchestrationActivity_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/TerminateOrchestrationActivity_Brs_X01_InputExample_V1.cs index 68a8663a..28510a7d 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Activities/TerminateOrchestrationActivity_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Activities/TerminateOrchestrationActivity_Brs_X01_InputExample_V1.cs @@ -17,16 +17,16 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Activities; -internal class TerminateOrchestrationActivity_Brs_X01_Example_V1( +internal class TerminateOrchestrationActivity_Brs_X01_InputExample_V1( IClock clock, IOrchestrationInstanceProgressRepository progressRepository) : ProgressActivityBase( clock, progressRepository) { - [Function(nameof(TerminateOrchestrationActivity_Brs_X01_Example_V1))] + [Function(nameof(TerminateOrchestrationActivity_Brs_X01_InputExample_V1))] public async Task Run( [ActivityTrigger] ActivityInput input) { diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Model/OrchestrationExecutionPlan.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Model/OrchestrationExecutionPlan.cs similarity index 90% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Model/OrchestrationExecutionPlan.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Model/OrchestrationExecutionPlan.cs index 10227e2a..1d695630 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Model/OrchestrationExecutionPlan.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Model/OrchestrationExecutionPlan.cs @@ -12,7 +12,7 @@ // See the License for the specific language governing permissions and // limitations under the License. -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Model; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Model; /// /// The purpose of this record is to give the orchestration information about diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Orchestration_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Orchestration_Brs_X01_InputExample_V1.cs similarity index 64% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Orchestration_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Orchestration_Brs_X01_InputExample_V1.cs index 82163a38..c30aaedc 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/Orchestration_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/Orchestration_Brs_X01_InputExample_V1.cs @@ -12,29 +12,29 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Activities; -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1.Model; using Energinet.DataHub.ProcessManagement.Core.Domain.OrchestrationInstance; using Energinet.DataHub.ProcessManagement.Core.Infrastructure.Extensions.DurableTask; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Activities; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1.Model; using Microsoft.Azure.Functions.Worker; using Microsoft.DurableTask; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1; -internal class Orchestration_Brs_X01_Example_V1 +internal class Orchestration_Brs_X01_InputExample_V1 { internal const int FirstStepSequence = 1; internal const int SkippableStepSequence = 2; private readonly TaskOptions _defaultRetryOptions; - public Orchestration_Brs_X01_Example_V1() + public Orchestration_Brs_X01_InputExample_V1() { _defaultRetryOptions = CreateDefaultRetryOptions(); } - [Function(nameof(Orchestration_Brs_X01_Example_V1))] + [Function(nameof(Orchestration_Brs_X01_InputExample_V1))] public async Task Run( [OrchestrationTrigger] TaskOrchestrationContext context) { @@ -48,20 +48,20 @@ public async Task Run( // Initialize var executionPlan = await context.CallActivityAsync( - nameof(InitializeOrchestrationActivity_Brs_X01_Example_V1), - new InitializeOrchestrationActivity_Brs_X01_Example_V1.ActivityInput( + nameof(InitializeOrchestrationActivity_Brs_X01_InputExample_V1), + new InitializeOrchestrationActivity_Brs_X01_InputExample_V1.ActivityInput( instanceId), _defaultRetryOptions); // First Step await context.CallActivityAsync( - nameof(FirstStepStartActivity_Brs_X01_Example_V1), - new FirstStepStartActivity_Brs_X01_Example_V1.ActivityInput( + nameof(FirstStepStartActivity_Brs_X01_InputExample_V1), + new FirstStepStartActivity_Brs_X01_InputExample_V1.ActivityInput( instanceId), _defaultRetryOptions); await context.CallActivityAsync( - nameof(FirstStepStopActivity_Brs_X01_Example_V1), - new FirstStepStopActivity_Brs_X01_Example_V1.ActivityInput( + nameof(FirstStepStopActivity_Brs_X01_InputExample_V1), + new FirstStepStopActivity_Brs_X01_InputExample_V1.ActivityInput( instanceId), _defaultRetryOptions); @@ -69,21 +69,21 @@ await context.CallActivityAsync( if (!executionPlan.SkippedStepsBySequence.Contains(SkippableStepSequence)) { await context.CallActivityAsync( - nameof(SecondStepStartActivity_Brs_X01_Example_V1), - new SecondStepStartActivity_Brs_X01_Example_V1.ActivityInput( + nameof(SecondStepStartActivity_Brs_X01_InputExample_V1), + new SecondStepStartActivity_Brs_X01_InputExample_V1.ActivityInput( instanceId), _defaultRetryOptions); await context.CallActivityAsync( - nameof(SecondStepStopActivity_Brs_X01_Example_V1), - new SecondStepStopActivity_Brs_X01_Example_V1.ActivityInput( + nameof(SecondStepStopActivity_Brs_X01_InputExample_V1), + new SecondStepStopActivity_Brs_X01_InputExample_V1.ActivityInput( instanceId), _defaultRetryOptions); } // Terminate await context.CallActivityAsync( - nameof(TerminateOrchestrationActivity_Brs_X01_Example_V1), - new TerminateOrchestrationActivity_Brs_X01_Example_V1.ActivityInput( + nameof(TerminateOrchestrationActivity_Brs_X01_InputExample_V1), + new TerminateOrchestrationActivity_Brs_X01_InputExample_V1.ActivityInput( instanceId), _defaultRetryOptions); diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/ScheduleTrigger_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/ScheduleTrigger_Brs_X01_InputExample_V1.cs similarity index 72% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/ScheduleTrigger_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/ScheduleTrigger_Brs_X01_InputExample_V1.cs index fc227abf..c39c4fde 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/ScheduleTrigger_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/ScheduleTrigger_Brs_X01_InputExample_V1.cs @@ -12,31 +12,31 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; using Microsoft.Azure.Functions.Worker; using FromBodyAttribute = Microsoft.Azure.Functions.Worker.Http.FromBodyAttribute; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1; -internal class ScheduleTrigger_Brs_X01_Example_V1( - StartExampleHandlerV1 handler) +internal class ScheduleTrigger_Brs_X01_InputExample_V1( + StartInputExampleHandlerV1 handler) { - private readonly StartExampleHandlerV1 _handler = handler; + private readonly StartInputExampleHandlerV1 _handler = handler; /// /// Schedule a BRS-X01 and return its id. /// - [Function(nameof(ScheduleTrigger_Brs_X01_Example_V1))] + [Function(nameof(ScheduleTrigger_Brs_X01_InputExample_V1))] public async Task Run( [HttpTrigger( AuthorizationLevel.Anonymous, "post", - Route = "orchestrationinstance/command/schedule/custom/brs_x01_example/1")] + Route = "orchestrationinstance/command/schedule/custom/brs_x01_inputExample/1")] HttpRequest httpRequest, [FromBody] - ScheduleExampleCommandV1 command, + ScheduleInputExampleCommandV1 command, FunctionContext executionContext) { var orchestrationInstanceId = await _handler.ScheduleNewExampleAsync(command).ConfigureAwait(false); diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/StartExampleHandlerV1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/StartInputExampleHandlerV1.cs similarity index 85% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/StartExampleHandlerV1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/StartInputExampleHandlerV1.cs index c3d0785e..c0808073 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/StartExampleHandlerV1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/StartInputExampleHandlerV1.cs @@ -12,24 +12,24 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; using Energinet.DataHub.ProcessManagement.Core.Application.Orchestration; using Energinet.DataHub.ProcessManagement.Core.Domain.OrchestrationDescription; using Energinet.DataHub.ProcessManagement.Core.Domain.OrchestrationInstance; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; using NodaTime.Extensions; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1; -internal class StartExampleHandlerV1( +internal class StartInputExampleHandlerV1( IStartOrchestrationInstanceCommands manager) { private readonly IStartOrchestrationInstanceCommands _manager = manager; - public async Task StartNewExampleAsync(StartExampleCommandV1 command) + public async Task StartNewExampleAsync(StartInputExampleCommandV1 command) { // Here we show how its possible, based on input, to decide certain steps should be skipped by the orchestration. IReadOnlyCollection skipStepsBySequence = command.InputParameter.ShouldSkipSkippableStep - ? [Orchestration_Brs_X01_Example_V1.SkippableStepSequence] + ? [Orchestration_Brs_X01_InputExample_V1.SkippableStepSequence] : []; var orchestrationInstanceId = await _manager @@ -47,11 +47,11 @@ public async Task StartNewExampleAsync(StartExampleComm return orchestrationInstanceId; } - public async Task ScheduleNewExampleAsync(ScheduleExampleCommandV1 command) + public async Task ScheduleNewExampleAsync(ScheduleInputExampleCommandV1 command) { // Here we show how its possible, based on input, to decide certain steps should be skipped by the orchestration. IReadOnlyCollection skipStepsBySequence = command.InputParameter.ShouldSkipSkippableStep - ? [Orchestration_Brs_X01_Example_V1.SkippableStepSequence] + ? [Orchestration_Brs_X01_InputExample_V1.SkippableStepSequence] : []; var orchestrationInstanceId = await _manager diff --git a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/StartTrigger_Brs_X01_Example_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/StartTrigger_Brs_X01_InputExample_V1.cs similarity index 66% rename from source/Example.Orchestrations/Processes/BRS_X01/Example/V1/StartTrigger_Brs_X01_Example_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/StartTrigger_Brs_X01_InputExample_V1.cs index 0fc0164c..0daa0976 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/Example/V1/StartTrigger_Brs_X01_Example_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/InputExample/V1/StartTrigger_Brs_X01_InputExample_V1.cs @@ -12,34 +12,34 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; using Microsoft.Azure.Functions.Worker; using FromBodyAttribute = Microsoft.Azure.Functions.Worker.Http.FromBodyAttribute; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1; -internal class StartTrigger_Brs_X01_Example_V1( - StartExampleHandlerV1 exampleHandler) +internal class StartTrigger_Brs_X01_InputExample_V1( + StartInputExampleHandlerV1 handler) { - private readonly StartExampleHandlerV1 _exampleHandler = exampleHandler; + private readonly StartInputExampleHandlerV1 _handler = handler; /// /// Start a BRS-X01 and return its id. /// - [Function(nameof(StartTrigger_Brs_X01_Example_V1))] + [Function(nameof(StartTrigger_Brs_X01_InputExample_V1))] public async Task Run( [HttpTrigger( AuthorizationLevel.Anonymous, "post", - Route = "orchestrationinstance/command/start/custom/Brs_X01_Example/1")] + Route = "orchestrationinstance/command/start/custom/Brs_X01_InputExample/1")] HttpRequest httpRequest, [FromBody] - StartExampleCommandV1 command, + StartInputExampleCommandV1 command, FunctionContext executionContext) { - var orchestrationInstanceId = await _exampleHandler.StartNewExampleAsync(command).ConfigureAwait(false); + var orchestrationInstanceId = await _handler.StartNewExampleAsync(command).ConfigureAwait(false); return new OkObjectResult(orchestrationInstanceId.Value); } } diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStartActivity_Brs_X01_NoInputExample_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStartActivity_Brs_X01_NoInputExample_V1.cs similarity index 93% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStartActivity_Brs_X01_NoInputExample_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStartActivity_Brs_X01_NoInputExample_V1.cs index 4b205c82..49f38cad 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStartActivity_Brs_X01_NoInputExample_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStartActivity_Brs_X01_NoInputExample_V1.cs @@ -17,7 +17,7 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; internal class FirstStepStartActivity_Brs_X01_NoInputExample_V1( IClock clock, diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStopActivity_Brs_X01_NoInputExample_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStopActivity_Brs_X01_NoInputExample_V1.cs similarity index 94% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStopActivity_Brs_X01_NoInputExample_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStopActivity_Brs_X01_NoInputExample_V1.cs index 6407cb6d..ae5286ea 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStopActivity_Brs_X01_NoInputExample_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/FirstStepStopActivity_Brs_X01_NoInputExample_V1.cs @@ -17,7 +17,7 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; internal class FirstStepStopActivity_Brs_X01_NoInputExample_V1( IClock clock, diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationInitializeActivity_Brs_X01_NoInputExample_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationInitializeActivity_Brs_X01_NoInputExample_V1.cs similarity index 91% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationInitializeActivity_Brs_X01_NoInputExample_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationInitializeActivity_Brs_X01_NoInputExample_V1.cs index dc0c1413..973f84df 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationInitializeActivity_Brs_X01_NoInputExample_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationInitializeActivity_Brs_X01_NoInputExample_V1.cs @@ -12,13 +12,13 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Model; using Energinet.DataHub.ProcessManagement.Core.Application.Orchestration; using Energinet.DataHub.ProcessManagement.Core.Domain.OrchestrationInstance; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Model; using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; internal class OrchestrationInitializeActivity_Brs_X01_NoInputExample_V1( IClock clock, diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationTerminateActivity_Brs_X01_NoInputExample_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationTerminateActivity_Brs_X01_NoInputExample_V1.cs similarity index 93% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationTerminateActivity_Brs_X01_NoInputExample_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationTerminateActivity_Brs_X01_NoInputExample_V1.cs index 5a848c64..c8185f36 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationTerminateActivity_Brs_X01_NoInputExample_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/OrchestrationTerminateActivity_Brs_X01_NoInputExample_V1.cs @@ -17,7 +17,7 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; internal class OrchestrationTerminateActivity_Brs_X01_NoInputExample_V1( IClock clock, diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/ProgressActivityBase.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/ProgressActivityBase.cs similarity index 89% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/ProgressActivityBase.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/ProgressActivityBase.cs index fea8f6be..342520e2 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/ProgressActivityBase.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/ProgressActivityBase.cs @@ -15,7 +15,7 @@ using Energinet.DataHub.ProcessManagement.Core.Application.Orchestration; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; internal abstract class ProgressActivityBase( IClock clock, diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStartActivity_Brs_X01_NoInputExample_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStartActivity_Brs_X01_NoInputExample_V1.cs similarity index 94% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStartActivity_Brs_X01_NoInputExample_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStartActivity_Brs_X01_NoInputExample_V1.cs index a2fd65d4..d3004cea 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStartActivity_Brs_X01_NoInputExample_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStartActivity_Brs_X01_NoInputExample_V1.cs @@ -17,7 +17,7 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; internal class SecondStepStartActivity_Brs_X01_NoInputExample_V1( IClock clock, diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStopActivity_Brs_X01_NoInputExample_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStopActivity_Brs_X01_NoInputExample_V1.cs similarity index 94% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStopActivity_Brs_X01_NoInputExample_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStopActivity_Brs_X01_NoInputExample_V1.cs index 7d3c1caf..f3d96248 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStopActivity_Brs_X01_NoInputExample_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Activities/SecondStepStopActivity_Brs_X01_NoInputExample_V1.cs @@ -17,7 +17,7 @@ using Microsoft.Azure.Functions.Worker; using NodaTime; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; internal class SecondStepStopActivity_Brs_X01_NoInputExample_V1( IClock clock, diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Model/OrchestrationExecutionPlan.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Model/OrchestrationExecutionPlan.cs similarity index 90% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Model/OrchestrationExecutionPlan.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Model/OrchestrationExecutionPlan.cs index b496e109..5e834571 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Model/OrchestrationExecutionPlan.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Model/OrchestrationExecutionPlan.cs @@ -12,7 +12,7 @@ // See the License for the specific language governing permissions and // limitations under the License. -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Model; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Model; /// /// The purpose of this record is to give the orchestration information about diff --git a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Orchestration_Brs_X01_NoInputExample_V1.cs b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Orchestration_Brs_X01_NoInputExample_V1.cs similarity index 91% rename from source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Orchestration_Brs_X01_NoInputExample_V1.cs rename to source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Orchestration_Brs_X01_NoInputExample_V1.cs index c460c1a8..e406eefc 100644 --- a/source/Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Orchestration_Brs_X01_NoInputExample_V1.cs +++ b/source/ProcessManager.Example.Orchestrations/Processes/BRS_X01/NoInputExample/V1/Orchestration_Brs_X01_NoInputExample_V1.cs @@ -12,13 +12,13 @@ // See the License for the specific language governing permissions and // limitations under the License. -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Model; using Energinet.DataHub.ProcessManagement.Core.Domain.OrchestrationInstance; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Activities; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1.Model; using Microsoft.Azure.Functions.Worker; using Microsoft.DurableTask; -namespace Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1; +namespace Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1; // TODO: Implement according to guidelines: https://energinet.atlassian.net/wiki/spaces/D3/pages/824803345/Durable+Functions+Development+Guidelines internal class Orchestration_Brs_X01_NoInputExample_V1 diff --git a/source/Example.Orchestrations/Program.cs b/source/ProcessManager.Example.Orchestrations/Program.cs similarity index 79% rename from source/Example.Orchestrations/Program.cs rename to source/ProcessManager.Example.Orchestrations/Program.cs index c7adfa55..675acecc 100644 --- a/source/Example.Orchestrations/Program.cs +++ b/source/ProcessManager.Example.Orchestrations/Program.cs @@ -15,15 +15,15 @@ using Energinet.DataHub.Core.App.Common.Extensions.DependencyInjection; using Energinet.DataHub.Core.App.FunctionApp.Extensions.Builder; using Energinet.DataHub.Core.App.FunctionApp.Extensions.DependencyInjection; -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.Example.V1.Model; -using Energinet.DataHub.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example; -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.Example.V1; -using Energinet.DataHub.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1; using Energinet.DataHub.ProcessManagement.Core.Domain.OrchestrationDescription; using Energinet.DataHub.ProcessManagement.Core.Infrastructure.Extensions.DependencyInjection; using Energinet.DataHub.ProcessManagement.Core.Infrastructure.Extensions.Startup; using Energinet.DataHub.ProcessManagement.Core.Infrastructure.Telemetry; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.InputExample.V1.Model; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Abstractions.Processes.BRS_X01.NoInputExample.V1.Model; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.InputExample.V1; +using Energinet.DataHub.ProcessManager.Example.Orchestrations.Processes.BRS_X01.NoInputExample.V1; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Hosting; @@ -46,8 +46,8 @@ }); // => Handlers - services.AddScoped(); - services.AddScoped(); + services.AddScoped(); + services.AddScoped(); }) .ConfigureLogging((hostingContext, logging) => { @@ -55,19 +55,19 @@ }) .Build(); -await host.SynchronizeWithOrchestrationRegisterAsync("Example.Orchestrations").ConfigureAwait(false); +await host.SynchronizeWithOrchestrationRegisterAsync("ProcessManager.Example.Orchestrations").ConfigureAwait(false); await host.RunAsync().ConfigureAwait(false); OrchestrationDescription CreateDescription_Brs_X01_Example_V1() { - var orchestrationDescriptionUniqueName = new Brs_X01_Example_V1(); + var orchestrationDescriptionUniqueName = new Brs_X01_InputExample_V1(); var description = new OrchestrationDescription( uniqueName: new OrchestrationDescriptionUniqueName( orchestrationDescriptionUniqueName.Name, orchestrationDescriptionUniqueName.Version), canBeScheduled: true, - functionName: nameof(Orchestration_Brs_X01_Example_V1)); + functionName: nameof(Orchestration_Brs_X01_InputExample_V1)); description.ParameterDefinition.SetFromType(); diff --git a/source/Example.Orchestrations/Properties/launchSettings.json b/source/ProcessManager.Example.Orchestrations/Properties/launchSettings.json similarity index 100% rename from source/Example.Orchestrations/Properties/launchSettings.json rename to source/ProcessManager.Example.Orchestrations/Properties/launchSettings.json diff --git a/source/Example.Orchestrations/host.json b/source/ProcessManager.Example.Orchestrations/host.json similarity index 100% rename from source/Example.Orchestrations/host.json rename to source/ProcessManager.Example.Orchestrations/host.json diff --git a/source/ProcessManager.Orchestrations.Abstractions/ProcessManager.Orchestrations.Abstractions.csproj b/source/ProcessManager.Orchestrations.Abstractions/ProcessManager.Orchestrations.Abstractions.csproj index fc487e3b..9ec1ef7d 100644 --- a/source/ProcessManager.Orchestrations.Abstractions/ProcessManager.Orchestrations.Abstractions.csproj +++ b/source/ProcessManager.Orchestrations.Abstractions/ProcessManager.Orchestrations.Abstractions.csproj @@ -7,7 +7,7 @@ Energinet.DataHub.ProcessManager.Orchestrations.Abstractions - 0.2.6$(VersionSuffix) + 0.2.7$(VersionSuffix) DH3 Process Manager Orchestrations Abstractions library Energinet-DataHub Energinet-DataHub diff --git a/source/ProcessManager.sln b/source/ProcessManager.sln index 184054c7..c4e6d04b 100644 --- a/source/ProcessManager.sln +++ b/source/ProcessManager.sln @@ -84,11 +84,11 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "7. Examples", "7. Examples" EndProject Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Tests", "Tests", "{1F5C05E6-047F-42A6-8D1F-A272D8EE8E2E}" EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Example.Orchestrations", "Example.Orchestrations\Example.Orchestrations.csproj", "{521163D1-3712-4DE6-A7BF-9425C9126350}" +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ProcessManager.Example.Orchestrations", "ProcessManager.Example.Orchestrations\ProcessManager.Example.Orchestrations.csproj", "{521163D1-3712-4DE6-A7BF-9425C9126350}" EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Example.Orchestrations.Abstrations", "Example.Orchestrations.Abstrations\Example.Orchestrations.Abstrations.csproj", "{13757251-5452-4F24-BF15-46997937AECD}" +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ProcessManager.Example.Orchestrations.Abstrations", "ProcessManager.Example.Orchestrations.Abstrations\ProcessManager.Example.Orchestrations.Abstrations.csproj", "{13757251-5452-4F24-BF15-46997937AECD}" EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Example.Orchestrations.Tests", "Example.Orchestrations.Tests\Example.Orchestrations.Tests.csproj", "{E394B655-B32A-416C-A3C9-BE6E475C60A8}" +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ProcessManager.Example.Orchestrations.Tests", "ProcessManager.Example.Orchestrations.Tests\ProcessManager.Example.Orchestrations.Tests.csproj", "{E394B655-B32A-416C-A3C9-BE6E475C60A8}" EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution