From dbacad168afb7884a1f2bdc1f098c3fbde7491ca Mon Sep 17 00:00:00 2001 From: vlad zverzhkhovskiy Date: Tue, 23 Sep 2025 11:05:53 +0300 Subject: [PATCH] =?UTF-8?q?=D0=9B=D0=BE=D0=B3=D0=B8=D1=80=D0=BE=D0=B2?= =?UTF-8?q?=D0=B0=D0=BD=D0=B8=D0=B5=20=D0=BE=D1=88=D0=B8=D0=B1=D0=BE=D0=BA?= =?UTF-8?q?=20=D0=BE=D1=82=D0=BF=D1=80=D0=B0=D0=B2=D0=BA=D0=B8=20=D0=BE?= =?UTF-8?q?=D0=BF=D0=BE=D0=B2=D0=B5=D1=89=D0=B5=D0=BD=D0=B8=D0=B9=20=D0=B2?= =?UTF-8?q?=20=D1=82=D0=B5=D0=BB=D0=B5=D0=B3=D1=80=D0=B0=D0=BC.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- KLHZ.Trader.Core/TG/Services/BotStarter.cs | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/KLHZ.Trader.Core/TG/Services/BotStarter.cs b/KLHZ.Trader.Core/TG/Services/BotStarter.cs index 5b9ec69..4c8e2a6 100644 --- a/KLHZ.Trader.Core/TG/Services/BotStarter.cs +++ b/KLHZ.Trader.Core/TG/Services/BotStarter.cs @@ -1,6 +1,7 @@ using KLHZ.Trader.Core.Contracts.Messaging.Dtos.Interfaces; using KLHZ.Trader.Core.Contracts.Messaging.Interfaces; using Microsoft.Extensions.Hosting; +using Microsoft.Extensions.Logging; using Microsoft.Extensions.Options; using System.Collections.Immutable; using System.Threading.Channels; @@ -15,9 +16,11 @@ namespace KLHZ.Trader.Core.TG.Services private readonly IUpdateHandler _updateHandler; private readonly Channel _messages = Channel.CreateUnbounded(); private readonly ImmutableArray _admins = []; + private readonly ILogger _logger; - public BotStarter(IOptions cfg, IUpdateHandler updateHandler, IDataBus dataBus, IOptions options) + public BotStarter(IOptions cfg, IUpdateHandler updateHandler, IDataBus dataBus, IOptions options, ILogger logger) { + _logger = logger; _botClient = new TelegramBotClient(cfg.Value.Token); _updateHandler = updateHandler; dataBus.AddChannel(string.Empty, _messages); @@ -32,7 +35,15 @@ namespace KLHZ.Trader.Core.TG.Services var message = await _messages.Reader.ReadAsync(); foreach (var admin in _admins) { - await _botClient.SendMessage(admin, message.Text); + try + { + await _botClient.SendMessage(admin, message.Text); + } + catch(Exception ex) + { + _logger.LogError(ex, "Ошибка при отправке сообщения в бота."); + } + } } }