refactor the telegram bot project into this one and some cleanup

Author: SolidProgramming

.gitignore

@@ -364,3 +364,4 @@ FodyWeavers.xsd
 /AniWorldReminder_API/settings.json
 /AniWorldReminder_API/appdata/settings.json
 /AniWorldReminder_API/appsettings.json
+.dotnet/

AniWorldReminder_API/AniWorldReminder_API.csproj

@@ -9,15 +9,16 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="BouncyCastle.Cryptography" Version="2.6.2" />
     <PackageReference Include="Dapper" Version="2.1.72" />
+    <PackageReference Include="Hangfire.AspNetCore" Version="1.8.23" />
+    <PackageReference Include="Hangfire.MemoryStorage" Version="1.8.1.2" />
     <PackageReference Include="HtmlAgilityPack" Version="1.12.4" />
     <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="10.0.5" />
     <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="10.0.5" />
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.23.0" />
     <PackageReference Include="MySql.Data" Version="9.6.0" />
+    <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="10.1.7" />
-    <PackageReference Include="System.Drawing.Common" Version="10.0.5" />
     <PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="8.17.0" />
     <PackageReference Include="Telegram.Bot" Version="22.9.5.3" />
   </ItemGroup>

AniWorldReminder_API/Classes/SettingsHelper.cs

@@ -16,7 +16,7 @@ internal static class SettingsHelper
 
                 // Ensure the directory exists before attempting to read or write the settings file
                 string? directory = Path.GetDirectoryName(path);
-                if(!Directory.Exists(directory))
+                if(!string.IsNullOrEmpty(directory) && !Directory.Exists(directory))
                 {
                     Directory.CreateDirectory(directory);
                 }
@@ -68,4 +68,4 @@ internal static class SettingsHelper
                 .GetValue(settings, null);
         }
     }
-}
+}

AniWorldReminder_API/Classes/UpsertEpisodeInfoJob.cs

@@ -4,7 +4,6 @@ public enum StreamingPortal
     {
         Undefined = 0,
         AniWorld = 1,
-        STO = 2,
-        MegaKino = 3
+        STO = 2
     }
 }

AniWorldReminder_API/Enums/StreamingPortal.cs

@@ -30,9 +30,6 @@ private static IStreamingPortalService CreateService(StreamingPortal streamingPo
                 case StreamingPortal.AniWorld:
                     ILogger<AniWorldService> loggerAniWorld = sp.GetRequiredService<ILogger<AniWorldService>>();
                     return new AniWorldService(loggerAniWorld, httpClientFactory, tmdbService);
-                case StreamingPortal.MegaKino:
-                    ILogger<MegaKinoService> loggerMegaKino = sp.GetRequiredService<ILogger<MegaKinoService>>();
-                    return new MegaKinoService(loggerMegaKino, httpClientFactory, "https://megakino.ws", "MegaKino", streamingPortal);
                 default:
                     throw new NotImplementedException();
             }

AniWorldReminder_API/Factories/StreamingPortalServiceFactory.cs

@@ -4,7 +4,9 @@ public interface IDBService
     {
         Task<bool> InitAsync();
         Task<UserModel?> GetUserByTelegramIdAsync(string telegramChatId);
+        Task<UserModel> InsertUserAsync(string telegramChatId);
         Task<UserModel?> GetUserByUsernameAsync(string username);
+        Task UpdateVerifyTokenAsync(string telegramChatId, string token);
         Task DeleteVerifyTokenAsync(string telegramChatId);
         Task UpdateVerificationStatusAsync(string telegramChatId, VerificationStatus verificationStatus);
         Task SetVerifyStatusAsync(UserModel user);
@@ -16,6 +18,11 @@ public interface IDBService
         Task InsertUsersSeriesAsync(UsersSeriesModel usersSeries);
         Task DeleteUsersSeriesAsync(UsersSeriesModel usersSeries);
         Task<List<UsersSeriesModel>?> GetUsersSeriesAsync(string userId);
+        Task<List<SeriesReminderModel>?> GetUsersReminderSeriesAsync();
+        Task<List<EpisodeModel>?> GetSeriesEpisodesAsync(int seriesId);
+        Task InsertEpisodesAsync(int seriesId, List<EpisodeModel> episodes);
+        Task UpdateEpisodesAsync(int seriesId, List<EpisodeModel> episodes);
+        Task UpdateSeriesInfoAsync(int seriesId, SeriesInfoModel seriesInfo);
         Task<UserWebsiteSettings?> GetUserWebsiteSettings(string userId);
         Task UpdateUserWebsiteSettings(string userId, UserWebsiteSettings userWebsiteSettings);
         Task CreateUserWebsiteSettings(string userId);

AniWorldReminder_API/Interfaces/IDBService.cs

@@ -7,7 +7,8 @@ namespace AniWorldReminder_API.Interfaces
     public interface ITelegramBotService
     {
         Task<bool> Init();
-        Task<Message?> SendMessageAsync(long chatId, string text, bool showLinkPreview = true, ParseMode parseMode = ParseMode.Html, bool silentMessage = false, ReplyKeyboardMarkup? rkm = null);
+        Task<Message?> SendMessageAsync(long chatId, string text, int? replyId = null, bool showLinkPreview = true, ParseMode parseMode = ParseMode.Html, bool silentMessage = false, ReplyKeyboardMarkup? rkm = null);
+        Task SendChatAction(long chatId, ChatAction chatAction);
         Task<Message?> SendPhotoAsync(long chatId, string photoUrl, string? text = null, ParseMode parseMode = ParseMode.Html, bool silentMessage = false);
     }
 }

AniWorldReminder_API/Interfaces/ITelegramBotService.cs

@@ -52,6 +52,24 @@ public static string UrlSanitize(this string text)
             return (!string.IsNullOrEmpty(result), result);
         }
 
+        public static IEnumerable<TEnum> GetFlags<TEnum>(this TEnum value, TEnum ignore = default)
+            where TEnum : struct, Enum
+        {
+            Enum enumValue = (Enum)(object)value;
+            TEnum[] allValues = Enum.GetValues<TEnum>();
+
+            return allValues.Where(flag =>
+            {
+                if (EqualityComparer<TEnum>.Default.Equals(flag, ignore))
+                    return false;
+
+                if (Convert.ToInt64(flag) == 0)
+                    return false;
+
+                return enumValue.HasFlag((Enum)(object)flag);
+            });
+        }
+
         private static Dictionary<Language, string> VOELanguageKeyCollection = new()
         {
             { Language.GerDub, "1"},
@@ -86,6 +104,28 @@ public static string UrlSanitize(this string text)
             return default;
         }
 
+        public static string ToLanguageText(this Language language)
+        {
+            if (language == Language.None)
+                return "None";
+
+            Dictionary<Language, string> languageTextCollection = new()
+            {
+                { Language.GerDub, "GerDub" },
+                { Language.GerSub, "GerSub" },
+                { Language.EngDub, "EngDub" },
+                { Language.EngSub, "EngSub" },
+                { Language.EngDubGerSub, "EngDub + GerSub" }
+            };
+
+            if (languageTextCollection.TryGetValue(language, out string? languageText))
+                return languageText;
+
+            return string.Join(", ", language
+                .GetFlags(Language.None)
+                .Select(flag => languageTextCollection.TryGetValue(flag, out string? text) ? text : flag.ToString()));
+        }
+
         public static string? GetClaim(this HttpContext httpContext, CustomClaimType claimType)
         {
             return httpContext.User.Claims
@@ -98,7 +138,6 @@ public static string UrlSanitize(this string text)
         {
             { "AniWorld", StreamingPortal.AniWorld },
             { "STO", StreamingPortal.STO },
-            { "MegaKino", StreamingPortal.MegaKino },
         };
 
         public static StreamingPortal ToStreamingPortal(this string streamingPortal)

AniWorldReminder_API/Misc/Extensions.cs

@@ -4,8 +4,22 @@ namespace AniWorldReminder_API.Misc
 {
     public static class Helper
     {
+        private const int VerifyTokenLifetimeInMinutes = 10;
+
         public static string GetString(byte[] reason) => Encoding.ASCII.GetString(reason);
         public static byte[] GetBytes(string reason) => Encoding.ASCII.GetBytes(reason);
+        public static string GenerateToken(string telegramChatId)
+        {
+            byte[] time = BitConverter.GetBytes(DateTime.Now.AddMinutes(VerifyTokenLifetimeInMinutes).ToBinary());
+            byte[] key = GetBytes(telegramChatId);
+            byte[] data = new byte[time.Length + key.Length];
+
+            Buffer.BlockCopy(time, 0, data, 0, time.Length);
+            Buffer.BlockCopy(key, 0, data, time.Length, key.Length);
+
+            return Convert.ToBase64String(data);
+        }
+
         public static TokenValidationModel ValidateToken(string token)
         {
             TokenValidationModel result = new();
@@ -27,6 +41,7 @@ public static TokenValidationModel ValidateToken(string token)
             byte[] _key = data.Skip(8).TakeLast(data.Length - 8).ToArray();
 
             DateTime when = DateTime.FromBinary(BitConverter.ToInt64(_time, 0));
+            result.ExpireDate = when;
             if (when < DateTime.Now)
             {
                 result.Errors.Add(TokenValidationStatus.TokenExpired);