Skip to content

Commit 7653cbe

Browse files
committed
ouroboros-network-api: RemtoeAddress encoding
Polymorphic over version, we need it in both `dmq-node` and `cardano-diffusion`.
1 parent 26d840e commit 7653cbe

File tree

2 files changed

+6
-7
lines changed
  • dmq-node/app
  • ouroboros-network-api/src/Ouroboros/Network/PeerSelection/PeerSharing

2 files changed

+6
-7
lines changed

dmq-node/app/Main.hs

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,8 @@ import DMQ.Diffusion.Arguments
3434
import DMQ.Diffusion.NodeKernel (mempool, withNodeKernel)
3535
import DMQ.Handlers.TopLevel (toplevelExceptionHandler)
3636
import DMQ.NodeToClient qualified as NtC
37-
import DMQ.NodeToNode (dmqCodecs, dmqLimitsAndTimeouts, ntnApps)
37+
import DMQ.NodeToNode (NodeToNodeVersion, dmqCodecs, dmqLimitsAndTimeouts,
38+
ntnApps)
3839
import DMQ.Protocol.LocalMsgSubmission.Codec
3940
import DMQ.Protocol.SigSubmission.Type (Sig (..))
4041
import DMQ.Tracer
@@ -122,10 +123,8 @@ runDMQ commandLineConfig = do
122123
dmqConfig
123124
nodeKernel
124125
(dmqCodecs
125-
-- TODO: `maxBound :: Cardano.Network.NodeToNode.NodeToNodeVersion`
126-
-- is unsafe here!
127-
(encodeRemoteAddress maxBound)
128-
(decodeRemoteAddress maxBound))
126+
(encodeRemoteAddress (maxBound @NodeToNodeVersion))
127+
(decodeRemoteAddress (maxBound @NodeToNodeVersion)))
129128
dmqLimitsAndTimeouts
130129
defaultSigDecisionPolicy
131130
dmqNtCApps =

ouroboros-network-api/src/Ouroboros/Network/PeerSelection/PeerSharing/Codec.hs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ decodePortNumber = fromIntegral <$> CBOR.decodeWord16
2727
---
2828
-- /Invariant:/ not a unix socket address type.
2929
---
30-
encodeRemoteAddress :: NodeToNodeVersion -> SockAddr -> CBOR.Encoding
30+
encodeRemoteAddress :: version -> SockAddr -> CBOR.Encoding
3131
encodeRemoteAddress _ = \case
3232
SockAddrInet pn w -> CBOR.encodeListLen 3
3333
<> CBOR.encodeWord 0
@@ -47,7 +47,7 @@ encodeRemoteAddress _ = \case
4747
--
4848
-- See the network design document for more details
4949
--
50-
decodeRemoteAddress :: NodeToNodeVersion -> CBOR.Decoder s SockAddr
50+
decodeRemoteAddress :: version -> CBOR.Decoder s SockAddr
5151
decodeRemoteAddress _ = do
5252
_ <- CBOR.decodeListLen
5353
tok <- CBOR.decodeWord

0 commit comments

Comments
 (0)