using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Text.RegularExpressions; using System.Web; using CodeHollow.FeedReader; using NLog; using Telegram.Bot.Exceptions; using Telegram.Bot.Types; using Telegram.Bot.Types.Enums; namespace RSSBot { public static class Commands { private static readonly Logger Logger = LogManager.GetCurrentClassLogger(); public static async void Welcome(Message message, GroupCollection matches) { await Bot.BotClient.SendTextMessageAsync( message.Chat, "Willkommen bei RikoBot!\nSende /help, um zu starten.", ParseMode.Html ); } public static async void Help(Message message, GroupCollection matches) { await Bot.BotClient.SendTextMessageAsync( message.Chat, "/rss [Chat]: Abonnierte Feeds anzeigen\n" + "/sub Feed-URL [Chat]: Feed abonnieren\n" + "/del Feed-URL [Chat]: Feed löschen\n" + "/show Feed-URL [Chat]: Feeds auf dieser Seite anzeigen\n" + "[Chat] ist ein optionales Argument mit dem @Kanalnamen.", ParseMode.Html ); } public static async void Subscribe(Message message, GroupCollection args) { string url = args[1].Value; long chatId = message.Chat.Id; RssBotFeed feed = new RssBotFeed(url); await Bot.BotClient.SendChatActionAsync(message.Chat, ChatAction.Typing); if (args.Count > 2) { Chat chatInfo; string chatName = args[2].Value; bool isId = long.TryParse(chatName, out chatId); if (isId) try { chatInfo = await Bot.BotClient.GetChatAsync(chatId); } catch { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Dieser Kanal existiert nicht."); return; } else try { chatInfo = await Bot.BotClient.GetChatAsync(chatName); } catch { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Dieser Kanal existiert nicht."); return; } chatId = chatInfo.Id; if (!await Utils.IsBotAdmin(chatId)) { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Du musst den Bot als Administrator zu diesem Kanal hinzufügen."); return; } } try { await feed.Check(); } catch { await Bot.BotClient.SendTextMessageAsync( message.Chat, "❌ Kein gültiger RSS-Feed." ); return; } // Check if we already have the feed RssBotFeed existingFeed = Bot.RssBotFeeds .FirstOrDefault(x => x.Url.ToLower().Equals(feed.Url.ToLower())); if (existingFeed == null) Bot.RssBotFeeds.Add(feed); else feed = existingFeed; // Check if chat already subscribed if (feed.Subs.Contains(chatId)) { await Bot.BotClient.SendTextMessageAsync(message.Chat, "✅ Dieser Feed wurde bereits abonniert."); } else { feed.Subs.Add(chatId); await Bot.BotClient.SendTextMessageAsync(message.Chat, "✅ Feed abonniert!"); Bot.Save(); } } public static async void Unsubscribe(Message message, GroupCollection args) { string url = args[1].Value; long chatId = message.Chat.Id; RssBotFeed feed = Bot.RssBotFeeds .FirstOrDefault(x => x.Url.ToLower().Equals(url.ToLower())); if (args.Count > 2) { Chat chatInfo; string chatName = args[2].Value; bool isId = long.TryParse(chatName, out chatId); if (isId) try { chatInfo = await Bot.BotClient.GetChatAsync(chatId); } catch { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Dieser Kanal existiert nicht."); return; } else try { chatInfo = await Bot.BotClient.GetChatAsync(chatName); } catch { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Dieser Kanal existiert nicht."); return; } chatId = chatInfo.Id; if (!await Utils.IsBotAdmin(chatId)) { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Du musst den Bot als Administrator zu diesem Kanal hinzufügen."); return; } } if (feed == null || !feed.Subs.Contains(chatId)) { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Feed wurde nicht abonniert."); return; } feed.Cleanup(chatId); if (feed.Subs.Count == 0) Bot.RssBotFeeds.Remove(feed); await Bot.BotClient.SendTextMessageAsync(message.Chat, "✅ Feed deabonniert!"); Bot.Save(); } public static async void Show(Message message, GroupCollection args) { long chatId = message.Chat.Id; string chatTitle = message.Chat.Type.Equals(ChatType.Private) ? message.Chat.FirstName : message.Chat.Title; await Bot.BotClient.SendChatActionAsync(message.Chat, ChatAction.Typing); if (args.Count > 1) { Chat chatInfo; string chatName = args[1].Value; bool isId = long.TryParse(chatName, out chatId); if (isId) try { chatInfo = await Bot.BotClient.GetChatAsync(chatId); } catch { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Dieser Kanal existiert nicht."); return; } else try { chatInfo = await Bot.BotClient.GetChatAsync(chatName); } catch { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Dieser Kanal existiert nicht."); return; } chatId = chatInfo.Id; chatTitle = chatInfo.Title; if (!await Utils.IsBotAdmin(chatId)) { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Du musst den Bot als Administrator zu diesem Kanal hinzufügen."); return; } } List feeds = Bot.RssBotFeeds.Where(x => x.Subs.Contains(chatId)).ToList(); StringBuilder text = new StringBuilder(); if (feeds.Count < 1) { text.Append("❌ Keine Feeds abonniert."); } else { text.Append($"{HttpUtility.HtmlEncode(chatTitle)} hat abonniert:\n"); for (int i = 0; i < feeds.Count; i++) text.Append($"{i + 1}) {feeds[i].Url}\n"); } await Bot.BotClient.SendTextMessageAsync(message.Chat, text.ToString(), ParseMode.Html, true); } public static async void Sync() { Logger.Info("================================"); bool hadEntries = false; foreach (RssBotFeed feed in Bot.RssBotFeeds.ToList()) { Logger.Info(feed.Url); try { await feed.Check(); } catch (Exception e) { Logger.Warn($"FEHLER: {e.Message}"); continue; } if (feed.NewEntries.Count == 0) { /* Logger.Info("Keine neuen Beiträge."); */ continue; } hadEntries = true; Logger.Info(feed.NewEntries.Count == 1 ? "1 neuer Beitrag" : $"{feed.NewEntries.Count} neue Beiträge"); foreach (FeedItem entry in feed.NewEntries) { string postTitle = "Kein Titel"; if (!string.IsNullOrWhiteSpace(entry.Title)) postTitle = Utils.StripHtml(entry.Title); string postLink = feed.MainLink; string linkName = postLink; if (!string.IsNullOrWhiteSpace(entry.Link)) { postLink = entry.Link; // FeedProxy URLs GroupCollection feedProxy = Utils.ReturnMatches(postLink, "^https?://feedproxy.google.com/~r/(.+?)/.*"); linkName = feedProxy.Count > 1 ? feedProxy[1].Value : new Uri(postLink).Host; } // Remove "www." int index = linkName.IndexOf("www.", StringComparison.Ordinal); if (index > -1) linkName = linkName.Remove(index, 4); string content = ""; if (!string.IsNullOrWhiteSpace(entry.Content)) content = Utils.ProcessContent(entry.Content); else if (!string.IsNullOrWhiteSpace(entry.Description)) content = Utils.ProcessContent(entry.Description); string text = $"[#RSS] {postTitle}\n{content}"; text += $"\nAuf {linkName} ansehen."; // Send foreach (long chatId in feed.Subs.ToList()) try { await Bot.BotClient.SendTextMessageAsync(chatId, text, ParseMode.Html, true, true); } catch (ApiRequestException e) { if (e.ErrorCode.Equals(403)) { Logger.Warn(e.Message); feed.Cleanup(chatId); if (feed.Subs.Count == 0) // was last subscriber Bot.RssBotFeeds.Remove(feed); } else { Logger.Error($"{e.ErrorCode}: {e.Message}"); } } } } /* Logger.Info("Nächster Check in 60 Sekunden"); */ if (hadEntries) Bot.Save(); Bot.JobQueue.Change(TimeSpan.FromMinutes(1), TimeSpan.FromMilliseconds(-1)); } public static async void ShowAvailableFeeds(Message message, GroupCollection args) { string url = args[1].Value; IEnumerable feeds; try { feeds = await FeedReader.GetFeedUrlsFromUrlAsync(url); } catch { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Sete konnte nicht erreicht werden."); return; } List htmlFeedLinks = feeds.ToList(); if (htmlFeedLinks.Count == 0) { await Bot.BotClient.SendTextMessageAsync(message.Chat, "❌ Keine Feeds gefunden."); return; } string text = htmlFeedLinks.Aggregate("Feeds gefunden:\n", (current, feedLink) => current + $"* {Utils.StripHtml(feedLink.Title)}\n"); await Bot.BotClient.SendTextMessageAsync(message.Chat, text, ParseMode.Html, true); } } }