private void handleReports()

in src/main/java/com/epam/digital/data/platform/report/ReportPublisherApplication.java [117:131]


  private void handleReports() {
    List<DataSource> dataSources = handleResponse(dataSourceClient.getDataSources());

    for (File reportsDir : getDirectories(appProperties.getReportsDirectoryName())) {
      log.info("Processing directory '{}'", reportsDir.getName());

      getDataSource(dataSources, reportsDir.getName())
          .ifPresent(dataSourceId -> {
            var context = createContext(dataSourceId);
            var files = getFiles(reportsDir);

            processPipelines(context, files);
          });
    }
  }