#nullable enable
using System;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
using System.Linq;
using System.Threading.Tasks;
using BTCPayServer.Data.Subscriptions;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Infrastructure;
using Newtonsoft.Json.Linq;

namespace BTCPayServer.Data;

[Table("email_rules")]
public class EmailRuleData : BaseEntityData
{
    public static string GetWebhookTriggerName(string webhookType) => $"WH-{webhookType}";
    [Column("store_id")]
    public string? StoreId { get; set; }
    [Column("offering_id")]
    public string? OfferingId { get; set; }

    [ForeignKey(nameof(OfferingId))]
    public OfferingData? Offering { get; set; }

    [Key]
    public long Id { get; set; }

    [ForeignKey(nameof(StoreId))]
    public StoreData? Store { get; set; }

    [Required]
    [Column("trigger")]
    public string Trigger { get; set; }  = null!;

    [Column("condition")]
    public string? Condition { get; set; }

    [Required]
    [Column("to")]
    public string[] To { get; set; }  = null!;
    [Required]
    [Column("cc")]
    public string[] CC { get; set; }  = [];
    [Required]
    [Column("bcc")]
    public string[] BCC { get; set; }  = [];

    [Required]
    [Column("subject")]
    public string Subject { get; set; } = null!;
    [Required]
    [Column("body")]
    public string Body { get; set; }  = null!;

    public class BTCPayAdditionalData
    {
        public bool CustomerEmail { get; set; }
    }
    public BTCPayAdditionalData? GetBTCPayAdditionalData() => this.GetAdditionalData<BTCPayAdditionalData>("btcpay");
    [Obsolete("Avoid using this method, if another plugin is modifying additional data at the same time, it would overwrite the changes. Only use if you can ensure that no other plugin is modifying the data at the same time to avoid race conditions.")]
    public void SetBTCPayAdditionalData(BTCPayAdditionalData? data) => this.SetAdditionalData("btcpay", data);

    internal static void OnModelCreating(ModelBuilder builder, DatabaseFacade databaseFacade)
    {
        var b = builder.Entity<EmailRuleData>();
        BaseEntityData.OnModelCreateBase(b, builder, databaseFacade);
        b.Property(o => o.Id).UseIdentityAlwaysColumn();
        b.HasOne(o => o.Offering).WithMany().OnDelete(DeleteBehavior.Cascade);
        b.HasOne(o => o.Store).WithMany().OnDelete(DeleteBehavior.Cascade);
        b.HasIndex(o => o.StoreId);
    }
}
public static partial class ApplicationDbContextExtensions
{
    public static IQueryable<EmailRuleData> GetRules(this IQueryable<EmailRuleData> query, string storeId)
    => query.Where(o => o.StoreId == storeId)
            .OrderBy(o => o.Id);
    public static IQueryable<EmailRuleData> GetServerRules(this IQueryable<EmailRuleData> query)
        => query.Where(o => o.StoreId == null).OrderBy(o => o.Id);

    public static Task<EmailRuleData[]> GetMatches(this DbSet<EmailRuleData> set, string? storeId, string trigger, JObject model)
    =>
        storeId is null
        ? set
            .FromSqlInterpolated($"""
                                  SELECT * FROM email_rules
                                  WHERE store_id IS NULL AND trigger = {trigger} AND (condition IS NULL OR jsonb_path_exists({model.ToString()}::JSONB, condition::JSONPATH))
                                  """)
            .ToArrayAsync()
        : set
            .FromSqlInterpolated($"""
                                  SELECT * FROM email_rules
                                  WHERE store_id = {storeId} AND trigger = {trigger} AND (condition IS NULL OR jsonb_path_exists({model.ToString()}::JSONB, condition::JSONPATH))
                                  """)
            .ToArrayAsync();

    public static Task<EmailRuleData?> GetRule(this IQueryable<EmailRuleData> query, string storeId, long id)
        => query.Where(o => o.StoreId == storeId && o.Id == id)
            .FirstOrDefaultAsync();
    public static Task<EmailRuleData?> GetServerRule(this IQueryable<EmailRuleData> query, long id)
        => query.Where(o => o.StoreId == null && o.Id == id)
            .FirstOrDefaultAsync();
}