fix: correctly remove deleted goal from multiple datastreams (#153)

kadaster-labs · Mar 17, 2022 · 39912f0 · 39912f0
1 parent 887711f
commit 39912f0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/query/processor/observation-goal.es.listener.ts b/src/query/processor/observation-goal.es.listener.ts
@@ -74,7 +74,7 @@ export class ObservationGoalEsListener extends AbstractQueryEsListener {
     async processObservationGoalRemoved(event: ObservationGoalRemoved): Promise<void> {
         try {
             const deviceFilter = { 'datastreams.observationGoalIds': event.observationGoalId };
-            const deviceUpdate = { $pull: { 'datastreams.$.observationGoalIds': event.observationGoalId } };
+            const deviceUpdate = { $pull: { 'datastreams.$[].observationGoalIds': event.observationGoalId } };
             await this.deviceModel.updateMany(deviceFilter, deviceUpdate);
 
             await this.deleteRelations(event.legalEntityId, TargetVariant.OBSERVATION_GOAL, event.observationGoalId);