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);
});
}
}