Fix Signature encode, removed debug calls
All checks were successful
continuous-integration/drone/push Build is passing
All checks were successful
continuous-integration/drone/push Build is passing
This commit is contained in:
parent
08d4c6a35b
commit
bc3dc90593
|
@ -200,8 +200,6 @@ func (s *ContentMessage) encodeMessage() []byte {
|
||||||
_, _ = s.Identifier.WriteBytes(message)
|
_, _ = s.Identifier.WriteBytes(message)
|
||||||
}
|
}
|
||||||
|
|
||||||
_, _ = s.Identifier.WriteBytes(message)
|
|
||||||
|
|
||||||
return message.Bytes()
|
return message.Bytes()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -231,7 +229,6 @@ func DecodeContentMessage(signatureBytes []byte) *ContentMessage {
|
||||||
|
|
||||||
message.Version, err = binary.ReadUvarint(buffer)
|
message.Version, err = binary.ReadUvarint(buffer)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Print(err)
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -239,22 +236,16 @@ func DecodeContentMessage(signatureBytes []byte) *ContentMessage {
|
||||||
message.PublicKey = make([]byte, ed25519.PublicKeySize)
|
message.PublicKey = make([]byte, ed25519.PublicKeySize)
|
||||||
_, err := buffer.Read(message.PublicKey)
|
_, err := buffer.Read(message.PublicKey)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Print(message.String())
|
|
||||||
log.Print(err)
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
message.IssueTime, err = binary.ReadVarint(buffer)
|
message.IssueTime, err = binary.ReadVarint(buffer)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Print(message.String())
|
|
||||||
log.Print(err)
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if message.Version == 1 {
|
if message.Version == 1 {
|
||||||
read, mh, err := multihash.MHFromBytes(buffer.Bytes())
|
read, mh, err := multihash.MHFromBytes(buffer.Bytes())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Print(message.String())
|
|
||||||
log.Print(err)
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
buffer.Next(read)
|
buffer.Next(read)
|
||||||
|
@ -262,8 +253,6 @@ func DecodeContentMessage(signatureBytes []byte) *ContentMessage {
|
||||||
} else {
|
} else {
|
||||||
_, message.Identifier, err = cid.CidFromReader(buffer)
|
_, message.Identifier, err = cid.CidFromReader(buffer)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Print(message.String())
|
|
||||||
log.Print(err)
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -271,14 +260,10 @@ func DecodeContentMessage(signatureBytes []byte) *ContentMessage {
|
||||||
message.Signature = make([]byte, ed25519.SignatureSize)
|
message.Signature = make([]byte, ed25519.SignatureSize)
|
||||||
_, err = buffer.Read(message.Signature)
|
_, err = buffer.Read(message.Signature)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Print(message.String())
|
|
||||||
log.Print(err)
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if buffer.Len() != 0 { //Unknown extra data
|
if buffer.Len() != 0 { //Unknown extra data
|
||||||
log.Print(message.String())
|
|
||||||
log.Printf("%x", buffer.Bytes())
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue