diff --git a/pkg/network/message.go b/pkg/network/message.go index 4589e64c5..84099c555 100644 --- a/pkg/network/message.go +++ b/pkg/network/message.go @@ -157,6 +157,11 @@ func (m *Message) decodePayload(r io.Reader) error { if err := p.Decode(tr); err != nil { return err } + case cmdInv: + p = payload.Inventories{} + if err := p.Decode(tr); err != nil { + return err + } default: return fmt.Errorf("unknown command to decode: %s", m.commandType()) }