Safe Haskell	Safe-Inferred
Language	Haskell2010

Mafoc.Upstream

Contents

Additions to cardano-api
Streaming
Base
Send traces to stdout
Newtypes for file paths
Hard-coded chainpoints
Datum
- Datums from script data
- From TxOut
Orphan instances

Synopsis

type SlotNoBhh = (SlotNo, Hash BlockHeader)
getSecurityParamAndNetworkId :: FilePath -> IO (SecurityParam, NetworkId)
getNetworkId :: FilePath -> IO NetworkId
tipDistance :: BlockInMode mode -> ChainTip -> Natural
newtype UnspecifiedException = UnspecifiedException String
queryCurrentEra :: LocalNodeConnectInfo CardanoMode -> IO AnyCardanoEra
querySecurityParamEra :: LocalNodeConnectInfo CardanoMode -> ShelleyBasedEra era -> IO SecurityParam
querySecurityParam :: LocalNodeConnectInfo CardanoMode -> IO SecurityParam
blockChainPoint :: BlockInMode mode -> ChainPoint
blockNo :: BlockInMode mode -> BlockNo
blockSlotNoBhh :: BlockInMode mode -> SlotNoBhh
blockSlotNo :: BlockInMode mode -> SlotNo
chainPointSlotNo :: ChainPoint -> SlotNo
txoAddressAny :: TxOut ctx era -> AddressAny
toAddressAny :: AddressInEra era -> AddressAny
streamPassReturn :: Monad m => Stream (Of a) m r -> (a -> Stream (Of a) m r -> Stream (Of b) m r) -> Stream (Of b) m r
loopM :: (MonadTrans t1, Monad m, Monad (t1 m)) => Stream (Of t2) m b -> (t2 -> t1 m a) -> t1 m b
foldYield :: Monad m => (st -> a -> m (st, b)) -> st -> Stream (Of a) m r -> Stream (Of b) m r
minusNaturalMaybe :: Natural -> Natural -> Maybe Natural
defaultConfigStderr :: IO Configuration
defaultConfigStderrSeverity :: Severity -> IO Configuration
newtype NodeFolder = NodeFolder FilePath
newtype NodeConfig = NodeConfig FilePath
newtype SocketPath = SocketPath FilePath
lastByron :: SlotNoBhh
lastShelley :: SlotNoBhh
lastAllegra :: SlotNoBhh
lastMary :: SlotNoBhh
lastAlonzo :: SlotNoBhh
data LedgerEra
- = Byron
- | Shelley
- | Allegra
- | Mary
- | Alonzo
- | Babbage
lastBlockOf :: LedgerEra -> Maybe SlotNoBhh
lastChainPointOfPreviousEra :: LedgerEra -> ChainPoint
slotEra :: SlotNo -> LedgerEra
newtype TxIndexInBlock = TxIndexInBlock Word64
allDatums :: Tx era -> [(Hash ScriptData, ScriptData)]
plutusDatums :: [Tx era] -> [(Hash ScriptData, ScriptData)]
txPlutusDatums :: Tx era -> [(Hash ScriptData, ScriptData)]
txAlonzoDatums :: Tx era -> [(DataHash (EraCrypto (ShelleyLedgerEra era)), Data (ShelleyLedgerEra era))]
alonzoTxBodyDatums :: TxBody era -> Map (DataHash (EraCrypto (ShelleyLedgerEra era))) (Data (ShelleyLedgerEra era))
datumFromAlonzo :: Data ledgerera -> (Hash ScriptData, ScriptData)
getFilteredTxOutDatumsFromTxs :: Maybe (Address ShelleyAddr -> Bool) -> [Tx era] -> Map (Hash ScriptData) ScriptData
getFilteredAddressDatumsFromTxs :: Maybe (Address ShelleyAddr -> Bool) -> [Tx era] -> [(AddressAny, Either (Hash ScriptData) (Hash ScriptData, ScriptData))]
txAddressDatums :: Tx era -> [(AddressAny, Either (Hash ScriptData) (Hash ScriptData, ScriptData))]
txDatums :: Tx era -> [Either (Hash ScriptData) (Hash ScriptData, ScriptData)]
maybeDatum :: TxOut CtxTx era -> Maybe (Either (Hash ScriptData) (Hash ScriptData, ScriptData))

Additions to cardano-api

type SlotNoBhh = (SlotNo, Hash BlockHeader) #

getSecurityParamAndNetworkId :: FilePath -> IO (SecurityParam, NetworkId) #

getNetworkId :: FilePath -> IO NetworkId #

tipDistance :: BlockInMode mode -> ChainTip -> Natural #

Query node

newtype UnspecifiedException #

Constructors

UnspecifiedException String

Instances

Instances details

Exception UnspecifiedException #
Instance details Defined in Mafoc.Upstream Methods toException :: UnspecifiedException -> SomeException # fromException :: SomeException -> Maybe UnspecifiedException # displayException :: UnspecifiedException -> String #
Show UnspecifiedException #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> UnspecifiedException -> ShowS # show :: UnspecifiedException -> String # showList :: [UnspecifiedException] -> ShowS #

queryCurrentEra :: LocalNodeConnectInfo CardanoMode -> IO AnyCardanoEra #

Query the current era of the local node's current state.

querySecurityParamEra :: LocalNodeConnectInfo CardanoMode -> ShelleyBasedEra era -> IO SecurityParam #

Query security param from the local node given a Shelley based era.

querySecurityParam :: LocalNodeConnectInfo CardanoMode -> IO SecurityParam #

Block accessors

blockChainPoint :: BlockInMode mode -> ChainPoint #

Create a ChainPoint from BlockInMode

blockNo :: BlockInMode mode -> BlockNo #

blockSlotNoBhh :: BlockInMode mode -> SlotNoBhh #

blockSlotNo :: BlockInMode mode -> SlotNo #

chainPointSlotNo :: ChainPoint -> SlotNo #

txoAddressAny :: TxOut ctx era -> AddressAny #

toAddressAny :: AddressInEra era -> AddressAny #

Labels

TxId

ChainPoint

BlockNo

SlotNo

Block header hash

Streaming

streamPassReturn :: Monad m => Stream (Of a) m r -> (a -> Stream (Of a) m r -> Stream (Of b) m r) -> Stream (Of b) m r #

loopM :: (MonadTrans t1, Monad m, Monad (t1 m)) => Stream (Of t2) m b -> (t2 -> t1 m a) -> t1 m b #

Consume a stream source in a loop and run effect f on it.

foldYield :: Monad m => (st -> a -> m (st, b)) -> st -> Stream (Of a) m r -> Stream (Of b) m r #

Fold a stream of a's, yield a stream of bs, while keeping a state of @st".

Base

minusNaturalMaybe :: Natural -> Natural -> Maybe Natural #

Send traces to stdout

defaultConfigStderr :: IO Configuration #

defaultConfigStderrSeverity :: Severity -> IO Configuration #

Newtypes for file paths

newtype NodeFolder #

Not sure if anyone actually wants these upstreamed

Constructors

NodeFolder FilePath

Instances

Instances details

IsString NodeFolder #
Instance details Defined in Mafoc.Upstream Methods fromString :: String -> NodeFolder #
Show NodeFolder #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> NodeFolder -> ShowS # show :: NodeFolder -> String # showList :: [NodeFolder] -> ShowS #
IsLabel "nodeConfig" (NodeFolder -> NodeConfig) #
Instance details Defined in Mafoc.Upstream Methods fromLabel :: NodeFolder -> NodeConfig #

newtype NodeConfig #

Constructors

NodeConfig FilePath

Instances

Instances details

IsString NodeConfig #
Instance details Defined in Mafoc.Upstream Methods fromString :: String -> NodeConfig #
Show NodeConfig #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> NodeConfig -> ShowS # show :: NodeConfig -> String # showList :: [NodeConfig] -> ShowS #
IsLabel "getNetworkId" (LocalChainsyncConfig NodeConfig -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig NodeConfig -> IO NetworkId #
IsLabel "getNetworkId" (LocalChainsyncConfig_ -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig_ -> IO NetworkId #
IsLabel "getNetworkId" (NodeInfo NodeConfig -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo NodeConfig -> IO NetworkId #
IsLabel "getNetworkId" (NodeConfig -> IO NetworkId) #
Instance details Defined in Mafoc.Upstream Methods fromLabel :: NodeConfig -> IO NetworkId #
IsLabel "nodeConfig" (LocalChainsyncConfig NodeConfig -> NodeConfig) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig NodeConfig -> NodeConfig #
IsLabel "nodeConfig" (NodeInfo NodeConfig -> NodeConfig) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo NodeConfig -> NodeConfig #
IsLabel "nodeConfig" (NodeFolder -> NodeConfig) #
Instance details Defined in Mafoc.Upstream Methods fromLabel :: NodeFolder -> NodeConfig #

newtype SocketPath #

Constructors

SocketPath FilePath

Instances

Instances details

IsString SocketPath #
Instance details Defined in Mafoc.Upstream Methods fromString :: String -> SocketPath #
Show SocketPath #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> SocketPath -> ShowS # show :: SocketPath -> String # showList :: [SocketPath] -> ShowS #
IsLabel "socketPath" (LocalChainsyncConfig a -> SocketPath) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig a -> SocketPath #
IsLabel "socketPath" (NodeInfo a -> SocketPath) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo a -> SocketPath #

Hard-coded chainpoints

lastByron :: SlotNoBhh #

Shamelessly stolen from Kupo's docs https://cardanosolutions.github.io/kupo/#section/Era-boundaries

lastShelley :: SlotNoBhh #

Shamelessly stolen from Kupo's docs https://cardanosolutions.github.io/kupo/#section/Era-boundaries

lastAllegra :: SlotNoBhh #

Shamelessly stolen from Kupo's docs https://cardanosolutions.github.io/kupo/#section/Era-boundaries

lastMary :: SlotNoBhh #

Shamelessly stolen from Kupo's docs https://cardanosolutions.github.io/kupo/#section/Era-boundaries

lastAlonzo :: SlotNoBhh #

Shamelessly stolen from Kupo's docs https://cardanosolutions.github.io/kupo/#section/Era-boundaries

data LedgerEra #

Constructors

Byron
Shelley
Allegra
Mary
Alonzo
Babbage

Instances

Instances details

ToJSON LedgerEra #
Instance details Defined in Mafoc.Upstream Methods toJSON :: LedgerEra -> Value toEncoding :: LedgerEra -> Encoding toJSONList :: [LedgerEra] -> Value toEncodingList :: [LedgerEra] -> Encoding
Bounded LedgerEra #
Instance details Defined in Mafoc.Upstream Methods minBound :: LedgerEra # maxBound :: LedgerEra #
Enum LedgerEra #
Instance details Defined in Mafoc.Upstream Methods succ :: LedgerEra -> LedgerEra # pred :: LedgerEra -> LedgerEra # toEnum :: Int -> LedgerEra # fromEnum :: LedgerEra -> Int # enumFrom :: LedgerEra -> [LedgerEra] # enumFromThen :: LedgerEra -> LedgerEra -> [LedgerEra] # enumFromTo :: LedgerEra -> LedgerEra -> [LedgerEra] # enumFromThenTo :: LedgerEra -> LedgerEra -> LedgerEra -> [LedgerEra] #
Generic LedgerEra #
Instance details Defined in Mafoc.Upstream Associated Types type Rep LedgerEra :: Type -> Type # Methods from :: LedgerEra -> Rep LedgerEra x # to :: Rep LedgerEra x -> LedgerEra #
Show LedgerEra #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> LedgerEra -> ShowS # show :: LedgerEra -> String # showList :: [LedgerEra] -> ShowS #
Eq LedgerEra #
Instance details Defined in Mafoc.Upstream Methods (==) :: LedgerEra -> LedgerEra -> Bool # (/=) :: LedgerEra -> LedgerEra -> Bool #
Ord LedgerEra #
Instance details Defined in Mafoc.Upstream Methods compare :: LedgerEra -> LedgerEra -> Ordering # (<) :: LedgerEra -> LedgerEra -> Bool # (<=) :: LedgerEra -> LedgerEra -> Bool # (>) :: LedgerEra -> LedgerEra -> Bool # (>=) :: LedgerEra -> LedgerEra -> Bool # max :: LedgerEra -> LedgerEra -> LedgerEra # min :: LedgerEra -> LedgerEra -> LedgerEra #
type Rep LedgerEra #
Instance details Defined in Mafoc.Upstream type Rep LedgerEra = D1 ('MetaData "LedgerEra" "Mafoc.Upstream" "mafoc-0.0.0.1-inplace" 'False) ((C1 ('MetaCons "Byron" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "Shelley" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Allegra" 'PrefixI 'False) (U1 :: Type -> Type))) :+: (C1 ('MetaCons "Mary" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "Alonzo" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Babbage" 'PrefixI 'False) (U1 :: Type -> Type))))

lastBlockOf :: LedgerEra -> Maybe SlotNoBhh #

lastChainPointOfPreviousEra :: LedgerEra -> ChainPoint #

slotEra :: SlotNo -> LedgerEra #

newtype TxIndexInBlock #

Constructors

TxIndexInBlock Word64

Instances

Instances details

FromJSON TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods parseJSON :: Value -> Parser TxIndexInBlock parseJSONList :: Value -> Parser [TxIndexInBlock]
ToJSON TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods toJSON :: TxIndexInBlock -> Value toEncoding :: TxIndexInBlock -> Encoding toJSONList :: [TxIndexInBlock] -> Value toEncodingList :: [TxIndexInBlock] -> Encoding
Enum TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods succ :: TxIndexInBlock -> TxIndexInBlock # pred :: TxIndexInBlock -> TxIndexInBlock # toEnum :: Int -> TxIndexInBlock # fromEnum :: TxIndexInBlock -> Int # enumFrom :: TxIndexInBlock -> [TxIndexInBlock] # enumFromThen :: TxIndexInBlock -> TxIndexInBlock -> [TxIndexInBlock] # enumFromTo :: TxIndexInBlock -> TxIndexInBlock -> [TxIndexInBlock] # enumFromThenTo :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock -> [TxIndexInBlock] #
Num TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods (+) :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock # (-) :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock # (*) :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock # negate :: TxIndexInBlock -> TxIndexInBlock # abs :: TxIndexInBlock -> TxIndexInBlock # signum :: TxIndexInBlock -> TxIndexInBlock # fromInteger :: Integer -> TxIndexInBlock #
Show TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> TxIndexInBlock -> ShowS # show :: TxIndexInBlock -> String # showList :: [TxIndexInBlock] -> ShowS #
FromCBOR TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods fromCBOR :: Decoder s TxIndexInBlock label :: Proxy TxIndexInBlock -> Text
ToCBOR TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods toCBOR :: TxIndexInBlock -> Encoding encodedSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy TxIndexInBlock -> Size encodedListSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy [TxIndexInBlock] -> Size
Eq TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods (==) :: TxIndexInBlock -> TxIndexInBlock -> Bool # (/=) :: TxIndexInBlock -> TxIndexInBlock -> Bool #
Ord TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods compare :: TxIndexInBlock -> TxIndexInBlock -> Ordering # (<) :: TxIndexInBlock -> TxIndexInBlock -> Bool # (<=) :: TxIndexInBlock -> TxIndexInBlock -> Bool # (>) :: TxIndexInBlock -> TxIndexInBlock -> Bool # (>=) :: TxIndexInBlock -> TxIndexInBlock -> Bool # max :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock # min :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock #
FromField TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods fromField :: FieldParser TxIndexInBlock
ToField TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods toField :: TxIndexInBlock -> SQLData

Datum

allDatums :: Tx era -> [(Hash ScriptData, ScriptData)] #

Datums from script data

plutusDatums :: [Tx era] -> [(Hash ScriptData, ScriptData)] #

Get a map of datum hash to datum from a list of transactions.

txPlutusDatums :: Tx era -> [(Hash ScriptData, ScriptData)] #

txAlonzoDatums :: Tx era -> [(DataHash (EraCrypto (ShelleyLedgerEra era)), Data (ShelleyLedgerEra era))] #

alonzoTxBodyDatums :: TxBody era -> Map (DataHash (EraCrypto (ShelleyLedgerEra era))) (Data (ShelleyLedgerEra era)) #

datumFromAlonzo :: Data ledgerera -> (Hash ScriptData, ScriptData) #

From TxOut

getFilteredTxOutDatumsFromTxs :: Maybe (Address ShelleyAddr -> Bool) -> [Tx era] -> Map (Hash ScriptData) ScriptData #

getFilteredAddressDatumsFromTxs :: Maybe (Address ShelleyAddr -> Bool) -> [Tx era] -> [(AddressAny, Either (Hash ScriptData) (Hash ScriptData, ScriptData))] #

txAddressDatums :: Tx era -> [(AddressAny, Either (Hash ScriptData) (Hash ScriptData, ScriptData))] #

txDatums :: Tx era -> [Either (Hash ScriptData) (Hash ScriptData, ScriptData)] #

maybeDatum :: TxOut CtxTx era -> Maybe (Either (Hash ScriptData) (Hash ScriptData, ScriptData)) #

Orphan instances

Exception AcquiringFailure #
Instance details Methods toException :: AcquiringFailure -> SomeException # fromException :: SomeException -> Maybe AcquiringFailure # displayException :: AcquiringFailure -> String #
Exception EraMismatch #
Instance details Methods toException :: EraMismatch -> SomeException # fromException :: SomeException -> Maybe EraMismatch # displayException :: EraMismatch -> String #
Ord ChainTip #
Instance details Methods compare :: ChainTip -> ChainTip -> Ordering # (<) :: ChainTip -> ChainTip -> Bool # (<=) :: ChainTip -> ChainTip -> Bool # (>) :: ChainTip -> ChainTip -> Bool # (>=) :: ChainTip -> ChainTip -> Bool # max :: ChainTip -> ChainTip -> ChainTip # min :: ChainTip -> ChainTip -> ChainTip #
IsLabel "blockHeaderHash" (Block era -> Hash BlockHeader) #
Instance details Methods fromLabel :: Block era -> Hash BlockHeader #
IsLabel "blockHeaderHash" (BlockHeader -> Hash BlockHeader) #
Instance details Methods fromLabel :: BlockHeader -> Hash BlockHeader #
IsLabel "blockHeaderHash" (BlockInMode era -> Hash BlockHeader) #
Instance details Methods fromLabel :: BlockInMode era -> Hash BlockHeader #
IsLabel "blockNo" (Block era -> BlockNo) #
Instance details Methods fromLabel :: Block era -> BlockNo #
IsLabel "blockNo" (BlockHeader -> BlockNo) #
Instance details Methods fromLabel :: BlockHeader -> BlockNo #
IsLabel "blockNo" (BlockInMode mode -> BlockNo) #
Instance details Methods fromLabel :: BlockInMode mode -> BlockNo #
IsLabel "calculateTxId" (Tx era -> TxId) #
Instance details Methods fromLabel :: Tx era -> TxId #
IsLabel "calculateTxId" (TxBody era -> TxId) #	We say calculate because transaction body is actually hashed.
Instance details Methods fromLabel :: TxBody era -> TxId #
IsLabel "chainPoint" (Block era -> ChainPoint) #
Instance details Methods fromLabel :: Block era -> ChainPoint #
IsLabel "chainPoint" (BlockHeader -> ChainPoint) #
Instance details Methods fromLabel :: BlockHeader -> ChainPoint #
IsLabel "chainPoint" (BlockInMode era -> ChainPoint) #
Instance details Methods fromLabel :: BlockInMode era -> ChainPoint #
IsLabel "chainPoint" (SlotNoBhh -> ChainPoint) #
Instance details Methods fromLabel :: SlotNoBhh -> ChainPoint #
IsLabel "slotNo" (Either SlotNo ChainPoint -> SlotNo) #
Instance details Methods fromLabel :: Either SlotNo ChainPoint -> SlotNo #
IsLabel "slotNo" (Block era -> SlotNo) #
Instance details Methods fromLabel :: Block era -> SlotNo #
IsLabel "slotNo" (BlockHeader -> SlotNo) #
Instance details Methods fromLabel :: BlockHeader -> SlotNo #
IsLabel "slotNo" (BlockInMode era -> SlotNo) #
Instance details Methods fromLabel :: BlockInMode era -> SlotNo #
IsLabel "slotNo" (ChainPoint -> SlotNo) #
Instance details Methods fromLabel :: ChainPoint -> SlotNo #
IsLabel "slotNo" (ChainTip -> SlotNo) #
Instance details Methods fromLabel :: ChainTip -> SlotNo #
IsLabel "slotNo" (SlotNoBhh -> SlotNo) #
Instance details Methods fromLabel :: SlotNoBhh -> SlotNo #
IsLabel "slotNoBhh" (Block era -> SlotNoBhh) #
Instance details Methods fromLabel :: Block era -> SlotNoBhh #
IsLabel "slotNoBhh" (BlockHeader -> SlotNoBhh) #
Instance details Methods fromLabel :: BlockHeader -> SlotNoBhh #
IsLabel "slotNoBhh" (BlockInMode era -> SlotNoBhh) #
Instance details Methods fromLabel :: BlockInMode era -> SlotNoBhh #