Initial mini-protocols for Peras

cabal.project

@@ -18,7 +18,7 @@ index-state:
   , hackage.haskell.org 2025-08-05T15:28:56Z
 
   -- Bump this if you need newer packages from CHaP
-  , cardano-haskell-packages 2025-03-18T17:41:11Z
+  , cardano-haskell-packages 2025-09-11T16:20:37Z
 
 packages: ./cardano-ping
           ./monoidal-synchronisation

ouroboros-network-api/changelog.d/20250929_093633_alexander.esgen_peras_diffusion.md

@@ -0,0 +1,7 @@
+### Breaking
+
+- Added `NodeToNodeV_16`.
+
+### Non-Breaking
+
+- Added `isPerasEnabled` predicate.

ouroboros-network-api/ouroboros-network-api.cabal

@@ -59,6 +59,7 @@ library
     base >=4.14 && <4.22,
     base16-bytestring,
     bytestring >=0.10 && <0.13,
+    cardano-base,
     cardano-binary,
     cardano-slotting,
     cardano-strict-containers,

ouroboros-network-api/src/Ouroboros/Network/NodeToNode/Version.hs

@@ -10,13 +10,18 @@ module Ouroboros.Network.NodeToNode.Version
   , ConnectionMode (..)
   , nodeToNodeVersionCodec
   , nodeToNodeCodecCBORTerm
+    -- * Feature predicates
+  , isPerasEnabled
   ) where
 
+import Data.Set (Set)
+import Data.Set qualified as Set
 import Data.Text (Text)
 import Data.Text qualified as T
 
 import Codec.CBOR.Term qualified as CBOR
 
+import Cardano.Base.FeatureFlags
 import Control.DeepSeq
 import GHC.Generics
 import NoThunks.Class (NoThunks)
@@ -71,16 +76,22 @@ data NodeToNodeVersion =
     -- ^ Plomin HF, mandatory on mainnet as of 2025.01.29
   | NodeToNodeV_15
     -- ^ SRV support
+  | NodeToNodeV_16
+    -- ^ Experimental.
+    --
+    -- Adds Peras mini-protocols (if 'PerasFlag' is set).
   deriving (Eq, Ord, Enum, Bounded, Show, Generic, NFData, NoThunks)
 
 nodeToNodeVersionCodec :: CodecCBORTerm (Text, Maybe Int) NodeToNodeVersion
 nodeToNodeVersionCodec = CodecCBORTerm { encodeTerm, decodeTerm }
   where
     encodeTerm NodeToNodeV_14 = CBOR.TInt 14
     encodeTerm NodeToNodeV_15 = CBOR.TInt 15
+    encodeTerm NodeToNodeV_16 = CBOR.TInt 16
 
     decodeTerm (CBOR.TInt 14) = Right NodeToNodeV_14
     decodeTerm (CBOR.TInt 15) = Right NodeToNodeV_15
+    decodeTerm (CBOR.TInt 16) = Right NodeToNodeV_16
     decodeTerm (CBOR.TInt n) = Left ( T.pack "decode NodeToNodeVersion: unknown tag: "
                                         <> T.pack (show n)
                                     , Just n
@@ -148,6 +159,7 @@ nodeToNodeCodecCBORTerm =
     \case
       NodeToNodeV_14 -> codec
       NodeToNodeV_15 -> codec
+      NodeToNodeV_16 -> codec
   where
     codec = CodecCBORTerm { encodeTerm = encodeTerm, decodeTerm = decodeTerm }
 
@@ -190,3 +202,8 @@ nodeToNodeCodecCBORTerm =
 
 
 data ConnectionMode = UnidirectionalMode | DuplexMode
+
+isPerasEnabled :: Set CardanoFeatureFlag -> NodeToNodeVersion -> Bool
+isPerasEnabled featureFlags v =
+       Set.member PerasFlag featureFlags
+    && v >= NodeToNodeV_16

ouroboros-network-protocols/cddl/specs/handshake-node-to-node-v14.cddl

@@ -15,7 +15,7 @@ msgQueryReply      = [3, versionTable]
 ; The codec only accepts definite-length maps.
 versionTable = { * versionNumber_v14 => v14.nodeToNodeVersionData }
 
-versionNumber_v14 = 14 / 15
+versionNumber_v14 = 14 / 15 / 16
 
 ; All version numbers
 versionNumbers = versionNumber_v14

ouroboros-network-protocols/changelog.d/20250929_093859_alexander.esgen_peras_diffusion.md

@@ -0,0 +1,3 @@
+### Non-Breaking
+
+- Added ObjectDiffusion mini-protocol for Ouroboros Peras.

ouroboros-network-protocols/ouroboros-network-protocols.cabal

@@ -62,6 +62,10 @@ library
     Ouroboros.Network.Protocol.LocalTxSubmission.Codec
     Ouroboros.Network.Protocol.LocalTxSubmission.Server
     Ouroboros.Network.Protocol.LocalTxSubmission.Type
+    Ouroboros.Network.Protocol.ObjectDiffusion.Codec
+    Ouroboros.Network.Protocol.ObjectDiffusion.Inbound
+    Ouroboros.Network.Protocol.ObjectDiffusion.Outbound
+    Ouroboros.Network.Protocol.ObjectDiffusion.Type
     Ouroboros.Network.Protocol.PeerSharing.Client
     Ouroboros.Network.Protocol.PeerSharing.Codec
     Ouroboros.Network.Protocol.PeerSharing.Server
@@ -161,6 +165,7 @@ library testlib
     Ouroboros.Network.Protocol.LocalTxSubmission.Direct
     Ouroboros.Network.Protocol.LocalTxSubmission.Examples
     Ouroboros.Network.Protocol.LocalTxSubmission.Test
+    Ouroboros.Network.Protocol.ObjectDiffusion.Test
     Ouroboros.Network.Protocol.PeerSharing.Codec.CDDL
     Ouroboros.Network.Protocol.PeerSharing.Direct
     Ouroboros.Network.Protocol.PeerSharing.Examples