File tree Expand file tree Collapse file tree 1 file changed +8
-4
lines changed
src/test/java/fr/insee/genesis/stubs Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Original file line number Diff line number Diff line change 1414import java .time .LocalDateTime ;
1515import java .time .Instant ;
1616import java .util .ArrayList ;
17+ import java .util .Collections ;
1718import java .util .HashMap ;
1819import java .util .HashSet ;
1920import java .util .List ;
@@ -137,11 +138,14 @@ public List<GroupedInterrogationDocument> aggregateRawGroupedWithNullProcessDate
137138 }
138139
139140 @ Override
140- public List <String > getUnprocessedInterrogationIds (String questionnaireId ) {
141- List <String > interrogationIds = new ArrayList <>();
141+ public List <GroupedInterrogationDocument > aggregateRawGroupedWithNullProcessDate (String questionnaireId ) {
142+ GroupedInterrogationDocument groupedInterrogationDocument = new GroupedInterrogationDocument ();
143+ groupedInterrogationDocument .setQuestionnaireId (questionnaireId );
144+ groupedInterrogationDocument .setPartitionOrCampaignId (questionnaireId );
145+ groupedInterrogationDocument .setInterrogationIds (new ArrayList <>());
142146 documents .stream ().filter (doc -> doc .questionnaireId ().equals (questionnaireId ) && doc .processDate () == null ).toList ()
143- .forEach (doc -> interrogationIds .add (doc .interrogationId ()));
144- return interrogationIds ;
147+ .forEach (doc -> groupedInterrogationDocument . getInterrogationIds () .add (doc .interrogationId ()));
148+ return Collections . singletonList ( groupedInterrogationDocument ) ;
145149 }
146150
147151 // Implémentations vides requises par MongoRepository
You can’t perform that action at this time.
0 commit comments