Skip to content

Commit

Permalink
refactor: or-2517 use formatters from domain project
Browse files Browse the repository at this point in the history
  • Loading branch information
koenmetsu authored and emalfroy committed Nov 12, 2024
1 parent 7dde17c commit 0c85213
Show file tree
Hide file tree
Showing 12 changed files with 46 additions and 53 deletions.
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
namespace AssociationRegistry.Admin.ProjectionHost.Projections.Detail;

using Constants;
using Events;
using Formats;
using Framework;
using Infrastructure.Extensions;
using JsonLdContext;
Expand All @@ -12,10 +12,10 @@ namespace AssociationRegistry.Admin.ProjectionHost.Projections.Detail;
using Vereniging;
using AdresFormatter = Formats.AdresFormatter;
using Contactgegeven = Schema.Detail.Contactgegeven;
using DateFormatter = Formats.DateFormatter;
using Doelgroep = Schema.Detail.Doelgroep;
using IEvent = Marten.Events.IEvent;
using Vertegenwoordiger = Schema.Detail.Vertegenwoordiger;
using WellknownFormats = Constants.WellknownFormats;

public class BeheerVerenigingDetailProjector
{
Expand All @@ -31,7 +31,8 @@ public static BeheerVerenigingDetailDocument Create(IEvent<FeitelijkeVerenigingW
Startdatum = feitelijkeVerenigingWerdGeregistreerd.Data.Startdatum?.ToString(WellknownFormats.DateOnly),
Doelgroep = BeheerVerenigingDetailMapper.MapDoelgroep(feitelijkeVerenigingWerdGeregistreerd.Data.Doelgroep,
feitelijkeVerenigingWerdGeregistreerd.Data.VCode),
DatumLaatsteAanpassing = DateFormatter.FormatAsBelgianDate(feitelijkeVerenigingWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip)),
DatumLaatsteAanpassing = feitelijkeVerenigingWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip)
.FormatAsBelgianDate(),
Status = VerenigingStatus.Actief,
IsUitgeschrevenUitPubliekeDatastroom = feitelijkeVerenigingWerdGeregistreerd.Data.IsUitgeschrevenUitPubliekeDatastroom,
Contactgegevens = feitelijkeVerenigingWerdGeregistreerd.Data.Contactgegevens
Expand Down Expand Up @@ -89,7 +90,7 @@ public static BeheerVerenigingDetailDocument Create(
Maximumleeftijd = AssociationRegistry.Vereniging.Doelgroep.StandaardMaximumleeftijd,
},
Rechtsvorm = verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Data.Rechtsvorm,
DatumLaatsteAanpassing = DateFormatter.FormatAsBelgianDate(verenigingMetRechtspersoonlijkheidWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip)),
DatumLaatsteAanpassing = verenigingMetRechtspersoonlijkheidWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip).FormatAsBelgianDate(),
Status = VerenigingStatus.Actief,
IsUitgeschrevenUitPubliekeDatastroom = false,
Contactgegevens = [],
Expand Down Expand Up @@ -325,7 +326,7 @@ public static void Apply(IEvent<LocatieWerdGewijzigd> locatieWerdGewijzigd, Behe
Naam = locatieWerdGewijzigd.Data.Locatie.Naam,
Adres = BeheerVerenigingDetailMapper.MapAdres(
locatieWerdGewijzigd.Data.Locatie.Adres, document.VCode, l.LocatieId),
Adresvoorstelling = AdresFormatter.ToAdresString(locatieWerdGewijzigd.Data.Locatie.Adres),
Adresvoorstelling = locatieWerdGewijzigd.Data.Locatie.Adres.ToAdresString(),
AdresId = BeheerVerenigingDetailMapper.MapAdresId(
locatieWerdGewijzigd.Data.Locatie.AdresId),
VerwijstNaar =
Expand Down Expand Up @@ -465,7 +466,7 @@ public static void Apply(

public static void UpdateMetadata(IEvent e, BeheerVerenigingDetailDocument document)
{
document.DatumLaatsteAanpassing = DateFormatter.FormatAsBelgianDate(e.GetHeaderInstant(MetadataHeaderNames.Tijdstip));
document.DatumLaatsteAanpassing = e.GetHeaderInstant(MetadataHeaderNames.Tijdstip).FormatAsBelgianDate();
document.Metadata = new Metadata(e.Sequence, e.Version);
}

Expand Down Expand Up @@ -533,7 +534,7 @@ public static void Apply(
Adres = BeheerVerenigingDetailMapper.MapAdres(
maatschappelijkeZetelWerdGewijzigdInKbo.Data.Locatie.Adres, document.VCode, l.LocatieId),
Adresvoorstelling =
AdresFormatter.ToAdresString(maatschappelijkeZetelWerdGewijzigdInKbo.Data.Locatie.Adres),
maatschappelijkeZetelWerdGewijzigdInKbo.Data.Locatie.Adres.ToAdresString(),
AdresId = BeheerVerenigingDetailMapper.MapAdresId(
maatschappelijkeZetelWerdGewijzigdInKbo.Data.Locatie.AdresId),
VerwijstNaar =
Expand Down Expand Up @@ -567,7 +568,7 @@ public static void Apply(
adresWerdOvergenomenUitAdressenregister.Data.Adres, document.VCode,
l.LocatieId),
Adresvoorstelling =
AdresFormatter.ToAdresString(adresWerdOvergenomenUitAdressenregister.Data.Adres),
adresWerdOvergenomenUitAdressenregister.Data.Adres.ToAdresString(),
AdresId = BeheerVerenigingDetailMapper.MapAdresId(
adresWerdOvergenomenUitAdressenregister.Data.AdresId),
VerwijstNaar = BeheerVerenigingDetailMapper.MapAdresVerwijzing(
Expand All @@ -590,7 +591,7 @@ public static void Apply(
adresWerdGewijzigdInAdressenregister.Data.Adres, document.VCode,
l.LocatieId),
Adresvoorstelling =
AdresFormatter.ToAdresString(adresWerdGewijzigdInAdressenregister.Data.Adres),
adresWerdGewijzigdInAdressenregister.Data.Adres.ToAdresString(),
AdresId = BeheerVerenigingDetailMapper.MapAdresId(
adresWerdGewijzigdInAdressenregister.Data.AdresId),
VerwijstNaar = BeheerVerenigingDetailMapper.MapAdresVerwijzing(
Expand Down
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
namespace AssociationRegistry.Admin.ProjectionHost.Projections.Historiek;

using Constants;
using Events;
using Formats;
using Framework;
using Infrastructure.Extensions;
using Marten.Events;
using Schema;
using Schema.Historiek;
using Schema.Historiek.EventData;
using Vereniging;
using DateFormatter = Formats.DateFormatter;
using IEvent = Marten.Events.IEvent;
using WellknownFormats = Constants.WellknownFormats;

public class BeheerVerenigingHistoriekProjector
{
Expand Down Expand Up @@ -267,7 +267,7 @@ public static void Apply(IEvent<LocatieWerdVerwijderd> locatieWerdVerwijderd, Be
private static void AddHistoriekEntry(IEvent @event, BeheerVerenigingHistoriekDocument document, string beschrijving)
{
var initiator = @event.GetHeaderString(MetadataHeaderNames.Initiator);
var tijdstip = DateFormatter.FormatAsZuluTime(@event.GetHeaderInstant(MetadataHeaderNames.Tijdstip));
var tijdstip = @event.GetHeaderInstant(MetadataHeaderNames.Tijdstip).FormatAsZuluTime();

document.Gebeurtenissen = document.Gebeurtenissen.Append(
new BeheerVerenigingHistoriekGebeurtenis(
Expand All @@ -282,7 +282,7 @@ private static void AddHistoriekEntry(IEvent @event, BeheerVerenigingHistoriekDo
private static void AddHistoriekEntry(IEvent @event, object data, BeheerVerenigingHistoriekDocument document, string beschrijving)
{
var initiator = @event.GetHeaderString(MetadataHeaderNames.Initiator);
var tijdstip = DateFormatter.FormatAsZuluTime(@event.GetHeaderInstant(MetadataHeaderNames.Tijdstip));
var tijdstip = @event.GetHeaderInstant(MetadataHeaderNames.Tijdstip).FormatAsZuluTime();

document.Gebeurtenissen = document.Gebeurtenissen.Append(
new BeheerVerenigingHistoriekGebeurtenis(
Expand Down
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
namespace AssociationRegistry.Admin.ProjectionHost.Projections.Search.Zoeken;

using Constants;
using Events;
using Formats;
using Infrastructure.Extensions;
using JsonLdContext;
using Schema;
using Schema.Constants;
using Schema.Search;
using Vereniging;
using AdresFormatter = Formats.AdresFormatter;
using DateFormatter = Formats.DateFormatter;
using Doelgroep = Schema.Search.Doelgroep;
using WellknownFormats = Constants.WellknownFormats;

public class BeheerZoekProjectionHandler
{
Expand Down Expand Up @@ -167,6 +167,7 @@ public async Task Handle(EventEnvelope<RoepnaamWerdGewijzigd> message)
public async Task Handle(EventEnvelope<KorteNaamWerdGewijzigd> message)
=> await _elasticRepository.UpdateAsync(
message.Data.VCode,

new VerenigingZoekDocument
{
KorteNaam = message.Data.KorteNaam,
Expand Down Expand Up @@ -322,7 +323,7 @@ private static VerenigingZoekDocument.Locatie Map(Registratiedata.Locatie locati
LocatieId = locatie.LocatieId,
Locatietype = locatie.Locatietype,
Naam = locatie.Naam,
Adresvoorstelling = AdresFormatter.ToAdresString(locatie.Adres),
Adresvoorstelling = locatie.Adres.ToAdresString(),
IsPrimair = locatie.IsPrimair,
Postcode = locatie.Adres?.Postcode ?? string.Empty,
Gemeente = locatie.Adres?.Gemeente ?? string.Empty,
Expand All @@ -335,8 +336,8 @@ private static VerenigingZoekDocument.Lidmaatschap Map(Registratiedata.Lidmaatsc

LidmaatschapId = lidmaatschap.LidmaatschapId,
AndereVereniging = lidmaatschap.AndereVereniging,
DatumVan = DateFormatter.FormatAsBelgianDate(lidmaatschap.DatumVan),
DatumTot = DateFormatter.FormatAsBelgianDate(lidmaatschap.DatumTot),
DatumVan = lidmaatschap.DatumVan.FormatAsBelgianDate(),
DatumTot = lidmaatschap.DatumTot.FormatAsBelgianDate(),
Beschrijving = lidmaatschap.Beschrijving,
Identificatie = lidmaatschap.Identificatie,
};
Expand All @@ -351,7 +352,7 @@ private static VerenigingZoekDocument.Locatie Map(
LocatieId = locatie.LocatieId,
Locatietype = locatie.Locatietype,
Naam = locatie.Naam,
Adresvoorstelling = AdresFormatter.ToAdresString(adresUitAdressenregister),
Adresvoorstelling = adresUitAdressenregister.ToAdresString(),
IsPrimair = locatie.IsPrimair,
Postcode = adresUitAdressenregister.Postcode ?? string.Empty,
Gemeente = adresUitAdressenregister.Gemeente ?? string.Empty,
Expand Down Expand Up @@ -467,7 +468,7 @@ public async Task Handle(EventEnvelope<AdresWerdOvergenomenUitAdressenregister>
await _elasticRepository.UpdateAdres<VerenigingZoekDocument>(
message.VCode,
message.Data.LocatieId,
AdresFormatter.ToAdresString(message.Data.Adres),
message.Data.Adres.ToAdresString(),
message.Data.Adres.Postcode,
message.Data.Adres.Gemeente);
}
Expand All @@ -477,7 +478,7 @@ public async Task Handle(EventEnvelope<AdresWerdGewijzigdInAdressenregister> mes
await _elasticRepository.UpdateAdres<VerenigingZoekDocument>(
message.VCode,
message.Data.LocatieId,
AdresFormatter.ToAdresString(message.Data.Adres),
message.Data.Adres.ToAdresString(),
message.Data.Adres.Postcode,
message.Data.Adres.Gemeente);
}
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
namespace AssociationRegistry.Public.ProjectionHost.Projections.Detail;

using Events;
using Formats;
using Framework;
using Infrastructure.Extensions;
using JsonLdContext;
Expand Down Expand Up @@ -32,7 +33,7 @@ public static PubliekVerenigingDetailDocument Create(
Startdatum = feitelijkeVerenigingWerdGeregistreerd.Data.Startdatum,
Doelgroep =
MapDoelgroep(feitelijkeVerenigingWerdGeregistreerd.Data.Doelgroep, feitelijkeVerenigingWerdGeregistreerd.Data.VCode),
DatumLaatsteAanpassing = feitelijkeVerenigingWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip).ToBelgianDate(),
DatumLaatsteAanpassing = feitelijkeVerenigingWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip).FormatAsBelgianDate(),
Status = VerenigingStatus.Actief,
Contactgegevens = feitelijkeVerenigingWerdGeregistreerd.Data.Contactgegevens.Select(
c => new PubliekVerenigingDetailDocument.Contactgegeven
Expand Down Expand Up @@ -110,7 +111,7 @@ public static PubliekVerenigingDetailDocument Create(
},
Rechtsvorm = verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Data.Rechtsvorm,
DatumLaatsteAanpassing = verenigingMetRechtspersoonlijkheidWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip)
.ToBelgianDate(),
.FormatAsBelgianDate(),
IsUitgeschrevenUitPubliekeDatastroom = false,
Status = VerenigingStatus.Actief,
Contactgegevens = [],
Expand Down Expand Up @@ -446,7 +447,7 @@ public static void Apply(IEvent<VerenigingWerdGestoptInKBO> verenigingWerdGestop

public static void UpdateMetadata(IEvent @event, PubliekVerenigingDetailDocument document)
{
document.DatumLaatsteAanpassing = @event.GetHeaderInstant(MetadataHeaderNames.Tijdstip).ToBelgianDate();
document.DatumLaatsteAanpassing = @event.GetHeaderInstant(MetadataHeaderNames.Tijdstip).FormatAsBelgianDate();
}

public static void Apply(IEvent<NaamWerdGewijzigdInKbo> naamWerdGewijzigdInKbo, PubliekVerenigingDetailDocument document)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -463,8 +463,8 @@ private static VerenigingZoekDocument.Lidmaatschap Map(Registratiedata.Lidmaatsc

LidmaatschapId = lidmaatschap.LidmaatschapId,
AndereVereniging = lidmaatschap.AndereVereniging,
DatumVan = lidmaatschap.DatumVan.ToBelgianDate(),
DatumTot = lidmaatschap.DatumTot.ToBelgianDate(),
DatumVan = lidmaatschap.DatumVan.FormatAsBelgianDate(),
DatumTot = lidmaatschap.DatumTot.FormatAsBelgianDate(),
Beschrijving = lidmaatschap.Beschrijving,
Identificatie = lidmaatschap.Identificatie,
};
Expand Down
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
namespace AssociationRegistry.Test.Admin.Api.Projections.V1.When_Retrieving_Historiek.Projector;

using AssociationRegistry.Admin.ProjectionHost.Constants;
using AssociationRegistry.Admin.ProjectionHost.Infrastructure.Extensions;
using AssociationRegistry.Admin.ProjectionHost.Projections.Historiek;
using AssociationRegistry.Admin.Schema.Historiek;
using AssociationRegistry.Events;
using AssociationRegistry.Test.Admin.Api.Framework;
using AutoFixture;
using FluentAssertions;
using Formats;
using Xunit;
using Xunit.Categories;
using DateFormatter = Formats.DateFormatter;
using WellknownFormats = AssociationRegistry.Admin.ProjectionHost.Constants.WellknownFormats;

[UnitTest]
public class Given_EinddatumWerdGewijzigd
Expand All @@ -31,6 +31,6 @@ public void Then_it_adds_a_new_gebeurtenis()
nameof(EinddatumWerdGewijzigd),
verenigingWerdGestopt.Data,
verenigingWerdGestopt.Initiator,
DateFormatter.FormatAsZuluTime(verenigingWerdGestopt.Tijdstip)));
verenigingWerdGestopt.Tijdstip.FormatAsZuluTime()));
}
}
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
namespace AssociationRegistry.Test.Admin.Api.Projections.V1.When_Retrieving_Historiek.Projector;

using AssociationRegistry.Admin.ProjectionHost.Constants;
using AssociationRegistry.Admin.ProjectionHost.Infrastructure.Extensions;
using AssociationRegistry.Admin.ProjectionHost.Projections.Historiek;
using AssociationRegistry.Admin.Schema.Historiek;
using AssociationRegistry.Events;
using AssociationRegistry.Test.Admin.Api.Framework;
using AutoFixture;
using FluentAssertions;
using Formats;
using Xunit;
using Xunit.Categories;
using DateFormatter = Formats.DateFormatter;
using WellknownFormats = AssociationRegistry.Admin.ProjectionHost.Constants.WellknownFormats;

[UnitTest]
public class Given_VerenigingWerdGestopt
Expand All @@ -31,7 +31,7 @@ public void Then_it_adds_a_new_gebeurtenis()
nameof(VerenigingWerdGestopt),
verenigingWerdGestopt.Data,
verenigingWerdGestopt.Initiator,
DateFormatter.FormatAsZuluTime(verenigingWerdGestopt.Tijdstip)));
verenigingWerdGestopt.Tijdstip.FormatAsZuluTime()));
}
}

Expand All @@ -54,6 +54,6 @@ public void Then_it_adds_a_new_gebeurtenis()
nameof(VerenigingWerdGestoptInKBO),
verenigingWerdGestopt.Data,
verenigingWerdGestopt.Initiator,
DateFormatter.FormatAsZuluTime(verenigingWerdGestopt.Tijdstip)));
verenigingWerdGestopt.Tijdstip.FormatAsZuluTime()));
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
using Framework.ApiSetup;
using Framework.TestClasses;
using FluentAssertions;
using Formats;
using Newtonsoft.Json.Linq;
using NodaTime.Extensions;
using Xunit;
Expand All @@ -31,7 +32,7 @@ public void WithVereniging()
{
VCode = TestContext.VCode,
TeVerwijderen = true,
DeletedAt = DateTime.UtcNow.Date.ToInstant().ToBelgianDate(),
DeletedAt = DateTime.UtcNow.Date.ToInstant().FormatAsBelgianDate(),
},
});
}
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
namespace AssociationRegistry.Test.E2E.When_Voeg_Lidmaatschap_Toe.Publiek.Detail;

using Formats;
using Framework.AlbaHost;
using KellermanSoftware.CompareNetObjects;
using Public.Api.Verenigingen.Detail.ResponseModels;
Expand Down Expand Up @@ -29,8 +30,8 @@ public void JsonContentMatches()
LidmaatschapId = 1,
AndereVereniging = _context.Request.AndereVereniging,
Beschrijving = _context.Request.Beschrijving,
Van = _context.Request.Van.ToBelgianDate(),
Tot = _context.Request.Tot.ToBelgianDate(),
Van = _context.Request.Van.FormatAsBelgianDate(),
Tot = _context.Request.Tot.FormatAsBelgianDate(),
Identificatie = _context.Request.Identificatie,
Naam = _context.Scenario.AndereFeitelijkeVerenigingWerdGeregistreerd.Naam,
};
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
using AutoFixture;
using Events;
using FluentAssertions;
using Formats;
using Framework;
using JsonLdContext;
using Vereniging;
Expand Down Expand Up @@ -55,7 +56,7 @@ public void Then_it_creates_a_new_vereniging()
},
Rechtsvorm = verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Data.Rechtsvorm,
DatumLaatsteAanpassing = verenigingMetRechtspersoonlijkheidWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip)
.ToBelgianDate(),
.FormatAsBelgianDate(),
Status = VerenigingStatus.Actief,
IsUitgeschrevenUitPubliekeDatastroom = false,
Contactgegevens = Array.Empty<PubliekVerenigingDetailDocument.Contactgegeven>(),
Expand Down
Loading

0 comments on commit 0c85213

Please sign in to comment.