mahdium/CatsOfMastodon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added /start message handling

Browse Source
This commit is contained in:
Mohammad Mahdi
2024-09-16 00:07:24 +03:30
parent 7e94e39a78
commit 94ee45d9bd
14 changed files with 68 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
Program.cs Normal file → Executable file
View File

@@ -1,7 +1,9 @@
using Microsoft.Extensions.Logging;
using CatsOfMastodonBot.Services;
using Microsoft.Extensions.Logging;
using mstdnCats.Services;
using Telegram.Bot;
using Telegram.Bot.Types;
using Telegram.Bot.Types.Enums;
public class MastodonBot
{
@@ -19,7 +21,8 @@ public class MastodonBot
});
var logger = loggerFactory.CreateLogger<MastodonBot>();
if(!CheckEnv.IsValid()){
if (!CheckEnv.IsValid())
{
logger.LogCritical("Error reading envinonment variables, either some values are missing or no .env file was found");
throw new Exception("Error reading envinonment variables, either some values are missing or no .env file was found");
}
@@ -34,31 +37,41 @@ public class MastodonBot
// Setup bot
var bot = new TelegramBotClient(DotNetEnv.Env.GetString("BOT_TOKEN"));
var bot = new TelegramBotClient(DotNetEnv.Env.GetString("BOT_TOKEN"));
var me = await bot.GetMeAsync();
await bot.DropPendingUpdatesAsync();
bot.OnUpdate += OnUpdate;
var me = await bot.GetMeAsync();
await bot.DropPendingUpdatesAsync();
bot.OnUpdate += OnUpdate;
bot.OnMessage += OnMessage;
logger.LogInformation($"Bot is running as {me.FirstName}.");
logger.LogInformation($"Bot is running as {me.FirstName}.");
// Handle bot updates
async Task OnUpdate(Update update)
// Handle bot updates
async Task OnUpdate(Update update)
{
switch (update)
{
switch (update)
{
case { CallbackQuery: { } callbackQuery }: await HandlePostAction.HandleCallbackQuery(callbackQuery, db, bot, logger); break;
default: logger.LogInformation($"Received unhandled update {update.Type}"); break;
};
case { CallbackQuery: { } callbackQuery }: {
if(callbackQuery.Data == "new_random") await HandleStartMessage.HandleStartMessageAsync(callbackQuery.Message, bot, db, logger);
else await HandlePostAction.HandleCallbackQuery(callbackQuery, db, bot, logger); break;
}
default: logger.LogInformation($"Received unhandled update {update.Type}"); break;
};
}
// Handle bot messages
async Task OnMessage(Message message, UpdateType type)
{
if (message.Text == "/start")
{
await HandleStartMessage.HandleStartMessageAsync(message,bot, db, logger);
}
}
// Set a timer to fetch and process posts every 15 minutes
_timer = new Timer(async _ => await RunCheck.runAsync(db, bot, DotNetEnv.Env.GetString("TAG"), logger, DotNetEnv.Env.GetString("CUSTOM_INSTANCE")), null, TimeSpan.Zero, TimeSpan.FromMinutes(15));
Console.ReadLine();
// Set a timer to fetch and process posts every 15 minutes
_timer = new Timer(async _ => await RunCheck.runAsync(db, bot, DotNetEnv.Env.GetString("TAG"), logger, DotNetEnv.Env.GetString("CUSTOM_INSTANCE")), null, TimeSpan.Zero, TimeSpan.FromMinutes(15));
Console.ReadLine();
}
}