Skip to content

Commit 54665c2

Browse files
[ETCM-355] Move fallback on NetworkMessageDecoder inside .ehtMessageDecoder
1 parent a3cecc7 commit 54665c2

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/main/scala/io/iohk/ethereum/network/p2p/MessageDecoders.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -110,9 +110,9 @@ object EthereumMessageDecoder {
110110
type Decoder = (Int, Array[Byte]) => Message
111111
def ethMessageDecoder(protocolVersion: Capability): MessageDecoder =
112112
protocolVersion match {
113-
case Capability.Capabilities.Etc64Capability => ETC64MessageDecoder.fromBytes
114-
case Capability.Capabilities.Eth63Capability => ETH63MessageDecoder.fromBytes
115-
case Capability.Capabilities.Eth64Capability => ETH64MessageDecoder.fromBytes
113+
case Capability.Capabilities.Etc64Capability => ETC64MessageDecoder.orElse(NetworkMessageDecoder)
114+
case Capability.Capabilities.Eth63Capability => ETH63MessageDecoder.orElse(NetworkMessageDecoder)
115+
case Capability.Capabilities.Eth64Capability => ETH64MessageDecoder.orElse(NetworkMessageDecoder)
116116
case _ => throw new RuntimeException(s"Unsupported Protocol Version $protocolVersion")
117117
}
118118
}

src/main/scala/io/iohk/ethereum/network/rlpx/RLPxConnectionHandler.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -396,7 +396,7 @@ object RLPxConnectionHandler {
396396
negotiated: Capability,
397397
p2pVersion: Long
398398
): MessageCodec = {
399-
val md = EthereumMessageDecoder.ethMessageDecoder(negotiated).orElse(NetworkMessageDecoder)
399+
val md = EthereumMessageDecoder.ethMessageDecoder(negotiated)
400400
new MessageCodec(frameCodec, md, p2pVersion)
401401
}
402402

0 commit comments

Comments
 (0)