Skip to content

Commit

Permalink
fix: event timestamp
Browse files Browse the repository at this point in the history
  • Loading branch information
ArneD committed Dec 20, 2023
1 parent 1db60d1 commit 167f0d7
Show file tree
Hide file tree
Showing 33 changed files with 49 additions and 30 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ namespace BuildingRegistry.Api.BackOffice.Handlers.Lambda.Requests.Building
{
using Be.Vlaanderen.Basisregisters.GrAr.Provenance;
using Be.Vlaanderen.Basisregisters.Sqs.Lambda.Requests;
using NodaTime;

public abstract record BuildingLambdaRequest : SqsLambdaRequest
{
Expand All @@ -13,5 +14,13 @@ protected BuildingLambdaRequest(
IDictionary<string, object?> metadata)
: base(messageGroupId, ticketId, ifMatchHeaderValue, provenance, metadata)
{ }

protected Provenance CommandProvenance => new Provenance(
SystemClock.Instance.GetCurrentInstant(),
Provenance.Application,
Provenance.Reason,
Provenance.Operator,
Provenance.Modification,
Provenance.Organisation);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ public ChangeBuildingMeasurement ToCommand()
new BuildingPersistentLocalId(BuildingPersistentLocalId),
Request.GrbData.GeometriePolygoon.ToExtendedWkbGeometry(),
Request.GrbData.ToBuildingGrbData(),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public ChangeBuildingOutline ToCommand()
return new ChangeBuildingOutline(
new BuildingPersistentLocalId(BuildingPersistentLocalId),
Request.GeometriePolygoon.ToExtendedWkbGeometry(),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ public CorrectBuildingMeasurement ToCommand()
new BuildingPersistentLocalId(BuildingPersistentLocalId),
Request.GrbData.GeometriePolygoon.ToExtendedWkbGeometry(),
Request.GrbData.ToBuildingGrbData(),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ public CorrectBuildingNotRealizationLambdaRequest(
/// <returns>CorrectBuildingNotRealization.</returns>
public CorrectBuildingNotRealization ToCommand()
{
return new CorrectBuildingNotRealization(new BuildingPersistentLocalId(BuildingPersistentLocalId), Provenance);
return new CorrectBuildingNotRealization(new BuildingPersistentLocalId(BuildingPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ public CorrectBuildingRealizationLambdaRequest(
/// <returns>CorrectBuildingRealization.</returns>
public CorrectBuildingRealization ToCommand()
{
return new CorrectBuildingRealization(new BuildingPersistentLocalId(BuildingPersistentLocalId), Provenance);
return new CorrectBuildingRealization(new BuildingPersistentLocalId(BuildingPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ public CorrectPlaceBuildingUnderConstructionLambdaRequest(
/// <returns>CorrectBuildingPlaceUnderConstruction.</returns>
public CorrectBuildingPlaceUnderConstruction ToCommand()
{
return new CorrectBuildingPlaceUnderConstruction(new BuildingPersistentLocalId(BuildingPersistentLocalId), Provenance);
return new CorrectBuildingPlaceUnderConstruction(new BuildingPersistentLocalId(BuildingPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ public DemolishBuilding ToCommand()
{
return new DemolishBuilding(new BuildingPersistentLocalId(BuildingPersistentLocalId),
Request.GrbData.ToBuildingGrbData(),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ public MeasureBuilding ToCommand()
new BuildingPersistentLocalId(BuildingPersistentLocalId),
Request.GrbData.GeometriePolygoon.ToExtendedWkbGeometry(),
Request.GrbData.ToBuildingGrbData(),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ public MergeBuildings ToCommand()
Request.GeometriePolygoon.ToExtendedWkbGeometry(),
Request.SamenvoegenGebouwen
.Select(x => new BuildingPersistentLocalId(Convert.ToInt32(x.AsIdentifier().Map(s => s).Value))),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ public NotRealizeBuildingLambdaRequest(string messageGroupId, NotRealizeBuilding
/// <returns>NotRealizeBuilding.</returns>
public NotRealizeBuilding ToCommand()
{
return new NotRealizeBuilding(new BuildingPersistentLocalId(BuildingPersistentLocalId), Provenance);
return new NotRealizeBuilding(new BuildingPersistentLocalId(BuildingPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ public PlaceBuildingUnderConstructionLambdaRequest(
/// <returns>PlaceBuildingUnderConstruction.</returns>
public PlaceBuildingUnderConstruction ToCommand()
{
return new PlaceBuildingUnderConstruction(new BuildingPersistentLocalId(BuildingPersistentLocalId), Provenance);
return new PlaceBuildingUnderConstruction(new BuildingPersistentLocalId(BuildingPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public PlanBuilding ToCommand()
return new PlanBuilding(
BuildingPersistentLocalId,
Request.GeometriePolygoon.ToExtendedWkbGeometry(),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ public RealizeAndMeasureUnplannedBuilding ToCommand()
new BuildingPersistentLocalId(BuildingPersistentLocalId),
Request.GrbData.GeometriePolygoon.ToExtendedWkbGeometry(),
Request.GrbData.ToBuildingGrbData(),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ public RealizeBuildingLambdaRequest(
/// <returns>RealizeBuilding.</returns>
public RealizeBuilding ToCommand()
{
return new RealizeBuilding(new BuildingPersistentLocalId(BuildingPersistentLocalId), Provenance);
return new RealizeBuilding(new BuildingPersistentLocalId(BuildingPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ public RemoveBuildingLambdaRequest(string messageGroupId, RemoveBuildingSqsReque
/// <returns>RemoveBuilding.</returns>
public RemoveBuilding ToCommand()
{
return new RemoveBuilding(new BuildingPersistentLocalId(BuildingPersistentLocalId), Provenance);
return new RemoveBuilding(new BuildingPersistentLocalId(BuildingPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ public AttachAddressToBuildingUnit ToCommand()
BuildingPersistentLocalId,
new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId),
new AddressPersistentLocalId(addressPersistentLocalId),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ namespace BuildingRegistry.Api.BackOffice.Handlers.Lambda.Requests.BuildingUnit
using Be.Vlaanderen.Basisregisters.GrAr.Provenance;
using Be.Vlaanderen.Basisregisters.Sqs.Lambda.Requests;
using BuildingRegistry.Building;
using NodaTime;

public abstract record BuildingUnitLambdaRequest : SqsLambdaRequest
{
Expand All @@ -17,5 +18,13 @@ protected BuildingUnitLambdaRequest(
IDictionary<string, object?> metadata)
: base(messageGroupId, ticketId, ifMatchHeaderValue, provenance, metadata)
{ }

protected Provenance CommandProvenance => new Provenance(
SystemClock.Instance.GetCurrentInstant(),
Provenance.Application,
Provenance.Reason,
Provenance.Operator,
Provenance.Modification,
Provenance.Organisation);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ public CorrectBuildingUnitDeregulation ToCommand()
return new CorrectBuildingUnitDeregulation(
BuildingPersistentLocalId,
new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ public CorrectBuildingUnitNotRealization ToCommand()
return new CorrectBuildingUnitNotRealization(
BuildingPersistentLocalId,
new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ public CorrectBuildingUnitPosition ToCommand()
new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId),
Request.PositieGeometrieMethode.Map(),
string.IsNullOrWhiteSpace(Request.Positie) ? null : Request.Positie.ToExtendedWkbGeometry(),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public CorrectBuildingUnitRealizationLambdaRequest(
/// <returns>CorrectBuildingUnitRealization.</returns>
public CorrectBuildingUnitRealization ToCommand()
{
return new CorrectBuildingUnitRealization(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), Provenance);
return new CorrectBuildingUnitRealization(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ public CorrectBuildingUnitRegularizationLambdaRequest(
/// <returns>CorrectBuildingUnitRealization.</returns>
public CorrectBuildingUnitRegularization ToCommand()
{
return new CorrectBuildingUnitRegularization(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), Provenance);
return new CorrectBuildingUnitRegularization(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public CorrectBuildingUnitRetirementLambdaRequest(
/// <returns>CorrectBuildingUnitRetirement.</returns>
public CorrectBuildingUnitRetirement ToCommand()
{
return new CorrectBuildingUnitRetirement(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), Provenance);
return new CorrectBuildingUnitRetirement(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public DeregulateBuildingUnitLambdaRequest(
/// <returns>DeregulateBuildingUnit.</returns>
public DeregulateBuildingUnit ToCommand()
{
return new DeregulateBuildingUnit(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), Provenance);
return new DeregulateBuildingUnit(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ public DetachAddressFromBuildingUnit ToCommand()
BuildingPersistentLocalId,
new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId),
new AddressPersistentLocalId(addressPersistentLocalId),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ public NotRealizeBuildingUnit ToCommand()
return new NotRealizeBuildingUnit(
BuildingPersistentLocalId,
new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ public PlanBuildingUnit ToCommand()
string.IsNullOrWhiteSpace(Request.Positie) ? null : Request.Positie.ToExtendedWkbGeometry(),
Request.Functie.Map(),
Request.AfwijkingVastgesteld,
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public RealizeBuildingUnitLambdaRequest(
/// <returns>RealizeBuildingUnit.</returns>
public RealizeBuildingUnit ToCommand()
{
return new RealizeBuildingUnit(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), Provenance);
return new RealizeBuildingUnit(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ public RegularizeBuildingUnit ToCommand()
return new RegularizeBuildingUnit(
BuildingPersistentLocalId,
new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ public RemoveBuildingUnit ToCommand()
return new RemoveBuildingUnit(
BuildingPersistentLocalId,
new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId),
Provenance);
CommandProvenance);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public RetireBuildingUnitLambdaRequest(
/// <returns>RetireBuildingUnit.</returns>
public RetireBuildingUnit ToCommand()
{
return new RetireBuildingUnit(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), Provenance);
return new RetireBuildingUnit(BuildingPersistentLocalId, new BuildingUnitPersistentLocalId(BuildingUnitPersistentLocalId), CommandProvenance);
}
}
}
1 change: 1 addition & 0 deletions src/BuildingRegistry/Building/ProvenanceFactory.cs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ namespace BuildingRegistry.Building
using System;
using Be.Vlaanderen.Basisregisters.AggregateSource;
using Be.Vlaanderen.Basisregisters.GrAr.Provenance;
using NodaTime;

public class ProvenanceFactory<TAggregateRoot> : IProvenanceFactory<TAggregateRoot>
where TAggregateRoot : IAggregateRootEntity
Expand Down

0 comments on commit 167f0d7

Please sign in to comment.