diff --git a/src/AssociationRegistry.Public.ProjectionHost/Projections/Search/ElasticRepository.cs b/src/AssociationRegistry.Public.ProjectionHost/Projections/Search/ElasticRepository.cs index 144f32d92..323c9179e 100644 --- a/src/AssociationRegistry.Public.ProjectionHost/Projections/Search/ElasticRepository.cs +++ b/src/AssociationRegistry.Public.ProjectionHost/Projections/Search/ElasticRepository.cs @@ -122,59 +122,6 @@ public async Task AppendRelatie(string id, Relatie relatie) if (!response.IsValid) throw new IndexDocumentFailed(response.DebugInformation); } - - public async Task UpdateNaamInRelaties(VerenigingZoekDocument documentToUpdate) - { - var matches = _elasticClient.Search(descriptor => descriptor.Query( - q => q - .Nested(n => n - .Path(document => document.Relaties) - .Query(nq => nq - .Nested(n => n - .Path(doc => doc.Relaties.First() - .AndereVereniging) - .Query(nq2 => nq2 - .Term(m => m - .Field( - doc => doc - .Relaties - .First() - .AndereVereniging - .VCode) - .Value( - documentToUpdate - .VCode))))) - ) - )); - - var response = await _elasticClient.UpdateByQueryAsync( - u => u - .Query( - q => q - .Nested(n => n - .Path(document => document.Relaties) - .Query(nq => nq - .Nested(n => n - .Path(doc => doc.Relaties.First().AndereVereniging) - .Query(nq2 => nq2 - .Term(m => m - .Field(doc => doc.Relaties.First().AndereVereniging.VCode) - .Value(documentToUpdate.VCode))))) - ) - ) - .Script(s => s - .Source("for(r in ctx._source.relaties){" + - " if(r.andereVereniging.vCode == params.gewijzigdeVereniging.vCode){" + - " r.andereVereniging.naam = params.gewijzigdeVereniging.naam" + - " }" + - "}") - .Params(objects => objects.Add(key: "gewijzigdeVereniging", documentToUpdate))) - ); - - if (!response.IsValid) - throw new IndexDocumentFailed(response.DebugInformation); - } - public async Task WijzigNaamAfdeling(string vCode, string nieuweNaam) { var afdeling = _elasticClient.Get(vCode); diff --git a/src/AssociationRegistry.Public.ProjectionHost/Projections/Search/IElasticRepository.cs b/src/AssociationRegistry.Public.ProjectionHost/Projections/Search/IElasticRepository.cs index 95fffd722..4b9cb85bb 100644 --- a/src/AssociationRegistry.Public.ProjectionHost/Projections/Search/IElasticRepository.cs +++ b/src/AssociationRegistry.Public.ProjectionHost/Projections/Search/IElasticRepository.cs @@ -17,6 +17,5 @@ Task IndexAsync(TDocument document) Task UpdateLocatie(string id, VerenigingZoekDocument.Locatie locatie); Task Remove(string id); Task AppendRelatie(string id, Relatie relatie); - Task UpdateNaamInRelaties(VerenigingZoekDocument documentToUpdate); Task WijzigNaamAfdeling(string vCode, string nieuweNaam); }