Multisig/watchonly wallet transaction creation flow proof of concept

BTCPayServer.Data/ApplicationDbContext.cs

@@ -1,4 +1,6 @@
 using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
@@ -76,6 +78,7 @@ public ApplicationDbContext(DbContextOptions<ApplicationDbContext> options, bool
         public DbSet<LightningAddressData> LightningAddresses { get; set; }
         public DbSet<PayoutProcessorData> PayoutProcessors { get; set; }
         public DbSet<FormData> Forms { get; set; }
+        public DbSet<PendingTransaction> PendingTransactions { get; set; }
 
         protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
         {
@@ -131,6 +134,7 @@ protected override void OnModelCreating(ModelBuilder builder)
             WebhookData.OnModelCreating(builder, Database);
             FormData.OnModelCreating(builder, Database);
             StoreRole.OnModelCreating(builder, Database);
+            PendingTransaction.OnModelCreating(builder, Database);
 
 
             if (Database.IsSqlite() && !_designTime)
@@ -156,4 +160,76 @@ protected override void OnModelCreating(ModelBuilder builder)
         }
     }
 
+
+    public class PendingTransaction: IHasBlob<PendingTransactionBlob>
+    {
+        public string TransactionId { get; set; }
+        public string CryptoCode { get; set; }
+        public string StoreId { get; set; }
+        public StoreData Store { get; set; }
+        public DateTimeOffset? Expiry { get; set; }
+        public PendingTransactionState State { get; set; }
+        public string[] OutpointsUsed { get; set; }
+
+        [NotMapped][Obsolete("Use Blob2 instead")]
+        public byte[] Blob { get; set; }
+
+        public string Blob2 { get; set; }
+
+
+        internal static void OnModelCreating(ModelBuilder builder, DatabaseFacade databaseFacade)
+        {
+            builder.Entity<PendingTransaction>()
+                .HasOne(o => o.Store)
+                .WithMany(i => i.PendingTransactions)
+                .HasForeignKey(i => i.StoreId).OnDelete(DeleteBehavior.Cascade);
+
+            builder.Entity<PendingTransaction>().HasKey(transaction => new {transaction.CryptoCode, transaction.TransactionId});
+
+            if (databaseFacade.IsNpgsql())
+            {
+                builder.Entity<PendingTransaction>()
+                    .Property(o => o.Blob2)
+                    .HasColumnType("JSONB"); 
+                builder.Entity<PendingTransaction>()
+                    .Property(o => o.OutpointsUsed)
+                    .HasColumnType("text[]");
+            }
+            else
+            {
+                builder.Entity<PendingTransaction>()
+                    .Property(e => e.OutpointsUsed)
+                    .HasConversion(
+                        v => string.Join(',', v),
+                        v => v.Split(',', StringSplitOptions.RemoveEmptyEntries));
+            }
+        }
+    }
+    public enum PendingTransactionState
+    {
+        Pending,
+        Cancelled,
+        Expired,
+        Invalidated,
+        Signed,
+        Broadcast
+    }
+
+    public class PendingTransactionBlob
+    {
+        public string PSBT { get; set; }
+        public List<CollectedSignature> CollectedSignatures { get; set; } = new();
+    }
+
+    public class CollectedSignature
+    {
+        public DateTimeOffset Timestamp { get; set; }
+        public string ReceivedPSBT { get; set; }
+
+
+    }
+
+
+
+
 }

BTCPayServer.Data/Data/StoreData.cs

@@ -50,6 +50,8 @@ public class StoreData
         public IEnumerable<StoreRole> StoreRoles { get; set; }
         public bool Archived { get; set; }
 
+        public IEnumerable<PendingTransaction> PendingTransactions{ get; set; }
+
         internal static void OnModelCreating(ModelBuilder builder, DatabaseFacade databaseFacade)
         {
             if (databaseFacade.IsNpgsql())