Transactional Emails/Transactions/TransactionStore.cs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
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;
        }
    }
}