Safe Haskell	None
Language	GHC2021

Network.LibP2P.NAT.Relay.Relay

Contents

Types
Configuration
State management
Handlers
Stream bridging
Relay address helpers

Description

Circuit Relay v2 server: manage reservations and bridge streams.

Protocols: libp2pcircuitrelay0.2.0/hop (client ↔ relay)

Provides: - Reservation management (with expiration and limits) - Stream bridging between source and target - Resource limits (max reservations, max circuits, data/duration limits)

Synopsis

data RelayConfig = RelayConfig {
- rcMaxReservations :: !Int
- rcMaxCircuits :: !Int
- rcReservationDuration :: !Word64
- rcDefaultDataLimit :: !Word64
- rcDefaultDurationLimit :: !Word32
}
data RelayState = RelayState {
- rsConfig :: !RelayConfig
- rsReservations :: !(TVar (Map PeerId ActiveReservation))
- rsCircuitCount :: !(TVar Int)
}
data ActiveReservation = ActiveReservation {
- arPeerId :: !PeerId
- arExpiration :: !Word64
}
defaultRelayConfig :: RelayConfig
newRelayState :: RelayConfig -> IO RelayState
handleReserve :: RelayState -> StreamIO -> PeerId -> IO ()
handleConnect :: RelayState -> StreamIO -> PeerId -> HopMessage -> (PeerId -> IO (Maybe StreamIO)) -> IO ()
bridgeStreams :: Maybe RelayLimit -> StreamIO -> StreamIO -> IO ()
buildRelayAddrBytes :: ByteString -> ByteString -> ByteString -> ByteString
isRelayedConnection :: ByteString -> Bool

Types

data RelayConfig Source #

Relay server configuration.

Constructors

RelayConfig
Fields rcMaxReservations :: !Int Max concurrent reservations rcMaxCircuits :: !Int Max concurrent relayed circuits rcReservationDuration :: !Word64 Reservation duration (seconds) rcDefaultDataLimit :: !Word64 Default data limit per circuit (bytes) rcDefaultDurationLimit :: !Word32 Default duration limit per circuit (seconds)

Instances

Instances details

Show RelayConfig Source #
Instance details Defined in Network.LibP2P.NAT.Relay.Relay Methods showsPrec :: Int -> RelayConfig -> ShowS # show :: RelayConfig -> String # showList :: [RelayConfig] -> ShowS #
Eq RelayConfig Source #
Instance details Defined in Network.LibP2P.NAT.Relay.Relay Methods (==) :: RelayConfig -> RelayConfig -> Bool # (/=) :: RelayConfig -> RelayConfig -> Bool #

data RelayState Source #

Mutable relay server state.

Constructors

RelayState
Fields rsConfig :: !RelayConfig rsReservations :: !(TVar (Map PeerId ActiveReservation)) rsCircuitCount :: !(TVar Int)

data ActiveReservation Source #

An active reservation for a peer.

Constructors

ActiveReservation
Fields arPeerId :: !PeerId arExpiration :: !Word64 Unix timestamp

Instances

Instances details

Show ActiveReservation Source #
Instance details Defined in Network.LibP2P.NAT.Relay.Relay Methods showsPrec :: Int -> ActiveReservation -> ShowS # show :: ActiveReservation -> String # showList :: [ActiveReservation] -> ShowS #
Eq ActiveReservation Source #
Instance details Defined in Network.LibP2P.NAT.Relay.Relay Methods (==) :: ActiveReservation -> ActiveReservation -> Bool # (/=) :: ActiveReservation -> ActiveReservation -> Bool #

Configuration

defaultRelayConfig :: RelayConfig Source #

Default relay configuration.

State management

newRelayState :: RelayConfig -> IO RelayState Source #

Create new relay state from configuration.

Handlers

handleReserve :: RelayState -> StreamIO -> PeerId -> IO () Source #

Handle a RESERVE request from a peer.

handleConnect :: RelayState -> StreamIO -> PeerId -> HopMessage -> (PeerId -> IO (Maybe StreamIO)) -> IO () Source #

Handle a CONNECT request from a peer. The openStopStream callback is used to open a stop stream to the target.

Stream bridging

bridgeStreams :: Maybe RelayLimit -> StreamIO -> StreamIO -> IO () Source #

Bridge two streams bidirectionally with optional data/duration limits. Terminates when either direction closes or limits are exceeded.

Relay address helpers

buildRelayAddrBytes :: ByteString -> ByteString -> ByteString -> ByteString Source #

Build a relay multiaddr in binary format. Format: relayAddrp2prelayIdp2p-circuitp2p/targetId

isRelayedConnection :: ByteString -> Bool Source #

Check if raw multiaddr bytes contain P2PCircuit (code 290). Simple heuristic: look for the varint encoding of 290.