Network.Haskoin.Node.Common

Documentation

type HostPort = (Host, Port)

type Host = String

type Port = Int

data OnlinePeer

Constructors

OnlinePeer

Fields

• onlinePeerAddress :: !SockAddr
• onlinePeerConnected :: !Bool
• onlinePeerVersion :: !Word32
• onlinePeerServices :: !Word64
• onlinePeerRemoteNonce :: !Word64
• onlinePeerUserAgent :: !ByteString
• onlinePeerRelay :: !Bool
• onlinePeerBestBlock :: !BlockNode
• onlinePeerAsync :: !(Async ())
• onlinePeerMailbox :: !Peer
• onlinePeerNonce :: !Word64
• onlinePeerPings :: ![NominalDiffTime]

data UniqueInbox a

Constructors

UniqueInbox

Fields

• uniqueInbox :: Inbox a
• uniqueId :: Unique

Instances

Mailbox UniqueInbox

Defined in Network.Haskoin.Node.Common

Methods

mailboxEmptySTM :: UniqueInbox msg -> STM Bool

sendSTM :: msg -> UniqueInbox msg -> STM ()

receiveSTM :: UniqueInbox msg -> STM msg

requeueMsg :: msg -> UniqueInbox msg -> STM ()

Eq (UniqueInbox a)

Defined in Network.Haskoin.Node.Common

Methods

(==) :: UniqueInbox a -> UniqueInbox a -> Bool

(/=) :: UniqueInbox a -> UniqueInbox a -> Bool

Hashable (UniqueInbox a)

Defined in Network.Haskoin.Node.Common

Methods

hashWithSalt :: Int -> UniqueInbox a -> Int

hash :: UniqueInbox a -> Int

type PeerSupervisor m = Inbox (SupervisorMessage m)

type NodeSupervisor m = Inbox (SupervisorMessage m)

type Peer = UniqueInbox PeerMessage

type Chain = Inbox ChainMessage

type Manager = Inbox ManagerMessage

data NodeConfig m

Constructors

NodeConfig

Fields

• maxPeers :: !Int
• database :: !DB
• initPeers :: ![HostPort]
• discover :: !Bool
• nodeEvents :: !(Listen NodeEvent)
• netAddress :: !NetworkAddress
• nodeSupervisor :: !(NodeSupervisor m)
• nodeChain :: !Chain
• nodeManager :: !Manager
• nodeNet :: !Network

data ManagerConfig m

Constructors

ManagerConfig

Fields

• mgrConfMaxPeers :: !Int
• mgrConfDB :: !DB
• mgrConfPeers :: ![HostPort]
• mgrConfDiscover :: !Bool
• mgrConfMgrListener :: !(Listen ManagerEvent)
• mgrConfPeerListener :: !(Listen (Peer, PeerEvent))
• mgrConfNetAddr :: !NetworkAddress
• mgrConfManager :: !Manager
• mgrConfChain :: !Chain
• mgrConfPeerSupervisor :: !(PeerSupervisor m)
• mgrConfNetwork :: !Network

data NodeEvent

Constructors

ManagerEvent !ManagerEvent

ChainEvent !ChainEvent

PeerEvent !(Peer, PeerEvent)

data ManagerEvent

Constructors

ManagerConnect !Peer

ManagerDisconnect !Peer

data ManagerMessage

Constructors

ManagerSetFilter !BloomFilter

ManagerSetBest !BlockNode

ManagerPing

ManagerGetAddr !Peer

ManagerNewPeers !Peer ![NetworkAddressTime]

ManagerKill !PeerException !Peer

ManagerSetPeerBest !Peer !BlockNode

ManagerGetPeerBest !Peer !(Reply (Maybe BlockNode))

ManagerSetPeerVersion !Peer !Version

ManagerGetPeerVersion !Peer !(Reply (Maybe Word32))

ManagerGetPeers !(Reply [OnlinePeer])

ManagerGetOnlinePeer !Peer !(Reply (Maybe OnlinePeer))

ManagerPeerPing !Peer !NominalDiffTime

PeerStopped !(Async (), Either SomeException ())

data ChainConfig

Constructors

ChainConfig

Fields

• chainConfDB :: !DB
• chainConfListener :: !(Listen ChainEvent)
• chainConfManager :: !Manager
• chainConfChain :: !Chain
• chainConfNetwork :: !Network

data ChainMessage

Constructors

ChainNewHeaders !Peer ![BlockHeaderCount]

ChainNewPeer !Peer

ChainRemovePeer !Peer

ChainGetBest !(BlockNode -> STM ())

ChainGetAncestor !BlockHeight !BlockNode !(Reply (Maybe BlockNode))

ChainGetSplit !BlockNode !BlockNode !(Reply BlockNode)

ChainGetBlock !BlockHash !(Reply (Maybe BlockNode))

ChainNewBlocks !Peer ![BlockHash]

ChainSendHeaders !Peer

ChainIsSynced !(Reply Bool)

data ChainEvent

Constructors

ChainNewBest !BlockNode

ChainSynced !BlockNode

ChainNotSynced !BlockNode

Instances

Eq ChainEvent

Defined in Network.Haskoin.Node.Common

Methods

(==) :: ChainEvent -> ChainEvent -> Bool

(/=) :: ChainEvent -> ChainEvent -> Bool

Show ChainEvent

Defined in Network.Haskoin.Node.Common

Methods

showsPrec :: Int -> ChainEvent -> ShowS

show :: ChainEvent -> String

showList :: [ChainEvent] -> ShowS

data PeerConfig

Constructors

PeerConfig

Fields

• peerConfConnect :: !NetworkAddress
• peerConfInitBest :: !BlockNode
• peerConfLocal :: !NetworkAddress
• peerConfManager :: !Manager
• peerConfChain :: !Chain
• peerConfListener :: !(Listen (Peer, PeerEvent))
• peerConfNonce :: !Word64
• peerConfNetwork :: !Network

data PeerException

Constructors

PeerMisbehaving !String

DecodeMessageError !String

CannotDecodePayload !String

MessageHeaderEmpty

PeerIsMyself

PayloadTooLarge !Word32

PeerAddressInvalid

BloomFiltersNotSupported

PeerSentBadHeaders

NotNetworkPeer

PeerNoSegWit

PeerTimeout

Instances

Eq PeerException

Defined in Network.Haskoin.Node.Common

Methods

(==) :: PeerException -> PeerException -> Bool

(/=) :: PeerException -> PeerException -> Bool

Show PeerException

Defined in Network.Haskoin.Node.Common

Methods

showsPrec :: Int -> PeerException -> ShowS

show :: PeerException -> String

showList :: [PeerException] -> ShowS

Exception PeerException

Defined in Network.Haskoin.Node.Common

Methods

toException :: PeerException -> SomeException

fromException :: SomeException -> Maybe PeerException

displayException :: PeerException -> String

data PeerEvent

Constructors

TxAvail ![TxHash]

GotBlock !Block

GotMerkleBlock !MerkleBlock

GotTx !Tx

GotPong !Word64

SendBlocks !GetBlocks

SendHeaders !GetHeaders

SendData ![InvVector]

TxNotFound !TxHash

BlockNotFound !BlockHash

WantMempool

Rejected !Reject

data PeerMessage

Constructors

PeerOutgoing !Message

PeerIncoming !Message

toSockAddr :: MonadUnliftIO m => HostPort -> m [SockAddr]

fromSockAddr :: MonadUnliftIO m => SockAddr -> m (Maybe HostPort)

computeTime :: MonadIO m => m Word32

myVersion :: Word32

managerSetBest :: MonadIO m => BlockNode -> Manager -> m ()

managerSetPeerVersion :: MonadIO m => Peer -> Version -> Manager -> m ()

managerGetPeerVersion :: MonadIO m => Peer -> Manager -> m (Maybe Word32)

managerGetPeerBest :: MonadIO m => Peer -> Manager -> m (Maybe BlockNode)

managerSetPeerBest :: MonadIO m => Peer -> BlockNode -> Manager -> m ()

managerGetPeers :: MonadIO m => Manager -> m [OnlinePeer]

managerGetPeer :: MonadIO m => Manager -> Peer -> m (Maybe OnlinePeer)

managerGetAddr :: MonadIO m => Peer -> Manager -> m ()

managerKill :: MonadIO m => PeerException -> Peer -> Manager -> m ()

managerNewPeers :: MonadIO m => Peer -> [NetworkAddressTime] -> Manager -> m ()

setManagerFilter :: MonadIO m => BloomFilter -> Manager -> m ()

sendMessage :: MonadIO m => Message -> Peer -> m ()

peerSetFilter :: MonadIO m => BloomFilter -> Peer -> m ()

getMerkleBlocks :: MonadIO m => Peer -> [BlockHash] -> m ()

peerGetBlocks :: MonadIO m => Network -> Peer -> [BlockHash] -> m ()

peerGetTxs :: MonadIO m => Network -> Peer -> [TxHash] -> m ()

buildVersion :: MonadIO m => Network -> Word64 -> BlockHeight -> NetworkAddress -> NetworkAddress -> m Version

chainNewPeer :: MonadIO m => Peer -> Chain -> m ()

chainRemovePeer :: MonadIO m => Peer -> Chain -> m ()

chainGetBlock :: MonadIO m => BlockHash -> Chain -> m (Maybe BlockNode)

chainGetBest :: MonadIO m => Chain -> m BlockNode

chainGetAncestor :: MonadIO m => BlockHeight -> BlockNode -> Chain -> m (Maybe BlockNode)

chainGetParents :: MonadIO m => BlockHeight -> BlockNode -> Chain -> m [BlockNode]

chainGetSplitBlock :: MonadIO m => BlockNode -> BlockNode -> Chain -> m BlockNode

chainBlockMain :: MonadIO m => BlockHash -> Chain -> m Bool

chainIsSynced :: MonadIO m => Chain -> m Bool