parr_api/PARR.EsppTemplateSync/TemplateSyncer.cs

using Microsoft.Extensions.Logging;
using PARR.BLL.Services.Interfaces;
using PARR.BLL.Settings;
using PARR.EsppTemplateSync.Services;
using PARR.EsppTemplateSync.Settings;

namespace PARR.EsppTemplateSync
{
    internal class TemplateSyncer : ITemplateSyncer
    {
        private readonly ILogger<TemplateSyncer> logger;
        private readonly IParserService parserService;
        private readonly IFileService fileService;
        private readonly GlobalSettings globalSettings;
        private readonly string dirPath;
        private readonly string filterExtensions;

        //private FileSystemWatcher? watcher;

        public TemplateSyncer(
            StorageSettings storageSettings,
            ILogger<TemplateSyncer> logger,
            IParserService parserService,
            IFileService fileService,
            GlobalSettings globalSettings
            )
        {
            this.logger = logger;
            this.parserService = parserService;
            this.fileService = fileService;
            this.globalSettings = globalSettings;
            if (storageSettings.EsppTemplates == null)
            {
                logger.LogError("Нет секции настроек хранилища. StorageSettings, EsppTemplates");
                throw new Exception("Нет секции настроек хранилища. StorageSettings, EsppTemplates");
            }

            string dirPath = Path.Combine(storageSettings.EsppTemplates.TemplatePath);
            this.dirPath = Path.Combine(storageSettings.StoragePath, dirPath);

            filterExtensions = string.Join(",", storageSettings.EsppTemplates!.AllowedExtensions).Replace(".", "*.");
        }

        public async Task StartWatchingAsync()
        {
            //смотрим, доступна ли папка
            if (!Directory.Exists(dirPath))
            {
                logger.LogError($"Не найдена папка: {dirPath}.");
                throw new Exception($"Не найдена папка: {dirPath}.");
            }

            logger.LogInformation($"Запущена проверка директории. Интервал: {globalSettings.CheckIntervalSeconds} секунд. Фильтр: {filterExtensions}");

            while (true)
            {
                await GetFilesAsync();
                await Task.Delay(globalSettings.CheckIntervalSeconds * 1000);
            }


            // сначала обрабатываем существующие файлы, до тех пор пока все не обработаем
            // после обработки всех файлов, запускаем вотчер
            //await GetFilesAsync();

            // код ниже, это то что надо использовать, но в доккере не работает watcher
            ////--- watcher
            //watcher = new FileSystemWatcher(dirPath);
            //watcher.NotifyFilter = NotifyFilters.FileName;
            ////watcher.Changed += OnChanged;
            ////todo: тут await???
            //watcher.Created += OnChanged;

            //watcher.Filter = filterExtensions;
            //watcher.EnableRaisingEvents = true;
            //watcher.IncludeSubdirectories = false;

            ////=== watcher

            //logger.LogInformation($"--- --- --- FileWatcher запущен --- --- ---");
        }


        public void StopWatching()
        {
            //watcher?.Dispose();
            logger.LogInformation($"=== === === FileWatcher остановлен === === ===");
        }

        //private async void OnChanged(object sender, FileSystemEventArgs e)
        //{
        //    var path = e.FullPath;
        //    await ParseFileAsync(path);
        //}

        private async Task GetFilesAsync()
        {
            // обрабатываем существующие файлы
            var files = Directory.GetFiles(this.dirPath, filterExtensions);

            //logger.LogInformation($"Запуск первоначальной загрузки файлов после старта сервиса. (До старта вотчера). Найдено файлов: {files.Length} шт.");
            logger.LogInformation($"Найдено файлов: {files.Length} шт.");

            foreach (var file in files)
            {
                if (File.Exists(file))
                    await ParseFileAsync(file);
                else
                    logger.LogInformation($"Файл не найден: {file}");
            }


            //если были файлы, запустим еще раз ручную обработку, вдруг за это время еще загрузили, а вотчер еще не был запущен
            //запускаем до тех пор, пока не останется необработанных файлов
            //if (files.Any())
            //    await GetFilesAsync();
        }


        private async Task ParseFileAsync(string path)
        {
            logger.LogInformation($"--- --- Найден файл. Готов для парсинга {path} --- ---");
            var parseResult = await parserService.ParseAsync(path);

            if (parseResult)
            {
                logger.LogInformation($"Парсинг успешно завершен. Удаляю файл {path}");
                var removeResult = fileService.DeleteFile(path);
            }
            else
            {
                logger.LogError($"Парсинг завершен c ошибкой. Файл не удален {path}");
            }
        }

    }
}