Files
Telegram-Bot-Template/TelegramBotService.cs
Dmitriy yawaflua Andreev 46714173c8 Add readme and template base
2024-07-30 23:01:30 +03:00

140 lines
4.5 KiB
C#

using Telegram.Bot;
using Telegram.Bot.Polling;
using Telegram.Bot.Types;
using Telegram.Bot.Types.Enums;
using Telegram.Bot.Types.InlineQueryResults;
namespace $safeprojectname$
{
public class TelegramBotService(IConfiguration conf, ILogger<TelegramBotService> logger) : TelegramBotClient(conf.GetValue<string>("tg-token")), IHostedService
{
private static Dictionary<long, string> _userStates = new Dictionary<long, string>();
// For add any property, u should to add it in StartAsync func, like this:
// _PROPERTY_NAME = PROPERTY_NAME_FROM_CLASS
private static ILogger<TelegramBotService> _logger { get; set; }
private static async Task MainHandler(ITelegramBotClient botClient, Update update, CancellationToken cancellationToken)
{
_logger.Log(
LogLevel.Information,
$"Received an update: {update.Type}, Caller ID: {update.Message?.From?.Id ?? update.CallbackQuery?.From.Id ?? update.InlineQuery?.From.Id}"
);
var handler = update switch
{
{ Message: { } message } => HandleUpdateAsync(botClient, message),
//{ EditedMessage: { } message } => BotOnMessageReceived(message, cancellationToken),
{ CallbackQuery: { } callbackQuery } => QueryUpdateHandler(botClient, callbackQuery),
{ InlineQuery: { } inlineQuery } => InlineUpdateHandler(botClient, inlineQuery),
//{ ChosenInlineResult: { } chosenInlineResult } => BotOnChosenInlineResultReceived(chosenInlineResult, cancellationToken),
_ => Task.CompletedTask
};
await handler;
}
private static async Task HandleUpdateAsync(ITelegramBotClient botClient, Message message)
{
try
{
string messageText = message.Text ?? message.Caption;
switch (messageText)
{
case "/start":
await botClient.SendTextMessageAsync(message.From.Id, "Start");
break;
default:
break;
}
}
catch (Exception ex)
{
_logger.LogError($"{ex.Message}");
_logger.LogError($"Stack: {ex.StackTrace}");
}
}
private static async Task QueryUpdateHandler(ITelegramBotClient botClient, CallbackQuery callbackQuery)
{
try
{
string queryData = callbackQuery.Data;
switch (queryData)
{
case "test":
await botClient.AnswerCallbackQueryAsync(callbackQuery.Id, "Tested");
break;
default:
break;
}
}
catch (Exception ex)
{
_logger.LogError($"{ex.Message}");
_logger.LogError($"Stack: {ex.StackTrace}");
}
}
private static async Task InlineUpdateHandler(ITelegramBotClient botClient, InlineQuery inlineQuery)
{
try
{
string inlineData = inlineQuery.Query;
switch (inlineData)
{
case "test":
await botClient.AnswerInlineQueryAsync(inlineQuery.Id, new InlineQueryResult[] { });
break;
default:
break;
}
}
catch (Exception ex)
{
_logger.LogError($"{ex.Message}");
_logger.LogError($"Stack: {ex.StackTrace}");
}
}
public async Task StartAsync(CancellationToken cancellationToken)
{
logger.Log(LogLevel.Information, $"Starting build {this.GetType().Name}");
// StartReceiving does not block the caller thread. Receiving is done on the ThreadPool.
ReceiverOptions receiverOptions = new()
{
AllowedUpdates = [UpdateType.Message, UpdateType.CallbackQuery, UpdateType.InlineQuery] // receive all update types except ChatMember related updates
};
_logger = logger;
this.StartReceiving(
updateHandler: MainHandler,
pollingErrorHandler: (k, ex, ctx) =>
{
logger.LogError(ex.StackTrace);
return Task.CompletedTask;
},
receiverOptions: receiverOptions,
cancellationToken: cancellationToken
);
var me = await this.GetMeAsync(cancellationToken: cancellationToken);
logger.Log(LogLevel.Information, $"Start listening bot @{me.Username}");
}
public async Task StopAsync(CancellationToken cancellationToken)
{
logger.Log(LogLevel.Information, $"Stopping service");
}
}
}