fix: register RecordTypeStorageLocation
This commit is contained in:
parent
ed97c03d16
commit
8806e69a66
|
@ -24,6 +24,9 @@ func Init() {
|
||||||
RegisterMessageType(int(types.ProtocolMethodHashQuery), func() base.IncomingMessage {
|
RegisterMessageType(int(types.ProtocolMethodHashQuery), func() base.IncomingMessage {
|
||||||
return NewHashQuery()
|
return NewHashQuery()
|
||||||
})
|
})
|
||||||
|
RegisterMessageType(int(types.RecordTypeStorageLocation), func() base.IncomingMessage {
|
||||||
|
return NewStorageLocation()
|
||||||
|
})
|
||||||
RegisterMessageType(int(types.ProtocolMethodSignedMessage), func() base.IncomingMessage {
|
RegisterMessageType(int(types.ProtocolMethodSignedMessage), func() base.IncomingMessage {
|
||||||
return signed.NewSignedMessage()
|
return signed.NewSignedMessage()
|
||||||
})
|
})
|
||||||
|
|
|
@ -30,6 +30,10 @@ type StorageLocation struct {
|
||||||
base.IncomingMessageHandler
|
base.IncomingMessageHandler
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func NewStorageLocation() *StorageLocation {
|
||||||
|
return &StorageLocation{}
|
||||||
|
}
|
||||||
|
|
||||||
func (s *StorageLocation) DecodeMessage(dec *msgpack.Decoder) error {
|
func (s *StorageLocation) DecodeMessage(dec *msgpack.Decoder) error {
|
||||||
data, err := dec.DecodeRaw()
|
data, err := dec.DecodeRaw()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue