Safe Haskell	None
Language	Haskell98

Network.Haskoin.Node.Peer

Synopsis

Documentation

minProtocolVersion :: Word32 Source

startPeer :: (MonadLoggerIO m, MonadBaseControl IO m) => PeerHost -> NodeT m () Source

startReconnectPeer :: (MonadLoggerIO m, MonadBaseControl IO m) => PeerHost -> NodeT m () Source

startPeerPid :: (MonadLoggerIO m, MonadBaseControl IO m) => PeerId -> PeerHost -> NodeT m () Source

isPeerHostBanned :: PeerHost -> NodeT STM Bool Source

isPeerHostConnected :: PeerHost -> NodeT STM Bool Source

decodeMessage :: (MonadLoggerIO m, MonadBaseControl IO m) => PeerId -> PeerHost -> Sink ByteString (StateT (Maybe (MerkleBlock, MerkleTxs)) (NodeT m)) () Source

Decode messages sent from the remote host and send them to the peers main message queue for processing. If we receive invalid messages, this function will also notify the PeerManager about a misbehaving remote host.

processMessage :: (MonadLoggerIO m, MonadBaseControl IO m) => PeerId -> PeerHost -> Message -> StateT (Maybe (MerkleBlock, MerkleTxs)) (NodeT m) () Source

processInvMessage :: (MonadLoggerIO m, MonadBaseControl IO m) => PeerId -> PeerHost -> Inv -> NodeT m () Source

encodeMessage :: MonadLoggerIO m => Conduit Message (NodeT m) ByteString Source

Encode message that are being sent to the remote host.

peerPing :: (MonadLoggerIO m, MonadBaseControl IO m) => PeerId -> PeerHost -> NodeT m () Source

isBloomDisabled :: Version -> Bool Source

peerHandshake :: (MonadLoggerIO m, MonadBaseControl IO m) => PeerId -> PeerHost -> TBMChan Message -> NodeT m () Source

waitPeerVersion :: PeerId -> NodeT STM Version Source

disconnectPeer :: MonadLoggerIO m => PeerId -> PeerHost -> NodeT m () Source

waitPeerAvailable :: PeerId -> NodeT STM () Source

waitBloomFilter :: NodeT STM BloomFilter Source

sendBloomFilter :: BloomFilter -> Int -> NodeT STM () Source

getMedianHeight :: NodeT STM BlockHeight Source

updateNetworkHeight :: NodeT STM () Source

getPeers :: NodeT STM [(PeerId, PeerSession)] Source

getConnectedPeers :: NodeT STM [(PeerId, PeerSession)] Source

getPeersAtNetHeight :: NodeT STM [(PeerId, PeerSession)] Source

getPeersAtHeight :: (BlockHeight -> Bool) -> NodeT STM [(PeerId, PeerSession)] Source

trySendMessage :: PeerId -> Message -> NodeT STM Bool Source

sendMessage :: PeerId -> Message -> NodeT STM () Source

sendMessageAll :: Message -> NodeT STM () Source

getNetworkHeight :: NodeT STM BlockHeight Source

misbehaving :: MonadLoggerIO m => PeerId -> PeerHost -> (PeerHostScore -> PeerHostScore) -> String -> NodeT m () Source

raceTimeout Source

Arguments

:: (MonadIO m, MonadBaseControl IO m)
=> Int	Timeout value in seconds
-> m a	Action to run if the main action times out
-> m b	Action to run until the time runs out
-> m (Either a b)

formatPid :: PeerId -> PeerHost -> String -> Text Source