1313import org .apache .logging .log4j .LogManager ;
1414import org .apache .logging .log4j .Logger ;
1515
16+ import java .util .Arrays ;
1617import java .util .Collection ;
1718import java .util .HashSet ;
1819import java .util .List ;
@@ -40,8 +41,13 @@ public Sender getSender() {
4041 private Queue <CrawlerUrlDTO > createDayUrlsToCrawl () {
4142 final Queue <CrawlerUrlDTO > dayUrlsToCrawl = new ConcurrentLinkedQueue <>();
4243 final List <String > days = DateUtils .generateDaysToCrawl (crawlerConfig );
44+ // funk hat keine program übersicht
45+ final String [] CLIENTS_WITHOUT_FUNK =
46+ Arrays .stream (ArdConstants .CLIENTS )
47+ .filter (c -> !"funk" .equals (c ))
48+ .toArray (String []::new );
4349 days .forEach ( dateString -> {
44- for (final String client : ArdConstants . CLIENTS ) {
50+ for (final String client : CLIENTS_WITHOUT_FUNK ) {
4551 final String url = String .format (ArdConstants .DAY_PAGE_URL , dateString , client );
4652 dayUrlsToCrawl .offer (new CrawlerUrlDTO (url ));
4753 }
@@ -57,7 +63,6 @@ protected RecursiveTask<Set<Film>> createCrawlerTask() {
5763 forkJoinPool .submit (new ArdDayPageTask (this , createDayUrlsToCrawl ()));
5864
5965 final Set <ArdFilmInfoDto > shows = dayTask .get ();
60- shows .clear ();
6166 printMessage (
6267 ServerMessages .DEBUG_ALL_SENDUNG_FOLGEN_COUNT , getSender ().getName (), shows .size ());
6368
@@ -74,12 +79,8 @@ protected RecursiveTask<Set<Film>> createCrawlerTask() {
7479 assitUrls .addAll (forkJoinPool .submit (groupsToAsset ).get ());
7580 LOG .debug ("sender group assit tasks: {}" , assitUrls .size ());
7681
77- //test.add(new CrawlerUrlDTO("https://api.ardmediathek.de/page-gateway/widgets/swr/asset/Y3JpZDovL3N3ci5kZS8yNDEwMzY1MA?pageNumber=0&pageSize=48&embedded=true&seasoned=false&seasonNumber=&withAudiodescription=false&withOriginalWithSubtitle=false&withOriginalversion=false&single=false"));
78- test .add (new CrawlerUrlDTO ("https://api.ardmediathek.de/page-gateway/widgets/wdr/asset/Y3JpZDovL3dkci5kZS93ZXN0cG9s?pageNumber=0&pageSize=48&embedded=true&seasoned=false&seasonNumber=&withAudiodescription=false&withOriginalWithSubtitle=false&withOriginalversion=false&single=false" ));
79-
8082 final ArdTopicPageTask topicTask =
8183 new ArdTopicPageTask (this , new ConcurrentLinkedQueue <>(assitUrls ));
82- //new ArdTopicPageTask(this, new ConcurrentLinkedQueue<>(test));
8384
8485 final int showsCountBefore = shows .size ();
8586 shows .addAll (forkJoinPool .submit (topicTask ).get ());
0 commit comments