Create a console/background worker host for chat that still uses the tasks api

Matt Robold · Matt Robold · commit fd485259b786 · 2025-04-10T14:11:56.000-07:00
diff --git a/.github/workflows/workflow.yml b/.github/workflows/workflow.yml
@@ -0,0 +1,31 @@
+name: Build and Test
+
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+    branches:
+      - main
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+
+    steps:
+    - name: Checkout repository
+      uses: actions/checkout@v2
+
+    - name: Setup .NET
+      uses: actions/setup-dotnet@v2
+      with:
+        dotnet-version: '9.0.x'
+
+    - name: Restore dependencies
+      run: dotnet restore
+
+    - name: Build solution
+      run: dotnet build --no-restore --configuration Release
+
+    - name: Run tests
+      run: dotnet test --no-build --verbosity normal --configuration Release
diff --git a/Moneo.sln b/Moneo.sln
@@ -41,6 +41,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Moneo.Hosts.Chat.Api", "src
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Moneo.Web.Common", "src\Moneo.Web.Common\Moneo.Web.Common.csproj", "{AC612371-092B-4A01-903A-393F3EC3B12D}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Moneo.Hosts.Telegram.Console", "src\Hosts\Moneo.Hosts.Telegram.Console\Moneo.Hosts.Telegram.Console.csproj", "{645D2325-A422-46C2-9863-85965BD20059}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -103,6 +105,10 @@ Global
 		{AC612371-092B-4A01-903A-393F3EC3B12D}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{AC612371-092B-4A01-903A-393F3EC3B12D}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{AC612371-092B-4A01-903A-393F3EC3B12D}.Release|Any CPU.Build.0 = Release|Any CPU
+		{645D2325-A422-46C2-9863-85965BD20059}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{645D2325-A422-46C2-9863-85965BD20059}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{645D2325-A422-46C2-9863-85965BD20059}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{645D2325-A422-46C2-9863-85965BD20059}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -125,6 +131,7 @@ Global
 		{2D782615-ECEE-440C-AFB8-515990FCACE2} = {C80150B3-C997-47FF-BE06-ED0709EA6DCB}
 		{F7DB7921-AD36-4A26-988B-C01318AE8045} = {C80150B3-C997-47FF-BE06-ED0709EA6DCB}
 		{AC612371-092B-4A01-903A-393F3EC3B12D} = {BAC297B4-CBE2-403F-AD70-110B317BBE28}
+		{645D2325-A422-46C2-9863-85965BD20059} = {C80150B3-C997-47FF-BE06-ED0709EA6DCB}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {9A69730A-25AE-421F-A76A-39B03C0A0207}
diff --git a/src/Chat/Moneo.Chat.Telegram/ServiceCollectionExtensions.cs b/src/Chat/Moneo.Chat.Telegram/ServiceCollectionExtensions.cs
@@ -29,6 +29,11 @@ public static IServiceCollection AddTelegramChatAdapter(this IServiceCollection
         //  https://docs.microsoft.com/en-us/dotnet/architecture/microservices/implement-resilient-applications/use-httpclientfactory-to-implement-resilient-http-requests
         services.AddHttpClient("tgclient")
             .AddTypedClient<ITelegramBotClient>(httpClient => new TelegramBotClient(options.BotToken, httpClient));
+
+        if (options.HostedServiceFlag)
+        {
+            services.AddHostedService<TelegramChatBackgroundService>();
+        }
         
         return services;
     }
diff --git a/src/Chat/Moneo.Chat.Telegram/TelegramChatAdapter.cs b/src/Chat/Moneo.Chat.Telegram/TelegramChatAdapter.cs
@@ -96,7 +96,7 @@ await _botClient.SendMessage(_options.MasterConversationId, apiRequestException.
         }
     }
 
-    public Task StartReceivingAsync(CancellationToken cancellationToken = default)
+    public async Task StartReceivingAsync(CancellationToken cancellationToken = default)
     {
         _isUsingWebhook = false;
         
@@ -107,10 +107,10 @@ public Task StartReceivingAsync(CancellationToken cancellationToken = default)
             AllowedUpdates = [UpdateType.Message, UpdateType.CallbackQuery],
             DropPendingUpdates = true
         };
+        await _botClient.DeleteWebhook(cancellationToken: cancellationToken);
+        
         _botClient.StartReceiving(HandleUpdateAsync, HandleErrorAsync, options, cancellationToken);
         IsActive = true;
-
-        return Task.CompletedTask;
     }
 
     public async Task StartReceivingAsync(string callbackUrl, CancellationToken cancellationToken = default)
diff --git a/src/Chat/Moneo.Chat.Telegram/TelegramChatAdapterOptions.cs b/src/Chat/Moneo.Chat.Telegram/TelegramChatAdapterOptions.cs
@@ -4,7 +4,9 @@ namespace Moneo.Chat.Telegram;
 
 public class TelegramChatAdapterOptions : ChatAdapterOptions
 {
+    public bool HostedServiceFlag { get; private set; }
     public string BotToken { get; set; } = string.Empty;
     public long MasterConversationId { get; set; }
     public string CallbackToken { get; set; } = string.Empty;
+    public void RegisterAsHostedService() => HostedServiceFlag = true;
 }
diff --git a/src/Chat/Moneo.Chat.Telegram/TelegramChatBackgroundService.cs b/src/Chat/Moneo.Chat.Telegram/TelegramChatBackgroundService.cs
@@ -0,0 +1,19 @@
+using Microsoft.Extensions.Hosting;
+using Moneo.Chat.BotRequests;
+using Telegram.Bot.Types;
+
+namespace Moneo.Chat.Telegram;
+
+public class TelegramChatBackgroundService : IHostedService
+{
+    private readonly IChatAdapter _chatAdapter;
+    
+    public Task StartAsync(CancellationToken cancellationToken) => _chatAdapter.StartReceivingAsync(cancellationToken);
+
+    public Task StopAsync(CancellationToken cancellationToken) => _chatAdapter.StopReceivingAsync(cancellationToken);
+
+    public TelegramChatBackgroundService(IChatAdapter chatAdapter)
+    {
+        _chatAdapter = chatAdapter;
+    }
+}
diff --git a/src/Hosts/Moneo.Hosts.Telegram.Console/Moneo.Hosts.Telegram.Console.csproj b/src/Hosts/Moneo.Hosts.Telegram.Console/Moneo.Hosts.Telegram.Console.csproj
@@ -0,0 +1,19 @@
+﻿<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net9.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+    </PropertyGroup>
+
+    <ItemGroup>
+      <ProjectReference Include="..\..\Chat\Moneo.Chat.Contracts\Moneo.Chat.Contracts.csproj" />
+      <ProjectReference Include="..\..\Chat\Moneo.Chat.Telegram\Moneo.Chat.Telegram.csproj" />
+      <ProjectReference Include="..\..\Chat\Moneo.Chat\Moneo.Chat.csproj" />
+      <ProjectReference Include="..\..\Moneo.Common\Moneo.Common.csproj" />
+      <ProjectReference Include="..\..\Moneo.Web.Common\Moneo.Web.Common.csproj" />
+      <ProjectReference Include="..\..\TaskManagement\Moneo.TaskManagement.Contracts\Moneo.TaskManagement.Contracts.csproj" />
+    </ItemGroup>
+
+</Project>
diff --git a/src/Hosts/Moneo.Hosts.Telegram.Console/Program.cs b/src/Hosts/Moneo.Hosts.Telegram.Console/Program.cs
diff --git a/src/Hosts/Moneo.Hosts.Telegram.Console/appsettings.Development.json b/src/Hosts/Moneo.Hosts.Telegram.Console/appsettings.Development.json
diff --git a/src/Hosts/Moneo.Hosts.Telegram.Console/appsettings.json b/src/Hosts/Moneo.Hosts.Telegram.Console/appsettings.json

Original file line number	Diff line number	Diff line change
`@@ -96,7 +96,7 @@ await _botClient.SendMessage(_options.MasterConversationId, apiRequestException.`
`96`	`96`	`}`
`97`	`97`	`}`
`98`	`98`
`99`		`- public Task StartReceivingAsync(CancellationToken cancellationToken = default)`
	`99`	`+ public async Task StartReceivingAsync(CancellationToken cancellationToken = default)`
`100`	`100`	`{`
`101`	`101`	`_isUsingWebhook = false;`
`102`	`102`
`@@ -107,10 +107,10 @@ public Task StartReceivingAsync(CancellationToken cancellationToken = default)`
`107`	`107`	`AllowedUpdates = [UpdateType.Message, UpdateType.CallbackQuery],`
`108`	`108`	`DropPendingUpdates = true`
`109`	`109`	`};`
	`110`	`+ await _botClient.DeleteWebhook(cancellationToken: cancellationToken);`
	`111`	`+`
`110`	`112`	`_botClient.StartReceiving(HandleUpdateAsync, HandleErrorAsync, options, cancellationToken);`
`111`	`113`	`IsActive = true;`
`112`		`-`
`113`		`- return Task.CompletedTask;`
`114`	`114`	`}`
`115`	`115`
`116`	`116`	`public async Task StartReceivingAsync(string callbackUrl, CancellationToken cancellationToken = default)`
Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,9 @@ namespace Moneo.Chat.Telegram;`
`4`	`4`
`5`	`5`	`public class TelegramChatAdapterOptions : ChatAdapterOptions`
`6`	`6`	`{`
	`7`	`+ public bool HostedServiceFlag { get; private set; }`
`7`	`8`	`public string BotToken { get; set; } = string.Empty;`
`8`	`9`	`public long MasterConversationId { get; set; }`
`9`	`10`	`public string CallbackToken { get; set; } = string.Empty;`
	`11`	`+ public void RegisterAsHostedService() => HostedServiceFlag = true;`
`10`	`12`	`}`