Skip to content

Commit

Permalink
renamed
Browse files Browse the repository at this point in the history
  • Loading branch information
MadsDue committed Dec 9, 2024
1 parent 1986f4f commit 78d17a5
Show file tree
Hide file tree
Showing 8 changed files with 26 additions and 25 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

## Version 0.2.0

- Implemented `Brs_021_MeteredDataForwarding_V1`
- Implemented `StartMeteredDataForwardingCommandV1`
- Implemented `Brs_021_ForwardMeteredData_V1`
- Implemented `StartForwardMeteredDataCommandV1`

## Version 0.1.0

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@

using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationDescription;

namespace Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.MeteredDataForwarding.V1.Model;
namespace Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.ForwardMeteredData.V1.Model;

public record Brs_021_MeteredDataForwarding_V1()
: OrchestrationDescriptionUniqueNameDto("BRS_021_MeteredDataForwarding", 1);
public record Brs_021_ForwardedMeteredData_V1()
: OrchestrationDescriptionUniqueNameDto("BRS_021_ForwardMeteredData", 1);
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
// See the License for the specific language governing permissions and
// limitations under the License.

namespace Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.MeteredDataForwarding.V1.Model;
namespace Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.ForwardMeteredData.V1.Model;

public record EnergyObservation(
string? Position,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,12 +14,13 @@

using Energinet.DataHub.ProcessManager.Abstractions.Api.Model;

namespace Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.MeteredDataForwarding.V1.Model;
namespace Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.ForwardMeteredData.V1.Model;

/// <summary>
/// An immutable input to start the orchestration instance for "BRS_021_MeteredDataForwarding" V1.
/// An immutable input to start the orchestration instance for "BRS_021_ForwardMeteredData" V1.
/// </summary>
public record MeteredDataForMeasurementPointMessageInputV1(
Guid AuthenticatedActorId,
string TransactionId,
string? MeteringPointId,
string? MeteringPointType,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,26 +15,26 @@
using Energinet.DataHub.ProcessManager.Abstractions.Api.Model;
using Energinet.DataHub.ProcessManager.Abstractions.Api.Model.OrchestrationInstance;

namespace Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.MeteredDataForwarding.V1.Model;
namespace Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.ForwardMeteredData.V1.Model;

/// <summary>
/// Command for starting a BRS-021-MeteredDataForwarding.
/// Command for starting a BRS-021-ForwardMeteredData.
/// Must be JSON serializable.
/// </summary>
public record StartMeteredDataForwardingCommandV1
public record StartForwardMeteredDataCommandV1
: StartOrchestrationInstanceCommand<ActorIdentityDto, MeteredDataForMeasurementPointMessageInputV1>
{
/// <summary>
/// Construct command.
/// </summary>
/// <param name="operatingIdentity">Identity of the user executing the command.</param>
/// <param name="inputParameter">Contains the Durable Functions orchestration input parameter value.</param>
public StartMeteredDataForwardingCommandV1(
public StartForwardMeteredDataCommandV1(
ActorIdentityDto operatingIdentity,
MeteredDataForMeasurementPointMessageInputV1 inputParameter)
: base(
operatingIdentity,
orchestrationDescriptionUniqueName: new Brs_021_MeteredDataForwarding_V1(),
orchestrationDescriptionUniqueName: new Brs_021_ForwardedMeteredData_V1(),
inputParameter)
{
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
</ItemGroup>
<ItemGroup>
<Folder Include="Api\Mappers\" />
<Folder Include="Processes\BRS_021\MeteredDataForwarding\" />
<Folder Include="Processes\BRS_021\ForwardMeteredData\" />
<Folder Include="Processes\BRS_026\V1\Activities\" />
</ItemGroup>
<ItemGroup>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,14 @@
// limitations under the License.

using Energinet.DataHub.ProcessManagement.Core.Infrastructure.Extensions.DurableTask;
using Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.MeteredDataForwarding.V1.Model;
using Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.ForwardMeteredData.V1.Model;
using Energinet.DataHub.ProcessManager.Orchestrations.Processes.BRS_021.ElectricalHeatingCalculation.V1;
using Microsoft.Azure.Functions.Worker;
using Microsoft.DurableTask;

namespace Energinet.DataHub.ProcessManager.Orchestrations.Processes.BRS_021.MeteredDataForwarding.V1;
namespace Energinet.DataHub.ProcessManager.Orchestrations.Processes.BRS_021.ForwardMeteredData.V1;

internal class Orchestration_Brs_021_MeteredDataForwarding_V1
internal class Orchestration_Brs_021_ForwardMeteredData_V1
{
internal static StepIdentifierDto[] Steps =>
[
Expand All @@ -35,7 +35,7 @@ internal class Orchestration_Brs_021_MeteredDataForwarding_V1

internal static StepIdentifierDto EnqueueMessagesStep => new(3, "Sætter beskeder i kø");

[Function(nameof(Orchestration_Brs_021_MeteredDataForwarding_V1))]
[Function(nameof(Orchestration_Brs_021_ForwardMeteredData_V1))]
public async Task<string> Run(
[OrchestrationTrigger] TaskOrchestrationContext context)
{
Expand Down
14 changes: 7 additions & 7 deletions source/ProcessManager.Orchestrations/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -20,12 +20,12 @@
using Energinet.DataHub.ProcessManagement.Core.Infrastructure.Extensions.Startup;
using Energinet.DataHub.ProcessManagement.Core.Infrastructure.Telemetry;
using Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.ElectricalHeatingCalculation.V1.Model;
using Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.MeteredDataForwarding.V1.Model;
using Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_021.ForwardMeteredData.V1.Model;
using Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_023_027.V1.Model;
using Energinet.DataHub.ProcessManager.Orchestrations.Abstractions.Processes.BRS_026.V1.Model;
using Energinet.DataHub.ProcessManager.Orchestrations.Extensions.DependencyInjection;
using Energinet.DataHub.ProcessManager.Orchestrations.Processes.BRS_021.ElectricalHeatingCalculation.V1;
using Energinet.DataHub.ProcessManager.Orchestrations.Processes.BRS_021.MeteredDataForwarding.V1;
using Energinet.DataHub.ProcessManager.Orchestrations.Processes.BRS_021.ForwardMeteredData.V1;
using Energinet.DataHub.ProcessManager.Orchestrations.Processes.BRS_023_027.V1;
using Energinet.DataHub.ProcessManager.Orchestrations.Processes.BRS_026.V1;
using Microsoft.Extensions.DependencyInjection;
Expand All @@ -52,11 +52,11 @@
var brs_021_ElectricalHeatingCalculation_v1 = CreateDescription_Brs_021_ElectricalHeatingCalculation_V1();
var brs_023_027_v1 = CreateBrs_023_027_V1Description();
var brs_026_v1 = CreateBrs_026_V1Description();
var brs_021_MeteredDataForwarding_v1 = CreateBrs_021_MeteredDataForwarding_V1Description();
var brs_021_ForwardMeteredData_v1 = CreateBrs_021_ForwardMeteredData_V1Description();

return [
brs_021_ElectricalHeatingCalculation_v1,
brs_021_MeteredDataForwarding_v1,
brs_021_ForwardMeteredData_v1,
brs_023_027_v1,
brs_026_v1];
});
Expand Down Expand Up @@ -134,16 +134,16 @@ OrchestrationDescription CreateBrs_026_V1Description()
return description;
}

OrchestrationDescription CreateBrs_021_MeteredDataForwarding_V1Description()
OrchestrationDescription CreateBrs_021_ForwardMeteredData_V1Description()
{
var orchestrationDescriptionUniqueName = new Brs_021_MeteredDataForwarding_V1();
var orchestrationDescriptionUniqueName = new Brs_021_ForwardedMeteredData_V1();

var description = new OrchestrationDescription(
uniqueName: new OrchestrationDescriptionUniqueName(
orchestrationDescriptionUniqueName.Name,
orchestrationDescriptionUniqueName.Version),
canBeScheduled: false,
functionName: nameof(Orchestration_Brs_021_MeteredDataForwarding_V1));
functionName: nameof(Orchestration_Brs_021_ForwardMeteredData_V1));

description.ParameterDefinition.SetFromType<MeteredDataForMeasurementPointMessageInputV1>();

Expand Down

0 comments on commit 78d17a5

Please sign in to comment.