Initial commit

1 files changed, 50 insertions, 0 deletions

diff --git a/Transactional Emails/Transactions/TransactionStore.cs b/Transactional Emails/Transactions/TransactionStore.cs
new file mode 100644
index 0000000..9a700ae
--- /dev/null
+++ b/Transactional Emails/Transactions/TransactionStore.cs
@@ -0,0 +1,50 @@
+using System;
+using System.Linq;
+
+using Microsoft.EntityFrameworkCore;
+
+using VNLib.Plugins.Extensions.Data;
+
+namespace Emails.Transactional.Transactions
+{
+
+    internal class TransactionStore : DbStore<EmailTransaction>
+    {
+        private readonly DbContextOptions Options;
+
+        public TransactionStore(DbContextOptions options)
+        {
+            Options = options;
+        }
+
+        public override TransactionalDbContext NewContext() => new EmailDbCtx(Options);
+        
+        public override string RecordIdBuilder => Guid.NewGuid().ToString("N");
+
+        protected override void OnRecordUpdate(EmailTransaction newRecord, EmailTransaction oldRecord)
+        {
+            oldRecord.LastModified = DateTime.UtcNow;
+        }
+       
+        protected override IQueryable<EmailTransaction> GetCollectionQueryBuilder(TransactionalDbContext context, params string[] constraints)
+        {
+            string userId = constraints[0];
+            //Get the last transactions for the specifed user
+            EmailDbCtx ctx = context as EmailDbCtx;
+            return  from trans in ctx.EmailTransactions
+                    where trans.UserId == userId
+                    orderby trans.LastModified descending
+                    select trans;
+        }
+
+        protected override IQueryable<EmailTransaction> GetSingleQueryBuilder(TransactionalDbContext context, params string[] constraints)
+        {
+            string transactionid = constraints[0];
+            EmailDbCtx ctx = context as EmailDbCtx;
+            //Selet the exact transaction from its id
+            return from trans in ctx.EmailTransactions
+                   where trans.Id == transactionid
+                   select trans;
+        }
+    }
+}