Skip to content

Commit 2720d65

Browse files
refactor(conn): update status packet type to StatusPacket68 for protocol consistency
1 parent 17dee83 commit 2720d65

File tree

1 file changed

+5
-5
lines changed
  • pkg/coordinator/utils/sentry

1 file changed

+5
-5
lines changed

pkg/coordinator/utils/sentry/conn.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ func (c *Conn) ReadEth() (any, error) {
140140

141141
switch int(code) {
142142
case eth.StatusMsg:
143-
msg = new(eth.StatusPacket)
143+
msg = new(eth.StatusPacket68)
144144
case eth.GetBlockHeadersMsg:
145145
msg = new(eth.GetBlockHeadersPacket)
146146
case eth.BlockHeadersMsg:
@@ -175,7 +175,7 @@ func (c *Conn) ReadEth() (any, error) {
175175

176176
// peer performs both the protocol handshake and the status message
177177
// exchange with the node in order to peer with it.
178-
func (c *Conn) Peer(chainID *big.Int, genesisHash, headHash common.Hash, forkID forkid.ID, status *eth.StatusPacket) error {
178+
func (c *Conn) Peer(chainID *big.Int, genesisHash, headHash common.Hash, forkID forkid.ID, status *eth.StatusPacket68) error {
179179
if err := c.handshake(); err != nil {
180180
return fmt.Errorf("handshake failed: %v", err)
181181
}
@@ -260,7 +260,7 @@ func (c *Conn) negotiateEthProtocol(caps []p2p.Cap) {
260260
}
261261

262262
// statusExchange performs a `Status` message exchange with the given node.
263-
func (c *Conn) statusExchange(chainID *big.Int, genesisHash, headHash common.Hash, forkID forkid.ID, status *eth.StatusPacket) error {
263+
func (c *Conn) statusExchange(chainID *big.Int, genesisHash, headHash common.Hash, forkID forkid.ID, status *eth.StatusPacket68) error {
264264
loop:
265265
for {
266266
code, data, err := c.Read()
@@ -269,7 +269,7 @@ loop:
269269
}
270270
switch code {
271271
case eth.StatusMsg + protoOffset(ethProto):
272-
msg := new(eth.StatusPacket)
272+
msg := new(eth.StatusPacket68)
273273
if err := rlp.DecodeBytes(data, &msg); err != nil {
274274
return fmt.Errorf("error decoding status packet: %w", err)
275275
}
@@ -310,7 +310,7 @@ loop:
310310
return fmt.Errorf("negotiated protocol version too large: %d", c.negotiatedProtoVersion)
311311
}
312312
// default status message
313-
status = &eth.StatusPacket{
313+
status = &eth.StatusPacket68{
314314
ProtocolVersion: uint32(c.negotiatedProtoVersion),
315315
NetworkID: chainID.Uint64(),
316316
TD: new(big.Int).SetUint64(0),

0 commit comments

Comments
 (0)