switch to mongo fw

backend/ZiziBot.Application/Handlers/RestApis/Webhook/PostWebhookPayloadRequest.cs

@@ -1,12 +1,11 @@
 using System.Diagnostics;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Logging;
+using MongoFramework.Linq;
 using Telegram.Bot;
 using Telegram.Bot.Types;
 using Telegram.Bot.Types.Enums;
 using ZiziBot.DataSource.MongoDb.Entities;
-using ZiziBot.DataSource.MongoEf;
-using ZiziBot.DataSource.MongoEf.Entities;
 
 namespace ZiziBot.Application.Handlers.RestApis.Webhook;
 
@@ -39,7 +38,6 @@ public class PostWebhookPayloadHandler(
     IMediator mediator,
     MediatorService mediatorService,
     MongoDbContextBase mongoDbContextBase,
-    MongoEfContext mongoEfContext,
     WebhookService webhookService,
     AppSettingRepository appSettingRepository,
     ChatSettingRepository chatSettingRepository,
@@ -128,7 +126,7 @@ CancellationToken cancellationToken
             }
         }
 
-        mongoEfContext.WebhookHistory.Add(new WebhookHistoryEntity {
+        mongoDbContextBase.WebhookHistory.Add(new WebhookHistoryEntity {
             RouteId = webhookChat.RouteId,
             TransactionId = $"{request.TransactionId}",
             ChatId = webhookChat.ChatId,
@@ -137,10 +135,10 @@ CancellationToken cancellationToken
             Elapsed = stopwatch.Elapsed,
             Payload = request.IsDebug ? content : string.Empty,
             Header = request.IsDebug ? webhookHeader : default,
-            Status = EventStatus.Complete
+            Status = (int)EventStatus.Complete
         });
 
-        await mongoEfContext.SaveChangesAsync(cancellationToken);
+        await mongoDbContextBase.SaveChangesAsync(cancellationToken);
 
         mongoDbContextBase.ChatActivity.Add(new ChatActivityEntity {
             ActivityType = ChatActivityType.BotSentWebHook,

backend/ZiziBot.DataSource/MongoDb/Entities/WebhookHistoryEntity.cs

@@ -0,0 +1,16 @@
+using ZiziBot.Types.Types;
+
+namespace ZiziBot.DataSource.MongoDb.Entities;
+
+[Table("WebhookHistory")]
+public class WebhookHistoryEntity : EntityBase
+{
+    public string RouteId { get; set; }
+    public long ChatId { get; set; }
+    public int MessageId { get; set; }
+    public int MessageThreadId { get; set; }
+    public WebhookSource WebhookSource { get; set; }
+    public TimeSpan Elapsed { get; set; }
+    public WebhookHeader? Header { get; set; }
+    public string? Payload { get; set; }
+}

backend/ZiziBot.DataSource/MongoDb/MongoDbContextBase.cs

@@ -40,7 +40,9 @@ public class MongoDbContextBase : MongoDbContext
     public MongoDbSet<NoteEntity> Note { get; set; }
     public MongoDbSet<RssSettingEntity> RssSetting { get; set; }
     public MongoDbSet<RssHistoryEntity> RssHistory { get; set; }
+
     public MongoDbSet<WebhookChatEntity> WebhookChat { get; set; }
+    public MongoDbSet<WebhookHistoryEntity> WebhookHistory { get; set; }
 
     public MongoDbSet<WordFilterEntity> WordFilter { get; set; }
 

backend/ZiziBot.DataSource/MongoEf/Entities/WebhookHistoryEntity.cs

@@ -1,15 +1,17 @@
 using MongoDB.EntityFrameworkCore;
+using ZiziBot.Types.Types;
 
 namespace ZiziBot.DataSource.MongoEf.Entities;
 
 [Collection("WebhookHistory")]
 public class WebhookHistoryEntity : EntityBase
 {
-    public required string RouteId { get; set; }
-    public required long ChatId { get; set; }
-    public required int MessageId { get; set; }
+    public string RouteId { get; set; }
+    public long ChatId { get; set; }
+    public int MessageId { get; set; }
     public int MessageThreadId { get; set; }
-    public required WebhookSource WebhookSource { get; set; }
+    public WebhookSource WebhookSource { get; set; }
     public TimeSpan Elapsed { get; set; }
-    public required string Payload { get; set; }
+    public WebhookHeader? Header { get; set; }
+    public string? Payload { get; set; }
 }