public record EquityAwardPoolUnits(

    decimal Approved // the total units that have been approved by the board/shareholders

    , decimal Granted // can also be called Allocated

    , decimal Available // Approved - Granted - Cancelled, etc.

    , decimal Cancelled

    , decimal Exercised

    , decimal Surrendered

    , decimal Reserved // In the process of being granted. Should we call this Blocked? Because the units are temporarily blocked 

    );

​

public class EquityAwardPool {

    public string Id { get; set; }

    public IssuerId IssuerId { get; set; }

    public decimal ApprovedUnits { get; set; }

    // but this will be huge

    public EquityAwardTransactionId[] SummarizedTransactions { get; set; }

    public decimal GetSize() => Units.Approved;

}

​

public class EquityAwardPoolSummaryBucket {

    // equityAwardPool/{poolId}

    // equityAwardPlan/{planId}

    // optionAwards

    // shareAwards

    // sarAwards

    // etc.

    public string Id { get; set; }

    public EquityAwardPoolUnits SummaryUnits { get; set; }

}

​

// yet another aggregate

public class EquityAwardPoolSummary {

    public EquityAwardPoolSummaryId Id { get; set; }

    public IssuerId IssuerId { get; set; }

    public EquityAwardPoolSummaryBucket[] SummaryUnits { get; set; }

    public DateTime? LastSummariedTransactionDate { get; set; }

    public

    // Id will be same as PoolId

    public void Summarize(

        IEventStream eventStream

    , EquityAwardTransaction transaction

    ){

        // modify the pool with the transaction information

        if(await tracker.IsSummarized(Id, transaction.Id)){

            // no-op

        }

        if(transaction.Type == "Granted"){

            Apply(new EquityAwardPoolUnitsSummaryChanged(Id, IssuerId, Units, NewUnits, transactionDetails))

        }

    }

}

​

var poolId = new EquityAwardPoolId(10);

var summaryId = new EquityAwardPoolSummaryId(poolId.Value);

​

// ability to mark tra

public interface IEquityPoolTransactionSummaryTracker

{

    // implementation can review all the events on the equity pool and see if

    // the transaction was already summarized

    Task<bool> IsSummarized(EquityAwardPoolId poolId, EquityAwardTransactionId transactionId);

    //Task MarkTransactionAsSummarized(EquityAwardTransaction transaction);

}

​

public class EquityAwardPlan {

    public string Id { get; set; }

    public string? PoolId { get; set; }

}

​

public class IssuerId {

}

​

public class EquityAwardTransaction {

    public string Id { get; set; }

    public IssuerId IssuerId { get; set; }

    public string EquityAwardPoolId { get; set; }

    public string EquityAWardPlanId { get; set; }

    // TODO: Is time relavent here?

    public DateTime Date { get; set; }

    // OptionAward, ShareAward, SARAward, ADR, etc.

    public string InstrumentType { get; set; }

    public string? InstrumentId { get; set; }

    /*

    Granted

    Cancelled

    Deleted??

    OptionAward*

    BonusOptionsCredited

    BonusOptionsReversed

    CancellationReversed, etc.

    */

    public string TransactionType { get; set; }

    /*

    "optionAward/{optionAwardId}",

    "shareAward/{shareAwardId}",

    "sarAward/{sarAwardId}",

    "someOtherAward/{awardId}"

    */

    public string GrantId { get; set; }

    public UnitsTranche[] Units { get; set; }

    public Dictionary<string, string> Properties { get; set ; }

    public class UnitsTranche {

        // TODO:

        public decimal Units { get; set; }

        public string TrancheId { get; set; }

    }

}

​