- timeout for telegram

Author: Igor Evdokimov

Botticelli.Framework.Telegram/Extensions/ServiceCollectionExtensions.cs

@@ -66,7 +66,12 @@ public static IServiceCollection AddTelegramBot(this IServiceCollection services
 
         var sp = services.BuildServiceProvider();
 
-        var bot = new TelegramBot(new TelegramBotClient(token),
+        var telegramClient = new TelegramBotClient(token)
+        {
+            Timeout = TimeSpan.FromMilliseconds(settings.Timeout)
+        };
+
+        var bot = new TelegramBot(telegramClient,
             sp.GetRequiredService<IBotUpdateHandler>(),
             sp.GetRequiredService<ILogger<TelegramBot>>(),
             sp.GetRequiredService<MetricsProcessor>(),

Botticelli.Framework.Telegram/Options/TelegramBotSettings.cs

@@ -5,4 +5,8 @@ namespace Botticelli.Framework.Telegram.Options;
 /// <inheritdoc />
 public class TelegramBotSettings : BotSettings
 {
+    /// <summary>
+    /// Timeout in ms
+    /// </summary>
+    public int Timeout { get; set; } = 60000;
 }

Botticelli.Framework.Telegram/TelegramBot.cs

@@ -145,7 +145,7 @@ protected override async Task<SendMessageResponse> InnerSendMessageAsync<TSendOp
 
             var text = new StringBuilder($"{request.Message.Subject} {request.Message.Body}");
             var retText = Escape(text).ToString();
-            List<(string chatId, string innerId)> pairs = new();
+            List<(string chatId, string innerId)> pairs = [];
 
             foreach (var link in request.Message.ChatIdInnerIdLinks)
                 pairs.AddRange(link.Value.Select(innerId => (link.Key, innerId)));
@@ -170,7 +170,7 @@ protected override async Task<SendMessageResponse> InnerSendMessageAsync<TSendOp
                     else
                     {
                         Logger.LogWarning(@"Streaming output isn't supported for Telegram now!");
-                        await SendText(@"Sorry, but streaming output isn't supported for Telegram now\!");
+                        await SendText(@"Sorry, but streaming output isn't supported for Telegram now!");
                     }
 
                     async Task SendText(string sendText)
@@ -403,7 +403,7 @@ private static StringBuilder Escape(StringBuilder text) =>
     /// <param name="request"></param>
     /// <param name="token"></param>
     /// <returns></returns>
-    protected override async Task<StartBotResponse> InnerStartBotAsync(StartBotRequest request, CancellationToken token)
+    protected override Task<StartBotResponse> InnerStartBotAsync(StartBotRequest request, CancellationToken token)
     {
         try
         {
@@ -414,7 +414,7 @@ protected override async Task<StartBotResponse> InnerStartBotAsync(StartBotReque
             {
                 Logger.LogInformation($"{nameof(StartBotAsync)}: already started");
 
-                return response;
+                return Task.FromResult(response);
             }
 
             BotStatusKeeper.IsStarted = true;
@@ -430,14 +430,14 @@ protected override async Task<StartBotResponse> InnerStartBotAsync(StartBotReque
 
             Logger.LogInformation($"{nameof(StartBotAsync)}: started");
 
-            return response;
+            return Task.FromResult(response);
         }
         catch (Exception ex)
         {
             Logger.LogError(ex, ex.Message);
         }
 
-        return StartBotResponse.GetInstance(AdminCommandStatus.Fail, "error");
+        return Task.FromResult(StartBotResponse.GetInstance(AdminCommandStatus.Fail, "error"));
     }
 
     /// <summary>
@@ -487,10 +487,7 @@ public override async Task SetBotKey(string key, CancellationToken token)
         }
     }
 
-    private void RecreateClient(string key)
-    {
-        _client = new TelegramBotClient(key);
-    }
+    private void RecreateClient(string key) => _client = new TelegramBotClient(key);
 
     private async Task StartBot(CancellationToken token)
     {

Samples/TelegramInlineLayoutsSample/Program.cs

@@ -27,6 +27,7 @@
                                         {
                                             ConnectionString = settings.SecureStorageConnectionString
                                         })
+                                        .Set(s => s.Timeout = 20000)
                                         .Set(s => s.Name = "test_bot"))
        .AddLogging(cfg => cfg.AddNLog())
        .AddBotCommand<GetCalendarCommand, GetCalendarCommandProcessor, PassValidator<GetCalendarCommand>>()