haskoin-node-0.3.0: Implementation of a Bitoin node.

Safe HaskellNone
LanguageHaskell98

Network.Haskoin.Node.STM

Documentation

type MerkleTxs = [TxHash] Source

type NodeT = ReaderT SharedNodeState Source

type PeerId = Unique Source

type PeerHostScore = Word32 Source

newtype ShowPeerId Source

Constructors

ShowPeerId 

Fields

getShowPeerId :: PeerId
 

Instances

runSql :: MonadBaseControl IO m => SqlPersistT m a -> Either SqlBackend ConnectionPool -> m a Source

runSqlNodeT :: MonadBaseControl IO m => SqlPersistT m a -> NodeT m a Source

getNodeState :: (MonadLoggerIO m, MonadBaseControl IO m) => Either SqlBackend ConnectionPool -> m SharedNodeState Source

runNodeT :: Monad m => NodeT m a -> SharedNodeState -> m a Source

withNodeT :: (MonadLoggerIO m, MonadBaseControl IO m) => NodeT m a -> Either SqlBackend ConnectionPool -> m a Source

atomicallyNodeT :: MonadIO m => NodeT STM a -> NodeT m a Source

data PeerHostSession Source

Constructors

PeerHostSession 

Fields

peerHostSessionScore :: !PeerHostScore
 
peerHostSessionReconnect :: !Int
 
peerHostSessionLog :: ![String]

Important host log messages that should appear in status command

Instances

data SharedNodeState Source

Constructors

SharedNodeState 

Fields

sharedPeerMap :: !(TVar (Map PeerId (TVar PeerSession)))

Map of all active peers and their sessions

sharedHostMap :: !(TVar (Map PeerHost (TVar PeerHostSession)))

The peer that is currently syncing the block headers

sharedNetworkHeight :: !(TVar BlockHeight)

The current height of the network

sharedHeaders :: !(TMVar (PeerId, Headers))

Block headers sent from a peer

sharedHeaderPeer :: !(TVar (Maybe PeerId))

Peer currently syncing headers

sharedMerklePeer :: !(TVar (Maybe PeerId))

Peer currently downloading merkle blocks

sharedSyncLock :: !Lock

Lock on the header syncing process

sharedBestHeader :: !(TVar NodeBlock)

Our best block header

sharedBestBlock :: !(TVar NodeBlock)

Our best merkle block's height

sharedTxGetData :: !(TVar (Map TxHash [(PeerId, PeerHost)]))

List of Tx GetData requests

sharedBloomFilter :: !(TVar (Maybe (BloomFilter, Int)))

Bloom filter

sharedTickleChan :: !(TBMChan (PeerId, PeerHost, BlockHash))

Channel containing all the block tickles received from peers

sharedTxChan :: !(TBMChan (PeerId, PeerHost, Tx))

Transaction channel

sharedRescan :: !(TMVar (Either Timestamp BlockHeight))

Rescan requests from a timestamp or from a block height

sharedMempool :: !(TVar Bool)

Did we do a Mempool sync ?

sharedSqlBackend :: !(Either SqlBackend ConnectionPool)
 

type PingNonce = Word64 Source

data PeerSession Source

Constructors

PeerSession 

Fields

peerSessionConnected :: !Bool

True if the peer is connected (completed the handshake)

peerSessionVersion :: !(Maybe Version)

Contains the version message that we received from the peer

peerSessionHeight :: !BlockHeight

Current known height of the peer

peerSessionChan :: !(TBMChan Message)

Message channel to send messages to the peer

peerSessionHost :: !PeerHost

Host to which this peer is connected

peerSessionThreadId :: !ThreadId

Peer ThreadId

peerSessionMerkleChan :: !(TBMChan (Either (MerkleBlock, MerkleTxs) Tx))

Merkle block/Merkle transaction channel

peerSessionPings :: !(TVar [PingNonce])

Time at which we requested pings

peerSessionScore :: !(Maybe NominalDiffTime)

Ping scores for this peer (round trip times)

Instances

data PeerHost Source

Constructors

PeerHost 

Fields

peerHost :: !String
 
peerPort :: !Int
 

Instances

peerHostString :: PeerHost -> String Source

data PeerStatus Source

Constructors

PeerStatus 

Fields

peerStatusPeerId :: !Int
 
peerStatusHost :: !PeerHost
 
peerStatusConnected :: !Bool
 
peerStatusHeight :: !BlockHeight
 
peerStatusProtocol :: !(Maybe Word32)
 
peerStatusUserAgent :: !(Maybe String)
 
peerStatusPing :: !(Maybe String)
 
peerStatusDoSScore :: !(Maybe PeerHostScore)
 
peerStatusHaveMerkles :: !Bool
 
peerStatusHaveMessage :: !Bool
 
peerStatusPingNonces :: ![PingNonce]
 
peerStatusReconnectTimer :: !(Maybe Int)
 
peerStatusLog :: !(Maybe [String])
 

Instances

ToJSON PeerStatus Source 
FromJSON PeerStatus Source 

data NodeStatus Source

Constructors

NodeStatus 

Fields

nodeStatusPeers :: ![PeerStatus]
 
nodeStatusNetworkHeight :: !BlockHeight
 
nodeStatusBestHeader :: !BlockHash
 
nodeStatusBestHeaderHeight :: !BlockHeight
 
nodeStatusBestBlock :: !BlockHash
 
nodeStatusBestBlockHeight :: !BlockHeight
 
nodeStatusBloomSize :: !Int
 
nodeStatusHeaderPeer :: !(Maybe Int)
 
nodeStatusMerklePeer :: !(Maybe Int)
 
nodeStatusHaveHeaders :: !Bool
 
nodeStatusHaveTickles :: !Bool
 
nodeStatusHaveTxs :: !Bool
 
nodeStatusGetData :: ![TxHash]
 
nodeStatusRescan :: !(Maybe (Either Timestamp BlockHeight))
 
nodeStatusMempool :: !Bool
 
nodeStatusSyncLock :: !Bool
 

Instances

ToJSON NodeStatus Source 
FromJSON NodeStatus Source 

tryGetPeerSession :: PeerId -> NodeT STM (Maybe PeerSession) Source

getPeerSession :: PeerId -> NodeT STM PeerSession Source

newPeerSession :: PeerId -> PeerSession -> NodeT STM () Source

modifyPeerSession :: PeerId -> (PeerSession -> PeerSession) -> NodeT STM () Source

removePeerSession :: PeerId -> NodeT STM (Maybe PeerSession) Source

getHostSession :: PeerHost -> NodeT STM (Maybe PeerHostSession) Source

modifyHostSession :: PeerHost -> (PeerHostSession -> PeerHostSession) -> NodeT STM () Source

newHostSession :: PeerHost -> PeerHostSession -> NodeT STM () Source

bannedScore :: PeerHostScore Source

minorDoS :: PeerHostScore -> PeerHostScore Source

moderateDoS :: PeerHostScore -> PeerHostScore Source

severeDoS :: PeerHostScore -> PeerHostScore Source

isHostScoreBanned :: PeerHostScore -> Bool Source

orElseNodeT :: NodeT STM a -> NodeT STM a -> NodeT STM a Source

readTVarS :: (SharedNodeState -> TVar a) -> NodeT STM a Source

writeTVarS :: (SharedNodeState -> TVar a) -> a -> NodeT STM () Source

takeTMVarS :: (SharedNodeState -> TMVar a) -> NodeT STM a Source

readTMVarS :: (SharedNodeState -> TMVar a) -> NodeT STM a Source

tryReadTMVarS :: (SharedNodeState -> TMVar a) -> NodeT STM (Maybe a) Source

putTMVarS :: (SharedNodeState -> TMVar a) -> a -> NodeT STM () Source

tryPutTMVarS :: (SharedNodeState -> TMVar a) -> a -> NodeT STM Bool Source

swapTMVarS :: (SharedNodeState -> TMVar a) -> a -> NodeT STM () Source

isEmptyTMVarS :: (SharedNodeState -> TMVar a) -> NodeT STM Bool Source

data NodeException Source

Constructors

NodeExceptionBanned 
NodeExceptionConnected 
NodeExceptionInvalidPeer !ShowPeerId 
NodeExceptionPeerNotConnected !ShowPeerId 
NodeException !String 

Instances

isNodeException :: SomeException -> Bool Source

catchAny :: MonadBaseControl IO m => m a -> (SomeException -> m a) -> m a Source

catchAny_ :: MonadBaseControl IO m => m () -> m () Source