module ProjectM36.Transaction where
import ProjectM36.Base
import qualified Data.Set as S
import qualified Data.UUID as U
import Data.Time.Clock
import qualified Data.List.NonEmpty as NE
parentIds :: Transaction -> S.Set TransactionId
parentIds (Transaction _ tinfo _) = S.fromList (NE.toList (parents tinfo))
rootParent :: TransactionParents
rootParent = singleParent U.nil
singleParent :: TransactionId -> TransactionParents
singleParent tid = tid NE.:| []
filterTransactionInfoTransactions :: S.Set TransactionId -> TransactionInfo -> TransactionInfo
filterTransactionInfoTransactions filterIds tinfo =
tinfo { parents = case
NE.filter (`S.member` filterIds) (parents tinfo) of
[] -> rootParent
xs -> NE.fromList xs}
filterParent :: TransactionId -> S.Set TransactionId -> TransactionId
filterParent parentId validIds = if S.member parentId validIds then parentId else U.nil
filterTransaction :: S.Set TransactionId -> Transaction -> Transaction
filterTransaction filterIds (Transaction selfId tInfo context) = Transaction selfId (filterTransactionInfoTransactions filterIds tInfo) context
concreteDatabaseContext :: Transaction -> DatabaseContext
concreteDatabaseContext (Transaction _ _ (Schemas context _)) = context
schemas :: Transaction -> Schemas
schemas (Transaction _ _ schemas') = schemas'
subschemas :: Transaction -> Subschemas
subschemas (Transaction _ _ (Schemas _ sschemas)) = sschemas
fresh :: TransactionId -> UTCTime -> Schemas -> Transaction
fresh freshId stamp' = Transaction freshId tinfo
where
tinfo = TransactionInfo {parents = rootParent,
stamp = stamp',
merkleHash = mempty
}
timestamp :: Transaction -> UTCTime
timestamp (Transaction _ tinfo _) = stamp tinfo