TransactionModule.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Events;
using Waher.Runtime.Inventory;
 
namespace Waher.Runtime.Transactions
{
    [Singleton]
    public class TransactionModule : IModule
    {
        private readonly static List<ITransactions> transactions = new List<ITransactions>();
        private static bool running = false;
 
        public TransactionModule()
        {
        }
 
        public static void Register(ITransactions Transactions)
        {
            lock (transactions)
            {
                if (!transactions.Contains(Transactions))
                    transactions.Add(Transactions);
            }
        }
 
        public static bool Unregister(ITransactions Transactions)
        {
            lock (transactions)
            {
                return transactions.Remove(Transactions);
            }
        }
 
        public static bool Running => running;
 
        public Task Start()
        {
            running = true;
            return Task.CompletedTask;
        }
 
        public async Task Stop()
        {
            ITransactions[] Collections;
 
            running = false;
 
            lock (transactions)
            {
                Collections = transactions.ToArray();
                transactions.Clear();
            }
 
            foreach (ITransactions Transactions in Collections)
            {
                try
                {
                    ITransaction[] Pending = await Transactions.GetTransactions();
 
                    foreach (ITransaction T in Pending)
                    {
                        try
                        {
                            await T.Abort();
                        }
                        catch (Exception ex)
                        {
                            Log.Exception(ex);
                        }
                    }
 
                    Transactions.Dispose();
                }
                catch (Exception ex)
                {
                    Log.Exception(ex);
                }
            }
        }
 
    }
}