fix: filter on process date the raw responses tthat needs to be processed

Author: loichenninger

src/main/java/fr/insee/genesis/infrastructure/adapter/RawResponseMongoAdapter.java

@@ -56,6 +56,6 @@ public List<String> getUnprocessedCollectionIds() {
     @Override
     public Set<String> findUnprocessedInterrogationIdsByCollectionInstrumentId(String collectionInstrumentId) {
         // We remove duplicate ids
-        return new HashSet<>(repository.findInterrogationIdByCollectionInstrumentId(collectionInstrumentId));
+        return new HashSet<>(repository.findInterrogationIdByCollectionInstrumentIdAndProcessDateIsNull(collectionInstrumentId));
     }
 }

src/main/java/fr/insee/genesis/infrastructure/repository/RawResponseRepository.java

@@ -21,9 +21,9 @@ public interface RawResponseRepository extends MongoRepository<RawResponseDocume
     List<String> findDistinctCollectionInstrumentIdByProcessDateIsNull();
 
     @Aggregation(pipeline = {
-            "{ $match: { collectionInstrumentId: ?0 } }",
+            "{ $match: { collectionInstrumentId: ?0,processDate: null } }",
             "{ $project: { _id: 0, interrogationId: '$interrogationId' } }"
     })
-    List<String> findInterrogationIdByCollectionInstrumentId(String collectionInstrumentId);
+    List<String> findInterrogationIdByCollectionInstrumentIdAndProcessDateIsNull(String collectionInstrumentId);
 
 }