Skip to content

Commit

Permalink
feat: or-2334 implement markeer als dubbel in acm
Browse files Browse the repository at this point in the history
  • Loading branch information
emalfroy committed Dec 18, 2024
1 parent 7bea5f9 commit 12b1e79
Show file tree
Hide file tree
Showing 3 changed files with 40 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -106,6 +106,15 @@ public async Task Project(IEvent<VerenigingWerdVerwijderd> verenigingWerdVerwijd
ops.StoreObjects(docs);
}

public async Task Project(IEvent<VerenigingWerdGemarkeerdAlsDubbelVan> verenigingWerdGemarkeerdAlsDubbelVan, IDocumentOperations ops)
{
var docs = new List<object>();

docs.AddRange(await VerenigingenPerInszProjector.Apply(verenigingWerdGemarkeerdAlsDubbelVan, ops));

ops.StoreObjects(docs);
}

public async Task Project(IEvent<VerenigingAanvaarddeDubbeleVereniging> verenigingAanvaarddeDubbeleVereniging, IDocumentOperations ops)
{
var docs = new List<object>();
Expand Down Expand Up @@ -265,7 +274,7 @@ public static async Task<List<VerenigingenPerInszDocument>> Apply(
{
verenigingenPerInszDocument.Verenigingen = verenigingenPerInszDocument.Verenigingen
.Where(v => v.VCode !=
verenigingWerdVerwijderd.StreamKey)
verenigingWerdVerwijderd.StreamKey)
.ToList();

docs.Add(verenigingenPerInszDocument);
Expand All @@ -283,7 +292,8 @@ public static async Task<List<VerenigingenPerInszDocument>> Apply(

foreach (var verenigingenPerInszDocument in documents)
{
verenigingenPerInszDocument.Verenigingen.Single(vereniging => vereniging.VCode == rechtsvormWerdGewijzigdInKbo.StreamKey!).Verenigingstype =
verenigingenPerInszDocument.Verenigingen.Single(vereniging => vereniging.VCode == rechtsvormWerdGewijzigdInKbo.StreamKey!)
.Verenigingstype =
MapVereniging(AssociationRegistry.Vereniging.Verenigingstype.Parse(rechtsvormWerdGewijzigdInKbo.Data.Rechtsvorm));

docs.Add(verenigingenPerInszDocument);
Expand All @@ -301,7 +311,9 @@ public static async Task<List<VerenigingenPerInszDocument>> Apply(

foreach (var verenigingenPerInszDocument in documents)
{
var vereniging = verenigingenPerInszDocument.Verenigingen.Single(vereniging => vereniging.VCode == verenigingAanvaarddeDubbeleVereniging.StreamKey!);
var vereniging =
verenigingenPerInszDocument.Verenigingen.Single(
vereniging => vereniging.VCode == verenigingAanvaarddeDubbeleVereniging.StreamKey!);

vereniging.CorresponderendeVCodes =
vereniging.CorresponderendeVCodes
Expand All @@ -313,6 +325,27 @@ public static async Task<List<VerenigingenPerInszDocument>> Apply(

return docs;
}

public static async Task<List<VerenigingenPerInszDocument>> Apply(
IEvent<VerenigingWerdGemarkeerdAlsDubbelVan> verenigingWerdGemarkeerdAlsDubbelVan,
IDocumentOperations ops)
{
var docs = new List<VerenigingenPerInszDocument>();
var documents = await ops.GetVerenigingenPerInszDocuments(verenigingWerdGemarkeerdAlsDubbelVan.Data.VCode);

foreach (var verenigingenPerInszDocument in documents)
{
var vereniging =
verenigingenPerInszDocument.Verenigingen.Single(
vereniging => vereniging.VCode == verenigingWerdGemarkeerdAlsDubbelVan.StreamKey!);

vereniging.IsDubbel = true;

docs.Add(verenigingenPerInszDocument);
}

return docs;
}
}

private static class VerenigingDocumentProjector
Expand Down Expand Up @@ -343,7 +376,8 @@ public static async Task<VerenigingDocument> Apply(
{
var verenigingDocument = await ops.GetVerenigingDocument(rechtsvormWerdGewijzigdInKbo.StreamKey);

verenigingDocument.VerenigingsType = MapVereniging(AssociationRegistry.Vereniging.Verenigingstype.Parse(rechtsvormWerdGewijzigdInKbo.Data.Rechtsvorm));
verenigingDocument.VerenigingsType =
MapVereniging(AssociationRegistry.Vereniging.Verenigingstype.Parse(rechtsvormWerdGewijzigdInKbo.Data.Rechtsvorm));

return verenigingDocument;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ public static VerenigingenPerInszResponse ToResponse(VerenigingenPerInszDocument
=> new()
{
Insz = doc.Insz,
Verenigingen = doc.Verenigingen.Select(Map).ToArray(),
Verenigingen = doc.Verenigingen.Where(x => !x.IsDubbel).Select(Map).ToArray(),
KboNummers = verenigingenPerKbo.Select(Map).ToArray(),
};

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ public void With_Verenigingen()
// Authentieke vereniging wordt getoond met corresponderende verenigingen
new VerenigingenPerInszResponse.Vereniging()
{
VCode = TestContext.VCode,
VCode = TestContext.Scenario.AndereFeitelijkeVerenigingWerdGeregistreerd.VCode,
CorresponderendeVCodes = [TestContext.Scenario.FeitelijkeVerenigingWerdGeregistreerd.VCode],
VertegenwoordigerId = TestContext.Scenario.AndereFeitelijkeVerenigingWerdGeregistreerd.Vertegenwoordigers[0].VertegenwoordigerId,
Naam = TestContext.Scenario.AndereFeitelijkeVerenigingWerdGeregistreerd.Naam,
Expand Down

0 comments on commit 12b1e79

Please sign in to comment.