void processVideos()

in streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeUserActivityCollector.java [193:213]

21 lines of code
16 McCabe index (conditional complexity)


  void processVideos(List<Video> videos, DateTime afterDate, DateTime beforeDate, com.google.api.services.youtube.model.Activity activity, ActivityListResponse feed) {
    try {
      for (Video video : videos) {
        if (video != null) {
          org.joda.time.DateTime published = new org.joda.time.DateTime(video.getSnippet().getPublishedAt().getValue());
          if ((afterDate == null && beforeDate == null)
              || (beforeDate == null && afterDate.isBefore(published))
              || (afterDate == null && beforeDate.isAfter(published))
              || ((afterDate != null && beforeDate != null) && (afterDate.isAfter(published) && beforeDate.isBefore(published)))) {
            LOGGER.debug("Providing Youtube Activity: {}", MAPPER.writeValueAsString(video));
            this.datumQueue.put(new StreamsDatum(gson.toJson(video), activity.getId()));
          } else if (afterDate != null && afterDate.isAfter(published)) {
            feed.setNextPageToken(null); // do not fetch next page
            break;
          }
        }
      }
    } catch (Exception ex) {
      LOGGER.error("Exception while trying to process video list: {}, {}", videos, ex);
    }
  }